logstream

Documentation

Index

• type CompletedStreamer
  • func NewCompletedStreamer(params CompletedStreamerParams) *CompletedStreamer
  • func (s *CompletedStreamer) Stream(ctx context.Context) chan *concurrency.AsyncResult[models.ExecutionLog]
• type CompletedStreamerParams
• type LiveStreamer
  • func NewLiveStreamer(params LiveStreamerParams) *LiveStreamer
  • func (s *LiveStreamer) Stream(ctx context.Context) chan *concurrency.AsyncResult[models.ExecutionLog]
• type LiveStreamerParams
• type Server
  • func NewServer(params ServerParams) *Server
  • func (s *Server) GetLogStream(ctx context.Context, request executor.LogStreamRequest) (<-chan *concurrency.AsyncResult[models.ExecutionLog], error)
• type ServerParams
• type Streamer

Types

type CompletedStreamer

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

CompletedStreamer is a streamer for completed executions that streams the output from the execution's RunOutput field to the channel.

func NewCompletedStreamer

func NewCompletedStreamer(params CompletedStreamerParams) *CompletedStreamer

func (*CompletedStreamer) Stream

func (s *CompletedStreamer) Stream(ctx context.Context) chan *concurrency.AsyncResult[models.ExecutionLog]

type CompletedStreamerParams

type CompletedStreamerParams struct {
	Execution *models.Execution
}

type LiveStreamer

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

LiveStreamer streams logs from a live execution's log stream to a channel

func NewLiveStreamer

func NewLiveStreamer(params LiveStreamerParams) *LiveStreamer

func (*LiveStreamer) Stream

func (s *LiveStreamer) Stream(ctx context.Context) chan *concurrency.AsyncResult[models.ExecutionLog]

type LiveStreamerParams

type LiveStreamerParams struct {
	Reader io.Reader
	Buffer int
}

type Server

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

func NewServer

func NewServer(params ServerParams) *Server

NewServer creates a new log stream server

func (*Server) GetLogStream

func (s *Server) GetLogStream(ctx context.Context, request executor.LogStreamRequest) (
	<-chan *concurrency.AsyncResult[models.ExecutionLog], error)

GetLogStream returns a stream of logs for a given execution

type ServerParams

type ServerParams struct {
	ExecutionStore store.ExecutionStore
	Executors      executor.ExecProvider
	// Buffer is the size of the channel buffer for each individual log stream.
	// If not set (0), defaultBuffer will be used.
	Buffer int
}

type Streamer

type Streamer interface {
	// Stream returns a channel of execution logs
	Stream(ctx context.Context) chan *concurrency.AsyncResult[models.ExecutionLog]
}

Streamer is an interface for streaming execution logs through a channel