manager

Documentation

Index

• Constants
• type CallbackPlan
• type CallbackPlanOption
• type SubscribeCenter
  • func GetSubscribeCenter() *SubscribeCenter
  • func NewSubscribeCenter(option *SubscribeCenterOption) *SubscribeCenter
  • func (s *SubscribeCenter) Close()
  • func (s *SubscribeCenter) DefaultCallbackMethod() string
  • func (s *SubscribeCenter) GetFlag() storage.Flag
  • func (s *SubscribeCenter) Notify(key string, newVal interface{}, event int)
  • func (s *SubscribeCenter) Subscribe(option *SubscribeManifest)
  • func (s *SubscribeCenter) View() []byte
• type SubscribeCenterOption
  • func DefaultSubscribeCenterOption() *SubscribeCenterOption
• type SubscribeManifest

Constants

const (
	CallbackSetEvent = iota
	CallbackDeleteEvent
)

event

Types

type CallbackPlan

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

CallbackPlan If the callback plan execute SUCCESS, the plan will be uninstalled

type CallbackPlanOption

type CallbackPlanOption struct {
	CallbackPath string
	Events       []int
	RetryTimes   int
	IsPersistent bool
	Method       string
	ExpectValue  interface{}
}

type SubscribeCenter

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

func GetSubscribeCenter

func GetSubscribeCenter() *SubscribeCenter

func NewSubscribeCenter

func NewSubscribeCenter(option *SubscribeCenterOption) *SubscribeCenter

func (*SubscribeCenter) Close

func (s *SubscribeCenter) Close()

func (*SubscribeCenter) DefaultCallbackMethod

func (s *SubscribeCenter) DefaultCallbackMethod() string

func (*SubscribeCenter) GetFlag

func (s *SubscribeCenter) GetFlag() storage.Flag

func (*SubscribeCenter) Notify

func (s *SubscribeCenter) Notify(key string, newVal interface{}, event int)

Notify just callback

func (*SubscribeCenter) Subscribe

func (s *SubscribeCenter) Subscribe(option *SubscribeManifest)

func (*SubscribeCenter) View

func (s *SubscribeCenter) View() []byte

type SubscribeCenterOption

type SubscribeCenterOption struct {
	DefaultCallbackMethod string `yaml:"DefaultCallbackMethod"`
	RetryQueueLen         uint   `yaml:"RetryQueueLen"`
	RetryTickInterval     uint   `yaml:"RetryTickInterval"`
}

func DefaultSubscribeCenterOption

func DefaultSubscribeCenterOption() *SubscribeCenterOption

type SubscribeManifest

type SubscribeManifest struct {
	Key          string      `json:"k"`
	CallbackPath string      `json:"cp"`
	ExpectEvent  []int       `json:"ee"`
	RetryTimes   int         `json:"rt"`
	IsPersistent bool        `json:"ip"`
	Method       string      `json:"m"`
	ExpectValue  interface{} `json:"ev"`
}