Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type CompletedStreamer ¶ added in v1.2.2
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 ¶ added in v1.2.2
func NewCompletedStreamer(params CompletedStreamerParams) *CompletedStreamer
func (*CompletedStreamer) Stream ¶ added in v1.2.2
func (s *CompletedStreamer) Stream(ctx context.Context) chan *concurrency.AsyncResult[models.ExecutionLog]
type CompletedStreamerParams ¶ added in v1.2.2
type LiveStreamer ¶ added in v1.2.2
type LiveStreamer struct {
// contains filtered or unexported fields
}
LiveStreamer streams logs from a live execution's log stream to a channel
func NewLiveStreamer ¶ added in v1.2.2
func NewLiveStreamer(params LiveStreamerParams) *LiveStreamer
func (*LiveStreamer) Stream ¶ added in v1.2.2
func (s *LiveStreamer) Stream(ctx context.Context) chan *concurrency.AsyncResult[models.ExecutionLog]
type LiveStreamerParams ¶ added in v1.2.2
type Server ¶ added in v1.2.2
type Server struct {
// contains filtered or unexported fields
}
func NewServer ¶ added in v1.2.2
func NewServer(params ServerParams) *Server
NewServer creates a new log stream server
func (*Server) GetLogStream ¶ added in v1.2.2
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 ¶ added in v1.2.2
type ServerParams struct { ExecutionStore store.ExecutionStore Executors executor.ExecutorProvider // 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 ¶ added in v1.2.2
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
Click to show internal directories.
Click to hide internal directories.