examplev1

package
v0.0.10 Latest Latest
Warning

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

 Go to latest Published: Jan 29, 2025 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	DefaultDieRollTaskQueueName = "service-task-queue"
	// Default activity schedule to close timeout if none is specified (24h0m0s)
	DefaultDieRollActivityScheduleToCloseTimeout = 86400

	// Name of workflow example.v1.DieRoll.ParentWorkflow
	WorkflowDieRollParentWorkflowName = "example.v1.DieRoll.ParentWorkflow"
	// Name of workflow example.v1.DieRoll.ChildWorkflow
	WorkflowDieRollChildWorkflowName = "example.v1.DieRoll.ChildWorkflow"
	// Name of workflow example.v1.DieRoll.ThrowDies
	WorkflowDieRollThrowDiesName = "example.v1.DieRoll.ThrowDies"
	// Name of workflow example.v1.DieRoll.ThrowUntilValue
	WorkflowDieRollThrowUntilValueName = "example.v1.DieRoll.ThrowUntilValue"

	// Name of activity example.v1.DieRoll.ThrowDie
	ActivityDieRollThrowDieName = "example.v1.DieRoll.ThrowDie"
	// Name of activity example.v1.DieRoll.Ping
	ActivityDieRollPingName = "ping.Ping"

	// Name of signal example.v1.DieRoll.Continue
	SignalDieRollContinueName = "example.v1.DieRoll.Continue"

	// Name of query example.v1.DieRoll.GetThrowsStatus
	QueryDieRollGetThrowsStatusName = "example.v1.DieRoll.GetThrowsStatus"
)

Variables

View Source 
var (
	Status_name = map[int32]string{
		0: "UNDEFINED",
		1: "SUCCESS",
		2: "FAILURE",
	}
	Status_value = map[string]int32{
		"UNDEFINED": 0,
		"SUCCESS":   1,
		"FAILURE":   2,
	}
)

Enum value maps for Status.

View Source 
var File_example_v1_example_proto protoreflect.FileDescriptor

Functions

func HandleQueryGetThrowsStatus added in v0.0.4 

func HandleQueryGetThrowsStatus(ctx workflow.Context, queryFunc func(req *emptypb.Empty) (*ThrowStatusResponse, error)) error

HandleQueryGetThrowsStatus sets up the GetThrowsStatus query and responds accordingly, returns an error if it failed

Types

type ChildDieRollChildWorkflowExecution added in v0.0.6 

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

ChildDieRollChildWorkflowExecution is a struct that wraps a workflow execution (called from another workflow)

func (*ChildDieRollChildWorkflowExecution) Get added in v0.0.6 

func (w *ChildDieRollChildWorkflowExecution) Get(ctx workflow.Context, valuePtr interface{}) error

Get gets the result of a given workflow with pointers -- discouraged to use but required to implement internal.Future

func (*ChildDieRollChildWorkflowExecution) GetChildWorkflowExecution added in v0.0.6 

func (w *ChildDieRollChildWorkflowExecution) GetChildWorkflowExecution() (ctx workflow.Future)

Wraps the GetChildWorkflowExecution and returns an workflow.Future

func (*ChildDieRollChildWorkflowExecution) IsReady added in v0.0.6 

func (w *ChildDieRollChildWorkflowExecution) IsReady() bool

Wraps the IsReady method from the future

func (*ChildDieRollChildWorkflowExecution) Result added in v0.0.6 

func (w *ChildDieRollChildWorkflowExecution) Result(ctx workflow.Context) (*emptypb.Empty, error)

Get gets the result of a given workflow with its native type

func (*ChildDieRollChildWorkflowExecution) SignalChildWorkflow added in v0.0.6 

func (w *ChildDieRollChildWorkflowExecution) SignalChildWorkflow(ctx workflow.Context, sigName string, data interface{}) workflow.Future

Signals the child workflow with a generic signal -- discouraged to use but required to implement internal.Future

type ChildDieRollParentWorkflowExecution added in v0.0.6 

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

ChildDieRollParentWorkflowExecution is a struct that wraps a workflow execution (called from another workflow)

func (*ChildDieRollParentWorkflowExecution) Get added in v0.0.6 

func (w *ChildDieRollParentWorkflowExecution) Get(ctx workflow.Context, valuePtr interface{}) error

Get gets the result of a given workflow with pointers -- discouraged to use but required to implement internal.Future

func (*ChildDieRollParentWorkflowExecution) GetChildWorkflowExecution added in v0.0.6 

func (w *ChildDieRollParentWorkflowExecution) GetChildWorkflowExecution() (ctx workflow.Future)

Wraps the GetChildWorkflowExecution and returns an workflow.Future

func (*ChildDieRollParentWorkflowExecution) IsReady added in v0.0.6 

func (w *ChildDieRollParentWorkflowExecution) IsReady() bool

Wraps the IsReady method from the future

func (*ChildDieRollParentWorkflowExecution) Result added in v0.0.6 

func (w *ChildDieRollParentWorkflowExecution) Result(ctx workflow.Context) (*ParentWorkflowReply, error)

Get gets the result of a given workflow with its native type

func (*ChildDieRollParentWorkflowExecution) SignalChildWorkflow added in v0.0.6 

func (w *ChildDieRollParentWorkflowExecution) SignalChildWorkflow(ctx workflow.Context, sigName string, data interface{}) workflow.Future

