package matryoshka:examples/block2
Source

⌘K
Ctrl+K
or
/

    Types

    Builder ¶
    Source

    Builder :: examples_block1.Builder

    Event ¶
    Source

    Event :: examples_block1.Event
     

    Aliases for Layer 1 items, builder, and tags.

    Mailbox ¶
    Source

    Mailbox :: ^matryoshka.PolyNode

    Master ¶
    Source

    Master :: struct {
	builder: examples_block1.Builder,
	inbox:   ^matryoshka.PolyNode,
	alloc:   runtime.Allocator,
}
     

    Master represents a worker context that runs on a thread. It owns its inbox (mailbox) and a builder for items.

    Related Procedures With Parameters
    Related Procedures With Returns

    MayItem ¶
    Source

    MayItem :: runtime.Maybe($T=^PolyNode)

    PolyNode ¶
    Source

    PolyNode :: matryoshka.PolyNode
     

    Aliases for matryoshka core types.

    Sensor ¶
    Source

    Sensor :: examples_block1.Sensor

    Constants

    This section is empty.

    Variables

    EVENT_TAG ¶
    Source

    EVENT_TAG: rawptr = …

    EXIT_TAG ¶
    Source

    EXIT_TAG: rawptr = …

    MAILBOX_TAG ¶
    Source

    MAILBOX_TAG: rawptr = …
     

    Tag alias and helper for infrastructure identity checks.

    SENSOR_TAG ¶
    Source

    SENSOR_TAG: rawptr = …

    Procedures

    batch_receiver_proc ¶
    Source

    batch_receiver_proc :: proc(t: ^thread.Thread) {…}
     

    Receiver processes items in batches.

    consumer_proc ¶
    Source

    consumer_proc :: proc(t: ^thread.Thread) {…}
     

    Consumer: Final stage.

    example_batch_processing ¶
    Source

    example_batch_processing :: proc() -> bool {…}
     

    example_batch_processing demonstrates batch retrieval using try_receive_batch.

    example_fan_in_out ¶
    Source

    example_fan_in_out :: proc() -> bool {…}
     

    example_fan_in_out demonstrates multiple producers and multiple consumers.

    example_interrupt_oob ¶
    Source

    example_interrupt_oob :: proc() -> bool {…}
     

    example_interrupt_oob demonstrates Out-Of-Band signaling.

    example_pipeline ¶
    Source

    example_pipeline :: proc() -> bool {…}
     

    example_pipeline demonstrates a chain of Masters.

    example_readme_worker ¶
    Source

    example_readme_worker :: proc() -> bool {…}
     

    example_readme_worker demonstrates the simple worker example from README.md.

    example_request_response ¶
    Source

    example_request_response :: proc() -> bool {…}
     

    request_response_example demonstrates two masters exchanging items.

    example_shutdown_exit ¶
    Source

    example_shutdown_exit :: proc() -> bool {…}
     

    example_shutdown_exit demonstrates shutdown via an exit message.

    freeMaster ¶
    Source

    freeMaster :: proc(m: ^Master) {…}
     

    freeMaster performs clean teardown of a Master. It closes the inbox, processes remaining items, and disposes the mailbox.

    newMaster ¶
    Source

    newMaster :: proc(alloc: runtime.Allocator) -> ^Master {…}
     

    newMaster creates a new Master with a builder and an inbox.

    oob_receiver_proc ¶
    Source

    oob_receiver_proc :: proc(t: ^thread.Thread) {…}
     

    Receiver waits on main_mb, and when interrupted, consumes oob_mb.

    producer_proc ¶
    Source

    producer_proc :: proc(t: ^thread.Thread) {…}
     

    Producer: Creates items and sends to next stage.

    transformer_proc ¶
    Source

    transformer_proc :: proc(t: ^thread.Thread) {…}
     

    Transformer: Receives from stage, transforms, sends to next.

    worker_exit_proc ¶
    Source

    worker_exit_proc :: proc(t: ^thread.Thread) {…}
     

    Worker waits for items.

    worker_fan_proc ¶
    Source

    worker_fan_proc :: proc(t: ^thread.Thread) {…}
     

    Worker process for fan-in/fan-out.

    worker_proc ¶
    Source

    worker_proc :: proc(t: ^thread.Thread) {…}
     

    worker_proc is the thread procedure for the worker doll.

    Procedure Groups

    This section is empty.

    Source Files