qtypes_messages

Documentation

Index

• func Sha1HashString(s string) string
• type Base
  • func NewBase(src string) Base
  • func NewBaseFromBase(src string, b Base) 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) ToJSON() map[string]interface{}
• type ContainerMessage
  • func NewContainerMessage(base Base, cnt *types.ContainerJSON, msg string) 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

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
}

func NewBase

func NewBase(src string) Base

func NewBaseFromBase

func NewBaseFromBase(src string, b Base) 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) ToJSON

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

type ContainerMessage

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

func NewContainerMessage

func NewContainerMessage(base Base, cnt *types.ContainerJSON, msg string) 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