Package cloud.google.com/go/run/apiv2/runpb (v0.5.0)

Variables

Condition_State_name, Condition_State_value

var (
	Condition_State_name = map[int32]string{
		0: "STATE_UNSPECIFIED",
		1: "CONDITION_PENDING",
		2: "CONDITION_RECONCILING",
		3: "CONDITION_FAILED",
		4: "CONDITION_SUCCEEDED",
	}
	Condition_State_value = map[string]int32{
		"STATE_UNSPECIFIED":     0,
		"CONDITION_PENDING":     1,
		"CONDITION_RECONCILING": 2,
		"CONDITION_FAILED":      3,
		"CONDITION_SUCCEEDED":   4,
	}
)

Enum value maps for Condition_State.

Condition_Severity_name, Condition_Severity_value

var (
	Condition_Severity_name = map[int32]string{
		0: "SEVERITY_UNSPECIFIED",
		1: "ERROR",
		2: "WARNING",
		3: "INFO",
	}
	Condition_Severity_value = map[string]int32{
		"SEVERITY_UNSPECIFIED": 0,
		"ERROR":                1,
		"WARNING":              2,
		"INFO":                 3,
	}
)

Enum value maps for Condition_Severity.

Condition_CommonReason_name, Condition_CommonReason_value

var (
	Condition_CommonReason_name = map[int32]string{
		0:  "COMMON_REASON_UNDEFINED",
		1:  "UNKNOWN",
		3:  "REVISION_FAILED",
		4:  "PROGRESS_DEADLINE_EXCEEDED",
		6:  "CONTAINER_MISSING",
		7:  "CONTAINER_PERMISSION_DENIED",
		8:  "CONTAINER_IMAGE_UNAUTHORIZED",
		9:  "CONTAINER_IMAGE_AUTHORIZATION_CHECK_FAILED",
		10: "ENCRYPTION_KEY_PERMISSION_DENIED",
		11: "ENCRYPTION_KEY_CHECK_FAILED",
		12: "SECRETS_ACCESS_CHECK_FAILED",
		13: "WAITING_FOR_OPERATION",
		14: "IMMEDIATE_RETRY",
		15: "POSTPONED_RETRY",
		16: "INTERNAL",
	}
	Condition_CommonReason_value = map[string]int32{
		"COMMON_REASON_UNDEFINED":                    0,
		"UNKNOWN":                                    1,
		"REVISION_FAILED":                            3,
		"PROGRESS_DEADLINE_EXCEEDED":                 4,
		"CONTAINER_MISSING":                          6,
		"CONTAINER_PERMISSION_DENIED":                7,
		"CONTAINER_IMAGE_UNAUTHORIZED":               8,
		"CONTAINER_IMAGE_AUTHORIZATION_CHECK_FAILED": 9,
		"ENCRYPTION_KEY_PERMISSION_DENIED":           10,
		"ENCRYPTION_KEY_CHECK_FAILED":                11,
		"SECRETS_ACCESS_CHECK_FAILED":                12,
		"WAITING_FOR_OPERATION":                      13,
		"IMMEDIATE_RETRY":                            14,
		"POSTPONED_RETRY":                            15,
		"INTERNAL":                                   16,
	}
)

Enum value maps for Condition_CommonReason.

Condition_RevisionReason_name, Condition_RevisionReason_value

var (
	Condition_RevisionReason_name = map[int32]string{
		0:  "REVISION_REASON_UNDEFINED",
		1:  "PENDING",
		2:  "RESERVE",
		3:  "RETIRED",
		4:  "RETIRING",
		5:  "RECREATING",
		6:  "HEALTH_CHECK_CONTAINER_ERROR",
		7:  "CUSTOMIZED_PATH_RESPONSE_PENDING",
		8:  "MIN_INSTANCES_NOT_PROVISIONED",
		9:  "ACTIVE_REVISION_LIMIT_REACHED",
		10: "NO_DEPLOYMENT",
		11: "HEALTH_CHECK_SKIPPED",
	}
	Condition_RevisionReason_value = map[string]int32{
		"REVISION_REASON_UNDEFINED":        0,
		"PENDING":                          1,
		"RESERVE":                          2,
		"RETIRED":                          3,
		"RETIRING":                         4,
		"RECREATING":                       5,
		"HEALTH_CHECK_CONTAINER_ERROR":     6,
		"CUSTOMIZED_PATH_RESPONSE_PENDING": 7,
		"MIN_INSTANCES_NOT_PROVISIONED":    8,
		"ACTIVE_REVISION_LIMIT_REACHED":    9,
		"NO_DEPLOYMENT":                    10,
		"HEALTH_CHECK_SKIPPED":             11,
	}
)

Enum value maps for Condition_RevisionReason.

Condition_ExecutionReason_name, Condition_ExecutionReason_value

var (
	Condition_ExecutionReason_name = map[int32]string{
		0: "EXECUTION_REASON_UNDEFINED",
		1: "JOB_STATUS_SERVICE_POLLING_ERROR",
		2: "NON_ZERO_EXIT_CODE",
		3: "CANCELLED",
	}
	Condition_ExecutionReason_value = map[string]int32{
		"EXECUTION_REASON_UNDEFINED":       0,
		"JOB_STATUS_SERVICE_POLLING_ERROR": 1,
		"NON_ZERO_EXIT_CODE":               2,
		"CANCELLED":                        3,
	}
)

Enum value maps for Condition_ExecutionReason.

TrafficTargetAllocationType_name, TrafficTargetAllocationType_value

var (
	TrafficTargetAllocationType_name = map[int32]string{
		0: "TRAFFIC_TARGET_ALLOCATION_TYPE_UNSPECIFIED",
		1: "TRAFFIC_TARGET_ALLOCATION_TYPE_LATEST",
		2: "TRAFFIC_TARGET_ALLOCATION_TYPE_REVISION",
	}
	TrafficTargetAllocationType_value = map[string]int32{
		"TRAFFIC_TARGET_ALLOCATION_TYPE_UNSPECIFIED": 0,
		"TRAFFIC_TARGET_ALLOCATION_TYPE_LATEST":      1,
		"TRAFFIC_TARGET_ALLOCATION_TYPE_REVISION":    2,
	}
)

Enum value maps for TrafficTargetAllocationType.

IngressTraffic_name, IngressTraffic_value

var (
	IngressTraffic_name = map[int32]string{
		0: "INGRESS_TRAFFIC_UNSPECIFIED",
		1: "INGRESS_TRAFFIC_ALL",
		2: "INGRESS_TRAFFIC_INTERNAL_ONLY",
		3: "INGRESS_TRAFFIC_INTERNAL_LOAD_BALANCER",
	}
	IngressTraffic_value = map[string]int32{
		"INGRESS_TRAFFIC_UNSPECIFIED":            0,
		"INGRESS_TRAFFIC_ALL":                    1,
		"INGRESS_TRAFFIC_INTERNAL_ONLY":          2,
		"INGRESS_TRAFFIC_INTERNAL_LOAD_BALANCER": 3,
	}
)

Enum value maps for IngressTraffic.

ExecutionEnvironment_name, ExecutionEnvironment_value

var (
	ExecutionEnvironment_name = map[int32]string{
		0: "EXECUTION_ENVIRONMENT_UNSPECIFIED",
		1: "EXECUTION_ENVIRONMENT_GEN1",
		2: "EXECUTION_ENVIRONMENT_GEN2",
	}
	ExecutionEnvironment_value = map[string]int32{
		"EXECUTION_ENVIRONMENT_UNSPECIFIED": 0,
		"EXECUTION_ENVIRONMENT_GEN1":        1,
		"EXECUTION_ENVIRONMENT_GEN2":        2,
	}
)

Enum value maps for ExecutionEnvironment.

VpcAccess_VpcEgress_name, VpcAccess_VpcEgress_value

var (
	VpcAccess_VpcEgress_name = map[int32]string{
		0: "VPC_EGRESS_UNSPECIFIED",
		1: "ALL_TRAFFIC",
		2: "PRIVATE_RANGES_ONLY",
	}
	VpcAccess_VpcEgress_value = map[string]int32{
		"VPC_EGRESS_UNSPECIFIED": 0,
		"ALL_TRAFFIC":            1,
		"PRIVATE_RANGES_ONLY":    2,
	}
)

Enum value maps for VpcAccess_VpcEgress.

File_google_cloud_run_v2_condition_proto

var File_google_cloud_run_v2_condition_proto protoreflect.FileDescriptor

File_google_cloud_run_v2_execution_proto

var File_google_cloud_run_v2_execution_proto protoreflect.FileDescriptor

File_google_cloud_run_v2_execution_template_proto

var File_google_cloud_run_v2_execution_template_proto protoreflect.FileDescriptor

File_google_cloud_run_v2_job_proto

