Variables
StreamAnnotationType_name, StreamAnnotationType_value
var (
StreamAnnotationType_name = map[int32]string{
0: "STREAM_ANNOTATION_TYPE_UNSPECIFIED",
1: "STREAM_ANNOTATION_TYPE_ACTIVE_ZONE",
2: "STREAM_ANNOTATION_TYPE_CROSSING_LINE",
}
StreamAnnotationType_value = map[string]int32{
"STREAM_ANNOTATION_TYPE_UNSPECIFIED": 0,
"STREAM_ANNOTATION_TYPE_ACTIVE_ZONE": 1,
"STREAM_ANNOTATION_TYPE_CROSSING_LINE": 2,
}
)
Enum value maps for StreamAnnotationType.
Cluster_State_name, Cluster_State_value
var (
Cluster_State_name = map[int32]string{
0: "STATE_UNSPECIFIED",
1: "PROVISIONING",
2: "RUNNING",
3: "STOPPING",
4: "ERROR",
}
Cluster_State_value = map[string]int32{
"STATE_UNSPECIFIED": 0,
"PROVISIONING": 1,
"RUNNING": 2,
"STOPPING": 3,
"ERROR": 4,
}
)
Enum value maps for Cluster_State.
RunMode_name, RunMode_value
var (
RunMode_name = map[int32]string{
0: "RUN_MODE_UNSPECIFIED",
1: "LIVE",
2: "SUBMISSION",
}
RunMode_value = map[string]int32{
"RUN_MODE_UNSPECIFIED": 0,
"LIVE": 1,
"SUBMISSION": 2,
}
)
Enum value maps for RunMode.
RunStatus_State_name, RunStatus_State_value
var (
RunStatus_State_name = map[int32]string{
0: "STATE_UNSPECIFIED",
1: "INITIALIZING",
2: "RUNNING",
3: "COMPLETED",
4: "FAILED",
5: "PENDING",
}
RunStatus_State_value = map[string]int32{
"STATE_UNSPECIFIED": 0,
"INITIALIZING": 1,
"RUNNING": 2,
"COMPLETED": 3,
"FAILED": 4,
"PENDING": 5,
}
)
Enum value maps for RunStatus_State.
Registry_name, Registry_value
var (
Registry_name = map[int32]string{
0: "REGISTRY_UNSPECIFIED",
1: "PUBLIC",
2: "PRIVATE",
}
Registry_value = map[string]int32{
"REGISTRY_UNSPECIFIED": 0,
"PUBLIC": 1,
"PRIVATE": 2,
}
)
Enum value maps for Registry.
ModelType_name, ModelType_value
var (
ModelType_name = map[int32]string{
0: "MODEL_TYPE_UNSPECIFIED",
1: "IMAGE_CLASSIFICATION",
2: "OBJECT_DETECTION",
3: "VIDEO_CLASSIFICATION",
4: "VIDEO_OBJECT_TRACKING",
5: "VIDEO_ACTION_RECOGNITION",
6: "OCCUPANCY_COUNTING",
7: "PERSON_BLUR",
8: "VERTEX_CUSTOM",
9: "PRODUCT_RECOGNIZER",
10: "TAG_RECOGNIZER",
15: "SYNTH_ID",
}
ModelType_value = map[string]int32{
"MODEL_TYPE_UNSPECIFIED": 0,
"IMAGE_CLASSIFICATION": 1,
"OBJECT_DETECTION": 2,
"VIDEO_CLASSIFICATION": 3,
"VIDEO_OBJECT_TRACKING": 4,
"VIDEO_ACTION_RECOGNITION": 5,
"OCCUPANCY_COUNTING": 6,
"PERSON_BLUR": 7,
"VERTEX_CUSTOM": 8,
"PRODUCT_RECOGNIZER": 9,
"TAG_RECOGNIZER": 10,
"SYNTH_ID": 15,
}
)
Enum value maps for ModelType.
AcceleratorType_name, AcceleratorType_value
var (
AcceleratorType_name = map[int32]string{
0: "ACCELERATOR_TYPE_UNSPECIFIED",
1: "NVIDIA_TESLA_K80",
2: "NVIDIA_TESLA_P100",
3: "NVIDIA_TESLA_V100",
4: "NVIDIA_TESLA_P4",
5: "NVIDIA_TESLA_T4",
8: "NVIDIA_TESLA_A100",
6: "TPU_V2",
7: "TPU_V3",
}
AcceleratorType_value = map[string]int32{
"ACCELERATOR_TYPE_UNSPECIFIED": 0,
"NVIDIA_TESLA_K80": 1,
"NVIDIA_TESLA_P100": 2,
"NVIDIA_TESLA_V100": 3,
"NVIDIA_TESLA_P4": 4,
"NVIDIA_TESLA_T4": 5,
"NVIDIA_TESLA_A100": 8,
"TPU_V2": 6,
"TPU_V3": 7,
}
)
Enum value maps for AcceleratorType.
DataType_name, DataType_value
var (
DataType_name = map[int32]string{
0: "DATA_TYPE_UNSPECIFIED",
1: "VIDEO",
3: "IMAGE",
2: "PROTO",
4: "PLACEHOLDER",
}
DataType_value = map[string]int32{
"DATA_TYPE_UNSPECIFIED": 0,
"VIDEO": 1,
"IMAGE": 3,
"PROTO": 2,
"PLACEHOLDER": 4,
}
)
Enum value maps for DataType.
Application_State_name, Application_State_value
var (
Application_State_name = map[int32]string{
0: "STATE_UNSPECIFIED",
1: "CREATED",
2: "DEPLOYING",
3: "DEPLOYED",
4: "UNDEPLOYING",
5: "DELETED",
6: "ERROR",
7: "CREATING",
8: "UPDATING",
9: "DELETING",
10: "FIXING",
}
Application_State_value = map[string]int32{
"STATE_UNSPECIFIED": 0,
"CREATED": 1,
"DEPLOYING": 2,
"DEPLOYED": 3,
"UNDEPLOYING": 4,
"DELETED": 5,
"ERROR": 6,
"CREATING": 7,
"UPDATING": 8,
"DELETING": 9,
"FIXING": 10,
}
)
Enum value maps for Application_State.
Application_BillingMode_name, Application_BillingMode_value
var (
Application_BillingMode_name = map[int32]string{
0: "BILLING_MODE_UNSPECIFIED",
1: "PAYG",
2: "MONTHLY",
}
Application_BillingMode_value = map[string]int32{
"BILLING_MODE_UNSPECIFIED": 0,
"PAYG": 1,
"MONTHLY": 2,
}
)
Enum value maps for Application_BillingMode.
Instance_InstanceType_name, Instance_InstanceType_value
var (
Instance_InstanceType_name = map[int32]string{
0: "INSTANCE_TYPE_UNSPECIFIED",
1: "STREAMING_PREDICTION",
2: "BATCH_PREDICTION",
3: "ONLINE_PREDICTION",
}
Instance_InstanceType_value = map[string]int32{
"INSTANCE_TYPE_UNSPECIFIED": 0,
"STREAMING_PREDICTION": 1,
"BATCH_PREDICTION": 2,
"ONLINE_PREDICTION": 3,
}
)
Enum value maps for Instance_InstanceType.
Instance_State_name, Instance_State_value
var (
Instance_State_name = map[int32]string{
0: "STATE_UNSPECIFIED",
1: "CREATING",
2: "CREATED",
3: "DEPLOYING",
4: "DEPLOYED",
5: "UNDEPLOYING",
6: "DELETED",
7: "ERROR",
8: "UPDATING",
9: "DELETING",
10: "FIXING",
11: "FINISHED",
}
Instance_State_value = map[string]int32{
"STATE_UNSPECIFIED": 0,
"CREATING": 1,
"CREATED": 2,
"DEPLOYING": 3,
"DEPLOYED": 4,
"UNDEPLOYING": 5,
"DELETED": 6,
"ERROR": 7,
"UPDATING": 8,
"DELETING": 9,
"FIXING": 10,
"FINISHED": 11,
}
)
Enum value maps for Instance_State.
Processor_ProcessorType_name, Processor_ProcessorType_value
var (
Processor_ProcessorType_name = map[int32]string{
0: "PROCESSOR_TYPE_UNSPECIFIED",
1: "PRETRAINED",
2: "CUSTOM",
3: "CONNECTOR",
}
Processor_ProcessorType_value = map[string]int32{
"PROCESSOR_TYPE_UNSPECIFIED": 0,
"PRETRAINED": 1,
"CUSTOM": 2,
"CONNECTOR": 3,
}
)
Enum value maps for Processor_ProcessorType.
Processor_ProcessorState_name, Processor_ProcessorState_value
var (
Processor_ProcessorState_name = map[int32]string{
0: "PROCESSOR_STATE_UNSPECIFIED",
1: "CREATING",
2: "ACTIVE",
3: "DELETING",
4: "FAILED",
}
Processor_ProcessorState_value = map[string]int32{
"PROCESSOR_STATE_UNSPECIFIED": 0,
"CREATING": 1,
"ACTIVE": 2,
"DELETING": 3,
"FAILED": 4,
}
)
Enum value maps for Processor_ProcessorState.
CustomProcessorSourceInfo_SourceType_name, CustomProcessorSourceInfo_SourceType_value
var (
CustomProcessorSourceInfo_SourceType_name = map[int32]string{
0: "SOURCE_TYPE_UNSPECIFIED",
1: "VERTEX_AUTOML",
2: "VERTEX_CUSTOM",
3: "PRODUCT_RECOGNIZER",
}
CustomProcessorSourceInfo_SourceType_value = map[string]int32{
"SOURCE_TYPE_UNSPECIFIED": 0,
"VERTEX_AUTOML": 1,
"VERTEX_CUSTOM": 2,
"PRODUCT_RECOGNIZER": 3,
}
)
Enum value maps for CustomProcessorSourceInfo_SourceType.
PersonBlurConfig_PersonBlurType_name, PersonBlurConfig_PersonBlurType_value
var (
PersonBlurConfig_PersonBlurType_name = map[int32]string{
0: "PERSON_BLUR_TYPE_UNSPECIFIED",
1: "FULL_OCCULUSION",
2: "BLUR_FILTER",
}
PersonBlurConfig_PersonBlurType_value = map[string]int32{
"PERSON_BLUR_TYPE_UNSPECIFIED": 0,
"FULL_OCCULUSION": 1,
"BLUR_FILTER": 2,
}
)
Enum value maps for PersonBlurConfig_PersonBlurType.
TagParsingConfig_EntityParsingConfig_EntityMatchingStrategy_name, TagParsingConfig_EntityParsingConfig_EntityMatchingStrategy_value
var (
TagParsingConfig_EntityParsingConfig_EntityMatchingStrategy_name = map[int32]string{
0: "ENTITY_MATCHING_STRATEGY_UNSPECIFIED",
1: "MULTI_LINE_MATCHING",
2: "MAX_OVERLAP_AREA",
}
TagParsingConfig_EntityParsingConfig_EntityMatchingStrategy_value = map[string]int32{
"ENTITY_MATCHING_STRATEGY_UNSPECIFIED": 0,
"MULTI_LINE_MATCHING": 1,
"MAX_OVERLAP_AREA": 2,
}
)
Enum value maps for TagParsingConfig_EntityParsingConfig_EntityMatchingStrategy.
LeaseType_name, LeaseType_value
var (
LeaseType_name = map[int32]string{
0: "LEASE_TYPE_UNSPECIFIED",
1: "LEASE_TYPE_READER",
2: "LEASE_TYPE_WRITER",
}
LeaseType_value = map[string]int32{
"LEASE_TYPE_UNSPECIFIED": 0,
"LEASE_TYPE_READER": 1,
"LEASE_TYPE_WRITER": 2,
}
)
Enum value maps for LeaseType.
Event_Clock_name, Event_Clock_value
var (
Event_Clock_name = map[int32]string{
0: "CLOCK_UNSPECIFIED",
1: "CAPTURE",
2: "INGEST",
}
Event_Clock_value = map[string]int32{
"CLOCK_UNSPECIFIED": 0,
"CAPTURE": 1,
"INGEST": 2,
}
)
Enum value maps for Event_Clock.
FacetBucketType_name, FacetBucketType_value
var (
FacetBucketType_name = map[int32]string{
0: "FACET_BUCKET_TYPE_UNSPECIFIED",
1: "FACET_BUCKET_TYPE_VALUE",
2: "FACET_BUCKET_TYPE_DATETIME",
3: "FACET_BUCKET_TYPE_FIXED_RANGE",
4: "FACET_BUCKET_TYPE_CUSTOM_RANGE",
}
FacetBucketType_value = map[string]int32{
"FACET_BUCKET_TYPE_UNSPECIFIED": 0,
"FACET_BUCKET_TYPE_VALUE": 1,
"FACET_BUCKET_TYPE_DATETIME": 2,
"FACET_BUCKET_TYPE_FIXED_RANGE": 3,
"FACET_BUCKET_TYPE_CUSTOM_RANGE": 4,
}
)
Enum value maps for FacetBucketType.
AnalyzeAssetMetadata_AnalysisStatus_State_name, AnalyzeAssetMetadata_AnalysisStatus_State_value
var (
AnalyzeAssetMetadata_AnalysisStatus_State_name = map[int32]string{
0: "STATE_UNSPECIFIED",
1: "IN_PROGRESS",
2: "SUCCEEDED",
3: "FAILED",
}
AnalyzeAssetMetadata_AnalysisStatus_State_value = map[string]int32{
"STATE_UNSPECIFIED": 0,
"IN_PROGRESS": 1,
"SUCCEEDED": 2,
"FAILED": 3,
}
)
Enum value maps for AnalyzeAssetMetadata_AnalysisStatus_State.
IndexingStatus_State_name, IndexingStatus_State_value
var (
IndexingStatus_State_name = map[int32]string{
0: "STATE_UNSPECIFIED",
1: "IN_PROGRESS",
2: "SUCCEEDED",
3: "FAILED",
}
IndexingStatus_State_value = map[string]int32{
"STATE_UNSPECIFIED": 0,
"IN_PROGRESS": 1,
"SUCCEEDED": 2,
"FAILED": 3,
}
)
Enum value maps for IndexingStatus_State.
SearchCapability_Type_name, SearchCapability_Type_value
var (
SearchCapability_Type_name = map[int32]string{
0: "TYPE_UNSPECIFIED",
1: "EMBEDDING_SEARCH",
}
SearchCapability_Type_value = map[string]int32{
"TYPE_UNSPECIFIED": 0,
"EMBEDDING_SEARCH": 1,
}
)
Enum value maps for SearchCapability_Type.
CollectionItem_Type_name, CollectionItem_Type_value
var (
CollectionItem_Type_name = map[int32]string{
0: "TYPE_UNSPECIFIED",
1: "ASSET",
}
CollectionItem_Type_value = map[string]int32{
"TYPE_UNSPECIFIED": 0,
"ASSET": 1,
}
)
Enum value maps for CollectionItem_Type.
Index_State_name, Index_State_value
var (
Index_State_name = map[int32]string{
0: "STATE_UNSPECIFIED",
1: "CREATING",
2: "CREATED",
3: "UPDATING",
}
Index_State_value = map[string]int32{
"STATE_UNSPECIFIED": 0,
"CREATING": 1,
"CREATED": 2,
"UPDATING": 3,
}
)
Enum value maps for Index_State.
Corpus_Type_name, Corpus_Type_value
var (
Corpus_Type_name = map[int32]string{
0: "TYPE_UNSPECIFIED",
1: "STREAM_VIDEO",
2: "IMAGE",
3: "VIDEO_ON_DEMAND",
}
Corpus_Type_value = map[string]int32{
"TYPE_UNSPECIFIED": 0,
"STREAM_VIDEO": 1,
"IMAGE": 2,
"VIDEO_ON_DEMAND": 3,
}
)
Enum value maps for Corpus_Type.
DataSchemaDetails_DataType_name, DataSchemaDetails_DataType_value
var (
DataSchemaDetails_DataType_name = map[int32]string{
0: "DATA_TYPE_UNSPECIFIED",
1: "INTEGER",
2: "FLOAT",
3: "STRING",
5: "DATETIME",
7: "GEO_COORDINATE",
8: "PROTO_ANY",
9: "BOOLEAN",
10: "LIST",
6: "CUSTOMIZED_STRUCT",
}
DataSchemaDetails_DataType_value = map[string]int32{
"DATA_TYPE_UNSPECIFIED": 0,
"INTEGER": 1,
"FLOAT": 2,
"STRING": 3,
"DATETIME": 5,
"GEO_COORDINATE": 7,
"PROTO_ANY": 8,
"BOOLEAN": 9,
"LIST": 10,
"CUSTOMIZED_STRUCT": 6,
}
)
Enum value maps for DataSchemaDetails_DataType.
DataSchemaDetails_Granularity_name, DataSchemaDetails_Granularity_value
var (
DataSchemaDetails_Granularity_name = map[int32]string{
0: "GRANULARITY_UNSPECIFIED",
1: "GRANULARITY_ASSET_LEVEL",
2: "GRANULARITY_PARTITION_LEVEL",
}
DataSchemaDetails_Granularity_value = map[string]int32{
"GRANULARITY_UNSPECIFIED": 0,
"GRANULARITY_ASSET_LEVEL": 1,
"GRANULARITY_PARTITION_LEVEL": 2,
}
)
Enum value maps for DataSchemaDetails_Granularity.
DataSchemaDetails_SearchStrategy_SearchStrategyType_name, DataSchemaDetails_SearchStrategy_SearchStrategyType_value
var (
DataSchemaDetails_SearchStrategy_SearchStrategyType_name = map[int32]string{
0: "NO_SEARCH",
1: "EXACT_SEARCH",
2: "SMART_SEARCH",
}
DataSchemaDetails_SearchStrategy_SearchStrategyType_value = map[string]int32{
"NO_SEARCH": 0,
"EXACT_SEARCH": 1,
"SMART_SEARCH": 2,
}
)
Enum value maps for DataSchemaDetails_SearchStrategy_SearchStrategyType.
IndexEndpoint_State_name, IndexEndpoint_State_value
var (
IndexEndpoint_State_name = map[int32]string{
0: "STATE_UNSPECIFIED",
1: "CREATING",
2: "CREATED",
3: "UPDATING",
4: "FAILED",
}
IndexEndpoint_State_value = map[string]int32{
"STATE_UNSPECIFIED": 0,
"CREATING": 1,
"CREATED": 2,
"UPDATING": 3,
"FAILED": 4,
}
)
Enum value maps for IndexEndpoint_State.
FacetProperty_DateTimeBucketSpec_Granularity_name, FacetProperty_DateTimeBucketSpec_Granularity_value
var (
FacetProperty_DateTimeBucketSpec_Granularity_name = map[int32]string{
0: "GRANULARITY_UNSPECIFIED",
1: "YEAR",
2: "MONTH",
3: "DAY",
}
FacetProperty_DateTimeBucketSpec_Granularity_value = map[string]int32{
"GRANULARITY_UNSPECIFIED": 0,
"YEAR": 1,
"MONTH": 2,
"DAY": 3,
}
)
Enum value maps for FacetProperty_DateTimeBucketSpec_Granularity.
IngestAssetRequest_Config_VideoType_ContainerFormat_name, IngestAssetRequest_Config_VideoType_ContainerFormat_value
var (
IngestAssetRequest_Config_VideoType_ContainerFormat_name = map[int32]string{
0: "CONTAINER_FORMAT_UNSPECIFIED",
1: "CONTAINER_FORMAT_MP4",
}
IngestAssetRequest_Config_VideoType_ContainerFormat_value = map[string]int32{
"CONTAINER_FORMAT_UNSPECIFIED": 0,
"CONTAINER_FORMAT_MP4": 1,
}
)
Enum value maps for IngestAssetRequest_Config_VideoType_ContainerFormat.
SchemaKeySortingStrategy_Option_AggregateMethod_name, SchemaKeySortingStrategy_Option_AggregateMethod_value
var (
SchemaKeySortingStrategy_Option_AggregateMethod_name = map[int32]string{
0: "AGGREGATE_METHOD_UNSPECIFIED",
1: "AGGREGATE_METHOD_LARGEST",
2: "AGGREGATE_METHOD_SMALLEST",
}
SchemaKeySortingStrategy_Option_AggregateMethod_value = map[string]int32{
"AGGREGATE_METHOD_UNSPECIFIED": 0,
"AGGREGATE_METHOD_LARGEST": 1,
"AGGREGATE_METHOD_SMALLEST": 2,
}
)
Enum value maps for SchemaKeySortingStrategy_Option_AggregateMethod.
File_google_cloud_visionai_v1_annotations_proto
var File_google_cloud_visionai_v1_annotations_proto protoreflect.FileDescriptor
File_google_cloud_visionai_v1_common_proto
var File_google_cloud_visionai_v1_common_proto protoreflect.FileDescriptor
File_google_cloud_visionai_v1_health_service_proto
var File_google_cloud_visionai_v1_health_service_proto protoreflect.FileDescriptor
File_google_cloud_visionai_v1_lva_proto
var File_google_cloud_visionai_v1_lva_proto protoreflect.FileDescriptor
File_google_cloud_visionai_v1_lva_resources_proto
var File_google_cloud_visionai_v1_lva_resources_proto protoreflect.FileDescriptor
File_google_cloud_visionai_v1_lva_service_proto
var File_google_cloud_visionai_v1_lva_service_proto protoreflect.FileDescriptor
File_google_cloud_visionai_v1_platform_proto
var File_google_cloud_visionai_v1_platform_proto protoreflect.FileDescriptor
File_google_cloud_visionai_v1_streaming_resources_proto
var File_google_cloud_visionai_v1_streaming_resources_proto protoreflect.FileDescriptor
File_google_cloud_visionai_v1_streaming_service_proto
var File_google_cloud_visionai_v1_streaming_service_proto protoreflect.FileDescriptor
File_google_cloud_visionai_v1_streams_resources_proto
var File_google_cloud_visionai_v1_streams_resources_proto protoreflect.FileDescriptor
File_google_cloud_visionai_v1_streams_service_proto
var File_google_cloud_visionai_v1_streams_service_proto protoreflect.FileDescriptor
File_google_cloud_visionai_v1_warehouse_proto
var File_google_cloud_visionai_v1_warehouse_proto protoreflect.FileDescriptor
Functions
func RegisterAppPlatformServer
func RegisterAppPlatformServer(s *grpc.Server, srv AppPlatformServer)
func RegisterHealthCheckServiceServer
func RegisterHealthCheckServiceServer(s *grpc.Server, srv HealthCheckServiceServer)
func RegisterLiveVideoAnalyticsServer
func RegisterLiveVideoAnalyticsServer(s *grpc.Server, srv LiveVideoAnalyticsServer)
func RegisterStreamingServiceServer
func RegisterStreamingServiceServer(s *grpc.Server, srv StreamingServiceServer)
func RegisterStreamsServiceServer
func RegisterStreamsServiceServer(s *grpc.Server, srv StreamsServiceServer)
func RegisterWarehouseServer
func RegisterWarehouseServer(s *grpc.Server, srv WarehouseServer)
AIEnabledDevicesInputConfig
type AIEnabledDevicesInputConfig struct {
// contains filtered or unexported fields
}
Message describing AI-enabled Devices Input Config.
func (*AIEnabledDevicesInputConfig) Descriptor
func (*AIEnabledDevicesInputConfig) Descriptor() ([]byte, []int)
Deprecated: Use AIEnabledDevicesInputConfig.ProtoReflect.Descriptor instead.
func (*AIEnabledDevicesInputConfig) ProtoMessage
func (*AIEnabledDevicesInputConfig) ProtoMessage()
func (*AIEnabledDevicesInputConfig) ProtoReflect
func (x *AIEnabledDevicesInputConfig) ProtoReflect() protoreflect.Message
func (*AIEnabledDevicesInputConfig) Reset
func (x *AIEnabledDevicesInputConfig) Reset()
func (*AIEnabledDevicesInputConfig) String
func (x *AIEnabledDevicesInputConfig) String() string
AcceleratorType
type AcceleratorType int32
Represents a hardware accelerator type.
AcceleratorType_ACCELERATOR_TYPE_UNSPECIFIED, AcceleratorType_NVIDIA_TESLA_K80, AcceleratorType_NVIDIA_TESLA_P100, AcceleratorType_NVIDIA_TESLA_V100, AcceleratorType_NVIDIA_TESLA_P4, AcceleratorType_NVIDIA_TESLA_T4, AcceleratorType_NVIDIA_TESLA_A100, AcceleratorType_TPU_V2, AcceleratorType_TPU_V3
const (
// Unspecified accelerator type, which means no accelerator.
AcceleratorType_ACCELERATOR_TYPE_UNSPECIFIED AcceleratorType = 0
// Nvidia Tesla K80 GPU.
AcceleratorType_NVIDIA_TESLA_K80 AcceleratorType = 1
// Nvidia Tesla P100 GPU.
AcceleratorType_NVIDIA_TESLA_P100 AcceleratorType = 2
// Nvidia Tesla V100 GPU.
AcceleratorType_NVIDIA_TESLA_V100 AcceleratorType = 3
// Nvidia Tesla P4 GPU.
AcceleratorType_NVIDIA_TESLA_P4 AcceleratorType = 4
// Nvidia Tesla T4 GPU.
AcceleratorType_NVIDIA_TESLA_T4 AcceleratorType = 5
// Nvidia Tesla A100 GPU.
AcceleratorType_NVIDIA_TESLA_A100 AcceleratorType = 8
// TPU v2.
AcceleratorType_TPU_V2 AcceleratorType = 6
// TPU v3.
AcceleratorType_TPU_V3 AcceleratorType = 7
)
func (AcceleratorType) Descriptor
func (AcceleratorType) Descriptor() protoreflect.EnumDescriptor
func (AcceleratorType) Enum
func (x AcceleratorType) Enum() *AcceleratorType
func (AcceleratorType) EnumDescriptor
func (AcceleratorType) EnumDescriptor() ([]byte, []int)
Deprecated: Use AcceleratorType.Descriptor instead.
func (AcceleratorType) Number
func (x AcceleratorType) Number() protoreflect.EnumNumber
func (AcceleratorType) String
func (x AcceleratorType) String() string
func (AcceleratorType) Type
func (AcceleratorType) Type() protoreflect.EnumType
AcquireLeaseRequest
type AcquireLeaseRequest struct {
Series string `protobuf:"bytes,1,opt,name=series,proto3" json:"series,omitempty"`
Owner string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
Term *durationpb.Duration `protobuf:"bytes,3,opt,name=term,proto3" json:"term,omitempty"`
LeaseType LeaseType "" /* 129 byte string literal not displayed */
}
Request message for acquiring a lease.
func (*AcquireLeaseRequest) Descriptor
func (*AcquireLeaseRequest) Descriptor() ([]byte, []int)
Deprecated: Use AcquireLeaseRequest.ProtoReflect.Descriptor instead.
func (*AcquireLeaseRequest) GetLeaseType
func (x *AcquireLeaseRequest) GetLeaseType() LeaseType
func (*AcquireLeaseRequest) GetOwner
func (x *AcquireLeaseRequest) GetOwner() string
func (*AcquireLeaseRequest) GetSeries
func (x *AcquireLeaseRequest) GetSeries() string
func (*AcquireLeaseRequest) GetTerm
func (x *AcquireLeaseRequest) GetTerm() *durationpb.Duration
func (*AcquireLeaseRequest) ProtoMessage
func (*AcquireLeaseRequest) ProtoMessage()
func (*AcquireLeaseRequest) ProtoReflect
func (x *AcquireLeaseRequest) ProtoReflect() protoreflect.Message
func (*AcquireLeaseRequest) Reset
func (x *AcquireLeaseRequest) Reset()
func (*AcquireLeaseRequest) String
func (x *AcquireLeaseRequest) String() string
AddApplicationStreamInputRequest
type AddApplicationStreamInputRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
ApplicationStreamInputs []*ApplicationStreamInput "" /* 132 byte string literal not displayed */
RequestId string `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
}
Message for adding stream input to an Application.
func (*AddApplicationStreamInputRequest) Descriptor
func (*AddApplicationStreamInputRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddApplicationStreamInputRequest.ProtoReflect.Descriptor instead.
func (*AddApplicationStreamInputRequest) GetApplicationStreamInputs
func (x *AddApplicationStreamInputRequest) GetApplicationStreamInputs() []*ApplicationStreamInput
func (*AddApplicationStreamInputRequest) GetName
func (x *AddApplicationStreamInputRequest) GetName() string
func (*AddApplicationStreamInputRequest) GetRequestId
func (x *AddApplicationStreamInputRequest) GetRequestId() string
func (*AddApplicationStreamInputRequest) ProtoMessage
func (*AddApplicationStreamInputRequest) ProtoMessage()
func (*AddApplicationStreamInputRequest) ProtoReflect
func (x *AddApplicationStreamInputRequest) ProtoReflect() protoreflect.Message
func (*AddApplicationStreamInputRequest) Reset
func (x *AddApplicationStreamInputRequest) Reset()
func (*AddApplicationStreamInputRequest) String
func (x *AddApplicationStreamInputRequest) String() string
AddApplicationStreamInputResponse
type AddApplicationStreamInputResponse struct {
// contains filtered or unexported fields
}
Message for AddApplicationStreamInput Response.
func (*AddApplicationStreamInputResponse) Descriptor
func (*AddApplicationStreamInputResponse) Descriptor() ([]byte, []int)
Deprecated: Use AddApplicationStreamInputResponse.ProtoReflect.Descriptor instead.
func (*AddApplicationStreamInputResponse) ProtoMessage
func (*AddApplicationStreamInputResponse) ProtoMessage()
func (*AddApplicationStreamInputResponse) ProtoReflect
func (x *AddApplicationStreamInputResponse) ProtoReflect() protoreflect.Message
func (*AddApplicationStreamInputResponse) Reset
func (x *AddApplicationStreamInputResponse) Reset()
func (*AddApplicationStreamInputResponse) String
func (x *AddApplicationStreamInputResponse) String() string
AddCollectionItemRequest
type AddCollectionItemRequest struct {
// Required. The item to be added.
Item *CollectionItem `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
// contains filtered or unexported fields
}
Request message for AddCollectionItem.
func (*AddCollectionItemRequest) Descriptor
func (*AddCollectionItemRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddCollectionItemRequest.ProtoReflect.Descriptor instead.
func (*AddCollectionItemRequest) GetItem
func (x *AddCollectionItemRequest) GetItem() *CollectionItem
func (*AddCollectionItemRequest) ProtoMessage
func (*AddCollectionItemRequest) ProtoMessage()
func (*AddCollectionItemRequest) ProtoReflect
func (x *AddCollectionItemRequest) ProtoReflect() protoreflect.Message
func (*AddCollectionItemRequest) Reset
func (x *AddCollectionItemRequest) Reset()
func (*AddCollectionItemRequest) String
func (x *AddCollectionItemRequest) String() string
AddCollectionItemResponse
type AddCollectionItemResponse struct {
// The item that has already been added.
Item *CollectionItem `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
// contains filtered or unexported fields
}
Response message for AddCollectionItem.
func (*AddCollectionItemResponse) Descriptor
func (*AddCollectionItemResponse) Descriptor() ([]byte, []int)
Deprecated: Use AddCollectionItemResponse.ProtoReflect.Descriptor instead.
func (*AddCollectionItemResponse) GetItem
func (x *AddCollectionItemResponse) GetItem() *CollectionItem
func (*AddCollectionItemResponse) ProtoMessage
func (*AddCollectionItemResponse) ProtoMessage()
func (*AddCollectionItemResponse) ProtoReflect
func (x *AddCollectionItemResponse) ProtoReflect() protoreflect.Message
func (*AddCollectionItemResponse) Reset
func (x *AddCollectionItemResponse) Reset()
func (*AddCollectionItemResponse) String
func (x *AddCollectionItemResponse) String() string
Analysis
type Analysis struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
Labels map[string]string "" /* 153 byte string literal not displayed */
AnalysisDefinition *AnalysisDefinition `protobuf:"bytes,5,opt,name=analysis_definition,json=analysisDefinition,proto3" json:"analysis_definition,omitempty"`
InputStreamsMapping map[string]string "" /* 208 byte string literal not displayed */
OutputStreamsMapping map[string]string "" /* 211 byte string literal not displayed */
DisableEventWatch bool `protobuf:"varint,8,opt,name=disable_event_watch,json=disableEventWatch,proto3" json:"disable_event_watch,omitempty"`
}
Message describing the Analysis object.
func (*Analysis) Descriptor
Deprecated: Use Analysis.ProtoReflect.Descriptor instead.
func (*Analysis) GetAnalysisDefinition
func (x *Analysis) GetAnalysisDefinition() *AnalysisDefinition
func (*Analysis) GetCreateTime
func (x *Analysis) GetCreateTime() *timestamppb.Timestamp
func (*Analysis) GetDisableEventWatch
func (*Analysis) GetInputStreamsMapping
func (*Analysis) GetLabels
func (*Analysis) GetName
func (*Analysis) GetOutputStreamsMapping
func (*Analysis) GetUpdateTime
func (x *Analysis) GetUpdateTime() *timestamppb.Timestamp
func (*Analysis) ProtoMessage
func (*Analysis) ProtoMessage()
func (*Analysis) ProtoReflect
func (x *Analysis) ProtoReflect() protoreflect.Message
func (*Analysis) Reset
func (x *Analysis) Reset()
func (*Analysis) String
AnalysisDefinition
type AnalysisDefinition struct {
// Analyzer definitions.
Analyzers []*AnalyzerDefinition `protobuf:"bytes,1,rep,name=analyzers,proto3" json:"analyzers,omitempty"`
// contains filtered or unexported fields
}
Defines a full analysis.
This is a description of the overall live analytics pipeline. You may think of this as an edge list representation of a multigraph.
This may be directly authored by a human in protobuf textformat, or it may be generated by a programming API (perhaps Python or JavaScript depending on context).
func (*AnalysisDefinition) Descriptor
func (*AnalysisDefinition) Descriptor() ([]byte, []int)
Deprecated: Use AnalysisDefinition.ProtoReflect.Descriptor instead.
func (*AnalysisDefinition) GetAnalyzers
func (x *AnalysisDefinition) GetAnalyzers() []*AnalyzerDefinition
func (*AnalysisDefinition) ProtoMessage
func (*AnalysisDefinition) ProtoMessage()
func (*AnalysisDefinition) ProtoReflect
func (x *AnalysisDefinition) ProtoReflect() protoreflect.Message
func (*AnalysisDefinition) Reset
func (x *AnalysisDefinition) Reset()
func (*AnalysisDefinition) String
func (x *AnalysisDefinition) String() string
AnalyzeAssetMetadata
type AnalyzeAssetMetadata struct {
// The status of analysis on all search capabilities.
AnalysisStatus []*AnalyzeAssetMetadata_AnalysisStatus `protobuf:"bytes,1,rep,name=analysis_status,json=analysisStatus,proto3" json:"analysis_status,omitempty"`
// The start time of the operation.
StartTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
// The update time of the operation.
UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
// contains filtered or unexported fields
}
Metadata for AnalyzeAsset.
func (*AnalyzeAssetMetadata) Descriptor
func (*AnalyzeAssetMetadata) Descriptor() ([]byte, []int)
Deprecated: Use AnalyzeAssetMetadata.ProtoReflect.Descriptor instead.
func (*AnalyzeAssetMetadata) GetAnalysisStatus
func (x *AnalyzeAssetMetadata) GetAnalysisStatus() []*AnalyzeAssetMetadata_AnalysisStatus
func (*AnalyzeAssetMetadata) GetStartTime
func (x *AnalyzeAssetMetadata) GetStartTime() *timestamppb.Timestamp
func (*AnalyzeAssetMetadata) GetUpdateTime
func (x *AnalyzeAssetMetadata) GetUpdateTime() *timestamppb.Timestamp
func (*AnalyzeAssetMetadata) ProtoMessage
func (*AnalyzeAssetMetadata) ProtoMessage()
func (*AnalyzeAssetMetadata) ProtoReflect
func (x *AnalyzeAssetMetadata) ProtoReflect() protoreflect.Message
func (*AnalyzeAssetMetadata) Reset
func (x *AnalyzeAssetMetadata) Reset()
func (*AnalyzeAssetMetadata) String
func (x *AnalyzeAssetMetadata) String() string
AnalyzeAssetMetadata_AnalysisStatus
type AnalyzeAssetMetadata_AnalysisStatus struct {
State AnalyzeAssetMetadata_AnalysisStatus_State "" /* 136 byte string literal not displayed */
StatusMessage string `protobuf:"bytes,3,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
SearchCapability *SearchCapability `protobuf:"bytes,4,opt,name=search_capability,json=searchCapability,proto3" json:"search_capability,omitempty"`
}
The status of analysis on each search capability.
func (*AnalyzeAssetMetadata_AnalysisStatus) Descriptor
func (*AnalyzeAssetMetadata_AnalysisStatus) Descriptor() ([]byte, []int)
Deprecated: Use AnalyzeAssetMetadata_AnalysisStatus.ProtoReflect.Descriptor instead.
func (*AnalyzeAssetMetadata_AnalysisStatus) GetSearchCapability
func (x *AnalyzeAssetMetadata_AnalysisStatus) GetSearchCapability() *SearchCapability
func (*AnalyzeAssetMetadata_AnalysisStatus) GetState
func (x *AnalyzeAssetMetadata_AnalysisStatus) GetState() AnalyzeAssetMetadata_AnalysisStatus_State
func (*AnalyzeAssetMetadata_AnalysisStatus) GetStatusMessage
func (x *AnalyzeAssetMetadata_AnalysisStatus) GetStatusMessage() string
func (*AnalyzeAssetMetadata_AnalysisStatus) ProtoMessage
func (*AnalyzeAssetMetadata_AnalysisStatus) ProtoMessage()
func (*AnalyzeAssetMetadata_AnalysisStatus) ProtoReflect
func (x *AnalyzeAssetMetadata_AnalysisStatus) ProtoReflect() protoreflect.Message
func (*AnalyzeAssetMetadata_AnalysisStatus) Reset
func (x *AnalyzeAssetMetadata_AnalysisStatus) Reset()
func (*AnalyzeAssetMetadata_AnalysisStatus) String
func (x *AnalyzeAssetMetadata_AnalysisStatus) String() string
AnalyzeAssetMetadata_AnalysisStatus_State
type AnalyzeAssetMetadata_AnalysisStatus_State int32
The state of the search capability.
AnalyzeAssetMetadata_AnalysisStatus_STATE_UNSPECIFIED, AnalyzeAssetMetadata_AnalysisStatus_IN_PROGRESS, AnalyzeAssetMetadata_AnalysisStatus_SUCCEEDED, AnalyzeAssetMetadata_AnalysisStatus_FAILED
const (
// The default process state should never happen.
AnalyzeAssetMetadata_AnalysisStatus_STATE_UNSPECIFIED AnalyzeAssetMetadata_AnalysisStatus_State = 0
// The ml model analysis is in progress.
AnalyzeAssetMetadata_AnalysisStatus_IN_PROGRESS AnalyzeAssetMetadata_AnalysisStatus_State = 1
// The ml model analysis is successfully done.
AnalyzeAssetMetadata_AnalysisStatus_SUCCEEDED AnalyzeAssetMetadata_AnalysisStatus_State = 2
// The ml model analysis failed.
AnalyzeAssetMetadata_AnalysisStatus_FAILED AnalyzeAssetMetadata_AnalysisStatus_State = 3
)
func (AnalyzeAssetMetadata_AnalysisStatus_State) Descriptor
func (AnalyzeAssetMetadata_AnalysisStatus_State) Descriptor() protoreflect.EnumDescriptor
func (AnalyzeAssetMetadata_AnalysisStatus_State) Enum
func (x AnalyzeAssetMetadata_AnalysisStatus_State) Enum() *AnalyzeAssetMetadata_AnalysisStatus_State
func (AnalyzeAssetMetadata_AnalysisStatus_State) EnumDescriptor
func (AnalyzeAssetMetadata_AnalysisStatus_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use AnalyzeAssetMetadata_AnalysisStatus_State.Descriptor instead.
func (AnalyzeAssetMetadata_AnalysisStatus_State) Number
func (x AnalyzeAssetMetadata_AnalysisStatus_State) Number() protoreflect.EnumNumber
func (AnalyzeAssetMetadata_AnalysisStatus_State) String
func (x AnalyzeAssetMetadata_AnalysisStatus_State) String() string
func (AnalyzeAssetMetadata_AnalysisStatus_State) Type
func (AnalyzeAssetMetadata_AnalysisStatus_State) Type() protoreflect.EnumType
AnalyzeAssetRequest
type AnalyzeAssetRequest struct {
// Required. The resource name of the asset to analyze.
// Format:
// `projects/{project_number}/locations/{location_id}/corpora/{corpus_id}/assets/{asset_id}`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
Request message for AnalyzeAsset.
func (*AnalyzeAssetRequest) Descriptor
func (*AnalyzeAssetRequest) Descriptor() ([]byte, []int)
Deprecated: Use AnalyzeAssetRequest.ProtoReflect.Descriptor instead.
func (*AnalyzeAssetRequest) GetName
func (x *AnalyzeAssetRequest) GetName() string
func (*AnalyzeAssetRequest) ProtoMessage
func (*AnalyzeAssetRequest) ProtoMessage()
func (*AnalyzeAssetRequest) ProtoReflect
func (x *AnalyzeAssetRequest) ProtoReflect() protoreflect.Message
func (*AnalyzeAssetRequest) Reset
func (x *AnalyzeAssetRequest) Reset()
func (*AnalyzeAssetRequest) String
func (x *AnalyzeAssetRequest) String() string
AnalyzeAssetResponse
type AnalyzeAssetResponse struct {
// contains filtered or unexported fields
}
Response message for AnalyzeAsset.
func (*AnalyzeAssetResponse) Descriptor
func (*AnalyzeAssetResponse) Descriptor() ([]byte, []int)
Deprecated: Use AnalyzeAssetResponse.ProtoReflect.Descriptor instead.
func (*AnalyzeAssetResponse) ProtoMessage
func (*AnalyzeAssetResponse) ProtoMessage()
func (*AnalyzeAssetResponse) ProtoReflect
func (x *AnalyzeAssetResponse) ProtoReflect() protoreflect.Message
func (*AnalyzeAssetResponse) Reset
func (x *AnalyzeAssetResponse) Reset()
func (*AnalyzeAssetResponse) String
func (x *AnalyzeAssetResponse) String() string
AnalyzeCorpusMetadata
type AnalyzeCorpusMetadata struct {
// The metadata of the operation.
Metadata *OperationMetadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata,omitempty"`
// contains filtered or unexported fields
}
The metadata message for AnalyzeCorpus LRO.
func (*AnalyzeCorpusMetadata) Descriptor
func (*AnalyzeCorpusMetadata) Descriptor() ([]byte, []int)
Deprecated: Use AnalyzeCorpusMetadata.ProtoReflect.Descriptor instead.
func (*AnalyzeCorpusMetadata) GetMetadata
func (x *AnalyzeCorpusMetadata) GetMetadata() *OperationMetadata
func (*AnalyzeCorpusMetadata) ProtoMessage
func (*AnalyzeCorpusMetadata) ProtoMessage()
func (*AnalyzeCorpusMetadata) ProtoReflect
func (x *AnalyzeCorpusMetadata) ProtoReflect() protoreflect.Message
func (*AnalyzeCorpusMetadata) Reset
func (x *AnalyzeCorpusMetadata) Reset()
func (*AnalyzeCorpusMetadata) String
func (x *AnalyzeCorpusMetadata) String() string
AnalyzeCorpusRequest
type AnalyzeCorpusRequest struct {
// Required. The parent corpus resource where the assets will be analyzed.
// Format:
// `projects/{project_number}/locations/{location_id}/corpora/{corpus_id}`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
Request message for AnalyzeCorpus.
func (*AnalyzeCorpusRequest) Descriptor
func (*AnalyzeCorpusRequest) Descriptor() ([]byte, []int)
Deprecated: Use AnalyzeCorpusRequest.ProtoReflect.Descriptor instead.
func (*AnalyzeCorpusRequest) GetName
func (x *AnalyzeCorpusRequest) GetName() string
func (*AnalyzeCorpusRequest) ProtoMessage
func (*AnalyzeCorpusRequest) ProtoMessage()
func (*AnalyzeCorpusRequest) ProtoReflect
func (x *AnalyzeCorpusRequest) ProtoReflect() protoreflect.Message
func (*AnalyzeCorpusRequest) Reset
func (x *AnalyzeCorpusRequest) Reset()
func (*AnalyzeCorpusRequest) String
func (x *AnalyzeCorpusRequest) String() string
AnalyzeCorpusResponse
type AnalyzeCorpusResponse struct {
// contains filtered or unexported fields
}
The response message for AnalyzeCorpus LRO.
func (*AnalyzeCorpusResponse) Descriptor
func (*AnalyzeCorpusResponse) Descriptor() ([]byte, []int)
Deprecated: Use AnalyzeCorpusResponse.ProtoReflect.Descriptor instead.
func (*AnalyzeCorpusResponse) ProtoMessage
func (*AnalyzeCorpusResponse) ProtoMessage()
func (*AnalyzeCorpusResponse) ProtoReflect
func (x *AnalyzeCorpusResponse) ProtoReflect() protoreflect.Message
func (*AnalyzeCorpusResponse) Reset
func (x *AnalyzeCorpusResponse) Reset()
func (*AnalyzeCorpusResponse) String
func (x *AnalyzeCorpusResponse) String() string
AnalyzerDefinition
type AnalyzerDefinition struct {
Analyzer string `protobuf:"bytes,1,opt,name=analyzer,proto3" json:"analyzer,omitempty"`
Operator string `protobuf:"bytes,2,opt,name=operator,proto3" json:"operator,omitempty"`
Inputs []*AnalyzerDefinition_StreamInput `protobuf:"bytes,3,rep,name=inputs,proto3" json:"inputs,omitempty"`
Attrs map[string]*AttributeValue "" /* 151 byte string literal not displayed */
DebugOptions *AnalyzerDefinition_DebugOptions `protobuf:"bytes,5,opt,name=debug_options,json=debugOptions,proto3" json:"debug_options,omitempty"`
OperatorOption *AnalyzerDefinition_OperatorOption `protobuf:"bytes,6,opt,name=operator_option,json=operatorOption,proto3" json:"operator_option,omitempty"`
}
Defines an Analyzer.
An analyzer processes data from its input streams using the logic defined in the Operator that it represents. Of course, it produces data for the output streams declared in the Operator.
func (*AnalyzerDefinition) Descriptor
func (*AnalyzerDefinition) Descriptor() ([]byte, []int)
Deprecated: Use AnalyzerDefinition.ProtoReflect.Descriptor instead.
func (*AnalyzerDefinition) GetAnalyzer
func (x *AnalyzerDefinition) GetAnalyzer() string
func (*AnalyzerDefinition) GetAttrs
func (x *AnalyzerDefinition) GetAttrs() map[string]*AttributeValue
func (*AnalyzerDefinition) GetDebugOptions
func (x *AnalyzerDefinition) GetDebugOptions() *AnalyzerDefinition_DebugOptions
func (*AnalyzerDefinition) GetInputs
func (x *AnalyzerDefinition) GetInputs() []*AnalyzerDefinition_StreamInput
func (*AnalyzerDefinition) GetOperator
func (x *AnalyzerDefinition) GetOperator() string
func (*AnalyzerDefinition) GetOperatorOption
func (x *AnalyzerDefinition) GetOperatorOption() *AnalyzerDefinition_OperatorOption
func (*AnalyzerDefinition) ProtoMessage
func (*AnalyzerDefinition) ProtoMessage()
func (*AnalyzerDefinition) ProtoReflect
func (x *AnalyzerDefinition) ProtoReflect() protoreflect.Message
func (*AnalyzerDefinition) Reset
func (x *AnalyzerDefinition) Reset()
func (*AnalyzerDefinition) String
func (x *AnalyzerDefinition) String() string
AnalyzerDefinition_DebugOptions
type AnalyzerDefinition_DebugOptions struct {
EnvironmentVariables map[string]string "" /* 209 byte string literal not displayed */
}
Options available for debugging purposes only.
func (*AnalyzerDefinition_DebugOptions) Descriptor
func (*AnalyzerDefinition_DebugOptions) Descriptor() ([]byte, []int)
Deprecated: Use AnalyzerDefinition_DebugOptions.ProtoReflect.Descriptor instead.
func (*AnalyzerDefinition_DebugOptions) GetEnvironmentVariables
func (x *AnalyzerDefinition_DebugOptions) GetEnvironmentVariables() map[string]string
func (*AnalyzerDefinition_DebugOptions) ProtoMessage
func (*AnalyzerDefinition_DebugOptions) ProtoMessage()
func (*AnalyzerDefinition_DebugOptions) ProtoReflect
func (x *AnalyzerDefinition_DebugOptions) ProtoReflect() protoreflect.Message
func (*AnalyzerDefinition_DebugOptions) Reset
func (x *AnalyzerDefinition_DebugOptions) Reset()
func (*AnalyzerDefinition_DebugOptions) String
func (x *AnalyzerDefinition_DebugOptions) String() string
AnalyzerDefinition_OperatorOption
type AnalyzerDefinition_OperatorOption struct {
// Tag of the operator.
Tag string `protobuf:"bytes,1,opt,name=tag,proto3" json:"tag,omitempty"`
// Registry of the operator. e.g. public, dev.
Registry string `protobuf:"bytes,2,opt,name=registry,proto3" json:"registry,omitempty"`
// contains filtered or unexported fields
}
Option related to the operator.
func (*AnalyzerDefinition_OperatorOption) Descriptor
func (*AnalyzerDefinition_OperatorOption) Descriptor() ([]byte, []int)
Deprecated: Use AnalyzerDefinition_OperatorOption.ProtoReflect.Descriptor instead.
func (*AnalyzerDefinition_OperatorOption) GetRegistry
func (x *AnalyzerDefinition_OperatorOption) GetRegistry() string
func (*AnalyzerDefinition_OperatorOption) GetTag
func (x *AnalyzerDefinition_OperatorOption) GetTag() string
func (*AnalyzerDefinition_OperatorOption) ProtoMessage
func (*AnalyzerDefinition_OperatorOption) ProtoMessage()
func (*AnalyzerDefinition_OperatorOption) ProtoReflect
func (x *AnalyzerDefinition_OperatorOption) ProtoReflect() protoreflect.Message
func (*AnalyzerDefinition_OperatorOption) Reset
func (x *AnalyzerDefinition_OperatorOption) Reset()
func (*AnalyzerDefinition_OperatorOption) String
func (x *AnalyzerDefinition_OperatorOption) String() string
AnalyzerDefinition_StreamInput
type AnalyzerDefinition_StreamInput struct {
// The name of the stream input (as discussed above).
Input string `protobuf:"bytes,1,opt,name=input,proto3" json:"input,omitempty"`
// contains filtered or unexported fields
}
The inputs to this analyzer.
We accept input name references of the following form:
Example:
Suppose you had an operator named "SomeOp" that has 2 output arguments, the first of which is named "foo" and the second of which is named "bar", and an operator named "MyOp" that accepts 2 inputs.
Also suppose that there is an analyzer named "some-analyzer" that is running "SomeOp" and another analyzer named "my-analyzer" running "MyOp".
To indicate that "my-analyzer" is to consume "some-analyzer"'s "foo" output as its first input and "some-analyzer"'s "bar" output as its second input, you can set this field to the following: input = ["some-analyzer:foo", "some-analyzer:bar"]
func (*AnalyzerDefinition_StreamInput) Descriptor
func (*AnalyzerDefinition_StreamInput) Descriptor() ([]byte, []int)
Deprecated: Use AnalyzerDefinition_StreamInput.ProtoReflect.Descriptor instead.
func (*AnalyzerDefinition_StreamInput) GetInput
func (x *AnalyzerDefinition_StreamInput) GetInput() string
func (*AnalyzerDefinition_StreamInput) ProtoMessage
func (*AnalyzerDefinition_StreamInput) ProtoMessage()
func (*AnalyzerDefinition_StreamInput) ProtoReflect
func (x *AnalyzerDefinition_StreamInput) ProtoReflect() protoreflect.Message
func (*AnalyzerDefinition_StreamInput) Reset
func (x *AnalyzerDefinition_StreamInput) Reset()
func (*AnalyzerDefinition_StreamInput) String
func (x *AnalyzerDefinition_StreamInput) String() string
Annotation
type Annotation struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
UserSpecifiedAnnotation *UserSpecifiedAnnotation "" /* 132 byte string literal not displayed */
}
An annotation is a resource in asset. It represents a key-value mapping of content in asset.
func (*Annotation) Descriptor
func (*Annotation) Descriptor() ([]byte, []int)
Deprecated: Use Annotation.ProtoReflect.Descriptor instead.
func (*Annotation) GetName
func (x *Annotation) GetName() string
func (*Annotation) GetUserSpecifiedAnnotation
func (x *Annotation) GetUserSpecifiedAnnotation() *UserSpecifiedAnnotation
func (*Annotation) ProtoMessage
func (*Annotation) ProtoMessage()
func (*Annotation) ProtoReflect
func (x *Annotation) ProtoReflect() protoreflect.Message
func (*Annotation) Reset
func (x *Annotation) Reset()
func (*Annotation) String
func (x *Annotation) String() string
AnnotationCustomizedStruct
type AnnotationCustomizedStruct struct {
Elements map[string]*AnnotationValue "" /* 157 byte string literal not displayed */
}
Customized struct represnation in annotation.
func (*AnnotationCustomizedStruct) Descriptor
func (*AnnotationCustomizedStruct) Descriptor() ([]byte, []int)
Deprecated: Use AnnotationCustomizedStruct.ProtoReflect.Descriptor instead.
func (*AnnotationCustomizedStruct) GetElements
func (x *AnnotationCustomizedStruct) GetElements() map[string]*AnnotationValue
func (*AnnotationCustomizedStruct) ProtoMessage
func (*AnnotationCustomizedStruct) ProtoMessage()
func (*AnnotationCustomizedStruct) ProtoReflect
func (x *AnnotationCustomizedStruct) ProtoReflect() protoreflect.Message
func (*AnnotationCustomizedStruct) Reset
func (x *AnnotationCustomizedStruct) Reset()
func (*AnnotationCustomizedStruct) String
func (x *AnnotationCustomizedStruct) String() string
AnnotationList
type AnnotationList struct {
// The values of `LIST` data type annotation.
Values []*AnnotationValue `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
// contains filtered or unexported fields
}
List representation in annotation.
func (*AnnotationList) Descriptor
func (*AnnotationList) Descriptor() ([]byte, []int)
Deprecated: Use AnnotationList.ProtoReflect.Descriptor instead.
func (*AnnotationList) GetValues
func (x *AnnotationList) GetValues() []*AnnotationValue
func (*AnnotationList) ProtoMessage
func (*AnnotationList) ProtoMessage()
func (*AnnotationList) ProtoReflect
func (x *AnnotationList) ProtoReflect() protoreflect.Message
func (*AnnotationList) Reset
func (x *AnnotationList) Reset()
func (*AnnotationList) String
func (x *AnnotationList) String() string
AnnotationMatchingResult
type AnnotationMatchingResult struct {
// The criteria used for matching. It can be an input search criteria or a
// criteria converted from a facet selection.
Criteria *Criteria `protobuf:"bytes,1,opt,name=criteria,proto3" json:"criteria,omitempty"`
// Matched annotations for the criteria.
MatchedAnnotations []*Annotation `protobuf:"bytes,2,rep,name=matched_annotations,json=matchedAnnotations,proto3" json:"matched_annotations,omitempty"`
// Status of the match result. Possible values:
// FAILED_PRECONDITION - the criteria is not eligible for match.
// OK - matching is performed.
Status *status.Status `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
// contains filtered or unexported fields
}
Stores the criteria-annotation matching results for each search result item.
func (*AnnotationMatchingResult) Descriptor
func (*AnnotationMatchingResult) Descriptor() ([]byte, []int)
Deprecated: Use AnnotationMatchingResult.ProtoReflect.Descriptor instead.
func (*AnnotationMatchingResult) GetCriteria
func (x *AnnotationMatchingResult) GetCriteria() *Criteria
func (*AnnotationMatchingResult) GetMatchedAnnotations
func (x *AnnotationMatchingResult) GetMatchedAnnotations() []*Annotation
func (*AnnotationMatchingResult) GetStatus
func (x *AnnotationMatchingResult) GetStatus() *status.Status
func (*AnnotationMatchingResult) ProtoMessage
func (*AnnotationMatchingResult) ProtoMessage()
func (*AnnotationMatchingResult) ProtoReflect
func (x *AnnotationMatchingResult) ProtoReflect() protoreflect.Message
func (*AnnotationMatchingResult) Reset
func (x *AnnotationMatchingResult) Reset()
func (*AnnotationMatchingResult) String
func (x *AnnotationMatchingResult) String() string
AnnotationValue
type AnnotationValue struct {
// Types that are assignable to Value:
//
// *AnnotationValue_IntValue
// *AnnotationValue_FloatValue
// *AnnotationValue_StrValue
// *AnnotationValue_DatetimeValue
// *AnnotationValue_GeoCoordinate
// *AnnotationValue_ProtoAnyValue
// *AnnotationValue_BoolValue
// *AnnotationValue_CustomizedStructDataValue
// *AnnotationValue_ListValue
// *AnnotationValue_CustomizedStructValue
Value isAnnotationValue_Value `protobuf_oneof:"value"`
// contains filtered or unexported fields
}
Value of annotation, including all types available in data schema.
func (*AnnotationValue) Descriptor
func (*AnnotationValue) Descriptor() ([]byte, []int)
Deprecated: Use AnnotationValue.ProtoReflect.Descriptor instead.
func (*AnnotationValue) GetBoolValue
func (x *AnnotationValue) GetBoolValue() bool
func (*AnnotationValue) GetCustomizedStructDataValue
func (x *AnnotationValue) GetCustomizedStructDataValue() *structpb.Struct
func (*AnnotationValue) GetCustomizedStructValue
func (x *AnnotationValue) GetCustomizedStructValue() *AnnotationCustomizedStruct
func (*AnnotationValue) GetDatetimeValue
func (x *AnnotationValue) GetDatetimeValue() string
func (*AnnotationValue) GetFloatValue
func (x *AnnotationValue) GetFloatValue() float32
func (*AnnotationValue) GetGeoCoordinate
func (x *AnnotationValue) GetGeoCoordinate() *GeoCoordinate
func (*AnnotationValue) GetIntValue
func (x *AnnotationValue) GetIntValue() int64
func (*AnnotationValue) GetListValue
func (x *AnnotationValue) GetListValue() *AnnotationList
func (*AnnotationValue) GetProtoAnyValue
func (x *AnnotationValue) GetProtoAnyValue() *anypb.Any
func (*AnnotationValue) GetStrValue
func (x *AnnotationValue) GetStrValue() string
func (*AnnotationValue) GetValue
func (m *AnnotationValue) GetValue() isAnnotationValue_Value
func (*AnnotationValue) ProtoMessage
func (*AnnotationValue) ProtoMessage()
func (*AnnotationValue) ProtoReflect
func (x *AnnotationValue) ProtoReflect() protoreflect.Message
func (*AnnotationValue) Reset
func (x *AnnotationValue) Reset()
func (*AnnotationValue) String
func (x *AnnotationValue) String() string
AnnotationValue_BoolValue
type AnnotationValue_BoolValue struct {
// Value of boolean type annotation.
BoolValue bool `protobuf:"varint,9,opt,name=bool_value,json=boolValue,proto3,oneof"`
}
AnnotationValue_CustomizedStructDataValue
type AnnotationValue_CustomizedStructDataValue struct {
// Value of customized struct annotation. This field does not have effects.
// Use customized_struct_value instead for customized struct annotation.
CustomizedStructDataValue *structpb.Struct `protobuf:"bytes,10,opt,name=customized_struct_data_value,json=customizedStructDataValue,proto3,oneof"`
}
AnnotationValue_CustomizedStructValue
type AnnotationValue_CustomizedStructValue struct {
// Value of custom struct type annotation.
CustomizedStructValue *AnnotationCustomizedStruct `protobuf:"bytes,6,opt,name=customized_struct_value,json=customizedStructValue,proto3,oneof"`
}
AnnotationValue_DatetimeValue
type AnnotationValue_DatetimeValue struct {
// Value of date time type annotation.
DatetimeValue string `protobuf:"bytes,5,opt,name=datetime_value,json=datetimeValue,proto3,oneof"`
}
AnnotationValue_FloatValue
type AnnotationValue_FloatValue struct {
// Value of float type annotation.
FloatValue float32 `protobuf:"fixed32,2,opt,name=float_value,json=floatValue,proto3,oneof"`
}
AnnotationValue_GeoCoordinate
type AnnotationValue_GeoCoordinate struct {
// Value of geo coordinate type annotation.
GeoCoordinate *GeoCoordinate `protobuf:"bytes,7,opt,name=geo_coordinate,json=geoCoordinate,proto3,oneof"`
}
AnnotationValue_IntValue
type AnnotationValue_IntValue struct {
// Value of int type annotation.
IntValue int64 `protobuf:"varint,1,opt,name=int_value,json=intValue,proto3,oneof"`
}
AnnotationValue_ListValue
type AnnotationValue_ListValue struct {
// Value of list type annotation.
ListValue *AnnotationList `protobuf:"bytes,11,opt,name=list_value,json=listValue,proto3,oneof"`
}
AnnotationValue_ProtoAnyValue
type AnnotationValue_ProtoAnyValue struct {
// Value of any proto value.
ProtoAnyValue *anypb.Any `protobuf:"bytes,8,opt,name=proto_any_value,json=protoAnyValue,proto3,oneof"`
}
AnnotationValue_StrValue
type AnnotationValue_StrValue struct {
// Value of string type annotation.
StrValue string `protobuf:"bytes,3,opt,name=str_value,json=strValue,proto3,oneof"`
}
AppPlatformClient
type AppPlatformClient interface {
// Lists Applications in a given project and location.
ListApplications(ctx context.Context, in *ListApplicationsRequest, opts ...grpc.CallOption) (*ListApplicationsResponse, error)
// Gets details of a single Application.
GetApplication(ctx context.Context, in *GetApplicationRequest, opts ...grpc.CallOption) (*Application, error)
// Creates a new Application in a given project and location.
CreateApplication(ctx context.Context, in *CreateApplicationRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Updates the parameters of a single Application.
UpdateApplication(ctx context.Context, in *UpdateApplicationRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Deletes a single Application.
DeleteApplication(ctx context.Context, in *DeleteApplicationRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Deploys a single Application.
DeployApplication(ctx context.Context, in *DeployApplicationRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Undeploys a single Application.
UndeployApplication(ctx context.Context, in *UndeployApplicationRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Adds target stream input to the Application.
// If the Application is deployed, the corresponding new Application instance
// will be created. If the stream has already been in the Application, the RPC
// will fail.
AddApplicationStreamInput(ctx context.Context, in *AddApplicationStreamInputRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Remove target stream input to the Application, if the Application is
// deployed, the corresponding instance based will be deleted. If the stream
// is not in the Application, the RPC will fail.
RemoveApplicationStreamInput(ctx context.Context, in *RemoveApplicationStreamInputRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Update target stream input to the Application, if the Application is
// deployed, the corresponding instance based will be deployed. For
// CreateOrUpdate behavior, set allow_missing to true.
UpdateApplicationStreamInput(ctx context.Context, in *UpdateApplicationStreamInputRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Lists Instances in a given project and location.
ListInstances(ctx context.Context, in *ListInstancesRequest, opts ...grpc.CallOption) (*ListInstancesResponse, error)
// Gets details of a single Instance.
GetInstance(ctx context.Context, in *GetInstanceRequest, opts ...grpc.CallOption) (*Instance, error)
// Adds target stream input to the Application.
// If the Application is deployed, the corresponding new Application instance
// will be created. If the stream has already been in the Application, the RPC
// will fail.
CreateApplicationInstances(ctx context.Context, in *CreateApplicationInstancesRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Remove target stream input to the Application, if the Application is
// deployed, the corresponding instance based will be deleted. If the stream
// is not in the Application, the RPC will fail.
DeleteApplicationInstances(ctx context.Context, in *DeleteApplicationInstancesRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Adds target stream input to the Application.
// If the Application is deployed, the corresponding new Application instance
// will be created. If the stream has already been in the Application, the RPC
// will fail.
UpdateApplicationInstances(ctx context.Context, in *UpdateApplicationInstancesRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Lists Drafts in a given project and location.
ListDrafts(ctx context.Context, in *ListDraftsRequest, opts ...grpc.CallOption) (*ListDraftsResponse, error)
// Gets details of a single Draft.
GetDraft(ctx context.Context, in *GetDraftRequest, opts ...grpc.CallOption) (*Draft, error)
// Creates a new Draft in a given project and location.
CreateDraft(ctx context.Context, in *CreateDraftRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Updates the parameters of a single Draft.
UpdateDraft(ctx context.Context, in *UpdateDraftRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Deletes a single Draft.
DeleteDraft(ctx context.Context, in *DeleteDraftRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Lists Processors in a given project and location.
ListProcessors(ctx context.Context, in *ListProcessorsRequest, opts ...grpc.CallOption) (*ListProcessorsResponse, error)
// ListPrebuiltProcessors is a custom pass-through verb that Lists Prebuilt
// Processors.
ListPrebuiltProcessors(ctx context.Context, in *ListPrebuiltProcessorsRequest, opts ...grpc.CallOption) (*ListPrebuiltProcessorsResponse, error)
// Gets details of a single Processor.
GetProcessor(ctx context.Context, in *GetProcessorRequest, opts ...grpc.CallOption) (*Processor, error)
// Creates a new Processor in a given project and location.
CreateProcessor(ctx context.Context, in *CreateProcessorRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Updates the parameters of a single Processor.
UpdateProcessor(ctx context.Context, in *UpdateProcessorRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
// Deletes a single Processor.
DeleteProcessor(ctx context.Context, in *DeleteProcessorRequest, opts ...grpc.CallOption) (*longrunningpb.Operation, error)
}
AppPlatformClient is the client API for AppPlatform service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewAppPlatformClient
func NewAppPlatformClient(cc grpc.ClientConnInterface) AppPlatformClient
AppPlatformCloudFunctionRequest
type AppPlatformCloudFunctionRequest struct {
// The metadata of the AppPlatform for customer to identify the source of the
// payload.
AppPlatformMetadata *AppPlatformMetadata `protobuf:"bytes,1,opt,name=app_platform_metadata,json=appPlatformMetadata,proto3" json:"app_platform_metadata,omitempty"`
// The actual annotations to be processed by the customized Cloud Function.
Annotations []*AppPlatformCloudFunctionRequest_StructedInputAnnotation `protobuf:"bytes,2,rep,name=annotations,proto3" json:"annotations,omitempty"`
// contains filtered or unexported fields
}
For any cloud function based customer processing logic, customer's cloud function is expected to receive AppPlatformCloudFunctionRequest as request and send back AppPlatformCloudFunctionResponse as response. Message of request from AppPlatform to Cloud Function.
func (*AppPlatformCloudFunctionRequest) Descriptor
func (*AppPlatformCloudFunctionRequest) Descriptor() ([]byte, []int)
Deprecated: Use AppPlatformCloudFunctionRequest.ProtoReflect.Descriptor instead.
func (*AppPlatformCloudFunctionRequest) GetAnnotations
func (x *AppPlatformCloudFunctionRequest) GetAnnotations() []*AppPlatformCloudFunctionRequest_StructedInputAnnotation
func (*AppPlatformCloudFunctionRequest) GetAppPlatformMetadata
func (x *AppPlatformCloudFunctionRequest) GetAppPlatformMetadata() *AppPlatformMetadata
func (*AppPlatformCloudFunctionRequest) ProtoMessage
func (*AppPlatformCloudFunctionRequest) ProtoMessage()
func (*AppPlatformCloudFunctionRequest) ProtoReflect
func (x *AppPlatformCloudFunctionRequest) ProtoReflect() protoreflect.Message
func (*AppPlatformCloudFunctionRequest) Reset
func (x *AppPlatformCloudFunctionRequest) Reset()
func (*AppPlatformCloudFunctionRequest) String
func (x *AppPlatformCloudFunctionRequest) String() string
AppPlatformCloudFunctionRequest_StructedInputAnnotation
type AppPlatformCloudFunctionRequest_StructedInputAnnotation struct {
// The ingestion time of the current annotation.
IngestionTimeMicros int64 `protobuf:"varint,1,opt,name=ingestion_time_micros,json=ingestionTimeMicros,proto3" json:"ingestion_time_micros,omitempty"`
// The struct format of the actual annotation.
Annotation *structpb.Struct `protobuf:"bytes,2,opt,name=annotation,proto3" json:"annotation,omitempty"`
// contains filtered or unexported fields
}
A general annotation message that uses struct format to represent different concrete annotation protobufs.
func (*AppPlatformCloudFunctionRequest_StructedInputAnnotation) Descriptor
func (*AppPlatformCloudFunctionRequest_StructedInputAnnotation) Descriptor() ([]byte, []int)
Deprecated: Use AppPlatformCloudFunctionRequest_StructedInputAnnotation.ProtoReflect.Descriptor instead.
func (*AppPlatformCloudFunctionRequest_StructedInputAnnotation) GetAnnotation
func (x *AppPlatformCloudFunctionRequest_StructedInputAnnotation) GetAnnotation() *structpb.Struct
func (*AppPlatformCloudFunctionRequest_StructedInputAnnotation) GetIngestionTimeMicros
func (x *AppPlatformCloudFunctionRequest_StructedInputAnnotation) GetIngestionTimeMicros() int64
func (*AppPlatformCloudFunctionRequest_StructedInputAnnotation) ProtoMessage
func (*AppPlatformCloudFunctionRequest_StructedInputAnnotation) ProtoMessage()
func (*AppPlatformCloudFunctionRequest_StructedInputAnnotation) ProtoReflect
func (x *AppPlatformCloudFunctionRequest_StructedInputAnnotation) ProtoReflect() protoreflect.Message
func (*AppPlatformCloudFunctionRequest_StructedInputAnnotation) Reset
func (x *AppPlatformCloudFunctionRequest_StructedInputAnnotation) Reset()
func (*AppPlatformCloudFunctionRequest_StructedInputAnnotation) String
func (x *AppPlatformCloudFunctionRequest_StructedInputAnnotation) String() string
AppPlatformCloudFunctionResponse
type AppPlatformCloudFunctionResponse struct {
// The modified annotations that is returned back to AppPlatform.
// If the annotations fields are empty, then those annotations will be dropped
// by AppPlatform.
Annotations []*AppPlatformCloudFunctionResponse_StructedOutputAnnotation `protobuf:"bytes,2,rep,name=annotations,proto3" json:"annotations,omitempty"`
// If set to true, AppPlatform will use original annotations instead of
// dropping them, even if it is empty in the annotations filed.
AnnotationPassthrough bool `protobuf:"varint,3,opt,name=annotation_passthrough,json=annotationPassthrough,proto3" json:"annotation_passthrough,omitempty"`
// The event notifications that is returned back to AppPlatform. Typically it
// will then be configured to be consumed/forwared to a operator that handles
// events, such as Pub/Sub operator.
Events []*AppPlatformEventBody `protobuf:"bytes,4,rep,name=events,proto3" json:"events,omitempty"`
// contains filtered or unexported fields
}
Message of the response from customer's Cloud Function to AppPlatform.
func (*AppPlatformCloudFunctionResponse) Descriptor
func (*AppPlatformCloudFunctionResponse) Descriptor() ([]byte, []int)
Deprecated: Use AppPlatformCloudFunctionResponse.ProtoReflect.Descriptor instead.
func (*AppPlatformCloudFunctionResponse) GetAnnotationPassthrough
func (x *AppPlatformCloudFunctionResponse) GetAnnotationPassthrough() bool
func (*AppPlatformCloudFunctionResponse) GetAnnotations
func (x *AppPlatformCloudFunctionResponse) GetAnnotations() []*AppPlatformCloudFunctionResponse_StructedOutputAnnotation
func (*AppPlatformCloudFunctionResponse) GetEvents
func (x *AppPlatformCloudFunctionResponse) GetEvents() []*AppPlatformEventBody
func (*AppPlatformCloudFunctionResponse) ProtoMessage
func (*AppPlatformCloudFunctionResponse) ProtoMessage()
func (*AppPlatformCloudFunctionResponse) ProtoReflect
func (x *AppPlatformCloudFunctionResponse) ProtoReflect() protoreflect.Message
func (*AppPlatformCloudFunctionResponse) Reset
func (x *AppPlatformCloudFunctionResponse) Reset()
func (*AppPlatformCloudFunctionResponse) String
func (x *AppPlatformCloudFunctionResponse) String() string
AppPlatformCloudFunctionResponse_StructedOutputAnnotation
type AppPlatformCloudFunctionResponse_StructedOutputAnnotation struct {
// The struct format of the actual annotation.
Annotation *structpb.Struct `protobuf:"bytes,1,opt,name=annotation,proto3" json:"annotation,omitempty"`
// contains filtered or unexported fields
}
A general annotation message that uses struct format to represent different concrete annotation protobufs.
func (*AppPlatformCloudFunctionResponse_StructedOutputAnnotation) Descriptor
func (*AppPlatformCloudFunctionResponse_StructedOutputAnnotation) Descriptor() ([]byte, []int)
Deprecated: Use AppPlatformCloudFunctionResponse_StructedOutputAnnotation.ProtoReflect.Descriptor instead.
func (*AppPlatformCloudFunctionResponse_StructedOutputAnnotation) GetAnnotation
func (x *AppPlatformCloudFunctionResponse_StructedOutputAnnotation) GetAnnotation() *structpb.Struct
func (*AppPlatformCloudFunctionResponse_StructedOutputAnnotation) ProtoMessage
func (*AppPlatformCloudFunctionResponse_StructedOutputAnnotation) ProtoMessage()
func (*AppPlatformCloudFunctionResponse_StructedOutputAnnotation) ProtoReflect
func (x *AppPlatformCloudFunctionResponse_StructedOutputAnnotation) ProtoReflect() protoreflect.Message
func (*AppPlatformCloudFunctionResponse_StructedOutputAnnotation) Reset
func (x *AppPlatformCloudFunctionResponse_StructedOutputAnnotation) Reset()
func (*AppPlatformCloudFunctionResponse_StructedOutputAnnotation) String
func (x *AppPlatformCloudFunctionResponse_StructedOutputAnnotation) String() string
AppPlatformEventBody
type AppPlatformEventBody struct {
// Human readable string of the event like "There are more than 6 people in
// the scene". or "Shelf is empty!".
EventMessage string `protobuf:"bytes,1,opt,name=event_message,json=eventMessage,proto3" json:"event_message,omitempty"`
// For the case of Pub/Sub, it will be stored in the message attributes.
// pubsub.proto
Payload *structpb.Struct `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
// User defined Event Id, used to classify event, within a delivery interval,
// events from the same application instance with the same id will be
// de-duplicated & only first one will be sent out. Empty event_id will be
// treated as "".
EventId string `protobuf:"bytes,3,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
// contains filtered or unexported fields
}
Message of content of appPlatform event
func (*AppPlatformEventBody) Descriptor
func (*AppPlatformEventBody) Descriptor() ([]byte, []int)
Deprecated: Use AppPlatformEventBody.ProtoReflect.Descriptor instead.
func (*AppPlatformEventBody) GetEventId
func (x *AppPlatformEventBody) GetEventId() string
func (*AppPlatformEventBody) GetEventMessage
func (x *AppPlatformEventBody) GetEventMessage() string
func (*AppPlatformEventBody) GetPayload
func (x *AppPlatformEventBody) GetPayload() *structpb.Struct
func (*AppPlatformEventBody) ProtoMessage
func (*AppPlatformEventBody) ProtoMessage()
func (*AppPlatformEventBody) ProtoReflect
func (x *AppPlatformEventBody) ProtoReflect() protoreflect.Message
func (*AppPlatformEventBody) Reset
func (x *AppPlatformEventBody) Reset()
func (*AppPlatformEventBody) String
func (x *AppPlatformEventBody) String() string
AppPlatformMetadata
type AppPlatformMetadata struct {
// The application resource name.
Application string `protobuf:"bytes,1,opt,name=application,proto3" json:"application,omitempty"`
// The instance resource id. Instance is the nested resource of application
// under collection 'instances'.
InstanceId string `protobuf:"bytes,2,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
// The node name of the application graph.
Node string `protobuf:"bytes,3,opt,name=node,proto3" json:"node,omitempty"`
// The referred processor resource name of the application node.
Processor string `protobuf:"bytes,4,opt,name=processor,proto3" json:"processor,omitempty"`
// contains filtered or unexported fields
}
Message of essential metadata of App Platform. This message is usually attached to a certain processor output annotation for customer to identify the source of the data.
func (*AppPlatformMetadata) Descriptor
func (*AppPlatformMetadata) Descriptor() ([]byte, []int)
Deprecated: Use AppPlatformMetadata.ProtoReflect.Descriptor instead.
func (*AppPlatformMetadata) GetApplication
func (x *AppPlatformMetadata) GetApplication() string
func (*AppPlatformMetadata) GetInstanceId
func (x *AppPlatformMetadata) GetInstanceId() string
func (*AppPlatformMetadata) GetNode
func (x *AppPlatformMetadata) GetNode() string
func (*AppPlatformMetadata) GetProcessor
func (x *AppPlatformMetadata) GetProcessor() string
func (*AppPlatformMetadata) ProtoMessage
func (*AppPlatformMetadata) ProtoMessage()
func (*AppPlatformMetadata) ProtoReflect
func (x *AppPlatformMetadata) ProtoReflect() protoreflect.Message
func (*AppPlatformMetadata) Reset
func (x *AppPlatformMetadata) Reset()
func (*AppPlatformMetadata) String
func (x *AppPlatformMetadata) String() string
AppPlatformServer
type AppPlatformServer interface {
// Lists Applications in a given project and location.
ListApplications(context.Context, *ListApplicationsRequest) (*ListApplicationsResponse, error)
// Gets details of a single Application.
GetApplication(context.Context, *GetApplicationRequest) (*Application, error)
// Creates a new Application in a given project and location.
CreateApplication(context.Context, *CreateApplicationRequest) (*longrunningpb.Operation, error)
// Updates the parameters of a single Application.
UpdateApplication(context.Context, *UpdateApplicationRequest) (*longrunningpb.Operation, error)
// Deletes a single Application.
DeleteApplication(context.Context, *DeleteApplicationRequest) (*longrunningpb.Operation, error)
// Deploys a single Application.
DeployApplication(context.Context, *DeployApplicationRequest) (*longrunningpb.Operation, error)
// Undeploys a single Application.
UndeployApplication(context.Context, *UndeployApplicationRequest) (*longrunningpb.Operation, error)
// Adds target stream input to the Application.
// If the Application is deployed, the corresponding new Application instance
// will be created. If the stream has already been in the Application, the RPC
// will fail.
AddApplicationStreamInput(context.Context, *AddApplicationStreamInputRequest) (*longrunningpb.Operation, error)
// Remove target stream input to the Application, if the Application is
// deployed, the corresponding instance based will be deleted. If the stream
// is not in the Application, the RPC will fail.
RemoveApplicationStreamInput(context.Context, *RemoveApplicationStreamInputRequest) (*longrunningpb.Operation, error)
// Update target stream input to the Application, if the Application is
// deployed, the corresponding instance based will be deployed. For
// CreateOrUpdate behavior, set allow_missing to true.
UpdateApplicationStreamInput(context.Context, *UpdateApplicationStreamInputRequest) (*longrunningpb.Operation, error)
// Lists Instances in a given project and location.
ListInstances(context.Context, *ListInstancesRequest) (*ListInstancesResponse, error)
// Gets details of a single Instance.
GetInstance(context.Context, *GetInstanceRequest) (*Instance, error)
// Adds target stream input to the Application.
// If the Application is deployed, the corresponding new Application instance
// will be created. If the stream has already been in the Application, the RPC
// will fail.
CreateApplicationInstances(context.Context, *CreateApplicationInstancesRequest) (*longrunningpb.Operation, error)
// Remove target stream input to the Application, if the Application is
// deployed, the corresponding instance based will be deleted. If the stream
// is not in the Application, the RPC will fail.
DeleteApplicationInstances(context.Context, *DeleteApplicationInstancesRequest) (*longrunningpb.Operation, error)
// Adds target stream input to the Application.
// If the Application is deployed, the corresponding new Application instance
// will be created. If the stream has already been in the Application, the RPC
// will fail.
UpdateApplicationInstances(context.Context, *UpdateApplicationInstancesRequest) (*longrunningpb.Operation, error)
// Lists Drafts in a given project and location.
ListDrafts(context.Context, *ListDraftsRequest) (*ListDraftsResponse, error)
// Gets details of a single Draft.
GetDraft(context.Context, *GetDraftRequest) (*Draft, error)
// Creates a new Draft in a given project and location.
CreateDraft(context.Context, *CreateDraftRequest) (*longrunningpb.Operation, error)
// Updates the parameters of a single Draft.
UpdateDraft(context.Context, *UpdateDraftRequest) (*longrunningpb.Operation, error)
// Deletes a single Draft.
DeleteDraft(context.Context, *DeleteDraftRequest) (*longrunningpb.Operation, error)
// Lists Processors in a given project and location.
ListProcessors(context.Context, *ListProcessorsRequest) (*ListProcessorsResponse, error)
// ListPrebuiltProcessors is a custom pass-through verb that Lists Prebuilt
// Processors.
ListPrebuiltProcessors(context.Context, *ListPrebuiltProcessorsRequest) (*ListPrebuiltProcessorsResponse, error)
// Gets details of a single Processor.
GetProcessor(context.Context, *GetProcessorRequest) (*Processor, error)
// Creates a new Processor in a given project and location.
CreateProcessor(context.Context, *CreateProcessorRequest) (*longrunningpb.Operation, error)
// Updates the parameters of a single Processor.
UpdateProcessor(context.Context, *UpdateProcessorRequest) (*longrunningpb.Operation, error)
// Deletes a single Processor.
DeleteProcessor(context.Context, *DeleteProcessorRequest) (*longrunningpb.Operation, error)
}
AppPlatformServer is the server API for AppPlatform service.
Application
type Application struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
Labels map[string]string "" /* 153 byte string literal not displayed */
DisplayName string `protobuf:"bytes,5,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
Description string `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
ApplicationConfigs *ApplicationConfigs `protobuf:"bytes,7,opt,name=application_configs,json=applicationConfigs,proto3" json:"application_configs,omitempty"`
RuntimeInfo *Application_ApplicationRuntimeInfo `protobuf:"bytes,8,opt,name=runtime_info,json=runtimeInfo,proto3" json:"runtime_info,omitempty"`
State Application_State `protobuf:"varint,9,opt,name=state,proto3,enum=google.cloud.visionai.v1.Application_State" json:"state,omitempty"`
BillingMode Application_BillingMode "" /* 150 byte string literal not displayed */
}
Message describing Application object
func (*Application) Descriptor
func (*Application) Descriptor() ([]byte, []int)
Deprecated: Use Application.ProtoReflect.Descriptor instead.
func (*Application) GetApplicationConfigs
func (x *Application) GetApplicationConfigs() *ApplicationConfigs
func (*Application) GetBillingMode
func (x *Application) GetBillingMode() Application_BillingMode
func (*Application) GetCreateTime
func (x *Application) GetCreateTime() *timestamppb.Timestamp
func (*Application) GetDescription
func (x *Application) GetDescription() string
func (*Application) GetDisplayName
func (x *Application) GetDisplayName() string
func (*Application) GetLabels
func (x *Application) GetLabels() map[string]string
func (*Application) GetName
func (x *Application) GetName() string
func (*Application) GetRuntimeInfo
func (x *Application) GetRuntimeInfo() *Application_ApplicationRuntimeInfo
func (*Application) GetState
func (x *Application) GetState() Application_State
func (*Application) GetUpdateTime
func (x *Application) GetUpdateTime() *timestamppb.Timestamp
func (*Application) ProtoMessage
func (*Application) ProtoMessage()
func (*Application) ProtoReflect
func (x *Application) ProtoReflect() protoreflect.Message
func (*Application) Reset
func (x *Application) Reset()
func (*Application) String
func (x *Application) String() string
ApplicationConfigs
type ApplicationConfigs struct {
// A list of nodes in the application graph.
Nodes []*Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
// Event-related configuration for this application.
EventDeliveryConfig *ApplicationConfigs_EventDeliveryConfig `protobuf:"bytes,3,opt,name=event_delivery_config,json=eventDeliveryConfig,proto3" json:"event_delivery_config,omitempty"`
// contains filtered or unexported fields
}
Message storing the graph of the application.
func (*ApplicationConfigs) Descriptor
func (*ApplicationConfigs) Descriptor() ([]byte, []int)
Deprecated: Use ApplicationConfigs.ProtoReflect.Descriptor instead.
func (*ApplicationConfigs) GetEventDeliveryConfig
func (x *ApplicationConfigs) GetEventDeliveryConfig() *ApplicationConfigs_EventDeliveryConfig
func (*ApplicationConfigs) GetNodes
func (x *ApplicationConfigs) GetNodes() []*Node
func (*ApplicationConfigs) ProtoMessage
func (*ApplicationConfigs) ProtoMessage()
func (*ApplicationConfigs) ProtoReflect
func (x *ApplicationConfigs) ProtoReflect() protoreflect.Message
func (*ApplicationConfigs) Reset
func (x *ApplicationConfigs) Reset()
func (*ApplicationConfigs) String
func (x *ApplicationConfigs) String() string
ApplicationConfigs_EventDeliveryConfig
type ApplicationConfigs_EventDeliveryConfig struct {
Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
MinimalDeliveryInterval *durationpb.Duration "" /* 132 byte string literal not displayed */
}
message storing the config for event delivery
func (*ApplicationConfigs_EventDeliveryConfig) Descriptor
func (*ApplicationConfigs_EventDeliveryConfig) Descriptor() ([]byte, []int)
Deprecated: Use ApplicationConfigs_EventDeliveryConfig.ProtoReflect.Descriptor instead.
func (*ApplicationConfigs_EventDeliveryConfig) GetChannel
func (x *ApplicationConfigs_EventDeliveryConfig) GetChannel() string
func (*ApplicationConfigs_EventDeliveryConfig) GetMinimalDeliveryInterval
func (x *ApplicationConfigs_EventDeliveryConfig) GetMinimalDeliveryInterval() *durationpb.Duration
func (*ApplicationConfigs_EventDeliveryConfig) ProtoMessage
func (*ApplicationConfigs_EventDeliveryConfig) ProtoMessage()
func (*ApplicationConfigs_EventDeliveryConfig) ProtoReflect
func (x *ApplicationConfigs_EventDeliveryConfig) ProtoReflect() protoreflect.Message
func (*ApplicationConfigs_EventDeliveryConfig) Reset
func (x *ApplicationConfigs_EventDeliveryConfig) Reset()
func (*ApplicationConfigs_EventDeliveryConfig) String
func (x *ApplicationConfigs_EventDeliveryConfig) String() string
ApplicationInstance
type ApplicationInstance struct {
// Required. Id of the requesting object.
InstanceId string `protobuf:"bytes,1,opt,name=instance_id,json=instanceId,proto3" json:"instance_id,omitempty"`
// Required. The resource being created.
Instance *Instance `protobuf:"bytes,2,opt,name=instance,proto3" json:"instance,omitempty"`
// contains filtered or unexported fields
}
Message for creating a Instance.
func (*ApplicationInstance) Descriptor
func (*ApplicationInstance) Descriptor() ([]byte, []int)
Deprecated: Use ApplicationInstance.ProtoReflect.Descriptor instead.
func (*ApplicationInstance) GetInstance
func (x *ApplicationInstance) GetInstance() *Instance
func (*ApplicationInstance) GetInstanceId
func (x *ApplicationInstance) GetInstanceId() string
func (*ApplicationInstance) ProtoMessage
func (*ApplicationInstance) ProtoMessage()
func (*ApplicationInstance) ProtoReflect
func (x *ApplicationInstance) ProtoReflect() protoreflect.Message
func (*ApplicationInstance) Reset
func (x *ApplicationInstance) Reset()
func (*ApplicationInstance) String
func (x *ApplicationInstance) String() string
ApplicationNodeAnnotation
type ApplicationNodeAnnotation struct {
// The node name of the application graph.
Node string `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
// The node specific stream annotations.
Annotations []*StreamAnnotation `protobuf:"bytes,2,rep,name=annotations,proto3" json:"annotations,omitempty"`
// contains filtered or unexported fields
}
Message describing annotations specific to application node. This message is a duplication of StreamWithAnnotation.NodeAnnotation.
func (*ApplicationNodeAnnotation) Descriptor
func (*ApplicationNodeAnnotation) Descriptor() ([]byte, []int)
Deprecated: Use ApplicationNodeAnnotation.ProtoReflect.Descriptor instead.
func (*ApplicationNodeAnnotation) GetAnnotations
func (x *ApplicationNodeAnnotation) GetAnnotations() []*StreamAnnotation
func (*ApplicationNodeAnnotation) GetNode
func (x *ApplicationNodeAnnotation) GetNode() string
func (*ApplicationNodeAnnotation) ProtoMessage
func (*ApplicationNodeAnnotation) ProtoMessage()
func (*ApplicationNodeAnnotation) ProtoReflect
func (x *ApplicationNodeAnnotation) ProtoReflect() protoreflect.Message
func (*ApplicationNodeAnnotation) Reset
func (x *ApplicationNodeAnnotation) Reset()
func (*ApplicationNodeAnnotation) String
func (x *ApplicationNodeAnnotation) String() string
ApplicationStreamInput
type ApplicationStreamInput struct {
StreamWithAnnotation *StreamWithAnnotation `protobuf:"bytes,1,opt,name=stream_with_annotation,json=streamWithAnnotation,proto3" json:"stream_with_annotation,omitempty"`
// contains filtered or unexported fields
}
Message about a single stream input config.
func (*ApplicationStreamInput) Descriptor
func (*ApplicationStreamInput) Descriptor() ([]byte, []int)
Deprecated: Use ApplicationStreamInput.ProtoReflect.Descriptor instead.
func (*ApplicationStreamInput) GetStreamWithAnnotation
func (x *ApplicationStreamInput) GetStreamWithAnnotation() *StreamWithAnnotation
func (*ApplicationStreamInput) ProtoMessage
func (*ApplicationStreamInput) ProtoMessage()
func (*ApplicationStreamInput) ProtoReflect
func (x *ApplicationStreamInput) ProtoReflect() protoreflect.Message
func (*ApplicationStreamInput) Reset
func (x *ApplicationStreamInput) Reset()
func (*ApplicationStreamInput) String
func (x *ApplicationStreamInput) String() string
Application_ApplicationRuntimeInfo
type Application_ApplicationRuntimeInfo struct {
// Timestamp when the engine be deployed
DeployTime *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=deploy_time,json=deployTime,proto3" json:"deploy_time,omitempty"`
// Globally created resources like warehouse dataschemas.
GlobalOutputResources []*Application_ApplicationRuntimeInfo_GlobalOutputResource `protobuf:"bytes,3,rep,name=global_output_resources,json=globalOutputResources,proto3" json:"global_output_resources,omitempty"`
// Monitoring-related configuration for this application.
MonitoringConfig *Application_ApplicationRuntimeInfo_MonitoringConfig `protobuf:"bytes,4,opt,name=monitoring_config,json=monitoringConfig,proto3" json:"monitoring_config,omitempty"`
// contains filtered or unexported fields
}
Message storing the runtime information of the application.
func (*Application_ApplicationRuntimeInfo) Descriptor
func (*Application_ApplicationRuntimeInfo) Descriptor() ([]byte, []int)
Deprecated: Use Application_ApplicationRuntimeInfo.ProtoReflect.Descriptor instead.
func (*Application_ApplicationRuntimeInfo) GetDeployTime
func (x *Application_ApplicationRuntimeInfo) GetDeployTime() *timestamppb.Timestamp
func (*Application_ApplicationRuntimeInfo) GetGlobalOutputResources
func (x *Application_ApplicationRuntimeInfo) GetGlobalOutputResources() []*Application_ApplicationRuntimeInfo_GlobalOutputResource
func (*Application_ApplicationRuntimeInfo) GetMonitoringConfig
func (x *Application_ApplicationRuntimeInfo) GetMonitoringConfig() *Application_ApplicationRuntimeInfo_MonitoringConfig
func (*Application_ApplicationRuntimeInfo) ProtoMessage
func (*Application_ApplicationRuntimeInfo) ProtoMessage()
func (*Application_ApplicationRuntimeInfo) ProtoReflect
func (x *Application_ApplicationRuntimeInfo) ProtoReflect() protoreflect.Message
func (*Application_ApplicationRuntimeInfo) Reset
func (x *Application_ApplicationRuntimeInfo) Reset()
func (*Application_ApplicationRuntimeInfo) String
func (x *Application_ApplicationRuntimeInfo) String() string
Application_ApplicationRuntimeInfo_GlobalOutputResource
type Application_ApplicationRuntimeInfo_GlobalOutputResource struct {
// The full resource name of the outputted resources.
OutputResource string `protobuf:"bytes,1,opt,name=output_resource,json=outputResource,proto3" json:"output_resource,omitempty"`
// The name of graph node who produces the output resource name.
// For example:
// output_resource:
// /projects/123/locations/us-central1/corpora/my-corpus/dataSchemas/my-schema
// producer_node: occupancy-count
ProducerNode string `protobuf:"bytes,2,opt,name=producer_node,json=producerNode,proto3" json:"producer_node,omitempty"`
// The key of the output resource, it has to be unique within the same
// producer node. One producer node can output several output resources,
// the key can be used to match corresponding output resources.
Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
// contains filtered or unexported fields
}
Message about output resources from application.
func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) Descriptor
func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) Descriptor() ([]byte, []int)
Deprecated: Use Application_ApplicationRuntimeInfo_GlobalOutputResource.ProtoReflect.Descriptor instead.
func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) GetKey
func (x *Application_ApplicationRuntimeInfo_GlobalOutputResource) GetKey() string
func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) GetOutputResource
func (x *Application_ApplicationRuntimeInfo_GlobalOutputResource) GetOutputResource() string
func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) GetProducerNode
func (x *Application_ApplicationRuntimeInfo_GlobalOutputResource) GetProducerNode() string
func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) ProtoMessage
func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) ProtoMessage()
func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) ProtoReflect
func (x *Application_ApplicationRuntimeInfo_GlobalOutputResource) ProtoReflect() protoreflect.Message
func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) Reset
func (x *Application_ApplicationRuntimeInfo_GlobalOutputResource) Reset()
func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) String
func (x *Application_ApplicationRuntimeInfo_GlobalOutputResource) String() string
Application_ApplicationRuntimeInfo_MonitoringConfig
type Application_ApplicationRuntimeInfo_MonitoringConfig struct {
// Whether this application has monitoring enabled.
Enabled bool `protobuf:"varint,1,opt,name=enabled,proto3" json:"enabled,omitempty"`
// contains filtered or unexported fields
}
Monitoring-related configuration for an application.
func (*Application_ApplicationRuntimeInfo_MonitoringConfig) Descriptor
func (*Application_ApplicationRuntimeInfo_MonitoringConfig) Descriptor() ([]byte, []int)
Deprecated: Use Application_ApplicationRuntimeInfo_MonitoringConfig.ProtoReflect.Descriptor instead.
func (*Application_ApplicationRuntimeInfo_MonitoringConfig) GetEnabled
func (x *Application_ApplicationRuntimeInfo_MonitoringConfig) GetEnabled() bool
func (*Application_ApplicationRuntimeInfo_MonitoringConfig) ProtoMessage
func (*Application_ApplicationRuntimeInfo_MonitoringConfig) ProtoMessage()
func (*Application_ApplicationRuntimeInfo_MonitoringConfig) ProtoReflect
func (x *Application_ApplicationRuntimeInfo_MonitoringConfig) ProtoReflect() protoreflect.Message
func (*Application_ApplicationRuntimeInfo_MonitoringConfig) Reset
func (x *Application_ApplicationRuntimeInfo_MonitoringConfig) Reset()
func (*Application_ApplicationRuntimeInfo_MonitoringConfig) String
func (x *Application_ApplicationRuntimeInfo_MonitoringConfig) String() string
Application_BillingMode
type Application_BillingMode int32
Billing mode of the Application
Application_BILLING_MODE_UNSPECIFIED, Application_PAYG, Application_MONTHLY
const (
// The default value.
Application_BILLING_MODE_UNSPECIFIED Application_BillingMode = 0
// Pay as you go billing mode.
Application_PAYG Application_BillingMode = 1
// Monthly billing mode.
Application_MONTHLY Application_BillingMode = 2
)
func (Application_BillingMode) Descriptor
func (Application_BillingMode) Descriptor() protoreflect.EnumDescriptor
func (Application_BillingMode) Enum
func (x Application_BillingMode) Enum() *Application_BillingMode
func (Application_BillingMode) EnumDescriptor
func (Application_BillingMode) EnumDescriptor() ([]byte, []int)
Deprecated: Use Application_BillingMode.Descriptor instead.
func (Application_BillingMode) Number
func (x Application_BillingMode) Number() protoreflect.EnumNumber
func (Application_BillingMode) String
func (x Application_BillingMode) String() string
func (Application_BillingMode) Type
func (Application_BillingMode) Type() protoreflect.EnumType
Application_State
type Application_State int32
State of the Application
Application_STATE_UNSPECIFIED, Application_CREATED, Application_DEPLOYING, Application_DEPLOYED, Application_UNDEPLOYING, Application_DELETED, Application_ERROR, Application_CREATING, Application_UPDATING, Application_DELETING, Application_FIXING
const (
// The default value. This value is used if the state is omitted.
Application_STATE_UNSPECIFIED Application_State = 0
// State CREATED.
Application_CREATED Application_State = 1
// State DEPLOYING.
Application_DEPLOYING Application_State = 2
// State DEPLOYED.
Application_DEPLOYED Application_State = 3
// State UNDEPLOYING.
Application_UNDEPLOYING Application_State = 4
// State DELETED.
Application_DELETED Application_State = 5
// State ERROR.
Application_ERROR Application_State = 6
// State CREATING.
Application_CREATING Application_State = 7
// State Updating.
Application_UPDATING Application_State = 8
// State Deleting.
Application_DELETING Application_State = 9
// State Fixing.
Application_FIXING Application_State = 10
)
func (Application_State) Descriptor
func (Application_State) Descriptor() protoreflect.EnumDescriptor
func (Application_State) Enum
func (x Application_State) Enum() *Application_State
func (Application_State) EnumDescriptor
func (Application_State) EnumDescriptor() ([]byte, []int)
Deprecated: Use Application_State.Descriptor instead.
func (Application_State) Number
func (x Application_State) Number() protoreflect.EnumNumber
func (Application_State) String
func (x Application_State) String() string
func (Application_State) Type
func (Application_State) Type() protoreflect.EnumType
Asset
type Asset struct {
// Resource name of the asset.
// Format:
// `projects/{project_number}/locations/{location_id}/corpora/{corpus_id}/assets/{asset_id}`
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// The duration for which all media assets, associated metadata, and search
// documents can exist. If not set, then it will using the default ttl in the
// parent corpus resource.
Ttl *durationpb.Duration `protobuf:"bytes,2,opt,name=ttl,proto3" json:"ttl,omitempty"`
// Output only. The original cloud storage source uri that is associated with
// this asset.
AssetGcsSource *AssetSource_AssetGcsSource `protobuf:"bytes,4,opt,name=asset_gcs_source,json=assetGcsSource,proto3" json:"asset_gcs_source,omitempty"`
// contains filtered or unexported fields
}
An asset is a resource in corpus. It represents a media object inside corpus, contains metadata and another resource annotation. Different feature could be applied to the asset to generate annotations. User could specified annotation related to the target asset.
func (*Asset) Descriptor
Deprecated: Use Asset.ProtoReflect.Descriptor instead.
func (*Asset) GetAssetGcsSource
func (x *Asset) GetAssetGcsSource() *AssetSource_AssetGcsSource
func (*Asset) GetName
func (*Asset) GetTtl
func (x *Asset) GetTtl() *durationpb.Duration
func (*Asset) ProtoMessage
func (*Asset) ProtoMessage()
func (*Asset) ProtoReflect
func (x *Asset) ProtoReflect() protoreflect.Message
func (*Asset) Reset
func (x *Asset) Reset()
func (*Asset) String
AssetSource
type AssetSource struct {
// Types that are assignable to SourceForm:
//
// *AssetSource_AssetGcsSource_
// *AssetSource_AssetContentData_
SourceForm isAssetSource_SourceForm `protobuf_oneof:"source_form"`
// contains filtered or unexported fields
}
The source of the asset.
func (*AssetSource) Descriptor
func (*AssetSource) Descriptor() ([]byte, []int)
Deprecated: Use AssetSource.ProtoReflect.Descriptor instead.
func (*AssetSource) GetAssetContentData
func (x *AssetSource) GetAssetContentData() *AssetSource_AssetContentData
func (*AssetSource) GetAssetGcsSource
func (x *AssetSource) GetAssetGcsSource() *AssetSource_AssetGcsSource
func (*AssetSource) GetSourceForm
func (m *AssetSource) GetSourceForm() isAssetSource_SourceForm
func (*AssetSource) ProtoMessage
func (*AssetSource) ProtoMessage()
func (*AssetSource) ProtoReflect
func (x *AssetSource) ProtoReflect() protoreflect.Message
func (*AssetSource) Reset
func (x *AssetSource) Reset()
func (*AssetSource) String
func (x *AssetSource) String() string
AssetSource_AssetContentData
type AssetSource_AssetContentData struct {
AssetContentData []byte `protobuf:"bytes,1,opt,name=asset_content_data,json=assetContentData,proto3" json:"asset_content_data,omitempty"`
// contains filtered or unexported fields
}
The content of the asset.
func (*AssetSource_AssetContentData) Descriptor
func (*AssetSource_AssetContentData) Descriptor() ([]byte, []int)
Deprecated: Use AssetSource_AssetContentData.ProtoReflect.Descriptor instead.
func (*AssetSource_AssetContentData) GetAssetContentData
func (x *AssetSource_AssetContentData) GetAssetContentData() []byte
func (*AssetSource_AssetContentData) ProtoMessage
func (*AssetSource_AssetContentData) ProtoMessage()
func (*AssetSource_AssetContentData) ProtoReflect
func (x *AssetSource_AssetContentData) ProtoReflect() protoreflect.Message
func (*AssetSource_AssetContentData) Reset
func (x *AssetSource_AssetContentData) Reset()
func (*AssetSource_AssetContentData) String
func (x *AssetSource_AssetContentData) String() string
AssetSource_AssetContentData_
type AssetSource_AssetContentData_ struct {
// The source of the asset is from content bytes.
AssetContentData *AssetSource_AssetContentData `protobuf:"bytes,2,opt,name=asset_content_data,json=assetContentData,proto3,oneof"`
}
AssetSource_AssetGcsSource
type AssetSource_AssetGcsSource struct