workflowsv1connect

package
v0.0.1 Latest Latest
Warning

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

 Go to latest Published: May 23, 2025 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// AutomationServiceListStorageLocationsProcedure is the fully-qualified name of the
	// AutomationService's ListStorageLocations RPC.
	AutomationServiceListStorageLocationsProcedure = "/workflows.v1.AutomationService/ListStorageLocations"
	// AutomationServiceGetStorageLocationProcedure is the fully-qualified name of the
	// AutomationService's GetStorageLocation RPC.
	AutomationServiceGetStorageLocationProcedure = "/workflows.v1.AutomationService/GetStorageLocation"
	// AutomationServiceCreateStorageLocationProcedure is the fully-qualified name of the
	// AutomationService's CreateStorageLocation RPC.
	AutomationServiceCreateStorageLocationProcedure = "/workflows.v1.AutomationService/CreateStorageLocation"
	// AutomationServiceDeleteStorageLocationProcedure is the fully-qualified name of the
	// AutomationService's DeleteStorageLocation RPC.
	AutomationServiceDeleteStorageLocationProcedure = "/workflows.v1.AutomationService/DeleteStorageLocation"
	// AutomationServiceListAutomationsProcedure is the fully-qualified name of the AutomationService's
	// ListAutomations RPC.
	AutomationServiceListAutomationsProcedure = "/workflows.v1.AutomationService/ListAutomations"
	// AutomationServiceGetAutomationProcedure is the fully-qualified name of the AutomationService's
	// GetAutomation RPC.
	AutomationServiceGetAutomationProcedure = "/workflows.v1.AutomationService/GetAutomation"
	// AutomationServiceCreateAutomationProcedure is the fully-qualified name of the AutomationService's
	// CreateAutomation RPC.
	AutomationServiceCreateAutomationProcedure = "/workflows.v1.AutomationService/CreateAutomation"
	// AutomationServiceUpdateAutomationProcedure is the fully-qualified name of the AutomationService's
	// UpdateAutomation RPC.
	AutomationServiceUpdateAutomationProcedure = "/workflows.v1.AutomationService/UpdateAutomation"
	// AutomationServiceDeleteAutomationProcedure is the fully-qualified name of the AutomationService's
	// DeleteAutomation RPC.
	AutomationServiceDeleteAutomationProcedure = "/workflows.v1.AutomationService/DeleteAutomation"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// JobServiceSubmitJobProcedure is the fully-qualified name of the JobService's SubmitJob RPC.
	JobServiceSubmitJobProcedure = "/workflows.v1.JobService/SubmitJob"
	// JobServiceGetJobProcedure is the fully-qualified name of the JobService's GetJob RPC.
	JobServiceGetJobProcedure = "/workflows.v1.JobService/GetJob"
	// JobServiceRetryJobProcedure is the fully-qualified name of the JobService's RetryJob RPC.
	JobServiceRetryJobProcedure = "/workflows.v1.JobService/RetryJob"
	// JobServiceCancelJobProcedure is the fully-qualified name of the JobService's CancelJob RPC.
	JobServiceCancelJobProcedure = "/workflows.v1.JobService/CancelJob"
	// JobServiceVisualizeJobProcedure is the fully-qualified name of the JobService's VisualizeJob RPC.
	JobServiceVisualizeJobProcedure = "/workflows.v1.JobService/VisualizeJob"
	// JobServiceListJobsProcedure is the fully-qualified name of the JobService's ListJobs RPC.
	JobServiceListJobsProcedure = "/workflows.v1.JobService/ListJobs"
	// JobServiceFilterJobsProcedure is the fully-qualified name of the JobService's FilterJobs RPC.
	JobServiceFilterJobsProcedure = "/workflows.v1.JobService/FilterJobs"
	// JobServiceGetJobPrototypeProcedure is the fully-qualified name of the JobService's
	// GetJobPrototype RPC.
	JobServiceGetJobPrototypeProcedure = "/workflows.v1.JobService/GetJobPrototype"
	// JobServiceCloneJobProcedure is the fully-qualified name of the JobService's CloneJob RPC.
	JobServiceCloneJobProcedure = "/workflows.v1.JobService/CloneJob"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// TaskServiceNextTaskProcedure is the fully-qualified name of the TaskService's NextTask RPC.
	TaskServiceNextTaskProcedure = "/workflows.v1.TaskService/NextTask"
	// TaskServiceTaskFailedProcedure is the fully-qualified name of the TaskService's TaskFailed RPC.
	TaskServiceTaskFailedProcedure = "/workflows.v1.TaskService/TaskFailed"
	// TaskServiceExtendTaskLeaseProcedure is the fully-qualified name of the TaskService's
	// ExtendTaskLease RPC.
	TaskServiceExtendTaskLeaseProcedure = "/workflows.v1.TaskService/ExtendTaskLease"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// WorkflowsServiceCreateClusterProcedure is the fully-qualified name of the WorkflowsService's
	// CreateCluster RPC.
	WorkflowsServiceCreateClusterProcedure = "/workflows.v1.WorkflowsService/CreateCluster"
	// WorkflowsServiceGetClusterProcedure is the fully-qualified name of the WorkflowsService's
	// GetCluster RPC.
	WorkflowsServiceGetClusterProcedure = "/workflows.v1.WorkflowsService/GetCluster"
	// WorkflowsServiceDeleteClusterProcedure is the fully-qualified name of the WorkflowsService's
	// DeleteCluster RPC.
	WorkflowsServiceDeleteClusterProcedure = "/workflows.v1.WorkflowsService/DeleteCluster"
	// WorkflowsServiceListClustersProcedure is the fully-qualified name of the WorkflowsService's
	// ListClusters RPC.
	WorkflowsServiceListClustersProcedure = "/workflows.v1.WorkflowsService/ListClusters"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// AutomationServiceName is the fully-qualified name of the AutomationService service.
	AutomationServiceName = "workflows.v1.AutomationService"
)
View Source 
const (
	// DiagramServiceName is the fully-qualified name of the DiagramService service.
	DiagramServiceName = "workflows.v1.DiagramService"
)
View Source 
const (
	// DiagramServiceRenderProcedure is the fully-qualified name of the DiagramService's Render RPC.
	DiagramServiceRenderProcedure = "/workflows.v1.DiagramService/Render"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// JobServiceName is the fully-qualified name of the JobService service.
	JobServiceName = "workflows.v1.JobService"
)
View Source 
const (
	// TaskServiceName is the fully-qualified name of the TaskService service.
	TaskServiceName = "workflows.v1.TaskService"
)
View Source 
const (
	// WorkflowsServiceName is the fully-qualified name of the WorkflowsService service.
	WorkflowsServiceName = "workflows.v1.WorkflowsService"
)

Variables

This section is empty.

Functions

func NewAutomationServiceHandler 

func NewAutomationServiceHandler(svc AutomationServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewAutomationServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewDiagramServiceHandler 

func NewDiagramServiceHandler(svc DiagramServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewDiagramServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewJobServiceHandler 

func NewJobServiceHandler(svc JobServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewJobServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewTaskServiceHandler 

func NewTaskServiceHandler(svc TaskServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewTaskServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewWorkflowsServiceHandler 

func NewWorkflowsServiceHandler(svc WorkflowsServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewWorkflowsServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

Types

type AutomationServiceClient 

type AutomationServiceClient interface {
	// ListStorageLocations lists all the storage buckets that are available for use as bucket triggers.
	ListStorageLocations(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[v1.StorageLocations], error)
	// GetStorageLocation gets a storage location by its ID.
	GetStorageLocation(context.Context, *connect.Request[v1.UUID]) (*connect.Response[v1.StorageLocation], error)
	// CreateStorageLocation creates a new storage bucket.
	CreateStorageLocation(context.Context, *connect.Request[v1.StorageLocation]) (*connect.Response[v1.StorageLocation], error)
	// DeleteStorageLocation deletes a storage location.
	DeleteStorageLocation(context.Context, *connect.Request[v1.UUID]) (*connect.Response[emptypb.Empty], error)
	// ListAutomations lists all the automations that are currently registered in a namespace.
	ListAutomations(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[v1.Automations], error)
	// GetAutomation gets an automation by its ID.
	GetAutomation(context.Context, *connect.Request[v1.UUID]) (*connect.Response[v1.AutomationPrototype], error)
	// CreateAutomation creates a new automation in a namespace.
	CreateAutomation(context.Context, *connect.Request[v1.AutomationPrototype]) (*connect.Response[v1.AutomationPrototype], error)
	// UpdateAutomation updates an automation in a namespace.
	UpdateAutomation(context.Context, *connect.Request[v1.AutomationPrototype]) (*connect.Response[v1.AutomationPrototype], error)
	// DeleteAutomation deletes an automation from a namespace.
	DeleteAutomation(context.Context, *connect.Request[v1.DeleteAutomationRequest]) (*connect.Response[emptypb.Empty], error)
}

AutomationServiceClient is a client for the workflows.v1.AutomationService service.

func NewAutomationServiceClient 

func NewAutomationServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) AutomationServiceClient

NewAutomationServiceClient constructs a client for the workflows.v1.AutomationService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type AutomationServiceHandler 

type AutomationServiceHandler interface {
	// ListStorageLocations lists all the storage buckets that are available for use as bucket triggers.
	ListStorageLocations(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[v1.StorageLocations], error)
	// GetStorageLocation gets a storage location by its ID.
	GetStorageLocation(context.Context, *connect.Request[v1.UUID]) (*connect.Response[v1.StorageLocation], error)
	// CreateStorageLocation creates a new storage bucket.
	CreateStorageLocation(context.Context, *connect.Request[v1.StorageLocation]) (*connect.Response[v1.StorageLocation], error)
	// DeleteStorageLocation deletes a storage location.
	DeleteStorageLocation(context.Context, *connect.Request[v1.UUID]) (*connect.Response[emptypb.Empty], error)
	// ListAutomations lists all the automations that are currently registered in a namespace.
	ListAutomations(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[v1.Automations], error)
	// GetAutomation gets an automation by its ID.
	GetAutomation(context.Context, *connect.Request[v1.UUID]) (*connect.Response[v1.AutomationPrototype], error)
	// CreateAutomation creates a new automation in a namespace.
	CreateAutomation(context.Context, *connect.Request[v1.AutomationPrototype]) (*connect.Response[v1.AutomationPrototype], error)
	// UpdateAutomation updates an automation in a namespace.
	UpdateAutomation(context.Context, *connect.Request[v1.AutomationPrototype]) (*connect.Response[v1.AutomationPrototype], error)
	// DeleteAutomation deletes an automation from a namespace.
	DeleteAutomation(context.Context, *connect.Request[v1.DeleteAutomationRequest]) (*connect.Response[emptypb.Empty], error)
}

AutomationServiceHandler is an implementation of the workflows.v1.AutomationService service.

type DiagramServiceClient 

type DiagramServiceClient interface {
	Render(context.Context, *connect.Request[v1.RenderDiagramRequest]) (*connect.Response[v1.Diagram], error)
}

DiagramServiceClient is a client for the workflows.v1.DiagramService service.

func NewDiagramServiceClient 

func NewDiagramServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) DiagramServiceClient

NewDiagramServiceClient constructs a client for the workflows.v1.DiagramService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type DiagramServiceHandler 

type DiagramServiceHandler interface {
	Render(context.Context, *connect.Request[v1.RenderDiagramRequest]) (*connect.Response[v1.Diagram], error)
}

DiagramServiceHandler is an implementation of the workflows.v1.DiagramService service.

type JobServiceClient 

type JobServiceClient interface {
	SubmitJob(context.Context, *connect.Request[v1.SubmitJobRequest]) (*connect.Response[v1.Job], error)
	GetJob(context.Context, *connect.Request[v1.GetJobRequest]) (*connect.Response[v1.Job], error)
	RetryJob(context.Context, *connect.Request[v1.RetryJobRequest]) (*connect.Response[v1.RetryJobResponse], error)
	CancelJob(context.Context, *connect.Request[v1.CancelJobRequest]) (*connect.Response[v1.CancelJobResponse], error)
	VisualizeJob(context.Context, *connect.Request[v1.VisualizeJobRequest]) (*connect.Response[v1.Diagram], error)
	ListJobs(context.Context, *connect.Request[v1.ListJobsRequest]) (*connect.Response[v1.ListJobsResponse], error)
	FilterJobs(context.Context, *connect.Request[v1.FilterJobsRequest]) (*connect.Response[v1.ListJobsResponse], error)
	GetJobPrototype(context.Context, *connect.Request[v1.GetJobPrototypeRequest]) (*connect.Response[v1.GetJobPrototypeResponse], error)
	CloneJob(context.Context, *connect.Request[v1.CloneJobRequest]) (*connect.Response[v1.Job], error)
}

JobServiceClient is a client for the workflows.v1.JobService service.

func NewJobServiceClient 

func NewJobServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) JobServiceClient

NewJobServiceClient constructs a client for the workflows.v1.JobService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type JobServiceHandler 

type JobServiceHandler interface {
	SubmitJob(context.Context, *connect.Request[v1.SubmitJobRequest]) (*connect.Response[v1.Job], error)
	GetJob(context.Context, *connect.Request[v1.GetJobRequest]) (*connect.Response[v1.Job], error)
	RetryJob(context.Context, *connect.Request[v1.RetryJobRequest]) (*connect.Response[v1.RetryJobResponse], error)
	CancelJob(context.Context, *connect.Request[v1.CancelJobRequest]) (*connect.Response[v1.CancelJobResponse], error)
	VisualizeJob(context.Context, *connect.Request[v1.VisualizeJobRequest]) (*connect.Response[v1.Diagram], error)
	ListJobs(context.Context, *connect.Request[v1.ListJobsRequest]) (*connect.Response[v1.ListJobsResponse], error)
	FilterJobs(context.Context, *connect.Request[v1.FilterJobsRequest]) (*connect.Response[v1.ListJobsResponse], error)
	GetJobPrototype(context.Context, *connect.Request[v1.GetJobPrototypeRequest]) (*connect.Response[v1.GetJobPrototypeResponse], error)
	CloneJob(context.Context, *connect.Request[v1.CloneJobRequest]) (*connect.Response[v1.Job], error)
}

JobServiceHandler is an implementation of the workflows.v1.JobService service.

type TaskServiceClient 

type TaskServiceClient interface {
	// NextTask marks a task as computed and asks for the next task to run.
	// If no task marked as computed is sent, it is assumed that the task runner just started up or was idling so
	// the task server will send a task to run using a work-stealing algorithm.
	// If a task marked as computed is sent, the task server will send a next task to run using a depth first execution
	// algorithm, and only fall back to work-stealing if otherwise no tasks are available.
	// If the next_task_to_run field of the request is not set, a next task will never be returned, but a task
	// can still be marked as computed this way.
	NextTask(context.Context, *connect.Request[v1.NextTaskRequest]) (*connect.Response[v1.NextTaskResponse], error)
	// TaskFailed tells the task server that we have failed to compute a task.
	// The task server will then mark the task as queued or failed, depending on the retry policy,
	// and possibly cancel the job.
	// If a task runner wants to continue executing tasks, it should afterwards fetch a new one using GetTaskToRun.
	TaskFailed(context.Context, *connect.Request[v1.TaskFailedRequest]) (*connect.Response[v1.TaskStateResponse], error)
	// ExtendTaskLease is called by the task runner to extend the lease on a task.
	// On success, the response will contain the new lease expiration time.
	// If the task does not need to be extended, the response will be empty.
	ExtendTaskLease(context.Context, *connect.Request[v1.TaskLeaseRequest]) (*connect.Response[v1.TaskLease], error)
}

TaskServiceClient is a client for the workflows.v1.TaskService service.

func NewTaskServiceClient 

func NewTaskServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) TaskServiceClient

NewTaskServiceClient constructs a client for the workflows.v1.TaskService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type TaskServiceHandler 

type TaskServiceHandler interface {
	// NextTask marks a task as computed and asks for the next task to run.
	// If no task marked as computed is sent, it is assumed that the task runner just started up or was idling so
	// the task server will send a task to run using a work-stealing algorithm.
	// If a task marked as computed is sent, the task server will send a next task to run using a depth first execution
	// algorithm, and only fall back to work-stealing if otherwise no tasks are available.
	// If the next_task_to_run field of the request is not set, a next task will never be returned, but a task
	// can still be marked as computed this way.
	NextTask(context.Context, *connect.Request[v1.NextTaskRequest]) (*connect.Response[v1.NextTaskResponse], error)
	// TaskFailed tells the task server that we have failed to compute a task.
	// The task server will then mark the task as queued or failed, depending on the retry policy,
	// and possibly cancel the job.
	// If a task runner wants to continue executing tasks, it should afterwards fetch a new one using GetTaskToRun.
	TaskFailed(context.Context, *connect.Request[v1.TaskFailedRequest]) (*connect.Response[v1.TaskStateResponse], error)
	// ExtendTaskLease is called by the task runner to extend the lease on a task.
	// On success, the response will contain the new lease expiration time.
	// If the task does not need to be extended, the response will be empty.
	ExtendTaskLease(context.Context, *connect.Request[v1.TaskLeaseRequest]) (*connect.Response[v1.TaskLease], error)
}

TaskServiceHandler is an implementation of the workflows.v1.TaskService service.

type UnimplementedAutomationServiceHandler 

type UnimplementedAutomationServiceHandler struct{}

UnimplementedAutomationServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedAutomationServiceHandler) CreateAutomation 

