searchattributesv1xns

Documentation

Overview

Code generated by protoc-gen-go_temporal. DO NOT EDIT. versions:

protoc-gen-go_temporal 1.10.2-next (0b994cbcb4a60e84ee2566d444a20428b160f204)
go go1.22.1
protoc (unknown)

source: example/searchattributes/v1/searchattributes.proto

Index

• func CancelExampleWorkflow(ctx workflow.Context, workflowID string, runID string) error
• func CancelExampleWorkflowAsync(ctx workflow.Context, workflowID string, runID string) workflow.Future
• func RegisterExampleActivities(r worker.ActivityRegistry, c v1.ExampleClient, opts ...ExampleOptions)
• func SearchAttributes(ctx workflow.Context, req *v1.SearchAttributesInput, ...) error
• type ExampleOptions
• type SearchAttributesRun
  • func SearchAttributesAsync(ctx workflow.Context, req *v1.SearchAttributesInput, ...) (SearchAttributesRun, error)
• type SearchAttributesWorkflowOptions
  • func NewSearchAttributesWorkflowOptions() *SearchAttributesWorkflowOptions
  • func (opts *SearchAttributesWorkflowOptions) WithActivityOptions(ao workflow.ActivityOptions) *SearchAttributesWorkflowOptions
  • func (opts *SearchAttributesWorkflowOptions) WithDetached(d bool) *SearchAttributesWorkflowOptions
  • func (opts *SearchAttributesWorkflowOptions) WithHeartbeatInterval(d time.Duration) *SearchAttributesWorkflowOptions
  • func (opts *SearchAttributesWorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *SearchAttributesWorkflowOptions

Functions

func CancelExampleWorkflow

func CancelExampleWorkflow(ctx workflow.Context, workflowID string, runID string) error

CancelExampleWorkflow cancels an existing workflow

func CancelExampleWorkflowAsync

func CancelExampleWorkflowAsync(ctx workflow.Context, workflowID string, runID string) workflow.Future

CancelExampleWorkflowAsync cancels an existing workflow

func RegisterExampleActivities

func RegisterExampleActivities(r worker.ActivityRegistry, c v1.ExampleClient, opts ...ExampleOptions)

RegisterExampleActivities registers example.searchattributes.v1.Example cross-namespace activities

func SearchAttributes

func SearchAttributes(ctx workflow.Context, req *v1.SearchAttributesInput, opts ...*SearchAttributesWorkflowOptions) error

SearchAttributes executes a(n) example.searchattributes.v1.Example.SearchAttributes workflow and blocks until error or response received

Types

type ExampleOptions

type ExampleOptions struct {
	// Filter is used to filter xns activity registrations. It receives as
	// input the original activity name, and should return one of the following:
	// 1. the original activity name, for no changes
	// 2. a modified activity name, to override the original activity name
	// 3. an empty string, to skip registration
	Filter func(string) string
}

ExampleOptions is used to configure example.searchattributes.v1.Example xns activity registration

type SearchAttributesRun

type SearchAttributesRun interface {
	// Cancel cancels the workflow
	Cancel(workflow.Context) error

	// Future returns the inner workflow.Future
	Future() workflow.Future

	// Get returns the inner workflow.Future
	Get(workflow.Context) error

	// ID returns the workflow id
	ID() string
}

SearchAttributesRun provides a handle to a example.searchattributes.v1.Example.SearchAttributes workflow execution

func SearchAttributesAsync

func SearchAttributesAsync(ctx workflow.Context, req *v1.SearchAttributesInput, opts ...*SearchAttributesWorkflowOptions) (SearchAttributesRun, error)

SearchAttributesAsync executes a(n) example.searchattributes.v1.Example.SearchAttributes workflow and blocks until error or response received

type SearchAttributesWorkflowOptions

type SearchAttributesWorkflowOptions struct {
	ActivityOptions      *workflow.ActivityOptions
	Detached             bool
	HeartbeatInterval    time.Duration
	StartWorkflowOptions *client.StartWorkflowOptions
}

SearchAttributesWorkflowOptions are used to configure a(n) example.searchattributes.v1.Example.SearchAttributes workflow execution

func NewSearchAttributesWorkflowOptions

func NewSearchAttributesWorkflowOptions() *SearchAttributesWorkflowOptions

NewSearchAttributesWorkflowOptions initializes a new SearchAttributesWorkflowOptions value

func (*SearchAttributesWorkflowOptions) WithActivityOptions

func (opts *SearchAttributesWorkflowOptions) WithActivityOptions(ao workflow.ActivityOptions) *SearchAttributesWorkflowOptions

WithActivityOptions can be used to customize the activity options

func (*SearchAttributesWorkflowOptions) WithDetached

func (opts *SearchAttributesWorkflowOptions) WithDetached(d bool) *SearchAttributesWorkflowOptions

WithDetached can be used to start a workflow execution and exit immediately

func (*SearchAttributesWorkflowOptions) WithHeartbeatInterval

func (opts *SearchAttributesWorkflowOptions) WithHeartbeatInterval(d time.Duration) *SearchAttributesWorkflowOptions

WithHeartbeatInterval can be used to customize the activity heartbeat interval

func (*SearchAttributesWorkflowOptions) WithStartWorkflow

func (opts *SearchAttributesWorkflowOptions) WithStartWorkflow(swo client.StartWorkflowOptions) *SearchAttributesWorkflowOptions

WithStartWorkflowOptions can be used to customize the start workflow options