workflowsv1

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

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

type AutomationPrototype_builder struct {

	// Unique identifier for the trigger
	Id *v1.ID
	// A human-readable name for the trigger
	Name string
	// The task submission to trigger
	Prototype *TaskSubmission
	// The storage event triggers that will trigger the task
	StorageEventTriggers []*StorageEventTrigger
	// The cron triggers that will trigger the task
	CronTriggers []*CronTrigger
	// Whether the automation is disabled (paused) or not.
	// the field is named disabled rather than enabled (with the semantics flipped) to make sure not setting the field at
	// all results in the automation being enabled by default.
	Disabled bool
	// contains filtered or unexported fields
}

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

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

type Automation_builder struct {

	// Details of the event that triggered the task. This is a serialized protobuf message. The type of the message
	// depends on the type of the trigger, either StorageEventTriggerEvent or CronTriggerEvent.
	TriggerEvent []byte
	// Additional, user-defined arguments for the task, to be deserialized by the task itself
	Args []byte
	// contains filtered or unexported fields
}

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

type Automations_builder struct {
	Automations []*AutomationPrototype
	// contains filtered or unexported fields
}

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

type CancelJobRequest_builder struct {

	// The job to cancel.
	JobId *v1.ID
	// contains filtered or unexported fields
}

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

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

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

type CloneJobRequest_builder struct {

	// The ID of the job to clone.
	JobId *v1.ID
	// The updated root tasks of the job.
	RootTasksOverrides []*TaskSubmission
	// The name of the job.
	JobName string
	// contains filtered or unexported fields
}

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

type Cluster_builder struct {

	// The unique slug of the cluster within the namespace.
	Slug string
	// The display name of the cluster.
	DisplayName string
	// Where the cluster is deletable
	Deletable bool
	// contains filtered or unexported fields
}

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

type ComputedTask_builder struct {

	// The id of the task that has been computed.
	Id *v1.ID
	// A display name for the task that has been computed for visualization purposes.
	// If not set, the display message specified upon task submission will be kept.
	Display string
	// A list of sub-tasks that the just computed task spawned.
	SubTasks []*TaskSubmission
	// A list of progress updates that the computed task wants to report.
	ProgressUpdates []*Progress
	// contains filtered or unexported fields
}

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

type CreateClusterRequest_builder struct {

	// The name of the cluster.
	Name string
	// contains filtered or unexported fields
}

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

type CronTrigger_builder struct {

	// Unique identifier for the trigger
	Id *v1.ID
	// A cron schedule for the trigger, e.g. "0 0 * * *" (every day at midnight)
	Schedule string
	// contains filtered or unexported fields
}

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

type DeleteAutomationRequest_builder struct {

	// The ID of the automation to delete.
	AutomationId *v1.ID
	// Whether to cancel all jobs that have been created by this automation.
	CancelJobs bool
	// contains filtered or unexported fields
}

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

type DeleteClusterRequest_builder struct {

	// The slug of the cluster to delete.
	ClusterSlug string
	// contains filtered or unexported fields
}

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

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

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

type DiagramServiceClient interface {
	Render(ctx context.Context, in *RenderDiagramRequest, opts ...grpc.CallOption) (*Diagram, error)
}

type DiagramServiceServer interface {
	Render(context.Context, *RenderDiagramRequest) (*Diagram, error)
	// contains filtered or unexported methods
}

type Diagram_builder struct {
	Svg []byte
	// contains filtered or unexported fields
}

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

type GetClusterRequest_builder struct {

	// The slug of the cluster to get details for.
	ClusterSlug string
	// contains filtered or unexported fields
}

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

type GetJobProgressRequest_builder struct {

	// The ID of the job to get progress for.
	JobId *v1.ID
	// contains filtered or unexported fields
}

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

type GetJobPrototypeRequest_builder struct {

	// The ID of the job to get a clone prototype for.
	JobId *v1.ID
	// contains filtered or unexported fields
}

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

type GetJobPrototypeResponse_builder struct {

	// The root tasks of the job.
	RootTasks []*TaskSubmission
	// The name of the job.
	JobName string
	// contains filtered or unexported fields
}

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

type GetJobRequest_builder struct {

	// The ID of the job to get details for.
	JobId *v1.ID
	// contains filtered or unexported fields
}

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

type IdlingResponse_builder struct {

	// The suggested duration the task runner should idle for before sending another request for a task.
	SuggestedIdlingDuration *durationpb.Duration
	// contains filtered or unexported fields
}

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

type JobServiceClient interface {
	SubmitJob(ctx context.Context, in *SubmitJobRequest, opts ...grpc.CallOption) (*Job, error)
	GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error)
	GetJobProgress(ctx context.Context, in *GetJobProgressRequest, opts ...grpc.CallOption) (*Job, error)
	RetryJob(ctx context.Context, in *RetryJobRequest, opts ...grpc.CallOption) (*RetryJobResponse, error)
	CancelJob(ctx context.Context, in *CancelJobRequest, opts ...grpc.CallOption) (*CancelJobResponse, error)
	VisualizeJob(ctx context.Context, in *VisualizeJobRequest, opts ...grpc.CallOption) (*Diagram, error)
	QueryJobs(ctx context.Context, in *QueryJobsRequest, opts ...grpc.CallOption) (*QueryJobsResponse, error)
	GetJobPrototype(ctx context.Context, in *GetJobPrototypeRequest, opts ...grpc.CallOption) (*GetJobPrototypeResponse, error)
	CloneJob(ctx context.Context, in *CloneJobRequest, opts ...grpc.CallOption) (*Job, error)
}