func (UnimplementedAutomationServiceHandler) CreateAutomation(context.Context, *connect.Request[v1.AutomationPrototype]) (*connect.Response[v1.AutomationPrototype], error)

func (UnimplementedAutomationServiceHandler) CreateStorageLocation 

func (UnimplementedAutomationServiceHandler) CreateStorageLocation(context.Context, *connect.Request[v1.StorageLocation]) (*connect.Response[v1.StorageLocation], error)

func (UnimplementedAutomationServiceHandler) DeleteAutomation 

func (UnimplementedAutomationServiceHandler) DeleteAutomation(context.Context, *connect.Request[v1.DeleteAutomationRequest]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedAutomationServiceHandler) DeleteStorageLocation 

func (UnimplementedAutomationServiceHandler) DeleteStorageLocation(context.Context, *connect.Request[v1.UUID]) (*connect.Response[emptypb.Empty], error)

func (UnimplementedAutomationServiceHandler) GetAutomation 

func (UnimplementedAutomationServiceHandler) GetAutomation(context.Context, *connect.Request[v1.UUID]) (*connect.Response[v1.AutomationPrototype], error)

func (UnimplementedAutomationServiceHandler) GetStorageLocation 

func (UnimplementedAutomationServiceHandler) GetStorageLocation(context.Context, *connect.Request[v1.UUID]) (*connect.Response[v1.StorageLocation], error)

