inputdockerstats

README

gogstash input dockerstats

Synopsis

{
	"input": [
		{
			"type": "docker",

			// (optional), docker endpoint, default: "unix:///var/run/docker.sock"
			"dockerurl": "unix:///var/run/docker.sock",

			// (optional), include docker name pattern, support regular expression of golang, default: []
			"include_patterns": [],

			// (optional), exclude docker name pattern, support regular expression of golang, default: []
			"exclude_patterns": [],

			// (optional), in seconds, stat interval, default: 15
			"stat_interval": 15,

			// (optional), in seconds, docker connection retry interval, default: 10
			"connection_retry_interval": 10

			// (optional), zero hierarchical_memory_limit in docker stats, sometimes it will cause elastic exception 'JsonParseException Numeric value out of range of long', default: false
			"zero_hierarchical_memory_limit": false
		}
	]
}

Documentation

Index

• Constants
• func InitHandler(confraw *config.ConfigRaw) (retconf config.TypeInputConfig, err error)
• type ErrorContainerLoopRunning
  • func (t *ErrorContainerLoopRunning) Error() string
• type InputConfig
  • func DefaultInputConfig() InputConfig
  • func (t *InputConfig) Start()

Constants

const (
	ModuleName = "dockerstats"
)

Functions

func InitHandler

func InitHandler(confraw *config.ConfigRaw) (retconf config.TypeInputConfig, err error)

Types

type ErrorContainerLoopRunning

type ErrorContainerLoopRunning struct {
	ID string
}

func (*ErrorContainerLoopRunning) Error

func (t *ErrorContainerLoopRunning) Error() string

type InputConfig

type InputConfig struct {
	config.InputConfig
	DockerURL               string   `json:"dockerurl"`
	IncludePatterns         []string `json:"include_patterns"`
	ExcludePatterns         []string `json:"exclude_patterns"`
	StatInterval            int      `json:"stat_interval"`
	ConnectionRetryInterval int      `json:"connection_retry_interval,omitempty"`

	ZeroHierarchicalMemoryLimit bool `json:"zero_hierarchical_memory_limit,omitempty"`
	// contains filtered or unexported fields
}

func DefaultInputConfig

func DefaultInputConfig() InputConfig

func (*InputConfig) Start

func (t *InputConfig) Start()