Signals the child workflow with a generic signal -- discouraged to use but required to implement internal.Future

func (*ChildDieRollParentWorkflowExecution) SignalContinue added in v0.0.7 

func (w *ChildDieRollParentWorkflowExecution) SignalContinue(ctx workflow.Context, req *ContinueSignalRequest) error

SignalContinue sends the Continue signal to the workflow

type ChildDieRollThrowDiesExecution added in v0.0.4 

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

ChildDieRollThrowDiesExecution is a struct that wraps a workflow execution (called from another workflow)

func (*ChildDieRollThrowDiesExecution) Get added in v0.0.4 

func (w *ChildDieRollThrowDiesExecution) Get(ctx workflow.Context, valuePtr interface{}) error

Get gets the result of a given workflow with pointers -- discouraged to use but required to implement internal.Future

func (*ChildDieRollThrowDiesExecution) GetChildWorkflowExecution added in v0.0.4 

func (w *ChildDieRollThrowDiesExecution) GetChildWorkflowExecution() (ctx workflow.Future)

Wraps the GetChildWorkflowExecution and returns an workflow.Future

func (*ChildDieRollThrowDiesExecution) IsReady added in v0.0.4 

func (w *ChildDieRollThrowDiesExecution) IsReady() bool

Wraps the IsReady method from the future

func (*ChildDieRollThrowDiesExecution) Result added in v0.0.4 

func (w *ChildDieRollThrowDiesExecution) Result(ctx workflow.Context) (*ThrowDiesResponse, error)

Get gets the result of a given workflow with its native type

func (*ChildDieRollThrowDiesExecution) SignalChildWorkflow added in v0.0.4 

func (w *ChildDieRollThrowDiesExecution) SignalChildWorkflow(ctx workflow.Context, sigName string, data interface{}) workflow.Future

Signals the child workflow with a generic signal -- discouraged to use but required to implement internal.Future

func (*ChildDieRollThrowDiesExecution) SignalContinue added in v0.0.4 

func (w *ChildDieRollThrowDiesExecution) SignalContinue(ctx workflow.Context, req *ContinueSignalRequest) error

SignalContinue sends the Continue signal to the workflow

type ChildDieRollThrowUntilValueExecution added in v0.0.4 

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

ChildDieRollThrowUntilValueExecution is a struct that wraps a workflow execution (called from another workflow)

func (*ChildDieRollThrowUntilValueExecution) Get added in v0.0.4 

func (w *ChildDieRollThrowUntilValueExecution) Get(ctx workflow.Context, valuePtr interface{}) error

Get gets the result of a given workflow with pointers -- discouraged to use but required to implement internal.Future

func (*ChildDieRollThrowUntilValueExecution) GetChildWorkflowExecution added in v0.0.4 

func (w *ChildDieRollThrowUntilValueExecution) GetChildWorkflowExecution() (ctx workflow.Future)

Wraps the GetChildWorkflowExecution and returns an workflow.Future

func (*ChildDieRollThrowUntilValueExecution) IsReady added in v0.0.4 

func (w *ChildDieRollThrowUntilValueExecution) IsReady() bool

Wraps the IsReady method from the future

func (*ChildDieRollThrowUntilValueExecution) Result added in v0.0.4 

func (w *ChildDieRollThrowUntilValueExecution) Result(ctx workflow.Context) (*emptypb.Empty, error)

Get gets the result of a given workflow with its native type

func (*ChildDieRollThrowUntilValueExecution) SignalChildWorkflow added in v0.0.4 

func (w *ChildDieRollThrowUntilValueExecution) SignalChildWorkflow(ctx workflow.Context, sigName string, data interface{}) workflow.Future

Signals the child workflow with a generic signal -- discouraged to use but required to implement internal.Future

type ContinueSignalRequest added in v0.0.4 

type ContinueSignalRequest struct {
	Continue bool `protobuf:"varint,1,opt,name=continue,proto3" json:"continue,omitempty"`
	// contains filtered or unexported fields
}

func ReceiveSignalContinue added in v0.0.4 

func ReceiveSignalContinue(ctx workflow.Context) (*ContinueSignalRequest, bool)

ReceiveSignalContinue waits for the the Continue signal

func ReceiveSignalContinueAsync added in v0.0.4 

func ReceiveSignalContinueAsync(ctx workflow.Context) (*ContinueSignalRequest, bool)

ReceiveSignalContinueAsync recieves the the Continue signal asynchronously. It doesn't wait if there is no signal in the queue

func (*ContinueSignalRequest) Descriptor deprecated added in v0.0.4 

func (*ContinueSignalRequest) Descriptor() ([]byte, []int)

Deprecated: Use ContinueSignalRequest.ProtoReflect.Descriptor instead.

func (*ContinueSignalRequest) GetContinue added in v0.0.4 

func (x *ContinueSignalRequest) GetContinue() bool

func (*ContinueSignalRequest) ProtoMessage added in v0.0.4 

func (*ContinueSignalRequest) ProtoMessage()

func (*ContinueSignalRequest) ProtoReflect added in v0.0.4 

func (x *ContinueSignalRequest) ProtoReflect() protoreflect.Message

func (*ContinueSignalRequest) Reset added in v0.0.4 

func (x *ContinueSignalRequest) Reset()

