eventmultiplexer

Documentation

Index

• type DockerEventMultiplexer
  • func New(in <-chan docker.ContainerEvent) *DockerEventMultiplexer
  • func (m *DockerEventMultiplexer) NewOutput(backendName string) chan docker.ContainerEvent
  • func (m *DockerEventMultiplexer) Run(ctx context.Context)

Types

type DockerEventMultiplexer

type DockerEventMultiplexer struct {
	In  <-chan docker.ContainerEvent
	Out map[string]chan docker.ContainerEvent
	// contains filtered or unexported fields
}

func New

func New(in <-chan docker.ContainerEvent) *DockerEventMultiplexer

func (*DockerEventMultiplexer) NewOutput

func (m *DockerEventMultiplexer) NewOutput(backendName string) chan docker.ContainerEvent

func (*DockerEventMultiplexer) Run

func (m *DockerEventMultiplexer) Run(ctx context.Context)