contracts

package
v0.11.0 Latest Latest
Warning

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

 Go to latest Published: Feb 19, 2024 License: MIT Imports: 10 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",
	}
	ConcurrencyLimitStrategy_value = map[string]int32{
		"CANCEL_IN_PROGRESS": 0,
		"DROP_NEWEST":        1,
		"QUEUE_NEWEST":       2,
	}
)

Enum value maps for ConcurrencyLimitStrategy.

View Source 
var File_workflows_proto protoreflect.FileDescriptor
View Source 
var WorkflowService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "WorkflowService",
	HandlerType: (*WorkflowServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListWorkflows",
			Handler:    _WorkflowService_ListWorkflows_Handler,
		},
		{
			MethodName: "PutWorkflow",
			Handler:    _WorkflowService_PutWorkflow_Handler,
		},
		{
			MethodName: "ScheduleWorkflow",
			Handler:    _WorkflowService_ScheduleWorkflow_Handler,
		},
		{
			MethodName: "TriggerWorkflow",
			Handler:    _WorkflowService_TriggerWorkflow_Handler,
		},
		{
			MethodName: "GetWorkflowByName",
			Handler:    _WorkflowService_GetWorkflowByName_Handler,
		},
		{
			MethodName: "ListWorkflowsForEvent",
			Handler:    _WorkflowService_ListWorkflowsForEvent_Handler,
		},
		{
			MethodName: "DeleteWorkflow",
			Handler:    _WorkflowService_DeleteWorkflow_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
)

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 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
	Timeout     string                    `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"`         // (optional) the job timeout
	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) GetTimeout 

func (x *CreateWorkflowJobOpts) GetTimeout() string

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
	// 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) 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
	// 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) 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) 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 DeleteWorkflowRequest 

