logstream

package
v1.5.0-dev14 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 2, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

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

type CompletedStreamerParams added in v1.2.2

type CompletedStreamerParams struct {
	Execution *models.Execution
}

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

type LiveStreamerParams added in v1.2.2

type LiveStreamerParams struct {
	Reader io.Reader
	Buffer int
}

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         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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL