Documentation
¶
Overview ¶
Package temporalpayloadruntime owns the sole runtime Temporal client and worker converter factory.
Index ¶
- type Client
- func (client *Client) Close()
- func (client *Client) ExecuteWorkflow(ctx context.Context, options client.StartWorkflowOptions, workflow any, ...) (client.WorkflowRun, error)
- func (owned *Client) SignalWithStartWorkflow(ctx context.Context, workflowID, signal string, argument any, ...) (client.WorkflowRun, error)
- func (client *Client) SignalWorkflow(ctx context.Context, workflowID, runID, signal string, argument any) error
- func (owned *Client) WorkflowHistory(ctx context.Context, workflowID, runID string) (*historypb.History, error)
- type Factory
- type S3Config
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client is a Temporal client created by Factory with the runtime-owned converter.
func (*Client) ExecuteWorkflow ¶
func (client *Client) ExecuteWorkflow(ctx context.Context, options client.StartWorkflowOptions, workflow any, arguments ...any) (client.WorkflowRun, error)
ExecuteWorkflow starts one private runtime workflow through the configured client.
func (*Client) SignalWithStartWorkflow ¶
func (owned *Client) SignalWithStartWorkflow(ctx context.Context, workflowID, signal string, argument any, options client.StartWorkflowOptions, workflow any, arguments ...any) (client.WorkflowRun, error)
SignalWithStartWorkflow atomically reaches an existing private workflow or starts it through the runtime-owned converter before delivering the signal.
type Factory ¶
type Factory struct {
// contains filtered or unexported fields
}
Factory applies one local temporalpayload codec to every runtime-owned Temporal client and worker.
func NewFactory ¶
func NewFactory(codec *temporalpayload.Codec) (*Factory, error)
NewFactory creates the only runtime-owned factory for Temporal converter configuration.
func NewS3Factory ¶
NewS3Factory creates the one owned codec/factory from the worker's separate temporal-payload bucket capability. Application code receives only Factory.
func (*Factory) NewClient ¶
NewClient checks retained compatibility before creating a runtime-owned Temporal client.
func (*Factory) NewWorker ¶
func (factory *Factory) NewWorker(temporalClient *Client, taskQueue string, options worker.Options) (worker.Worker, error)
NewWorker creates a runtime worker from a checked runtime-owned client.
The Temporal Go SDK takes the DataConverter from its client, not from worker.Options. Keeping worker creation beside NewClient prevents a second raw client/worker composition seam from appearing in runtime code.
func (*Factory) NewWorkflowReplayer ¶
func (factory *Factory) NewWorkflowReplayer() (worker.WorkflowReplayer, error)
NewWorkflowReplayer applies the exact owned converter to historic workflow replay so codec indirection cannot be bypassed in retained evidence.
Source Files