func (*ContinueSignalRequest) String added in v0.0.4 

func (x *ContinueSignalRequest) String() string

type DieRollChildWorkflow added in v0.0.6 

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

DieRollChildWorkflow is a struct that wraps a workflow

func (*DieRollChildWorkflow) Cancel added in v0.0.6 

func (w *DieRollChildWorkflow) Cancel(ctx context.Context) error

Cancel cancels a given workflow

func (*DieRollChildWorkflow) Get added in v0.0.6 

func (w *DieRollChildWorkflow) Get(ctx context.Context, valuePtr interface{}) error

Get gets the result of a given workflow with pointers -- discouraged to use but required to implement internal.WorkflowRun

func (*DieRollChildWorkflow) GetID added in v0.0.6 

func (w *DieRollChildWorkflow) GetID() string

Returns the workflow ID

func (*DieRollChildWorkflow) GetRunID added in v0.0.6 

func (w *DieRollChildWorkflow) GetRunID() string

Returns the run ID

func (*DieRollChildWorkflow) GetWithOptions added in v0.0.6 

func (w *DieRollChildWorkflow) GetWithOptions(ctx context.Context, valuePtr interface{}, options client.WorkflowRunGetOptions) error

Get gets the result of a given workflow with pointers -- discouraged to use but required to implement internal.WorkflowRun

func (*DieRollChildWorkflow) Result added in v0.0.6 

func (w *DieRollChildWorkflow) Result(ctx context.Context) (*emptypb.Empty, error)

Get gets the result of a given workflow with its native type

func (*DieRollChildWorkflow) ResultWithOptions added in v0.0.6 

func (w *DieRollChildWorkflow) ResultWithOptions(ctx context.Context, options client.WorkflowRunGetOptions) (*emptypb.Empty, error)

ResultWithOptions gets the result of a given workflow with its native type

func (*DieRollChildWorkflow) Terminate added in v0.0.6 

func (w *DieRollChildWorkflow) Terminate(ctx context.Context, reason string, details ...interface{}) error

Terminates terminates a given workflow

type DieRollClient added in v0.0.4 

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

DieRollClient: Client for the DieRoll service

func NewDieRollClient added in v0.0.4 

func NewDieRollClient(client client.Client, taskQueue ...string) (*DieRollClient, error)

NewDieRollClient: Returns a new instance of the client. If `taskQueue` stays empty the default one will be used

func (*DieRollClient) ExecuteActivityPing added in v0.0.4 

func (c *DieRollClient) ExecuteActivityPing(ctx workflow.Context, req *emptypb.Empty, options ...workflow.ActivityOptions) workflow.Future

ExecuteActivityPing executes the activity asynchronously and returns a future to it

func (*DieRollClient) ExecuteActivityPingSync added in v0.0.4 

func (c *DieRollClient) ExecuteActivityPingSync(ctx workflow.Context, req *emptypb.Empty, options ...workflow.ActivityOptions) (*emptypb.Empty, error)

ExecuteActivityPingSync executes the activity synchronously and returns the result when finished

func (*DieRollClient) ExecuteActivityThrowDie added in v0.0.4 

func (c *DieRollClient) ExecuteActivityThrowDie(ctx workflow.Context, req *emptypb.Empty, options ...workflow.ActivityOptions) workflow.Future

ExecuteActivityThrowDie executes the activity asynchronously and returns a future to it

func (*DieRollClient) ExecuteActivityThrowDieSync added in v0.0.4 

func (c *DieRollClient) ExecuteActivityThrowDieSync(ctx workflow.Context, req *emptypb.Empty, options ...workflow.ActivityOptions) (*ThrowDieResponse, error)

ExecuteActivityThrowDieSync executes the activity synchronously and returns the result when finished

func (*DieRollClient) ExecuteChildChildWorkflow added in v0.0.6 

func (c *DieRollClient) ExecuteChildChildWorkflow(ctx workflow.Context, req *emptypb.Empty, options ...workflow.ChildWorkflowOptions) (workflow.ChildWorkflowFuture, error)

ExecuteChildChildWorkflow executes the workflow as a child workflow and returns a future to it

func (*DieRollClient) ExecuteChildChildWorkflowSync added in v0.0.6 

func (c *DieRollClient) ExecuteChildChildWorkflowSync(ctx workflow.Context, req *emptypb.Empty, options ...workflow.ChildWorkflowOptions) (*emptypb.Empty, error)

ExecuteChildChildWorkflowSync executes the workflow as a child workflow and returns the result when finished

func (*DieRollClient) ExecuteChildParentWorkflow added in v0.0.6 

func (c *DieRollClient) ExecuteChildParentWorkflow(ctx workflow.Context, req *emptypb.Empty, options ...workflow.ChildWorkflowOptions) (workflow.ChildWorkflowFuture, error)

ExecuteChildParentWorkflow executes the workflow as a child workflow and returns a future to it

func (*DieRollClient) ExecuteChildParentWorkflowSync added in v0.0.6 

func (c *DieRollClient) ExecuteChildParentWorkflowSync(ctx workflow.Context, req *emptypb.Empty, options ...workflow.ChildWorkflowOptions) (*ParentWorkflowReply, error)

ExecuteChildParentWorkflowSync executes the workflow as a child workflow and returns the result when finished

