Documentation ¶
Index ¶
Constants ¶
View Source
const (
LogsProcotolID = "/bacalhau/compute/logs/1.0.0"
)
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type LogStreamClient ¶
type LogStreamClient struct {
// contains filtered or unexported fields
}
func NewLogStreamClient ¶
func NewLogStreamClient(ctx context.Context, address string) (*LogStreamClient, error)
NewLogStreamClient creates a new client communicating with the provided multiaddr string.
func (*LogStreamClient) Close ¶
func (c *LogStreamClient) Close()
Close will close the underlying stream and resources in-use.
func (*LogStreamClient) Connect ¶
func (c *LogStreamClient) Connect(ctx context.Context, executionID string, withHistory bool, follow bool) error
Connect sends the initial request to the logserver before
func (*LogStreamClient) ReadDataFrame ¶
ReadDataFrame reads a single dataframe from the client's stream (if connected)
type LogStreamRequest ¶
type LogStreamServer ¶
type LogStreamServer struct { Address string // contains filtered or unexported fields }
func NewLogStreamServer ¶
func NewLogStreamServer(options LogStreamServerOptions) *LogStreamServer
func (*LogStreamServer) Handle ¶
func (s *LogStreamServer) Handle(stream network.Stream)
type LogStreamServerOptions ¶
type LogStreamServerOptions struct { Ctx context.Context Host host.Host ExecutionStore store.ExecutionStore Executors executor.ExecutorProvider }
Click to show internal directories.
Click to hide internal directories.