ingestor

Documentation

Index

• func Run(ctx context.Context) error
• type GatewayIngestor
  • func NewGatewayIngestor() (*GatewayIngestor, error)
  • func (gi *GatewayIngestor) CurrentBlockFunc(ctx context.Context) (uint64, error)
  • func (gi *GatewayIngestor) EventsFunc(ctx context.Context, events []*types.GatewayEvent) error
  • func (gi *GatewayIngestor) PendingEventFunc(ctx context.Context, pendingEvent *types.GatewayEvent) error
  • func (gi *GatewayIngestor) Run(ctx context.Context) error
  • func (gi *GatewayIngestor) SetCurrentBlockFunc(ctx context.Context, height uint64) error

Functions

func Run

func Run(ctx context.Context) error

Types

type GatewayIngestor

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

func NewGatewayIngestor

func NewGatewayIngestor() (*GatewayIngestor, error)

func (*GatewayIngestor) CurrentBlockFunc

func (gi *GatewayIngestor) CurrentBlockFunc(ctx context.Context) (uint64, error)

func (*GatewayIngestor) EventsFunc

func (gi *GatewayIngestor) EventsFunc(ctx context.Context, events []*types.GatewayEvent) error

func (*GatewayIngestor) PendingEventFunc

func (gi *GatewayIngestor) PendingEventFunc(ctx context.Context, pendingEvent *types.GatewayEvent) error

func (*GatewayIngestor) Run

func (gi *GatewayIngestor) Run(ctx context.Context) error

func (*GatewayIngestor) SetCurrentBlockFunc

func (gi *GatewayIngestor) SetCurrentBlockFunc(ctx context.Context, height uint64) error