func (*DieRollClient) ExecuteChildThrowDies added in v0.0.4 

func (c *DieRollClient) ExecuteChildThrowDies(ctx workflow.Context, req *ThrowDiesRequest, options ...workflow.ChildWorkflowOptions) (workflow.ChildWorkflowFuture, error)

ExecuteChildThrowDies executes the workflow as a child workflow and returns a future to it

func (*DieRollClient) ExecuteChildThrowDiesSync added in v0.0.4 

func (c *DieRollClient) ExecuteChildThrowDiesSync(ctx workflow.Context, req *ThrowDiesRequest, options ...workflow.ChildWorkflowOptions) (*ThrowDiesResponse, error)

ExecuteChildThrowDiesSync executes the workflow as a child workflow and returns the result when finished

func (*DieRollClient) ExecuteChildThrowUntilValue added in v0.0.4 

func (c *DieRollClient) ExecuteChildThrowUntilValue(ctx workflow.Context, req *ThrowUntilValueRequest, options ...workflow.ChildWorkflowOptions) (workflow.ChildWorkflowFuture, error)

ExecuteChildThrowUntilValue executes the workflow as a child workflow and returns a future to it

func (*DieRollClient) ExecuteChildThrowUntilValueSync added in v0.0.4 

func (c *DieRollClient) ExecuteChildThrowUntilValueSync(ctx workflow.Context, req *ThrowUntilValueRequest, options ...workflow.ChildWorkflowOptions) (*emptypb.Empty, error)

ExecuteChildThrowUntilValueSync executes the workflow as a child workflow and returns the result when finished

func (*DieRollClient) ExecuteWorkflowChildWorkflow added in v0.0.6 

func (c *DieRollClient) ExecuteWorkflowChildWorkflow(ctx context.Context, req *emptypb.Empty, options ...client.StartWorkflowOptions) (client.WorkflowRun, error)

ExecuteWorkflowChildWorkflow executes the workflow and returns a future to it

func (*DieRollClient) ExecuteWorkflowChildWorkflowSync added in v0.0.6 

func (c *DieRollClient) ExecuteWorkflowChildWorkflowSync(ctx context.Context, req *emptypb.Empty, options ...client.StartWorkflowOptions) (*emptypb.Empty, error)

ExecuteWorkflowChildWorkflowSync executes the workflow and returns the result when finished

func (*DieRollClient) ExecuteWorkflowParentWorkflow added in v0.0.6 

func (c *DieRollClient) ExecuteWorkflowParentWorkflow(ctx context.Context, req *emptypb.Empty, options ...client.StartWorkflowOptions) (client.WorkflowRun, error)

ExecuteWorkflowParentWorkflow executes the workflow and returns a future to it

func (*DieRollClient) ExecuteWorkflowParentWorkflowSync added in v0.0.6 

func (c *DieRollClient) ExecuteWorkflowParentWorkflowSync(ctx context.Context, req *emptypb.Empty, options ...client.StartWorkflowOptions) (*ParentWorkflowReply, error)

ExecuteWorkflowParentWorkflowSync executes the workflow and returns the result when finished

func (*DieRollClient) ExecuteWorkflowThrowDies added in v0.0.4 

func (c *DieRollClient) ExecuteWorkflowThrowDies(ctx context.Context, req *ThrowDiesRequest, options ...client.StartWorkflowOptions) (client.WorkflowRun, error)

ExecuteWorkflowThrowDies executes the workflow and returns a future to it

func (*DieRollClient) ExecuteWorkflowThrowDiesSync added in v0.0.4 

func (c *DieRollClient) ExecuteWorkflowThrowDiesSync(ctx context.Context, req *ThrowDiesRequest, options ...client.StartWorkflowOptions) (*ThrowDiesResponse, error)

ExecuteWorkflowThrowDiesSync executes the workflow and returns the result when finished

func (*DieRollClient) ExecuteWorkflowThrowUntilValue added in v0.0.4 

func (c *DieRollClient) ExecuteWorkflowThrowUntilValue(ctx context.Context, req *ThrowUntilValueRequest, options ...client.StartWorkflowOptions) (client.WorkflowRun, error)

ExecuteWorkflowThrowUntilValue executes the workflow and returns a future to it

func (*DieRollClient) ExecuteWorkflowThrowUntilValueSync added in v0.0.4 

func (c *DieRollClient) ExecuteWorkflowThrowUntilValueSync(ctx context.Context, req *ThrowUntilValueRequest, options ...client.StartWorkflowOptions) (*emptypb.Empty, error)

ExecuteWorkflowThrowUntilValueSync executes the workflow and returns the result when finished

func (*DieRollClient) GetChildDieRollChildWorkflowExecution added in v0.0.6 

func (c *DieRollClient) GetChildDieRollChildWorkflowExecution(future workflow.ChildWorkflowFuture) *ChildDieRollChildWorkflowExecution

GetChildDieRollChildWorkflowExecution gets an instance of a given workflow from a future

func (*DieRollClient) GetChildDieRollParentWorkflowExecution added in v0.0.6 

func (c *DieRollClient) GetChildDieRollParentWorkflowExecution(future workflow.ChildWorkflowFuture) *ChildDieRollParentWorkflowExecution

GetChildDieRollParentWorkflowExecution gets an instance of a given workflow from a future

func (*DieRollClient) GetChildDieRollThrowDiesExecution added in v0.0.4 

