Documentation ¶
Index ¶
- func Run(ctx context.Context) error
- type RouterIngestor
- func (gi *RouterIngestor) CurrentBlockFunc(ctx context.Context) (uint64, error)
- func (gi *RouterIngestor) EventsFunc(ctx context.Context, events []*types.RouterEvent) error
- func (gi *RouterIngestor) PendingEventFunc(ctx context.Context, pendingEvent *types.RouterEvent) error
- func (gi *RouterIngestor) Run(ctx context.Context) error
- func (gi *RouterIngestor) SetCurrentBlockFunc(ctx context.Context, height uint64) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type RouterIngestor ¶
type RouterIngestor struct {
// contains filtered or unexported fields
}
func NewRouterIngestor ¶
func NewRouterIngestor() (*RouterIngestor, error)
func (*RouterIngestor) CurrentBlockFunc ¶
func (gi *RouterIngestor) CurrentBlockFunc(ctx context.Context) (uint64, error)
func (*RouterIngestor) EventsFunc ¶
func (gi *RouterIngestor) EventsFunc(ctx context.Context, events []*types.RouterEvent) error
func (*RouterIngestor) PendingEventFunc ¶
func (gi *RouterIngestor) PendingEventFunc(ctx context.Context, pendingEvent *types.RouterEvent) error
func (*RouterIngestor) SetCurrentBlockFunc ¶
func (gi *RouterIngestor) SetCurrentBlockFunc(ctx context.Context, height uint64) error
Click to show internal directories.
Click to hide internal directories.