examplev1xns

package
v1.8.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 30, 2024 License: MIT Imports: 16 Imported by: 0

Documentation

Overview

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

protoc-gen-go_temporal 1.8.1-next (a780d91b8f008d31e60874f28b1dce86ebefabc2)
go go1.21.6
protoc (unknown)

source: example/v1/example.proto

Index

Constants

This section is empty.

Variables

This section is empty.

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 CancelExternalWorkflow 

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

CancelExternalWorkflow cancels an existing workflow

func CancelExternalWorkflowAsync 

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

CancelExternalWorkflowAsync cancels an existing workflow

func CreateFoo 

func CreateFoo(ctx workflow.Context, req *v1.CreateFooInput, opts ...*CreateFooWorkflowOptions) (*v1.CreateFooResponse, error)

CreateFoo creates a new foo operation

func CreateFooWithSetFooProgress 

func CreateFooWithSetFooProgress(ctx workflow.Context, req *v1.CreateFooInput, signal *v1.SetFooProgressRequest, opts ...*CreateFooWorkflowOptions) (*v1.CreateFooResponse, error)

CreateFoo creates a new foo operation

func GetFooProgress 

func GetFooProgress(ctx workflow.Context, workflowID string, runID string, opts ...*GetFooProgressQueryOptions) (*v1.GetFooProgressResponse, error)

GetFooProgress returns the status of a CreateFoo operation

func ProvisionFoo 

func ProvisionFoo(ctx workflow.Context, req *v1.ProvisionFooInput, opts ...*ProvisionFooWorkflowOptions) (*v1.ProvisionFooResponse, error)

ProvisionFoo executes a(n) example.v1.External.ProvisionFoo workflow and blocks until error or response received

func RegisterExampleActivities 

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

RegisterExampleActivities registers example.v1.Example cross-namespace activities

func RegisterExternalActivities 

func RegisterExternalActivities(r worker.ActivityRegistry, c v1.ExternalClient, opts ...ExternalOptions)

RegisterExternalActivities registers example.v1.External cross-namespace activities

func SetFooProgress 

func SetFooProgress(ctx workflow.Context, workflowID string, runID string, req *v1.SetFooProgressRequest, opts ...*SetFooProgressSignalOptions) error

SetFooProgress sets the current status of a CreateFoo operation

func UpdateFooProgress 

func UpdateFooProgress(ctx workflow.Context, workflowID string, runID string, req *v1.SetFooProgressRequest, opts ...*UpdateFooProgressUpdateOptions) (*v1.GetFooProgressResponse, error)

UpdateFooProgress sets the current status of a CreateFoo operation

Types

type CreateFooRun 

type CreateFooRun 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) (*v1.CreateFooResponse, error)
	// ID returns the workflow id
	ID() string
	// GetFooProgress returns the status of a CreateFoo operation
	GetFooProgress(workflow.Context, ...*GetFooProgressQueryOptions) (*v1.GetFooProgressResponse, error)
	// GetFooProgress returns the status of a CreateFoo operation
	GetFooProgressAsync(workflow.Context, ...*GetFooProgressQueryOptions) (GetFooProgressQueryHandle, error)
	// SetFooProgress sets the current status of a CreateFoo operation
	SetFooProgress(workflow.Context, *v1.SetFooProgressRequest, ...*SetFooProgressSignalOptions) error
	// SetFooProgress sets the current status of a CreateFoo operation
	SetFooProgressAsync(workflow.Context, *v1.SetFooProgressRequest, ...*SetFooProgressSignalOptions) (SetFooProgressSignalHandle, error)
	// UpdateFooProgress sets the current status of a CreateFoo operation
	UpdateFooProgress(workflow.Context, *v1.SetFooProgressRequest, ...*UpdateFooProgressUpdateOptions) (*v1.GetFooProgressResponse, error)
	// UpdateFooProgress sets the current status of a CreateFoo operation
	UpdateFooProgressAsync(workflow.Context, *v1.SetFooProgressRequest, ...*UpdateFooProgressUpdateOptions) (UpdateFooProgressHandle, error)
}

