pkg

Documentation

Index

• type DockerProvider
  • func NewLocalDockerProvider() *DockerProvider
  • func (dp *DockerProvider) GetSources() []Source
  • func (dp *DockerProvider) Name() string
  • func (dp *DockerProvider) Refresh(ctx context.Context)
• type DockerSource
  • func (ds *DockerSource) Name() string
  • func (ds *DockerSource) Tail(ctx context.Context, follow bool, tail string) (io.ReadCloser, io.ReadCloser)
• type Provider
• type Source

Types

type DockerProvider

type DockerProvider struct {
	// contains filtered or unexported fields
}

func NewLocalDockerProvider

func NewLocalDockerProvider() *DockerProvider

func (*DockerProvider) GetSources

func (dp *DockerProvider) GetSources() []Source

func (*DockerProvider) Name

func (dp *DockerProvider) Name() string

func (*DockerProvider) Refresh

func (dp *DockerProvider) Refresh(ctx context.Context)

type DockerSource

type DockerSource struct {
	// contains filtered or unexported fields
}

func (*DockerSource) Name

func (ds *DockerSource) Name() string

func (*DockerSource) Tail

func (ds *DockerSource) Tail(ctx context.Context, follow bool, tail string) (io.ReadCloser, io.ReadCloser)

type Provider

type Provider interface {
	Name() string
	ListSources() []Source
}

type Source

type Source interface {
	Name() string
	Tail(ctx context.Context, follow bool, tail string) (io.ReadCloser, io.ReadCloser)
}