type DeleteWorkflowRequest struct {
	WorkflowId string `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use DeleteWorkflowRequest.ProtoReflect.Descriptor instead.

func (*DeleteWorkflowRequest) GetWorkflowId 

func (x *DeleteWorkflowRequest) GetWorkflowId() string

func (*DeleteWorkflowRequest) ProtoMessage 

func (*DeleteWorkflowRequest) ProtoMessage()

func (*DeleteWorkflowRequest) ProtoReflect 

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

func (*DeleteWorkflowRequest) Reset 

func (x *DeleteWorkflowRequest) Reset()

func (*DeleteWorkflowRequest) String 

func (x *DeleteWorkflowRequest) String() string

type GetWorkflowByNameRequest 

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

func (*GetWorkflowByNameRequest) Descriptor deprecated 

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

Deprecated: Use GetWorkflowByNameRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowByNameRequest) GetName 

func (x *GetWorkflowByNameRequest) GetName() string

func (*GetWorkflowByNameRequest) ProtoMessage 

func (*GetWorkflowByNameRequest) ProtoMessage()

func (*GetWorkflowByNameRequest) ProtoReflect 

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

func (*GetWorkflowByNameRequest) Reset 

func (x *GetWorkflowByNameRequest) Reset()

func (*GetWorkflowByNameRequest) String 

func (x *GetWorkflowByNameRequest) String() string

type Job 

type Job 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"`
	TenantId          string                  `protobuf:"bytes,5,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	WorkflowVersionId string                  `protobuf:"bytes,6,opt,name=workflow_version_id,json=workflowVersionId,proto3" json:"workflow_version_id,omitempty"`
	Name              string                  `protobuf:"bytes,7,opt,name=name,proto3" json:"name,omitempty"`
	Description       *wrapperspb.StringValue `protobuf:"bytes,8,opt,name=description,proto3" json:"description,omitempty"` // Optional
	Steps             []*Step                 `protobuf:"bytes,9,rep,name=steps,proto3" json:"steps,omitempty"`
	Timeout           *wrapperspb.StringValue `protobuf:"bytes,10,opt,name=timeout,proto3" json:"timeout,omitempty"` // Optional
	// contains filtered or unexported fields
}

Job represents the Job model.

func (*Job) Descriptor deprecated 

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetCreatedAt 

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

func (*Job) GetDescription 

func (x *Job) GetDescription() *wrapperspb.StringValue

func (*Job) GetId 

func (x *Job) GetId() string

func (*Job) GetName 

func (x *Job) GetName() string

func (*Job) GetSteps 

func (x *Job) GetSteps() []*Step

func (*Job) GetTenantId 

func (x *Job) GetTenantId() string

func (*Job) GetTimeout 

func (x *Job) GetTimeout() *wrapperspb.StringValue

func (*Job) GetUpdatedAt 

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

func (*Job) GetWorkflowVersionId 

func (x *Job) GetWorkflowVersionId() string

func (*Job) ProtoMessage 

func (*Job) ProtoMessage()

func (*Job) ProtoReflect 

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

func (*Job) Reset 

func (x *Job) Reset()

func (*Job) String 

func (x *Job) String() string

type ListWorkflowsForEventRequest 

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

ListWorkflowsForEventRequest is the request for ListWorkflowsForEvent.

func (*ListWorkflowsForEventRequest) Descriptor deprecated 

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

Deprecated: Use ListWorkflowsForEventRequest.ProtoReflect.Descriptor instead.

func (*ListWorkflowsForEventRequest) GetEventKey 

func (x *ListWorkflowsForEventRequest) GetEventKey() string

func (*ListWorkflowsForEventRequest) ProtoMessage 

func (*ListWorkflowsForEventRequest) ProtoMessage()

func (*ListWorkflowsForEventRequest) ProtoReflect 

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

func (*ListWorkflowsForEventRequest) Reset 

func (x *ListWorkflowsForEventRequest) Reset()

func (*ListWorkflowsForEventRequest) String 

func (x *ListWorkflowsForEventRequest) 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 ListWorkflowsResponse 

type ListWorkflowsResponse struct {
	Workflows []*Workflow `protobuf:"bytes,1,rep,name=workflows,proto3" json:"workflows,omitempty"`
	// contains filtered or unexported fields
}

ListWorkflowsResponse is the response for ListWorkflows.

func (*ListWorkflowsResponse) Descriptor deprecated 

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

Deprecated: Use ListWorkflowsResponse.ProtoReflect.Descriptor instead.

func (*ListWorkflowsResponse) GetWorkflows 

func (x *ListWorkflowsResponse) GetWorkflows() []*Workflow

func (*ListWorkflowsResponse) ProtoMessage 

func (*ListWorkflowsResponse) ProtoMessage()

func (*ListWorkflowsResponse) ProtoReflect 

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

func (*ListWorkflowsResponse) Reset 

func (x *ListWorkflowsResponse) Reset()

func (*ListWorkflowsResponse) String 

func (x *ListWorkflowsResponse) 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 ScheduleWorkflowRequest 

type ScheduleWorkflowRequest struct {
	WorkflowId string                   `protobuf:"bytes,1,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,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"`
	// contains filtered or unexported fields
}

func (*ScheduleWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use ScheduleWorkflowRequest.ProtoReflect.Descriptor instead.

func (*ScheduleWorkflowRequest) GetInput 

func (x *ScheduleWorkflowRequest) GetInput() string

func (*ScheduleWorkflowRequest) GetSchedules 

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

func (*ScheduleWorkflowRequest) GetWorkflowId 

func (x *ScheduleWorkflowRequest) GetWorkflowId() string

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 Step 

type Step 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"`
	ReadableId *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=readable_id,json=readableId,proto3" json:"readable_id,omitempty"` // Optional
	TenantId   string                  `protobuf:"bytes,6,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	JobId      string                  `protobuf:"bytes,7,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Action     string                  `protobuf:"bytes,8,opt,name=action,proto3" json:"action,omitempty"`
	Timeout    *wrapperspb.StringValue `protobuf:"bytes,9,opt,name=timeout,proto3" json:"timeout,omitempty"` // Optional
	Parents    []string                `protobuf:"bytes,10,rep,name=parents,proto3" json:"parents,omitempty"`
	Children   []string                `protobuf:"bytes,11,rep,name=children,proto3" json:"children,omitempty"`
	// contains filtered or unexported fields
}

