ship

Documentation

Index

• type LogShipper
  • func NewLogShipper(cl streamer, man *pb.RunManifest, verbose bool) *LogShipper
  • func (l *LogShipper) Close()
  • func (l *LogShipper) Errs() []error
  • func (l *LogShipper) Start(ctx context.Context)
  • func (l *LogShipper) Write(delta *pb.Delta)

Types

type LogShipper

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

LogShipper subscribes to the Log Bus & streams log entries up to the remote Logstream service. It uses a non-blocking, dynamically resizing buffer to reliably stream logs to the server.

func NewLogShipper

func NewLogShipper(cl streamer, man *pb.RunManifest, verbose bool) *LogShipper

NewLogShipper creates and returns a new LogShipper.

func (*LogShipper) Close

func (l *LogShipper) Close()

Close the process and allow for a 10s grace period where lagging messages will be drained.

func (*LogShipper) Errs

func (l *LogShipper) Errs() []error

Errs returns all errors that were encountered during the process.

func (*LogShipper) Start

func (l *LogShipper) Start(ctx context.Context)

Start the log streaming process and begin writing logs to the server.

func (*LogShipper) Write

func (l *LogShipper) Write(delta *pb.Delta)