🧩 Creating Custom Endpoints

To create a new endpoint, implements the IEndpointInternal class or directly use the CompositeEndpoint class.

classDiagram
    class IEndpointInternal {
        <<interface>>
        +open()
        +close()
        +write()
    }

    class CompositeEndpoint {
        +muxer: IMuxerInternal
        +sink: ISinkInternal
        +metrics: EndpointMetrics
    }

    IEndpointInternal <|.. CompositeEndpoint

Muxers

Muxers implement the IMuxer interface. Muxers are passed in the constructor of the CompositeEndpoint.

To create a new muxer, implements the IMuxerInternal class.

Sinks

Sinks implement the ISink interface. Sinks are passed in the constructor of the CompositeEndpoint.

To create a new sink, implements the ISinkInternal class.