Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Clients ¶
type Clients struct {
// contains filtered or unexported fields
}
Clients notify clients
func NewClients ¶
NewClients New NotifyClients
type LiveMsgHeader ¶
type LiveMsgHeader struct { TraceId string `json:"trace_id"` Caller string `json:"caller"` SourceGroup string `json:"source_group"` Group string `json:"group"` }
LiveMsgHeader live databus message.value.caller_header
type LiveMsgValue ¶
type LiveMsgValue struct { Topic string `json:"topic"` MsgID interface{} `json:"msg_id"` MsgKey interface{} `json:"msg_key"` MsgContent interface{} `json:"msg_content"` Timestamp float64 `json:"timestamp"` CallerHeader *LiveMsgHeader `json:"caller_header"` }
LiveMsgValue live databus message.value
type LiverpcClients ¶
type LiverpcClients struct {
// contains filtered or unexported fields
}
LiverpcClients liverpc clients
type Pub ¶
type Pub struct {
// contains filtered or unexported fields
}
Pub define producer.
Click to show internal directories.
Click to hide internal directories.