ingress

Documentation

Index

• type Client
  • func NewClient(baseUri string, opts ...options.IngressClientOption) *Client
• type Invocation
• type InvocationHandle
  • func AttachInvocation[O any](c *Client, invocationID string) InvocationHandle[O]
  • func AttachObject[O any](c *Client, serviceName, objectKey, handlerName, idempotencyKey string) InvocationHandle[O]
  • func AttachService[O any](c *Client, serviceName, handlerName, idempotencyKey string) InvocationHandle[O]
  • func AttachWorkflow[O any](c *Client, serviceName, workflowID string) InvocationHandle[O]
• type InvocationNotFoundError
• type InvocationNotReadyError
• type Requester
  • func Object[I any, O any](c *Client, serviceName, objectKey, handlerName string) Requester[I, O]
  • func Service[I any, O any](c *Client, serviceName, handlerName string) Requester[I, O]
  • func Workflow[I any, O any](c *Client, serviceName, workflowID, handlerName string) Requester[I, O]
• type SendRequester
  • func ObjectSend[I any](c *Client, serviceName, objectKey, handlerName string) SendRequester[I]
  • func ServiceSend[I any](c *Client, serviceName, handlerName string) SendRequester[I]
  • func WorkflowSend[I any](c *Client, serviceName, workflowID, handlerName string) SendRequester[I]

Types

type Client

type Client = ingress.Client

func NewClient

func NewClient(baseUri string, opts ...options.IngressClientOption) *Client

type Invocation

type Invocation = ingress.Invocation

type InvocationHandle

type InvocationHandle[O any] interface {
	Attach(ctx context.Context) (O, error)
	Output(ctx context.Context) (O, error)
}

func AttachInvocation

func AttachInvocation[O any](c *Client, invocationID string) InvocationHandle[O]

AttachInvocation gets an attachment client based on an invocation ID.

func AttachObject

func AttachObject[O any](c *Client, serviceName, objectKey, handlerName, idempotencyKey string) InvocationHandle[O]

AttachObject gets an attachment client based on a service handler, object key and idempotency key.

func AttachService

func AttachService[O any](c *Client, serviceName, handlerName, idempotencyKey string) InvocationHandle[O]

AttachService gets an attachment client based on a service handler and idempotency key.

func AttachWorkflow

func AttachWorkflow[O any](c *Client, serviceName, workflowID string) InvocationHandle[O]

AttachWorkflow gets and attachment client based on a service and a workflow ID.

type InvocationNotFoundError

type InvocationNotFoundError = ingress.InvocationNotFoundError

type InvocationNotReadyError

type InvocationNotReadyError = ingress.InvocationNotReadyError

type Requester

type Requester[I any, O any] interface {
	Request(ctx context.Context, input I, options ...options.IngressRequestOption) (O, error)
	SendRequester[I]
}

func Object

func Object[I any, O any](c *Client, serviceName, objectKey, handlerName string) Requester[I, O]

Object gets an Object request ingress client by service name, key and handlerName name

func Service

func Service[I any, O any](c *Client, serviceName, handlerName string) Requester[I, O]

Service gets a Service request ingress client by service and handlerName name

func Workflow

func Workflow[I any, O any](c *Client, serviceName, workflowID, handlerName string) Requester[I, O]

Workflow gets a Workflow request ingress client by service name, workflow ID and handlerName name

type SendRequester

type SendRequester[I any] interface {
	Send(ctx context.Context, input I, options ...options.IngressSendOption) Invocation
}

func ObjectSend

func ObjectSend[I any](c *Client, serviceName, objectKey, handlerName string) SendRequester[I]

ObjectSend gets an Object send ingress client by service name, key and handlerName name

func ServiceSend

func ServiceSend[I any](c *Client, serviceName, handlerName string) SendRequester[I]

ServiceSend gets a Service send ingress client by service and handlerName name

func WorkflowSend

func WorkflowSend[I any](c *Client, serviceName, workflowID, handlerName string) SendRequester[I]

WorkflowSend gets a Workflow send ingress client by service name, workflow ID and handlerName name