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