pilot

package

Go to main page

Versions in this module

v0

v0.9.7

Apr 26, 2019

Changes in this version

+ func ReadFile(path string, separator string) ([]string, error)

type FilebeatPiloter

+ func (p *FilebeatPiloter) GetBaseConf() string

type FluentdPiloter

+ func (p *FluentdPiloter) GetBaseConf() string

type Piloter

+ GetBaseConf func() string

v0.9.6

Oct 17, 2018

Changes in this version

+ const DOCKER_SYSTEM_PATH

+ const ENV_FLUENTD_WORKER

+ const FILEBEAT_BASE_CONF

+ const FILEBEAT_EXEC_CMD

+ const FILEBEAT_REGISTRY

+ const FLUENTD_BASE_CONF

+ const FLUENTD_CONF_DIR

+ const FLUENTD_CONF_FILE

+ const FLUENTD_EXEC_CMD

+ const FLUENTD_PLUGINS

+ const KUBELET_SYSTEM_PATH

type FilebeatPiloter

+ func (p *FilebeatPiloter) GetConfHome() string

+ func (p *FilebeatPiloter) GetConfPath(container string) string

type FluentdPiloter

+ func (p *FluentdPiloter) GetConfHome() string

+ func (p *FluentdPiloter) GetConfPath(container string) string

type Piloter

+ func NewPiloter(baseDir string) (Piloter, error)

+ GetConfHome func() string

+ GetConfPath func(container string) string

v0.9.5

Jul 25, 2018

v0.9.4

Jul 25, 2018

Changes in this version

+ const DOCKER_HOME_PATH

+ const ENV_FILEBEAT_OUTPUT

+ const ENV_FLUENTD_OUTPUT

+ const ENV_LOGGING_OUTPUT

+ const ENV_PILOT_CREATE_SYMLINK

+ const ENV_PILOT_LOG_PREFIX

+ const ENV_PILOT_TYPE

+ const ENV_SERVICE_LOGS_TEMPL

+ const ERR_ALREADY_STARTED

+ const FILEBEAT_CONF_DIR

+ const FILEBEAT_CONF_FILE

+ const FILEBEAT_CONF_HOME

+ const FILEBEAT_EXEC_BIN

+ const FILEBEAT_LOG_DIR

+ const FILEBEAT_REGISTRY_FILE

+ const FLUENTD_CONF_HOME

+ const KUBELET_HOME_PATH

+ const LABEL_K8S_CONTAINER_NAME

+ const LABEL_K8S_POD_NAMESPACE

+ const LABEL_POD

+ const LABEL_PROJECT

+ const LABEL_PROJECT_SWARM_MODE

+ const LABEL_SERVICE

+ const LABEL_SERVICE_LOGS_TEMPL

+ const LABEL_SERVICE_SWARM_MODE

+ const PILOT_FILEBEAT

+ const PILOT_FLUENTD

+ const SYMLINK_LOGS_BASE

+ var NODE_NAME = os.Getenv("NODE_NAME")

+ func Convert(info *LogInfoNode) (map[string]string, error)

+ func Register(format string, converter FormatConverter)

+ func Run(tpl string, baseDir string) error

+ type Config struct

+ Paths []string

+ type FileInode struct

+ Device uint64

+ Inode uint64

+ type FilebeatPiloter struct

+ func (p *FilebeatPiloter) ConfHome() string

+ func (p *FilebeatPiloter) ConfPathOf(container string) string

+ func (p *FilebeatPiloter) Name() string

+ func (p *FilebeatPiloter) OnDestroyEvent(container string) error

+ func (p *FilebeatPiloter) Reload() error

+ func (p *FilebeatPiloter) Start() error

+ func (p *FilebeatPiloter) Stop() error

+ type FluentdPiloter struct

+ func (p *FluentdPiloter) ConfHome() string

+ func (p *FluentdPiloter) ConfPathOf(container string) string

+ func (p *FluentdPiloter) Name() string

+ func (p *FluentdPiloter) OnDestroyEvent(container string) error

+ func (p *FluentdPiloter) Reload() error

+ func (p *FluentdPiloter) Start() error

+ func (p *FluentdPiloter) Stop() error

+ type FormatConverter func(info *LogInfoNode) (map[string]string, error)

+ type LogConfig struct

+ ContainerDir string

+ EstimateTime bool

+ File string

+ Format string

+ FormatConfig map[string]string

+ HostDir string

+ Name string

+ Stdout bool

+ Tags map[string]string

+ Target string

+ type LogInfoNode struct

+ type Pilot struct

+ func New(tplStr string, baseDir string) (*Pilot, error)

+ type Piloter interface

+ ConfHome func() string

+ ConfPathOf func(container string) string

+ Name func() string

+ OnDestroyEvent func(container string) error

+ Reload func() error

+ Start func() error

+ Stop func() error

+ func NewFilebeatPiloter(base string) (Piloter, error)

+ func NewFluentdPiloter() (Piloter, error)

+ type RegistryState struct

+ FileStateOS FileInode

+ Offset int64

+ Source string

+ TTL time.Duration

+ Timestamp time.Time

+ Type string

+ type SimpleConverter struct

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL