contracts

package
v0.3.0-alpha.2 Latest Latest
Warning

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

 Go to latest Published: Jan 2, 2024 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 (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
	// 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 (x *CreateWorkflowVersionOpts) GetJobs() []*CreateWorkflowJobOpts

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 (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 {
	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 (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 {
	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 (x *PutWorkflowRequest) GetOpts() *CreateWorkflowVersionOpts

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

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.

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