Documentation ¶
Index ¶
- Variables
- type RequestLogEntry
- func (*RequestLogEntry) Descriptor() ([]byte, []int)deprecated
- 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
- type RequestLogEntry_ErrorCause
- func (RequestLogEntry_ErrorCause) Descriptor() protoreflect.EnumDescriptor
- func (x RequestLogEntry_ErrorCause) Enum() *RequestLogEntry_ErrorCause
- func (RequestLogEntry_ErrorCause) EnumDescriptor() ([]byte, []int)deprecated
- func (x RequestLogEntry_ErrorCause) Number() protoreflect.EnumNumber
- func (x RequestLogEntry_ErrorCause) String() string
- func (RequestLogEntry_ErrorCause) Type() protoreflect.EnumType
- type RequestLogEntry_RequestType
- func (RequestLogEntry_RequestType) Descriptor() protoreflect.EnumDescriptor
- func (x RequestLogEntry_RequestType) Enum() *RequestLogEntry_RequestType
- func (RequestLogEntry_RequestType) EnumDescriptor() ([]byte, []int)deprecated
- func (x RequestLogEntry_RequestType) Number() protoreflect.EnumNumber
- func (x RequestLogEntry_RequestType) String() string
- func (RequestLogEntry_RequestType) Type() protoreflect.EnumType
Constants ¶
This section is empty.
Variables ¶
View Source
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_RequestType.
View Source
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, } )
Enum value maps for RequestLogEntry_ErrorCause.
View Source
var File_google_cloud_datapipelines_logging_v1_logging_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type RequestLogEntry ¶
type RequestLogEntry struct { // Type of the Data Pipelines API request. RequestType RequestLogEntry_RequestType `` /* 166-byte string literal not displayed */ // 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 `` /* 162-byte string literal not displayed */ // contains filtered or unexported fields }
Cloud Logging structured payload for events generated from Data Pipelines API requests.
func (*RequestLogEntry) Descriptor
deprecated
func (*RequestLogEntry) Descriptor() ([]byte, []int)
Deprecated: Use RequestLogEntry.ProtoReflect.Descriptor instead.
func (*RequestLogEntry) GetErrorCause ¶
func (x *RequestLogEntry) GetErrorCause() RequestLogEntry_ErrorCause
func (*RequestLogEntry) GetRequestType ¶
func (x *RequestLogEntry) GetRequestType() RequestLogEntry_RequestType
func (*RequestLogEntry) GetStatus ¶
func (x *RequestLogEntry) GetStatus() *status.Status
func (*RequestLogEntry) ProtoMessage ¶
func (*RequestLogEntry) ProtoMessage()
func (*RequestLogEntry) ProtoReflect ¶
func (x *RequestLogEntry) ProtoReflect() protoreflect.Message
func (*RequestLogEntry) Reset ¶
func (x *RequestLogEntry) Reset()
func (*RequestLogEntry) String ¶
func (x *RequestLogEntry) String() string
type RequestLogEntry_ErrorCause ¶
type RequestLogEntry_ErrorCause int32
Cause code for a Data Pipelines API request error.
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 ¶
func (RequestLogEntry_ErrorCause) Descriptor() protoreflect.EnumDescriptor
func (RequestLogEntry_ErrorCause) Enum ¶
func (x RequestLogEntry_ErrorCause) Enum() *RequestLogEntry_ErrorCause
func (RequestLogEntry_ErrorCause) EnumDescriptor
deprecated
func (RequestLogEntry_ErrorCause) EnumDescriptor() ([]byte, []int)
Deprecated: Use RequestLogEntry_ErrorCause.Descriptor instead.
func (RequestLogEntry_ErrorCause) Number ¶
func (x RequestLogEntry_ErrorCause) Number() protoreflect.EnumNumber
func (RequestLogEntry_ErrorCause) String ¶
func (x RequestLogEntry_ErrorCause) String() string
func (RequestLogEntry_ErrorCause) Type ¶
func (RequestLogEntry_ErrorCause) Type() protoreflect.EnumType
type RequestLogEntry_RequestType ¶
type RequestLogEntry_RequestType int32
Type of a Data Pipelines API request.
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 ¶
func (RequestLogEntry_RequestType) Descriptor() protoreflect.EnumDescriptor
func (RequestLogEntry_RequestType) Enum ¶
func (x RequestLogEntry_RequestType) Enum() *RequestLogEntry_RequestType
func (RequestLogEntry_RequestType) EnumDescriptor
deprecated
func (RequestLogEntry_RequestType) EnumDescriptor() ([]byte, []int)
Deprecated: Use RequestLogEntry_RequestType.Descriptor instead.
func (RequestLogEntry_RequestType) Number ¶
func (x RequestLogEntry_RequestType) Number() protoreflect.EnumNumber
func (RequestLogEntry_RequestType) String ¶
func (x RequestLogEntry_RequestType) String() string
func (RequestLogEntry_RequestType) Type ¶
func (RequestLogEntry_RequestType) Type() protoreflect.EnumType
Click to show internal directories.
Click to hide internal directories.