runnerv2client

Documentation

Index

• Constants
• type Client
  • func New(clientConn *grpc.ClientConn, logger *zap.Logger) *Client
  • func (c *Client) Close() error
  • func (c *Client) ExecuteProgram(ctx context.Context, cfg *runnerv2.ProgramConfig, opts ExecuteProgramOptions) error
• type ExecuteProgramOptions

Constants

const MaxMsgSize = 32 * 1024 * 1024 // 32 MiB

Types

type Client

type Client struct {
	runnerv2.RunnerServiceClient
	grpc_health_v1.HealthClient
	// contains filtered or unexported fields
}

func New

func New(clientConn *grpc.ClientConn, logger *zap.Logger) *Client

func (*Client) Close

func (c *Client) Close() error

func (*Client) ExecuteProgram

func (c *Client) ExecuteProgram(
	ctx context.Context,
	cfg *runnerv2.ProgramConfig,
	opts ExecuteProgramOptions,
) error

type ExecuteProgramOptions

type ExecuteProgramOptions struct {
	InputData        []byte
	SessionID        string
	Stdin            io.ReadCloser
	Stdout           io.Writer
	Stderr           io.Writer
	StoreStdoutInEnv bool
	Winsize          *runnerv2.Winsize
}