httpserverclient

Documentation

Index

• type Client
  • func NewClient(client *http.Client, baseURL string) (*Client, error)
  • func (c *Client) CancelJobExecution(ctx context.Context, in *api.CancelJobExecutionRequest, ...) (*api.CancelJobExecutionResponse, error)
  • func (c *Client) CreatePipeline(ctx context.Context, in *api.CreatePipelineRequest, opts ...grpc.CallOption) (*api.CreatePipelineResponse, error)
  • func (c *Client) GetJobExecution(ctx context.Context, in *api.GetJobExecutionRequest, opts ...grpc.CallOption) (*api.GetJobExecutionResponse, error)
  • func (c *Client) GetLogLines(ctx context.Context, in *api.GetLogLinesRequest, opts ...grpc.CallOption) (*api.GetLogLinesResponse, error)
  • func (c *Client) GetStepExecution(ctx context.Context, in *api.GetStepExecutionRequest, opts ...grpc.CallOption) (*api.GetStepExecutionResponse, error)
  • func (c *Client) Heartbeat(ctx context.Context, in *api.HeartbeatRequest, opts ...grpc.CallOption) (*api.HeartbeatResponse, error)
  • func (c *Client) ListJobExecutions(ctx context.Context, in *api.ListJobExecutionsRequest, opts ...grpc.CallOption) (*api.ListJobExecutionsResponse, error)
  • func (c *Client) Ping(ctx context.Context, in *api.ServerPingRequest, opts ...grpc.CallOption) (*api.ServerPingResponse, error)
  • func (c *Client) RequestJob(ctx context.Context, in *api.RequestJobRequest, opts ...grpc.CallOption) (*api.RequestJobResponse, error)
  • func (c *Client) UpdateJobExecution(ctx context.Context, in *api.UpdateJobExecutionRequest, ...) (*api.UpdateJobExecutionResponse, error)
  • func (c *Client) UpdateStepExecution(ctx context.Context, in *api.UpdateStepExecutionRequest, ...) (*api.UpdateStepExecutionResponse, error)
  • func (c *Client) UploadLogLines(ctx context.Context, in *api.UpdateLogLinesRequest, opts ...grpc.CallOption) (*api.UpdateLogLinesResponse, error)

Types

type Client

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

func NewClient

func NewClient(client *http.Client, baseURL string) (*Client, error)

func (*Client) CancelJobExecution

func (c *Client) CancelJobExecution(ctx context.Context, in *api.CancelJobExecutionRequest, opts ...grpc.CallOption) (*api.CancelJobExecutionResponse, error)

func (*Client) CreatePipeline

func (c *Client) CreatePipeline(ctx context.Context, in *api.CreatePipelineRequest, opts ...grpc.CallOption) (*api.CreatePipelineResponse, error)

func (*Client) GetJobExecution

func (c *Client) GetJobExecution(ctx context.Context, in *api.GetJobExecutionRequest, opts ...grpc.CallOption) (*api.GetJobExecutionResponse, error)

func (*Client) GetLogLines

func (c *Client) GetLogLines(ctx context.Context, in *api.GetLogLinesRequest, opts ...grpc.CallOption) (*api.GetLogLinesResponse, error)

func (*Client) GetStepExecution

func (c *Client) GetStepExecution(ctx context.Context, in *api.GetStepExecutionRequest, opts ...grpc.CallOption) (*api.GetStepExecutionResponse, error)

func (*Client) Heartbeat

func (c *Client) Heartbeat(ctx context.Context, in *api.HeartbeatRequest, opts ...grpc.CallOption) (*api.HeartbeatResponse, error)

func (*Client) ListJobExecutions

func (c *Client) ListJobExecutions(ctx context.Context, in *api.ListJobExecutionsRequest, opts ...grpc.CallOption) (*api.ListJobExecutionsResponse, error)

func (*Client) Ping

func (c *Client) Ping(ctx context.Context, in *api.ServerPingRequest, opts ...grpc.CallOption) (*api.ServerPingResponse, error)

func (*Client) RequestJob

func (c *Client) RequestJob(ctx context.Context, in *api.RequestJobRequest, opts ...grpc.CallOption) (*api.RequestJobResponse, error)

func (*Client) UpdateJobExecution

func (c *Client) UpdateJobExecution(ctx context.Context, in *api.UpdateJobExecutionRequest,
	opts ...grpc.CallOption,
) (*api.UpdateJobExecutionResponse, error)

func (*Client) UpdateStepExecution

func (c *Client) UpdateStepExecution(ctx context.Context, in *api.UpdateStepExecutionRequest, opts ...grpc.CallOption) (*api.UpdateStepExecutionResponse, error)

func (*Client) UploadLogLines

func (c *Client) UploadLogLines(ctx context.Context, in *api.UpdateLogLinesRequest, opts ...grpc.CallOption) (*api.UpdateLogLinesResponse, error)