val

Documentation

Overview

*

• @Author: kwens *
• @Date: 2023-06-05 15:58:45
• @Description:

Index

• Constants
• Variables
• type EventCallBack
• type PubInfo
• type SendMode
• type SubInfo

Constants

const DefalutSubName = "defaultSubscriber"

const (
	DefaultMaxQueue = 1000
)

Variables

var (
	EventCtxKey = struct{}{}
	TraceIDKey  = struct{}{}
)

Types

type EventCallBack

type EventCallBack func(context.Context, interface{}) error

type PubInfo

type PubInfo struct {
	EventID   string      `json:"EventId"`   // 事件id
	EventName string      `json:"EventName"` // 事件名称
	Data      interface{} `json:"Data"`      // 数据
}

type SendMode

type SendMode int

const (
	DefaultSend SendMode = iota // 默认发送模式，本地&远程
	OnlyLocal
	OnlyRemote
)

type SubInfo

type SubInfo struct {
	EventName string
	SubName   string
	Exec      EventCallBack
}