ingester

Documentation

Index

• type Coordinator
  • func (c *Coordinator) Start() (string, error)
  • func (c *Coordinator) Stop()

Types

type Coordinator

type Coordinator struct {
	LastMsgID string
	Resume    bool
	File      *file.Opts
	Kafka     *kafka.Opts
	// contains filtered or unexported fields
}

Coordinator ingests an SSE stream from WMF and processes each event in turn

func (*Coordinator) Start

func (c *Coordinator) Start() (string, error)

Start begins consumption of the SSE stream If the current terminal is a TTY, it will output a progress spinner

func (*Coordinator) Stop

func (c *Coordinator) Stop()

Stop will stop the coordinator, close the connection and request all goroutines to exit It blocks until shutdown is complete