CreateFooRun provides a handle to a CreateFoo workflow execution

func CreateFooAsync 

func CreateFooAsync(ctx workflow.Context, req *v1.CreateFooInput, opts ...*CreateFooWorkflowOptions) (CreateFooRun, error)

CreateFoo creates a new foo operation

func CreateFooWithSetFooProgressAsync 

func CreateFooWithSetFooProgressAsync(ctx workflow.Context, req *v1.CreateFooInput, signal *v1.SetFooProgressRequest, opts ...*CreateFooWorkflowOptions) (CreateFooRun, error)

CreateFoo creates a new foo operation

type CreateFooWorkflowOptions 

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

CreateFooWorkflowOptions are used to configure a(n) CreateFoo workflow execution

func NewCreateFooWorkflowOptions 

func NewCreateFooWorkflowOptions() *CreateFooWorkflowOptions

NewCreateFooWorkflowOptions initializes a new CreateFooWorkflowOptions value

func (*CreateFooWorkflowOptions) WithActivityOptions 

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

WithActivityOptions can be used to customize the activity options

func (*CreateFooWorkflowOptions) WithDetached 

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

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

func (*CreateFooWorkflowOptions) WithHeartbeatInterval 

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

WithHeartbeatInterval can be used to customize the activity heartbeat interval

func (*CreateFooWorkflowOptions) WithStartWorkflow 

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

WithStartWorkflowOptions can be used to customize the start workflow options

type ExampleOptions added in v1.5.2 

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.v1.Example xns activity registration

type ExternalOptions added in v1.5.2 

type ExternalOptions 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
}

ExternalOptions is used to configure example.v1.External xns activity registration

type GetFooProgressQueryHandle 

type GetFooProgressQueryHandle 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) (*v1.GetFooProgressResponse, error)
}

GetFooProgressQueryHandle provides a handle for a GetFooProgress query activity

func GetFooProgressAsync 

func GetFooProgressAsync(ctx workflow.Context, workflowID string, runID string, opts ...*GetFooProgressQueryOptions) (GetFooProgressQueryHandle, error)

GetFooProgress returns the status of a CreateFoo operation

type GetFooProgressQueryOptions 

type GetFooProgressQueryOptions struct {
	ActivityOptions   *workflow.ActivityOptions
	HeartbeatInterval time.Duration
}

GetFooProgressQueryOptions are used to configure a(n) example.v1.Example.GetFooProgress query execution

func NewGetFooProgressQueryOptions 

func NewGetFooProgressQueryOptions() *GetFooProgressQueryOptions

NewGetFooProgressQueryOptions initializes a new GetFooProgressQueryOptions value

func (*GetFooProgressQueryOptions) WithActivityOptions 

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

WithActivityOptions can be used to customize the activity options

func (*GetFooProgressQueryOptions) WithHeartbeatInterval 

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

WithHeartbeatInterval can be used to customize the activity heartbeat interval

type ProvisionFooRun 

type ProvisionFooRun 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) (*v1.ProvisionFooResponse, error)
	// ID returns the workflow id
	ID() string
}

ProvisionFooRun provides a handle to a ProvisionFoo workflow execution

func ProvisionFooAsync 

func ProvisionFooAsync(ctx workflow.Context, req *v1.ProvisionFooInput, opts ...*ProvisionFooWorkflowOptions) (ProvisionFooRun, error)

ProvisionFooAsync executes a(n) example.v1.External.ProvisionFoo workflow and blocks until error or response received

type ProvisionFooWorkflowOptions 

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

ProvisionFooWorkflowOptions are used to configure a(n) ProvisionFoo workflow execution

func NewProvisionFooWorkflowOptions 

func NewProvisionFooWorkflowOptions() *ProvisionFooWorkflowOptions

