qtypes_messages

Documentation

Index

• func Sha1HashString(s string) string
• type Base
  • func NewBase(src string) Base
  • func NewBaseFromBase(src string, b Base) Base
  • func NewBaseMessage(src, msg string) Base
  • func NewTimeBaseMessage(src string, t time.Time, msg string) Base
  • func NewTimedBase(src string, t time.Time) Base
  • func (b *Base) AppendSource(src string)
  • func (b *Base) GenDefaultID() string
  • func (b *Base) GetLastSource() string
  • func (b *Base) GetMessageDigest() string
  • func (b *Base) GetTimeRFC() string
  • func (b *Base) GetTimeUnix() int64
  • func (b *Base) GetTimeUnixNano() int64
  • func (b *Base) InputsMatch(inputs []string) bool
  • func (b *Base) IsLastSource(src string) bool
  • func (b *Base) StopProcessing(p *qtypes_plugin.Plugin, allowEmptyInput bool) bool
  • func (b *Base) ToFlatJSON() map[string]interface{}
  • func (b *Base) ToJSON() map[string]interface{}
• type ContainerMessage
  • func NewContainerMessage(base Base, cnt *types.ContainerJSON) ContainerMessage
  • func (cm *ContainerMessage) AddEngineInfo(e *types.Info)
  • func (c *ContainerMessage) GenContainerMsgID() string
  • func (c *ContainerMessage) GetContainerName() string
• type Message
  • func NewMessage(b Base, msg string) Message
  • func (m *Message) ParseJsonMap(p *qtypes_plugin.Plugin, keys mapset.Set, kv map[string]string) map[string]string
  • func (m *Message) ToStringRFC54242() (res string, err error)
• type SyslogMessage
  • func NewSyslogMessage(b Base, sl qtypes_syslog.Syslog) SyslogMessage
  • func (sm *SyslogMessage) ToRFC5424() (str string, err error)

Functions

func Sha1HashString

func Sha1HashString(s string) string

Types

type Base

type Base struct {
	BaseVersion   string
	ID            string
	Time          time.Time
	SourceID      int
	SourcePath    []string
	SourceSuccess bool
	Tags          map[string]string // Additional KV
	Msg           string
}

func NewBase

func NewBase(src string) Base

func NewBaseFromBase

func NewBaseFromBase(src string, b Base) Base

func NewBaseMessage

func NewBaseMessage(src, msg string) Base

func NewTimeBaseMessage

func NewTimeBaseMessage(src string, t time.Time, msg string) Base

func NewTimedBase

func NewTimedBase(src string, t time.Time) Base

func (*Base) AppendSource

func (b *Base) AppendSource(src string)

func (*Base) GenDefaultID

func (b *Base) GenDefaultID() string

GenDefaultID uses "<source>-<time.UnixNano()>" and does a sha1 hash.

func (*Base) GetLastSource

func (b *Base) GetLastSource() string

func (*Base) GetMessageDigest

func (b *Base) GetMessageDigest() string

func (*Base) GetTimeRFC

func (b *Base) GetTimeRFC() string

func (*Base) GetTimeUnix

func (b *Base) GetTimeUnix() int64

func (*Base) GetTimeUnixNano

func (b *Base) GetTimeUnixNano() int64

func (*Base) InputsMatch

func (b *Base) InputsMatch(inputs []string) bool

func (*Base) IsLastSource

func (b *Base) IsLastSource(src string) bool

func (*Base) StopProcessing

func (b *Base) StopProcessing(p *qtypes_plugin.Plugin, allowEmptyInput bool) bool

func (*Base) ToFlatJSON

func (b *Base) ToFlatJSON() map[string]interface{}

func (*Base) ToJSON

func (b *Base) ToJSON() map[string]interface{}

type ContainerMessage

type ContainerMessage struct {
	Base
	Container types.ContainerJSON
	Engine    types.Info // TODO:
}

func NewContainerMessage

func NewContainerMessage(base Base, cnt *types.ContainerJSON) ContainerMessage

func (*ContainerMessage) AddEngineInfo

func (cm *ContainerMessage) AddEngineInfo(e *types.Info)

func (*ContainerMessage) GenContainerMsgID

func (c *ContainerMessage) GenContainerMsgID() string

GenContainerMsgID uses "<container_id>-<time.UnixNano()>-<MSG>" and does a sha1 hash.

func (*ContainerMessage) GetContainerName

func (c *ContainerMessage) GetContainerName() string

type Message

type Message struct {
	Base
	Message string
}

func NewMessage

func NewMessage(b Base, msg string) Message

func (*Message) ParseJsonMap

func (m *Message) ParseJsonMap(p *qtypes_plugin.Plugin, keys mapset.Set, kv map[string]string) map[string]string

ParseJSONMap iterates over set of potential keys and if unmarshalls the string value of all keys into a new map.

func (*Message) ToStringRFC54242

func (m *Message) ToStringRFC54242() (res string, err error)

ToStringRFC54242 returns a string in RFC5424 format

type SyslogMessage

type SyslogMessage struct {
	Base
	Syslog qtypes_syslog.Syslog
}

func NewSyslogMessage

func NewSyslogMessage(b Base, sl qtypes_syslog.Syslog) SyslogMessage

func (*SyslogMessage) ToRFC5424

func (sm *SyslogMessage) ToRFC5424() (str string, err error)