Versions in this module Expand all Collapse all v0 v0.1.1 Feb 1, 2025 v0.1.0 Jan 31, 2025 Changes in this version + const JobEventChannel + const KeeperEventChannel + func InitEventBus(redisAddr string) error + type EventBus struct + func GetEventBus() *EventBus + func (eb *EventBus) PublishJobEvent(ctx context.Context, event JobEvent) error + func (eb *EventBus) PublishKeeperEvent(ctx context.Context, event KeeperEvent) error + func (eb *EventBus) Redis() *redis.Client + type JobEvent struct + ChainID int + JobID int64 + JobType int + Type string + type KeeperEvent struct + KeeperID int64 + Type string
Go to main page