notify

Documentation

Overview

Notify system

Index

• func Clean()
• func NewEventID() uint32
• func Publish(ctx context.Context, event uint32, payload interface{}, cb *Callback)
• func Subscribe(event uint32, subscriber Subscriber)
• func UnSubscribe(event uint32, subscriber Subscriber)
• type Callback
• type Notify
• type Publisher
• type Response
• type Subscriber

Functions

func Clean

func Clean()

func NewEventID

func NewEventID() uint32

func Publish

func Publish(ctx context.Context, event uint32, payload interface{}, cb *Callback)

Publish - add new event

func Subscribe

func Subscribe(event uint32, subscriber Subscriber)

func UnSubscribe

func UnSubscribe(event uint32, subscriber Subscriber)

Types

type Callback

type Callback struct {
	CB             chan<- interface{}
	ResponseFilter string
}

type Notify

type Notify struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type Publisher

type Publisher interface {
	Subscribe(event *int, subscriber Subscriber)
	UnSubscribe(subscriber Subscriber)
}

type Response

type Response struct {
	Name    string
	Payload interface{}
	Error   error
}

type Subscriber

type Subscriber interface {
	Notify(ctx context.Context, event uint32, payload interface{}) Response
}