internal

Documentation

Index

• type Streamer
  • func NewStreamer(config *sysconfig.SystemConfig) (*Streamer, *cli.ExitError)
  • func (s *Streamer) Start() *cli.ExitError
  • func (s *Streamer) Stop() *cli.ExitError

Types

type Streamer

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

func NewStreamer

func NewStreamer(
	config *sysconfig.SystemConfig,
) (*Streamer, *cli.ExitError)

func (*Streamer) Start

func (s *Streamer) Start() *cli.ExitError

func (*Streamer) Stop

func (s *Streamer) Stop() *cli.ExitError