contracts

package
v0.28.0 Latest Latest
Warning

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

 Go to latest Published: May 16, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ConcurrencyLimitStrategy_name = map[int32]string{
		0: "CANCEL_IN_PROGRESS",
		1: "DROP_NEWEST",
		2: "QUEUE_NEWEST",
		3: "GROUP_ROUND_ROBIN",
	}
	ConcurrencyLimitStrategy_value = map[string]int32{
		"CANCEL_IN_PROGRESS": 0,
		"DROP_NEWEST":        1,
		"QUEUE_NEWEST":       2,
		"GROUP_ROUND_ROBIN":  3,
	}
)

Enum value maps for ConcurrencyLimitStrategy.

View Source 
var (
	RateLimitDuration_name = map[int32]string{
		0: "SECOND",
		1: "MINUTE",
		2: "HOUR",
		3: "DAY",
		4: "WEEK",
		5: "MONTH",
		6: "YEAR",
	}
	RateLimitDuration_value = map[string]int32{
		"SECOND": 0,
		"MINUTE": 1,
		"HOUR":   2,
		"DAY":    3,
		"WEEK":   4,
		"MONTH":  5,
		"YEAR":   6,
	}
)

Enum value maps for RateLimitDuration.

View Source 
var File_workflows_proto protoreflect.FileDescriptor
View Source 
var WorkflowService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "WorkflowService",
	HandlerType: (*WorkflowServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PutWorkflow",
			Handler:    _WorkflowService_PutWorkflow_Handler,
		},
		{
			MethodName: "ScheduleWorkflow",
			Handler:    _WorkflowService_ScheduleWorkflow_Handler,
		},
		{
			MethodName: "TriggerWorkflow",
			Handler:    _WorkflowService_TriggerWorkflow_Handler,
		},
		{
			MethodName: "PutRateLimit",
			Handler:    _WorkflowService_PutRateLimit_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "workflows.proto",
}

WorkflowService_ServiceDesc is the grpc.ServiceDesc for WorkflowService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterWorkflowServiceServer 

func RegisterWorkflowServiceServer(s grpc.ServiceRegistrar, srv WorkflowServiceServer)

Types

type ConcurrencyLimitStrategy added in v0.8.0 

type ConcurrencyLimitStrategy int32
const (
	ConcurrencyLimitStrategy_CANCEL_IN_PROGRESS ConcurrencyLimitStrategy = 0
	ConcurrencyLimitStrategy_DROP_NEWEST        ConcurrencyLimitStrategy = 1
	ConcurrencyLimitStrategy_QUEUE_NEWEST       ConcurrencyLimitStrategy = 2
	ConcurrencyLimitStrategy_GROUP_ROUND_ROBIN  ConcurrencyLimitStrategy = 3
)

func (ConcurrencyLimitStrategy) Descriptor added in v0.8.0 

func (ConcurrencyLimitStrategy) Descriptor() protoreflect.EnumDescriptor

func (ConcurrencyLimitStrategy) Enum added in v0.8.0 

func (x ConcurrencyLimitStrategy) Enum() *ConcurrencyLimitStrategy

func (ConcurrencyLimitStrategy) EnumDescriptor deprecated added in v0.8.0 

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

Deprecated: Use ConcurrencyLimitStrategy.Descriptor instead.

func (ConcurrencyLimitStrategy) Number added in v0.8.0 

func (x ConcurrencyLimitStrategy) Number() protoreflect.EnumNumber

func (ConcurrencyLimitStrategy) String added in v0.8.0 

func (x ConcurrencyLimitStrategy) String() string

func (ConcurrencyLimitStrategy) Type added in v0.8.0 

func (ConcurrencyLimitStrategy) Type() protoreflect.EnumType

type CreateStepRateLimit added in v0.19.0 

type CreateStepRateLimit struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`      // (required) the key for the rate limit
	Units int32  `protobuf:"varint,2,opt,name=units,proto3" json:"units,omitempty"` // (required) the number of units this step consumes
	// contains filtered or unexported fields
}

func (*CreateStepRateLimit) Descriptor deprecated added in v0.19.0 

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

Deprecated: Use CreateStepRateLimit.ProtoReflect.Descriptor instead.

func (*CreateStepRateLimit) GetKey added in v0.19.0 

func (x *CreateStepRateLimit) GetKey() string

func (*CreateStepRateLimit) GetUnits added in v0.19.0 

func (x *CreateStepRateLimit) GetUnits() int32

func (*CreateStepRateLimit) ProtoMessage added in v0.19.0 

func (*CreateStepRateLimit) ProtoMessage()

func (*CreateStepRateLimit) ProtoReflect added in v0.19.0 

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

func (*CreateStepRateLimit) Reset added in v0.19.0 

func (x *CreateStepRateLimit) Reset()

func (*CreateStepRateLimit) String added in v0.19.0 

func (x *CreateStepRateLimit) String() string

type CreateWorkflowJobOpts 

type CreateWorkflowJobOpts struct {
	Name        string                    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`               // (required) the job name
	Description string                    `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"` // (optional) the job description
	Steps       []*CreateWorkflowStepOpts `protobuf:"bytes,4,rep,name=steps,proto3" json:"steps,omitempty"`             // (required) the job steps
	// contains filtered or unexported fields
}

CreateWorkflowJobOpts represents options to create a workflow job.

func (*CreateWorkflowJobOpts) Descriptor deprecated 

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

Deprecated: Use CreateWorkflowJobOpts.ProtoReflect.Descriptor instead.

func (*CreateWorkflowJobOpts) GetDescription 

func (x *CreateWorkflowJobOpts) GetDescription() string

func (*CreateWorkflowJobOpts) GetName 

func (x *CreateWorkflowJobOpts) GetName() string

func (*CreateWorkflowJobOpts) GetSteps 

func (x *CreateWorkflowJobOpts) GetSteps() []*CreateWorkflowStepOpts

func (*CreateWorkflowJobOpts) ProtoMessage 

func (*CreateWorkflowJobOpts) ProtoMessage()

func (*CreateWorkflowJobOpts) ProtoReflect 

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

func (*CreateWorkflowJobOpts) Reset 

func (x *CreateWorkflowJobOpts) Reset()

func (*CreateWorkflowJobOpts) String 

func (x *CreateWorkflowJobOpts) String() string

type CreateWorkflowStepOpts 

type CreateWorkflowStepOpts struct {
	ReadableId string                 `protobuf:"bytes,1,opt,name=readable_id,json=readableId,proto3" json:"readable_id,omitempty"` // (required) the step name
	Action     string                 `protobuf:"bytes,2,opt,name=action,proto3" json:"action,omitempty"`                           // (required) the step action id
	Timeout    string                 `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"`                         // (optional) the step timeout
	Inputs     string                 `protobuf:"bytes,4,opt,name=inputs,proto3" json:"inputs,omitempty"`                           // (optional) the step inputs, assuming string representation of JSON
	Parents    []string               `protobuf:"bytes,5,rep,name=parents,proto3" json:"parents,omitempty"`                         // (optional) the step parents. if none are passed in, this is a root step
	UserData   string                 `protobuf:"bytes,6,opt,name=user_data,json=userData,proto3" json:"user_data,omitempty"`       // (optional) the custom step user data, assuming string representation of JSON
	Retries    int32                  `protobuf:"varint,7,opt,name=retries,proto3" json:"retries,omitempty"`                        // (optional) the number of retries for the step, default 0
	RateLimits []*CreateStepRateLimit `protobuf:"bytes,8,rep,name=rate_limits,json=rateLimits,proto3" json:"rate_limits,omitempty"` // (optional) the rate limits for the step
	// contains filtered or unexported fields
}

CreateWorkflowStepOpts represents options to create a workflow step.

func (*CreateWorkflowStepOpts) Descriptor deprecated 

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

Deprecated: Use CreateWorkflowStepOpts.ProtoReflect.Descriptor instead.

func (*CreateWorkflowStepOpts) GetAction 

func (x *CreateWorkflowStepOpts) GetAction() string

func (*CreateWorkflowStepOpts) GetInputs 

func (x *CreateWorkflowStepOpts) GetInputs() string

func (*CreateWorkflowStepOpts) GetParents 

func (x *CreateWorkflowStepOpts) GetParents() []string

func (*CreateWorkflowStepOpts) GetRateLimits added in v0.19.0 

func (x *CreateWorkflowStepOpts) GetRateLimits() []*CreateStepRateLimit

func (*CreateWorkflowStepOpts) GetReadableId 

func (x *CreateWorkflowStepOpts) GetReadableId() string

func (*CreateWorkflowStepOpts) GetRetries added in v0.11.0 

