Versions in this module Expand all Collapse all v0 v0.2.2 Jan 15, 2025 Changes in this version + type Callback func(events *substrate.EventRecords) + type FileState struct + func (e *FileState) Get(cl *gsrpc.SubstrateAPI) (types.BlockNumber, error) + func (e *FileState) Set(num types.BlockNumber) error + type Processor struct + func NewProcessor(sub substrate.Manager, cb Callback, state State) *Processor + func (e *Processor) Start(ctx context.Context) + type RedisConsumer struct + func NewConsumer(address, id string) (*RedisConsumer, error) + func (r *RedisConsumer) ContractCancelled(ctx context.Context) (<-chan pkg.ContractCancelledEvent, error) + func (r *RedisConsumer) ContractLocked(ctx context.Context) (<-chan pkg.ContractLockedEvent, error) + func (r *RedisConsumer) PowerTargetChange(ctx context.Context) (<-chan pkg.PowerTargetChangeEvent, error) + func (r *RedisConsumer) PublicConfig(ctx context.Context) (<-chan pkg.PublicConfigEvent, error) + type RedisStream struct + func NewRedisStream(sub substrate.Manager, address string, farm pkg.FarmID, node uint32, ...) (*RedisStream, error) + func (r *RedisStream) Start(ctx context.Context) + type State interface + Get func(cl *gsrpc.SubstrateAPI) (types.BlockNumber, error) + Set func(num types.BlockNumber) error + func NewFileState(path string) State
Go to main page