var File_google_cloud_run_v2_job_proto protoreflect.FileDescriptor

File_google_cloud_run_v2_k8s_min_proto

var File_google_cloud_run_v2_k8s_min_proto protoreflect.FileDescriptor

File_google_cloud_run_v2_revision_proto

var File_google_cloud_run_v2_revision_proto protoreflect.FileDescriptor

File_google_cloud_run_v2_revision_template_proto

var File_google_cloud_run_v2_revision_template_proto protoreflect.FileDescriptor

File_google_cloud_run_v2_service_proto

var File_google_cloud_run_v2_service_proto protoreflect.FileDescriptor

File_google_cloud_run_v2_task_proto

var File_google_cloud_run_v2_task_proto protoreflect.FileDescriptor

File_google_cloud_run_v2_task_template_proto

var File_google_cloud_run_v2_task_template_proto protoreflect.FileDescriptor

File_google_cloud_run_v2_traffic_target_proto

var File_google_cloud_run_v2_traffic_target_proto protoreflect.FileDescriptor

File_google_cloud_run_v2_vendor_settings_proto

var File_google_cloud_run_v2_vendor_settings_proto protoreflect.FileDescriptor

Functions

func RegisterExecutionsServer

func RegisterExecutionsServer(s *grpc.Server, srv ExecutionsServer)

func RegisterJobsServer

func RegisterJobsServer(s *grpc.Server, srv JobsServer)

func RegisterRevisionsServer

func RegisterRevisionsServer(s *grpc.Server, srv RevisionsServer)

func RegisterServicesServer

func RegisterServicesServer(s *grpc.Server, srv ServicesServer)

func RegisterTasksServer

func RegisterTasksServer(s *grpc.Server, srv TasksServer)

BinaryAuthorization

type BinaryAuthorization struct {
	BinauthzMethod isBinaryAuthorization_BinauthzMethod `protobuf_oneof:"binauthz_method"`

	BreakglassJustification string "" /* 130 byte string literal not displayed */

}

Settings for Binary Authorization feature.

func (*BinaryAuthorization) Descriptor

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

Deprecated: Use BinaryAuthorization.ProtoReflect.Descriptor instead.

func (*BinaryAuthorization) GetBinauthzMethod

func (m *BinaryAuthorization) GetBinauthzMethod() isBinaryAuthorization_BinauthzMethod

func (*BinaryAuthorization) GetBreakglassJustification

func (x *BinaryAuthorization) GetBreakglassJustification() string

func (*BinaryAuthorization) GetUseDefault

func (x *BinaryAuthorization) GetUseDefault() bool

func (*BinaryAuthorization) ProtoMessage

func (*BinaryAuthorization) ProtoMessage()

func (*BinaryAuthorization) ProtoReflect

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

func (*BinaryAuthorization) Reset

func (x *BinaryAuthorization) Reset()

func (*BinaryAuthorization) String

func (x *BinaryAuthorization) String() string

BinaryAuthorization_UseDefault

type BinaryAuthorization_UseDefault struct {
	// If True, indicates to use the default project's binary authorization
	// policy. If False, binary authorization will be disabled.
	UseDefault bool `protobuf:"varint,1,opt,name=use_default,json=useDefault,proto3,oneof"`
}

CloudSqlInstance

type CloudSqlInstance struct {

	// The Cloud SQL instance connection names, as can be found in
	// https://console.cloud.google.com/sql/instances. Visit
	// https://cloud.google.com/sql/docs/mysql/connect-run for more information on
	// how to connect Cloud SQL and Cloud Run. Format:
	// {project}:{location}:{instance}
	Instances []string `protobuf:"bytes,1,rep,name=instances,proto3" json:"instances,omitempty"`
	// contains filtered or unexported fields
}

Represents a specific Cloud SQL instance.

func (*CloudSqlInstance) Descriptor

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

Deprecated: Use CloudSqlInstance.ProtoReflect.Descriptor instead.

func (*CloudSqlInstance) GetInstances

func (x *CloudSqlInstance) GetInstances() []string

func (*CloudSqlInstance) ProtoMessage

func (*CloudSqlInstance) ProtoMessage()

func (*CloudSqlInstance) ProtoReflect

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

func (*CloudSqlInstance) Reset

func (x *CloudSqlInstance) Reset()

func (*CloudSqlInstance) String

func (x *CloudSqlInstance) String() string

Condition

type Condition struct {

	// type is used to communicate the status of the reconciliation process.
	// See also:
	// https://github.com/knative/serving/blob/main/docs/spec/errors.md#error-conditions-and-reporting
	// Types common to all resources include:
	// * "Ready": True when the Resource is ready.
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// State of the condition.
	State Condition_State `protobuf:"varint,2,opt,name=state,proto3,enum=google.cloud.run.v2.Condition_State" json:"state,omitempty"`
	// Human readable message indicating details about the current status.
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	// Last time the condition transitioned from one status to another.
	LastTransitionTime *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=last_transition_time,json=lastTransitionTime,proto3" json:"last_transition_time,omitempty"`
	// How to interpret failures of this condition, one of Error, Warning, Info
	Severity Condition_Severity `protobuf:"varint,5,opt,name=severity,proto3,enum=google.cloud.run.v2.Condition_Severity" json:"severity,omitempty"`
	// The reason for this condition. Depending on the condition type,
	// it will populate one of these fields.
	// Successful conditions cannot have a reason.
	//
	// Types that are assignable to Reasons:
	//
	//	*Condition_Reason
	//	*Condition_RevisionReason_
	//	*Condition_ExecutionReason_
	Reasons isCondition_Reasons `protobuf_oneof:"reasons"`
	// contains filtered or unexported fields
}

Defines a status condition for a resource.

func (*Condition) Descriptor

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

Deprecated: Use Condition.ProtoReflect.Descriptor instead.

func (*Condition) GetExecutionReason

func (x *Condition) GetExecutionReason() Condition_ExecutionReason

func (*Condition) GetLastTransitionTime

func (x *Condition) GetLastTransitionTime() *timestamppb.Timestamp

func (*Condition) GetMessage

func (x *Condition) GetMessage() string

func (*Condition) GetReason

func (x *Condition) GetReason() Condition_CommonReason

func (*Condition) GetReasons

func (m *Condition) GetReasons() isCondition_Reasons

func (*Condition) GetRevisionReason

func (x *Condition) GetRevisionReason() Condition_RevisionReason

func (*Condition) GetSeverity

func (x *Condition) GetSeverity() Condition_Severity

func (*Condition) GetState

func (x *Condition) GetState() Condition_State

func (*Condition) GetType

func (x *Condition) GetType() string

func (*Condition) ProtoMessage

func (*Condition) ProtoMessage()

func (*Condition) ProtoReflect

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

func (*Condition) Reset

func (x *Condition) Reset()

func (*Condition) String

func (x *Condition) String() string

Condition_CommonReason

type Condition_CommonReason int32

Reasons common to all types of conditions.

Condition_COMMON_REASON_UNDEFINED, Condition_UNKNOWN, Condition_REVISION_FAILED, Condition_PROGRESS_DEADLINE_EXCEEDED, Condition_CONTAINER_MISSING, Condition_CONTAINER_PERMISSION_DENIED, Condition_CONTAINER_IMAGE_UNAUTHORIZED, Condition_CONTAINER_IMAGE_AUTHORIZATION_CHECK_FAILED, Condition_ENCRYPTION_KEY_PERMISSION_DENIED, Condition_ENCRYPTION_KEY_CHECK_FAILED, Condition_SECRETS_ACCESS_CHECK_FAILED, Condition_WAITING_FOR_OPERATION, Condition_IMMEDIATE_RETRY, Condition_POSTPONED_RETRY, Condition_INTERNAL

const (
	// Default value.
	Condition_COMMON_REASON_UNDEFINED Condition_CommonReason = 0
	// Reason unknown. Further details will be in message.
	Condition_UNKNOWN Condition_CommonReason = 1
	// Revision creation process failed.
	Condition_REVISION_FAILED Condition_CommonReason = 3
	// Timed out waiting for completion.
	Condition_PROGRESS_DEADLINE_EXCEEDED Condition_CommonReason = 4
	// The container image path is incorrect.
	Condition_CONTAINER_MISSING Condition_CommonReason = 6
	// Insufficient permissions on the container image.
	Condition_CONTAINER_PERMISSION_DENIED Condition_CommonReason = 7
	// Container image is not authorized by policy.
	Condition_CONTAINER_IMAGE_UNAUTHORIZED Condition_CommonReason = 8
	// Container image policy authorization check failed.
	Condition_CONTAINER_IMAGE_AUTHORIZATION_CHECK_FAILED Condition_CommonReason = 9
	// Insufficient permissions on encryption key.
	Condition_ENCRYPTION_KEY_PERMISSION_DENIED Condition_CommonReason = 10
	// Permission check on encryption key failed.
	Condition_ENCRYPTION_KEY_CHECK_FAILED Condition_CommonReason = 11
	// At least one Access check on secrets failed.
	Condition_SECRETS_ACCESS_CHECK_FAILED Condition_CommonReason = 12
	// Waiting for operation to complete.
	Condition_WAITING_FOR_OPERATION Condition_CommonReason = 13
	// System will retry immediately.
	Condition_IMMEDIATE_RETRY Condition_CommonReason = 14
	// System will retry later; current attempt failed.
	Condition_POSTPONED_RETRY Condition_CommonReason = 15
	// An internal error occurred. Further information may be in the message.
	Condition_INTERNAL Condition_CommonReason = 16
)