Step represents the Step model.

func (*Step) Descriptor deprecated 

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

Deprecated: Use Step.ProtoReflect.Descriptor instead.

func (*Step) GetAction 

func (x *Step) GetAction() string

func (*Step) GetChildren 

func (x *Step) GetChildren() []string

func (*Step) GetCreatedAt 

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

func (*Step) GetId 

func (x *Step) GetId() string

func (*Step) GetJobId 

func (x *Step) GetJobId() string

func (*Step) GetParents 

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

func (*Step) GetReadableId 

func (x *Step) GetReadableId() *wrapperspb.StringValue

func (*Step) GetTenantId 

func (x *Step) GetTenantId() string

func (*Step) GetTimeout 

func (x *Step) GetTimeout() *wrapperspb.StringValue

func (*Step) GetUpdatedAt 

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

func (*Step) ProtoMessage 

func (*Step) ProtoMessage()

func (*Step) ProtoReflect 

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

func (*Step) Reset 

func (x *Step) Reset()

func (*Step) String 

func (x *Step) 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"`
	// 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) 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) 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) DeleteWorkflow 

func (UnimplementedWorkflowServiceServer) DeleteWorkflow(context.Context, *DeleteWorkflowRequest) (*Workflow, error)

func (UnimplementedWorkflowServiceServer) GetWorkflowByName 

func (UnimplementedWorkflowServiceServer) GetWorkflowByName(context.Context, *GetWorkflowByNameRequest) (*Workflow, error)

func (UnimplementedWorkflowServiceServer) ListWorkflows 

func (UnimplementedWorkflowServiceServer) ListWorkflows(context.Context, *ListWorkflowsRequest) (*ListWorkflowsResponse, error)

func (UnimplementedWorkflowServiceServer) ListWorkflowsForEvent 

