client

Documentation

Index

• type Client
  • func New(serverAddress string) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) Kill() error
  • func (c *Client) StageExecute(name string, paramProvider ParamProvider) (map[string]string, error)
  • func (c *Client) Status() error
• type ParamProvider
• type StdinStreamer
  • func NewStreamer(stream pb.CorkTypeService_StageExecuteClient) *StdinStreamer
  • func (s *StdinStreamer) Write(inputBytes []byte) (int, error)

Types

type Client

type Client struct {
	GClient pb.CorkTypeServiceClient
	Conn    *grpc.ClientConn
}

func New

func New(serverAddress string) (*Client, error)

func (*Client) Close

func (c *Client) Close() error

func (*Client) Kill

func (c *Client) Kill() error

func (*Client) StageExecute

func (c *Client) StageExecute(name string, paramProvider ParamProvider) (map[string]string, error)

func (*Client) Status

func (c *Client) Status() error

type ParamProvider

type ParamProvider interface {
	LoadParams(paramDefinitions map[string]*pb.ParamDefinition) (map[string]string, error)
}

type StdinStreamer

type StdinStreamer struct {
	Stream pb.CorkTypeService_StageExecuteClient
}

func NewStreamer

func NewStreamer(stream pb.CorkTypeService_StageExecuteClient) *StdinStreamer

func (*StdinStreamer) Write

func (s *StdinStreamer) Write(inputBytes []byte) (int, error)