func (Condition_CommonReason) Descriptor

func (Condition_CommonReason) Enum

func (Condition_CommonReason) EnumDescriptor

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

Deprecated: Use Condition_CommonReason.Descriptor instead.

func (Condition_CommonReason) Number

func (Condition_CommonReason) String

func (x Condition_CommonReason) String() string

func (Condition_CommonReason) Type

Condition_ExecutionReason

type Condition_ExecutionReason int32

Reasons specific to Execution resource.

Condition_EXECUTION_REASON_UNDEFINED, Condition_JOB_STATUS_SERVICE_POLLING_ERROR, Condition_NON_ZERO_EXIT_CODE, Condition_CANCELLED

const (
	// Default value.
	Condition_EXECUTION_REASON_UNDEFINED Condition_ExecutionReason = 0
	// Internal system error getting execution status. System will retry.
	Condition_JOB_STATUS_SERVICE_POLLING_ERROR Condition_ExecutionReason = 1
	// A task reached its retry limit and the last attempt failed due to the
	// user container exiting with a non-zero exit code.
	Condition_NON_ZERO_EXIT_CODE Condition_ExecutionReason = 2
	// The execution was cancelled by users.
	Condition_CANCELLED Condition_ExecutionReason = 3
)

func (Condition_ExecutionReason) Descriptor

func (Condition_ExecutionReason) Enum

func (Condition_ExecutionReason) EnumDescriptor

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

Deprecated: Use Condition_ExecutionReason.Descriptor instead.

func (Condition_ExecutionReason) Number

func (Condition_ExecutionReason) String

func (x Condition_ExecutionReason) String() string

func (Condition_ExecutionReason) Type

Condition_ExecutionReason_

type Condition_ExecutionReason_ struct {
	ExecutionReason Condition_ExecutionReason "" /* 131 byte string literal not displayed */
}

Condition_Reason

type Condition_Reason struct {
	// A common (service-level) reason for this condition.
	Reason Condition_CommonReason `protobuf:"varint,6,opt,name=reason,proto3,enum=google.cloud.run.v2.Condition_CommonReason,oneof"`
}

Condition_RevisionReason

type Condition_RevisionReason int32

Reasons specific to Revision resource.

Condition_REVISION_REASON_UNDEFINED, Condition_PENDING, Condition_RESERVE, Condition_RETIRED, Condition_RETIRING, Condition_RECREATING, Condition_HEALTH_CHECK_CONTAINER_ERROR, Condition_CUSTOMIZED_PATH_RESPONSE_PENDING, Condition_MIN_INSTANCES_NOT_PROVISIONED, Condition_ACTIVE_REVISION_LIMIT_REACHED, Condition_NO_DEPLOYMENT, Condition_HEALTH_CHECK_SKIPPED

const (
	// Default value.
	Condition_REVISION_REASON_UNDEFINED Condition_RevisionReason = 0
	// Revision in Pending state.
	Condition_PENDING Condition_RevisionReason = 1
	// Revision is in Reserve state.
	Condition_RESERVE Condition_RevisionReason = 2
	// Revision is Retired.
	Condition_RETIRED Condition_RevisionReason = 3
	// Revision is being retired.
	Condition_RETIRING Condition_RevisionReason = 4
	// Revision is being recreated.
	Condition_RECREATING Condition_RevisionReason = 5
	// There was a health check error.
	Condition_HEALTH_CHECK_CONTAINER_ERROR Condition_RevisionReason = 6
	// Health check failed due to user error from customized path of the
	// container. System will retry.
	Condition_CUSTOMIZED_PATH_RESPONSE_PENDING Condition_RevisionReason = 7
	// A revision with min_instance_count > 0 was created and is reserved, but
	// it was not configured to serve traffic, so it's not live. This can also
	// happen momentarily during traffic migration.
	Condition_MIN_INSTANCES_NOT_PROVISIONED Condition_RevisionReason = 8
	// The maximum allowed number of active revisions has been reached.
	Condition_ACTIVE_REVISION_LIMIT_REACHED Condition_RevisionReason = 9
	// There was no deployment defined.
	// This value is no longer used, but Services created in older versions of
	// the API might contain this value.
	Condition_NO_DEPLOYMENT Condition_RevisionReason = 10
	// A revision's container has no port specified since the revision is of a
	// manually scaled service with 0 instance count
	Condition_HEALTH_CHECK_SKIPPED Condition_RevisionReason = 11
)

func (Condition_RevisionReason) Descriptor

func (Condition_RevisionReason) Enum

func (Condition_RevisionReason) EnumDescriptor

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

Deprecated: Use Condition_RevisionReason.Descriptor instead.

func (Condition_RevisionReason) Number

func (Condition_RevisionReason) String

func (x Condition_RevisionReason) String() string

func (Condition_RevisionReason) Type

Condition_RevisionReason_

type Condition_RevisionReason_ struct {
	RevisionReason Condition_RevisionReason "" /* 127 byte string literal not displayed */
}

Condition_Severity

type Condition_Severity int32

Represents the severity of the condition failures.

Condition_SEVERITY_UNSPECIFIED, Condition_ERROR, Condition_WARNING, Condition_INFO

const (
	// Unspecified severity
	Condition_SEVERITY_UNSPECIFIED Condition_Severity = 0
	// Error severity.
	Condition_ERROR Condition_Severity = 1
	// Warning severity.
	Condition_WARNING Condition_Severity = 2
	// Info severity.
	Condition_INFO Condition_Severity = 3
)

func (Condition_Severity) Descriptor

func (Condition_Severity) Enum

func (Condition_Severity) EnumDescriptor

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

Deprecated: Use Condition_Severity.Descriptor instead.

func (Condition_Severity) Number

func (Condition_Severity) String

func (x Condition_Severity) String() string

func (Condition_Severity) Type

Condition_State

type Condition_State int32

Represents the possible Condition states.

Condition_STATE_UNSPECIFIED, Condition_CONDITION_PENDING, Condition_CONDITION_RECONCILING, Condition_CONDITION_FAILED, Condition_CONDITION_SUCCEEDED

const (
	// The default value. This value is used if the state is omitted.
	Condition_STATE_UNSPECIFIED Condition_State = 0
	// Transient state: Reconciliation has not started yet.
	Condition_CONDITION_PENDING Condition_State = 1
	// Transient state: reconciliation is still in progress.
	Condition_CONDITION_RECONCILING Condition_State = 2
	// Terminal state: Reconciliation did not succeed.
	Condition_CONDITION_FAILED Condition_State = 3
	// Terminal state: Reconciliation completed successfully.
	Condition_CONDITION_SUCCEEDED Condition_State = 4
)

func (Condition_State) Descriptor

func (Condition_State) Enum

func (x Condition_State) Enum() *Condition_State

func (Condition_State) EnumDescriptor

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

Deprecated: Use Condition_State.Descriptor instead.

func (Condition_State) Number

func (Condition_State) String

func (x Condition_State) String() string

func (Condition_State) Type

Container

