triggers

Documentation

Index

• type Trigger
  • func (this *Trigger) Invoke()
  • func (this *Trigger) Lock()
  • func (this *Trigger) Unlock()
• type Triggermgr
  • func NewTriggermgr() *Triggermgr
  • func (this *Triggermgr) Add(name string, exec func()) error
  • func (this *Triggermgr) Finalize()
  • func (this *Triggermgr) Get(name string) *Trigger
  • func (this *Triggermgr) Watch(client redis.UniversalClient, channelName string)

Types

type Trigger

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

Trigger 信號資料

func (*Trigger) Invoke

func (this *Trigger) Invoke()

Invoke 觸發信號

func (*Trigger) Lock

func (this *Trigger) Lock()

Lock 鎖定信號

func (*Trigger) Unlock

func (this *Trigger) Unlock()

Unlock 解鎖信號

type Triggermgr

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

Triggermgr 信號調度管理器, 提供了新增, 鎖定和觸發信號的功能; 每個信號都有一個名稱和一個處理函式, 管理器會保證名稱和處理函式的唯一性; 當觸發信號時, 管理器會先鎖定該信號, 然後執行信號的處理函式, 在處理函式執行期間,其他試圖鎖定該信號的操作會被阻塞,避免出現競爭條件

func NewTriggermgr

func NewTriggermgr() *Triggermgr

NewTriggermgr 建立信號調度管理器

func (*Triggermgr) Add

func (this *Triggermgr) Add(name string, exec func()) error

Add 新增信號

func (*Triggermgr) Finalize

func (this *Triggermgr) Finalize()

Finalize 結束處理

func (*Triggermgr) Get

func (this *Triggermgr) Get(name string) *Trigger

Get 取得信號

func (*Triggermgr) Watch

func (this *Triggermgr) Watch(client redis.UniversalClient, channelName string)

Watch 設定監聽redis的頻道, 當頻道出現信號名稱時, 就觸發該信號