func (UnimplementedWorkflowServiceServer) ListWorkflowsForEvent(context.Context, *ListWorkflowsForEventRequest) (*ListWorkflowsResponse, 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 Workflow 

type Workflow 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"`
	TenantId    string                  `protobuf:"bytes,5,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	Name        string                  `protobuf:"bytes,6,opt,name=name,proto3" json:"name,omitempty"`
	Description *wrapperspb.StringValue `protobuf:"bytes,7,opt,name=description,proto3" json:"description,omitempty"` // Optional
	Versions    []*WorkflowVersion      `protobuf:"bytes,8,rep,name=versions,proto3" json:"versions,omitempty"`
	// contains filtered or unexported fields
}

Workflow represents the Workflow model.

func (*Workflow) Descriptor deprecated 

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

Deprecated: Use Workflow.ProtoReflect.Descriptor instead.

func (*Workflow) GetCreatedAt 

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

func (*Workflow) GetDescription 

func (x *Workflow) GetDescription() *wrapperspb.StringValue

func (*Workflow) GetId 

func (x *Workflow) GetId() string

func (*Workflow) GetName 

func (x *Workflow) GetName() string

func (*Workflow) GetTenantId 

func (x *Workflow) GetTenantId() string

func (*Workflow) GetUpdatedAt 

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

func (*Workflow) GetVersions 

func (x *Workflow) GetVersions() []*WorkflowVersion

func (*Workflow) ProtoMessage 

func (*Workflow) ProtoMessage()

func (*Workflow) ProtoReflect 

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

func (*Workflow) Reset 

func (x *Workflow) Reset()

func (*Workflow) String 

func (x *Workflow) String() string

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 {
	ListWorkflows(ctx context.Context, in *ListWorkflowsRequest, opts ...grpc.CallOption) (*ListWorkflowsResponse, error)
	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)
	GetWorkflowByName(ctx context.Context, in *GetWorkflowByNameRequest, opts ...grpc.CallOption) (*Workflow, error)
	ListWorkflowsForEvent(ctx context.Context, in *ListWorkflowsForEventRequest, opts ...grpc.CallOption) (*ListWorkflowsResponse, error)
	DeleteWorkflow(ctx context.Context, in *DeleteWorkflowRequest, opts ...grpc.CallOption) (*Workflow, 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 {
	ListWorkflows(context.Context, *ListWorkflowsRequest) (*ListWorkflowsResponse, error)
	PutWorkflow(context.Context, *PutWorkflowRequest) (*WorkflowVersion, error)
	ScheduleWorkflow(context.Context, *ScheduleWorkflowRequest) (*WorkflowVersion, error)
	TriggerWorkflow(context.Context, *TriggerWorkflowRequest) (*TriggerWorkflowResponse, error)
	GetWorkflowByName(context.Context, *GetWorkflowByNameRequest) (*Workflow, error)
	ListWorkflowsForEvent(context.Context, *ListWorkflowsForEventRequest) (*ListWorkflowsResponse, error)
	DeleteWorkflow(context.Context, *DeleteWorkflowRequest) (*Workflow, 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 WorkflowTriggers 

type WorkflowTriggers 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"`
	WorkflowVersionId string                     `protobuf:"bytes,5,opt,name=workflow_version_id,json=workflowVersionId,proto3" json:"workflow_version_id,omitempty"`
	TenantId          string                     `protobuf:"bytes,6,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	Events            []*WorkflowTriggerEventRef `protobuf:"bytes,7,rep,name=events,proto3" json:"events,omitempty"`
	Crons             []*WorkflowTriggerCronRef  `protobuf:"bytes,8,rep,name=crons,proto3" json:"crons,omitempty"`
	// contains filtered or unexported fields
}

WorkflowTriggers represents the WorkflowTriggers model.

func (*WorkflowTriggers) Descriptor deprecated 

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

Deprecated: Use WorkflowTriggers.ProtoReflect.Descriptor instead.

func (*WorkflowTriggers) GetCreatedAt 

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

func (*WorkflowTriggers) GetCrons 

func (x *WorkflowTriggers) GetCrons() []*WorkflowTriggerCronRef

func (*WorkflowTriggers) GetEvents 

func (x *WorkflowTriggers) GetEvents() []*WorkflowTriggerEventRef

func (*WorkflowTriggers) GetId 

func (x *WorkflowTriggers) GetId() string

func (*WorkflowTriggers) GetTenantId 

func (x *WorkflowTriggers) GetTenantId() string

func (*WorkflowTriggers) GetUpdatedAt 

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

func (*WorkflowTriggers) GetWorkflowVersionId 

func (x *WorkflowTriggers) GetWorkflowVersionId() string

func (*WorkflowTriggers) ProtoMessage 

func (*WorkflowTriggers) ProtoMessage()

func (*WorkflowTriggers) ProtoReflect 

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

func (*WorkflowTriggers) Reset 

func (x *WorkflowTriggers) Reset()

func (*WorkflowTriggers) String 

func (x *WorkflowTriggers) 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"`
	Triggers   *WorkflowTriggers      `protobuf:"bytes,8,opt,name=triggers,proto3" json:"triggers,omitempty"`
	Jobs       []*Job                 `protobuf:"bytes,9,rep,name=jobs,proto3" json:"jobs,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) GetJobs 

func (x *WorkflowVersion) GetJobs() []*Job

func (*WorkflowVersion) GetOrder 

func (x *WorkflowVersion) GetOrder() int32

func (*WorkflowVersion) GetTriggers 

func (x *WorkflowVersion) GetTriggers() *WorkflowTriggers

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.