grpc

Documentation

Index

• Constants
• type ExecutorGRPCPlugin
  • func (p *ExecutorGRPCPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)
  • func (p *ExecutorGRPCPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error
• type GRPCClient
  • func (c *GRPCClient) Cancel(ctx context.Context, id string) error
  • func (c *GRPCClient) GetOutputStream(ctx context.Context, executionID string, withHistory bool, follow bool) (io.ReadCloser, error)
  • func (c *GRPCClient) IsInstalled(ctx context.Context) (bool, error)
  • func (c *GRPCClient) Run(ctx context.Context, args *executor.RunCommandRequest) (*models.RunCommandResult, error)
  • func (c *GRPCClient) ShouldBid(ctx context.Context, request bidstrategy.BidStrategyRequest) (bidstrategy.BidStrategyResponse, error)
  • func (c *GRPCClient) ShouldBidBasedOnUsage(ctx context.Context, request bidstrategy.BidStrategyRequest, ...) (bidstrategy.BidStrategyResponse, error)
  • func (c *GRPCClient) Start(ctx context.Context, request *executor.RunCommandRequest) error
  • func (c *GRPCClient) Wait(ctx context.Context, executionID string) (<-chan *models.RunCommandResult, <-chan error)
• type GRPCServer
  • func (s *GRPCServer) Cancel(ctx context.Context, request *proto.CancelCommandRequest) (*proto.CancelCommandResponse, error)
  • func (s *GRPCServer) GetOutputStream(request *proto.OutputStreamRequest, ...) error
  • func (s *GRPCServer) IsInstalled(ctx context.Context, _ *proto.IsInstalledRequest) (*proto.IsInstalledResponse, error)
  • func (s *GRPCServer) Run(ctx context.Context, request *proto.RunCommandRequest) (*proto.RunCommandResponse, error)
  • func (s *GRPCServer) ShouldBid(ctx context.Context, request *proto.ShouldBidRequest) (*proto.ShouldBidResponse, error)
  • func (s *GRPCServer) ShouldBidBasedOnUsage(ctx context.Context, request *proto.ShouldBidBasedOnUsageRequest) (*proto.ShouldBidResponse, error)
  • func (s *GRPCServer) Start(_ context.Context, request *proto.RunCommandRequest) (*proto.StartResponse, error)
  • func (s *GRPCServer) Wait(request *proto.WaitRequest, server proto.Executor_WaitServer) error
• type StreamReader
  • func (sr *StreamReader) Close() error
  • func (sr *StreamReader) Read(p []byte) (n int, err error)

Constants

const (
	DefaultStreamBufferSize = 1024
)

Types

type ExecutorGRPCPlugin

type ExecutorGRPCPlugin struct {
	plugin.Plugin
	Impl executor.Executor
}

func (*ExecutorGRPCPlugin) GRPCClient

func (p *ExecutorGRPCPlugin) GRPCClient(ctx context.Context, broker *plugin.GRPCBroker, c *grpc.ClientConn) (interface{}, error)

func (*ExecutorGRPCPlugin) GRPCServer

func (p *ExecutorGRPCPlugin) GRPCServer(broker *plugin.GRPCBroker, s *grpc.Server) error

type GRPCClient

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

func (*GRPCClient) Cancel

func (c *GRPCClient) Cancel(ctx context.Context, id string) error

func (*GRPCClient) GetOutputStream

func (c *GRPCClient) GetOutputStream(ctx context.Context, executionID string, withHistory bool, follow bool) (io.ReadCloser, error)

func (*GRPCClient) IsInstalled

func (c *GRPCClient) IsInstalled(ctx context.Context) (bool, error)

func (*GRPCClient) Run

func (c *GRPCClient) Run(ctx context.Context, args *executor.RunCommandRequest) (*models.RunCommandResult, error)

func (*GRPCClient) ShouldBid

func (c *GRPCClient) ShouldBid(ctx context.Context, request bidstrategy.BidStrategyRequest) (bidstrategy.BidStrategyResponse, error)

func (*GRPCClient) ShouldBidBasedOnUsage

func (c *GRPCClient) ShouldBidBasedOnUsage(
	ctx context.Context,
	request bidstrategy.BidStrategyRequest,
	usage models.Resources) (bidstrategy.BidStrategyResponse, error)

func (*GRPCClient) Start

func (c *GRPCClient) Start(ctx context.Context, request *executor.RunCommandRequest) error

func (*GRPCClient) Wait

func (c *GRPCClient) Wait(ctx context.Context, executionID string) (<-chan *models.RunCommandResult, <-chan error)

type GRPCServer

type GRPCServer struct {
	Impl executor.Executor

	proto.UnimplementedExecutorServer
}

func (*GRPCServer) Cancel

func (s *GRPCServer) Cancel(ctx context.Context, request *proto.CancelCommandRequest) (*proto.CancelCommandResponse, error)

func (*GRPCServer) GetOutputStream

func (s *GRPCServer) GetOutputStream(request *proto.OutputStreamRequest, server proto.Executor_GetOutputStreamServer) error

func (*GRPCServer) IsInstalled

func (s *GRPCServer) IsInstalled(ctx context.Context, _ *proto.IsInstalledRequest) (*proto.IsInstalledResponse, error)

func (*GRPCServer) Run

func (s *GRPCServer) Run(ctx context.Context, request *proto.RunCommandRequest) (*proto.RunCommandResponse, error)

func (*GRPCServer) ShouldBid

func (s *GRPCServer) ShouldBid(ctx context.Context, request *proto.ShouldBidRequest) (*proto.ShouldBidResponse, error)

func (*GRPCServer) ShouldBidBasedOnUsage

func (s *GRPCServer) ShouldBidBasedOnUsage(
	ctx context.Context,
	request *proto.ShouldBidBasedOnUsageRequest) (*proto.ShouldBidResponse, error)

func (*GRPCServer) Start

func (s *GRPCServer) Start(_ context.Context, request *proto.RunCommandRequest) (*proto.StartResponse, error)

func (*GRPCServer) Wait

func (s *GRPCServer) Wait(request *proto.WaitRequest, server proto.Executor_WaitServer) error

type StreamReader

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

func (*StreamReader) Close

func (sr *StreamReader) Close() error

func (*StreamReader) Read

func (sr *StreamReader) Read(p []byte) (n int, err error)