type Container struct {

	// Name of the container specified as a DNS_LABEL.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Required. URL of the Container image in Google Container Registry or Google Artifact
	// Registry. More info: https://kubernetes.io/docs/concepts/containers/images
	Image string `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	// Entrypoint array. Not executed within a shell.
	// The docker image's ENTRYPOINT is used if this is not provided.
	// Variable references $(VAR_NAME) are expanded using the container's
	// environment. If a variable cannot be resolved, the reference in the input
	// string will be unchanged. The $(VAR_NAME) syntax can be escaped with a
	// double $$, ie: $$(VAR_NAME). Escaped references will never be expanded,
	// regardless of whether the variable exists or not.
	// More info:
	// https://kubernetes.io/docs/tasks/inject-data-application/define-command-argument-container/#running-a-command-in-a-shell
	Command []string `protobuf:"bytes,3,rep,name=command,proto3" json:"command,omitempty"`
	// Arguments to the entrypoint.
	// The docker image's CMD is used if this is not provided.
	// Variable references $(VAR_NAME) are expanded using the container's
	// environment. If a variable cannot be resolved, the reference in the input
	// string will be unchanged. The $(VAR_NAME) syntax can be escaped with a
	// double $$, ie: $$(VAR_NAME). Escaped references will never be expanded,
	// regardless of whether the variable exists or not.
	// More info:
	// https://kubernetes.io/docs/tasks/inject-data-application/define-command-argument-container/#running-a-command-in-a-shell
	Args []string `protobuf:"bytes,4,rep,name=args,proto3" json:"args,omitempty"`
	// List of environment variables to set in the container.
	Env []*EnvVar `protobuf:"bytes,5,rep,name=env,proto3" json:"env,omitempty"`
	// Compute Resource requirements by this container.
	// More info:
	// https://kubernetes.io/docs/concepts/storage/persistent-volumes#resources
	Resources *ResourceRequirements `protobuf:"bytes,6,opt,name=resources,proto3" json:"resources,omitempty"`
	// List of ports to expose from the container. Only a single port can be
	// specified. The specified ports must be listening on all interfaces
	// (0.0.0.0) within the container to be accessible.
	//
	// If omitted, a port number will be chosen and passed to the container
	// through the PORT environment variable for the container to listen on.
	Ports []*ContainerPort `protobuf:"bytes,7,rep,name=ports,proto3" json:"ports,omitempty"`
	// Volume to mount into the container's filesystem.
	VolumeMounts []*VolumeMount `protobuf:"bytes,8,rep,name=volume_mounts,json=volumeMounts,proto3" json:"volume_mounts,omitempty"`
	// Container's working directory.
	// If not specified, the container runtime's default will be used, which
	// might be configured in the container image.
	WorkingDir string `protobuf:"bytes,9,opt,name=working_dir,json=workingDir,proto3" json:"working_dir,omitempty"`
	// Periodic probe of container liveness.
	// Container will be restarted if the probe fails.
	// More info:
	// https://kubernetes.io/docs/concepts/workloads/pods/pod-lifecycle#container-probes
	LivenessProbe *Probe `protobuf:"bytes,10,opt,name=liveness_probe,json=livenessProbe,proto3" json:"liveness_probe,omitempty"`
	// Startup probe of application within the container.
	// All other probes are disabled if a startup probe is provided, until it
	// succeeds. Container will not be added to service endpoints if the probe
	// fails.
	// More info:
	// https://kubernetes.io/docs/concepts/workloads/pods/pod-lifecycle#container-probes
	StartupProbe *Probe `protobuf:"bytes,11,opt,name=startup_probe,json=startupProbe,proto3" json:"startup_probe,omitempty"`
	// contains filtered or unexported fields
}

A single application container. This specifies both the container to run, the command to run in the container and the arguments to supply to it. Note that additional arguments may be supplied by the system to the container at runtime.

func (*Container) Descriptor

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

Deprecated: Use Container.ProtoReflect.Descriptor instead.

func (*Container) GetArgs

func (x *Container) GetArgs() []string

func (*Container) GetCommand

func (x *Container) GetCommand() []string

func (*Container) GetEnv

func (x *Container) GetEnv() []*EnvVar

func (*Container) GetImage

func (x *Container) GetImage() string

func (*Container) GetLivenessProbe

func (x *Container) GetLivenessProbe() *Probe

func (*Container) GetName

func (x *Container) GetName() string

func (*Container) GetPorts

func (x *Container) GetPorts() []*ContainerPort

func (*Container) GetResources

func (x *Container) GetResources() *ResourceRequirements

func (*Container) GetStartupProbe

func (x *Container) GetStartupProbe() *Probe

func (*Container) GetVolumeMounts

func (x *Container) GetVolumeMounts() []*VolumeMount

func (*Container) GetWorkingDir

func (x *Container) GetWorkingDir() string

func (*Container) ProtoMessage

func (*Container) ProtoMessage()

func (*Container) ProtoReflect

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

func (*Container) Reset

func (x *Container) Reset()

func (*Container) String

func (x *Container) String() string

ContainerPort

type ContainerPort struct {

	// If specified, used to specify which protocol to use.
	// Allowed values are "http1" and "h2c".
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Port number the container listens on.
	// This must be a valid TCP port number, 0 < container_port="">< 65536.="" containerport="">int32 `protobuf:"varint,3,opt,name=container_port,json=containerPort,proto3" json:"container_port,omitempty"`
	// contains filtered or unexported fields
}

ContainerPort represents a network port in a single container.

func (*ContainerPort) Descriptor

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

Deprecated: Use ContainerPort.ProtoReflect.Descriptor instead.

func (*ContainerPort) GetContainerPort

func (x *ContainerPort) GetContainerPort() int32

func (*ContainerPort) GetName

func (x *ContainerPort) GetName() string

func (*ContainerPort) ProtoMessage

func (*ContainerPort) ProtoMessage()

func (*ContainerPort) ProtoReflect

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

func (*ContainerPort) Reset

func (x *ContainerPort) Reset()

func (*ContainerPort) String

func (x *ContainerPort) String() string

CreateJobRequest

type CreateJobRequest struct {

	// Required. The location and project in which this Job should be created.
	// Format: projects/{project}/locations/{location}, where {project} can be
	// project id or number.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The Job instance to create.
	Job *Job `protobuf:"bytes,2,opt,name=job,proto3" json:"job,omitempty"`
	// Required. The unique identifier for the Job. The name of the job becomes
	// {parent}/jobs/{job_id}.
	JobId string `protobuf:"bytes,3,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// Indicates that the request should be validated and default values
	// populated, without persisting the request or creating any resources.
	ValidateOnly bool `protobuf:"varint,4,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

Request message for creating a Job.

func (*CreateJobRequest) Descriptor

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

Deprecated: Use CreateJobRequest.ProtoReflect.Descriptor instead.

func (*CreateJobRequest) GetJob

func (x *CreateJobRequest) GetJob() *Job

func (*CreateJobRequest) GetJobId

func (x *CreateJobRequest) GetJobId() string

func (*CreateJobRequest) GetParent

func (x *CreateJobRequest) GetParent() string

func (*CreateJobRequest) GetValidateOnly

func (x *CreateJobRequest) GetValidateOnly() bool

func (*CreateJobRequest) ProtoMessage

func (*CreateJobRequest) ProtoMessage()

func (*CreateJobRequest) ProtoReflect

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

func (*CreateJobRequest) Reset

func (x *CreateJobRequest) Reset()

func (*CreateJobRequest) String

func (x *CreateJobRequest) String() string

CreateServiceRequest

type CreateServiceRequest struct {

	// Required. The location and project in which this service should be created.
	// Format: projects/{project}/locations/{location}, where {project} can be
	// project id or number. Only lowercase characters, digits, and hyphens.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Required. The Service instance to create.
	Service *Service `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	// Required. The unique identifier for the Service. It must begin with letter,
	// and cannot end with hyphen; must contain fewer than 50 characters.
	// The name of the service becomes {parent}/services/{service_id}.
	ServiceId string `protobuf:"bytes,3,opt,name=service_id,json=serviceId,proto3" json:"service_id,omitempty"`
	// Indicates that the request should be validated and default values
	// populated, without persisting the request or creating any resources.
	ValidateOnly bool `protobuf:"varint,4,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// contains filtered or unexported fields
}

Request message for creating a Service.

func (*CreateServiceRequest) Descriptor

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

Deprecated: Use CreateServiceRequest.ProtoReflect.Descriptor instead.

func (*CreateServiceRequest) GetParent

func (x *CreateServiceRequest) GetParent() string

func (*CreateServiceRequest) GetService

func (x *CreateServiceRequest) GetService() *Service

func (*CreateServiceRequest) GetServiceId

func (x *CreateServiceRequest) GetServiceId() string

func (*CreateServiceRequest) GetValidateOnly

func (x *CreateServiceRequest) GetValidateOnly() bool

func (*CreateServiceRequest) ProtoMessage

func (*CreateServiceRequest) ProtoMessage()

func (*CreateServiceRequest) ProtoReflect

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

func (*CreateServiceRequest) Reset

func (x *CreateServiceRequest) Reset()

func (*CreateServiceRequest) String

func (x *CreateServiceRequest) String() string

DeleteExecutionRequest

type DeleteExecutionRequest struct {

	// Required. The name of the Execution to delete.
	// Format:
	// projects/{project}/locations/{location}/jobs/{job}/executions/{execution},
	// where {project} can be project id or number.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Indicates that the request should be validated without actually
	// deleting any resources.
	ValidateOnly bool `protobuf:"varint,2,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// A system-generated fingerprint for this version of the resource.
	// This may be used to detect modification conflict during updates.
	Etag string `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"`
	// contains filtered or unexported fields
}

Request message for deleting an Execution.