type JobServiceServer interface {
	SubmitJob(context.Context, *SubmitJobRequest) (*Job, error)
	GetJob(context.Context, *GetJobRequest) (*Job, error)
	GetJobProgress(context.Context, *GetJobProgressRequest) (*Job, error)
	RetryJob(context.Context, *RetryJobRequest) (*RetryJobResponse, error)
	CancelJob(context.Context, *CancelJobRequest) (*CancelJobResponse, error)
	VisualizeJob(context.Context, *VisualizeJobRequest) (*Diagram, error)
	QueryJobs(context.Context, *QueryJobsRequest) (*QueryJobsResponse, error)
	GetJobPrototype(context.Context, *GetJobPrototypeRequest) (*GetJobPrototypeResponse, error)
	CloneJob(context.Context, *CloneJobRequest) (*Job, error)
	// contains filtered or unexported methods
}

type JobState int32

type Job_builder struct {
	Id          *v1.ID
	Name        string
	TraceParent string
	// Whether the job has been canceled.
	Canceled bool
	// The current state of the job.
	State JobState
	// The time the job was submitted.
	SubmittedAt *timestamppb.Timestamp
	// The time the job started running.
	StartedAt *timestamppb.Timestamp
	// The task' summaries of the job.
	TaskSummaries []*TaskSummary
	// The automation that submitted the job.
	AutomationId *v1.ID
	// A list of progress indicators for the job.
	Progress []*Progress
	// contains filtered or unexported fields
}

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

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

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

type ListClustersResponse_builder struct {

	// The clusters.
	Clusters []*Cluster
	// contains filtered or unexported fields
}

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

type NextTaskRequest_builder struct {

	// The task that has been computed. If not set, the next task will
	ComputedTask *ComputedTask
	// The capabilities of the task runner, and therefore the potential tasks that can be run by that task runner.
	NextTaskToRun *NextTaskToRun
	// contains filtered or unexported fields
}

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

type NextTaskResponse_builder struct {
	NextTask *Task
	Idling   *IdlingResponse
	// contains filtered or unexported fields
}

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

type NextTaskToRun_builder struct {

	// The cluster that this task runner is running on.
	ClusterSlug string
	// The task identifiers that this task runner can run.
	Identifiers []*TaskIdentifier
	// contains filtered or unexported fields
}

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

type Progress_builder struct {

	// A human-readable label for the progress indicator. Can also be empty.
	Label string
	// The total number of work units to be processed.
	Total uint64
	// The number of work units that have already been processed.
	Done uint64
	// contains filtered or unexported fields
}

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

type QueryFilters_builder struct {
	TimeInterval *v1.TimeInterval
	IdInterval   *v1.IDInterval
	// Filter jobs by automation id.
	AutomationId *v1.ID
	// contains filtered or unexported fields
}

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

type QueryJobsRequest_builder struct {

	// Filters to apply to the query.
	Filters *QueryFilters
	// The pagination parameters for this request.
	Page *v1.Pagination
	// contains filtered or unexported fields
}

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

type QueryJobsResponse_builder struct {

	// The jobs.
	Jobs []*Job
	// The pagination parameters for the next page.
	NextPage *v1.Pagination
	// contains filtered or unexported fields
}

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

type RenderDiagramRequest_builder struct {

	// The diagram graph in the D2 syntax
	Diagram string
	// The options for rendering the diagram
	RenderOptions *RenderOptions
	// contains filtered or unexported fields
}

type RenderOptions struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}

type RenderOptions_builder struct {

	// The layout to use for rendering the diagram: https://d2lang.com/tour/layouts/.
	// "dagre" or "elk". Defaults to "dagre"
	Layout string
	// The D2 theme to use when rendering the diagram: https://d2lang.com/tour/themes/
	ThemeId *int64
	// Whether to render the diagram in a sketchy (hand-drawn) style
	Sketchy bool
	// The padding around the diagram
	Padding int64
	// Set explicitly the direction of the diagram: https://d2lang.com/tour/layouts/#direction.
	Direction string
	// contains filtered or unexported fields
}

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

type RetryJobRequest_builder struct {

	// The job to retry.
	JobId *v1.ID
	// contains filtered or unexported fields
}

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

type RetryJobResponse_builder struct {

	// The number of tasks that were rescheduled.
	NumTasksRescheduled int64
	// contains filtered or unexported fields
}

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

type StorageEventTrigger_builder struct {

	// Unique identifier for the trigger
	Id *v1.ID
	// The storage location to watch for events
	StorageLocation *StorageLocation
	// A glob pattern to match objects/files in the storage location
	GlobPattern string
	// contains filtered or unexported fields
}

type StorageEventType int32

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

type StorageLocation_builder struct {

	// Unique identifier for the storage location
	Id *v1.ID
	// A unique identifier for the storage location in the storage system
	Location string
	// The type of the storage location, e.g. GCS, S3, FS
	Type StorageType
	// contains filtered or unexported fields
}

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

type StorageLocations_builder struct {
	Locations []*StorageLocation
	// contains filtered or unexported fields
}

type StorageType int32

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

type SubmitJobRequest_builder struct {

	// The root tasks for the job.
	Tasks []*TaskSubmission
	// The name of the job.
	JobName string
	// Tracing information for the job. This is used to propagate tracing information to the workers that execute the job.
	TraceParent string
	// Optional. The ID of the automation that submits this job.
	AutomationId *v1.ID
	// contains filtered or unexported fields
}

type Task struct {
	XXX_raceDetectHookData protoimpl.RaceDetectHookData
	XXX_presence           [1]uint32
	// contains filtered or unexported fields
}