databus

Documentation

Index

• Variables
• func Add(m *AddInfo) (err error)
• func Cancel(m *CancelInfo) (err error)
• func CloseAegis()
• func InitAegis(c *databus.Config)
• func Update(m *UpdateInfo) (err error)
• type AddInfo
• type CancelInfo
• type RscMsg
• type UpdateInfo

Variables

var (
	ErrInfo     = errors.New("error info")
	ErrNilAgent = errors.New("nil agent")
)

var

Functions

func Add

func Add(m *AddInfo) (err error)

Add .

func Cancel

func Cancel(m *CancelInfo) (err error)

Cancel .

func CloseAegis

func CloseAegis()

CloseAegis .

func InitAegis

func InitAegis(c *databus.Config)

InitAegis .

func Update

func Update(m *UpdateInfo) (err error)

Update .

Types

type AddInfo

type AddInfo struct {
	BusinessID int64  `json:"business_id"`
	NetID      int64  `json:"net_id"`
	OID        string `json:"oid"`
	MID        int64  `json:"mid"`
	Content    string `json:"content"`
	Extra1     int64  `json:"extra1"`
	Extra2     int64  `json:"extra2"`
	Extra3     int64  `json:"extra3"`
	Extra4     int64  `json:"extra4"`
	Extra5     int64  `json:"extra5"`
	Extra6     int64  `json:"extra6"`
	Extra1s    string `json:"extra1s"`
	Extra2s    string `json:"extra2s"`
	Extra3s    string `json:"extra3s"`
	Extra4s    string `json:"extra4s"`
	MetaData   string `json:"metadata"`
	ExtraTime1 time.Time
	OCtime     time.Time
	Ptime      time.Time
}

AddInfo info for add

type CancelInfo

type CancelInfo = model.CancelOption

CancelInfo info for cancel

type RscMsg

type RscMsg struct {
	Action string          `json:"action"`
	BizID  int64           `json:"business_id"`
	Raw    json.RawMessage `json:"raw"`
}

RscMsg .

type UpdateInfo

type UpdateInfo = model.UpdateOption

UpdateInfo info for update