events

Documentation

Index

• Constants
• func InitEventBus(redisAddr string) error
• type EventBus
  • 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
• type KeeperEvent

Constants

const (
	JobEventChannel    = "job_events"
	KeeperEventChannel = "keeper_events"
)

Functions

func InitEventBus

func InitEventBus(redisAddr string) error

Types

type EventBus

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

func GetEventBus

func GetEventBus() *EventBus

func (*EventBus) PublishJobEvent

func (eb *EventBus) PublishJobEvent(ctx context.Context, event JobEvent) error

func (*EventBus) PublishKeeperEvent

func (eb *EventBus) PublishKeeperEvent(ctx context.Context, event KeeperEvent) error

func (*EventBus) Redis

func (eb *EventBus) Redis() *redis.Client

type JobEvent

type JobEvent struct {
	Type    string `json:"type"`
	JobID   int64  `json:"job_id"`
	JobType int    `json:"job_type"`
	ChainID int    `json:"chain_id"`
}

type KeeperEvent

type KeeperEvent struct {
	Type     string `json:"type"`
	KeeperID int64  `json:"keeper_id"`
}