workflowspb

package
v1.14.0 Latest Latest
Warning

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

 Go to latest Published: Mar 19, 2025 License: Apache-2.0 Imports: 13 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ExecutionHistoryLevel_name = map[int32]string{
		0: "EXECUTION_HISTORY_LEVEL_UNSPECIFIED",
		1: "EXECUTION_HISTORY_BASIC",
		2: "EXECUTION_HISTORY_DETAILED",
	}
	ExecutionHistoryLevel_value = map[string]int32{
		"EXECUTION_HISTORY_LEVEL_UNSPECIFIED": 0,
		"EXECUTION_HISTORY_BASIC":             1,
		"EXECUTION_HISTORY_DETAILED":          2,
	}
)

Enum value maps for ExecutionHistoryLevel.

View Source 
var (
	Workflow_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "ACTIVE",
		2: "UNAVAILABLE",
	}
	Workflow_State_value = map[string]int32{
		"STATE_UNSPECIFIED": 0,
		"ACTIVE":            1,
		"UNAVAILABLE":       2,
	}
)

Enum value maps for Workflow_State.

View Source 
var (
	Workflow_CallLogLevel_name = map[int32]string{
		0: "CALL_LOG_LEVEL_UNSPECIFIED",
		1: "LOG_ALL_CALLS",
		2: "LOG_ERRORS_ONLY",
		3: "LOG_NONE",
	}
	Workflow_CallLogLevel_value = map[string]int32{
		"CALL_LOG_LEVEL_UNSPECIFIED": 0,
		"LOG_ALL_CALLS":              1,
		"LOG_ERRORS_ONLY":            2,
		"LOG_NONE":                   3,
	}
)

Enum value maps for Workflow_CallLogLevel.

View Source 
var (
	Workflow_StateError_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "KMS_ERROR",
	}
	Workflow_StateError_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED": 0,
		"KMS_ERROR":        1,
	}
)

Enum value maps for Workflow_StateError_Type.

View Source 
var File_google_cloud_workflows_v1_workflows_proto protoreflect.FileDescriptor

Functions

func RegisterWorkflowsServer 

func RegisterWorkflowsServer(s *grpc.Server, srv WorkflowsServer)

Types

type CreateWorkflowRequest 

type CreateWorkflowRequest struct {

	// Required. Project and location in which the workflow should be created.
	// Format:  projects/{project}/locations/{location}
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. Workflow to be created.
	Workflow *Workflow `protobuf:"bytes,2,opt,name=workflow,proto3" json:"workflow,omitempty"`
	// Required. The ID of the workflow to be created. It has to fulfill the
	// following requirements:
	//
	// * Must contain only letters, numbers, underscores and hyphens.
	// * Must start with a letter.
	// * Must be between 1-64 characters.
	// * Must end with a number or a letter.
	// * Must be unique within the customer project and location.
	WorkflowId string `protobuf:"bytes,3,opt,name=workflow_id,json=workflowId,proto3" json:"workflow_id,omitempty"`
	// contains filtered or unexported fields
}

Request for the [CreateWorkflow][google.cloud.workflows.v1.Workflows.CreateWorkflow] method.

