iterator

Documentation

Index

• type CDC
  • func NewCDC(stripeSvc Stripe, pos *Position) *CDC
  • func (i *CDC) Next() (sdk.Record, error)
• type Iterator
  • func New(stripeSvc Stripe, pos *Position) *Iterator
  • func (iter *Iterator) Next() (sdk.Record, error)
• type Position
  • func ParseSDKPosition(position sdk.Position) (*Position, error)
• type Snapshot
  • func NewSnapshot(stripeSvc Stripe, pos *Position) *Snapshot
  • func (i *Snapshot) Next() (sdk.Record, error)
• type Stripe

Types

type CDC

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

A CDC represents a struct of cdc iterator.

func NewCDC

func NewCDC(stripeSvc Stripe, pos *Position) *CDC

NewCDC initializes cdc iterator.

func (*CDC) Next

func (i *CDC) Next() (sdk.Record, error)

Next returns the next record.

type Iterator

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

An Iterator represents a struct of iterator.

func New

func New(stripeSvc Stripe, pos *Position) *Iterator

New initializes an iterator.

func (*Iterator) Next

func (iter *Iterator) Next() (sdk.Record, error)

Next returns the next record.

type Position

type Position struct {
	// Mode represents current iterator mode.
	IteratorMode mode `json:"mode"`

	// CreatedAt is the Unix time from which the system should receive events of the resource in the CDC iterator.
	CreatedAt int64 `json:"created_at"`

	// Cursor is the resource or event identifier for receiving shifted data in the following requests.
	Cursor string `json:"cursor"`

	// Index is the current index of the returning record from the batch of previously received resources.
	Index int `json:"index"`
}

Position represents Oracle position.

func ParseSDKPosition

func ParseSDKPosition(position sdk.Position) (*Position, error)

ParseSDKPosition parses sdk.Position and returns Position.

type Snapshot

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

A Snapshot represents a struct of snapshot iterator.

func NewSnapshot

func NewSnapshot(stripeSvc Stripe, pos *Position) *Snapshot

NewSnapshot initializes snapshot iterator.

func (*Snapshot) Next

func (i *Snapshot) Next() (sdk.Record, error)

Next returns the next record. Note: The `Snapshot` iterator creates a copy of the data, which is sorted by date of creation in descending order.

type Stripe

type Stripe interface {
	GetResource(string) (models.ResourceResponse, error)
	GetEvent(createdAt int64, startingAfter, endingBefore string) (models.EventResponse, error)
}

A Stripe defines the interface of methods.