Package cloud.google.com/go/visionai/apiv1/visionaipb (v0.4.3)

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 (*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) Enum

func (x AcceleratorType) Enum() *AcceleratorType

func (AcceleratorType) EnumDescriptor

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

Deprecated: Use AcceleratorType.Descriptor instead.

func (AcceleratorType) Number

func (AcceleratorType) String

func (x AcceleratorType) String() string

func (AcceleratorType) Type

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 (*AddApplicationStreamInputRequest) GetRequestId

func (x *AddApplicationStreamInputRequest) GetRequestId() string

func (*AddApplicationStreamInputRequest) ProtoMessage

func (*AddApplicationStreamInputRequest) ProtoMessage()

func (*AddApplicationStreamInputRequest) ProtoReflect

func (*AddApplicationStreamInputRequest) Reset

func (*AddApplicationStreamInputRequest) 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 (*AddApplicationStreamInputResponse) Reset

func (*AddApplicationStreamInputResponse) 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 (*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 (*AddCollectionItemResponse) ProtoMessage

func (*AddCollectionItemResponse) ProtoMessage()

func (*AddCollectionItemResponse) ProtoReflect

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

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

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 (x *Analysis) GetDisableEventWatch() bool

func (*Analysis) GetInputStreamsMapping

func (x *Analysis) GetInputStreamsMapping() map[string]string

func (*Analysis) GetLabels

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

func (*Analysis) GetName

func (x *Analysis) GetName() string

func (*Analysis) GetOutputStreamsMapping

func (x *Analysis) GetOutputStreamsMapping() map[string]string

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

func (x *Analysis) String() 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 (*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 (*AnalyzeAssetMetadata_AnalysisStatus) GetStatusMessage

func (x *AnalyzeAssetMetadata_AnalysisStatus) GetStatusMessage() string

func (*AnalyzeAssetMetadata_AnalysisStatus) ProtoMessage

func (*AnalyzeAssetMetadata_AnalysisStatus) ProtoMessage()

func (*AnalyzeAssetMetadata_AnalysisStatus) ProtoReflect

func (*AnalyzeAssetMetadata_AnalysisStatus) Reset

func (*AnalyzeAssetMetadata_AnalysisStatus) 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) Enum

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 (AnalyzeAssetMetadata_AnalysisStatus_State) String

func (AnalyzeAssetMetadata_AnalysisStatus_State) Type

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 (*AnalyzerDefinition) GetInputs

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 (*AnalyzerDefinition_DebugOptions) Reset

func (*AnalyzerDefinition_DebugOptions) 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 (*AnalyzerDefinition_OperatorOption) ProtoMessage

func (*AnalyzerDefinition_OperatorOption) ProtoMessage()

func (*AnalyzerDefinition_OperatorOption) ProtoReflect

func (*AnalyzerDefinition_OperatorOption) Reset

func (*AnalyzerDefinition_OperatorOption) 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 (*AnalyzerDefinition_StreamInput) Reset

func (x *AnalyzerDefinition_StreamInput) Reset()

func (*AnalyzerDefinition_StreamInput) 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 (*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 (*AppPlatformCloudFunctionRequest) GetAppPlatformMetadata

func (x *AppPlatformCloudFunctionRequest) GetAppPlatformMetadata() *AppPlatformMetadata

func (*AppPlatformCloudFunctionRequest) ProtoMessage

func (*AppPlatformCloudFunctionRequest) ProtoMessage()

func (*AppPlatformCloudFunctionRequest) ProtoReflect

func (*AppPlatformCloudFunctionRequest) Reset

func (*AppPlatformCloudFunctionRequest) 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

Deprecated: Use AppPlatformCloudFunctionRequest_StructedInputAnnotation.ProtoReflect.Descriptor instead.

func (*AppPlatformCloudFunctionRequest_StructedInputAnnotation) GetAnnotation

func (*AppPlatformCloudFunctionRequest_StructedInputAnnotation) GetIngestionTimeMicros

func (*AppPlatformCloudFunctionRequest_StructedInputAnnotation) ProtoMessage

func (*AppPlatformCloudFunctionRequest_StructedInputAnnotation) ProtoReflect

func (*AppPlatformCloudFunctionRequest_StructedInputAnnotation) Reset

func (*AppPlatformCloudFunctionRequest_StructedInputAnnotation) 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 (*AppPlatformCloudFunctionResponse) GetEvents

func (*AppPlatformCloudFunctionResponse) ProtoMessage

func (*AppPlatformCloudFunctionResponse) ProtoMessage()

func (*AppPlatformCloudFunctionResponse) ProtoReflect

func (*AppPlatformCloudFunctionResponse) Reset

func (*AppPlatformCloudFunctionResponse) 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

Deprecated: Use AppPlatformCloudFunctionResponse_StructedOutputAnnotation.ProtoReflect.Descriptor instead.

func (*AppPlatformCloudFunctionResponse_StructedOutputAnnotation) GetAnnotation

func (*AppPlatformCloudFunctionResponse_StructedOutputAnnotation) ProtoMessage

func (*AppPlatformCloudFunctionResponse_StructedOutputAnnotation) ProtoReflect

func (*AppPlatformCloudFunctionResponse_StructedOutputAnnotation) Reset

func (*AppPlatformCloudFunctionResponse_StructedOutputAnnotation) 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 (*ApplicationConfigs_EventDeliveryConfig) GetMinimalDeliveryInterval

func (x *ApplicationConfigs_EventDeliveryConfig) GetMinimalDeliveryInterval() *durationpb.Duration

func (*ApplicationConfigs_EventDeliveryConfig) ProtoMessage

func (*ApplicationConfigs_EventDeliveryConfig) ProtoReflect

func (*ApplicationConfigs_EventDeliveryConfig) Reset

func (*ApplicationConfigs_EventDeliveryConfig) 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 (*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 (*Application_ApplicationRuntimeInfo) GetGlobalOutputResources

func (*Application_ApplicationRuntimeInfo) GetMonitoringConfig

func (*Application_ApplicationRuntimeInfo) ProtoMessage

func (*Application_ApplicationRuntimeInfo) ProtoMessage()

func (*Application_ApplicationRuntimeInfo) ProtoReflect

func (*Application_ApplicationRuntimeInfo) Reset

func (*Application_ApplicationRuntimeInfo) 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

Deprecated: Use Application_ApplicationRuntimeInfo_GlobalOutputResource.ProtoReflect.Descriptor instead.

func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) GetKey

func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) GetOutputResource

func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) GetProducerNode

func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) ProtoMessage

func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) ProtoReflect

func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) Reset

func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) 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

Deprecated: Use Application_ApplicationRuntimeInfo_MonitoringConfig.ProtoReflect.Descriptor instead.

func (*Application_ApplicationRuntimeInfo_MonitoringConfig) GetEnabled

func (*Application_ApplicationRuntimeInfo_MonitoringConfig) ProtoMessage

func (*Application_ApplicationRuntimeInfo_MonitoringConfig) ProtoReflect

func (*Application_ApplicationRuntimeInfo_MonitoringConfig) Reset

func (*Application_ApplicationRuntimeInfo_MonitoringConfig) 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) Enum

func (Application_BillingMode) EnumDescriptor

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

Deprecated: Use Application_BillingMode.Descriptor instead.

func (Application_BillingMode) Number

func (Application_BillingMode) String

func (x Application_BillingMode) String() string

func (Application_BillingMode) Type

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) Enum

func (Application_State) EnumDescriptor

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

Deprecated: Use Application_State.Descriptor instead.

func (Application_State) Number

func (Application_State) String

func (x Application_State) String() string

func (Application_State) Type

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

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

Deprecated: Use Asset.ProtoReflect.Descriptor instead.

func (*Asset) GetAssetGcsSource

func (x *Asset) GetAssetGcsSource() *AssetSource_AssetGcsSource

func (*Asset) GetName

func (x *Asset) GetName() string

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

func (x *Asset) String() 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 (*AssetSource_AssetContentData) Reset

func (x *AssetSource_AssetContentData) Reset()

func (*AssetSource_AssetContentData) 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