fluentbit

Documentation

Index

• Variables
• type Fluentbit
  • func (f *Fluentbit) AllocTaskStreamToConfig(Alloc *api.Allocation, Task *api.Task, Stream string) string
  • func (f *Fluentbit) AllocToConfig(Alloc *api.Allocation) string
  • func (f *Fluentbit) Run()
  • func (f *Fluentbit) UpdateConf(Allocs []*api.Allocation)
• type FluentbitConfig
• type FluentbitFilterParser

Variables

var FluentbitConfTmpl string

Types

type Fluentbit

type Fluentbit struct {
	Nomad     *nomad.Nomad
	ConfFile  string
	TagPrefix string
	Parser    string
	ReloadCmd string
}

func (*Fluentbit) AllocTaskStreamToConfig

func (f *Fluentbit) AllocTaskStreamToConfig(Alloc *api.Allocation, Task *api.Task, Stream string) string

func (*Fluentbit) AllocToConfig

func (f *Fluentbit) AllocToConfig(Alloc *api.Allocation) string

func (*Fluentbit) Run

func (f *Fluentbit) Run()

func (*Fluentbit) UpdateConf

func (f *Fluentbit) UpdateConf(Allocs []*api.Allocation)

type FluentbitConfig

type FluentbitConfig struct {
	Tag            string
	Path           string
	Parser         string
	FilterParsers  []*FluentbitFilterParser
	NomadNamespace string
	NomadJob       string
	NomadTaskGroup string
	NomadTask      string
	NomadAllocID   string
	NomadAllocName string
	NomadNodeID    string
	NomadLogStream string
}

type FluentbitFilterParser

type FluentbitFilterParser struct {
	Key    string
	Parser string
}