func (x *CreateWorkflowStepOpts) GetRetries() int32

func (*CreateWorkflowStepOpts) GetTimeout 

func (x *CreateWorkflowStepOpts) GetTimeout() string

func (*CreateWorkflowStepOpts) GetUserData added in v0.10.2 

func (x *CreateWorkflowStepOpts) GetUserData() string

func (*CreateWorkflowStepOpts) ProtoMessage 

func (*CreateWorkflowStepOpts) ProtoMessage()

func (*CreateWorkflowStepOpts) ProtoReflect 

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

func (*CreateWorkflowStepOpts) Reset 

func (x *CreateWorkflowStepOpts) Reset()

func (*CreateWorkflowStepOpts) String 

func (x *CreateWorkflowStepOpts) String() string

type CreateWorkflowVersionOpts 

type CreateWorkflowVersionOpts struct {
	Name              string                   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`                                                    // (required) the workflow name
	Description       string                   `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`                                      // (optional) the workflow description
	Version           string                   `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`                                              // (required) the workflow version
	EventTriggers     []string                 `protobuf:"bytes,4,rep,name=event_triggers,json=eventTriggers,proto3" json:"event_triggers,omitempty"`             // (optional) event triggers for the workflow
	CronTriggers      []string                 `protobuf:"bytes,5,rep,name=cron_triggers,json=cronTriggers,proto3" json:"cron_triggers,omitempty"`                // (optional) cron triggers for the workflow
	ScheduledTriggers []*timestamppb.Timestamp `protobuf:"bytes,6,rep,name=scheduled_triggers,json=scheduledTriggers,proto3" json:"scheduled_triggers,omitempty"` // (optional) scheduled triggers for the workflow
	Jobs              []*CreateWorkflowJobOpts `protobuf:"bytes,7,rep,name=jobs,proto3" json:"jobs,omitempty"`                                                    // (required) the workflow jobs
	Concurrency       *WorkflowConcurrencyOpts `protobuf:"bytes,8,opt,name=concurrency,proto3" json:"concurrency,omitempty"`                                      // (optional) the workflow concurrency options
	ScheduleTimeout   *string                  `protobuf:"bytes,9,opt,name=schedule_timeout,json=scheduleTimeout,proto3,oneof" json:"schedule_timeout,omitempty"` // (optional) the timeout for the schedule
	CronInput         *string                  `protobuf:"bytes,10,opt,name=cron_input,json=cronInput,proto3,oneof" json:"cron_input,omitempty"`                  // (optional) the input for the cron trigger
	OnFailureJob      *CreateWorkflowJobOpts   `protobuf:"bytes,11,opt,name=on_failure_job,json=onFailureJob,proto3,oneof" json:"on_failure_job,omitempty"`       // (optional) the job to run on failure
	// contains filtered or unexported fields
}

CreateWorkflowVersionOpts represents options to create a workflow version.

func (*CreateWorkflowVersionOpts) Descriptor deprecated 

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

Deprecated: Use CreateWorkflowVersionOpts.ProtoReflect.Descriptor instead.

func (*CreateWorkflowVersionOpts) GetConcurrency added in v0.8.0 

func (x *CreateWorkflowVersionOpts) GetConcurrency() *WorkflowConcurrencyOpts

func (*CreateWorkflowVersionOpts) GetCronInput added in v0.19.0 

func (x *CreateWorkflowVersionOpts) GetCronInput() string

func (*CreateWorkflowVersionOpts) GetCronTriggers 

func (x *CreateWorkflowVersionOpts) GetCronTriggers() []string

func (*CreateWorkflowVersionOpts) GetDescription 

func (x *CreateWorkflowVersionOpts) GetDescription() string

func (*CreateWorkflowVersionOpts) GetEventTriggers 

func (x *CreateWorkflowVersionOpts) GetEventTriggers() []string

func (*CreateWorkflowVersionOpts) GetJobs 

func (x *CreateWorkflowVersionOpts) GetJobs() []*CreateWorkflowJobOpts

func (*CreateWorkflowVersionOpts) GetName 

func (x *CreateWorkflowVersionOpts) GetName() string

func (*CreateWorkflowVersionOpts) GetOnFailureJob added in v0.25.0 

func (x *CreateWorkflowVersionOpts) GetOnFailureJob() *CreateWorkflowJobOpts

func (*CreateWorkflowVersionOpts) GetScheduleTimeout added in v0.13.2 

func (x *CreateWorkflowVersionOpts) GetScheduleTimeout() string

func (*CreateWorkflowVersionOpts) GetScheduledTriggers 

func (x *CreateWorkflowVersionOpts) GetScheduledTriggers() []*timestamppb.Timestamp

func (*CreateWorkflowVersionOpts) GetVersion 

func (x *CreateWorkflowVersionOpts) GetVersion() string

func (*CreateWorkflowVersionOpts) ProtoMessage 

func (*CreateWorkflowVersionOpts) ProtoMessage()

func (*CreateWorkflowVersionOpts) ProtoReflect 

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

func (*CreateWorkflowVersionOpts) Reset 

func (x *CreateWorkflowVersionOpts) Reset()

func (*CreateWorkflowVersionOpts) String 

func (x *CreateWorkflowVersionOpts) String() string

type ListWorkflowsRequest 

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

ListWorkflowsRequest is the request for ListWorkflows.

func (*ListWorkflowsRequest) Descriptor deprecated 

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

Deprecated: Use ListWorkflowsRequest.ProtoReflect.Descriptor instead.

func (*ListWorkflowsRequest) ProtoMessage 

func (*ListWorkflowsRequest) ProtoMessage()

func (*ListWorkflowsRequest) ProtoReflect 

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

func (*ListWorkflowsRequest) Reset 

func (x *ListWorkflowsRequest) Reset()

func (*ListWorkflowsRequest) String 

func (x *ListWorkflowsRequest) String() string

type PutRateLimitRequest added in v0.19.0 

type PutRateLimitRequest struct {

	// (required) the global key for the rate limit
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// (required) the max limit for the rate limit (per unit of time)
	Limit int32 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// (required) the duration of time for the rate limit (second|minute|hour)
	Duration RateLimitDuration `protobuf:"varint,3,opt,name=duration,proto3,enum=RateLimitDuration" json:"duration,omitempty"`
	// contains filtered or unexported fields
}

func (*PutRateLimitRequest) Descriptor deprecated added in v0.19.0 

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

Deprecated: Use PutRateLimitRequest.ProtoReflect.Descriptor instead.

func (*PutRateLimitRequest) GetDuration added in v0.19.0 

func (x *PutRateLimitRequest) GetDuration() RateLimitDuration

func (*PutRateLimitRequest) GetKey added in v0.19.0 

func (x *PutRateLimitRequest) GetKey() string

func (*PutRateLimitRequest) GetLimit added in v0.19.0 

func (x *PutRateLimitRequest) GetLimit() int32

func (*PutRateLimitRequest) ProtoMessage added in v0.19.0 

func (*PutRateLimitRequest) ProtoMessage()

func (*PutRateLimitRequest) ProtoReflect added in v0.19.0 

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

func (*PutRateLimitRequest) Reset added in v0.19.0 

func (x *PutRateLimitRequest) Reset()

func (*PutRateLimitRequest) String added in v0.19.0 

func (x *PutRateLimitRequest) String() string

type PutRateLimitResponse added in v0.19.0 

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

func (*PutRateLimitResponse) Descriptor deprecated added in v0.19.0 

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

Deprecated: Use PutRateLimitResponse.ProtoReflect.Descriptor instead.

func (*PutRateLimitResponse) ProtoMessage added in v0.19.0 

func (*PutRateLimitResponse) ProtoMessage()

func (*PutRateLimitResponse) ProtoReflect added in v0.19.0 

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

func (*PutRateLimitResponse) Reset added in v0.19.0 

func (x *PutRateLimitResponse) Reset()

func (*PutRateLimitResponse) String added in v0.19.0 

func (x *PutRateLimitResponse) String() string

type PutWorkflowRequest 

type PutWorkflowRequest struct {
	Opts *CreateWorkflowVersionOpts `protobuf:"bytes,1,opt,name=opts,proto3" json:"opts,omitempty"`
	// contains filtered or unexported fields
}

func (*PutWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use PutWorkflowRequest.ProtoReflect.Descriptor instead.

func (*PutWorkflowRequest) GetOpts 

func (x *PutWorkflowRequest) GetOpts() *CreateWorkflowVersionOpts

func (*PutWorkflowRequest) ProtoMessage 

func (*PutWorkflowRequest) ProtoMessage()

func (*PutWorkflowRequest) ProtoReflect 

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

func (*PutWorkflowRequest) Reset 

func (x *PutWorkflowRequest) Reset()

func (*PutWorkflowRequest) String 

func (x *PutWorkflowRequest) String() string

type RateLimitDuration added in v0.19.0 

type RateLimitDuration int32
const (
	RateLimitDuration_SECOND RateLimitDuration = 0
	RateLimitDuration_MINUTE RateLimitDuration = 1
	RateLimitDuration_HOUR   RateLimitDuration = 2
	RateLimitDuration_DAY    RateLimitDuration = 3
	RateLimitDuration_WEEK   RateLimitDuration = 4
	RateLimitDuration_MONTH  RateLimitDuration = 5
	RateLimitDuration_YEAR   RateLimitDuration = 6
)

func (RateLimitDuration) Descriptor added in v0.19.0 

func (RateLimitDuration) Descriptor() protoreflect.EnumDescriptor

func (RateLimitDuration) Enum added in v0.19.0 

func (x RateLimitDuration) Enum() *RateLimitDuration

func (RateLimitDuration) EnumDescriptor deprecated added in v0.19.0 

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

Deprecated: Use RateLimitDuration.Descriptor instead.

func (RateLimitDuration) Number added in v0.19.0 

func (x RateLimitDuration) Number() protoreflect.EnumNumber

func (RateLimitDuration) String added in v0.19.0 

func (x RateLimitDuration) String() string

func (RateLimitDuration) Type added in v0.19.0 

func (RateLimitDuration) Type() protoreflect.EnumType

type ScheduleWorkflowRequest 

type ScheduleWorkflowRequest struct {
	Name      string                   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Schedules []*timestamppb.Timestamp `protobuf:"bytes,2,rep,name=schedules,proto3" json:"schedules,omitempty"`
	// (optional) the input data for the workflow
	Input string `protobuf:"bytes,3,opt,name=input,proto3" json:"input,omitempty"`
	// (optional) the parent workflow run id
	ParentId *string `protobuf:"bytes,4,opt,name=parent_id,json=parentId,proto3,oneof" json:"parent_id,omitempty"`
	// (optional) the parent step run id
	ParentStepRunId *string `protobuf:"bytes,5,opt,name=parent_step_run_id,json=parentStepRunId,proto3,oneof" json:"parent_step_run_id,omitempty"`
	// (optional) the index of the child workflow. if this is set, matches on the index or the
	// child key will be a no-op, even if the schedule has changed.
	ChildIndex *int32 `protobuf:"varint,6,opt,name=child_index,json=childIndex,proto3,oneof" json:"child_index,omitempty"`
	// (optional) the key for the child. if this is set, matches on the index or the
	// child key will be a no-op, even if the schedule has changed.
	ChildKey *string `protobuf:"bytes,7,opt,name=child_key,json=childKey,proto3,oneof" json:"child_key,omitempty"`
	// contains filtered or unexported fields
}

func (*ScheduleWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use ScheduleWorkflowRequest.ProtoReflect.Descriptor instead.

func (*ScheduleWorkflowRequest) GetChildIndex added in v0.18.0 

func (x *ScheduleWorkflowRequest) GetChildIndex() int32

func (*ScheduleWorkflowRequest) GetChildKey added in v0.18.0 

func (x *ScheduleWorkflowRequest) GetChildKey() string

func (*ScheduleWorkflowRequest) GetInput 

func (x *ScheduleWorkflowRequest) GetInput() string

func (*ScheduleWorkflowRequest) GetName added in v0.17.0 

func (x *ScheduleWorkflowRequest) GetName() string

func (*ScheduleWorkflowRequest) GetParentId added in v0.18.0 

func (x *ScheduleWorkflowRequest) GetParentId() string

func (*ScheduleWorkflowRequest) GetParentStepRunId added in v0.18.0 

func (x *ScheduleWorkflowRequest) GetParentStepRunId() string

func (*ScheduleWorkflowRequest) GetSchedules 

func (x *ScheduleWorkflowRequest) GetSchedules() []*timestamppb.Timestamp

func (*ScheduleWorkflowRequest) ProtoMessage 

func (*ScheduleWorkflowRequest) ProtoMessage()

func (*ScheduleWorkflowRequest) ProtoReflect 

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

func (*ScheduleWorkflowRequest) Reset 

func (x *ScheduleWorkflowRequest) Reset()

func (*ScheduleWorkflowRequest) String 

func (x *ScheduleWorkflowRequest) String() string

type TriggerWorkflowRequest added in v0.9.0 

type TriggerWorkflowRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// (optional) the input data for the workflow
	Input string `protobuf:"bytes,2,opt,name=input,proto3" json:"input,omitempty"`
	// (optional) the parent workflow run id
	ParentId *string `protobuf:"bytes,3,opt,name=parent_id,json=parentId,proto3,oneof" json:"parent_id,omitempty"`
	// (optional) the parent step run id
	ParentStepRunId *string `protobuf:"bytes,4,opt,name=parent_step_run_id,json=parentStepRunId,proto3,oneof" json:"parent_step_run_id,omitempty"`
	// (optional) the index of the child workflow. if this is set, matches on the index or the
	// child key will return an existing workflow run if the parent id, parent step run id, and
	// child index/key match an existing workflow run.
	ChildIndex *int32 `protobuf:"varint,5,opt,name=child_index,json=childIndex,proto3,oneof" json:"child_index,omitempty"`
	// (optional) the key for the child. if this is set, matches on the index or the
	// child key will return an existing workflow run if the parent id, parent step run id, and
	// child index/key match an existing workflow run.
	ChildKey *string `protobuf:"bytes,6,opt,name=child_key,json=childKey,proto3,oneof" json:"child_key,omitempty"`
	// (optional) additional metadata for the workflow
	AdditionalMetadata *string `protobuf:"bytes,7,opt,name=additional_metadata,json=additionalMetadata,proto3,oneof" json:"additional_metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*TriggerWorkflowRequest) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use TriggerWorkflowRequest.ProtoReflect.Descriptor instead.

func (*TriggerWorkflowRequest) GetAdditionalMetadata added in v0.25.0 

func (x *TriggerWorkflowRequest) GetAdditionalMetadata() string

func (*TriggerWorkflowRequest) GetChildIndex added in v0.18.0 

func (x *TriggerWorkflowRequest) GetChildIndex() int32

func (*TriggerWorkflowRequest) GetChildKey added in v0.18.0 

func (x *TriggerWorkflowRequest) GetChildKey() string

func (*TriggerWorkflowRequest) GetInput added in v0.9.0 

func (x *TriggerWorkflowRequest) GetInput() string

func (*TriggerWorkflowRequest) GetName added in v0.9.0 

func (x *TriggerWorkflowRequest) GetName() string

func (*TriggerWorkflowRequest) GetParentId added in v0.18.0 

func (x *TriggerWorkflowRequest) GetParentId() string

func (*TriggerWorkflowRequest) GetParentStepRunId added in v0.18.0 

func (x *TriggerWorkflowRequest) GetParentStepRunId() string

func (*TriggerWorkflowRequest) ProtoMessage added in v0.9.0 

func (*TriggerWorkflowRequest) ProtoMessage()

func (*TriggerWorkflowRequest) ProtoReflect added in v0.9.0 

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

func (*TriggerWorkflowRequest) Reset added in v0.9.0 

func (x *TriggerWorkflowRequest) Reset()

func (*TriggerWorkflowRequest) String added in v0.9.0 

func (x *TriggerWorkflowRequest) String() string

type TriggerWorkflowResponse added in v0.9.0 

type TriggerWorkflowResponse struct {
	WorkflowRunId string `protobuf:"bytes,1,opt,name=workflow_run_id,json=workflowRunId,proto3" json:"workflow_run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TriggerWorkflowResponse) Descriptor deprecated added in v0.9.0 

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

Deprecated: Use TriggerWorkflowResponse.ProtoReflect.Descriptor instead.

func (*TriggerWorkflowResponse) GetWorkflowRunId added in v0.9.0 

func (x *TriggerWorkflowResponse) GetWorkflowRunId() string

func (*TriggerWorkflowResponse) ProtoMessage added in v0.9.0 

func (*TriggerWorkflowResponse) ProtoMessage()

func (*TriggerWorkflowResponse) ProtoReflect added in v0.9.0 

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

func (*TriggerWorkflowResponse) Reset added in v0.9.0 

func (x *TriggerWorkflowResponse) Reset()

func (*TriggerWorkflowResponse) String added in v0.9.0 

func (x *TriggerWorkflowResponse) String() string

type UnimplementedWorkflowServiceServer 

type UnimplementedWorkflowServiceServer struct {
}

UnimplementedWorkflowServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedWorkflowServiceServer) PutRateLimit added in v0.19.0 

func (UnimplementedWorkflowServiceServer) PutRateLimit(context.Context, *PutRateLimitRequest) (*PutRateLimitResponse, error)

func (UnimplementedWorkflowServiceServer) PutWorkflow 

func (UnimplementedWorkflowServiceServer) PutWorkflow(context.Context, *PutWorkflowRequest) (*WorkflowVersion, error)

func (UnimplementedWorkflowServiceServer) ScheduleWorkflow 

func (UnimplementedWorkflowServiceServer) ScheduleWorkflow(context.Context, *ScheduleWorkflowRequest) (*WorkflowVersion, error)

func (UnimplementedWorkflowServiceServer) TriggerWorkflow added in v0.9.0 

func (UnimplementedWorkflowServiceServer) TriggerWorkflow(context.Context, *TriggerWorkflowRequest) (*TriggerWorkflowResponse, error)

type UnsafeWorkflowServiceServer 

type UnsafeWorkflowServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeWorkflowServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WorkflowServiceServer will result in compilation errors.

type WorkflowConcurrencyOpts added in v0.8.0 

type WorkflowConcurrencyOpts struct {
	Action        string                   `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"`                   // (required) the action id for getting the concurrency group
	MaxRuns       int32                    `protobuf:"varint,2,opt,name=max_runs,json=maxRuns,proto3" json:"max_runs,omitempty"` // (optional) the maximum number of concurrent workflow runs, default 1
	LimitStrategy ConcurrencyLimitStrategy ``                                                                                    // (optional) the strategy to use when the concurrency limit is reached, default CANCEL_IN_PROGRESS
	/* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*WorkflowConcurrencyOpts) Descriptor deprecated added in v0.8.0 

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

Deprecated: Use WorkflowConcurrencyOpts.ProtoReflect.Descriptor instead.

func (*WorkflowConcurrencyOpts) GetAction added in v0.8.0 

func (x *WorkflowConcurrencyOpts) GetAction() string

func (*WorkflowConcurrencyOpts) GetLimitStrategy added in v0.8.0 

func (x *WorkflowConcurrencyOpts) GetLimitStrategy() ConcurrencyLimitStrategy

func (*WorkflowConcurrencyOpts) GetMaxRuns added in v0.8.0 

func (x *WorkflowConcurrencyOpts) GetMaxRuns() int32

func (*WorkflowConcurrencyOpts) ProtoMessage added in v0.8.0 

func (*WorkflowConcurrencyOpts) ProtoMessage()

func (*WorkflowConcurrencyOpts) ProtoReflect added in v0.8.0 

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

func (*WorkflowConcurrencyOpts) Reset added in v0.8.0 

func (x *WorkflowConcurrencyOpts) Reset()

func (*WorkflowConcurrencyOpts) String added in v0.8.0 

func (x *WorkflowConcurrencyOpts) String() string

type WorkflowServiceClient 

type WorkflowServiceClient interface {
	PutWorkflow(ctx context.Context, in *PutWorkflowRequest, opts ...grpc.CallOption) (*WorkflowVersion, error)
	ScheduleWorkflow(ctx context.Context, in *ScheduleWorkflowRequest, opts ...grpc.CallOption) (*WorkflowVersion, error)
	TriggerWorkflow(ctx context.Context, in *TriggerWorkflowRequest, opts ...grpc.CallOption) (*TriggerWorkflowResponse, error)
	PutRateLimit(ctx context.Context, in *PutRateLimitRequest, opts ...grpc.CallOption) (*PutRateLimitResponse, error)
}

WorkflowServiceClient is the client API for WorkflowService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewWorkflowServiceClient 

func NewWorkflowServiceClient(cc grpc.ClientConnInterface) WorkflowServiceClient

type WorkflowServiceServer 

type WorkflowServiceServer interface {
	PutWorkflow(context.Context, *PutWorkflowRequest) (*WorkflowVersion, error)
	ScheduleWorkflow(context.Context, *ScheduleWorkflowRequest) (*WorkflowVersion, error)
	TriggerWorkflow(context.Context, *TriggerWorkflowRequest) (*TriggerWorkflowResponse, error)
	PutRateLimit(context.Context, *PutRateLimitRequest) (*PutRateLimitResponse, error)
	// contains filtered or unexported methods
}

WorkflowServiceServer is the server API for WorkflowService service. All implementations must embed UnimplementedWorkflowServiceServer for forward compatibility

type WorkflowTriggerCronRef 

type WorkflowTriggerCronRef struct {
	ParentId string `protobuf:"bytes,1,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"`
	Cron     string `protobuf:"bytes,2,opt,name=cron,proto3" json:"cron,omitempty"`
	// contains filtered or unexported fields
}

WorkflowTriggerCronRef represents the WorkflowTriggerCronRef model.

func (*WorkflowTriggerCronRef) Descriptor deprecated 

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

Deprecated: Use WorkflowTriggerCronRef.ProtoReflect.Descriptor instead.

func (*WorkflowTriggerCronRef) GetCron 

func (x *WorkflowTriggerCronRef) GetCron() string

func (*WorkflowTriggerCronRef) GetParentId 

func (x *WorkflowTriggerCronRef) GetParentId() string

func (*WorkflowTriggerCronRef) ProtoMessage 

func (*WorkflowTriggerCronRef) ProtoMessage()

func (*WorkflowTriggerCronRef) ProtoReflect 

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

func (*WorkflowTriggerCronRef) Reset 

func (x *WorkflowTriggerCronRef) Reset()

func (*WorkflowTriggerCronRef) String 

func (x *WorkflowTriggerCronRef) String() string

type WorkflowTriggerEventRef 

type WorkflowTriggerEventRef struct {
	ParentId string `protobuf:"bytes,1,opt,name=parent_id,json=parentId,proto3" json:"parent_id,omitempty"`
	EventKey string `protobuf:"bytes,2,opt,name=event_key,json=eventKey,proto3" json:"event_key,omitempty"`
	// contains filtered or unexported fields
}

WorkflowTriggerEventRef represents the WorkflowTriggerEventRef model.

func (*WorkflowTriggerEventRef) Descriptor deprecated 

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

Deprecated: Use WorkflowTriggerEventRef.ProtoReflect.Descriptor instead.

func (*WorkflowTriggerEventRef) GetEventKey 

func (x *WorkflowTriggerEventRef) GetEventKey() string

func (*WorkflowTriggerEventRef) GetParentId 

func (x *WorkflowTriggerEventRef) GetParentId() string

func (*WorkflowTriggerEventRef) ProtoMessage 

func (*WorkflowTriggerEventRef) ProtoMessage()

func (*WorkflowTriggerEventRef) ProtoReflect 

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

func (*WorkflowTriggerEventRef) Reset 

func (x *WorkflowTriggerEventRef) Reset()

func (*WorkflowTriggerEventRef) String 

func (x *WorkflowTriggerEventRef) String() string

type WorkflowVersion 

type WorkflowVersion struct {
	Id         string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	CreatedAt  *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt  *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	Version    string                 `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	Order      int32                  `protobuf:"varint,6,opt,name=order,proto3" json:"order,omitempty"`
	WorkflowId string                 `protobuf:"bytes,7,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	// contains filtered or unexported fields
}

WorkflowVersion represents the WorkflowVersion model.

func (*WorkflowVersion) Descriptor deprecated 

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

Deprecated: Use WorkflowVersion.ProtoReflect.Descriptor instead.

func (*WorkflowVersion) GetCreatedAt 

func (x *WorkflowVersion) GetCreatedAt() *timestamppb.Timestamp

func (*WorkflowVersion) GetId 

func (x *WorkflowVersion) GetId() string

func (*WorkflowVersion) GetOrder 

func (x *WorkflowVersion) GetOrder() int32

func (*WorkflowVersion) GetUpdatedAt 

func (x *WorkflowVersion) GetUpdatedAt() *timestamppb.Timestamp

func (*WorkflowVersion) GetVersion 

func (x *WorkflowVersion) GetVersion() string

func (*WorkflowVersion) GetWorkflowId 

func (x *WorkflowVersion) GetWorkflowId() string

func (*WorkflowVersion) ProtoMessage 

func (*WorkflowVersion) ProtoMessage()

func (*WorkflowVersion) ProtoReflect 

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

func (*WorkflowVersion) Reset 

func (x *WorkflowVersion) Reset()

func (*WorkflowVersion) String 

func (x *WorkflowVersion) 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.