iterator

Documentation

Index

• type CDCIterator
  • func NewCDCIterator(ctx context.Context, username, apiToken, domain string, ...) (*CDCIterator, error)
  • func (c *CDCIterator) HasNext(_ context.Context) bool
  • func (c *CDCIterator) Next(ctx context.Context) (sdk.Record, error)
  • func (c *CDCIterator) Stop()
• type ZendeskCursor

Types

type CDCIterator

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

func NewCDCIterator

func NewCDCIterator(
	ctx context.Context,
	username, apiToken, domain string,
	pollingPeriod time.Duration,
	tp *position.TicketPosition,
	cursors ...ZendeskCursor,
) (*CDCIterator, error)

NewCDCIterator will initialize CDCIterator parameters and also initialize goroutine to fetch records from server

func (*CDCIterator) HasNext

func (c *CDCIterator) HasNext(_ context.Context) bool

HasNext return true when buffer is not empty

func (*CDCIterator) Next

func (c *CDCIterator) Next(ctx context.Context) (sdk.Record, error)

Next will check the case whether to push data into buffer

func (*CDCIterator) Stop

func (c *CDCIterator) Stop()

type ZendeskCursor

type ZendeskCursor interface {
	FetchRecords(ctx context.Context) ([]sdk.Record, error)
	Close()
}