func (*DeleteExecutionRequest) Descriptor

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

Deprecated: Use DeleteExecutionRequest.ProtoReflect.Descriptor instead.

func (*DeleteExecutionRequest) GetEtag

func (x *DeleteExecutionRequest) GetEtag() string

func (*DeleteExecutionRequest) GetName

func (x *DeleteExecutionRequest) GetName() string

func (*DeleteExecutionRequest) GetValidateOnly

func (x *DeleteExecutionRequest) GetValidateOnly() bool

func (*DeleteExecutionRequest) ProtoMessage

func (*DeleteExecutionRequest) ProtoMessage()

func (*DeleteExecutionRequest) ProtoReflect

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

func (*DeleteExecutionRequest) Reset

func (x *DeleteExecutionRequest) Reset()

func (*DeleteExecutionRequest) String

func (x *DeleteExecutionRequest) String() string

DeleteJobRequest

type DeleteJobRequest struct {

	// Required. The full name of the Job.
	// Format: projects/{project}/locations/{location}/jobs/{job}, where {project}
	// can be project id or number.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Indicates that the request should be validated without actually
	// deleting any resources.
	ValidateOnly bool `protobuf:"varint,3,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// A system-generated fingerprint for this version of the
	// resource. May be used to detect modification conflict during updates.
	Etag string `protobuf:"bytes,4,opt,name=etag,proto3" json:"etag,omitempty"`
	// contains filtered or unexported fields
}

Request message to delete a Job by its full name.

func (*DeleteJobRequest) Descriptor

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

Deprecated: Use DeleteJobRequest.ProtoReflect.Descriptor instead.

func (*DeleteJobRequest) GetEtag

func (x *DeleteJobRequest) GetEtag() string

func (*DeleteJobRequest) GetName

func (x *DeleteJobRequest) GetName() string

func (*DeleteJobRequest) GetValidateOnly

func (x *DeleteJobRequest) GetValidateOnly() bool

func (*DeleteJobRequest) ProtoMessage

func (*DeleteJobRequest) ProtoMessage()

func (*DeleteJobRequest) ProtoReflect

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

func (*DeleteJobRequest) Reset

func (x *DeleteJobRequest) Reset()

func (*DeleteJobRequest) String

func (x *DeleteJobRequest) String() string

DeleteRevisionRequest

type DeleteRevisionRequest struct {

	// Required. The name of the Revision to delete.
	// Format:
	// projects/{project}/locations/{location}/services/{service}/revisions/{revision}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Indicates that the request should be validated without actually
	// deleting any resources.
	ValidateOnly bool `protobuf:"varint,2,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// A system-generated fingerprint for this version of the
	// resource. This may be used to detect modification conflict during updates.
	Etag string `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"`
	// contains filtered or unexported fields
}

Request message for deleting a retired Revision. Revision lifecycle is usually managed by making changes to the parent Service. Only retired revisions can be deleted with this API.

func (*DeleteRevisionRequest) Descriptor

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

Deprecated: Use DeleteRevisionRequest.ProtoReflect.Descriptor instead.

func (*DeleteRevisionRequest) GetEtag

func (x *DeleteRevisionRequest) GetEtag() string

func (*DeleteRevisionRequest) GetName

func (x *DeleteRevisionRequest) GetName() string

func (*DeleteRevisionRequest) GetValidateOnly

func (x *DeleteRevisionRequest) GetValidateOnly() bool

func (*DeleteRevisionRequest) ProtoMessage

func (*DeleteRevisionRequest) ProtoMessage()

func (*DeleteRevisionRequest) ProtoReflect

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

func (*DeleteRevisionRequest) Reset

func (x *DeleteRevisionRequest) Reset()

func (*DeleteRevisionRequest) String

func (x *DeleteRevisionRequest) String() string

DeleteServiceRequest

type DeleteServiceRequest struct {

	// Required. The full name of the Service.
	// Format: projects/{project}/locations/{location}/services/{service}, where
	// {project} can be project id or number.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Indicates that the request should be validated without actually
	// deleting any resources.
	ValidateOnly bool `protobuf:"varint,2,opt,name=validate_only,json=validateOnly,proto3" json:"validate_only,omitempty"`
	// A system-generated fingerprint for this version of the
	// resource. May be used to detect modification conflict during updates.
	Etag string `protobuf:"bytes,3,opt,name=etag,proto3" json:"etag,omitempty"`
	// contains filtered or unexported fields
}

Request message to delete a Service by its full name.

func (*DeleteServiceRequest) Descriptor

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

Deprecated: Use DeleteServiceRequest.ProtoReflect.Descriptor instead.

func (*DeleteServiceRequest) GetEtag

func (x *DeleteServiceRequest) GetEtag() string

func (*DeleteServiceRequest) GetName

func (x *DeleteServiceRequest) GetName() string

func (*DeleteServiceRequest) GetValidateOnly

func (x *DeleteServiceRequest) GetValidateOnly() bool

func (*DeleteServiceRequest) ProtoMessage

func (*DeleteServiceRequest) ProtoMessage()

func (*DeleteServiceRequest) ProtoReflect

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

func (*DeleteServiceRequest) Reset

func (x *DeleteServiceRequest) Reset()

func (*DeleteServiceRequest) String

func (x *DeleteServiceRequest) String() string

EnvVar

type EnvVar struct {

	// Required. Name of the environment variable. Must be a C_IDENTIFIER, and mnay not
	// exceed 32768 characters.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Types that are assignable to Values:
	//
	//	*EnvVar_Value
	//	*EnvVar_ValueSource
	Values isEnvVar_Values `protobuf_oneof:"values"`
	// contains filtered or unexported fields
}

EnvVar represents an environment variable present in a Container.

func (*EnvVar) Descriptor

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

Deprecated: Use EnvVar.ProtoReflect.Descriptor instead.

func (*EnvVar) GetName

func (x *EnvVar) GetName() string

func (*EnvVar) GetValue

func (x *EnvVar) GetValue() string

func (*EnvVar) GetValueSource

func (x *EnvVar) GetValueSource() *EnvVarSource

func (*EnvVar) GetValues

func (m *EnvVar) GetValues() isEnvVar_Values

func (*EnvVar) ProtoMessage

func (*EnvVar) ProtoMessage()

func (*EnvVar) ProtoReflect

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

func (*EnvVar) Reset

func (x *EnvVar) Reset()

func (*EnvVar) String

func (x *EnvVar) String() string

EnvVarSource

type EnvVarSource struct {

	// Selects a secret and a specific version from Cloud Secret Manager.
	SecretKeyRef *SecretKeySelector `protobuf:"bytes,1,opt,name=secret_key_ref,json=secretKeyRef,proto3" json:"secret_key_ref,omitempty"`
	// contains filtered or unexported fields
}

EnvVarSource represents a source for the value of an EnvVar.

func (*EnvVarSource) Descriptor

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

Deprecated: Use EnvVarSource.ProtoReflect.Descriptor instead.

func (*EnvVarSource) GetSecretKeyRef

func (x *EnvVarSource) GetSecretKeyRef() *SecretKeySelector

func (*EnvVarSource) ProtoMessage

func (*EnvVarSource) ProtoMessage()

func (*EnvVarSource) ProtoReflect

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

func (*EnvVarSource) Reset

func (x *EnvVarSource) Reset()

func (*EnvVarSource) String

func (x *EnvVarSource) String() string

EnvVar_Value

type EnvVar_Value struct {
	// Variable references $(VAR_NAME) are expanded
	// using the previous defined environment variables in the container and
	// any route environment variables. If a variable cannot be resolved,
	// the reference in the input string will be unchanged. The $(VAR_NAME)
	// syntax can be escaped with a double $$, ie: $$(VAR_NAME). Escaped
	// references will never be expanded, regardless of whether the variable
	// exists or not.
	// Defaults to "", and the maximum length is 32768 bytes.
	Value string `protobuf:"bytes,2,opt,name=value,proto3,oneof"`
}

EnvVar_ValueSource

type EnvVar_ValueSource struct {
	// Source for the environment variable's value.
	ValueSource *EnvVarSource `protobuf:"bytes,3,opt,name=value_source,json=valueSource,proto3,oneof"`
}

Execution

