clientutil

Documentation

Index

• type CallResponseHandler
  • func NewCallResponseHandler(opts CallResponseHandlerOptions) (*CallResponseHandler, error)
  • func (c *CallResponseHandler) AddResponseType(activityName string, typ reflect.Type, idField string) error
  • func (c *CallResponseHandler) Call(ctx context.Context, cl client.Client, workflowID string, runID string, ...) (interface{}, error)
  • func (c *CallResponseHandler) PrepareCall(ctx context.Context) (id string, chOk <-chan interface{}, chErr <-chan error)
  • func (c *CallResponseHandler) TaskQueue() string
• type CallResponseHandlerOptions

Types

type CallResponseHandler

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

func NewCallResponseHandler

func NewCallResponseHandler(opts CallResponseHandlerOptions) (*CallResponseHandler, error)

func (*CallResponseHandler) AddResponseType

func (c *CallResponseHandler) AddResponseType(activityName string, typ reflect.Type, idField string) error

func (*CallResponseHandler) Call

func (c *CallResponseHandler) Call(
	ctx context.Context,
	cl client.Client,
	workflowID string,
	runID string,
	signalName string,
	newReq func(id string) interface{},
) (interface{}, error)

func (*CallResponseHandler) PrepareCall

func (c *CallResponseHandler) PrepareCall(ctx context.Context) (id string, chOk <-chan interface{}, chErr <-chan error)

func (*CallResponseHandler) TaskQueue

func (c *CallResponseHandler) TaskQueue() string

type CallResponseHandlerOptions

type CallResponseHandlerOptions struct {
	TaskQueue string
	Worker    worker.Worker
}