containerstreamer

Documentation

Index

• func NewContainerStreamer(log *zap.SugaredLogger, cli *client.Client) app.ContainerStreamer
• func NewMockStreamer() app.ContainerStreamer
• type ContainerStreamer
  • func (c *ContainerStreamer) GetStats(ctx context.Context) ([]models.Stats, error)
  • func (c *ContainerStreamer) StartStreaming(ctx context.Context, errCh chan error) chan []models.Stats
  • func (c *ContainerStreamer) WaitForAll()

Functions

func NewContainerStreamer

func NewContainerStreamer(log *zap.SugaredLogger, cli *client.Client) app.ContainerStreamer

func NewMockStreamer

func NewMockStreamer() app.ContainerStreamer

Types

type ContainerStreamer

type ContainerStreamer struct {
	sync.WaitGroup
	sync.Mutex
	// contains filtered or unexported fields
}

func (*ContainerStreamer) GetStats

func (c *ContainerStreamer) GetStats(ctx context.Context) ([]models.Stats, error)

func (*ContainerStreamer) StartStreaming

func (c *ContainerStreamer) StartStreaming(ctx context.Context, errCh chan error) chan []models.Stats

func (*ContainerStreamer) WaitForAll

func (c *ContainerStreamer) WaitForAll()