Documentation ¶
Index ¶
- type Client
- type DockerLogs
- type SocketClient
- func (c *SocketClient) ContainerInspect(ctx context.Context, containerID string) (types.ContainerJSON, error)
- func (c *SocketClient) ContainerList(ctx context.Context, options types.ContainerListOptions) ([]types.Container, error)
- func (c *SocketClient) ContainerLogs(ctx context.Context, containerID string, options types.ContainerLogsOptions) (io.ReadCloser, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client interface { ContainerList(ctx context.Context, options types.ContainerListOptions) ([]types.Container, error) ContainerLogs(ctx context.Context, containerID string, options types.ContainerLogsOptions) (io.ReadCloser, error) ContainerInspect(ctx context.Context, containerID string) (types.ContainerJSON, error) }
func NewEnvClient ¶
type DockerLogs ¶
type DockerLogs struct { Endpoint string `toml:"endpoint"` FromBeginning bool `toml:"from_beginning"` Timeout config.Duration `toml:"timeout"` LabelInclude []string `toml:"docker_label_include"` LabelExclude []string `toml:"docker_label_exclude"` ContainerInclude []string `toml:"container_name_include"` ContainerExclude []string `toml:"container_name_exclude"` ContainerStateInclude []string `toml:"container_state_include"` ContainerStateExclude []string `toml:"container_state_exclude"` IncludeSourceTag bool `toml:"source_tag"` tlsint.ClientConfig // contains filtered or unexported fields }
func (*DockerLogs) Gather ¶
func (d *DockerLogs) Gather(acc telegraf.Accumulator) error
func (*DockerLogs) Init ¶
func (d *DockerLogs) Init() error
func (*DockerLogs) SampleConfig ¶
func (*DockerLogs) SampleConfig() string
func (*DockerLogs) Start ¶
func (d *DockerLogs) Start(telegraf.Accumulator) error
Start is a noop which is required for a *DockerLogs to implement the telegraf.ServiceInput interface
func (*DockerLogs) Stop ¶
func (d *DockerLogs) Stop()
type SocketClient ¶
type SocketClient struct {
// contains filtered or unexported fields
}
func (*SocketClient) ContainerInspect ¶
func (c *SocketClient) ContainerInspect(ctx context.Context, containerID string) (types.ContainerJSON, error)
func (*SocketClient) ContainerList ¶
func (c *SocketClient) ContainerList(ctx context.Context, options types.ContainerListOptions) ([]types.Container, error)
func (*SocketClient) ContainerLogs ¶
func (c *SocketClient) ContainerLogs(ctx context.Context, containerID string, options types.ContainerLogsOptions) (io.ReadCloser, error)
Click to show internal directories.
Click to hide internal directories.