qtypes_messages

Documentation

Index

• func Sha1HashString(s string) string
• type Base
  • func NewBase(src string) Base
  • func NewBaseFromBase(src string, b Base) Base
  • func NewBaseFromOldBase(src string, b qtypes.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, allowEmptyInput bool) bool
  • func (b *Base) ToJSON() map[string]interface{}
• 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 NewBaseFromOldBase

func NewBaseFromOldBase(src string, b qtypes.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, allowEmptyInput bool) bool

func (*Base) ToJSON

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

type Message

type Message struct {
	Base
	Message string
}

func NewMessage

func NewMessage(b Base, msg string) Message