Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChannelBindings ¶
type ChannelBindings struct{}
type Consumer ¶
type Consumer interface {
Subscriber(ctx context.Context, channelName string, bindings *ChannelBindings) (Subscriber, error)
}
Sub
type EnvelopeMarshaler ¶
type EnvelopeMarshaler interface {
MarshalIPEnvelope(envelope EnvelopeWriter) error
}
type EnvelopeReader ¶
type EnvelopeReader interface { io.Reader Headers() run.Headers Headers4() (*ipv4.Header, error) Headers6() (*ipv6.Header, error) }
Sub
type EnvelopeUnmarshaler ¶
type EnvelopeUnmarshaler interface {
UnmarshalIPEnvelope(envelope EnvelopeReader) error
}
type EnvelopeWriter ¶
type EnvelopeWriter interface { io.Writer ResetPayload() SetHeaders(headers run.Headers) SetContentType(contentType string) SetBindings(bindings MessageBindings) }
Pub
type MessageBindings ¶
type MessageBindings struct{}
type OperationBindings ¶
type OperationBindings struct{}
type Producer ¶
type Producer interface {
Publisher(ctx context.Context, channelName string, bindings *ChannelBindings) (Publisher, error)
}
Pub
type Publisher ¶
type Publisher interface { Send(ctx context.Context, envelopes ...EnvelopeWriter) error Close() error }
Pub
type ServerBindings ¶
type ServerBindings struct{}
type Subscriber ¶
type Subscriber interface { Receive(ctx context.Context, cb func(envelope EnvelopeReader)) error Close() error }
Sub
Click to show internal directories.
Click to hide internal directories.