iterator

Documentation

Index

• type SheetsIterator
  • func NewSheetsIterator(ctx context.Context, tp position.SheetPosition, args sheets.BatchReaderArgs) (*SheetsIterator, error)
  • func (c *SheetsIterator) HasNext() bool
  • func (c *SheetsIterator) Next(ctx context.Context) (sdk.Record, error)
  • func (c *SheetsIterator) Stop(ctx context.Context)

Types

type SheetsIterator

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

func NewSheetsIterator

func NewSheetsIterator(ctx context.Context,
	tp position.SheetPosition,
	args sheets.BatchReaderArgs,
) (*SheetsIterator, error)

NewSheetsIterator creates a new instance of sheets iterator and starts polling google sheets api for new changes using the row offset of last successful row read in a separate go routine, row offset is received in sheet position

func (*SheetsIterator) HasNext

func (c *SheetsIterator) HasNext() bool

HasNext returns whether there are any more records to be returned

func (*SheetsIterator) Next

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

Next returns the next record in buffer and error in case there are no more records and there was an error leading to tomb dying or context was cancelled

func (*SheetsIterator) Stop

func (c *SheetsIterator) Stop(ctx context.Context)

Stop the go routines and ticker