events

package

v0.1.10 Latest Latest Go to latest Published: May 26, 2025 License: Apache-2.0 Imports: 18 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Callback func(events *substrate.EventRecords)

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

func (e *FileState) Get(cl *gsrpc.SubstrateAPI) (types.BlockNumber, error)

func (e *FileState) Set(num types.BlockNumber) error

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

Events processor receives all events starting from the given state and for each set of events calls callback cb

func NewProcessor(sub substrate.Manager, cb Callback, state State) *Processor

func (e *Processor) Start(ctx context.Context)

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

func NewConsumer(address, id string) (*RedisConsumer, error)

NewConsumer creates a new event consumer on given redis address, and consumer id, consumer id has to be unique

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 {
	// contains filtered or unexported fields
}

func NewRedisStream(sub substrate.Manager, address string, farm pkg.FarmID, node uint32, state string) (*RedisStream, error)

func (r *RedisStream) Start(ctx context.Context)

type State interface {
	Set(num types.BlockNumber) error
	Get(cl *gsrpc.SubstrateAPI) (types.BlockNumber, error)
}

State is used to track the blocks already processed by the processor

func NewFileState(path string) State