cluster_events

Documentation

Index

• func InitClusterEvents(daoDeps []interface{}, pullInterval int) error
• type ClusterEventManager
  • func (c *ClusterEventManager) Init(daoDeps []interface{}) error
  • func (c *ClusterEventManager) RegisterEventExecutor(channel string, exec EventExecutor)
  • func (c *ClusterEventManager) StartPullEvents()
• type EventExecutor

Functions

func InitClusterEvents

func InitClusterEvents(daoDeps []interface{}, pullInterval int) error

Types

type ClusterEventManager

type ClusterEventManager struct {
	Dao *dao.ClusterEventDao
	// contains filtered or unexported fields
}

func (*ClusterEventManager) Init

func (c *ClusterEventManager) Init(daoDeps []interface{}) error

@daoDeps: dao 实例依赖

func (*ClusterEventManager) RegisterEventExecutor

func (c *ClusterEventManager) RegisterEventExecutor(channel string, exec EventExecutor)

func (*ClusterEventManager) StartPullEvents

func (c *ClusterEventManager) StartPullEvents()

type EventExecutor

type EventExecutor interface {
	Create(channel string, data string) error
	Delete(channel string, data string) error
	Update(channel string, data string) error
}

集群更新事件相关