func (c *DieRollClient) GetChildDieRollThrowDiesExecution(future workflow.ChildWorkflowFuture) *ChildDieRollThrowDiesExecution

GetChildDieRollThrowDiesExecution gets an instance of a given workflow from a future

func (*DieRollClient) GetChildDieRollThrowUntilValueExecution added in v0.0.4 

func (c *DieRollClient) GetChildDieRollThrowUntilValueExecution(future workflow.ChildWorkflowFuture) *ChildDieRollThrowUntilValueExecution

GetChildDieRollThrowUntilValueExecution gets an instance of a given workflow from a future

func (*DieRollClient) GetChildWorkflow added in v0.0.6 

func (c *DieRollClient) GetChildWorkflow(ctx context.Context, workflowId string, runId string) *DieRollChildWorkflow

GetChildWorkflow gets an instance of a given workflow

func (*DieRollClient) GetChildWorkflowFromRun added in v0.0.6 

func (c *DieRollClient) GetChildWorkflowFromRun(future client.WorkflowRun) *DieRollChildWorkflow

GetChildWorkflowFromRun gets an instance of a given workflow from a future

func (*DieRollClient) GetParentWorkflow added in v0.0.6 

func (c *DieRollClient) GetParentWorkflow(ctx context.Context, workflowId string, runId string) *DieRollParentWorkflow

GetParentWorkflow gets an instance of a given workflow

func (*DieRollClient) GetParentWorkflowFromRun added in v0.0.6 

func (c *DieRollClient) GetParentWorkflowFromRun(future client.WorkflowRun) *DieRollParentWorkflow

GetParentWorkflowFromRun gets an instance of a given workflow from a future

func (*DieRollClient) GetThrowDies added in v0.0.4 

func (c *DieRollClient) GetThrowDies(ctx context.Context, workflowId string, runId string) *DieRollThrowDies

GetThrowDies gets an instance of a given workflow

func (*DieRollClient) GetThrowDiesFromRun added in v0.0.4 

func (c *DieRollClient) GetThrowDiesFromRun(future client.WorkflowRun) *DieRollThrowDies

GetThrowDiesFromRun gets an instance of a given workflow from a future

func (*DieRollClient) GetThrowUntilValue added in v0.0.4 

func (c *DieRollClient) GetThrowUntilValue(ctx context.Context, workflowId string, runId string) *DieRollThrowUntilValue

GetThrowUntilValue gets an instance of a given workflow

func (*DieRollClient) GetThrowUntilValueFromRun added in v0.0.4 

func (c *DieRollClient) GetThrowUntilValueFromRun(future client.WorkflowRun) *DieRollThrowUntilValue

GetThrowUntilValueFromRun gets an instance of a given workflow from a future

func (*DieRollClient) GetWorkflowChildWorkflowResult added in v0.0.6 

func (c *DieRollClient) GetWorkflowChildWorkflowResult(ctx context.Context, workflowId string, runId string) (*emptypb.Empty, error)

GetWorkflowChildWorkflowResult gets the result of a given workflow

func (*DieRollClient) GetWorkflowParentWorkflowResult added in v0.0.6 

func (c *DieRollClient) GetWorkflowParentWorkflowResult(ctx context.Context, workflowId string, runId string) (*ParentWorkflowReply, error)

GetWorkflowParentWorkflowResult gets the result of a given workflow

func (*DieRollClient) GetWorkflowThrowDiesResult added in v0.0.4 

func (c *DieRollClient) GetWorkflowThrowDiesResult(ctx context.Context, workflowId string, runId string) (*ThrowDiesResponse, error)

GetWorkflowThrowDiesResult gets the result of a given workflow

func (*DieRollClient) GetWorkflowThrowUntilValueResult added in v0.0.4 

func (c *DieRollClient) GetWorkflowThrowUntilValueResult(ctx context.Context, workflowId string, runId string) (*emptypb.Empty, error)

GetWorkflowThrowUntilValueResult gets the result of a given workflow

func (*DieRollClient) QueryGetThrowsStatus added in v0.0.4 

func (c *DieRollClient) QueryGetThrowsStatus(ctx context.Context, workflowID string, runID string, req *emptypb.Empty) (*ThrowStatusResponse, error)

QueryGetThrowsStatus sends the GetThrowsStatus query to a workflow

func (*DieRollClient) SendSignalContinue added in v0.0.4 

func (c *DieRollClient) SendSignalContinue(ctx context.Context, workflowID string, runID string, req *ContinueSignalRequest) error

SendSignalContinue sends the Continue signal to a workflow

type DieRollParentWorkflow added in v0.0.6 

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

DieRollParentWorkflow is a struct that wraps a workflow

func (*DieRollParentWorkflow) Cancel added in v0.0.6 

func (w *DieRollParentWorkflow) Cancel(ctx context.Context) error

Cancel cancels a given workflow

func (*DieRollParentWorkflow) Get added in v0.0.6 

func (w *DieRollParentWorkflow) Get(ctx context.Context, valuePtr interface{}) error

Get gets the result of a given workflow with pointers -- discouraged to use but required to implement internal.WorkflowRun

func (*DieRollParentWorkflow) GetID added in v0.0.6 

func (w *DieRollParentWorkflow) GetID() string

Returns the workflow ID

