ingress

Documentation

Index

• type Client
  • func NewClient(baseUri string, opts options.IngressClientOptions) *Client
  • func (c *Client) Attach(ctx context.Context, params IngressAttachParams, output any, ...) error
  • func (c *Client) Output(ctx context.Context, params IngressAttachParams, output any, ...) error
  • func (c *Client) Request(ctx context.Context, params IngressParams, input, output any, ...) error
  • func (c *Client) Send(ctx context.Context, params IngressParams, input any, ...) (Invocation, error)
• type GenericError
  • func (e GenericError) Error() string
• type IngressAttachParams
• type IngressParams
• type Invocation
• type InvocationNotFoundError
  • func (e InvocationNotFoundError) Error() string
• type InvocationNotReadyError
  • func (e InvocationNotReadyError) Error() string

Types

type Client

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

Client is an ingress client used to initiate Restate invocations outside a Restate context.

func NewClient

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

func (*Client) Attach

func (c *Client) Attach(ctx context.Context, params IngressAttachParams, output any, attachOpts options.IngressInvocationHandleOptions) error

func (*Client) Output

func (c *Client) Output(ctx context.Context, params IngressAttachParams, output any, outputOpts options.IngressInvocationHandleOptions) error

func (*Client) Request

func (c *Client) Request(ctx context.Context, params IngressParams, input, output any, reqOpts options.IngressRequestOptions) error

func (*Client) Send

func (c *Client) Send(ctx context.Context, params IngressParams, input any, sendOpts options.IngressSendOptions) (Invocation, error)

type GenericError

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

func (GenericError) Error

func (e GenericError) Error() string

type IngressAttachParams

type IngressAttachParams struct {
	ServiceName    string
	MethodName     string
	ObjectKey      string
	InvocationID   string
	IdempotencyKey string
	WorkflowID     string
}

type IngressParams

type IngressParams struct {
	Service string
	Handler string
	Key     string
}

type Invocation

type Invocation struct {
	Id     string `json:"invocationId"`
	Status string `json:"status"`
}

type InvocationNotFoundError

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

func (InvocationNotFoundError) Error

func (e InvocationNotFoundError) Error() string

type InvocationNotReadyError

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

func (InvocationNotReadyError) Error

func (e InvocationNotReadyError) Error() string