client

type Action struct {
	// the worker id
	WorkerId string

	// the tenant id
	TenantId string

	// the job id
	JobId string

	// the job name
	JobName string

	// the job run id
	JobRunId string

	// the step id
	StepId string

	// the step run id
	StepRunId string

	// the action id
	ActionId string

	// the action payload
	ActionPayload ActionPayload

	// the action type
	ActionType ActionType
}

type ActionEvent struct {
	*Action

	// the event timestamp
	EventTimestamp *time.Time

	// the step event type
	EventType ActionEventType

	// The event payload. This must be JSON-compatible as it gets marshalled to a JSON string.
	EventPayload interface{}
}

type ActionEventResponse struct {
	// the tenant id
	TenantId string

	// the id of the worker
	WorkerId string
}

type ActionEventType string

type ActionPayload func(target interface{}) error

type ActionType string

type AdminClient interface {
	PutWorkflow(workflow *types.Workflow) error
}

type Client interface {
	Admin() AdminClient
	Dispatcher() DispatcherClient
	Event() EventClient
}

type ClientOpt func(*ClientOpts)

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

type DispatcherClient interface {
	GetActionListener(ctx context.Context, req *GetActionListenerRequest) (WorkerActionListener, error)

	SendActionEvent(ctx context.Context, in *ActionEvent) (*ActionEventResponse, error)
}

type EventClient interface {
	Push(ctx context.Context, eventKey string, payload interface{}) error
}

type GetActionListenerRequest struct {
	WorkerName string
	Services   []string
	Actions    []string
}

type WorkerActionListener interface {
	Actions(ctx context.Context, errCh chan<- error) (<-chan *Action, error)

	Unregister() error
}