func (*DieRollParentWorkflow) GetRunID added in v0.0.6 

func (w *DieRollParentWorkflow) GetRunID() string

Returns the run ID

func (*DieRollParentWorkflow) GetWithOptions added in v0.0.6 

func (w *DieRollParentWorkflow) GetWithOptions(ctx context.Context, valuePtr interface{}, options client.WorkflowRunGetOptions) error

Get gets the result of a given workflow with pointers -- discouraged to use but required to implement internal.WorkflowRun

func (*DieRollParentWorkflow) Result added in v0.0.6 

func (w *DieRollParentWorkflow) Result(ctx context.Context) (*ParentWorkflowReply, error)

Get gets the result of a given workflow with its native type

func (*DieRollParentWorkflow) ResultWithOptions added in v0.0.6 

func (w *DieRollParentWorkflow) ResultWithOptions(ctx context.Context, options client.WorkflowRunGetOptions) (*ParentWorkflowReply, error)

ResultWithOptions gets the result of a given workflow with its native type

func (*DieRollParentWorkflow) SignalContinue added in v0.0.7 

func (w *DieRollParentWorkflow) SignalContinue(ctx context.Context, req *ContinueSignalRequest) error

SignalContinue sends the Continue signal to the workflow

func (*DieRollParentWorkflow) Terminate added in v0.0.6 

func (w *DieRollParentWorkflow) Terminate(ctx context.Context, reason string, details ...interface{}) error

Terminates terminates a given workflow

type DieRollService added in v0.0.4 

type DieRollService interface {

	// Parent workflow that calls the Child workflow -- to test workflow ID generations mainly
	ParentWorkflow(ctx workflow.Context, req *emptypb.Empty) (*ParentWorkflowReply, error)
	//
	ChildWorkflow(ctx workflow.Context, req *emptypb.Empty) (*emptypb.Empty, error)
	// Throws dies a few times and return the result
	ThrowDies(ctx workflow.Context, req *ThrowDiesRequest) (*ThrowDiesResponse, error)
	//
	ThrowUntilValue(ctx workflow.Context, req *ThrowUntilValueRequest) (*emptypb.Empty, error)

	// Throws a d6 and returns the result
	ThrowDie(ctx context.Context, req *emptypb.Empty) (*ThrowDieResponse, error)
	// Just a simple ping
	// Takes no parameters
	// returns nothing
	Ping(ctx context.Context, req *emptypb.Empty) (*emptypb.Empty, error)
}

type DieRollThrowDies added in v0.0.4 

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

DieRollThrowDies is a struct that wraps a workflow

func (*DieRollThrowDies) Cancel added in v0.0.4 

func (w *DieRollThrowDies) Cancel(ctx context.Context) error

Cancel cancels a given workflow

func (*DieRollThrowDies) Get added in v0.0.4 

func (w *DieRollThrowDies) Get(ctx context.Context, valuePtr interface{}) error

Get gets the result of a given workflow with pointers -- discouraged to use but required to implement internal.WorkflowRun

func (*DieRollThrowDies) GetID added in v0.0.4 

func (w *DieRollThrowDies) GetID() string

Returns the workflow ID

func (*DieRollThrowDies) GetRunID added in v0.0.4 

func (w *DieRollThrowDies) GetRunID() string

Returns the run ID

func (*DieRollThrowDies) GetWithOptions added in v0.0.4 

func (w *DieRollThrowDies) GetWithOptions(ctx context.Context, valuePtr interface{}, options client.WorkflowRunGetOptions) error

Get gets the result of a given workflow with pointers -- discouraged to use but required to implement internal.WorkflowRun

func (*DieRollThrowDies) Result added in v0.0.4 

func (w *DieRollThrowDies) Result(ctx context.Context) (*ThrowDiesResponse, error)

Get gets the result of a given workflow with its native type

func (*DieRollThrowDies) ResultWithOptions added in v0.0.4 

func (w *DieRollThrowDies) ResultWithOptions(ctx context.Context, options client.WorkflowRunGetOptions) (*ThrowDiesResponse, error)

ResultWithOptions gets the result of a given workflow with its native type

func (*DieRollThrowDies) SignalContinue added in v0.0.4 

func (w *DieRollThrowDies) SignalContinue(ctx context.Context, req *ContinueSignalRequest) error

SignalContinue sends the Continue signal to the workflow

func (*DieRollThrowDies) Terminate added in v0.0.4 

func (w *DieRollThrowDies) Terminate(ctx context.Context, reason string, details ...interface{}) error

Terminates terminates a given workflow

type DieRollThrowUntilValue added in v0.0.4 

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

DieRollThrowUntilValue is a struct that wraps a workflow

func (*DieRollThrowUntilValue) Cancel added in v0.0.4 

func (w *DieRollThrowUntilValue) Cancel(ctx context.Context) error

Cancel cancels a given workflow

func (*DieRollThrowUntilValue) Get added in v0.0.4 

func (w *DieRollThrowUntilValue) Get(ctx context.Context, valuePtr interface{}) error

Get gets the result of a given workflow with pointers -- discouraged to use but required to implement internal.WorkflowRun

func (*DieRollThrowUntilValue) GetID added in v0.0.4 

func (w *DieRollThrowUntilValue) GetID() string

Returns the workflow ID

func (*DieRollThrowUntilValue) GetRunID added in v0.0.4 