func (*CreateWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use CreateWorkflowRequest.ProtoReflect.Descriptor instead.

func (*CreateWorkflowRequest) GetParent 

func (x *CreateWorkflowRequest) GetParent() string

func (*CreateWorkflowRequest) GetWorkflow 

func (x *CreateWorkflowRequest) GetWorkflow() *Workflow

func (*CreateWorkflowRequest) GetWorkflowId 

func (x *CreateWorkflowRequest) GetWorkflowId() string

func (*CreateWorkflowRequest) ProtoMessage 

func (*CreateWorkflowRequest) ProtoMessage()

func (*CreateWorkflowRequest) ProtoReflect 

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

func (*CreateWorkflowRequest) Reset 

func (x *CreateWorkflowRequest) Reset()

func (*CreateWorkflowRequest) String 

func (x *CreateWorkflowRequest) String() string

type DeleteWorkflowRequest 

type DeleteWorkflowRequest struct {

	// Required. Name of the workflow to be deleted.
	// Format: projects/{project}/locations/{location}/workflows/{workflow}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request for the [DeleteWorkflow][google.cloud.workflows.v1.Workflows.DeleteWorkflow] method.

func (*DeleteWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use DeleteWorkflowRequest.ProtoReflect.Descriptor instead.

func (*DeleteWorkflowRequest) GetName 

func (x *DeleteWorkflowRequest) GetName() 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 ExecutionHistoryLevel added in v1.14.0 

type ExecutionHistoryLevel int32

Define possible options for enabling the execution history level. 

const (
	// The default/unset value.
	ExecutionHistoryLevel_EXECUTION_HISTORY_LEVEL_UNSPECIFIED ExecutionHistoryLevel = 0
	// Enable execution history basic feature.
	ExecutionHistoryLevel_EXECUTION_HISTORY_BASIC ExecutionHistoryLevel = 1
	// Enable execution history detailed feature.
	ExecutionHistoryLevel_EXECUTION_HISTORY_DETAILED ExecutionHistoryLevel = 2
)

func (ExecutionHistoryLevel) Descriptor added in v1.14.0 

func (ExecutionHistoryLevel) Descriptor() protoreflect.EnumDescriptor

func (ExecutionHistoryLevel) Enum added in v1.14.0 

func (x ExecutionHistoryLevel) Enum() *ExecutionHistoryLevel

func (ExecutionHistoryLevel) EnumDescriptor deprecated added in v1.14.0 

func (ExecutionHistoryLevel) EnumDescriptor() ([]byte, []int)

Deprecated: Use ExecutionHistoryLevel.Descriptor instead.

func (ExecutionHistoryLevel) Number added in v1.14.0 

func (x ExecutionHistoryLevel) Number() protoreflect.EnumNumber

func (ExecutionHistoryLevel) String added in v1.14.0 

func (x ExecutionHistoryLevel) String() string

func (ExecutionHistoryLevel) Type added in v1.14.0 

func (ExecutionHistoryLevel) Type() protoreflect.EnumType

type GetWorkflowRequest 

type GetWorkflowRequest struct {

	// Required. Name of the workflow for which information should be retrieved.
	// Format: projects/{project}/locations/{location}/workflows/{workflow}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Optional. The revision of the workflow to retrieve. If the revision_id is
	// empty, the latest revision is retrieved.
	// The format is "000001-a4d", where the first six characters define
	// the zero-padded decimal revision number. They are followed by a hyphen and
	// three hexadecimal characters.
	RevisionId string `protobuf:"bytes,2,opt,name=revision_id,json=revisionId,proto3" json:"revision_id,omitempty"`
	// contains filtered or unexported fields
}

Request for the [GetWorkflow][google.cloud.workflows.v1.Workflows.GetWorkflow] method.

func (*GetWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use GetWorkflowRequest.ProtoReflect.Descriptor instead.

func (*GetWorkflowRequest) GetName 

func (x *GetWorkflowRequest) GetName() string

func (*GetWorkflowRequest) GetRevisionId added in v1.12.0 

func (x *GetWorkflowRequest) GetRevisionId() string

func (*GetWorkflowRequest) ProtoMessage 

func (*GetWorkflowRequest) ProtoMessage()

func (*GetWorkflowRequest) ProtoReflect 

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

func (*GetWorkflowRequest) Reset 

func (x *GetWorkflowRequest) Reset()

func (*GetWorkflowRequest) String 

func (x *GetWorkflowRequest) String() string

type ListWorkflowRevisionsRequest added in v1.14.0 

type ListWorkflowRevisionsRequest struct {

	// Required. Workflow for which the revisions should be listed.
	// Format: projects/{project}/locations/{location}/workflows/{workflow}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The maximum number of revisions to return per page. If a value is not
	// specified, a default value of 20 is used. The maximum permitted value is
	// 100. Values greater than 100 are coerced down to 100.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// The page token, received from a previous ListWorkflowRevisions call.
	// Provide this to retrieve the subsequent page.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// contains filtered or unexported fields
}

Request for the [ListWorkflowRevisions][google.cloud.workflows.v1.Workflows.ListWorkflowRevisions] method.

func (*ListWorkflowRevisionsRequest) Descriptor deprecated added in v1.14.0 

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

Deprecated: Use ListWorkflowRevisionsRequest.ProtoReflect.Descriptor instead.

func (*ListWorkflowRevisionsRequest) GetName added in v1.14.0 

func (x *ListWorkflowRevisionsRequest) GetName() string

func (*ListWorkflowRevisionsRequest) GetPageSize added in v1.14.0 

func (x *ListWorkflowRevisionsRequest) GetPageSize() int32

func (*ListWorkflowRevisionsRequest) GetPageToken added in v1.14.0 

func (x *ListWorkflowRevisionsRequest) GetPageToken() string

func (*ListWorkflowRevisionsRequest) ProtoMessage added in v1.14.0 

func (*ListWorkflowRevisionsRequest) ProtoMessage()

func (*ListWorkflowRevisionsRequest) ProtoReflect added in v1.14.0 

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

func (*ListWorkflowRevisionsRequest) Reset added in v1.14.0 

func (x *ListWorkflowRevisionsRequest) Reset()

func (*ListWorkflowRevisionsRequest) String added in v1.14.0 

func (x *ListWorkflowRevisionsRequest) String() string

type ListWorkflowRevisionsResponse added in v1.14.0 

type ListWorkflowRevisionsResponse struct {

	// The revisions of the workflow, ordered in reverse chronological order.
	Workflows []*Workflow `protobuf:"bytes,1,rep,name=workflows,proto3" json:"workflows,omitempty"`
	// A token, which can be sent as `page_token` to retrieve the next page.
	// If this field is omitted, there are no subsequent pages.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// contains filtered or unexported fields
}

Response for the [ListWorkflowRevisions][google.cloud.workflows.v1.Workflows.ListWorkflowRevisions] method.

func (*ListWorkflowRevisionsResponse) Descriptor deprecated added in v1.14.0 

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

Deprecated: Use ListWorkflowRevisionsResponse.ProtoReflect.Descriptor instead.

func (*ListWorkflowRevisionsResponse) GetNextPageToken added in v1.14.0 

func (x *ListWorkflowRevisionsResponse) GetNextPageToken() string

func (*ListWorkflowRevisionsResponse) GetWorkflows added in v1.14.0 

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

func (*ListWorkflowRevisionsResponse) ProtoMessage added in v1.14.0 

func (*ListWorkflowRevisionsResponse) ProtoMessage()

func (*ListWorkflowRevisionsResponse) ProtoReflect added in v1.14.0 

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

func (*ListWorkflowRevisionsResponse) Reset added in v1.14.0 

func (x *ListWorkflowRevisionsResponse) Reset()

func (*ListWorkflowRevisionsResponse) String added in v1.14.0 

func (x *ListWorkflowRevisionsResponse) String() string

type ListWorkflowsRequest 

type ListWorkflowsRequest struct {

	// Required. Project and location from which the workflows should be listed.
	// Format: projects/{project}/locations/{location}
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Maximum number of workflows to return per call. The service might return
	// fewer than this value even if not at the end of the collection. If a value
	// is not specified, a default value of 500 is used. The maximum permitted
	// value is 1000 and values greater than 1000 are coerced down to 1000.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// A page token, received from a previous `ListWorkflows` call.
	// Provide this to retrieve the subsequent page.
	//
	// When paginating, all other parameters provided to `ListWorkflows` must
	// match the call that provided the page token.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// Filter to restrict results to specific workflows.
	// For details, see <a href="https://google.aip.dev/160"
	// class="external">AIP-160</a>.
	//
	// For example, if you are using the Google APIs Explorer:
	//
	// `state="SUCCEEDED"`
	//
	// or
	//
	// `createTime>"2023-08-01" AND state="FAILED"`
	Filter string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`
	// Comma-separated list of fields that specify the order of the results.
	// Default sorting order for a field is ascending. To specify descending order
	// for a field, append a "desc" suffix.
	// If not specified, the results are returned in an unspecified order.
	OrderBy string `protobuf:"bytes,5,opt,name=order_by,json=orderBy,proto3" json:"order_by,omitempty"`
	// contains filtered or unexported fields
}

Request for the [ListWorkflows][google.cloud.workflows.v1.Workflows.ListWorkflows] method.

func (*ListWorkflowsRequest) Descriptor deprecated 

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

Deprecated: Use ListWorkflowsRequest.ProtoReflect.Descriptor instead.

func (*ListWorkflowsRequest) GetFilter 

func (x *ListWorkflowsRequest) GetFilter() string

func (*ListWorkflowsRequest) GetOrderBy 

func (x *ListWorkflowsRequest) GetOrderBy() string

func (*ListWorkflowsRequest) GetPageSize 

func (x *ListWorkflowsRequest) GetPageSize() int32

func (*ListWorkflowsRequest) GetPageToken 

func (x *ListWorkflowsRequest) GetPageToken() string

func (*ListWorkflowsRequest) GetParent 

func (x *ListWorkflowsRequest) GetParent() 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 {

	// The workflows that match the request.
	Workflows []*Workflow `protobuf:"bytes,1,rep,name=workflows,proto3" json:"workflows,omitempty"`
	// A token, which can be sent as `page_token` to retrieve the next page.
	// If this field is omitted, there are no subsequent pages.
	NextPageToken string `protobuf:"bytes,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"`
	// Unreachable resources.
	Unreachable []string `protobuf:"bytes,3,rep,name=unreachable,proto3" json:"unreachable,omitempty"`
	// contains filtered or unexported fields
}

Response for the [ListWorkflows][google.cloud.workflows.v1.Workflows.ListWorkflows] method.

func (*ListWorkflowsResponse) Descriptor deprecated 

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

Deprecated: Use ListWorkflowsResponse.ProtoReflect.Descriptor instead.

func (*ListWorkflowsResponse) GetNextPageToken 

func (x *ListWorkflowsResponse) GetNextPageToken() string

func (*ListWorkflowsResponse) GetUnreachable 

func (x *ListWorkflowsResponse) GetUnreachable() []string

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 OperationMetadata 

type OperationMetadata struct {

	// The time the operation was created.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// The time the operation finished running.
	EndTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=end_time,json=endTime,proto3" json:"end_time,omitempty"`
	// Server-defined resource path for the target of the operation.
	Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	// Name of the verb executed by the operation.
	Verb string `protobuf:"bytes,4,opt,name=verb,proto3" json:"verb,omitempty"`
	// API version used to start the operation.
	ApiVersion string `protobuf:"bytes,5,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
	// contains filtered or unexported fields
}

Represents the metadata of the long-running operation.

func (*OperationMetadata) Descriptor deprecated 

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

Deprecated: Use OperationMetadata.ProtoReflect.Descriptor instead.

func (*OperationMetadata) GetApiVersion 

func (x *OperationMetadata) GetApiVersion() string

func (*OperationMetadata) GetCreateTime 

func (x *OperationMetadata) GetCreateTime() *timestamppb.Timestamp

func (*OperationMetadata) GetEndTime 

func (x *OperationMetadata) GetEndTime() *timestamppb.Timestamp

func (*OperationMetadata) GetTarget 

func (x *OperationMetadata) GetTarget() string

func (*OperationMetadata) GetVerb 

func (x *OperationMetadata) GetVerb() string

func (*OperationMetadata) ProtoMessage 

func (*OperationMetadata) ProtoMessage()

func (*OperationMetadata) ProtoReflect 

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

func (*OperationMetadata) Reset 

func (x *OperationMetadata) Reset()

func (*OperationMetadata) String 

func (x *OperationMetadata) String() string

type UnimplementedWorkflowsServer 

type UnimplementedWorkflowsServer struct {
}

UnimplementedWorkflowsServer can be embedded to have forward compatible implementations.

func (*UnimplementedWorkflowsServer) CreateWorkflow 

func (*UnimplementedWorkflowsServer) CreateWorkflow(context.Context, *CreateWorkflowRequest) (*longrunningpb.Operation, error)

func (*UnimplementedWorkflowsServer) DeleteWorkflow 

func (*UnimplementedWorkflowsServer) DeleteWorkflow(context.Context, *DeleteWorkflowRequest) (*longrunningpb.Operation, error)

func (*UnimplementedWorkflowsServer) GetWorkflow 

func (*UnimplementedWorkflowsServer) GetWorkflow(context.Context, *GetWorkflowRequest) (*Workflow, error)

func (*UnimplementedWorkflowsServer) ListWorkflowRevisions added in v1.14.0 

func (*UnimplementedWorkflowsServer) ListWorkflowRevisions(context.Context, *ListWorkflowRevisionsRequest) (*ListWorkflowRevisionsResponse, error)

func (*UnimplementedWorkflowsServer) ListWorkflows 

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

func (*UnimplementedWorkflowsServer) UpdateWorkflow 

func (*UnimplementedWorkflowsServer) UpdateWorkflow(context.Context, *UpdateWorkflowRequest) (*longrunningpb.Operation, error)

type UpdateWorkflowRequest 

type UpdateWorkflowRequest struct {

	// Required. Workflow to be updated.
	Workflow *Workflow `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"`
	// List of fields to be updated. If not present, the entire workflow
	// will be updated.
	UpdateMask *fieldmaskpb.FieldMask `protobuf:"bytes,2,opt,name=update_mask,json=updateMask,proto3" json:"update_mask,omitempty"`
	// contains filtered or unexported fields
}

Request for the [UpdateWorkflow][google.cloud.workflows.v1.Workflows.UpdateWorkflow] method.

func (*UpdateWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use UpdateWorkflowRequest.ProtoReflect.Descriptor instead.

func (*UpdateWorkflowRequest) GetUpdateMask 

func (x *UpdateWorkflowRequest) GetUpdateMask() *fieldmaskpb.FieldMask

func (*UpdateWorkflowRequest) GetWorkflow 

func (x *UpdateWorkflowRequest) GetWorkflow() *Workflow

func (*UpdateWorkflowRequest) ProtoMessage 

func (*UpdateWorkflowRequest) ProtoMessage()

func (*UpdateWorkflowRequest) ProtoReflect 

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

func (*UpdateWorkflowRequest) Reset 

func (x *UpdateWorkflowRequest) Reset()

func (*UpdateWorkflowRequest) String 

func (x *UpdateWorkflowRequest) String() string

type Workflow 

type Workflow struct {

	// The resource name of the workflow.
	// Format: projects/{project}/locations/{location}/workflows/{workflow}.
	// This is a workflow-wide field and is not tied to a specific revision.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Description of the workflow provided by the user.
	// Must be at most 1000 Unicode characters long.
	// This is a workflow-wide field and is not tied to a specific revision.
	Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
	// Output only. State of the workflow deployment.
	State Workflow_State `protobuf:"varint,3,opt,name=state,proto3,enum=google.cloud.workflows.v1.Workflow_State" json:"state,omitempty"`
	// Output only. The revision of the workflow.
	// A new revision of a workflow is created as a result of updating the
	// following properties of a workflow:
	//
	// - [Service account][google.cloud.workflows.v1.Workflow.service_account]
	// - [Workflow code to be
	// executed][google.cloud.workflows.v1.Workflow.source_contents]
	//
	// The format is "000001-a4d", where the first six characters define
	// the zero-padded revision ordinal number. They are followed by a hyphen and
	// three hexadecimal random characters.
	RevisionId string `protobuf:"bytes,4,opt,name=revision_id,json=revisionId,proto3" json:"revision_id,omitempty"`
	// Output only. The timestamp for when the workflow was created.
	// This is a workflow-wide field and is not tied to a specific revision.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The timestamp for when the workflow was last updated.
	// This is a workflow-wide field and is not tied to a specific revision.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Output only. The timestamp for the latest revision of the workflow's
	// creation.
	RevisionCreateTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=revision_create_time,json=revisionCreateTime,proto3" json:"revision_create_time,omitempty"`
	// Labels associated with this workflow.
	// Labels can contain at most 64 entries. Keys and values can be no longer
	// than 63 characters and can only contain lowercase letters, numeric
	// characters, underscores, and dashes. Label keys must start with a letter.
	// International characters are allowed.
	// This is a workflow-wide field and is not tied to a specific revision.
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// The service account associated with the latest workflow version.
	// This service account represents the identity of the workflow and determines
	// what permissions the workflow has.
	// Format: projects/{project}/serviceAccounts/{account} or {account}
	//
	// Using `-` as a wildcard for the `{project}` or not providing one at all
	// will infer the project from the account. The `{account}` value can be the
	// `email` address or the `unique_id` of the service account.
	//
	// If not provided, workflow will use the project's default service account.
	// Modifying this field for an existing workflow results in a new workflow
	// revision.
	ServiceAccount string `protobuf:"bytes,9,opt,name=service_account,json=serviceAccount,proto3" json:"service_account,omitempty"`
	// Required. Location of the workflow source code.
	// Modifying this field for an existing workflow results in a new workflow
	// revision.
	//
	// Types that are assignable to SourceCode:
	//
	//	*Workflow_SourceContents
	SourceCode isWorkflow_SourceCode `protobuf_oneof:"source_code"`
	// Optional. The resource name of a KMS crypto key used to encrypt or decrypt
	// the data associated with the workflow.
	//
	// Format:
	// projects/{project}/locations/{location}/keyRings/{keyRing}/cryptoKeys/{cryptoKey}
	//
	// Using `-` as a wildcard for the `{project}` or not providing one at all
	// will infer the project from the account.
	//
	// If not provided, data associated with the workflow will not be
	// CMEK-encrypted.
	CryptoKeyName string `protobuf:"bytes,11,opt,name=crypto_key_name,json=cryptoKeyName,proto3" json:"crypto_key_name,omitempty"`
	// Output only. Error regarding the state of the workflow. For example, this
	// field will have error details if the execution data is unavailable due to
	// revoked KMS key permissions.
	StateError *Workflow_StateError `protobuf:"bytes,12,opt,name=state_error,json=stateError,proto3" json:"state_error,omitempty"`
	// Optional. Describes the level of platform logging to apply to calls and
	// call responses during executions of this workflow. If both the workflow and
	// the execution specify a logging level, the execution level takes
	// precedence.
	CallLogLevel Workflow_CallLogLevel `` /* 154-byte string literal not displayed */
	// Optional. User-defined environment variables associated with this workflow
	// revision. This map has a maximum length of 20. Each string can take up to
	// 4KiB. Keys cannot be empty strings and cannot start with "GOOGLE" or
	// "WORKFLOWS".
	UserEnvVars map[string]string `` /* 185-byte string literal not displayed */
	// Optional. Describes the execution history level to apply to this workflow.
	ExecutionHistoryLevel ExecutionHistoryLevel `` /* 181-byte string literal not displayed */
	// Output only. A list of all KMS crypto keys used to encrypt or decrypt the
	// data associated with the workflow.
	AllKmsKeys []string `protobuf:"bytes,16,rep,name=all_kms_keys,json=allKmsKeys,proto3" json:"all_kms_keys,omitempty"`
	// Output only. A list of all KMS crypto key versions used to encrypt or
	// decrypt the data associated with the workflow.
	AllKmsKeysVersions []string `protobuf:"bytes,17,rep,name=all_kms_keys_versions,json=allKmsKeysVersions,proto3" json:"all_kms_keys_versions,omitempty"`
	// Output only. The resource name of a KMS crypto key version used to encrypt
	// or decrypt the data associated with the workflow.
	//
	// Format:
	// projects/{project}/locations/{location}/keyRings/{keyRing}/cryptoKeys/{cryptoKey}/cryptoKeyVersions/{cryptoKeyVersion}
	CryptoKeyVersion string `protobuf:"bytes,18,opt,name=crypto_key_version,json=cryptoKeyVersion,proto3" json:"crypto_key_version,omitempty"`
	// Optional. Input only. Immutable. Tags associated with this workflow.
	Tags map[string]string `` /* 150-byte string literal not displayed */
	// contains filtered or unexported fields
}

Workflow program to be executed by Workflows.

func (*Workflow) Descriptor deprecated 

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

Deprecated: Use Workflow.ProtoReflect.Descriptor instead.

func (*Workflow) GetAllKmsKeys added in v1.14.0 

func (x *Workflow) GetAllKmsKeys() []string

func (*Workflow) GetAllKmsKeysVersions added in v1.14.0 

func (x *Workflow) GetAllKmsKeysVersions() []string

func (*Workflow) GetCallLogLevel added in v1.12.0 

func (x *Workflow) GetCallLogLevel() Workflow_CallLogLevel

func (*Workflow) GetCreateTime 

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

func (*Workflow) GetCryptoKeyName added in v1.12.0 

func (x *Workflow) GetCryptoKeyName() string

func (*Workflow) GetCryptoKeyVersion added in v1.14.0 

func (x *Workflow) GetCryptoKeyVersion() string

func (*Workflow) GetDescription 

func (x *Workflow) GetDescription() string

func (*Workflow) GetExecutionHistoryLevel added in v1.14.0 

func (x *Workflow) GetExecutionHistoryLevel() ExecutionHistoryLevel

func (*Workflow) GetLabels 

func (x *Workflow) GetLabels() map[string]string

func (*Workflow) GetName 

func (x *Workflow) GetName() string

func (*Workflow) GetRevisionCreateTime 

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

func (*Workflow) GetRevisionId 

func (x *Workflow) GetRevisionId() string

func (*Workflow) GetServiceAccount 

func (x *Workflow) GetServiceAccount() string

func (*Workflow) GetSourceCode 

func (m *Workflow) GetSourceCode() isWorkflow_SourceCode

func (*Workflow) GetSourceContents 

func (x *Workflow) GetSourceContents() string

func (*Workflow) GetState 

func (x *Workflow) GetState() Workflow_State

func (*Workflow) GetStateError added in v1.12.0 

func (x *Workflow) GetStateError() *Workflow_StateError

func (*Workflow) GetTags added in v1.14.0 

func (x *Workflow) GetTags() map[string]string

func (*Workflow) GetUpdateTime 

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

func (*Workflow) GetUserEnvVars added in v1.12.0 

func (x *Workflow) GetUserEnvVars() map[string]string

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 Workflow_CallLogLevel added in v1.12.0 

type Workflow_CallLogLevel int32

Describes the level of platform logging to apply to calls and call responses during workflow executions. 

const (
	// No call logging level specified.
	Workflow_CALL_LOG_LEVEL_UNSPECIFIED Workflow_CallLogLevel = 0
	// Log all call steps within workflows, all call returns, and all exceptions
	// raised.
	Workflow_LOG_ALL_CALLS Workflow_CallLogLevel = 1
	// Log only exceptions that are raised from call steps within workflows.
	Workflow_LOG_ERRORS_ONLY Workflow_CallLogLevel = 2
	// Explicitly log nothing.
	Workflow_LOG_NONE Workflow_CallLogLevel = 3
)

func (Workflow_CallLogLevel) Descriptor added in v1.12.0 

func (Workflow_CallLogLevel) Descriptor() protoreflect.EnumDescriptor

func (Workflow_CallLogLevel) Enum added in v1.12.0 

func (x Workflow_CallLogLevel) Enum() *Workflow_CallLogLevel

func (Workflow_CallLogLevel) EnumDescriptor deprecated added in v1.12.0 

func (Workflow_CallLogLevel) EnumDescriptor() ([]byte, []int)

Deprecated: Use Workflow_CallLogLevel.Descriptor instead.

func (Workflow_CallLogLevel) Number added in v1.12.0 

func (x Workflow_CallLogLevel) Number() protoreflect.EnumNumber

func (Workflow_CallLogLevel) String added in v1.12.0 

func (x Workflow_CallLogLevel) String() string

func (Workflow_CallLogLevel) Type added in v1.12.0 

func (Workflow_CallLogLevel) Type() protoreflect.EnumType

type Workflow_SourceContents 

type Workflow_SourceContents struct {
	// Workflow code to be executed. The size limit is 128KB.
	SourceContents string `protobuf:"bytes,10,opt,name=source_contents,json=sourceContents,proto3,oneof"`
}

type Workflow_State 

type Workflow_State int32

Describes the current state of workflow deployment. 

const (
	// Invalid state.
	Workflow_STATE_UNSPECIFIED Workflow_State = 0
	// The workflow has been deployed successfully and is serving.
	Workflow_ACTIVE Workflow_State = 1
	// Workflow data is unavailable. See the `state_error` field.
	Workflow_UNAVAILABLE Workflow_State = 2
)

func (Workflow_State) Descriptor 

func (Workflow_State) Descriptor() protoreflect.EnumDescriptor

func (Workflow_State) Enum 

func (x Workflow_State) Enum() *Workflow_State

func (Workflow_State) EnumDescriptor deprecated 

func (Workflow_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use Workflow_State.Descriptor instead.

func (Workflow_State) Number 

func (x Workflow_State) Number() protoreflect.EnumNumber

func (Workflow_State) String 

func (x Workflow_State) String() string

func (Workflow_State) Type 

func (Workflow_State) Type() protoreflect.EnumType

type Workflow_StateError added in v1.12.0 

type Workflow_StateError struct {

	// Provides specifics about the error.
	Details string `protobuf:"bytes,1,opt,name=details,proto3" json:"details,omitempty"`
	// The type of this state error.
	Type Workflow_StateError_Type `protobuf:"varint,2,opt,name=type,proto3,enum=google.cloud.workflows.v1.Workflow_StateError_Type" json:"type,omitempty"`
	// contains filtered or unexported fields
}

Describes an error related to the current state of the workflow.

func (*Workflow_StateError) Descriptor deprecated added in v1.12.0 

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

Deprecated: Use Workflow_StateError.ProtoReflect.Descriptor instead.

func (*Workflow_StateError) GetDetails added in v1.12.0 

func (x *Workflow_StateError) GetDetails() string

func (*Workflow_StateError) GetType added in v1.12.0 

func (x *Workflow_StateError) GetType() Workflow_StateError_Type

func (*Workflow_StateError) ProtoMessage added in v1.12.0 

func (*Workflow_StateError) ProtoMessage()

func (*Workflow_StateError) ProtoReflect added in v1.12.0 

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

func (*Workflow_StateError) Reset added in v1.12.0 

func (x *Workflow_StateError) Reset()

func (*Workflow_StateError) String added in v1.12.0 

func (x *Workflow_StateError) String() string

type Workflow_StateError_Type added in v1.12.0 

type Workflow_StateError_Type int32

Describes the possibled types of a state error. 

const (
	// No type specified.
	Workflow_StateError_TYPE_UNSPECIFIED Workflow_StateError_Type = 0
	// Caused by an issue with KMS.
	Workflow_StateError_KMS_ERROR Workflow_StateError_Type = 1
)

func (Workflow_StateError_Type) Descriptor added in v1.12.0 

func (Workflow_StateError_Type) Descriptor() protoreflect.EnumDescriptor

func (Workflow_StateError_Type) Enum added in v1.12.0 

func (x Workflow_StateError_Type) Enum() *Workflow_StateError_Type

func (Workflow_StateError_Type) EnumDescriptor deprecated added in v1.12.0 

func (Workflow_StateError_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use Workflow_StateError_Type.Descriptor instead.

func (Workflow_StateError_Type) Number added in v1.12.0 

func (x Workflow_StateError_Type) Number() protoreflect.EnumNumber

func (Workflow_StateError_Type) String added in v1.12.0 

func (x Workflow_StateError_Type) String() string

func (Workflow_StateError_Type) Type added in v1.12.0 

func (Workflow_StateError_Type) Type() protoreflect.EnumType

type WorkflowsClient 

type WorkflowsClient interface {
	// Lists workflows in a given project and location.
	// The default order is not specified.
	ListWorkflows(ctx context.Context, in *ListWorkflowsRequest, opts ...grpc.CallOption) (*ListWorkflowsResponse, error)
	// Gets details of a single workflow.
	GetWorkflow(ctx context.Context, in *GetWorkflowRequest, opts ...grpc.CallOption) (*Workflow, error)
	// Creates a new workflow. If a workflow with the specified name already
	// exists in the specified project and location, the long running operation
	// returns a [ALREADY_EXISTS][google.rpc.Code.ALREADY_EXISTS] error.
	CreateWorkflow(ctx context.Context, in *CreateWorkflowRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Deletes a workflow with the specified name.
	// This method also cancels and deletes all running executions of the
	// workflow.
	DeleteWorkflow(ctx context.Context, in *DeleteWorkflowRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Updates an existing workflow.
	// Running this method has no impact on already running executions of the
	// workflow. A new revision of the workflow might be created as a result of a
	// successful update operation. In that case, the new revision is used
	// in new workflow executions.
	UpdateWorkflow(ctx context.Context, in *UpdateWorkflowRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
	// Lists revisions for a given workflow.
	ListWorkflowRevisions(ctx context.Context, in *ListWorkflowRevisionsRequest, opts ...grpc.CallOption) (*ListWorkflowRevisionsResponse, error)
}

WorkflowsClient is the client API for Workflows service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewWorkflowsClient 

func NewWorkflowsClient(cc grpc.ClientConnInterface) WorkflowsClient

type WorkflowsServer 

type WorkflowsServer interface {
	// Lists workflows in a given project and location.
	// The default order is not specified.
	ListWorkflows(context.Context, *ListWorkflowsRequest) (*ListWorkflowsResponse, error)
	// Gets details of a single workflow.
	GetWorkflow(context.Context, *GetWorkflowRequest) (*Workflow, error)
	// Creates a new workflow. If a workflow with the specified name already
	// exists in the specified project and location, the long running operation
	// returns a [ALREADY_EXISTS][google.rpc.Code.ALREADY_EXISTS] error.
	CreateWorkflow(context.Context, *CreateWorkflowRequest) (*longrunningpb.Operation, error)
	// Deletes a workflow with the specified name.
	// This method also cancels and deletes all running executions of the
	// workflow.
	DeleteWorkflow(context.Context, *DeleteWorkflowRequest) (*longrunningpb.Operation, error)
	// Updates an existing workflow.
	// Running this method has no impact on already running executions of the
	// workflow. A new revision of the workflow might be created as a result of a
	// successful update operation. In that case, the new revision is used
	// in new workflow executions.
	UpdateWorkflow(context.Context, *UpdateWorkflowRequest) (*longrunningpb.Operation, error)
	// Lists revisions for a given workflow.
	ListWorkflowRevisions(context.Context, *ListWorkflowRevisionsRequest) (*ListWorkflowRevisionsResponse, error)
}

WorkflowsServer is the server API for Workflows 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.