type Execution struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`

	Generation int64 `protobuf:"varint,3,opt,name=generation,proto3" json:"generation,omitempty"`

	Labels map[string]string "" /* 153 byte string literal not displayed */

	Annotations map[string]string "" /* 163 byte string literal not displayed */

	CreateTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	StartTime *timestamppb.Timestamp `protobuf:"bytes,22,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`

	CompletionTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=completion_time,json=completionTime,proto3" json:"completion_time,omitempty"`

	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`

	DeleteTime *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=delete_time,json=deleteTime,proto3" json:"delete_time,omitempty"`

	ExpireTime *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`

	LaunchStage api.LaunchStage `protobuf:"varint,11,opt,name=launch_stage,json=launchStage,proto3,enum=google.api.LaunchStage" json:"launch_stage,omitempty"`

	Job string `protobuf:"bytes,12,opt,name=job,proto3" json:"job,omitempty"`

	Parallelism int32 `protobuf:"varint,13,opt,name=parallelism,proto3" json:"parallelism,omitempty"`

	TaskCount int32 `protobuf:"varint,14,opt,name=task_count,json=taskCount,proto3" json:"task_count,omitempty"`

	Template *TaskTemplate `protobuf:"bytes,15,opt,name=template,proto3" json:"template,omitempty"`

	Reconciling bool `protobuf:"varint,16,opt,name=reconciling,proto3" json:"reconciling,omitempty"`

	Conditions []*Condition `protobuf:"bytes,17,rep,name=conditions,proto3" json:"conditions,omitempty"`

	ObservedGeneration int64 `protobuf:"varint,18,opt,name=observed_generation,json=observedGeneration,proto3" json:"observed_generation,omitempty"`

	RunningCount int32 `protobuf:"varint,19,opt,name=running_count,json=runningCount,proto3" json:"running_count,omitempty"`

	SucceededCount int32 `protobuf:"varint,20,opt,name=succeeded_count,json=succeededCount,proto3" json:"succeeded_count,omitempty"`

	FailedCount int32 `protobuf:"varint,21,opt,name=failed_count,json=failedCount,proto3" json:"failed_count,omitempty"`

	Etag string `protobuf:"bytes,99,opt,name=etag,proto3" json:"etag,omitempty"`

}

Execution represents the configuration of a single execution. A execution an immutable resource that references a container image which is run to completion.

func (*Execution) Descriptor

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

Deprecated: Use Execution.ProtoReflect.Descriptor instead.

func (*Execution) GetAnnotations

func (x *Execution) GetAnnotations() map[string]string

func (*Execution) GetCompletionTime

func (x *Execution) GetCompletionTime() *timestamppb.Timestamp

func (*Execution) GetConditions

func (x *Execution) GetConditions() []*Condition

func (*Execution) GetCreateTime

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

func (*Execution) GetDeleteTime

func (x *Execution) GetDeleteTime() *timestamppb.Timestamp

func (*Execution) GetEtag

func (x *Execution) GetEtag() string

func (*Execution) GetExpireTime

func (x *Execution) GetExpireTime() *timestamppb.Timestamp

func (*Execution) GetFailedCount

func (x *Execution) GetFailedCount() int32

func (*Execution) GetGeneration

func (x *Execution) GetGeneration() int64

func (*Execution) GetJob

func (x *Execution) GetJob() string

func (*Execution) GetLabels

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

func (*Execution) GetLaunchStage

func (x *Execution) GetLaunchStage() api.LaunchStage

func (*Execution) GetName

func (x *Execution) GetName() string

func (*Execution) GetObservedGeneration

func (x *Execution) GetObservedGeneration() int64

func (*Execution) GetParallelism

func (x *Execution) GetParallelism() int32

func (*Execution) GetReconciling

func (x *Execution) GetReconciling() bool

func (*Execution) GetRunningCount

func (x *Execution) GetRunningCount() int32

func (*Execution) GetStartTime

func (x *Execution) GetStartTime() *timestamppb.Timestamp

func (*Execution) GetSucceededCount

func (x *Execution) GetSucceededCount() int32

func (*Execution) GetTaskCount

func (x *Execution) GetTaskCount() int32

func (*Execution) GetTemplate

func (x *Execution) GetTemplate() *TaskTemplate

func (*Execution) GetUid

func (x *Execution) GetUid() string

func (*Execution) GetUpdateTime

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

func (*Execution) ProtoMessage

func (*Execution) ProtoMessage()

func (*Execution) ProtoReflect

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

func (*Execution) Reset

func (x *Execution) Reset()

func (*Execution) String

func (x *Execution) String() string

ExecutionEnvironment

type ExecutionEnvironment int32

Alternatives for execution environments.

ExecutionEnvironment_EXECUTION_ENVIRONMENT_UNSPECIFIED, ExecutionEnvironment_EXECUTION_ENVIRONMENT_GEN1, ExecutionEnvironment_EXECUTION_ENVIRONMENT_GEN2

const (
	// Unspecified
	ExecutionEnvironment_EXECUTION_ENVIRONMENT_UNSPECIFIED ExecutionEnvironment = 0
	// Uses the First Generation environment.
	ExecutionEnvironment_EXECUTION_ENVIRONMENT_GEN1 ExecutionEnvironment = 1
	// Uses Second Generation environment.
	ExecutionEnvironment_EXECUTION_ENVIRONMENT_GEN2 ExecutionEnvironment = 2
)

func (ExecutionEnvironment) Descriptor

func (ExecutionEnvironment) Enum

func (ExecutionEnvironment) EnumDescriptor

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

Deprecated: Use ExecutionEnvironment.Descriptor instead.

func (ExecutionEnvironment) Number

func (ExecutionEnvironment) String

func (x ExecutionEnvironment) String() string

func (ExecutionEnvironment) Type

ExecutionReference

type ExecutionReference struct {

	// Name of the execution.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Creation timestamp of the execution.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Creation timestamp of the execution.
	CompletionTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=completion_time,json=completionTime,proto3" json:"completion_time,omitempty"`
	// contains filtered or unexported fields
}

Reference to an Execution. Use /Executions.GetExecution with the given name to get full execution including the latest status.

func (*ExecutionReference) Descriptor

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

Deprecated: Use ExecutionReference.ProtoReflect.Descriptor instead.

func (*ExecutionReference) GetCompletionTime

func (x *ExecutionReference) GetCompletionTime() *timestamppb.Timestamp

func (*ExecutionReference) GetCreateTime

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

func (*ExecutionReference) GetName

func (x *ExecutionReference) GetName() string

func (*ExecutionReference) ProtoMessage

func (*ExecutionReference) ProtoMessage()

func (*ExecutionReference) ProtoReflect

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

func (*ExecutionReference) Reset

func (x *ExecutionReference) Reset()

func (*ExecutionReference) String

func (x *ExecutionReference) String() string

ExecutionTemplate

type ExecutionTemplate struct {
	Labels map[string]string "" /* 153 byte string literal not displayed */

	Annotations map[string]string "" /* 163 byte string literal not displayed */

	Parallelism int32 `protobuf:"varint,3,opt,name=parallelism,proto3" json:"parallelism,omitempty"`

	TaskCount int32 `protobuf:"varint,4,opt,name=task_count,json=taskCount,proto3" json:"task_count,omitempty"`

	Template *TaskTemplate `protobuf:"bytes,5,opt,name=template,proto3" json:"template,omitempty"`

}

ExecutionTemplate describes the data an execution should have when created from a template.

func (*ExecutionTemplate) Descriptor

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

Deprecated: Use ExecutionTemplate.ProtoReflect.Descriptor instead.

func (*ExecutionTemplate) GetAnnotations

func (x *ExecutionTemplate) GetAnnotations() map[string]string

func (*ExecutionTemplate) GetLabels

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

func (*ExecutionTemplate) GetParallelism

func (x *ExecutionTemplate) GetParallelism() int32

func (*ExecutionTemplate) GetTaskCount

func (x *ExecutionTemplate) GetTaskCount() int32

func (*ExecutionTemplate) GetTemplate

func (x *ExecutionTemplate) GetTemplate() *TaskTemplate

func (*ExecutionTemplate) ProtoMessage

func (*ExecutionTemplate) ProtoMessage()

func (*ExecutionTemplate) ProtoReflect

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

func (*ExecutionTemplate) Reset

func (x *ExecutionTemplate) Reset()

func (*ExecutionTemplate) String

func (x *ExecutionTemplate) String() string

ExecutionsClient

