natsstreaming

Documentation

Index

• type AsyncSinkFactory
  • func (f AsyncSinkFactory) NewAsyncSink(ctx context.Context, req *proto.StartPublishRequest) (substrate.AsyncMessageSink, error)
• type AsyncSourceFactory
  • func (f AsyncSourceFactory) NewAsyncSource(ctx context.Context, req *proto.StartConsumeRequest) (substrate.AsyncMessageSource, error)

Types

type AsyncSinkFactory

type AsyncSinkFactory struct {
	URL       string
	ClientID  string
	ClusterID string
}

func (AsyncSinkFactory) NewAsyncSink

func (f AsyncSinkFactory) NewAsyncSink(ctx context.Context, req *proto.StartPublishRequest) (substrate.AsyncMessageSink, error)

type AsyncSourceFactory

type AsyncSourceFactory struct {
	URL                    string
	ClientID               string
	ClusterID              string
	AckWait                time.Duration
	MaxInflight            int
	ConnectionNumPings     int
	ConnectionPingInterval int
}

func (AsyncSourceFactory) NewAsyncSource

func (f AsyncSourceFactory) NewAsyncSource(ctx context.Context, req *proto.StartConsumeRequest) (substrate.AsyncMessageSource, error)