Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var EventProcessors = map[string]Initializer{}
Functions ¶
func DecodeConfig ¶
func DecodeConfig(src, dst interface{}) error
func Register ¶
func Register(name string, initFn Initializer)
Types ¶
type EventMsg ¶
type EventMsg struct {
Name string `json:"name,omitempty"` // measurement name
Timestamp int64 `json:"timestamp,omitempty"`
Tags map[string]string `json:"tags,omitempty"`
Values map[string]interface{} `json:"values,omitempty"`
Deletes []string `json:"deletes,omitempty"`
}
EventMsg //
func ResponseToEventMsgs ¶
func ResponseToEventMsgs(name string, rsp *gnmi.SubscribeResponse, meta map[string]string, eps ...EventProcessor) ([]*EventMsg, error)
ResponseToEventMsgs //
type EventProcessor ¶
type Initializer ¶
type Initializer func() EventProcessor
type MarshalOptions ¶
type MarshalOptions struct {
Multiline bool // could get rid of this and deduct it from len(Indent)
Indent string
Format string
}
func (*MarshalOptions) FormatJSON ¶
FormatJSON formats a proto.Message and returns a []byte and an error
func (*MarshalOptions) Marshal ¶
func (o *MarshalOptions) Marshal(msg proto.Message, meta map[string]string, eps ...EventProcessor) ([]byte, error)
Marshal //
type NotificationRspMsg ¶
type NotificationRspMsg struct {
Meta map[string]interface{} `json:"meta,omitempty"`
Source string `json:"source,omitempty"`
SystemName string `json:"system-name,omitempty"`
SubscriptionName string `json:"subscription-name,omitempty"`
Timestamp int64 `json:"timestamp,omitempty"`
Time *time.Time `json:"time,omitempty"`
Prefix string `json:"prefix,omitempty"`
Target string `json:"target,omitempty"`
Updates []update `json:"updates,omitempty"`
Deletes []string `json:"deletes,omitempty"`
}
Click to show internal directories.
Click to hide internal directories.