event

Documentation

Index

• Constants
• func GetAs[T any](r Result) (T, *cd.Error)
• func GetValAs[T any](r Result, key string) (T, bool)
• func MatchValue(pattern, val string) bool
• type Event
  • func NewEvent(id, source, destination string, header Values, data interface{}) Event
  • func NewEventWitchContext(id, source, destination string, header Values, context context.Context, ...) Event
• type Hub
  • func NewHub(capacitySize int) Hub
• type ID2ActionChanelMap
• type ID2ObserverFuncMap
• type ID2ObserverMap
• type Observer
• type ObserverFunc
• type ObserverList
• type Result
  • func NewResult(id, source, destination string) Result
• type SimpleObserver
  • func NewSimpleObserver(id string, hub Hub) SimpleObserver
• type Values
  • func NewValues() Values
  • func (s Values) Get(key string) interface{}
  • func (s Values) GetBool(key string) bool
  • func (s Values) GetInt(key string) int
  • func (s Values) GetString(key string) string
  • func (s Values) Set(key string, value interface{})

Constants

const (
	Action = "_action_"
	Add    = "add"
	Del    = "del"
	Mod    = "mod"
	Notify = "notify"
)

Functions

func GetAs

func GetAs[T any](r Result) (T, *cd.Error)

GetAs 尝试把 Result.Get() 的值转换为指定类型

func GetValAs

func GetValAs[T any](r Result, key string) (T, bool)

GetValAs 尝试把 Result.GetVal() 的值转换为指定类型

func MatchValue

func MatchValue(pattern, val string) bool

Types

type Event

type Event interface {
	ID() string
	Source() string
	Destination() string
	Header() Values
	Context() context.Context
	BindContext(ctx context.Context)
	Data() interface{}
	SetData(key string, val interface{})
	GetData(key string) interface{}
	Match(pattern string) bool
}

func NewEvent

func NewEvent(id, source, destination string, header Values, data interface{}) Event

func NewEventWitchContext

func NewEventWitchContext(id, source, destination string, header Values, context context.Context, data interface{}) Event

type Hub

type Hub interface {
	Subscribe(eventID string, observer Observer)
	Unsubscribe(eventID string, observer Observer)
	Post(event Event)
	Send(event Event) Result
	Call(event Event) Result
	Terminate()
}

func NewHub

func NewHub(capacitySize int) Hub

type ID2ActionChanelMap

type ID2ActionChanelMap map[string]actionChannel

type ID2ObserverFuncMap

type ID2ObserverFuncMap map[string]ObserverFunc

type ID2ObserverMap

type ID2ObserverMap map[string]ObserverList

type Observer

type Observer interface {
	ID() string
	Notify(event Event, result Result)
}

type ObserverFunc

type ObserverFunc func(Event, Result)

type ObserverList

type ObserverList []Observer

type Result

type Result interface {
	Error() *cd.Error
	Set(data interface{}, err *cd.Error)
	Get() (interface{}, *cd.Error)
	SetVal(key string, val interface{})
	GetVal(key string) interface{}
}

func NewResult

func NewResult(id, source, destination string) Result

type SimpleObserver

type SimpleObserver interface {
	Observer
	Subscribe(eventID string, observerFunc ObserverFunc)
	Unsubscribe(eventID string)
}

func NewSimpleObserver

func NewSimpleObserver(id string, hub Hub) SimpleObserver

type Values

type Values map[string]interface{}

func NewValues

func NewValues() Values

func (Values) Get

func (s Values) Get(key string) interface{}

func (Values) GetBool

func (s Values) GetBool(key string) bool

func (Values) GetInt

func (s Values) GetInt(key string) int

func (Values) GetString

func (s Values) GetString(key string) string

func (Values) Set

func (s Values) Set(key string, value interface{})