contracts

package
v0.2.0-alpha.5 Latest Latest
Warning

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

Go to latest
Published: Dec 28, 2023 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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: "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 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 (*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
	// 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) GetReadableId

func (x *CreateWorkflowStepOpts) GetReadableId() string

func (*CreateWorkflowStepOpts) GetTimeout

func (x *CreateWorkflowStepOpts) GetTimeout() 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
	Jobs          []*CreateWorkflowJobOpts `protobuf:"bytes,6,rep,name=jobs,proto3" json:"jobs,omitempty"`                                        // (required) the workflow jobs
	// 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) 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 (*CreateWorkflowVersionOpts) GetName

func (x *CreateWorkflowVersionOpts) GetName() string

func (*CreateWorkflowVersionOpts) GetVersion

func (x *CreateWorkflowVersionOpts) GetVersion() string

func (*CreateWorkflowVersionOpts) ProtoMessage

func (*CreateWorkflowVersionOpts) ProtoMessage()

func (*CreateWorkflowVersionOpts) ProtoReflect

func (*CreateWorkflowVersionOpts) Reset

func (x *CreateWorkflowVersionOpts) Reset()

func (*CreateWorkflowVersionOpts) String

func (x *CreateWorkflowVersionOpts) String() string

type DeleteWorkflowRequest

type DeleteWorkflowRequest struct {
	TenantId   string `protobuf:"bytes,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	WorkflowId string `protobuf:"bytes,2,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) GetTenantId

func (x *DeleteWorkflowRequest) GetTenantId() string

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 {
	TenantId string `protobuf:"bytes,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	Name     string `protobuf:"bytes,2,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) GetTenantId

func (x *GetWorkflowByNameRequest) GetTenantId() 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 {
	TenantId string `protobuf:"bytes,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	EventKey string `protobuf:"bytes,2,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) GetTenantId

func (x *ListWorkflowsForEventRequest) GetTenantId() string

func (*ListWorkflowsForEventRequest) ProtoMessage

func (*ListWorkflowsForEventRequest) ProtoMessage()

func (*ListWorkflowsForEventRequest) ProtoReflect

func (*ListWorkflowsForEventRequest) Reset

func (x *ListWorkflowsForEventRequest) Reset()

func (*ListWorkflowsForEventRequest) String

type ListWorkflowsRequest

type ListWorkflowsRequest struct {
	TenantId string `protobuf:"bytes,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	// 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) GetTenantId

func (x *ListWorkflowsRequest) GetTenantId() string

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 {
	TenantId string                     `protobuf:"bytes,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	Opts     *CreateWorkflowVersionOpts `protobuf:"bytes,2,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 (*PutWorkflowRequest) GetTenantId

func (x *PutWorkflowRequest) GetTenantId() string

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 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
	NextId     string                  `protobuf:"bytes,10,opt,name=next_id,json=nextId,proto3" json:"next_id,omitempty"` // Optional
	// 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) 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) GetNextId

func (x *Step) GetNextId() 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 UnimplementedWorkflowServiceServer

type UnimplementedWorkflowServiceServer struct {
}

UnimplementedWorkflowServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedWorkflowServiceServer) DeleteWorkflow

func (UnimplementedWorkflowServiceServer) GetWorkflowByName

func (UnimplementedWorkflowServiceServer) ListWorkflows

func (UnimplementedWorkflowServiceServer) ListWorkflowsForEvent

func (UnimplementedWorkflowServiceServer) PutWorkflow

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 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)
	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.

type WorkflowServiceServer

type WorkflowServiceServer interface {
	ListWorkflows(context.Context, *ListWorkflowsRequest) (*ListWorkflowsResponse, error)
	PutWorkflow(context.Context, *PutWorkflowRequest) (*WorkflowVersion, 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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL