Documentation

Index

• type Subscription
  • func NewSubscription(readClient api.Streams_ReadClient, subscriptionId string, ...) *Subscription
  • func (subscription *Subscription) Start() error
  • func (subscription *Subscription) Stop() error

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Subscription

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

func NewSubscription

func NewSubscription(readClient api.Streams_ReadClient, subscriptionId string, eventAppeared func(messages.RecordedEvent), checkpointReached func(position.Position), subscriptionDropped func(reason string)) *Subscription

func (*Subscription) Start

func (subscription *Subscription) Start() error

func (*Subscription) Stop

func (subscription *Subscription) Stop() error