ip

Documentation

Index

• type ChannelBindings
• type Consumer
• type EnvelopeMarshaler
• type EnvelopeReader
• type EnvelopeUnmarshaler
• type EnvelopeWriter
• type MessageBindings
• type OperationBindings
• type Producer
• type Publisher
• type ServerBindings
• type Subscriber

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