http

Documentation

Index

• type HTTP
  • func (h *HTTP) List(ctx context.Context, requestor string, states []job.State, tags []string) (*api.ListResponse, error)
  • func (h *HTTP) Retry(ctx context.Context, requestor string, jobID types.JobID) (*api.RetryResponse, error)
  • func (h *HTTP) Start(ctx context.Context, requestor string, jobDescriptor string) (*api.StartResponse, error)
  • func (h *HTTP) Status(ctx context.Context, requestor string, jobID types.JobID) (*api.StatusResponse, error)
  • func (h *HTTP) Stop(ctx context.Context, requestor string, jobID types.JobID) (*api.StopResponse, error)
  • func (h *HTTP) Version(ctx context.Context, requestor string) (*api.VersionResponse, error)
• type HTTPPartiallyDecodedResponse

Types

type HTTP

type HTTP struct {
	Addr string
}

HTTP communicates with ConTest Server via http(s)/json transport HTTP implements the Transport interface

func (*HTTP) List

func (h *HTTP) List(ctx context.Context, requestor string, states []job.State, tags []string) (*api.ListResponse, error)

func (*HTTP) Retry

func (h *HTTP) Retry(ctx context.Context, requestor string, jobID types.JobID) (*api.RetryResponse, error)

func (*HTTP) Start

func (h *HTTP) Start(ctx context.Context, requestor string, jobDescriptor string) (*api.StartResponse, error)

func (*HTTP) Status

func (h *HTTP) Status(ctx context.Context, requestor string, jobID types.JobID) (*api.StatusResponse, error)

func (*HTTP) Stop

func (h *HTTP) Stop(ctx context.Context, requestor string, jobID types.JobID) (*api.StopResponse, error)

func (*HTTP) Version

func (h *HTTP) Version(ctx context.Context, requestor string) (*api.VersionResponse, error)

type HTTPPartiallyDecodedResponse

type HTTPPartiallyDecodedResponse struct {
	ServerID string
	Type     string
	Data     json.RawMessage
	Error    *xjson.Error
}

HttpPartiallyDecodedResponse is a httplistener.HTTPAPIResponse, but with the Data not fully decoded yet