NewProvisionFooWorkflowOptions initializes a new ProvisionFooWorkflowOptions value

func (*ProvisionFooWorkflowOptions) WithActivityOptions 

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

WithActivityOptions can be used to customize the activity options

func (*ProvisionFooWorkflowOptions) WithDetached 

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

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

func (*ProvisionFooWorkflowOptions) WithHeartbeatInterval 

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

WithHeartbeatInterval can be used to customize the activity heartbeat interval

func (*ProvisionFooWorkflowOptions) WithStartWorkflow 

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

WithStartWorkflowOptions can be used to customize the start workflow options

type SetFooProgressSignalHandle 

type SetFooProgressSignalHandle 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
}

SetFooProgressSignalHandle provides a handle for a SetFooProgress signal activity

func SetFooProgressAsync 

func SetFooProgressAsync(ctx workflow.Context, workflowID string, runID string, req *v1.SetFooProgressRequest, opts ...*SetFooProgressSignalOptions) (SetFooProgressSignalHandle, error)

SetFooProgress sets the current status of a CreateFoo operation

type SetFooProgressSignalOptions 

type SetFooProgressSignalOptions struct {
	ActivityOptions   *workflow.ActivityOptions
	HeartbeatInterval time.Duration
}

SetFooProgressSignalOptions are used to configure a(n) example.v1.Example.SetFooProgress signal execution

func NewSetFooProgressSignalOptions 

func NewSetFooProgressSignalOptions() *SetFooProgressSignalOptions

NewSetFooProgressSignalOptions initializes a new SetFooProgressSignalOptions value

func (*SetFooProgressSignalOptions) WithActivityOptions 

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

WithActivityOptions can be used to customize the activity options

func (*SetFooProgressSignalOptions) WithHeartbeatInterval 

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

WithHeartbeatInterval can be used to customize the activity heartbeat interval

type UpdateFooProgressHandle 

type UpdateFooProgressHandle interface {
	// Cancel cancels the update activity
	Cancel(workflow.Context) error
	// Future returns the inner workflow.Future
	Future() workflow.Future
	// Get blocks on update completion and returns the result
	Get(workflow.Context) (*v1.GetFooProgressResponse, error)
	// ID returns the update id
	ID() string
}

UpdateFooProgressHandle provides a handle to a UpdateFooProgress workflow update

func UpdateFooProgressAsync 

func UpdateFooProgressAsync(ctx workflow.Context, workflowID string, runID string, req *v1.SetFooProgressRequest, opts ...*UpdateFooProgressUpdateOptions) (UpdateFooProgressHandle, error)

UpdateFooProgress sets the current status of a CreateFoo operation

type UpdateFooProgressUpdateOptions 

type UpdateFooProgressUpdateOptions struct {
	ActivityOptions       *workflow.ActivityOptions
	HeartbeatInterval     time.Duration
	UpdateWorkflowOptions *client.UpdateWorkflowWithOptionsRequest
}

UpdateFooProgressUpdateOptions are used to configure a(n) UpdateFooProgress update execution

func NewUpdateFooProgressUpdateOptions 

func NewUpdateFooProgressUpdateOptions() *UpdateFooProgressUpdateOptions

NewUpdateFooProgressUpdateOptions initializes a new UpdateFooProgressUpdateOptions value

func (*UpdateFooProgressUpdateOptions) WithActivityOptions 

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

WithActivityOptions can be used to customize the activity options

func (*UpdateFooProgressUpdateOptions) WithHeartbeatInterval 

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

WithHeartbeatInterval can be used to customize the activity heartbeat interval

func (*UpdateFooProgressUpdateOptions) WithUpdateWorkflowOptions 

func (opts *UpdateFooProgressUpdateOptions) WithUpdateWorkflowOptions(uwo client.UpdateWorkflowWithOptionsRequest) *UpdateFooProgressUpdateOptions

WithUpdateWorkflowOptions can be used to customize the update workflow options

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.