Enum value maps for RequestLogEntry_RequestType.
var (
RequestLogEntry_RequestType_name = map[int32]string{
0: "REQUEST_TYPE_UNSPECIFIED",
1: "CREATE_PIPELINE",
2: "UPDATE_PIPELINE",
3: "DELETE_PIPELINE",
4: "LIST_PIPELINES",
5: "GET_PIPELINE",
6: "STOP_PIPELINE",
7: "RUN_PIPELINE",
8: "LIST_JOBS",
}
RequestLogEntry_RequestType_value = map[string]int32{
"REQUEST_TYPE_UNSPECIFIED": 0,
"CREATE_PIPELINE": 1,
"UPDATE_PIPELINE": 2,
"DELETE_PIPELINE": 3,
"LIST_PIPELINES": 4,
"GET_PIPELINE": 5,
"STOP_PIPELINE": 6,
"RUN_PIPELINE": 7,
"LIST_JOBS": 8,
}
)
Enum value maps for RequestLogEntry_ErrorCause.
var (
RequestLogEntry_ErrorCause_name = map[int32]string{
0: "ERROR_CAUSE_UNSPECIFIED",
1: "INVALID_REQUEST",
2: "PROJECT_NUMBER_NOT_FOUND",
3: "PIPELINE_ID_ALREADY_EXISTS",
4: "PIPELINE_QUOTA_ALLOCATION_FAILED",
5: "PIPELINE_NOT_FOUND",
6: "INVALID_PIPELINE_WORKLOAD",
7: "DATAFLOW_WORKER_SERVICE_ACCOUNT_PERMISSION_DENIED",
8: "CLOUD_SCHEDULER_SERVICE_ACCOUNT_PERMISSION_DENIED",
9: "INTERNAL_DATA_PIPELINES_SERVICE_ACCOUNT_ISSUE",
10: "CLOUD_SCHEDULER_INVALID_ARGUMENT",
11: "CLOUD_SCHEDULER_RESOURCE_EXHAUSTED",
12: "CLOUD_SCHEDULER_JOB_NOT_FOUND",
13: "OTHER_CLOUD_SCHEDULER_ISSUE",
14: "DATAFLOW_JOB_ALREADY_EXISTS",
15: "DATAFLOW_INVALID_ARGUMENT",
16: "DATAFLOW_RESOURCE_EXHAUSTED",
17: "DATAFLOW_JOB_NOT_FOUND",
18: "OTHER_DATAFLOW_ISSUE",
19: "DATABASE_ERROR",
20: "WRONG_PIPELINE_TYPE",
21: "INTERNAL_ERROR",
22: "PIPELINE_OR_PROJECT_NOT_FOUND",
}
RequestLogEntry_ErrorCause_value = map[string]int32{
"ERROR_CAUSE_UNSPECIFIED": 0,
"INVALID_REQUEST": 1,
"PROJECT_NUMBER_NOT_FOUND": 2,
"PIPELINE_ID_ALREADY_EXISTS": 3,
"PIPELINE_QUOTA_ALLOCATION_FAILED": 4,
"PIPELINE_NOT_FOUND": 5,
"INVALID_PIPELINE_WORKLOAD": 6,
"DATAFLOW_WORKER_SERVICE_ACCOUNT_PERMISSION_DENIED": 7,
"CLOUD_SCHEDULER_SERVICE_ACCOUNT_PERMISSION_DENIED": 8,
"INTERNAL_DATA_PIPELINES_SERVICE_ACCOUNT_ISSUE": 9,
"CLOUD_SCHEDULER_INVALID_ARGUMENT": 10,
"CLOUD_SCHEDULER_RESOURCE_EXHAUSTED": 11,
"CLOUD_SCHEDULER_JOB_NOT_FOUND": 12,
"OTHER_CLOUD_SCHEDULER_ISSUE": 13,
"DATAFLOW_JOB_ALREADY_EXISTS": 14,
"DATAFLOW_INVALID_ARGUMENT": 15,
"DATAFLOW_RESOURCE_EXHAUSTED": 16,
"DATAFLOW_JOB_NOT_FOUND": 17,
"OTHER_DATAFLOW_ISSUE": 18,
"DATABASE_ERROR": 19,
"WRONG_PIPELINE_TYPE": 20,
"INTERNAL_ERROR": 21,
"PIPELINE_OR_PROJECT_NOT_FOUND": 22,
}
)
var File_google_cloud_datapipelines_logging_v1_logging_proto protoreflect.FileDescriptor
Cloud Logging structured payload for events generated from Data Pipelines API requests.
type RequestLogEntry struct {
// Type of the Data Pipelines API request.
RequestType RequestLogEntry_RequestType `protobuf:"varint,1,opt,name=request_type,json=requestType,proto3,enum=google.cloud.datapipelines.logging.v1.RequestLogEntry_RequestType" json:"request_type,omitempty"`
// The resulting status of the Data Pipelines API request.
Status *status.Status `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
// Cause of the error status.
ErrorCause RequestLogEntry_ErrorCause `protobuf:"varint,3,opt,name=error_cause,json=errorCause,proto3,enum=google.cloud.datapipelines.logging.v1.RequestLogEntry_ErrorCause" json:"error_cause,omitempty"`
// contains filtered or unexported fields
}
func (*RequestLogEntry) Descriptor() ([]byte, []int)
Deprecated: Use RequestLogEntry.ProtoReflect.Descriptor instead.
func (x *RequestLogEntry) GetErrorCause() RequestLogEntry_ErrorCause
func (x *RequestLogEntry) GetRequestType() RequestLogEntry_RequestType
func (x *RequestLogEntry) GetStatus() *status.Status
func (*RequestLogEntry) ProtoMessage()
func (x *RequestLogEntry) ProtoReflect() protoreflect.Message
func (x *RequestLogEntry) Reset()
func (x *RequestLogEntry) String() string
Cause code for a Data Pipelines API request error.
type RequestLogEntry_ErrorCause int32
const (
// Default value. This value is not used.
RequestLogEntry_ERROR_CAUSE_UNSPECIFIED RequestLogEntry_ErrorCause = 0
// The request is invalid.
RequestLogEntry_INVALID_REQUEST RequestLogEntry_ErrorCause = 1
// Failed to fetch project number for the provided project id.
RequestLogEntry_PROJECT_NUMBER_NOT_FOUND RequestLogEntry_ErrorCause = 2
// The given pipeline already exists.
RequestLogEntry_PIPELINE_ID_ALREADY_EXISTS RequestLogEntry_ErrorCause = 3
// Failed to allocate a token for the per project pipeline count quota.
RequestLogEntry_PIPELINE_QUOTA_ALLOCATION_FAILED RequestLogEntry_ErrorCause = 4
// The given pipeline is not found.
RequestLogEntry_PIPELINE_NOT_FOUND RequestLogEntry_ErrorCause = 5
// The pipeline's workload is invalid.
RequestLogEntry_INVALID_PIPELINE_WORKLOAD RequestLogEntry_ErrorCause = 6
// The user cannot act as the Dataflow worker service account.
RequestLogEntry_DATAFLOW_WORKER_SERVICE_ACCOUNT_PERMISSION_DENIED RequestLogEntry_ErrorCause = 7
// The user cannot act as the Cloud Scheduler service account.
RequestLogEntry_CLOUD_SCHEDULER_SERVICE_ACCOUNT_PERMISSION_DENIED RequestLogEntry_ErrorCause = 8
// Issues related to the per service per project service account.
RequestLogEntry_INTERNAL_DATA_PIPELINES_SERVICE_ACCOUNT_ISSUE RequestLogEntry_ErrorCause = 9
// Invalid argument in Cloud Scheduler service call.
RequestLogEntry_CLOUD_SCHEDULER_INVALID_ARGUMENT RequestLogEntry_ErrorCause = 10
// Exceeds Cloud Scheduler service quota limit.
RequestLogEntry_CLOUD_SCHEDULER_RESOURCE_EXHAUSTED RequestLogEntry_ErrorCause = 11
// Cloud Scheduler job not found.
RequestLogEntry_CLOUD_SCHEDULER_JOB_NOT_FOUND RequestLogEntry_ErrorCause = 12
// Other Cloud Scheduler related issues.
RequestLogEntry_OTHER_CLOUD_SCHEDULER_ISSUE RequestLogEntry_ErrorCause = 13
// Dataflow job with the same name already exists.
RequestLogEntry_DATAFLOW_JOB_ALREADY_EXISTS RequestLogEntry_ErrorCause = 14
// Invalid argument in Dataflow service call.
RequestLogEntry_DATAFLOW_INVALID_ARGUMENT RequestLogEntry_ErrorCause = 15
// Exceeds Dataflow service quota limit.
RequestLogEntry_DATAFLOW_RESOURCE_EXHAUSTED RequestLogEntry_ErrorCause = 16
// Dataflow job not found.
RequestLogEntry_DATAFLOW_JOB_NOT_FOUND RequestLogEntry_ErrorCause = 17
// Other Dataflow related issues.
RequestLogEntry_OTHER_DATAFLOW_ISSUE RequestLogEntry_ErrorCause = 18
// Database related issues.
RequestLogEntry_DATABASE_ERROR RequestLogEntry_ErrorCause = 19
// Request with the wrong pipeline type. For example, RunPipeline cannot be
// used with a streaming pipeline.
RequestLogEntry_WRONG_PIPELINE_TYPE RequestLogEntry_ErrorCause = 20
// Issues related to other Google internal services/systems.
RequestLogEntry_INTERNAL_ERROR RequestLogEntry_ErrorCause = 21
// Cannot find the given pipeline or project.
RequestLogEntry_PIPELINE_OR_PROJECT_NOT_FOUND RequestLogEntry_ErrorCause = 22
)
func (RequestLogEntry_ErrorCause) Descriptor() protoreflect.EnumDescriptor
func (x RequestLogEntry_ErrorCause) Enum() *RequestLogEntry_ErrorCause
func (RequestLogEntry_ErrorCause) EnumDescriptor() ([]byte, []int)
Deprecated: Use RequestLogEntry_ErrorCause.Descriptor instead.
func (x RequestLogEntry_ErrorCause) Number() protoreflect.EnumNumber
func (x RequestLogEntry_ErrorCause) String() string
func (RequestLogEntry_ErrorCause) Type() protoreflect.EnumType
Type of a Data Pipelines API request.
type RequestLogEntry_RequestType int32
const (
// Default value. This value is not used.
RequestLogEntry_REQUEST_TYPE_UNSPECIFIED RequestLogEntry_RequestType = 0
// A Data Pipelines Create Pipeline request.
RequestLogEntry_CREATE_PIPELINE RequestLogEntry_RequestType = 1
// A Data Pipelines Update Pipeline request.
RequestLogEntry_UPDATE_PIPELINE RequestLogEntry_RequestType = 2
// A Data Pipelines Delete Pipeline request.
RequestLogEntry_DELETE_PIPELINE RequestLogEntry_RequestType = 3
// A Data Pipelines List Pipelines request.
RequestLogEntry_LIST_PIPELINES RequestLogEntry_RequestType = 4
// A Data Pipelines Get Pipeline request.
RequestLogEntry_GET_PIPELINE RequestLogEntry_RequestType = 5
// A Data Pipelines Stop Pipeline request.
RequestLogEntry_STOP_PIPELINE RequestLogEntry_RequestType = 6
// A Data Pipelines Run Pipeline request.
RequestLogEntry_RUN_PIPELINE RequestLogEntry_RequestType = 7
// A Data Pipelines List Jobs request.
RequestLogEntry_LIST_JOBS RequestLogEntry_RequestType = 8
)
func (RequestLogEntry_RequestType) Descriptor() protoreflect.EnumDescriptor
func (x RequestLogEntry_RequestType) Enum() *RequestLogEntry_RequestType
func (RequestLogEntry_RequestType) EnumDescriptor() ([]byte, []int)
Deprecated: Use RequestLogEntry_RequestType.Descriptor instead.
func (x RequestLogEntry_RequestType) Number() protoreflect.EnumNumber
func (x RequestLogEntry_RequestType) String() string
func (RequestLogEntry_RequestType) Type() protoreflect.EnumType