func (UnimplementedAutomationServiceHandler) ListAutomations 

func (UnimplementedAutomationServiceHandler) ListAutomations(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[v1.Automations], error)

func (UnimplementedAutomationServiceHandler) ListStorageLocations 

func (UnimplementedAutomationServiceHandler) ListStorageLocations(context.Context, *connect.Request[emptypb.Empty]) (*connect.Response[v1.StorageLocations], error)

func (UnimplementedAutomationServiceHandler) UpdateAutomation 

func (UnimplementedAutomationServiceHandler) UpdateAutomation(context.Context, *connect.Request[v1.AutomationPrototype]) (*connect.Response[v1.AutomationPrototype], error)

type UnimplementedDiagramServiceHandler 

type UnimplementedDiagramServiceHandler struct{}

UnimplementedDiagramServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedDiagramServiceHandler) Render 

func (UnimplementedDiagramServiceHandler) Render(context.Context, *connect.Request[v1.RenderDiagramRequest]) (*connect.Response[v1.Diagram], error)

type UnimplementedJobServiceHandler 

type UnimplementedJobServiceHandler struct{}

UnimplementedJobServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedJobServiceHandler) CancelJob 

func (UnimplementedJobServiceHandler) CancelJob(context.Context, *connect.Request[v1.CancelJobRequest]) (*connect.Response[v1.CancelJobResponse], error)