type ExecutionsClient interface {
	// Gets information about an Execution.
	GetExecution(ctx context.Context, in *GetExecutionRequest, opts ...grpc.CallOption) (*Execution, error)
	// Lists Executions from a Job.
	ListExecutions(ctx context.Context, in *ListExecutionsRequest, opts ...grpc.CallOption) (*ListExecutionsResponse, error)
	// Deletes an Execution.
	DeleteExecution(ctx context.Context, in *DeleteExecutionRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
}

ExecutionsClient is the client API for Executions service.

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

func NewExecutionsClient

func NewExecutionsClient(cc grpc.ClientConnInterface) ExecutionsClient

ExecutionsServer

type ExecutionsServer interface {
	// Gets information about an Execution.
	GetExecution(context.Context, *GetExecutionRequest) (*Execution, error)
	// Lists Executions from a Job.
	ListExecutions(context.Context, *ListExecutionsRequest) (*ListExecutionsResponse, error)
	// Deletes an Execution.
	DeleteExecution(context.Context, *DeleteExecutionRequest) (*longrunning.Operation, error)
}

ExecutionsServer is the server API for Executions service.

GRPCAction

type GRPCAction struct {

	// Port number of the gRPC service. Number must be in the range 1 to 65535.
	// If not specified, defaults to 8080.
	Port int32 `protobuf:"varint,1,opt,name=port,proto3" json:"port,omitempty"`
	// Service is the name of the service to place in the gRPC HealthCheckRequest
	// (see https://github.com/grpc/grpc/blob/master/doc/health-checking.md). If
	// this is not specified, the default behavior is defined by gRPC.
	Service string `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

GRPCAction describes an action involving a GRPC port.

func (*GRPCAction) Descriptor

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

Deprecated: Use GRPCAction.ProtoReflect.Descriptor instead.

func (*GRPCAction) GetPort

func (x *GRPCAction) GetPort() int32

func (*GRPCAction) GetService

func (x *GRPCAction) GetService() string

func (*GRPCAction) ProtoMessage

func (*GRPCAction) ProtoMessage()

func (*GRPCAction) ProtoReflect

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

func (*GRPCAction) Reset

func (x *GRPCAction) Reset()

func (*GRPCAction) String

func (x *GRPCAction) String() string

GetExecutionRequest

type GetExecutionRequest struct {

	// Required. The full name of the Execution.
	// Format:
	// projects/{project}/locations/{location}/jobs/{job}/executions/{execution},
	// where {project} can be project id or number.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request message for obtaining a Execution by its full name.

func (*GetExecutionRequest) Descriptor

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

Deprecated: Use GetExecutionRequest.ProtoReflect.Descriptor instead.

func (*GetExecutionRequest) GetName

func (x *GetExecutionRequest) GetName() string

func (*GetExecutionRequest) ProtoMessage

func (*GetExecutionRequest) ProtoMessage()

func (*GetExecutionRequest) ProtoReflect

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

func (*GetExecutionRequest) Reset

func (x *GetExecutionRequest) Reset()

func (*GetExecutionRequest) String

func (x *GetExecutionRequest) String() string

GetJobRequest

type GetJobRequest struct {

	// Required. The full name of the Job.
	// Format: projects/{project}/locations/{location}/jobs/{job}, where {project}
	// can be project id or number.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request message for obtaining a Job by its full name.

func (*GetJobRequest) Descriptor

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

Deprecated: Use GetJobRequest.ProtoReflect.Descriptor instead.

func (*GetJobRequest) GetName

func (x *GetJobRequest) GetName() string

func (*GetJobRequest) ProtoMessage

func (*GetJobRequest) ProtoMessage()

func (*GetJobRequest) ProtoReflect

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

func (*GetJobRequest) Reset

func (x *GetJobRequest) Reset()

func (*GetJobRequest) String

func (x *GetJobRequest) String() string

GetRevisionRequest

type GetRevisionRequest struct {

	// Required. The full name of the Revision.
	// Format:
	// projects/{project}/locations/{location}/services/{service}/revisions/{revision}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request message for obtaining a Revision by its full name.

func (*GetRevisionRequest) Descriptor

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

Deprecated: Use GetRevisionRequest.ProtoReflect.Descriptor instead.

func (*GetRevisionRequest) GetName

func (x *GetRevisionRequest) GetName() string

func (*GetRevisionRequest) ProtoMessage

func (*GetRevisionRequest) ProtoMessage()

func (*GetRevisionRequest) ProtoReflect

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

func (*GetRevisionRequest) Reset

func (x *GetRevisionRequest) Reset()

func (*GetRevisionRequest) String

func (x *GetRevisionRequest) String() string

GetServiceRequest

type GetServiceRequest struct {

	// Required. The full name of the Service.
	// Format: projects/{project}/locations/{location}/services/{service}, where
	// {project} can be project id or number.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request message for obtaining a Service by its full name.

func (*GetServiceRequest) Descriptor

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

Deprecated: Use GetServiceRequest.ProtoReflect.Descriptor instead.

func (*GetServiceRequest) GetName

func (x *GetServiceRequest) GetName() string

func (*GetServiceRequest) ProtoMessage

func (*GetServiceRequest) ProtoMessage()

func (*GetServiceRequest) ProtoReflect

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

func (*GetServiceRequest) Reset

func (x *GetServiceRequest) Reset()

func (*GetServiceRequest) String

func (x *GetServiceRequest) String() string

GetTaskRequest

type GetTaskRequest struct {

	// Required. The full name of the Task.
	// Format:
	// projects/{project}/locations/{location}/jobs/{job}/executions/{execution}/tasks/{task}
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Request message for obtaining a Task by its full name.

func (*GetTaskRequest) Descriptor

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

Deprecated: Use GetTaskRequest.ProtoReflect.Descriptor instead.

func (*GetTaskRequest) GetName

func (x *GetTaskRequest) GetName() string

func (*GetTaskRequest) ProtoMessage

func (*GetTaskRequest) ProtoMessage()

func (*GetTaskRequest) ProtoReflect

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

func (*GetTaskRequest) Reset

func (x *GetTaskRequest) Reset()

func (*GetTaskRequest) String

func (x *GetTaskRequest) String() string

HTTPGetAction

type HTTPGetAction struct {

	// Path to access on the HTTP server. Defaults to '/'.
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	// Custom headers to set in the request. HTTP allows repeated headers.
	HttpHeaders []*HTTPHeader `protobuf:"bytes,4,rep,name=http_headers,json=httpHeaders,proto3" json:"http_headers,omitempty"`
	// contains filtered or unexported fields
}

HTTPGetAction describes an action based on HTTP Get requests.

func (*HTTPGetAction) Descriptor

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

Deprecated: Use HTTPGetAction.ProtoReflect.Descriptor instead.

func (*HTTPGetAction) GetHttpHeaders

func (x *HTTPGetAction) GetHttpHeaders() []*HTTPHeader

func (*HTTPGetAction) GetPath

func (x *HTTPGetAction) GetPath() string

func (*HTTPGetAction) ProtoMessage

func (*HTTPGetAction) ProtoMessage()

func (*HTTPGetAction) ProtoReflect

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

func (*HTTPGetAction) Reset

func (x *HTTPGetAction) Reset()

func (*HTTPGetAction) String

func (x *HTTPGetAction) String() string

HTTPHeader

type HTTPHeader struct {

	// Required. The header field name
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The header field value
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

HTTPHeader describes a custom header to be used in HTTP probes

func (*HTTPHeader) Descriptor

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

Deprecated: Use HTTPHeader.ProtoReflect.Descriptor instead.

func (*HTTPHeader) GetName

func (x *HTTPHeader) GetName() string

func (*HTTPHeader) GetValue

func (x *HTTPHeader) GetValue() string

func (*HTTPHeader) ProtoMessage

func (*HTTPHeader) ProtoMessage()

func (*HTTPHeader) ProtoReflect

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

func (*HTTPHeader) Reset

func (x *HTTPHeader) Reset()

func (*HTTPHeader) String

func (x *HTTPHeader) String() string

IngressTraffic

type IngressTraffic int32

Allowed ingress traffic for the Container.

IngressTraffic_INGRESS_TRAFFIC_UNSPECIFIED, IngressTraffic_INGRESS_TRAFFIC_ALL, IngressTraffic_INGRESS_TRAFFIC_INTERNAL_ONLY, IngressTraffic_INGRESS_TRAFFIC_INTERNAL_LOAD_BALANCER

const (
	// Unspecified
	IngressTraffic_INGRESS_TRAFFIC_UNSPECIFIED IngressTraffic = 0
	// All inbound traffic is allowed.
	IngressTraffic_INGRESS_TRAFFIC_ALL IngressTraffic = 1
	// Only internal traffic is allowed.
	IngressTraffic_INGRESS_TRAFFIC_INTERNAL_ONLY IngressTraffic = 2
	// Both internal and Google Cloud Load Balancer traffic is allowed.
	IngressTraffic_INGRESS_TRAFFIC_INTERNAL_LOAD_BALANCER IngressTraffic = 3
)

func (IngressTraffic) Descriptor

func (IngressTraffic) Enum

func (x IngressTraffic) Enum() *IngressTraffic

func (IngressTraffic) EnumDescriptor

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

Deprecated: Use IngressTraffic.Descriptor instead.

func (IngressTraffic) Number

func (IngressTraffic) String

func (x IngressTraffic) String() string

func (IngressTraffic) Type

Job

type Job struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`

	Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`

	Generation int64 `protobuf:"varint,3,opt,name=generation,proto3" json:"generation,omitempty"`

	Labels map[string]string "" /* 153 byte string literal not displayed */

	Annotations map[string]string "" /* 163 byte string literal not displayed */

	CreateTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`

	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`

	DeleteTime *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=delete_time,json=deleteTime,proto3" json:"delete_time,omitempty"`

	ExpireTime *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=expire_time,json=expireTime,proto3" json:"expire_time,omitempty"`

	Creator string `protobuf:"bytes,10,opt,name=creator,proto3" json:"creator,omitempty"`

	LastModifier string `protobuf:"bytes,11,opt,name=last_modifier,json=lastModifier,proto3" json:"last_modifier,omitempty"`

	Client string `protobuf:"bytes,12,opt,name=client,proto3" json:"client,omitempty"`

	ClientVersion string `protobuf:"bytes,13,opt,name=client_version,json=clientVersion,proto3" json:"client_version,omitempty"`

	LaunchStage api.LaunchStage `protobuf:"varint,14,opt,name=launch_stage,json=launchStage,proto3,enum=google.api.LaunchStage" json:"launch_stage,omitempty"`

	BinaryAuthorization *BinaryAuthorization `protobuf:"bytes,15,opt,name=binary_authorization,json=binaryAuthorization,proto3" json:"binary_authorization,omitempty"`

	Template *ExecutionTemplate `protobuf:"bytes,16,opt,name=template,proto3" json:"template,omitempty"`

	ObservedGeneration int64 `protobuf:"varint,17,opt,name=observed_generation,json=observedGeneration,proto3" json:"observed_generation,omitempty"`

	TerminalCondition *Condition `protobuf:"bytes,18,opt,name=terminal_condition,json=terminalCondition,proto3" json:"terminal_condition,omitempty"`

	Conditions []*Condition `protobuf:"bytes,19,rep,name=conditions,proto3" json:"conditions,omitempty"`

	ExecutionCount int32 `protobuf:"varint,20,opt,name=execution_count,json=executionCount,proto3" json:"execution_count,omitempty"`

	LatestCreatedExecution *ExecutionReference "" /* 130 byte string literal not displayed */

	Reconciling bool `protobuf:"varint,23,opt,name=reconciling,proto3" json:"reconciling,omitempty"`

	Etag string `protobuf:"bytes,99,opt,name=etag,proto3" json:"etag,omitempty"`

}

Job represents the configuration of a single job. A job an immutable resource that references a container image which is run to completion.

func (*Job) Descriptor

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

Deprecated: Use Job.ProtoReflect.Descriptor instead.

func (*Job) GetAnnotations

func (x *Job) GetAnnotations() map[string]string

func (*Job) GetBinaryAuthorization

func (x *Job) GetBinaryAuthorization() *BinaryAuthorization

func (*Job) GetClient

func (x *Job) GetClient() string

func (*Job) GetClientVersion

func (x *Job) GetClientVersion() string

func (*Job) GetConditions

func (x *Job) GetConditions() []*Condition

func (*Job) GetCreateTime

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

func (*Job) GetCreator

func (x *Job) GetCreator() string

func (*Job) GetDeleteTime

func (x *Job) GetDeleteTime() *timestamppb.Timestamp

func (*Job) GetEtag

func (x *Job) GetEtag() string

func (*Job) GetExecutionCount

func (x *Job) GetExecutionCount() int32

func (*Job) GetExpireTime

func (x *Job) GetExpireTime() *timestamppb.Timestamp

func (*Job) GetGeneration

func (x *Job) GetGeneration() int64

func (*Job) GetLabels

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

func (*Job) GetLastModifier

func (x *Job) GetLastModifier() string

func (*Job) GetLatestCreatedExecution

func (x *Job) GetLatestCreatedExecution() *ExecutionReference

func (*Job) GetLaunchStage

func (x *Job) GetLaunchStage() api.LaunchStage

func (*Job) GetName

func (x *Job) GetName() string

func (*Job) GetObservedGeneration

func (x *Job) GetObservedGeneration() int64

func (*Job) GetReconciling

func (x *Job) GetReconciling() bool

func (*Job) GetTemplate

func (x *Job) GetTemplate() *ExecutionTemplate

func (*Job) GetTerminalCondition

func (x *Job) GetTerminalCondition() *Condition

func (*Job) GetUid

func (x *Job) GetUid() string

func (*Job) GetUpdateTime

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

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

JobsClient

type JobsClient interface {
	// Creates a Job.
	CreateJob(ctx context.Context, in *CreateJobRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Gets information about a Job.
	GetJob(ctx context.Context, in *GetJobRequest, opts ...grpc.CallOption) (*Job, error)
	// Lists Jobs.
	ListJobs(ctx context.Context, in *ListJobsRequest, opts ...grpc.CallOption) (*ListJobsResponse, error)
	// Updates a Job.
	UpdateJob(ctx context.Context, in *UpdateJobRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Deletes a Job.
	DeleteJob(ctx context.Context, in *DeleteJobRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Triggers creation of a new Execution of this Job.
	RunJob(ctx context.Context, in *RunJobRequest, opts ...grpc.CallOption) (*longrunning.Operation, error)
	// Gets the IAM Access Control policy currently in effect for the given Job.
	// This result does not include any inherited policies.
	GetIamPolicy(ctx context.Context, in *v1.GetIamPolicyRequest, opts ...grpc.CallOption) (*v1.Policy, error)
	// Sets the IAM Access control policy for the specified Job. Overwrites
	// any existing policy.
	SetIamPolicy(ctx context.Context, in *v1.SetIamPolicyRequest, opts ...grpc.CallOption) (*v1.Policy, error)
	// Returns permissions that a caller has on the specified Project.
	//
	// There are no permissions required for making this API call.
	TestIamPermissions(ctx context.Context, in *v1.TestIamPermissionsRequest, opts ...grpc.CallOption) (*v1.TestIamPermissionsResponse, error)
}

JobsClient is the client API for Jobs service.

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

func NewJobsClient

func NewJobsClient(cc grpc.ClientConnInterface) JobsClient

JobsServer

type JobsServer interface {
	// Creates a Job.
	CreateJob(context.Context, *CreateJobRequest) (*longrunning.Operation, error)
	// Gets information about a Job.
	GetJob(context.Context, *GetJobRequest) (*Job, error)
	// Lists Jobs.
	ListJobs(context.Context, *ListJobsRequest) (*ListJobsResponse, error)
	// Updates a Job.
	UpdateJob(context.Context, *UpdateJobRequest) (*longrunning.Operation, error)
	// Deletes a Job.
	DeleteJob(context.Context, *DeleteJobRequest) (*longrunning.Operation, error)
	// Triggers creation of a new Execution of this Job.
	RunJob(context.Context, *RunJobRequest) (*longrunning.Operation, error)
	// Gets the IAM Access Control policy currently in effect for the given Job.
	// This result does not include any inherited policies.
	GetIamPolicy(context.Context, *v1.GetIamPolicyRequest) (*v1.Policy, error)
	// Sets the IAM Access control policy for the specified Job. Overwrites
	// any existing policy.
	SetIamPolicy(context.Context, *v1.SetIamPolicyRequest) (*v1.Policy, error)
	// Returns permissions that a caller has on the specified Project.
	//
	// There are no permissions required for making this API call.
	TestIamPermissions(context.Context, *v1.TestIamPermissionsRequest) (*v1.TestIamPermissionsResponse, error)
}

JobsServer is the server API for Jobs service.

ListExecutionsRequest

type ListExecutionsRequest struct {

	// Required. The Execution from which the Executions should be listed.
	// To list all Executions across Jobs, use "-" instead of Job name.
	// Format: projects/{project}/locations/{location}/jobs/{job}, where {project}
	// can be project id or number.
	Parent string `protobuf:"bytes,1,opt,name=parent,proto3" json:"parent,omitempty"`
	// Maximum number of Executions to return in this call.
	PageSize int32 `protobuf:"varint,2,opt,name=page_size,json=pageSize,proto3" json:"page_size,omitempty"`
	// A page token received from a previous call to ListExecutions.
	// All other parameters must match.
	PageToken string `protobuf:"bytes,3,opt,name=page_token,json=pageToken,proto3" json:"page_token,omitempty"`
	// If true, returns deleted (but unexpired) resources along with active ones.
	ShowDeleted bool `protobuf:"varint,4,opt,name=show_deleted,json=showDeleted,proto3" json:"show_deleted,omitempty"`
	// contains filtered or unexported fields
}

Request message for retrieving a list of Executions.

func (*ListExecutionsRequest) Descriptor

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

Deprecated: Use ListExecutionsRequest.ProtoReflect.Descriptor instead.

func (*ListExecutionsRequest) GetPageSize

func (x *ListExecutionsRequest) GetPageSize() int32

func (*ListExecutionsRequest) GetPageToken

func (x *ListExecutionsRequest) GetPageToken() string