func (w *DieRollThrowUntilValue) GetRunID() string

Returns the run ID

func (*DieRollThrowUntilValue) GetWithOptions added in v0.0.4 

func (w *DieRollThrowUntilValue) GetWithOptions(ctx context.Context, valuePtr interface{}, options client.WorkflowRunGetOptions) error

Get gets the result of a given workflow with pointers -- discouraged to use but required to implement internal.WorkflowRun

func (*DieRollThrowUntilValue) QueryGetThrowsStatus added in v0.0.4 

func (w *DieRollThrowUntilValue) QueryGetThrowsStatus(ctx context.Context, req *emptypb.Empty) (*ThrowStatusResponse, error)

QueryGetThrowsStatus queries the workflow with GetThrowsStatus

func (*DieRollThrowUntilValue) Result added in v0.0.4 

func (w *DieRollThrowUntilValue) Result(ctx context.Context) (*emptypb.Empty, error)

Get gets the result of a given workflow with its native type

func (*DieRollThrowUntilValue) ResultWithOptions added in v0.0.4 

func (w *DieRollThrowUntilValue) ResultWithOptions(ctx context.Context, options client.WorkflowRunGetOptions) (*emptypb.Empty, error)

ResultWithOptions gets the result of a given workflow with its native type

func (*DieRollThrowUntilValue) Terminate added in v0.0.4 

func (w *DieRollThrowUntilValue) Terminate(ctx context.Context, reason string, details ...interface{}) error

Terminates terminates a given workflow

type DieRollWorker added in v0.0.4 

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

DieRollWorker: Worker for the DieRoll service

func NewDieRollWorker added in v0.0.4 

func NewDieRollWorker(client client.Client, svc DieRollService, taskQueue string, workerOptions ...worker.Options) (*DieRollWorker, error)

NewDieRollWorker: Returns a new instance of the worker. If `taskQueue` stays empty the default one will be used

func (*DieRollWorker) Register added in v0.0.4 

func (w *DieRollWorker) Register()

Register registers the worker and its activities/workflows in temporal

func (*DieRollWorker) Run added in v0.0.4 

func (w *DieRollWorker) Run() error

Run will run the worker

func (*DieRollWorker) Stop added in v0.0.4 

func (w *DieRollWorker) Stop()

Stop will stop the worker, may panic if called twice

type GetStatusResponse added in v0.0.4 

type GetStatusResponse struct {
	Progress int64 `protobuf:"varint,1,opt,name=progress,proto3" json:"progress,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStatusResponse) Descriptor deprecated added in v0.0.4 

func (*GetStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetStatusResponse.ProtoReflect.Descriptor instead.

func (*GetStatusResponse) GetProgress added in v0.0.4 

func (x *GetStatusResponse) GetProgress() int64

func (*GetStatusResponse) ProtoMessage added in v0.0.4 

func (*GetStatusResponse) ProtoMessage()

func (*GetStatusResponse) ProtoReflect added in v0.0.4 

func (x *GetStatusResponse) ProtoReflect() protoreflect.Message

func (*GetStatusResponse) Reset added in v0.0.4 

func (x *GetStatusResponse) Reset()

func (*GetStatusResponse) String added in v0.0.4 

func (x *GetStatusResponse) String() string

type ParentWorkflowReply added in v0.0.8 

type ParentWorkflowReply struct {
	Status Status `protobuf:"varint,1,opt,name=status,proto3,enum=example.v1.Status" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ParentWorkflowReply) Descriptor deprecated added in v0.0.8 

func (*ParentWorkflowReply) Descriptor() ([]byte, []int)

Deprecated: Use ParentWorkflowReply.ProtoReflect.Descriptor instead.

func (*ParentWorkflowReply) GetStatus added in v0.0.8 

func (x *ParentWorkflowReply) GetStatus() Status

func (*ParentWorkflowReply) ProtoMessage added in v0.0.8 

func (*ParentWorkflowReply) ProtoMessage()

func (*ParentWorkflowReply) ProtoReflect added in v0.0.8 

func (x *ParentWorkflowReply) ProtoReflect() protoreflect.Message

func (*ParentWorkflowReply) Reset added in v0.0.8 

func (x *ParentWorkflowReply) Reset()

func (*ParentWorkflowReply) String added in v0.0.8 

func (x *ParentWorkflowReply) String() string

type Status added in v0.0.8 

type Status int32
const (
	Status_UNDEFINED Status = 0
	Status_SUCCESS   Status = 1
	Status_FAILURE   Status = 2
)

func (Status) Descriptor added in v0.0.8 

func (Status) Descriptor() protoreflect.EnumDescriptor

func (Status) Enum added in v0.0.8 

func (x Status) Enum() *Status

func (Status) EnumDescriptor deprecated added in v0.0.8 

func (Status) EnumDescriptor() ([]byte, []int)

Deprecated: Use Status.Descriptor instead.

func (Status) Number added in v0.0.8 

func (x Status) Number() protoreflect.EnumNumber

func (Status) String added in v0.0.8 

func (x Status) String() string

func (Status) Type added in v0.0.8 

func (Status) Type() protoreflect.EnumType

type ThrowDieResponse added in v0.0.4 

type ThrowDieResponse struct {
	Result int32 `protobuf:"varint,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*ThrowDieResponse) Descriptor deprecated added in v0.0.4 

func (*ThrowDieResponse) Descriptor() ([]byte, []int)

Deprecated: Use ThrowDieResponse.ProtoReflect.Descriptor instead.

func (*ThrowDieResponse) GetResult added in v0.0.4 

func (x *ThrowDieResponse) GetResult() int32

func (*ThrowDieResponse) ProtoMessage added in v0.0.4 

func (*ThrowDieResponse) ProtoMessage()

func (*ThrowDieResponse) ProtoReflect added in v0.0.4 

func (x *ThrowDieResponse) ProtoReflect() protoreflect.Message

func (*ThrowDieResponse) Reset added in v0.0.4 

func (x *ThrowDieResponse) Reset()

func (*ThrowDieResponse) String added in v0.0.4 

func (x *ThrowDieResponse) String() string

type ThrowDiesRequest added in v0.0.4 

type ThrowDiesRequest struct {
	Results int32 `protobuf:"varint,1,opt,name=results,proto3" json:"results,omitempty"`
	Loop    bool  `protobuf:"varint,2,opt,name=loop,proto3" json:"loop,omitempty"`
	// contains filtered or unexported fields
}

func (*ThrowDiesRequest) Descriptor deprecated added in v0.0.4 

func (*ThrowDiesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ThrowDiesRequest.ProtoReflect.Descriptor instead.

func (*ThrowDiesRequest) GetLoop added in v0.0.4 

func (x *ThrowDiesRequest) GetLoop() bool

func (*ThrowDiesRequest) GetResults added in v0.0.4 

func (x *ThrowDiesRequest) GetResults() int32

func (*ThrowDiesRequest) ProtoMessage added in v0.0.4 

func (*ThrowDiesRequest) ProtoMessage()

func (*ThrowDiesRequest) ProtoReflect added in v0.0.4 

func (x *ThrowDiesRequest) ProtoReflect() protoreflect.Message

func (*ThrowDiesRequest) Reset added in v0.0.4 

func (x *ThrowDiesRequest) Reset()

func (*ThrowDiesRequest) String added in v0.0.4 

func (x *ThrowDiesRequest) String() string

type ThrowDiesResponse added in v0.0.4 

type ThrowDiesResponse struct {
	Results []int32 `protobuf:"varint,1,rep,packed,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

func (*ThrowDiesResponse) Descriptor deprecated added in v0.0.4 

func (*ThrowDiesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ThrowDiesResponse.ProtoReflect.Descriptor instead.

func (*ThrowDiesResponse) GetResults added in v0.0.4 

func (x *ThrowDiesResponse) GetResults() []int32

func (*ThrowDiesResponse) ProtoMessage added in v0.0.4 

func (*ThrowDiesResponse) ProtoMessage()

func (*ThrowDiesResponse) ProtoReflect added in v0.0.4 

func (x *ThrowDiesResponse) ProtoReflect() protoreflect.Message

func (*ThrowDiesResponse) Reset added in v0.0.4 

func (x *ThrowDiesResponse) Reset()

func (*ThrowDiesResponse) String added in v0.0.4 

func (x *ThrowDiesResponse) String() string

type ThrowStatusResponse added in v0.0.4 

type ThrowStatusResponse struct {
	Throws int32 `protobuf:"varint,1,opt,name=throws,proto3" json:"throws,omitempty"`
	// contains filtered or unexported fields
}

func (*ThrowStatusResponse) Descriptor deprecated added in v0.0.4 

func (*ThrowStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use ThrowStatusResponse.ProtoReflect.Descriptor instead.

func (*ThrowStatusResponse) GetThrows added in v0.0.4 

func (x *ThrowStatusResponse) GetThrows() int32

func (*ThrowStatusResponse) ProtoMessage added in v0.0.4 

func (*ThrowStatusResponse) ProtoMessage()

func (*ThrowStatusResponse) ProtoReflect added in v0.0.4 

func (x *ThrowStatusResponse) ProtoReflect() protoreflect.Message

func (*ThrowStatusResponse) Reset added in v0.0.4 

func (x *ThrowStatusResponse) Reset()

func (*ThrowStatusResponse) String added in v0.0.4 

func (x *ThrowStatusResponse) String() string

type ThrowUntilValueRequest added in v0.0.4 

type ThrowUntilValueRequest struct {
	Value int32 `protobuf:"varint,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ThrowUntilValueRequest) Descriptor deprecated added in v0.0.4 

func (*ThrowUntilValueRequest) Descriptor() ([]byte, []int)

Deprecated: Use ThrowUntilValueRequest.ProtoReflect.Descriptor instead.

func (*ThrowUntilValueRequest) GetValue added in v0.0.4 

func (x *ThrowUntilValueRequest) GetValue() int32

func (*ThrowUntilValueRequest) ProtoMessage added in v0.0.4 

func (*ThrowUntilValueRequest) ProtoMessage()

func (*ThrowUntilValueRequest) ProtoReflect added in v0.0.4 

func (x *ThrowUntilValueRequest) ProtoReflect() protoreflect.Message

func (*ThrowUntilValueRequest) Reset added in v0.0.4 

func (x *ThrowUntilValueRequest) Reset()

func (*ThrowUntilValueRequest) String added in v0.0.4 

func (x *ThrowUntilValueRequest) String() string

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.