func (UnimplementedJobServiceHandler) CloneJob 

func (UnimplementedJobServiceHandler) CloneJob(context.Context, *connect.Request[v1.CloneJobRequest]) (*connect.Response[v1.Job], error)

func (UnimplementedJobServiceHandler) FilterJobs 

func (UnimplementedJobServiceHandler) FilterJobs(context.Context, *connect.Request[v1.FilterJobsRequest]) (*connect.Response[v1.ListJobsResponse], error)

func (UnimplementedJobServiceHandler) GetJob 

func (UnimplementedJobServiceHandler) GetJob(context.Context, *connect.Request[v1.GetJobRequest]) (*connect.Response[v1.Job], error)

func (UnimplementedJobServiceHandler) GetJobPrototype 

func (UnimplementedJobServiceHandler) GetJobPrototype(context.Context, *connect.Request[v1.GetJobPrototypeRequest]) (*connect.Response[v1.GetJobPrototypeResponse], error)

func (UnimplementedJobServiceHandler) ListJobs 

func (UnimplementedJobServiceHandler) ListJobs(context.Context, *connect.Request[v1.ListJobsRequest]) (*connect.Response[v1.ListJobsResponse], error)

func (UnimplementedJobServiceHandler) RetryJob 

func (UnimplementedJobServiceHandler) RetryJob(context.Context, *connect.Request[v1.RetryJobRequest]) (*connect.Response[v1.RetryJobResponse], error)

