httpclient

Documentation

Overview

Package httpclient is a lightweight implementation of a client for the HTTP gateway.

Index

• Variables
• type AdminAPI
  • func NewAdminAPI(endpoint string, client http.Client) *AdminAPI
  • func (api *AdminAPI) Status(ctx context.Context) (*apiserver.Health, error)
  • func (api *AdminAPI) Version(ctx context.Context) (*version.Info, error)
• type ConsentAPI
  • func NewConsentAPI(endpoint string, client http.Client) *ConsentAPI
  • func (api *ConsentAPI) Update(ctx context.Context, msg *types.ConsentMessage) error
  • func (api *ConsentAPI) UpdateFromStatus(ctx context.Context, consentID string, status *types.ConsentStatus) error
  • func (api *ConsentAPI) UpdateFromString(ctx context.Context, consentID string, status string) error
• type InvocationAPI
  • func NewInvocationAPI(endpoint string, client http.Client) *InvocationAPI
  • func (api *InvocationAPI) Cancel(ctx context.Context, id string) error
  • func (api *InvocationAPI) Events(ctx context.Context, id string) (*apiserver.ObjectEvents, error)
  • func (api *InvocationAPI) Get(ctx context.Context, id string) (*types.WorkflowInvocation, error)
  • func (api *InvocationAPI) Invoke(ctx context.Context, spec *types.WorkflowInvocationSpec) (*types.ObjectMetadata, error)
  • func (api *InvocationAPI) InvokeSync(ctx context.Context, spec *types.WorkflowInvocationSpec) (..., error)
  • func (api *InvocationAPI) List(ctx context.Context) (*apiserver.WorkflowInvocationList, error)
  • func (api *InvocationAPI) Validate(ctx context.Context, spec *types.WorkflowInvocationSpec) error
• type WorkflowAPI
  • func NewWorkflowAPI(endpoint string, client http.Client) *WorkflowAPI
  • func (api *WorkflowAPI) Create(ctx context.Context, spec *types.WorkflowSpec) (*types.ObjectMetadata, error)
  • func (api *WorkflowAPI) CreateSync(ctx context.Context, spec *types.WorkflowSpec) (*types.Workflow, error)
  • func (api *WorkflowAPI) Delete(ctx context.Context, id string) error
  • func (api *WorkflowAPI) Events(ctx context.Context, id string) (*apiserver.ObjectEvents, error)
  • func (api *WorkflowAPI) Get(ctx context.Context, id string) (*types.Workflow, error)
  • func (api *WorkflowAPI) List(ctx context.Context) (*apiserver.WorkflowList, error)

Variables

var (
	ErrResponseError = errors.New("response error")
	ErrRequestCreate = errors.New("failed to create request")
	ErrRequestSend   = errors.New("failed to send request")
	ErrSerialize     = errors.New("failed to serialize input")
	ErrDeserialize   = errors.New("failed to deserialize input")
)

Types

type AdminAPI

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

func NewAdminAPI

func NewAdminAPI(endpoint string, client http.Client) *AdminAPI

func (*AdminAPI) Status

func (api *AdminAPI) Status(ctx context.Context) (*apiserver.Health, error)

func (*AdminAPI) Version

func (api *AdminAPI) Version(ctx context.Context) (*version.Info, error)

type ConsentAPI

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

func NewConsentAPI

func NewConsentAPI(endpoint string, client http.Client) *ConsentAPI

func (*ConsentAPI) Update

func (api *ConsentAPI) Update(ctx context.Context, msg *types.ConsentMessage) error

func (*ConsentAPI) UpdateFromStatus

func (api *ConsentAPI) UpdateFromStatus(ctx context.Context, consentID string, status *types.ConsentStatus) error

func (*ConsentAPI) UpdateFromString

func (api *ConsentAPI) UpdateFromString(ctx context.Context, consentID string, status string) error

type InvocationAPI

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

func NewInvocationAPI

func NewInvocationAPI(endpoint string, client http.Client) *InvocationAPI

func (*InvocationAPI) Cancel

func (api *InvocationAPI) Cancel(ctx context.Context, id string) error

func (*InvocationAPI) Events

func (api *InvocationAPI) Events(ctx context.Context, id string) (*apiserver.ObjectEvents, error)

func (*InvocationAPI) Get

func (api *InvocationAPI) Get(ctx context.Context, id string) (*types.WorkflowInvocation, error)

func (*InvocationAPI) Invoke

func (api *InvocationAPI) Invoke(ctx context.Context, spec *types.WorkflowInvocationSpec) (*types.ObjectMetadata,
	error)

func (*InvocationAPI) InvokeSync

func (api *InvocationAPI) InvokeSync(ctx context.Context, spec *types.WorkflowInvocationSpec) (*types.
	WorkflowInvocation, error)

func (*InvocationAPI) List

func (api *InvocationAPI) List(ctx context.Context) (*apiserver.WorkflowInvocationList, error)

func (*InvocationAPI) Validate

func (api *InvocationAPI) Validate(ctx context.Context, spec *types.WorkflowInvocationSpec) error

type WorkflowAPI

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

func NewWorkflowAPI

func NewWorkflowAPI(endpoint string, client http.Client) *WorkflowAPI

func (*WorkflowAPI) Create

func (api *WorkflowAPI) Create(ctx context.Context, spec *types.WorkflowSpec) (*types.ObjectMetadata, error)

func (*WorkflowAPI) CreateSync

func (api *WorkflowAPI) CreateSync(ctx context.Context, spec *types.WorkflowSpec) (*types.Workflow, error)

func (*WorkflowAPI) Delete

func (api *WorkflowAPI) Delete(ctx context.Context, id string) error

func (*WorkflowAPI) Events

func (api *WorkflowAPI) Events(ctx context.Context, id string) (*apiserver.ObjectEvents, error)

func (*WorkflowAPI) Get

func (api *WorkflowAPI) Get(ctx context.Context, id string) (*types.Workflow, error)

func (*WorkflowAPI) List

func (api *WorkflowAPI) List(ctx context.Context) (*apiserver.WorkflowList, error)