pubsub

Documentation

Index

• type Iterator
  • func NewIterator(ctx context.Context, params IteratorParams) (*Iterator, error)
  • func (i *Iterator) HasNext(ctx context.Context) bool
  • func (i *Iterator) Next(ctx context.Context) (sdk.Record, error)
  • func (i *Iterator) Stop() (err error)
• type IteratorParams

Types

type Iterator

type Iterator struct {
	// contains filtered or unexported fields
}

Iterator is a iterator for Pub/Sub communication model. It receives any new message from NATS.

func NewIterator

func NewIterator(ctx context.Context, params IteratorParams) (*Iterator, error)

NewIterator creates new instance of the Iterator.

func (*Iterator) HasNext

func (i *Iterator) HasNext(ctx context.Context) bool

HasNext checks is the iterator has messages.

func (*Iterator) Next

func (i *Iterator) Next(ctx context.Context) (sdk.Record, error)

Next returns the next record from the underlying messages channel.

func (*Iterator) Stop

func (i *Iterator) Stop() (err error)

Stop stops the Iterator, unsubscribes from a subject.

type IteratorParams

type IteratorParams struct {
	Conn       *nats.Conn
	BufferSize int
	Subject    string
}

IteratorParams contains incoming params for the NewIterator function.