func (UnimplementedJobServiceHandler) SubmitJob 

func (UnimplementedJobServiceHandler) SubmitJob(context.Context, *connect.Request[v1.SubmitJobRequest]) (*connect.Response[v1.Job], error)

func (UnimplementedJobServiceHandler) VisualizeJob 

func (UnimplementedJobServiceHandler) VisualizeJob(context.Context, *connect.Request[v1.VisualizeJobRequest]) (*connect.Response[v1.Diagram], error)

type UnimplementedTaskServiceHandler 

type UnimplementedTaskServiceHandler struct{}

UnimplementedTaskServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedTaskServiceHandler) ExtendTaskLease 

func (UnimplementedTaskServiceHandler) ExtendTaskLease(context.Context, *connect.Request[v1.TaskLeaseRequest]) (*connect.Response[v1.TaskLease], error)

func (UnimplementedTaskServiceHandler) NextTask 

func (UnimplementedTaskServiceHandler) NextTask(context.Context, *connect.Request[v1.NextTaskRequest]) (*connect.Response[v1.NextTaskResponse], error)

func (UnimplementedTaskServiceHandler) TaskFailed 

func (UnimplementedTaskServiceHandler) TaskFailed(context.Context, *connect.Request[v1.TaskFailedRequest]) (*connect.Response[v1.TaskStateResponse], error)

type UnimplementedWorkflowsServiceHandler 

type UnimplementedWorkflowsServiceHandler struct{}

UnimplementedWorkflowsServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedWorkflowsServiceHandler) CreateCluster 

func (UnimplementedWorkflowsServiceHandler) CreateCluster(context.Context, *connect.Request[v1.CreateClusterRequest]) (*connect.Response[v1.Cluster], error)

func (UnimplementedWorkflowsServiceHandler) DeleteCluster 

func (UnimplementedWorkflowsServiceHandler) DeleteCluster(context.Context, *connect.Request[v1.DeleteClusterRequest]) (*connect.Response[v1.DeleteClusterResponse], error)

func (UnimplementedWorkflowsServiceHandler) GetCluster 

func (UnimplementedWorkflowsServiceHandler) GetCluster(context.Context, *connect.Request[v1.GetClusterRequest]) (*connect.Response[v1.Cluster], error)

func (UnimplementedWorkflowsServiceHandler) ListClusters 

func (UnimplementedWorkflowsServiceHandler) ListClusters(context.Context, *connect.Request[v1.ListClustersRequest]) (*connect.Response[v1.ListClustersResponse], error)

type WorkflowsServiceClient 

type WorkflowsServiceClient interface {
	CreateCluster(context.Context, *connect.Request[v1.CreateClusterRequest]) (*connect.Response[v1.Cluster], error)
	GetCluster(context.Context, *connect.Request[v1.GetClusterRequest]) (*connect.Response[v1.Cluster], error)
	DeleteCluster(context.Context, *connect.Request[v1.DeleteClusterRequest]) (*connect.Response[v1.DeleteClusterResponse], error)
	ListClusters(context.Context, *connect.Request[v1.ListClustersRequest]) (*connect.Response[v1.ListClustersResponse], error)
}

WorkflowsServiceClient is a client for the workflows.v1.WorkflowsService service.

func NewWorkflowsServiceClient 

func NewWorkflowsServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) WorkflowsServiceClient

NewWorkflowsServiceClient constructs a client for the workflows.v1.WorkflowsService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type WorkflowsServiceHandler 

type WorkflowsServiceHandler interface {
	CreateCluster(context.Context, *connect.Request[v1.CreateClusterRequest]) (*connect.Response[v1.Cluster], error)
	GetCluster(context.Context, *connect.Request[v1.GetClusterRequest]) (*connect.Response[v1.Cluster], error)
	DeleteCluster(context.Context, *connect.Request[v1.DeleteClusterRequest]) (*connect.Response[v1.DeleteClusterResponse], error)
	ListClusters(context.Context, *connect.Request[v1.ListClustersRequest]) (*connect.Response[v1.ListClustersResponse], error)
}

WorkflowsServiceHandler is an implementation of the workflows.v1.WorkflowsService service.

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.