visionaiv1

package
v1.36.5-20240502114401... Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: unknown License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const AttributeValue_B_case case_AttributeValue_Value = 3
View Source 
const AttributeValue_F_case case_AttributeValue_Value = 2
View Source 
const AttributeValue_I_case case_AttributeValue_Value = 1
View Source 
const AttributeValue_S_case case_AttributeValue_Value = 4
View Source 
const AttributeValue_Value_not_set_case case_AttributeValue_Value = 0
View Source 
const CustomProcessorSourceInfo_ArtifactPath_not_set_case case_CustomProcessorSourceInfo_ArtifactPath = 0
View Source 
const CustomProcessorSourceInfo_VertexModel_case case_CustomProcessorSourceInfo_ArtifactPath = 2
View Source 
const Node_OutputAllOutputChannelsToStream_case case_Node_StreamOutputConfig = 6
View Source 
const Node_StreamOutputConfig_not_set_case case_Node_StreamOutputConfig = 0
View Source 
const ProcessorConfig_AiEnabledDevicesInputConfig_case case_ProcessorConfig_ProcessorConfig = 20
View Source 
const ProcessorConfig_BigQueryConfig_case case_ProcessorConfig_ProcessorConfig = 19
View Source 
const ProcessorConfig_GeneralObjectDetectionConfig_case case_ProcessorConfig_ProcessorConfig = 18
View Source 
const ProcessorConfig_MediaWarehouseConfig_case case_ProcessorConfig_ProcessorConfig = 10
View Source 
const ProcessorConfig_OccupancyCountConfig_case case_ProcessorConfig_ProcessorConfig = 12
View Source 
const ProcessorConfig_PersonBlurConfig_case case_ProcessorConfig_ProcessorConfig = 11
View Source 
const ProcessorConfig_PersonVehicleDetectionConfig_case case_ProcessorConfig_ProcessorConfig = 15
View Source 
const ProcessorConfig_PersonalProtectiveEquipmentDetectionConfig_case case_ProcessorConfig_ProcessorConfig = 22
View Source 
const ProcessorConfig_ProcessorConfig_not_set_case case_ProcessorConfig_ProcessorConfig = 0
View Source 
const ProcessorConfig_VertexAutomlVideoConfig_case case_ProcessorConfig_ProcessorConfig = 14
View Source 
const ProcessorConfig_VertexAutomlVisionConfig_case case_ProcessorConfig_ProcessorConfig = 13
View Source 
const ProcessorConfig_VertexCustomConfig_case case_ProcessorConfig_ProcessorConfig = 17
View Source 
const ProcessorConfig_VideoStreamInputConfig_case case_ProcessorConfig_ProcessorConfig = 9
View Source 
const ProcessorIOSpec_InstanceResourceInputBindingSpec_ConfigTypeUri_case case_ProcessorIOSpec_InstanceResourceInputBindingSpec_ResourceType = 2
View Source 
const ProcessorIOSpec_InstanceResourceInputBindingSpec_ResourceTypeUri_case case_ProcessorIOSpec_InstanceResourceInputBindingSpec_ResourceType = 3
View Source 
const ProcessorIOSpec_InstanceResourceInputBindingSpec_ResourceType_not_set_case case_ProcessorIOSpec_InstanceResourceInputBindingSpec_ResourceType = 0
View Source 
const StreamAnnotation_ActiveZone_case case_StreamAnnotation_AnnotationPayload = 5
View Source 
const StreamAnnotation_AnnotationPayload_not_set_case case_StreamAnnotation_AnnotationPayload = 0
View Source 
const StreamAnnotation_CrossingLine_case case_StreamAnnotation_AnnotationPayload = 6

Variables

View Source 
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.

View Source 
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.

View Source 
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",
	}
	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,
	}
)

Enum value maps for ModelType.

View Source 
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.

View Source 
var (
	DataType_name = map[int32]string{
		0: "DATA_TYPE_UNSPECIFIED",
		1: "VIDEO",
		3: "IMAGE",
		2: "PROTO",
	}
	DataType_value = map[string]int32{
		"DATA_TYPE_UNSPECIFIED": 0,
		"VIDEO":                 1,
		"IMAGE":                 3,
		"PROTO":                 2,
	}
)

Enum value maps for DataType.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
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.

View Source 
var File_google_events_cloud_visionai_v1_data_proto protoreflect.FileDescriptor
View Source 
var File_google_events_cloud_visionai_v1_events_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type AIEnabledDevicesInputConfig 

type AIEnabledDevicesInputConfig struct {
	// contains filtered or unexported fields
}

Message describing AI-enabled Devices Input Config.

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

type AIEnabledDevicesInputConfig_builder 

type AIEnabledDevicesInputConfig_builder struct {
	// contains filtered or unexported fields
}

func (AIEnabledDevicesInputConfig_builder) Build 

func (b0 AIEnabledDevicesInputConfig_builder) Build() *AIEnabledDevicesInputConfig

type AcceleratorType 

type AcceleratorType int32

Represents a hardware accelerator type. 

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

func (x AcceleratorType) Number() protoreflect.EnumNumber

func (AcceleratorType) String 

func (x AcceleratorType) String() string

func (AcceleratorType) Type 

func (AcceleratorType) Type() protoreflect.EnumType

type Analysis 

type Analysis struct {

	// The name of resource.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. The create timestamp.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The update timestamp.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Labels as key value pairs.
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// The definition of the analysis.
	AnalysisDefinition *AnalysisDefinition `protobuf:"bytes,5,opt,name=analysis_definition,json=analysisDefinition,proto3" json:"analysis_definition,omitempty"`
	// Map from the input parameter in the definition to the real stream.
	// E.g., suppose you had a stream source operator named "input-0" and you try
	// to receive from the real stream "stream-0". You can add the following
	// mapping: [input-0: stream-0].
	InputStreamsMapping map[string]string `` /* 194-byte string literal not displayed */
	// Map from the output parameter in the definition to the real stream.
	// E.g., suppose you had a stream sink operator named "output-0" and you try
	// to send to the real stream "stream-0". You can add the following
	// mapping: [output-0: stream-0].
	OutputStreamsMapping map[string]string `` /* 197-byte string literal not displayed */
	// Boolean flag to indicate whether you would like to disable the ability
	// to automatically start a Process when new event happening in the input
	// Stream. If you would like to start a Process manually, the field needs
	// to be set to true.
	DisableEventWatch bool `protobuf:"varint,8,opt,name=disable_event_watch,json=disableEventWatch,proto3" json:"disable_event_watch,omitempty"`
	// contains filtered or unexported fields
}

Message describing the Analysis object.

func (*Analysis) ClearAnalysisDefinition 

func (x *Analysis) ClearAnalysisDefinition()

func (*Analysis) ClearCreateTime 

func (x *Analysis) ClearCreateTime()

func (*Analysis) ClearUpdateTime 

func (x *Analysis) ClearUpdateTime()

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

func (x *Analysis) HasAnalysisDefinition() bool

func (*Analysis) HasCreateTime 

func (x *Analysis) HasCreateTime() bool

func (*Analysis) HasUpdateTime 

func (x *Analysis) HasUpdateTime() bool

func (*Analysis) ProtoMessage 

func (*Analysis) ProtoMessage()

func (*Analysis) ProtoReflect 

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

func (*Analysis) Reset 

func (x *Analysis) Reset()

func (*Analysis) SetAnalysisDefinition 

func (x *Analysis) SetAnalysisDefinition(v *AnalysisDefinition)

func (*Analysis) SetCreateTime 

func (x *Analysis) SetCreateTime(v *timestamppb.Timestamp)

func (*Analysis) SetDisableEventWatch 

func (x *Analysis) SetDisableEventWatch(v bool)

func (*Analysis) SetInputStreamsMapping 

func (x *Analysis) SetInputStreamsMapping(v map[string]string)

func (*Analysis) SetLabels 

func (x *Analysis) SetLabels(v map[string]string)

func (*Analysis) SetName 

func (x *Analysis) SetName(v string)

func (*Analysis) SetOutputStreamsMapping 

func (x *Analysis) SetOutputStreamsMapping(v map[string]string)

func (*Analysis) SetUpdateTime 

func (x *Analysis) SetUpdateTime(v *timestamppb.Timestamp)

func (*Analysis) String 

func (x *Analysis) String() string

type AnalysisCreatedEvent 

type AnalysisCreatedEvent struct {

	// The data associated with the event.
	Data *AnalysisEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when an Analysis is created.

func (*AnalysisCreatedEvent) ClearData 

func (x *AnalysisCreatedEvent) ClearData()

func (*AnalysisCreatedEvent) GetData 

func (x *AnalysisCreatedEvent) GetData() *AnalysisEventData

func (*AnalysisCreatedEvent) HasData 

func (x *AnalysisCreatedEvent) HasData() bool

func (*AnalysisCreatedEvent) ProtoMessage 

func (*AnalysisCreatedEvent) ProtoMessage()

func (*AnalysisCreatedEvent) ProtoReflect 

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

func (*AnalysisCreatedEvent) Reset 

func (x *AnalysisCreatedEvent) Reset()

func (*AnalysisCreatedEvent) SetData 

func (x *AnalysisCreatedEvent) SetData(v *AnalysisEventData)

func (*AnalysisCreatedEvent) String 

func (x *AnalysisCreatedEvent) String() string

type AnalysisCreatedEvent_builder 

type AnalysisCreatedEvent_builder struct {

	// The data associated with the event.
	Data *AnalysisEventData
	// contains filtered or unexported fields
}

func (AnalysisCreatedEvent_builder) Build 

func (b0 AnalysisCreatedEvent_builder) Build() *AnalysisCreatedEvent

type 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) 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) SetAnalyzers 

func (x *AnalysisDefinition) SetAnalyzers(v []*AnalyzerDefinition)

func (*AnalysisDefinition) String 

func (x *AnalysisDefinition) String() string

type AnalysisDefinition_builder 

type AnalysisDefinition_builder struct {

	// Analyzer definitions.
	Analyzers []*AnalyzerDefinition
	// contains filtered or unexported fields
}

func (AnalysisDefinition_builder) Build 

func (b0 AnalysisDefinition_builder) Build() *AnalysisDefinition

type AnalysisDeletedEvent 

type AnalysisDeletedEvent struct {

	// The data associated with the event.
	Data *AnalysisEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when an Analysis is deleted.

func (*AnalysisDeletedEvent) ClearData 

func (x *AnalysisDeletedEvent) ClearData()

func (*AnalysisDeletedEvent) GetData 

func (x *AnalysisDeletedEvent) GetData() *AnalysisEventData

func (*AnalysisDeletedEvent) HasData 

func (x *AnalysisDeletedEvent) HasData() bool

func (*AnalysisDeletedEvent) ProtoMessage 

func (*AnalysisDeletedEvent) ProtoMessage()

func (*AnalysisDeletedEvent) ProtoReflect 

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

func (*AnalysisDeletedEvent) Reset 

func (x *AnalysisDeletedEvent) Reset()

func (*AnalysisDeletedEvent) SetData 

func (x *AnalysisDeletedEvent) SetData(v *AnalysisEventData)

func (*AnalysisDeletedEvent) String 

func (x *AnalysisDeletedEvent) String() string

type AnalysisDeletedEvent_builder 

type AnalysisDeletedEvent_builder struct {

	// The data associated with the event.
	Data *AnalysisEventData
	// contains filtered or unexported fields
}

func (AnalysisDeletedEvent_builder) Build 

func (b0 AnalysisDeletedEvent_builder) Build() *AnalysisDeletedEvent

type AnalysisEventData 

type AnalysisEventData struct {

	// Optional. The Analysis event payload. Unset for deletion events.
	Payload *Analysis `protobuf:"bytes,1,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The data within all Analysis events.

func (*AnalysisEventData) ClearPayload 

func (x *AnalysisEventData) ClearPayload()

func (*AnalysisEventData) GetPayload 

func (x *AnalysisEventData) GetPayload() *Analysis

func (*AnalysisEventData) HasPayload 

func (x *AnalysisEventData) HasPayload() bool

func (*AnalysisEventData) ProtoMessage 

func (*AnalysisEventData) ProtoMessage()

func (*AnalysisEventData) ProtoReflect 

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

func (*AnalysisEventData) Reset 

func (x *AnalysisEventData) Reset()

func (*AnalysisEventData) SetPayload 

func (x *AnalysisEventData) SetPayload(v *Analysis)

func (*AnalysisEventData) String 

func (x *AnalysisEventData) String() string

type AnalysisEventData_builder 

type AnalysisEventData_builder struct {

	// Optional. The Analysis event payload. Unset for deletion events.
	Payload *Analysis
	// contains filtered or unexported fields
}

func (AnalysisEventData_builder) Build 

func (b0 AnalysisEventData_builder) Build() *AnalysisEventData

type AnalysisUpdatedEvent 

type AnalysisUpdatedEvent struct {

	// The data associated with the event.
	Data *AnalysisEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when an Analysis is updated.

func (*AnalysisUpdatedEvent) ClearData 

func (x *AnalysisUpdatedEvent) ClearData()

func (*AnalysisUpdatedEvent) GetData 

func (x *AnalysisUpdatedEvent) GetData() *AnalysisEventData

func (*AnalysisUpdatedEvent) HasData 

func (x *AnalysisUpdatedEvent) HasData() bool

func (*AnalysisUpdatedEvent) ProtoMessage 

func (*AnalysisUpdatedEvent) ProtoMessage()

func (*AnalysisUpdatedEvent) ProtoReflect 

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

func (*AnalysisUpdatedEvent) Reset 

func (x *AnalysisUpdatedEvent) Reset()

func (*AnalysisUpdatedEvent) SetData 

func (x *AnalysisUpdatedEvent) SetData(v *AnalysisEventData)

func (*AnalysisUpdatedEvent) String 

func (x *AnalysisUpdatedEvent) String() string

type AnalysisUpdatedEvent_builder 

type AnalysisUpdatedEvent_builder struct {

	// The data associated with the event.
	Data *AnalysisEventData
	// contains filtered or unexported fields
}

func (AnalysisUpdatedEvent_builder) Build 

func (b0 AnalysisUpdatedEvent_builder) Build() *AnalysisUpdatedEvent

type Analysis_builder 

type Analysis_builder struct {

	// The name of resource.
	Name string
	// Output only. The create timestamp.
	CreateTime *timestamppb.Timestamp
	// Output only. The update timestamp.
	UpdateTime *timestamppb.Timestamp
	// Labels as key value pairs.
	Labels map[string]string
	// The definition of the analysis.
	AnalysisDefinition *AnalysisDefinition
	// Map from the input parameter in the definition to the real stream.
	// E.g., suppose you had a stream source operator named "input-0" and you try
	// to receive from the real stream "stream-0". You can add the following
	// mapping: [input-0: stream-0].
	InputStreamsMapping map[string]string
	// Map from the output parameter in the definition to the real stream.
	// E.g., suppose you had a stream sink operator named "output-0" and you try
	// to send to the real stream "stream-0". You can add the following
	// mapping: [output-0: stream-0].
	OutputStreamsMapping map[string]string
	// Boolean flag to indicate whether you would like to disable the ability
	// to automatically start a Process when new event happening in the input
	// Stream. If you would like to start a Process manually, the field needs
	// to be set to true.
	DisableEventWatch bool
	// contains filtered or unexported fields
}

func (Analysis_builder) Build 

func (b0 Analysis_builder) Build() *Analysis

type AnalyzerDefinition 

type AnalyzerDefinition struct {

	// The name of this analyzer.
	//
	// Tentatively [a-z][a-z0-9]*(_[a-z0-9]+)*.
	Analyzer string `protobuf:"bytes,1,opt,name=analyzer,proto3" json:"analyzer,omitempty"`
	// The name of the operator that this analyzer runs.
	//
	// Must match the name of a supported operator.
	Operator string `protobuf:"bytes,2,opt,name=operator,proto3" json:"operator,omitempty"`
	// Input streams.
	Inputs []*AnalyzerDefinition_StreamInput `protobuf:"bytes,3,rep,name=inputs,proto3" json:"inputs,omitempty"`
	// The attribute values that this analyzer applies to the operator.
	//
	// Supply a mapping between the attribute names and the actual value you wish
	// to apply. If an attribute name is omitted, then it will take a
	// preconfigured default value.
	Attrs map[string]*AttributeValue `` /* 137-byte string literal not displayed */
	// Debug options.
	DebugOptions *AnalyzerDefinition_DebugOptions `protobuf:"bytes,5,opt,name=debug_options,json=debugOptions,proto3" json:"debug_options,omitempty"`
	// contains filtered or unexported fields
}

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

func (x *AnalyzerDefinition) ClearDebugOptions()

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

func (x *AnalyzerDefinition) HasDebugOptions() bool

func (*AnalyzerDefinition) ProtoMessage 

func (*AnalyzerDefinition) ProtoMessage()

func (*AnalyzerDefinition) ProtoReflect 

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

func (*AnalyzerDefinition) Reset 

func (x *AnalyzerDefinition) Reset()

func (*AnalyzerDefinition) SetAnalyzer 

func (x *AnalyzerDefinition) SetAnalyzer(v string)

func (*AnalyzerDefinition) SetAttrs 

func (x *AnalyzerDefinition) SetAttrs(v map[string]*AttributeValue)

func (*AnalyzerDefinition) SetDebugOptions 

func (x *AnalyzerDefinition) SetDebugOptions(v *AnalyzerDefinition_DebugOptions)

func (*AnalyzerDefinition) SetInputs 

func (x *AnalyzerDefinition) SetInputs(v []*AnalyzerDefinition_StreamInput)

func (*AnalyzerDefinition) SetOperator 

func (x *AnalyzerDefinition) SetOperator(v string)

func (*AnalyzerDefinition) String 

func (x *AnalyzerDefinition) String() string

type AnalyzerDefinition_DebugOptions 

type AnalyzerDefinition_DebugOptions struct {

	// Environment variables.
	EnvironmentVariables map[string]string `` /* 195-byte string literal not displayed */
	// contains filtered or unexported fields
}

Options available for debugging purposes only.

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

func (x *AnalyzerDefinition_DebugOptions) SetEnvironmentVariables(v map[string]string)

func (*AnalyzerDefinition_DebugOptions) String 

func (x *AnalyzerDefinition_DebugOptions) String() string

type AnalyzerDefinition_DebugOptions_builder 

type AnalyzerDefinition_DebugOptions_builder struct {

	// Environment variables.
	EnvironmentVariables map[string]string
	// contains filtered or unexported fields
}

func (AnalyzerDefinition_DebugOptions_builder) Build 

func (b0 AnalyzerDefinition_DebugOptions_builder) Build() *AnalyzerDefinition_DebugOptions

type 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: <analyzer-name>:<output-argument-name>

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

func (x *AnalyzerDefinition_StreamInput) SetInput(v string)

func (*AnalyzerDefinition_StreamInput) String 

func (x *AnalyzerDefinition_StreamInput) String() string

type AnalyzerDefinition_StreamInput_builder 

type AnalyzerDefinition_StreamInput_builder struct {

	// The name of the stream input (as discussed above).
	Input string
	// contains filtered or unexported fields
}

func (AnalyzerDefinition_StreamInput_builder) Build 

func (b0 AnalyzerDefinition_StreamInput_builder) Build() *AnalyzerDefinition_StreamInput

type AnalyzerDefinition_builder 

type AnalyzerDefinition_builder struct {

	// The name of this analyzer.
	//
	// Tentatively [a-z][a-z0-9]*(_[a-z0-9]+)*.
	Analyzer string
	// The name of the operator that this analyzer runs.
	//
	// Must match the name of a supported operator.
	Operator string
	// Input streams.
	Inputs []*AnalyzerDefinition_StreamInput
	// The attribute values that this analyzer applies to the operator.
	//
	// Supply a mapping between the attribute names and the actual value you wish
	// to apply. If an attribute name is omitted, then it will take a
	// preconfigured default value.
	Attrs map[string]*AttributeValue
	// Debug options.
	DebugOptions *AnalyzerDefinition_DebugOptions
	// contains filtered or unexported fields
}

func (AnalyzerDefinition_builder) Build 

func (b0 AnalyzerDefinition_builder) Build() *AnalyzerDefinition

type Application 

type Application struct {

	// name of resource
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. [Output only] Create timestamp
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. [Output only] Update timestamp
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Labels as key value pairs
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// Required. A user friendly display name for the solution.
	DisplayName string `protobuf:"bytes,5,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// A description for this application.
	Description string `protobuf:"bytes,6,opt,name=description,proto3" json:"description,omitempty"`
	// Application graph configuration.
	ApplicationConfigs *ApplicationConfigs `protobuf:"bytes,7,opt,name=application_configs,json=applicationConfigs,proto3" json:"application_configs,omitempty"`
	// Output only. Application graph runtime info. Only exists when application
	// state equals to DEPLOYED.
	RuntimeInfo *Application_ApplicationRuntimeInfo `protobuf:"bytes,8,opt,name=runtime_info,json=runtimeInfo,proto3" json:"runtime_info,omitempty"`
	// Output only. State of the application.
	State Application_State `protobuf:"varint,9,opt,name=state,proto3,enum=google.events.cloud.visionai.v1.Application_State" json:"state,omitempty"`
	// Billing mode of the application.
	BillingMode Application_BillingMode `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

Message describing Application object

func (*Application) ClearApplicationConfigs 

func (x *Application) ClearApplicationConfigs()

func (*Application) ClearCreateTime 

func (x *Application) ClearCreateTime()

func (*Application) ClearRuntimeInfo 

func (x *Application) ClearRuntimeInfo()

func (*Application) ClearUpdateTime 

func (x *Application) ClearUpdateTime()

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

func (x *Application) HasApplicationConfigs() bool

func (*Application) HasCreateTime 

func (x *Application) HasCreateTime() bool

func (*Application) HasRuntimeInfo 

func (x *Application) HasRuntimeInfo() bool

func (*Application) HasUpdateTime 

func (x *Application) HasUpdateTime() bool

func (*Application) ProtoMessage 

func (*Application) ProtoMessage()

func (*Application) ProtoReflect 

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

func (*Application) Reset 

func (x *Application) Reset()

func (*Application) SetApplicationConfigs 

func (x *Application) SetApplicationConfigs(v *ApplicationConfigs)

func (*Application) SetBillingMode 

func (x *Application) SetBillingMode(v Application_BillingMode)

func (*Application) SetCreateTime 

func (x *Application) SetCreateTime(v *timestamppb.Timestamp)

func (*Application) SetDescription 

func (x *Application) SetDescription(v string)

func (*Application) SetDisplayName 

func (x *Application) SetDisplayName(v string)

func (*Application) SetLabels 

func (x *Application) SetLabels(v map[string]string)

func (*Application) SetName 

func (x *Application) SetName(v string)

func (*Application) SetRuntimeInfo 

func (x *Application) SetRuntimeInfo(v *Application_ApplicationRuntimeInfo)

func (*Application) SetState 

func (x *Application) SetState(v Application_State)

func (*Application) SetUpdateTime 

func (x *Application) SetUpdateTime(v *timestamppb.Timestamp)

func (*Application) String 

func (x *Application) String() string

type ApplicationConfigs 

type ApplicationConfigs struct {

	// A list of nodes  in the application graph.
	Nodes []*Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

Message storing the graph of the application.

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

func (x *ApplicationConfigs) SetNodes(v []*Node)

func (*ApplicationConfigs) String 

func (x *ApplicationConfigs) String() string

type ApplicationConfigs_builder 

type ApplicationConfigs_builder struct {

	// A list of nodes  in the application graph.
	Nodes []*Node
	// contains filtered or unexported fields
}

func (ApplicationConfigs_builder) Build 

func (b0 ApplicationConfigs_builder) Build() *ApplicationConfigs

type ApplicationCreatedEvent 

type ApplicationCreatedEvent struct {

	// The data associated with the event.
	Data *ApplicationEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when an Application is created.

func (*ApplicationCreatedEvent) ClearData 

func (x *ApplicationCreatedEvent) ClearData()

func (*ApplicationCreatedEvent) GetData 

func (x *ApplicationCreatedEvent) GetData() *ApplicationEventData

func (*ApplicationCreatedEvent) HasData 

func (x *ApplicationCreatedEvent) HasData() bool

func (*ApplicationCreatedEvent) ProtoMessage 

func (*ApplicationCreatedEvent) ProtoMessage()

func (*ApplicationCreatedEvent) ProtoReflect 

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

func (*ApplicationCreatedEvent) Reset 

func (x *ApplicationCreatedEvent) Reset()

func (*ApplicationCreatedEvent) SetData 

func (x *ApplicationCreatedEvent) SetData(v *ApplicationEventData)

func (*ApplicationCreatedEvent) String 

func (x *ApplicationCreatedEvent) String() string

type ApplicationCreatedEvent_builder 

type ApplicationCreatedEvent_builder struct {

	// The data associated with the event.
	Data *ApplicationEventData
	// contains filtered or unexported fields
}

func (ApplicationCreatedEvent_builder) Build 

func (b0 ApplicationCreatedEvent_builder) Build() *ApplicationCreatedEvent

type ApplicationDeletedEvent 

type ApplicationDeletedEvent struct {

	// The data associated with the event.
	Data *ApplicationEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when an Application is deleted.

func (*ApplicationDeletedEvent) ClearData 

func (x *ApplicationDeletedEvent) ClearData()

func (*ApplicationDeletedEvent) GetData 

func (x *ApplicationDeletedEvent) GetData() *ApplicationEventData

func (*ApplicationDeletedEvent) HasData 

func (x *ApplicationDeletedEvent) HasData() bool

func (*ApplicationDeletedEvent) ProtoMessage 

func (*ApplicationDeletedEvent) ProtoMessage()

func (*ApplicationDeletedEvent) ProtoReflect 

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

func (*ApplicationDeletedEvent) Reset 

func (x *ApplicationDeletedEvent) Reset()

func (*ApplicationDeletedEvent) SetData 

func (x *ApplicationDeletedEvent) SetData(v *ApplicationEventData)

func (*ApplicationDeletedEvent) String 

func (x *ApplicationDeletedEvent) String() string

type ApplicationDeletedEvent_builder 

type ApplicationDeletedEvent_builder struct {

	// The data associated with the event.
	Data *ApplicationEventData
	// contains filtered or unexported fields
}

func (ApplicationDeletedEvent_builder) Build 

func (b0 ApplicationDeletedEvent_builder) Build() *ApplicationDeletedEvent

type ApplicationEventData 

type ApplicationEventData struct {

	// Optional. The Application event payload. Unset for deletion events.
	Payload *Application `protobuf:"bytes,1,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The data within all Application events.

func (*ApplicationEventData) ClearPayload 

func (x *ApplicationEventData) ClearPayload()

func (*ApplicationEventData) GetPayload 

func (x *ApplicationEventData) GetPayload() *Application

func (*ApplicationEventData) HasPayload 

func (x *ApplicationEventData) HasPayload() bool

func (*ApplicationEventData) ProtoMessage 

func (*ApplicationEventData) ProtoMessage()

func (*ApplicationEventData) ProtoReflect 

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

func (*ApplicationEventData) Reset 

func (x *ApplicationEventData) Reset()

func (*ApplicationEventData) SetPayload 

func (x *ApplicationEventData) SetPayload(v *Application)

func (*ApplicationEventData) String 

func (x *ApplicationEventData) String() string

type ApplicationEventData_builder 

type ApplicationEventData_builder struct {

	// Optional. The Application event payload. Unset for deletion events.
	Payload *Application
	// contains filtered or unexported fields
}

func (ApplicationEventData_builder) Build 

func (b0 ApplicationEventData_builder) Build() *ApplicationEventData

type ApplicationUpdatedEvent 

type ApplicationUpdatedEvent struct {

	// The data associated with the event.
	Data *ApplicationEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when an Application is updated.

func (*ApplicationUpdatedEvent) ClearData 

func (x *ApplicationUpdatedEvent) ClearData()

func (*ApplicationUpdatedEvent) GetData 

func (x *ApplicationUpdatedEvent) GetData() *ApplicationEventData

func (*ApplicationUpdatedEvent) HasData 

func (x *ApplicationUpdatedEvent) HasData() bool

func (*ApplicationUpdatedEvent) ProtoMessage 

func (*ApplicationUpdatedEvent) ProtoMessage()

func (*ApplicationUpdatedEvent) ProtoReflect 

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

func (*ApplicationUpdatedEvent) Reset 

func (x *ApplicationUpdatedEvent) Reset()

func (*ApplicationUpdatedEvent) SetData 

func (x *ApplicationUpdatedEvent) SetData(v *ApplicationEventData)

func (*ApplicationUpdatedEvent) String 

func (x *ApplicationUpdatedEvent) String() string

type ApplicationUpdatedEvent_builder 

type ApplicationUpdatedEvent_builder struct {

	// The data associated with the event.
	Data *ApplicationEventData
	// contains filtered or unexported fields
}

func (ApplicationUpdatedEvent_builder) Build 

func (b0 ApplicationUpdatedEvent_builder) Build() *ApplicationUpdatedEvent

type 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 `` /* 126-byte string literal not displayed */
	// 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) ClearDeployTime 

func (x *Application_ApplicationRuntimeInfo) ClearDeployTime()

func (*Application_ApplicationRuntimeInfo) ClearMonitoringConfig 

func (x *Application_ApplicationRuntimeInfo) ClearMonitoringConfig()

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

func (x *Application_ApplicationRuntimeInfo) HasDeployTime() bool

func (*Application_ApplicationRuntimeInfo) HasMonitoringConfig 

func (x *Application_ApplicationRuntimeInfo) HasMonitoringConfig() bool

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

func (x *Application_ApplicationRuntimeInfo) SetDeployTime(v *timestamppb.Timestamp)

func (*Application_ApplicationRuntimeInfo) SetGlobalOutputResources 

func (x *Application_ApplicationRuntimeInfo) SetGlobalOutputResources(v []*Application_ApplicationRuntimeInfo_GlobalOutputResource)

func (*Application_ApplicationRuntimeInfo) SetMonitoringConfig 

func (x *Application_ApplicationRuntimeInfo) SetMonitoringConfig(v *Application_ApplicationRuntimeInfo_MonitoringConfig)

func (*Application_ApplicationRuntimeInfo) String 

func (x *Application_ApplicationRuntimeInfo) String() string

type 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) 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) SetKey 

func (x *Application_ApplicationRuntimeInfo_GlobalOutputResource) SetKey(v string)

func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) SetOutputResource 

func (x *Application_ApplicationRuntimeInfo_GlobalOutputResource) SetOutputResource(v string)

func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) SetProducerNode 

func (x *Application_ApplicationRuntimeInfo_GlobalOutputResource) SetProducerNode(v string)

func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) String 

func (x *Application_ApplicationRuntimeInfo_GlobalOutputResource) String() string

type Application_ApplicationRuntimeInfo_GlobalOutputResource_builder 

type Application_ApplicationRuntimeInfo_GlobalOutputResource_builder struct {

	// The full resource name of the outputted resources.
	OutputResource string
	// 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
	// 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
	// contains filtered or unexported fields
}

func (Application_ApplicationRuntimeInfo_GlobalOutputResource_builder) Build 

func (b0 Application_ApplicationRuntimeInfo_GlobalOutputResource_builder) Build() *Application_ApplicationRuntimeInfo_GlobalOutputResource

type 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) 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) SetEnabled 

func (x *Application_ApplicationRuntimeInfo_MonitoringConfig) SetEnabled(v bool)

func (*Application_ApplicationRuntimeInfo_MonitoringConfig) String 

func (x *Application_ApplicationRuntimeInfo_MonitoringConfig) String() string

type Application_ApplicationRuntimeInfo_MonitoringConfig_builder 

type Application_ApplicationRuntimeInfo_MonitoringConfig_builder struct {

	// Whether this application has monitoring enabled.
	Enabled bool
	// contains filtered or unexported fields
}

func (Application_ApplicationRuntimeInfo_MonitoringConfig_builder) Build 

func (b0 Application_ApplicationRuntimeInfo_MonitoringConfig_builder) Build() *Application_ApplicationRuntimeInfo_MonitoringConfig

type Application_ApplicationRuntimeInfo_builder 

type Application_ApplicationRuntimeInfo_builder struct {

	// Timestamp when the engine be deployed
	DeployTime *timestamppb.Timestamp
	// Globally created resources like warehouse dataschemas.
	GlobalOutputResources []*Application_ApplicationRuntimeInfo_GlobalOutputResource
	// Monitoring-related configuration for this application.
	MonitoringConfig *Application_ApplicationRuntimeInfo_MonitoringConfig
	// contains filtered or unexported fields
}

func (Application_ApplicationRuntimeInfo_builder) Build 

func (b0 Application_ApplicationRuntimeInfo_builder) Build() *Application_ApplicationRuntimeInfo

type Application_BillingMode 

type Application_BillingMode int32

Billing mode of the Application 

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

type Application_State 

type Application_State int32

State of the Application 

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

type Application_builder 

type Application_builder struct {

	// name of resource
	Name string
	// Output only. [Output only] Create timestamp
	CreateTime *timestamppb.Timestamp
	// Output only. [Output only] Update timestamp
	UpdateTime *timestamppb.Timestamp
	// Labels as key value pairs
	Labels map[string]string
	// Required. A user friendly display name for the solution.
	DisplayName string
	// A description for this application.
	Description string
	// Application graph configuration.
	ApplicationConfigs *ApplicationConfigs
	// Output only. Application graph runtime info. Only exists when application
	// state equals to DEPLOYED.
	RuntimeInfo *Application_ApplicationRuntimeInfo
	// Output only. State of the application.
	State Application_State
	// Billing mode of the application.
	BillingMode Application_BillingMode
	// contains filtered or unexported fields
}

func (Application_builder) Build 

func (b0 Application_builder) Build() *Application

type AttributeValue 

type AttributeValue struct {

	// Attribute value.
	//
	// Types that are valid to be assigned to Value:
	//
	//	*AttributeValue_I
	//	*AttributeValue_F
	//	*AttributeValue_B
	//	*AttributeValue_S
	Value isAttributeValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

Represents an actual value of an operator attribute.

func (*AttributeValue) ClearB 

func (x *AttributeValue) ClearB()

func (*AttributeValue) ClearF 

func (x *AttributeValue) ClearF()

func (*AttributeValue) ClearI 

func (x *AttributeValue) ClearI()

func (*AttributeValue) ClearS 

func (x *AttributeValue) ClearS()

func (*AttributeValue) ClearValue 

func (x *AttributeValue) ClearValue()

func (*AttributeValue) GetB 

func (x *AttributeValue) GetB() bool

func (*AttributeValue) GetF 

func (x *AttributeValue) GetF() float32

func (*AttributeValue) GetI 

func (x *AttributeValue) GetI() int64

func (*AttributeValue) GetS 

func (x *AttributeValue) GetS() []byte

func (*AttributeValue) GetValue 

func (x *AttributeValue) GetValue() isAttributeValue_Value

func (*AttributeValue) HasB 

func (x *AttributeValue) HasB() bool

func (*AttributeValue) HasF 

func (x *AttributeValue) HasF() bool

func (*AttributeValue) HasI 

func (x *AttributeValue) HasI() bool

func (*AttributeValue) HasS 

func (x *AttributeValue) HasS() bool

func (*AttributeValue) HasValue 

func (x *AttributeValue) HasValue() bool

func (*AttributeValue) ProtoMessage 

func (*AttributeValue) ProtoMessage()

func (*AttributeValue) ProtoReflect 

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

func (*AttributeValue) Reset 

func (x *AttributeValue) Reset()

func (*AttributeValue) SetB 

func (x *AttributeValue) SetB(v bool)

func (*AttributeValue) SetF 

func (x *AttributeValue) SetF(v float32)

func (*AttributeValue) SetI 

func (x *AttributeValue) SetI(v int64)

func (*AttributeValue) SetS 

func (x *AttributeValue) SetS(v []byte)

func (*AttributeValue) String 

func (x *AttributeValue) String() string

func (*AttributeValue) WhichValue 

func (x *AttributeValue) WhichValue() case_AttributeValue_Value

type AttributeValue_B 

type AttributeValue_B struct {
	// bool.
	B bool `protobuf:"varint,3,opt,name=b,proto3,oneof"`
}

type AttributeValue_F 

type AttributeValue_F struct {
	// float.
	F float32 `protobuf:"fixed32,2,opt,name=f,proto3,oneof"`
}

type AttributeValue_I 

type AttributeValue_I struct {
	// int.
	I int64 `protobuf:"varint,1,opt,name=i,proto3,oneof"`
}

type AttributeValue_S 

type AttributeValue_S struct {
	// string.
	S []byte `protobuf:"bytes,4,opt,name=s,proto3,oneof"`
}

type AttributeValue_builder 

type AttributeValue_builder struct {

	// Fields of oneof Value:
	// int.
	I *int64
	// float.
	F *float32
	// bool.
	B *bool
	// string.
	S []byte
	// contains filtered or unexported fields
}

func (AttributeValue_builder) Build 

func (b0 AttributeValue_builder) Build() *AttributeValue

type AutoscalingMetricSpec 

type AutoscalingMetricSpec struct {

	// Required. The resource metric name.
	// Supported metrics:
	//
	// * For Online Prediction:
	// * `aiplatform.googleapis.com/prediction/online/accelerator/duty_cycle`
	// * `aiplatform.googleapis.com/prediction/online/cpu/utilization`
	MetricName string `protobuf:"bytes,1,opt,name=metric_name,json=metricName,proto3" json:"metric_name,omitempty"`
	// The target resource utilization in percentage (1% - 100%) for the given
	// metric; once the real usage deviates from the target by a certain
	// percentage, the machine replicas change. The default value is 60
	// (representing 60%) if not provided.
	Target int32 `protobuf:"varint,2,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

The metric specification that defines the target resource utilization (CPU utilization, accelerator's duty cycle, and so on) for calculating the desired replica count.

func (*AutoscalingMetricSpec) GetMetricName 

func (x *AutoscalingMetricSpec) GetMetricName() string

func (*AutoscalingMetricSpec) GetTarget 

func (x *AutoscalingMetricSpec) GetTarget() int32

func (*AutoscalingMetricSpec) ProtoMessage 

func (*AutoscalingMetricSpec) ProtoMessage()

func (*AutoscalingMetricSpec) ProtoReflect 

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

func (*AutoscalingMetricSpec) Reset 

func (x *AutoscalingMetricSpec) Reset()

func (*AutoscalingMetricSpec) SetMetricName 

func (x *AutoscalingMetricSpec) SetMetricName(v string)

func (*AutoscalingMetricSpec) SetTarget 

func (x *AutoscalingMetricSpec) SetTarget(v int32)

func (*AutoscalingMetricSpec) String 

func (x *AutoscalingMetricSpec) String() string

type AutoscalingMetricSpec_builder 

type AutoscalingMetricSpec_builder struct {

	// Required. The resource metric name.
	// Supported metrics:
	//
	// * For Online Prediction:
	// * `aiplatform.googleapis.com/prediction/online/accelerator/duty_cycle`
	// * `aiplatform.googleapis.com/prediction/online/cpu/utilization`
	MetricName string
	// The target resource utilization in percentage (1% - 100%) for the given
	// metric; once the real usage deviates from the target by a certain
	// percentage, the machine replicas change. The default value is 60
	// (representing 60%) if not provided.
	Target int32
	// contains filtered or unexported fields
}

func (AutoscalingMetricSpec_builder) Build 

func (b0 AutoscalingMetricSpec_builder) Build() *AutoscalingMetricSpec

type BigQueryConfig 

type BigQueryConfig struct {

	// BigQuery table resource for Vision AI Platform to ingest annotations to.
	Table string `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	// Data Schema
	// By default, Vision AI Application will try to write annotations to the
	// target BigQuery table using the following schema:
	//
	// ingestion_time: TIMESTAMP, the ingestion time of the original data.
	//
	// application: STRING, name of the application which produces the annotation.
	//
	// instance: STRING, Id of the instance which produces the annotation.
	//
	// node: STRING, name of the application graph node which produces the
	// annotation.
	//
	// annotation: STRING or JSON, the actual annotation protobuf will be
	// converted to json string with bytes field as 64 encoded string. It can be
	// written to both String or Json type column.
	//
	// To forward annotation data to an existing BigQuery table, customer needs to
	// make sure the compatibility of the schema.
	// The map maps application node name to its corresponding cloud function
	// endpoint to transform the annotations directly to the
	// google.cloud.bigquery.storage.v1.AppendRowsRequest (only avro_rows or
	// proto_rows should be set). If configured, annotations produced by
	// corresponding application node will sent to the Cloud Function at first
	// before be forwarded to BigQuery.
	//
	// If the default table schema doesn't fit, customer is able to transform the
	// annotation output from Vision AI Application to arbitrary BigQuery table
	// schema with CloudFunction.
	// * The cloud function will receive AppPlatformCloudFunctionRequest where
	// the annotations field will be the json format of Vision AI annotation.
	// * The cloud function should return AppPlatformCloudFunctionResponse with
	// AppendRowsRequest stored in the annotations field.
	// * To drop the annotation, simply clear the annotations field in the
	// returned AppPlatformCloudFunctionResponse.
	CloudFunctionMapping map[string]string `` /* 197-byte string literal not displayed */
	// If true, App Platform will create the BigQuery DataSet and the
	// BigQuery Table with default schema if the specified table doesn't exist.
	// This doesn't work if any cloud function customized schema is specified
	// since the system doesn't know your desired schema.
	// JSON column will be used in the default table created by App Platform.
	CreateDefaultTableIfNotExists bool `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

Message of configurations for BigQuery processor.

func (*BigQueryConfig) GetCloudFunctionMapping 

func (x *BigQueryConfig) GetCloudFunctionMapping() map[string]string

func (*BigQueryConfig) GetCreateDefaultTableIfNotExists 

func (x *BigQueryConfig) GetCreateDefaultTableIfNotExists() bool

func (*BigQueryConfig) GetTable 

func (x *BigQueryConfig) GetTable() string

func (*BigQueryConfig) ProtoMessage 

func (*BigQueryConfig) ProtoMessage()

func (*BigQueryConfig) ProtoReflect 

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

func (*BigQueryConfig) Reset 

func (x *BigQueryConfig) Reset()

func (*BigQueryConfig) SetCloudFunctionMapping 

func (x *BigQueryConfig) SetCloudFunctionMapping(v map[string]string)

func (*BigQueryConfig) SetCreateDefaultTableIfNotExists 

func (x *BigQueryConfig) SetCreateDefaultTableIfNotExists(v bool)

func (*BigQueryConfig) SetTable 

func (x *BigQueryConfig) SetTable(v string)

func (*BigQueryConfig) String 

func (x *BigQueryConfig) String() string

type BigQueryConfig_builder 

type BigQueryConfig_builder struct {

	// BigQuery table resource for Vision AI Platform to ingest annotations to.
	Table string
	// Data Schema
	// By default, Vision AI Application will try to write annotations to the
	// target BigQuery table using the following schema:
	//
	// ingestion_time: TIMESTAMP, the ingestion time of the original data.
	//
	// application: STRING, name of the application which produces the annotation.
	//
	// instance: STRING, Id of the instance which produces the annotation.
	//
	// node: STRING, name of the application graph node which produces the
	// annotation.
	//
	// annotation: STRING or JSON, the actual annotation protobuf will be
	// converted to json string with bytes field as 64 encoded string. It can be
	// written to both String or Json type column.
	//
	// To forward annotation data to an existing BigQuery table, customer needs to
	// make sure the compatibility of the schema.
	// The map maps application node name to its corresponding cloud function
	// endpoint to transform the annotations directly to the
	// google.cloud.bigquery.storage.v1.AppendRowsRequest (only avro_rows or
	// proto_rows should be set). If configured, annotations produced by
	// corresponding application node will sent to the Cloud Function at first
	// before be forwarded to BigQuery.
	//
	// If the default table schema doesn't fit, customer is able to transform the
	// annotation output from Vision AI Application to arbitrary BigQuery table
	// schema with CloudFunction.
	// * The cloud function will receive AppPlatformCloudFunctionRequest where
	// the annotations field will be the json format of Vision AI annotation.
	// * The cloud function should return AppPlatformCloudFunctionResponse with
	// AppendRowsRequest stored in the annotations field.
	// * To drop the annotation, simply clear the annotations field in the
	// returned AppPlatformCloudFunctionResponse.
	CloudFunctionMapping map[string]string
	// If true, App Platform will create the BigQuery DataSet and the
	// BigQuery Table with default schema if the specified table doesn't exist.
	// This doesn't work if any cloud function customized schema is specified
	// since the system doesn't know your desired schema.
	// JSON column will be used in the default table created by App Platform.
	CreateDefaultTableIfNotExists bool
	// contains filtered or unexported fields
}

func (BigQueryConfig_builder) Build 

func (b0 BigQueryConfig_builder) Build() *BigQueryConfig

type Cluster 

type Cluster struct {

	// Output only. Name of the resource.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. The create timestamp.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The update timestamp.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Labels as key value pairs
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// Annotations to allow clients to store small amounts of arbitrary data.
	Annotations map[string]string `` /* 149-byte string literal not displayed */
	// Output only. The DNS name of the data plane service
	DataplaneServiceEndpoint string `` /* 135-byte string literal not displayed */
	// Output only. The current state of the cluster.
	State Cluster_State `protobuf:"varint,7,opt,name=state,proto3,enum=google.events.cloud.visionai.v1.Cluster_State" json:"state,omitempty"`
	// Output only. The private service connection service target name.
	PscTarget string `protobuf:"bytes,8,opt,name=psc_target,json=pscTarget,proto3" json:"psc_target,omitempty"`
	// contains filtered or unexported fields
}

Message describing the Cluster object.

func (*Cluster) ClearCreateTime 

func (x *Cluster) ClearCreateTime()

func (*Cluster) ClearUpdateTime 

func (x *Cluster) ClearUpdateTime()

func (*Cluster) GetAnnotations 

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

func (*Cluster) GetCreateTime 

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

func (*Cluster) GetDataplaneServiceEndpoint 

func (x *Cluster) GetDataplaneServiceEndpoint() string

func (*Cluster) GetLabels 

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

func (*Cluster) GetName 

func (x *Cluster) GetName() string

func (*Cluster) GetPscTarget 

func (x *Cluster) GetPscTarget() string

func (*Cluster) GetState 

func (x *Cluster) GetState() Cluster_State

func (*Cluster) GetUpdateTime 

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

func (*Cluster) HasCreateTime 

func (x *Cluster) HasCreateTime() bool

func (*Cluster) HasUpdateTime 

func (x *Cluster) HasUpdateTime() bool

func (*Cluster) ProtoMessage 

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect 

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

func (*Cluster) Reset 

func (x *Cluster) Reset()

func (*Cluster) SetAnnotations 

func (x *Cluster) SetAnnotations(v map[string]string)

func (*Cluster) SetCreateTime 

func (x *Cluster) SetCreateTime(v *timestamppb.Timestamp)

func (*Cluster) SetDataplaneServiceEndpoint 

func (x *Cluster) SetDataplaneServiceEndpoint(v string)

func (*Cluster) SetLabels 

func (x *Cluster) SetLabels(v map[string]string)

func (*Cluster) SetName 

func (x *Cluster) SetName(v string)

func (*Cluster) SetPscTarget 

func (x *Cluster) SetPscTarget(v string)

func (*Cluster) SetState 

func (x *Cluster) SetState(v Cluster_State)

func (*Cluster) SetUpdateTime 

func (x *Cluster) SetUpdateTime(v *timestamppb.Timestamp)

func (*Cluster) String 

func (x *Cluster) String() string

type ClusterCreatedEvent 

type ClusterCreatedEvent struct {

	// The data associated with the event.
	Data *ClusterEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Cluster is created.

func (*ClusterCreatedEvent) ClearData 

func (x *ClusterCreatedEvent) ClearData()

func (*ClusterCreatedEvent) GetData 

func (x *ClusterCreatedEvent) GetData() *ClusterEventData

func (*ClusterCreatedEvent) HasData 

func (x *ClusterCreatedEvent) HasData() bool

func (*ClusterCreatedEvent) ProtoMessage 

func (*ClusterCreatedEvent) ProtoMessage()

func (*ClusterCreatedEvent) ProtoReflect 

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

func (*ClusterCreatedEvent) Reset 

func (x *ClusterCreatedEvent) Reset()

func (*ClusterCreatedEvent) SetData 

func (x *ClusterCreatedEvent) SetData(v *ClusterEventData)

func (*ClusterCreatedEvent) String 

func (x *ClusterCreatedEvent) String() string

type ClusterCreatedEvent_builder 

type ClusterCreatedEvent_builder struct {

	// The data associated with the event.
	Data *ClusterEventData
	// contains filtered or unexported fields
}

func (ClusterCreatedEvent_builder) Build 

func (b0 ClusterCreatedEvent_builder) Build() *ClusterCreatedEvent

type ClusterDeletedEvent 

type ClusterDeletedEvent struct {

	// The data associated with the event.
	Data *ClusterEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Cluster is deleted.

func (*ClusterDeletedEvent) ClearData 

func (x *ClusterDeletedEvent) ClearData()

func (*ClusterDeletedEvent) GetData 

func (x *ClusterDeletedEvent) GetData() *ClusterEventData

func (*ClusterDeletedEvent) HasData 

func (x *ClusterDeletedEvent) HasData() bool

func (*ClusterDeletedEvent) ProtoMessage 

func (*ClusterDeletedEvent) ProtoMessage()

func (*ClusterDeletedEvent) ProtoReflect 

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

func (*ClusterDeletedEvent) Reset 

func (x *ClusterDeletedEvent) Reset()

func (*ClusterDeletedEvent) SetData 

func (x *ClusterDeletedEvent) SetData(v *ClusterEventData)

func (*ClusterDeletedEvent) String 

func (x *ClusterDeletedEvent) String() string

type ClusterDeletedEvent_builder 

type ClusterDeletedEvent_builder struct {

	// The data associated with the event.
	Data *ClusterEventData
	// contains filtered or unexported fields
}

func (ClusterDeletedEvent_builder) Build 

func (b0 ClusterDeletedEvent_builder) Build() *ClusterDeletedEvent

type ClusterEventData 

type ClusterEventData struct {

	// Optional. The Cluster event payload. Unset for deletion events.
	Payload *Cluster `protobuf:"bytes,1,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The data within all Cluster events.

func (*ClusterEventData) ClearPayload 

func (x *ClusterEventData) ClearPayload()

func (*ClusterEventData) GetPayload 

func (x *ClusterEventData) GetPayload() *Cluster

func (*ClusterEventData) HasPayload 

func (x *ClusterEventData) HasPayload() bool

func (*ClusterEventData) ProtoMessage 

func (*ClusterEventData) ProtoMessage()

func (*ClusterEventData) ProtoReflect 

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

func (*ClusterEventData) Reset 

func (x *ClusterEventData) Reset()

func (*ClusterEventData) SetPayload 

func (x *ClusterEventData) SetPayload(v *Cluster)

func (*ClusterEventData) String 

func (x *ClusterEventData) String() string

type ClusterEventData_builder 

type ClusterEventData_builder struct {

	// Optional. The Cluster event payload. Unset for deletion events.
	Payload *Cluster
	// contains filtered or unexported fields
}

func (ClusterEventData_builder) Build 

func (b0 ClusterEventData_builder) Build() *ClusterEventData

type ClusterUpdatedEvent 

type ClusterUpdatedEvent struct {

	// The data associated with the event.
	Data *ClusterEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Cluster is updated.

func (*ClusterUpdatedEvent) ClearData 

func (x *ClusterUpdatedEvent) ClearData()

func (*ClusterUpdatedEvent) GetData 

func (x *ClusterUpdatedEvent) GetData() *ClusterEventData

func (*ClusterUpdatedEvent) HasData 

func (x *ClusterUpdatedEvent) HasData() bool

func (*ClusterUpdatedEvent) ProtoMessage 

func (*ClusterUpdatedEvent) ProtoMessage()

func (*ClusterUpdatedEvent) ProtoReflect 

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

func (*ClusterUpdatedEvent) Reset 

func (x *ClusterUpdatedEvent) Reset()

func (*ClusterUpdatedEvent) SetData 

func (x *ClusterUpdatedEvent) SetData(v *ClusterEventData)

func (*ClusterUpdatedEvent) String 

func (x *ClusterUpdatedEvent) String() string

type ClusterUpdatedEvent_builder 

type ClusterUpdatedEvent_builder struct {

	// The data associated with the event.
	Data *ClusterEventData
	// contains filtered or unexported fields
}

func (ClusterUpdatedEvent_builder) Build 

func (b0 ClusterUpdatedEvent_builder) Build() *ClusterUpdatedEvent

type Cluster_State 

type Cluster_State int32

The current state of the cluster. 

const (
	// Not set.
	Cluster_STATE_UNSPECIFIED Cluster_State = 0
	// The PROVISIONING state indicates the cluster is being created.
	Cluster_PROVISIONING Cluster_State = 1
	// The RUNNING state indicates the cluster has been created and is fully
	// usable.
	Cluster_RUNNING Cluster_State = 2
	// The STOPPING state indicates the cluster is being deleted.
	Cluster_STOPPING Cluster_State = 3
	// The ERROR state indicates the cluster is unusable. It will be
	// automatically deleted.
	Cluster_ERROR Cluster_State = 4
)

func (Cluster_State) Descriptor 

func (Cluster_State) Descriptor() protoreflect.EnumDescriptor

func (Cluster_State) Enum 

func (x Cluster_State) Enum() *Cluster_State

func (Cluster_State) Number 

func (x Cluster_State) Number() protoreflect.EnumNumber

func (Cluster_State) String 

func (x Cluster_State) String() string

func (Cluster_State) Type 

func (Cluster_State) Type() protoreflect.EnumType

type Cluster_builder 

type Cluster_builder struct {

	// Output only. Name of the resource.
	Name string
	// Output only. The create timestamp.
	CreateTime *timestamppb.Timestamp
	// Output only. The update timestamp.
	UpdateTime *timestamppb.Timestamp
	// Labels as key value pairs
	Labels map[string]string
	// Annotations to allow clients to store small amounts of arbitrary data.
	Annotations map[string]string
	// Output only. The DNS name of the data plane service
	DataplaneServiceEndpoint string
	// Output only. The current state of the cluster.
	State Cluster_State
	// Output only. The private service connection service target name.
	PscTarget string
	// contains filtered or unexported fields
}

func (Cluster_builder) Build 

func (b0 Cluster_builder) Build() *Cluster

type CustomProcessorSourceInfo 

type CustomProcessorSourceInfo struct {

	// The path where App Platform loads the artifacts for the custom processor.
	//
	// Types that are valid to be assigned to ArtifactPath:
	//
	//	*CustomProcessorSourceInfo_VertexModel
	ArtifactPath isCustomProcessorSourceInfo_ArtifactPath `protobuf_oneof:"artifact_path"`
	// The original product which holds the custom processor's functionality.
	SourceType CustomProcessorSourceInfo_SourceType `` /* 166-byte string literal not displayed */
	// Output only. Additional info related to the imported custom processor.
	// Data is filled in by app platform during the processor creation.
	AdditionalInfo map[string]string `` /* 177-byte string literal not displayed */
	// Model schema files which specifies the signature of the model.
	// For VERTEX_CUSTOM models, instances schema is required.
	// If instances schema is not specified during the processor creation,
	// VisionAI Platform will try to get it from Vertex, if it doesn't exist, the
	// creation will fail.
	ModelSchema *CustomProcessorSourceInfo_ModelSchema `protobuf:"bytes,5,opt,name=model_schema,json=modelSchema,proto3" json:"model_schema,omitempty"`
	// contains filtered or unexported fields
}

Describes the source info for a custom processor.

func (*CustomProcessorSourceInfo) ClearArtifactPath 

func (x *CustomProcessorSourceInfo) ClearArtifactPath()

func (*CustomProcessorSourceInfo) ClearModelSchema 

func (x *CustomProcessorSourceInfo) ClearModelSchema()

func (*CustomProcessorSourceInfo) ClearVertexModel 

func (x *CustomProcessorSourceInfo) ClearVertexModel()

func (*CustomProcessorSourceInfo) GetAdditionalInfo 

func (x *CustomProcessorSourceInfo) GetAdditionalInfo() map[string]string

func (*CustomProcessorSourceInfo) GetArtifactPath 

func (x *CustomProcessorSourceInfo) GetArtifactPath() isCustomProcessorSourceInfo_ArtifactPath

func (*CustomProcessorSourceInfo) GetModelSchema 

func (x *CustomProcessorSourceInfo) GetModelSchema() *CustomProcessorSourceInfo_ModelSchema

func (*CustomProcessorSourceInfo) GetSourceType 

func (x *CustomProcessorSourceInfo) GetSourceType() CustomProcessorSourceInfo_SourceType

func (*CustomProcessorSourceInfo) GetVertexModel 

func (x *CustomProcessorSourceInfo) GetVertexModel() string

func (*CustomProcessorSourceInfo) HasArtifactPath 

func (x *CustomProcessorSourceInfo) HasArtifactPath() bool

func (*CustomProcessorSourceInfo) HasModelSchema 

func (x *CustomProcessorSourceInfo) HasModelSchema() bool

func (*CustomProcessorSourceInfo) HasVertexModel 

func (x *CustomProcessorSourceInfo) HasVertexModel() bool

func (*CustomProcessorSourceInfo) ProtoMessage 

func (*CustomProcessorSourceInfo) ProtoMessage()

func (*CustomProcessorSourceInfo) ProtoReflect 

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

func (*CustomProcessorSourceInfo) Reset 

func (x *CustomProcessorSourceInfo) Reset()

func (*CustomProcessorSourceInfo) SetAdditionalInfo 

func (x *CustomProcessorSourceInfo) SetAdditionalInfo(v map[string]string)

func (*CustomProcessorSourceInfo) SetModelSchema 

func (x *CustomProcessorSourceInfo) SetModelSchema(v *CustomProcessorSourceInfo_ModelSchema)

func (*CustomProcessorSourceInfo) SetSourceType 

func (x *CustomProcessorSourceInfo) SetSourceType(v CustomProcessorSourceInfo_SourceType)

func (*CustomProcessorSourceInfo) SetVertexModel 

func (x *CustomProcessorSourceInfo) SetVertexModel(v string)

func (*CustomProcessorSourceInfo) String 

func (x *CustomProcessorSourceInfo) String() string

func (*CustomProcessorSourceInfo) WhichArtifactPath 

func (x *CustomProcessorSourceInfo) WhichArtifactPath() case_CustomProcessorSourceInfo_ArtifactPath

type CustomProcessorSourceInfo_ModelSchema 

type CustomProcessorSourceInfo_ModelSchema struct {

	// Cloud Storage location to a YAML file that defines the format of a single
	// instance used in prediction and explanation requests.
	InstancesSchema *GcsSource `protobuf:"bytes,1,opt,name=instances_schema,json=instancesSchema,proto3" json:"instances_schema,omitempty"`
	// Cloud Storage location to a YAML file that defines the prediction and
	// explanation parameters.
	ParametersSchema *GcsSource `protobuf:"bytes,2,opt,name=parameters_schema,json=parametersSchema,proto3" json:"parameters_schema,omitempty"`
	// Cloud Storage location to a YAML file that defines the format of a single
	// prediction or explanation.
	PredictionsSchema *GcsSource `protobuf:"bytes,3,opt,name=predictions_schema,json=predictionsSchema,proto3" json:"predictions_schema,omitempty"`
	// contains filtered or unexported fields
}

The schema is defined as an OpenAPI 3.0.2 [Schema Object](https://github.com/OAI/OpenAPI-Specification/blob/main/versions/3.0.2.md#schemaObject).

func (*CustomProcessorSourceInfo_ModelSchema) ClearInstancesSchema 

func (x *CustomProcessorSourceInfo_ModelSchema) ClearInstancesSchema()

func (*CustomProcessorSourceInfo_ModelSchema) ClearParametersSchema 

func (x *CustomProcessorSourceInfo_ModelSchema) ClearParametersSchema()

func (*CustomProcessorSourceInfo_ModelSchema) ClearPredictionsSchema 

func (x *CustomProcessorSourceInfo_ModelSchema) ClearPredictionsSchema()

func (*CustomProcessorSourceInfo_ModelSchema) GetInstancesSchema 

func (x *CustomProcessorSourceInfo_ModelSchema) GetInstancesSchema() *GcsSource

func (*CustomProcessorSourceInfo_ModelSchema) GetParametersSchema 

func (x *CustomProcessorSourceInfo_ModelSchema) GetParametersSchema() *GcsSource

func (*CustomProcessorSourceInfo_ModelSchema) GetPredictionsSchema 

func (x *CustomProcessorSourceInfo_ModelSchema) GetPredictionsSchema() *GcsSource

func (*CustomProcessorSourceInfo_ModelSchema) HasInstancesSchema 

func (x *CustomProcessorSourceInfo_ModelSchema) HasInstancesSchema() bool

func (*CustomProcessorSourceInfo_ModelSchema) HasParametersSchema 

func (x *CustomProcessorSourceInfo_ModelSchema) HasParametersSchema() bool

func (*CustomProcessorSourceInfo_ModelSchema) HasPredictionsSchema 

func (x *CustomProcessorSourceInfo_ModelSchema) HasPredictionsSchema() bool

func (*CustomProcessorSourceInfo_ModelSchema) ProtoMessage 

func (*CustomProcessorSourceInfo_ModelSchema) ProtoMessage()

func (*CustomProcessorSourceInfo_ModelSchema) ProtoReflect 

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

func (*CustomProcessorSourceInfo_ModelSchema) Reset 

func (x *CustomProcessorSourceInfo_ModelSchema) Reset()

func (*CustomProcessorSourceInfo_ModelSchema) SetInstancesSchema 

func (x *CustomProcessorSourceInfo_ModelSchema) SetInstancesSchema(v *GcsSource)

func (*CustomProcessorSourceInfo_ModelSchema) SetParametersSchema 

func (x *CustomProcessorSourceInfo_ModelSchema) SetParametersSchema(v *GcsSource)

func (*CustomProcessorSourceInfo_ModelSchema) SetPredictionsSchema 

func (x *CustomProcessorSourceInfo_ModelSchema) SetPredictionsSchema(v *GcsSource)

func (*CustomProcessorSourceInfo_ModelSchema) String 

func (x *CustomProcessorSourceInfo_ModelSchema) String() string

type CustomProcessorSourceInfo_ModelSchema_builder 

type CustomProcessorSourceInfo_ModelSchema_builder struct {

	// Cloud Storage location to a YAML file that defines the format of a single
	// instance used in prediction and explanation requests.
	InstancesSchema *GcsSource
	// Cloud Storage location to a YAML file that defines the prediction and
	// explanation parameters.
	ParametersSchema *GcsSource
	// Cloud Storage location to a YAML file that defines the format of a single
	// prediction or explanation.
	PredictionsSchema *GcsSource
	// contains filtered or unexported fields
}

func (CustomProcessorSourceInfo_ModelSchema_builder) Build 

func (b0 CustomProcessorSourceInfo_ModelSchema_builder) Build() *CustomProcessorSourceInfo_ModelSchema

type CustomProcessorSourceInfo_SourceType 

type CustomProcessorSourceInfo_SourceType int32

Source type of the imported custom processor. 

const (
	// Source type unspecified.
	CustomProcessorSourceInfo_SOURCE_TYPE_UNSPECIFIED CustomProcessorSourceInfo_SourceType = 0
	// Custom processors coming from Vertex AutoML product.
	CustomProcessorSourceInfo_VERTEX_AUTOML CustomProcessorSourceInfo_SourceType = 1
	// Custom processors coming from general custom models from Vertex.
	CustomProcessorSourceInfo_VERTEX_CUSTOM CustomProcessorSourceInfo_SourceType = 2
	// Source for Product Recognizer.
	CustomProcessorSourceInfo_PRODUCT_RECOGNIZER CustomProcessorSourceInfo_SourceType = 3
)

func (CustomProcessorSourceInfo_SourceType) Descriptor 

func (CustomProcessorSourceInfo_SourceType) Descriptor() protoreflect.EnumDescriptor

func (CustomProcessorSourceInfo_SourceType) Enum 

func (x CustomProcessorSourceInfo_SourceType) Enum() *CustomProcessorSourceInfo_SourceType

func (CustomProcessorSourceInfo_SourceType) Number 

func (x CustomProcessorSourceInfo_SourceType) Number() protoreflect.EnumNumber

func (CustomProcessorSourceInfo_SourceType) String 

func (x CustomProcessorSourceInfo_SourceType) String() string

func (CustomProcessorSourceInfo_SourceType) Type 

func (CustomProcessorSourceInfo_SourceType) Type() protoreflect.EnumType

type CustomProcessorSourceInfo_VertexModel 

type CustomProcessorSourceInfo_VertexModel struct {
	// The resource name original model hosted in the vertex AI platform.
	VertexModel string `protobuf:"bytes,2,opt,name=vertex_model,json=vertexModel,proto3,oneof"`
}

type CustomProcessorSourceInfo_builder 

type CustomProcessorSourceInfo_builder struct {

	// Fields of oneof ArtifactPath:
	// The resource name original model hosted in the vertex AI platform.
	VertexModel *string
	// -- end of ArtifactPath
	// The original product which holds the custom processor's functionality.
	SourceType CustomProcessorSourceInfo_SourceType
	// Output only. Additional info related to the imported custom processor.
	// Data is filled in by app platform during the processor creation.
	AdditionalInfo map[string]string
	// Model schema files which specifies the signature of the model.
	// For VERTEX_CUSTOM models, instances schema is required.
	// If instances schema is not specified during the processor creation,
	// VisionAI Platform will try to get it from Vertex, if it doesn't exist, the
	// creation will fail.
	ModelSchema *CustomProcessorSourceInfo_ModelSchema
	// contains filtered or unexported fields
}

func (CustomProcessorSourceInfo_builder) Build 

func (b0 CustomProcessorSourceInfo_builder) Build() *CustomProcessorSourceInfo

type DataType 

type DataType int32

All supported data types. 

const (
	// The default value of DataType.
	DataType_DATA_TYPE_UNSPECIFIED DataType = 0
	// Video data type like H264.
	DataType_VIDEO DataType = 1
	// Image data type.
	DataType_IMAGE DataType = 3
	// Protobuf data type, usually used for general data blob.
	DataType_PROTO DataType = 2
)

func (DataType) Descriptor 

func (DataType) Descriptor() protoreflect.EnumDescriptor

func (DataType) Enum 

func (x DataType) Enum() *DataType

func (DataType) Number 

func (x DataType) Number() protoreflect.EnumNumber

func (DataType) String 

func (x DataType) String() string

func (DataType) Type 

func (DataType) Type() protoreflect.EnumType

type DedicatedResources 

type DedicatedResources struct {

	// Required. Immutable. The specification of a single machine used by the
	// prediction.
	MachineSpec *MachineSpec `protobuf:"bytes,1,opt,name=machine_spec,json=machineSpec,proto3" json:"machine_spec,omitempty"`
	// Required. Immutable. The minimum number of machine replicas this
	// DeployedModel will be always deployed on. This value must be greater than
	// or equal to 1.
	//
	// If traffic against the DeployedModel increases, it may dynamically be
	// deployed onto more replicas, and as traffic decreases, some of these extra
	// replicas may be freed.
	MinReplicaCount int32 `protobuf:"varint,2,opt,name=min_replica_count,json=minReplicaCount,proto3" json:"min_replica_count,omitempty"`
	// Immutable. The maximum number of replicas this DeployedModel may be
	// deployed on when the traffic against it increases. If the requested value
	// is too large, the deployment will error, but if deployment succeeds then
	// the ability to scale the model to that many replicas is guaranteed (barring
	// service outages). If traffic against the DeployedModel increases beyond
	// what its replicas at maximum may handle, a portion of the traffic will be
	// dropped. If this value is not provided, will use
	// [min_replica_count][google.cloud.visionai.v1.DedicatedResources.min_replica_count]
	// as the default value.
	//
	// The value of this field impacts the charge against Vertex CPU and GPU
	// quotas. Specifically, you will be charged for max_replica_count *
	// number of cores in the selected machine type) and (max_replica_count *
	// number of GPUs per replica in the selected machine type).
	MaxReplicaCount int32 `protobuf:"varint,3,opt,name=max_replica_count,json=maxReplicaCount,proto3" json:"max_replica_count,omitempty"`
	// Immutable. The metric specifications that overrides a resource
	// utilization metric (CPU utilization, accelerator's duty cycle, and so on)
	// target value (default to 60 if not set). At most one entry is allowed per
	// metric.
	//
	// If
	// [machine_spec.accelerator_count][google.cloud.visionai.v1.MachineSpec.accelerator_count]
	// is above 0, the autoscaling will be based on both CPU utilization and
	// accelerator's duty cycle metrics and scale up when either metrics exceeds
	// its target value while scale down if both metrics are under their target
	// value. The default target value is 60 for both metrics.
	//
	// If
	// [machine_spec.accelerator_count][google.cloud.visionai.v1.MachineSpec.accelerator_count]
	// is 0, the autoscaling will be based on CPU utilization metric only with
	// default target value 60 if not explicitly set.
	//
	// For example, in the case of Online Prediction, if you want to override
	// target CPU utilization to 80, you should set
	// [autoscaling_metric_specs.metric_name][google.cloud.visionai.v1.AutoscalingMetricSpec.metric_name]
	// to `aiplatform.googleapis.com/prediction/online/cpu/utilization` and
	// [autoscaling_metric_specs.target][google.cloud.visionai.v1.AutoscalingMetricSpec.target]
	// to `80`.
	AutoscalingMetricSpecs []*AutoscalingMetricSpec `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

A description of resources that are dedicated to a DeployedModel, and that need a higher degree of manual configuration.

func (*DedicatedResources) ClearMachineSpec 

func (x *DedicatedResources) ClearMachineSpec()

func (*DedicatedResources) GetAutoscalingMetricSpecs 

func (x *DedicatedResources) GetAutoscalingMetricSpecs() []*AutoscalingMetricSpec

func (*DedicatedResources) GetMachineSpec 

func (x *DedicatedResources) GetMachineSpec() *MachineSpec

func (*DedicatedResources) GetMaxReplicaCount 

func (x *DedicatedResources) GetMaxReplicaCount() int32

func (*DedicatedResources) GetMinReplicaCount 

func (x *DedicatedResources) GetMinReplicaCount() int32

func (*DedicatedResources) HasMachineSpec 

func (x *DedicatedResources) HasMachineSpec() bool

func (*DedicatedResources) ProtoMessage 

func (*DedicatedResources) ProtoMessage()

func (*DedicatedResources) ProtoReflect 

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

func (*DedicatedResources) Reset 

func (x *DedicatedResources) Reset()

func (*DedicatedResources) SetAutoscalingMetricSpecs 

func (x *DedicatedResources) SetAutoscalingMetricSpecs(v []*AutoscalingMetricSpec)

func (*DedicatedResources) SetMachineSpec 

func (x *DedicatedResources) SetMachineSpec(v *MachineSpec)

func (*DedicatedResources) SetMaxReplicaCount 

func (x *DedicatedResources) SetMaxReplicaCount(v int32)

func (*DedicatedResources) SetMinReplicaCount 

func (x *DedicatedResources) SetMinReplicaCount(v int32)

func (*DedicatedResources) String 

func (x *DedicatedResources) String() string

type DedicatedResources_builder 

type DedicatedResources_builder struct {

	// Required. Immutable. The specification of a single machine used by the
	// prediction.
	MachineSpec *MachineSpec
	// Required. Immutable. The minimum number of machine replicas this
	// DeployedModel will be always deployed on. This value must be greater than
	// or equal to 1.
	//
	// If traffic against the DeployedModel increases, it may dynamically be
	// deployed onto more replicas, and as traffic decreases, some of these extra
	// replicas may be freed.
	MinReplicaCount int32
	// Immutable. The maximum number of replicas this DeployedModel may be
	// deployed on when the traffic against it increases. If the requested value
	// is too large, the deployment will error, but if deployment succeeds then
	// the ability to scale the model to that many replicas is guaranteed (barring
	// service outages). If traffic against the DeployedModel increases beyond
	// what its replicas at maximum may handle, a portion of the traffic will be
	// dropped. If this value is not provided, will use
	// [min_replica_count][google.cloud.visionai.v1.DedicatedResources.min_replica_count]
	// as the default value.
	//
	// The value of this field impacts the charge against Vertex CPU and GPU
	// quotas. Specifically, you will be charged for max_replica_count *
	// number of cores in the selected machine type) and (max_replica_count *
	// number of GPUs per replica in the selected machine type).
	MaxReplicaCount int32
	// Immutable. The metric specifications that overrides a resource
	// utilization metric (CPU utilization, accelerator's duty cycle, and so on)
	// target value (default to 60 if not set). At most one entry is allowed per
	// metric.
	//
	// If
	// [machine_spec.accelerator_count][google.cloud.visionai.v1.MachineSpec.accelerator_count]
	// is above 0, the autoscaling will be based on both CPU utilization and
	// accelerator's duty cycle metrics and scale up when either metrics exceeds
	// its target value while scale down if both metrics are under their target
	// value. The default target value is 60 for both metrics.
	//
	// If
	// [machine_spec.accelerator_count][google.cloud.visionai.v1.MachineSpec.accelerator_count]
	// is 0, the autoscaling will be based on CPU utilization metric only with
	// default target value 60 if not explicitly set.
	//
	// For example, in the case of Online Prediction, if you want to override
	// target CPU utilization to 80, you should set
	// [autoscaling_metric_specs.metric_name][google.cloud.visionai.v1.AutoscalingMetricSpec.metric_name]
	// to `aiplatform.googleapis.com/prediction/online/cpu/utilization` and
	// [autoscaling_metric_specs.target][google.cloud.visionai.v1.AutoscalingMetricSpec.target]
	// to `80`.
	AutoscalingMetricSpecs []*AutoscalingMetricSpec
	// contains filtered or unexported fields
}

func (DedicatedResources_builder) Build 

func (b0 DedicatedResources_builder) Build() *DedicatedResources

type Draft 

type Draft struct {

	// name of resource
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. [Output only] Create timestamp
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. [Output only] Create timestamp
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Labels as key value pairs
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// Required. A user friendly display name for the solution.
	DisplayName string `protobuf:"bytes,4,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// A description for this application.
	Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	// The draft application configs which haven't been updated to an application.
	DraftApplicationConfigs *ApplicationConfigs `` /* 132-byte string literal not displayed */
	// contains filtered or unexported fields
}

Message describing Draft object

func (*Draft) ClearCreateTime 

func (x *Draft) ClearCreateTime()

func (*Draft) ClearDraftApplicationConfigs 

func (x *Draft) ClearDraftApplicationConfigs()

func (*Draft) ClearUpdateTime 

func (x *Draft) ClearUpdateTime()

func (*Draft) GetCreateTime 

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

func (*Draft) GetDescription 

func (x *Draft) GetDescription() string

func (*Draft) GetDisplayName 

func (x *Draft) GetDisplayName() string

func (*Draft) GetDraftApplicationConfigs 

func (x *Draft) GetDraftApplicationConfigs() *ApplicationConfigs

func (*Draft) GetLabels 

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

func (*Draft) GetName 

func (x *Draft) GetName() string

func (*Draft) GetUpdateTime 

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

func (*Draft) HasCreateTime 

func (x *Draft) HasCreateTime() bool

func (*Draft) HasDraftApplicationConfigs 

func (x *Draft) HasDraftApplicationConfigs() bool

func (*Draft) HasUpdateTime 

func (x *Draft) HasUpdateTime() bool

func (*Draft) ProtoMessage 

func (*Draft) ProtoMessage()

func (*Draft) ProtoReflect 

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

func (*Draft) Reset 

func (x *Draft) Reset()

func (*Draft) SetCreateTime 

func (x *Draft) SetCreateTime(v *timestamppb.Timestamp)

func (*Draft) SetDescription 

func (x *Draft) SetDescription(v string)

func (*Draft) SetDisplayName 

func (x *Draft) SetDisplayName(v string)

func (*Draft) SetDraftApplicationConfigs 

func (x *Draft) SetDraftApplicationConfigs(v *ApplicationConfigs)

func (*Draft) SetLabels 

func (x *Draft) SetLabels(v map[string]string)

func (*Draft) SetName 

func (x *Draft) SetName(v string)

func (*Draft) SetUpdateTime 

func (x *Draft) SetUpdateTime(v *timestamppb.Timestamp)

func (*Draft) String 

func (x *Draft) String() string

type DraftCreatedEvent 

type DraftCreatedEvent struct {

	// The data associated with the event.
	Data *DraftEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Draft is created.

func (*DraftCreatedEvent) ClearData 

func (x *DraftCreatedEvent) ClearData()

func (*DraftCreatedEvent) GetData 

func (x *DraftCreatedEvent) GetData() *DraftEventData

func (*DraftCreatedEvent) HasData 

func (x *DraftCreatedEvent) HasData() bool

func (*DraftCreatedEvent) ProtoMessage 

func (*DraftCreatedEvent) ProtoMessage()

func (*DraftCreatedEvent) ProtoReflect 

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

func (*DraftCreatedEvent) Reset 

func (x *DraftCreatedEvent) Reset()

func (*DraftCreatedEvent) SetData 

func (x *DraftCreatedEvent) SetData(v *DraftEventData)

func (*DraftCreatedEvent) String 

func (x *DraftCreatedEvent) String() string

type DraftCreatedEvent_builder 

type DraftCreatedEvent_builder struct {

	// The data associated with the event.
	Data *DraftEventData
	// contains filtered or unexported fields
}

func (DraftCreatedEvent_builder) Build 

func (b0 DraftCreatedEvent_builder) Build() *DraftCreatedEvent

type DraftDeletedEvent 

type DraftDeletedEvent struct {

	// The data associated with the event.
	Data *DraftEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Draft is deleted.

func (*DraftDeletedEvent) ClearData 

func (x *DraftDeletedEvent) ClearData()

func (*DraftDeletedEvent) GetData 

func (x *DraftDeletedEvent) GetData() *DraftEventData

func (*DraftDeletedEvent) HasData 

func (x *DraftDeletedEvent) HasData() bool

func (*DraftDeletedEvent) ProtoMessage 

func (*DraftDeletedEvent) ProtoMessage()

func (*DraftDeletedEvent) ProtoReflect 

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

func (*DraftDeletedEvent) Reset 

func (x *DraftDeletedEvent) Reset()

func (*DraftDeletedEvent) SetData 

func (x *DraftDeletedEvent) SetData(v *DraftEventData)

func (*DraftDeletedEvent) String 

func (x *DraftDeletedEvent) String() string

type DraftDeletedEvent_builder 

type DraftDeletedEvent_builder struct {

	// The data associated with the event.
	Data *DraftEventData
	// contains filtered or unexported fields
}

func (DraftDeletedEvent_builder) Build 

func (b0 DraftDeletedEvent_builder) Build() *DraftDeletedEvent

type DraftEventData 

type DraftEventData struct {

	// Optional. The Draft event payload. Unset for deletion events.
	Payload *Draft `protobuf:"bytes,1,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The data within all Draft events.

func (*DraftEventData) ClearPayload 

func (x *DraftEventData) ClearPayload()

func (*DraftEventData) GetPayload 

func (x *DraftEventData) GetPayload() *Draft

func (*DraftEventData) HasPayload 

func (x *DraftEventData) HasPayload() bool

func (*DraftEventData) ProtoMessage 

func (*DraftEventData) ProtoMessage()

func (*DraftEventData) ProtoReflect 

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

func (*DraftEventData) Reset 

func (x *DraftEventData) Reset()

func (*DraftEventData) SetPayload 

func (x *DraftEventData) SetPayload(v *Draft)

func (*DraftEventData) String 

func (x *DraftEventData) String() string

type DraftEventData_builder 

type DraftEventData_builder struct {

	// Optional. The Draft event payload. Unset for deletion events.
	Payload *Draft
	// contains filtered or unexported fields
}

func (DraftEventData_builder) Build 

func (b0 DraftEventData_builder) Build() *DraftEventData

type DraftUpdatedEvent 

type DraftUpdatedEvent struct {

	// The data associated with the event.
	Data *DraftEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Draft is updated.

func (*DraftUpdatedEvent) ClearData 

func (x *DraftUpdatedEvent) ClearData()

func (*DraftUpdatedEvent) GetData 

func (x *DraftUpdatedEvent) GetData() *DraftEventData

func (*DraftUpdatedEvent) HasData 

func (x *DraftUpdatedEvent) HasData() bool

func (*DraftUpdatedEvent) ProtoMessage 

func (*DraftUpdatedEvent) ProtoMessage()

func (*DraftUpdatedEvent) ProtoReflect 

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

func (*DraftUpdatedEvent) Reset 

func (x *DraftUpdatedEvent) Reset()

func (*DraftUpdatedEvent) SetData 

func (x *DraftUpdatedEvent) SetData(v *DraftEventData)

func (*DraftUpdatedEvent) String 

func (x *DraftUpdatedEvent) String() string

type DraftUpdatedEvent_builder 

type DraftUpdatedEvent_builder struct {

	// The data associated with the event.
	Data *DraftEventData
	// contains filtered or unexported fields
}

func (DraftUpdatedEvent_builder) Build 

func (b0 DraftUpdatedEvent_builder) Build() *DraftUpdatedEvent

type Draft_builder 

type Draft_builder struct {

	// name of resource
	Name string
	// Output only. [Output only] Create timestamp
	CreateTime *timestamppb.Timestamp
	// Output only. [Output only] Create timestamp
	UpdateTime *timestamppb.Timestamp
	// Labels as key value pairs
	Labels map[string]string
	// Required. A user friendly display name for the solution.
	DisplayName string
	// A description for this application.
	Description string
	// The draft application configs which haven't been updated to an application.
	DraftApplicationConfigs *ApplicationConfigs
	// contains filtered or unexported fields
}

func (Draft_builder) Build 

func (b0 Draft_builder) Build() *Draft

type Event 

type Event struct {

	// Name of the resource.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. The create timestamp.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The update timestamp.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Labels as key value pairs.
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// Annotations to allow clients to store small amounts of arbitrary data.
	Annotations map[string]string `` /* 149-byte string literal not displayed */
	// The clock used for joining streams.
	AlignmentClock Event_Clock `` /* 153-byte string literal not displayed */
	// Grace period for cleaning up the event. This is the time the controller
	// waits for before deleting the event. During this period, if there is any
	// active channel on the event. The deletion of the event after grace_period
	// will be ignored.
	GracePeriod *durationpb.Duration `protobuf:"bytes,7,opt,name=grace_period,json=gracePeriod,proto3" json:"grace_period,omitempty"`
	// contains filtered or unexported fields
}

Message describing the Event object.

func (*Event) ClearCreateTime 

func (x *Event) ClearCreateTime()

func (*Event) ClearGracePeriod 

func (x *Event) ClearGracePeriod()

func (*Event) ClearUpdateTime 

func (x *Event) ClearUpdateTime()

func (*Event) GetAlignmentClock 

func (x *Event) GetAlignmentClock() Event_Clock

func (*Event) GetAnnotations 

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

func (*Event) GetCreateTime 

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

func (*Event) GetGracePeriod 

func (x *Event) GetGracePeriod() *durationpb.Duration

func (*Event) GetLabels 

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

func (*Event) GetName 

func (x *Event) GetName() string

func (*Event) GetUpdateTime 

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

func (*Event) HasCreateTime 

func (x *Event) HasCreateTime() bool

func (*Event) HasGracePeriod 

func (x *Event) HasGracePeriod() bool

func (*Event) HasUpdateTime 

func (x *Event) HasUpdateTime() bool

func (*Event) ProtoMessage 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect 

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

func (*Event) Reset 

func (x *Event) Reset()

func (*Event) SetAlignmentClock 

func (x *Event) SetAlignmentClock(v Event_Clock)

func (*Event) SetAnnotations 

func (x *Event) SetAnnotations(v map[string]string)

func (*Event) SetCreateTime 

func (x *Event) SetCreateTime(v *timestamppb.Timestamp)

func (*Event) SetGracePeriod 

func (x *Event) SetGracePeriod(v *durationpb.Duration)

func (*Event) SetLabels 

func (x *Event) SetLabels(v map[string]string)

func (*Event) SetName 

func (x *Event) SetName(v string)

func (*Event) SetUpdateTime 

func (x *Event) SetUpdateTime(v *timestamppb.Timestamp)

func (*Event) String 

func (x *Event) String() string

type EventCreatedEvent 

type EventCreatedEvent struct {

	// The data associated with the event.
	Data *EventEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when an Event is created.

func (*EventCreatedEvent) ClearData 

func (x *EventCreatedEvent) ClearData()

func (*EventCreatedEvent) GetData 

func (x *EventCreatedEvent) GetData() *EventEventData

func (*EventCreatedEvent) HasData 

func (x *EventCreatedEvent) HasData() bool

func (*EventCreatedEvent) ProtoMessage 

func (*EventCreatedEvent) ProtoMessage()

func (*EventCreatedEvent) ProtoReflect 

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

func (*EventCreatedEvent) Reset 

func (x *EventCreatedEvent) Reset()

func (*EventCreatedEvent) SetData 

func (x *EventCreatedEvent) SetData(v *EventEventData)

func (*EventCreatedEvent) String 

func (x *EventCreatedEvent) String() string

type EventCreatedEvent_builder 

type EventCreatedEvent_builder struct {

	// The data associated with the event.
	Data *EventEventData
	// contains filtered or unexported fields
}

func (EventCreatedEvent_builder) Build 

func (b0 EventCreatedEvent_builder) Build() *EventCreatedEvent

type EventDeletedEvent 

type EventDeletedEvent struct {

	// The data associated with the event.
	Data *EventEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when an Event is deleted.

func (*EventDeletedEvent) ClearData 

func (x *EventDeletedEvent) ClearData()

func (*EventDeletedEvent) GetData 

func (x *EventDeletedEvent) GetData() *EventEventData

func (*EventDeletedEvent) HasData 

func (x *EventDeletedEvent) HasData() bool

func (*EventDeletedEvent) ProtoMessage 

func (*EventDeletedEvent) ProtoMessage()

func (*EventDeletedEvent) ProtoReflect 

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

func (*EventDeletedEvent) Reset 

func (x *EventDeletedEvent) Reset()

func (*EventDeletedEvent) SetData 

func (x *EventDeletedEvent) SetData(v *EventEventData)

func (*EventDeletedEvent) String 

func (x *EventDeletedEvent) String() string

type EventDeletedEvent_builder 

type EventDeletedEvent_builder struct {

	// The data associated with the event.
	Data *EventEventData
	// contains filtered or unexported fields
}

func (EventDeletedEvent_builder) Build 

func (b0 EventDeletedEvent_builder) Build() *EventDeletedEvent

type EventEventData 

type EventEventData struct {

	// Optional. The Event event payload. Unset for deletion events.
	Payload *Event `protobuf:"bytes,1,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The data within all Event events.

func (*EventEventData) ClearPayload 

func (x *EventEventData) ClearPayload()

func (*EventEventData) GetPayload 

func (x *EventEventData) GetPayload() *Event

func (*EventEventData) HasPayload 

func (x *EventEventData) HasPayload() bool

func (*EventEventData) ProtoMessage 

func (*EventEventData) ProtoMessage()

func (*EventEventData) ProtoReflect 

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

func (*EventEventData) Reset 

func (x *EventEventData) Reset()

func (*EventEventData) SetPayload 

func (x *EventEventData) SetPayload(v *Event)

func (*EventEventData) String 

func (x *EventEventData) String() string

type EventEventData_builder 

type EventEventData_builder struct {

	// Optional. The Event event payload. Unset for deletion events.
	Payload *Event
	// contains filtered or unexported fields
}

func (EventEventData_builder) Build 

func (b0 EventEventData_builder) Build() *EventEventData

type EventUpdatedEvent 

type EventUpdatedEvent struct {

	// The data associated with the event.
	Data *EventEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when an Event is updated.

func (*EventUpdatedEvent) ClearData 

func (x *EventUpdatedEvent) ClearData()

func (*EventUpdatedEvent) GetData 

func (x *EventUpdatedEvent) GetData() *EventEventData

func (*EventUpdatedEvent) HasData 

func (x *EventUpdatedEvent) HasData() bool

func (*EventUpdatedEvent) ProtoMessage 

func (*EventUpdatedEvent) ProtoMessage()

func (*EventUpdatedEvent) ProtoReflect 

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

func (*EventUpdatedEvent) Reset 

func (x *EventUpdatedEvent) Reset()

func (*EventUpdatedEvent) SetData 

func (x *EventUpdatedEvent) SetData(v *EventEventData)

func (*EventUpdatedEvent) String 

func (x *EventUpdatedEvent) String() string

type EventUpdatedEvent_builder 

type EventUpdatedEvent_builder struct {

	// The data associated with the event.
	Data *EventEventData
	// contains filtered or unexported fields
}

func (EventUpdatedEvent_builder) Build 

func (b0 EventUpdatedEvent_builder) Build() *EventUpdatedEvent

type Event_Clock 

type Event_Clock int32

Clock that will be used for joining streams. 

const (
	// Clock is not specified.
	Event_CLOCK_UNSPECIFIED Event_Clock = 0
	// Use the timestamp when the data is captured. Clients need to sync the
	// clock.
	Event_CAPTURE Event_Clock = 1
	// Use the timestamp when the data is received.
	Event_INGEST Event_Clock = 2
)

func (Event_Clock) Descriptor 

func (Event_Clock) Descriptor() protoreflect.EnumDescriptor

func (Event_Clock) Enum 

func (x Event_Clock) Enum() *Event_Clock

func (Event_Clock) Number 

func (x Event_Clock) Number() protoreflect.EnumNumber

func (Event_Clock) String 

func (x Event_Clock) String() string

func (Event_Clock) Type 

func (Event_Clock) Type() protoreflect.EnumType

type Event_builder 

type Event_builder struct {

	// Name of the resource.
	Name string
	// Output only. The create timestamp.
	CreateTime *timestamppb.Timestamp
	// Output only. The update timestamp.
	UpdateTime *timestamppb.Timestamp
	// Labels as key value pairs.
	Labels map[string]string
	// Annotations to allow clients to store small amounts of arbitrary data.
	Annotations map[string]string
	// The clock used for joining streams.
	AlignmentClock Event_Clock
	// Grace period for cleaning up the event. This is the time the controller
	// waits for before deleting the event. During this period, if there is any
	// active channel on the event. The deletion of the event after grace_period
	// will be ignored.
	GracePeriod *durationpb.Duration
	// contains filtered or unexported fields
}

func (Event_builder) Build 

func (b0 Event_builder) Build() *Event

type GcsSource 

type GcsSource struct {

	// Required. References to a Google Cloud Storage paths.
	Uris []string `protobuf:"bytes,1,rep,name=uris,proto3" json:"uris,omitempty"`
	// contains filtered or unexported fields
}

The Google Cloud Storage location for the input content.

func (*GcsSource) GetUris 

func (x *GcsSource) GetUris() []string

func (*GcsSource) ProtoMessage 

func (*GcsSource) ProtoMessage()

func (*GcsSource) ProtoReflect 

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

func (*GcsSource) Reset 

func (x *GcsSource) Reset()

func (*GcsSource) SetUris 

func (x *GcsSource) SetUris(v []string)

func (*GcsSource) String 

func (x *GcsSource) String() string

type GcsSource_builder 

type GcsSource_builder struct {

	// Required. References to a Google Cloud Storage paths.
	Uris []string
	// contains filtered or unexported fields
}

func (GcsSource_builder) Build 

func (b0 GcsSource_builder) Build() *GcsSource

type GeneralObjectDetectionConfig 

type GeneralObjectDetectionConfig struct {
	// contains filtered or unexported fields
}

Message of configurations for General Object Detection processor.

func (*GeneralObjectDetectionConfig) ProtoMessage 

func (*GeneralObjectDetectionConfig) ProtoMessage()

func (*GeneralObjectDetectionConfig) ProtoReflect 

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

func (*GeneralObjectDetectionConfig) Reset 

func (x *GeneralObjectDetectionConfig) Reset()

func (*GeneralObjectDetectionConfig) String 

func (x *GeneralObjectDetectionConfig) String() string

type GeneralObjectDetectionConfig_builder 

type GeneralObjectDetectionConfig_builder struct {
	// contains filtered or unexported fields
}

func (GeneralObjectDetectionConfig_builder) Build 

func (b0 GeneralObjectDetectionConfig_builder) Build() *GeneralObjectDetectionConfig

type MachineSpec 

type MachineSpec struct {

	// Immutable. The type of the machine.
	//
	// See the [list of machine types supported for
	// prediction](https://cloud.google.com/vertex-ai/docs/predictions/configure-compute#machine-types)
	//
	// See the [list of machine types supported for custom
	// training](https://cloud.google.com/vertex-ai/docs/training/configure-compute#machine-types).
	//
	// For [DeployedModel][] this field is optional, and the default
	// value is `n1-standard-2`. For [BatchPredictionJob][] or as part of
	// [WorkerPoolSpec][] this field is required.
	MachineType string `protobuf:"bytes,1,opt,name=machine_type,json=machineType,proto3" json:"machine_type,omitempty"`
	// Immutable. The type of accelerator(s) that may be attached to the machine
	// as per
	// [accelerator_count][google.cloud.visionai.v1.MachineSpec.accelerator_count].
	AcceleratorType AcceleratorType `` /* 160-byte string literal not displayed */
	// The number of accelerators to attach to the machine.
	AcceleratorCount int32 `protobuf:"varint,3,opt,name=accelerator_count,json=acceleratorCount,proto3" json:"accelerator_count,omitempty"`
	// contains filtered or unexported fields
}

Specification of a single machine.

func (*MachineSpec) GetAcceleratorCount 

func (x *MachineSpec) GetAcceleratorCount() int32

func (*MachineSpec) GetAcceleratorType 

func (x *MachineSpec) GetAcceleratorType() AcceleratorType

func (*MachineSpec) GetMachineType 

func (x *MachineSpec) GetMachineType() string

func (*MachineSpec) ProtoMessage 

func (*MachineSpec) ProtoMessage()

func (*MachineSpec) ProtoReflect 

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

func (*MachineSpec) Reset 

func (x *MachineSpec) Reset()

func (*MachineSpec) SetAcceleratorCount 

func (x *MachineSpec) SetAcceleratorCount(v int32)

func (*MachineSpec) SetAcceleratorType 

func (x *MachineSpec) SetAcceleratorType(v AcceleratorType)

func (*MachineSpec) SetMachineType 

func (x *MachineSpec) SetMachineType(v string)

func (*MachineSpec) String 

func (x *MachineSpec) String() string

type MachineSpec_builder 

type MachineSpec_builder struct {

	// Immutable. The type of the machine.
	//
	// See the [list of machine types supported for
	// prediction](https://cloud.google.com/vertex-ai/docs/predictions/configure-compute#machine-types)
	//
	// See the [list of machine types supported for custom
	// training](https://cloud.google.com/vertex-ai/docs/training/configure-compute#machine-types).
	//
	// For [DeployedModel][] this field is optional, and the default
	// value is `n1-standard-2`. For [BatchPredictionJob][] or as part of
	// [WorkerPoolSpec][] this field is required.
	MachineType string
	// Immutable. The type of accelerator(s) that may be attached to the machine
	// as per
	// [accelerator_count][google.cloud.visionai.v1.MachineSpec.accelerator_count].
	AcceleratorType AcceleratorType
	// The number of accelerators to attach to the machine.
	AcceleratorCount int32
	// contains filtered or unexported fields
}

func (MachineSpec_builder) Build 

func (b0 MachineSpec_builder) Build() *MachineSpec

type MediaWarehouseConfig 

type MediaWarehouseConfig struct {

	// Resource name of the Media Warehouse corpus.
	// Format:
	// projects/${project_id}/locations/${location_id}/corpora/${corpus_id}
	Corpus string `protobuf:"bytes,1,opt,name=corpus,proto3" json:"corpus,omitempty"`
	// Deprecated.
	Region string `protobuf:"bytes,2,opt,name=region,proto3" json:"region,omitempty"`
	// The duration for which all media assets, associated metadata, and search
	// documents can exist.
	Ttl *durationpb.Duration `protobuf:"bytes,3,opt,name=ttl,proto3" json:"ttl,omitempty"`
	// contains filtered or unexported fields
}

Message describing MediaWarehouseConfig.

func (*MediaWarehouseConfig) ClearTtl 

func (x *MediaWarehouseConfig) ClearTtl()

func (*MediaWarehouseConfig) GetCorpus 

func (x *MediaWarehouseConfig) GetCorpus() string

func (*MediaWarehouseConfig) GetRegion 

func (x *MediaWarehouseConfig) GetRegion() string

func (*MediaWarehouseConfig) GetTtl 

func (x *MediaWarehouseConfig) GetTtl() *durationpb.Duration

func (*MediaWarehouseConfig) HasTtl 

func (x *MediaWarehouseConfig) HasTtl() bool

func (*MediaWarehouseConfig) ProtoMessage 

func (*MediaWarehouseConfig) ProtoMessage()

func (*MediaWarehouseConfig) ProtoReflect 

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

func (*MediaWarehouseConfig) Reset 

func (x *MediaWarehouseConfig) Reset()

func (*MediaWarehouseConfig) SetCorpus 

func (x *MediaWarehouseConfig) SetCorpus(v string)

func (*MediaWarehouseConfig) SetRegion 

func (x *MediaWarehouseConfig) SetRegion(v string)

func (*MediaWarehouseConfig) SetTtl 

func (x *MediaWarehouseConfig) SetTtl(v *durationpb.Duration)

func (*MediaWarehouseConfig) String 

func (x *MediaWarehouseConfig) String() string

type MediaWarehouseConfig_builder 

type MediaWarehouseConfig_builder struct {

	// Resource name of the Media Warehouse corpus.
	// Format:
	// projects/${project_id}/locations/${location_id}/corpora/${corpus_id}
	Corpus string
	// Deprecated.
	Region string
	// The duration for which all media assets, associated metadata, and search
	// documents can exist.
	Ttl *durationpb.Duration
	// contains filtered or unexported fields
}

func (MediaWarehouseConfig_builder) Build 

func (b0 MediaWarehouseConfig_builder) Build() *MediaWarehouseConfig

type ModelType 

type ModelType int32

All the supported model types in Vision AI App Platform. 

const (
	// Processor Type UNSPECIFIED.
	ModelType_MODEL_TYPE_UNSPECIFIED ModelType = 0
	// Model Type Image Classification.
	ModelType_IMAGE_CLASSIFICATION ModelType = 1
	// Model Type Object Detection.
	ModelType_OBJECT_DETECTION ModelType = 2
	// Model Type Video Classification.
	ModelType_VIDEO_CLASSIFICATION ModelType = 3
	// Model Type Object Tracking.
	ModelType_VIDEO_OBJECT_TRACKING ModelType = 4
	// Model Type Action Recognition.
	ModelType_VIDEO_ACTION_RECOGNITION ModelType = 5
	// Model Type Occupancy Counting.
	ModelType_OCCUPANCY_COUNTING ModelType = 6
	// Model Type Person Blur.
	ModelType_PERSON_BLUR ModelType = 7
	// Model Type Vertex Custom.
	ModelType_VERTEX_CUSTOM ModelType = 8
)

func (ModelType) Descriptor 

func (ModelType) Descriptor() protoreflect.EnumDescriptor

func (ModelType) Enum 

func (x ModelType) Enum() *ModelType

func (ModelType) Number 

func (x ModelType) Number() protoreflect.EnumNumber

func (ModelType) String 

func (x ModelType) String() string

func (ModelType) Type 

func (ModelType) Type() protoreflect.EnumType

type Node 

type Node struct {

	// Types that are valid to be assigned to StreamOutputConfig:
	//
	//	*Node_OutputAllOutputChannelsToStream
	StreamOutputConfig isNode_StreamOutputConfig `protobuf_oneof:"stream_output_config"`
	// Required. A unique name for the node.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// A user friendly display name for the node.
	DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Node config.
	NodeConfig *ProcessorConfig `protobuf:"bytes,3,opt,name=node_config,json=nodeConfig,proto3" json:"node_config,omitempty"`
	// Processor name refer to the chosen processor resource.
	Processor string `protobuf:"bytes,4,opt,name=processor,proto3" json:"processor,omitempty"`
	// Parent node. Input node should not have parent node. For V1 Alpha1/Beta
	// only media warehouse node can have multiple parents, other types of nodes
	// will only have one parent.
	Parents []*Node_InputEdge `protobuf:"bytes,5,rep,name=parents,proto3" json:"parents,omitempty"`
	// contains filtered or unexported fields
}

Message describing node object.

func (*Node) ClearNodeConfig 

func (x *Node) ClearNodeConfig()

func (*Node) ClearOutputAllOutputChannelsToStream 

func (x *Node) ClearOutputAllOutputChannelsToStream()

func (*Node) ClearStreamOutputConfig 

func (x *Node) ClearStreamOutputConfig()

func (*Node) GetDisplayName 

func (x *Node) GetDisplayName() string

func (*Node) GetName 

func (x *Node) GetName() string

func (*Node) GetNodeConfig 

func (x *Node) GetNodeConfig() *ProcessorConfig

func (*Node) GetOutputAllOutputChannelsToStream 

func (x *Node) GetOutputAllOutputChannelsToStream() bool

func (*Node) GetParents 

func (x *Node) GetParents() []*Node_InputEdge

func (*Node) GetProcessor 

func (x *Node) GetProcessor() string

func (*Node) GetStreamOutputConfig 

func (x *Node) GetStreamOutputConfig() isNode_StreamOutputConfig

func (*Node) HasNodeConfig 

func (x *Node) HasNodeConfig() bool

func (*Node) HasOutputAllOutputChannelsToStream 

func (x *Node) HasOutputAllOutputChannelsToStream() bool

func (*Node) HasStreamOutputConfig 

func (x *Node) HasStreamOutputConfig() bool

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) ProtoReflect 

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

func (*Node) Reset 

func (x *Node) Reset()

func (*Node) SetDisplayName 

func (x *Node) SetDisplayName(v string)

func (*Node) SetName 

func (x *Node) SetName(v string)

func (*Node) SetNodeConfig 

func (x *Node) SetNodeConfig(v *ProcessorConfig)

func (*Node) SetOutputAllOutputChannelsToStream 

func (x *Node) SetOutputAllOutputChannelsToStream(v bool)

func (*Node) SetParents 

func (x *Node) SetParents(v []*Node_InputEdge)

func (*Node) SetProcessor 

func (x *Node) SetProcessor(v string)

func (*Node) String 

func (x *Node) String() string

func (*Node) WhichStreamOutputConfig 

func (x *Node) WhichStreamOutputConfig() case_Node_StreamOutputConfig

type Node_InputEdge 

type Node_InputEdge struct {

	// The name of the parent node.
	ParentNode string `protobuf:"bytes,1,opt,name=parent_node,json=parentNode,proto3" json:"parent_node,omitempty"`
	// The connected output artifact of the parent node.
	// It can be omitted if target processor only has 1 output artifact.
	ParentOutputChannel string `protobuf:"bytes,2,opt,name=parent_output_channel,json=parentOutputChannel,proto3" json:"parent_output_channel,omitempty"`
	// The connected input channel of the current node's processor.
	// It can be omitted if target processor only has 1 input channel.
	ConnectedInputChannel string `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

Message describing one edge pointing into a node.

func (*Node_InputEdge) GetConnectedInputChannel 

func (x *Node_InputEdge) GetConnectedInputChannel() string

func (*Node_InputEdge) GetParentNode 

func (x *Node_InputEdge) GetParentNode() string

func (*Node_InputEdge) GetParentOutputChannel 

func (x *Node_InputEdge) GetParentOutputChannel() string

func (*Node_InputEdge) ProtoMessage 

func (*Node_InputEdge) ProtoMessage()

func (*Node_InputEdge) ProtoReflect 

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

func (*Node_InputEdge) Reset 

func (x *Node_InputEdge) Reset()

func (*Node_InputEdge) SetConnectedInputChannel 

func (x *Node_InputEdge) SetConnectedInputChannel(v string)

func (*Node_InputEdge) SetParentNode 

func (x *Node_InputEdge) SetParentNode(v string)

func (*Node_InputEdge) SetParentOutputChannel 

func (x *Node_InputEdge) SetParentOutputChannel(v string)

func (*Node_InputEdge) String 

func (x *Node_InputEdge) String() string

type Node_InputEdge_builder 

type Node_InputEdge_builder struct {

	// The name of the parent node.
	ParentNode string
	// The connected output artifact of the parent node.
	// It can be omitted if target processor only has 1 output artifact.
	ParentOutputChannel string
	// The connected input channel of the current node's processor.
	// It can be omitted if target processor only has 1 input channel.
	ConnectedInputChannel string
	// contains filtered or unexported fields
}

func (Node_InputEdge_builder) Build 

func (b0 Node_InputEdge_builder) Build() *Node_InputEdge

type Node_OutputAllOutputChannelsToStream 

type Node_OutputAllOutputChannelsToStream struct {
	// By default, the output of the node will only be available to downstream
	// nodes. To consume the direct output from the application node, the output
	// must be sent to Vision AI Streams at first.
	//
	// By setting output_all_output_channels_to_stream to true, App Platform
	// will automatically send all the outputs of the current node to Vision AI
	// Stream resources (one stream per output channel). The output stream
	// resource will be created by App Platform automatically during deployment
	// and deleted after application un-deployment.
	// Note that this config applies to all the Application Instances.
	//
	// The output stream can be override at instance level by
	// configuring the `output_resources` section of Instance resource.
	// `producer_node` should be current node, `output_resource_binding` should
	// be the output channel name (or leave it blank if there is only 1 output
	// channel of the processor) and `output_resource` should be the target
	// output stream.
	OutputAllOutputChannelsToStream bool `protobuf:"varint,6,opt,name=output_all_output_channels_to_stream,json=outputAllOutputChannelsToStream,proto3,oneof"`
}

type Node_builder 

type Node_builder struct {

	// Fields of oneof StreamOutputConfig:
	// By default, the output of the node will only be available to downstream
	// nodes. To consume the direct output from the application node, the output
	// must be sent to Vision AI Streams at first.
	//
	// By setting output_all_output_channels_to_stream to true, App Platform
	// will automatically send all the outputs of the current node to Vision AI
	// Stream resources (one stream per output channel). The output stream
	// resource will be created by App Platform automatically during deployment
	// and deleted after application un-deployment.
	// Note that this config applies to all the Application Instances.
	//
	// The output stream can be override at instance level by
	// configuring the `output_resources` section of Instance resource.
	// `producer_node` should be current node, `output_resource_binding` should
	// be the output channel name (or leave it blank if there is only 1 output
	// channel of the processor) and `output_resource` should be the target
	// output stream.
	OutputAllOutputChannelsToStream *bool
	// -- end of StreamOutputConfig
	// Required. A unique name for the node.
	Name string
	// A user friendly display name for the node.
	DisplayName string
	// Node config.
	NodeConfig *ProcessorConfig
	// Processor name refer to the chosen processor resource.
	Processor string
	// Parent node. Input node should not have parent node. For V1 Alpha1/Beta
	// only media warehouse node can have multiple parents, other types of nodes
	// will only have one parent.
	Parents []*Node_InputEdge
	// contains filtered or unexported fields
}

func (Node_builder) Build 

func (b0 Node_builder) Build() *Node

type NormalizedPolygon 

type NormalizedPolygon struct {

	// The bounding polygon normalized vertices. Top left corner of the image
	// will be [0, 0].
	NormalizedVertices []*NormalizedVertex `protobuf:"bytes,1,rep,name=normalized_vertices,json=normalizedVertices,proto3" json:"normalized_vertices,omitempty"`
	// contains filtered or unexported fields
}

Normalized Polygon.

func (*NormalizedPolygon) GetNormalizedVertices 

func (x *NormalizedPolygon) GetNormalizedVertices() []*NormalizedVertex

func (*NormalizedPolygon) ProtoMessage 

func (*NormalizedPolygon) ProtoMessage()

func (*NormalizedPolygon) ProtoReflect 

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

func (*NormalizedPolygon) Reset 

func (x *NormalizedPolygon) Reset()

func (*NormalizedPolygon) SetNormalizedVertices 

func (x *NormalizedPolygon) SetNormalizedVertices(v []*NormalizedVertex)

func (*NormalizedPolygon) String 

func (x *NormalizedPolygon) String() string

type NormalizedPolygon_builder 

type NormalizedPolygon_builder struct {

	// The bounding polygon normalized vertices. Top left corner of the image
	// will be [0, 0].
	NormalizedVertices []*NormalizedVertex
	// contains filtered or unexported fields
}

func (NormalizedPolygon_builder) Build 

func (b0 NormalizedPolygon_builder) Build() *NormalizedPolygon

type NormalizedPolyline 

type NormalizedPolyline struct {

	// A sequence of vertices connected by straight lines.
	NormalizedVertices []*NormalizedVertex `protobuf:"bytes,1,rep,name=normalized_vertices,json=normalizedVertices,proto3" json:"normalized_vertices,omitempty"`
	// contains filtered or unexported fields
}

Normalized Pplyline, which represents a curve consisting of connected straight-line segments.

func (*NormalizedPolyline) GetNormalizedVertices 

func (x *NormalizedPolyline) GetNormalizedVertices() []*NormalizedVertex

func (*NormalizedPolyline) ProtoMessage 

func (*NormalizedPolyline) ProtoMessage()

func (*NormalizedPolyline) ProtoReflect 

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

func (*NormalizedPolyline) Reset 

func (x *NormalizedPolyline) Reset()

func (*NormalizedPolyline) SetNormalizedVertices 

func (x *NormalizedPolyline) SetNormalizedVertices(v []*NormalizedVertex)

func (*NormalizedPolyline) String 

func (x *NormalizedPolyline) String() string

type NormalizedPolyline_builder 

type NormalizedPolyline_builder struct {

	// A sequence of vertices connected by straight lines.
	NormalizedVertices []*NormalizedVertex
	// contains filtered or unexported fields
}

func (NormalizedPolyline_builder) Build 

func (b0 NormalizedPolyline_builder) Build() *NormalizedPolyline

type NormalizedVertex 

type NormalizedVertex struct {

	// X coordinate.
	X float32 `protobuf:"fixed32,1,opt,name=x,proto3" json:"x,omitempty"`
	// Y coordinate.
	Y float32 `protobuf:"fixed32,2,opt,name=y,proto3" json:"y,omitempty"`
	// contains filtered or unexported fields
}

A vertex represents a 2D point in the image. NOTE: the normalized vertex coordinates are relative to the original image and range from 0 to 1.

func (*NormalizedVertex) GetX 

func (x *NormalizedVertex) GetX() float32

func (*NormalizedVertex) GetY 

func (x *NormalizedVertex) GetY() float32

func (*NormalizedVertex) ProtoMessage 

func (*NormalizedVertex) ProtoMessage()

func (*NormalizedVertex) ProtoReflect 

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

func (*NormalizedVertex) Reset 

func (x *NormalizedVertex) Reset()

func (*NormalizedVertex) SetX 

func (x *NormalizedVertex) SetX(v float32)

func (*NormalizedVertex) SetY 

func (x *NormalizedVertex) SetY(v float32)

func (*NormalizedVertex) String 

func (x *NormalizedVertex) String() string

type NormalizedVertex_builder 

type NormalizedVertex_builder struct {

	// X coordinate.
	X float32
	// Y coordinate.
	Y float32
	// contains filtered or unexported fields
}

func (NormalizedVertex_builder) Build 

func (b0 NormalizedVertex_builder) Build() *NormalizedVertex

type OccupancyCountConfig 

type OccupancyCountConfig struct {

	// Whether to count the appearances of people, output counts have 'people' as
	// the key.
	EnablePeopleCounting bool `protobuf:"varint,1,opt,name=enable_people_counting,json=enablePeopleCounting,proto3" json:"enable_people_counting,omitempty"`
	// Whether to count the appearances of vehicles, output counts will have
	// 'vehicle' as the key.
	EnableVehicleCounting bool `` /* 127-byte string literal not displayed */
	// Whether to track each invidual object's loitering time inside the scene or
	// specific zone.
	EnableDwellingTimeTracking bool `` /* 144-byte string literal not displayed */
	// contains filtered or unexported fields
}

Message describing OccupancyCountConfig.

func (*OccupancyCountConfig) GetEnableDwellingTimeTracking 

func (x *OccupancyCountConfig) GetEnableDwellingTimeTracking() bool

func (*OccupancyCountConfig) GetEnablePeopleCounting 

func (x *OccupancyCountConfig) GetEnablePeopleCounting() bool

func (*OccupancyCountConfig) GetEnableVehicleCounting 

func (x *OccupancyCountConfig) GetEnableVehicleCounting() bool

func (*OccupancyCountConfig) ProtoMessage 

func (*OccupancyCountConfig) ProtoMessage()

func (*OccupancyCountConfig) ProtoReflect 

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

func (*OccupancyCountConfig) Reset 

func (x *OccupancyCountConfig) Reset()

func (*OccupancyCountConfig) SetEnableDwellingTimeTracking 

func (x *OccupancyCountConfig) SetEnableDwellingTimeTracking(v bool)

func (*OccupancyCountConfig) SetEnablePeopleCounting 

func (x *OccupancyCountConfig) SetEnablePeopleCounting(v bool)

func (*OccupancyCountConfig) SetEnableVehicleCounting 

func (x *OccupancyCountConfig) SetEnableVehicleCounting(v bool)

func (*OccupancyCountConfig) String 

func (x *OccupancyCountConfig) String() string

type OccupancyCountConfig_builder 

type OccupancyCountConfig_builder struct {

	// Whether to count the appearances of people, output counts have 'people' as
	// the key.
	EnablePeopleCounting bool
	// Whether to count the appearances of vehicles, output counts will have
	// 'vehicle' as the key.
	EnableVehicleCounting bool
	// Whether to track each invidual object's loitering time inside the scene or
	// specific zone.
	EnableDwellingTimeTracking bool
	// contains filtered or unexported fields
}

func (OccupancyCountConfig_builder) Build 

func (b0 OccupancyCountConfig_builder) Build() *OccupancyCountConfig

type PersonBlurConfig 

type PersonBlurConfig struct {

	// Person blur type.
	PersonBlurType PersonBlurConfig_PersonBlurType `` /* 175-byte string literal not displayed */
	// Whether only blur faces other than the whole object in the processor.
	FacesOnly bool `protobuf:"varint,2,opt,name=faces_only,json=facesOnly,proto3" json:"faces_only,omitempty"`
	// contains filtered or unexported fields
}

Message describing FaceBlurConfig.

func (*PersonBlurConfig) GetFacesOnly 

func (x *PersonBlurConfig) GetFacesOnly() bool

func (*PersonBlurConfig) GetPersonBlurType 

func (x *PersonBlurConfig) GetPersonBlurType() PersonBlurConfig_PersonBlurType

func (*PersonBlurConfig) ProtoMessage 

func (*PersonBlurConfig) ProtoMessage()

func (*PersonBlurConfig) ProtoReflect 

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

func (*PersonBlurConfig) Reset 

func (x *PersonBlurConfig) Reset()

func (*PersonBlurConfig) SetFacesOnly 

func (x *PersonBlurConfig) SetFacesOnly(v bool)

func (*PersonBlurConfig) SetPersonBlurType 

func (x *PersonBlurConfig) SetPersonBlurType(v PersonBlurConfig_PersonBlurType)

func (*PersonBlurConfig) String 

func (x *PersonBlurConfig) String() string

type PersonBlurConfig_PersonBlurType 

type PersonBlurConfig_PersonBlurType int32

Type of Person Blur 

const (
	// PersonBlur Type UNSPECIFIED.
	PersonBlurConfig_PERSON_BLUR_TYPE_UNSPECIFIED PersonBlurConfig_PersonBlurType = 0
	// FaceBlur Type full occlusion.
	PersonBlurConfig_FULL_OCCULUSION PersonBlurConfig_PersonBlurType = 1
	// FaceBlur Type blur filter.
	PersonBlurConfig_BLUR_FILTER PersonBlurConfig_PersonBlurType = 2
)

func (PersonBlurConfig_PersonBlurType) Descriptor 

func (PersonBlurConfig_PersonBlurType) Descriptor() protoreflect.EnumDescriptor

func (PersonBlurConfig_PersonBlurType) Enum 

func (x PersonBlurConfig_PersonBlurType) Enum() *PersonBlurConfig_PersonBlurType

func (PersonBlurConfig_PersonBlurType) Number 

func (x PersonBlurConfig_PersonBlurType) Number() protoreflect.EnumNumber

func (PersonBlurConfig_PersonBlurType) String 

func (x PersonBlurConfig_PersonBlurType) String() string

func (PersonBlurConfig_PersonBlurType) Type 

func (PersonBlurConfig_PersonBlurType) Type() protoreflect.EnumType

type PersonBlurConfig_builder 

type PersonBlurConfig_builder struct {

	// Person blur type.
	PersonBlurType PersonBlurConfig_PersonBlurType
	// Whether only blur faces other than the whole object in the processor.
	FacesOnly bool
	// contains filtered or unexported fields
}

func (PersonBlurConfig_builder) Build 

func (b0 PersonBlurConfig_builder) Build() *PersonBlurConfig

type PersonVehicleDetectionConfig 

type PersonVehicleDetectionConfig struct {

	// At least one of enable_people_counting and enable_vehicle_counting fields
	// must be set to true.
	// Whether to count the appearances of people, output counts have 'people' as
	// the key.
	EnablePeopleCounting bool `protobuf:"varint,1,opt,name=enable_people_counting,json=enablePeopleCounting,proto3" json:"enable_people_counting,omitempty"`
	// Whether to count the appearances of vehicles, output counts will have
	// 'vehicle' as the key.
	EnableVehicleCounting bool `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

Message describing PersonVehicleDetectionConfig.

func (*PersonVehicleDetectionConfig) GetEnablePeopleCounting 

func (x *PersonVehicleDetectionConfig) GetEnablePeopleCounting() bool

func (*PersonVehicleDetectionConfig) GetEnableVehicleCounting 

func (x *PersonVehicleDetectionConfig) GetEnableVehicleCounting() bool

func (*PersonVehicleDetectionConfig) ProtoMessage 

func (*PersonVehicleDetectionConfig) ProtoMessage()

func (*PersonVehicleDetectionConfig) ProtoReflect 

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

func (*PersonVehicleDetectionConfig) Reset 

func (x *PersonVehicleDetectionConfig) Reset()

func (*PersonVehicleDetectionConfig) SetEnablePeopleCounting 

func (x *PersonVehicleDetectionConfig) SetEnablePeopleCounting(v bool)

func (*PersonVehicleDetectionConfig) SetEnableVehicleCounting 

func (x *PersonVehicleDetectionConfig) SetEnableVehicleCounting(v bool)

func (*PersonVehicleDetectionConfig) String 

func (x *PersonVehicleDetectionConfig) String() string

type PersonVehicleDetectionConfig_builder 

type PersonVehicleDetectionConfig_builder struct {

	// At least one of enable_people_counting and enable_vehicle_counting fields
	// must be set to true.
	// Whether to count the appearances of people, output counts have 'people' as
	// the key.
	EnablePeopleCounting bool
	// Whether to count the appearances of vehicles, output counts will have
	// 'vehicle' as the key.
	EnableVehicleCounting bool
	// contains filtered or unexported fields
}

func (PersonVehicleDetectionConfig_builder) Build 

func (b0 PersonVehicleDetectionConfig_builder) Build() *PersonVehicleDetectionConfig

type PersonalProtectiveEquipmentDetectionConfig 

type PersonalProtectiveEquipmentDetectionConfig struct {

	// Whether to enable face coverage detection.
	EnableFaceCoverageDetection bool `` /* 147-byte string literal not displayed */
	// Whether to enable head coverage detection.
	EnableHeadCoverageDetection bool `` /* 147-byte string literal not displayed */
	// Whether to enable hands coverage detection.
	EnableHandsCoverageDetection bool `` /* 150-byte string literal not displayed */
	// contains filtered or unexported fields
}

Message describing PersonalProtectiveEquipmentDetectionConfig.

func (*PersonalProtectiveEquipmentDetectionConfig) GetEnableFaceCoverageDetection 

func (x *PersonalProtectiveEquipmentDetectionConfig) GetEnableFaceCoverageDetection() bool

func (*PersonalProtectiveEquipmentDetectionConfig) GetEnableHandsCoverageDetection 

func (x *PersonalProtectiveEquipmentDetectionConfig) GetEnableHandsCoverageDetection() bool

func (*PersonalProtectiveEquipmentDetectionConfig) GetEnableHeadCoverageDetection 

func (x *PersonalProtectiveEquipmentDetectionConfig) GetEnableHeadCoverageDetection() bool

func (*PersonalProtectiveEquipmentDetectionConfig) ProtoMessage 

func (*PersonalProtectiveEquipmentDetectionConfig) ProtoMessage()

func (*PersonalProtectiveEquipmentDetectionConfig) ProtoReflect 

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

func (*PersonalProtectiveEquipmentDetectionConfig) Reset 

func (x *PersonalProtectiveEquipmentDetectionConfig) Reset()

func (*PersonalProtectiveEquipmentDetectionConfig) SetEnableFaceCoverageDetection 

func (x *PersonalProtectiveEquipmentDetectionConfig) SetEnableFaceCoverageDetection(v bool)

func (*PersonalProtectiveEquipmentDetectionConfig) SetEnableHandsCoverageDetection 

func (x *PersonalProtectiveEquipmentDetectionConfig) SetEnableHandsCoverageDetection(v bool)

func (*PersonalProtectiveEquipmentDetectionConfig) SetEnableHeadCoverageDetection 

func (x *PersonalProtectiveEquipmentDetectionConfig) SetEnableHeadCoverageDetection(v bool)

func (*PersonalProtectiveEquipmentDetectionConfig) String 

func (x *PersonalProtectiveEquipmentDetectionConfig) String() string

type PersonalProtectiveEquipmentDetectionConfig_builder 

type PersonalProtectiveEquipmentDetectionConfig_builder struct {

	// Whether to enable face coverage detection.
	EnableFaceCoverageDetection bool
	// Whether to enable head coverage detection.
	EnableHeadCoverageDetection bool
	// Whether to enable hands coverage detection.
	EnableHandsCoverageDetection bool
	// contains filtered or unexported fields
}

func (PersonalProtectiveEquipmentDetectionConfig_builder) Build 

func (b0 PersonalProtectiveEquipmentDetectionConfig_builder) Build() *PersonalProtectiveEquipmentDetectionConfig

type Process 

type Process struct {

	// The name of resource.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. The create timestamp.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The update timestamp.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Required. Reference to an existing Analysis resource.
	Analysis string `protobuf:"bytes,4,opt,name=analysis,proto3" json:"analysis,omitempty"`
	// Optional. Attribute overrides of the Analyzers.
	// Format for each single override item:
	// "{analyzer_name}:{attribute_key}={value}"
	AttributeOverrides []string `protobuf:"bytes,5,rep,name=attribute_overrides,json=attributeOverrides,proto3" json:"attribute_overrides,omitempty"`
	// Optional. Status of the Process.
	RunStatus *RunStatus `protobuf:"bytes,6,opt,name=run_status,json=runStatus,proto3" json:"run_status,omitempty"`
	// Optional. Run mode of the Process.
	RunMode RunMode `` /* 128-byte string literal not displayed */
	// Optional. Event ID of the input/output streams.
	// This is useful when you have a StreamSource/StreamSink operator in the
	// Analysis, and you want to manually specify the Event to read from/write to.
	EventId string `protobuf:"bytes,8,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	// Optional. Optional: Batch ID of the Process.
	BatchId string `protobuf:"bytes,9,opt,name=batch_id,json=batchId,proto3" json:"batch_id,omitempty"`
	// Optional. Optional: The number of retries for a process in submission mode
	// the system should try before declaring failure. By default, no retry will
	// be performed.
	RetryCount int32 `protobuf:"varint,10,opt,name=retry_count,json=retryCount,proto3" json:"retry_count,omitempty"`
	// contains filtered or unexported fields
}

Message describing the Process object.

func (*Process) ClearCreateTime 

func (x *Process) ClearCreateTime()

func (*Process) ClearRunStatus 

func (x *Process) ClearRunStatus()

func (*Process) ClearUpdateTime 

func (x *Process) ClearUpdateTime()

func (*Process) GetAnalysis 

func (x *Process) GetAnalysis() string

func (*Process) GetAttributeOverrides 

func (x *Process) GetAttributeOverrides() []string

func (*Process) GetBatchId 

func (x *Process) GetBatchId() string

func (*Process) GetCreateTime 

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

func (*Process) GetEventId 

func (x *Process) GetEventId() string

func (*Process) GetName 

func (x *Process) GetName() string

func (*Process) GetRetryCount 

func (x *Process) GetRetryCount() int32

func (*Process) GetRunMode 

func (x *Process) GetRunMode() RunMode

func (*Process) GetRunStatus 

func (x *Process) GetRunStatus() *RunStatus

func (*Process) GetUpdateTime 

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

func (*Process) HasCreateTime 

func (x *Process) HasCreateTime() bool

func (*Process) HasRunStatus 

func (x *Process) HasRunStatus() bool

func (*Process) HasUpdateTime 

func (x *Process) HasUpdateTime() bool

func (*Process) ProtoMessage 

func (*Process) ProtoMessage()

func (*Process) ProtoReflect 

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

func (*Process) Reset 

func (x *Process) Reset()

func (*Process) SetAnalysis 

func (x *Process) SetAnalysis(v string)

func (*Process) SetAttributeOverrides 

func (x *Process) SetAttributeOverrides(v []string)

func (*Process) SetBatchId 

func (x *Process) SetBatchId(v string)

func (*Process) SetCreateTime 

func (x *Process) SetCreateTime(v *timestamppb.Timestamp)

func (*Process) SetEventId 

func (x *Process) SetEventId(v string)

func (*Process) SetName 

func (x *Process) SetName(v string)

func (*Process) SetRetryCount 

func (x *Process) SetRetryCount(v int32)

func (*Process) SetRunMode 

func (x *Process) SetRunMode(v RunMode)

func (*Process) SetRunStatus 

func (x *Process) SetRunStatus(v *RunStatus)

func (*Process) SetUpdateTime 

func (x *Process) SetUpdateTime(v *timestamppb.Timestamp)

func (*Process) String 

func (x *Process) String() string

type ProcessCreatedEvent 

type ProcessCreatedEvent struct {

	// The data associated with the event.
	Data *ProcessEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Process is created.

func (*ProcessCreatedEvent) ClearData 

func (x *ProcessCreatedEvent) ClearData()

func (*ProcessCreatedEvent) GetData 

func (x *ProcessCreatedEvent) GetData() *ProcessEventData

func (*ProcessCreatedEvent) HasData 

func (x *ProcessCreatedEvent) HasData() bool

func (*ProcessCreatedEvent) ProtoMessage 

func (*ProcessCreatedEvent) ProtoMessage()

func (*ProcessCreatedEvent) ProtoReflect 

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

func (*ProcessCreatedEvent) Reset 

func (x *ProcessCreatedEvent) Reset()

func (*ProcessCreatedEvent) SetData 

func (x *ProcessCreatedEvent) SetData(v *ProcessEventData)

func (*ProcessCreatedEvent) String 

func (x *ProcessCreatedEvent) String() string

type ProcessCreatedEvent_builder 

type ProcessCreatedEvent_builder struct {

	// The data associated with the event.
	Data *ProcessEventData
	// contains filtered or unexported fields
}

func (ProcessCreatedEvent_builder) Build 

func (b0 ProcessCreatedEvent_builder) Build() *ProcessCreatedEvent

type ProcessDeletedEvent 

type ProcessDeletedEvent struct {

	// The data associated with the event.
	Data *ProcessEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Process is deleted.

func (*ProcessDeletedEvent) ClearData 

func (x *ProcessDeletedEvent) ClearData()

func (*ProcessDeletedEvent) GetData 

func (x *ProcessDeletedEvent) GetData() *ProcessEventData

func (*ProcessDeletedEvent) HasData 

func (x *ProcessDeletedEvent) HasData() bool

func (*ProcessDeletedEvent) ProtoMessage 

func (*ProcessDeletedEvent) ProtoMessage()

func (*ProcessDeletedEvent) ProtoReflect 

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

func (*ProcessDeletedEvent) Reset 

func (x *ProcessDeletedEvent) Reset()

func (*ProcessDeletedEvent) SetData 

func (x *ProcessDeletedEvent) SetData(v *ProcessEventData)

func (*ProcessDeletedEvent) String 

func (x *ProcessDeletedEvent) String() string

type ProcessDeletedEvent_builder 

type ProcessDeletedEvent_builder struct {

	// The data associated with the event.
	Data *ProcessEventData
	// contains filtered or unexported fields
}

func (ProcessDeletedEvent_builder) Build 

func (b0 ProcessDeletedEvent_builder) Build() *ProcessDeletedEvent

type ProcessEventData 

type ProcessEventData struct {

	// Optional. The Process event payload. Unset for deletion events.
	Payload *Process `protobuf:"bytes,1,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The data within all Process events.

func (*ProcessEventData) ClearPayload 

func (x *ProcessEventData) ClearPayload()

func (*ProcessEventData) GetPayload 

func (x *ProcessEventData) GetPayload() *Process

func (*ProcessEventData) HasPayload 

func (x *ProcessEventData) HasPayload() bool

func (*ProcessEventData) ProtoMessage 

func (*ProcessEventData) ProtoMessage()

func (*ProcessEventData) ProtoReflect 

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

func (*ProcessEventData) Reset 

func (x *ProcessEventData) Reset()

func (*ProcessEventData) SetPayload 

func (x *ProcessEventData) SetPayload(v *Process)

func (*ProcessEventData) String 

func (x *ProcessEventData) String() string

type ProcessEventData_builder 

type ProcessEventData_builder struct {

	// Optional. The Process event payload. Unset for deletion events.
	Payload *Process
	// contains filtered or unexported fields
}

func (ProcessEventData_builder) Build 

func (b0 ProcessEventData_builder) Build() *ProcessEventData

type ProcessUpdatedEvent 

type ProcessUpdatedEvent struct {

	// The data associated with the event.
	Data *ProcessEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Process is updated.

func (*ProcessUpdatedEvent) ClearData 

func (x *ProcessUpdatedEvent) ClearData()

func (*ProcessUpdatedEvent) GetData 

func (x *ProcessUpdatedEvent) GetData() *ProcessEventData

func (*ProcessUpdatedEvent) HasData 

func (x *ProcessUpdatedEvent) HasData() bool

func (*ProcessUpdatedEvent) ProtoMessage 

func (*ProcessUpdatedEvent) ProtoMessage()

func (*ProcessUpdatedEvent) ProtoReflect 

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

func (*ProcessUpdatedEvent) Reset 

func (x *ProcessUpdatedEvent) Reset()

func (*ProcessUpdatedEvent) SetData 

func (x *ProcessUpdatedEvent) SetData(v *ProcessEventData)

func (*ProcessUpdatedEvent) String 

func (x *ProcessUpdatedEvent) String() string

type ProcessUpdatedEvent_builder 

type ProcessUpdatedEvent_builder struct {

	// The data associated with the event.
	Data *ProcessEventData
	// contains filtered or unexported fields
}

func (ProcessUpdatedEvent_builder) Build 

func (b0 ProcessUpdatedEvent_builder) Build() *ProcessUpdatedEvent

type Process_builder 

type Process_builder struct {

	// The name of resource.
	Name string
	// Output only. The create timestamp.
	CreateTime *timestamppb.Timestamp
	// Output only. The update timestamp.
	UpdateTime *timestamppb.Timestamp
	// Required. Reference to an existing Analysis resource.
	Analysis string
	// Optional. Attribute overrides of the Analyzers.
	// Format for each single override item:
	// "{analyzer_name}:{attribute_key}={value}"
	AttributeOverrides []string
	// Optional. Status of the Process.
	RunStatus *RunStatus
	// Optional. Run mode of the Process.
	RunMode RunMode
	// Optional. Event ID of the input/output streams.
	// This is useful when you have a StreamSource/StreamSink operator in the
	// Analysis, and you want to manually specify the Event to read from/write to.
	EventId string
	// Optional. Optional: Batch ID of the Process.
	BatchId string
	// Optional. Optional: The number of retries for a process in submission mode
	// the system should try before declaring failure. By default, no retry will
	// be performed.
	RetryCount int32
	// contains filtered or unexported fields
}

func (Process_builder) Build 

func (b0 Process_builder) Build() *Process

type Processor 

type Processor struct {

	// name of resource.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. [Output only] Create timestamp.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. [Output only] Update timestamp.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Labels as key value pairs.
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// Required. A user friendly display name for the processor.
	DisplayName string `protobuf:"bytes,5,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Illustrative sentences for describing the functionality of the processor.
	Description string `protobuf:"bytes,10,opt,name=description,proto3" json:"description,omitempty"`
	// Output only. Processor Type.
	ProcessorType Processor_ProcessorType `` /* 162-byte string literal not displayed */
	// Model Type.
	ModelType ModelType `` /* 137-byte string literal not displayed */
	// Source info for customer created processor.
	CustomProcessorSourceInfo *CustomProcessorSourceInfo `` /* 140-byte string literal not displayed */
	// Output only. State of the Processor.
	State Processor_ProcessorState `` /* 126-byte string literal not displayed */
	// Output only. [Output only] The input / output specifications of a
	// processor, each type of processor has fixed input / output specs which
	// cannot be altered by customer.
	ProcessorIoSpec *ProcessorIOSpec `protobuf:"bytes,11,opt,name=processor_io_spec,json=processorIoSpec,proto3" json:"processor_io_spec,omitempty"`
	// Output only. The corresponding configuration can be used in the Application
	// to customize the behavior of the processor.
	ConfigurationTypeurl     string                 `protobuf:"bytes,14,opt,name=configuration_typeurl,json=configurationTypeurl,proto3" json:"configuration_typeurl,omitempty"`
	SupportedAnnotationTypes []StreamAnnotationType `` /* 202-byte string literal not displayed */
	// Indicates if the processor supports post processing.
	SupportsPostProcessing bool `` /* 131-byte string literal not displayed */
	// contains filtered or unexported fields
}

Message describing Processor object. Next ID: 19

func (*Processor) ClearCreateTime 

func (x *Processor) ClearCreateTime()

func (*Processor) ClearCustomProcessorSourceInfo 

func (x *Processor) ClearCustomProcessorSourceInfo()

func (*Processor) ClearProcessorIoSpec 

func (x *Processor) ClearProcessorIoSpec()

func (*Processor) ClearUpdateTime 

func (x *Processor) ClearUpdateTime()

func (*Processor) GetConfigurationTypeurl 

func (x *Processor) GetConfigurationTypeurl() string

func (*Processor) GetCreateTime 

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

func (*Processor) GetCustomProcessorSourceInfo 

func (x *Processor) GetCustomProcessorSourceInfo() *CustomProcessorSourceInfo

func (*Processor) GetDescription 

func (x *Processor) GetDescription() string

func (*Processor) GetDisplayName 

func (x *Processor) GetDisplayName() string

func (*Processor) GetLabels 

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

func (*Processor) GetModelType 

func (x *Processor) GetModelType() ModelType

func (*Processor) GetName 

func (x *Processor) GetName() string

func (*Processor) GetProcessorIoSpec 

func (x *Processor) GetProcessorIoSpec() *ProcessorIOSpec

func (*Processor) GetProcessorType 

func (x *Processor) GetProcessorType() Processor_ProcessorType

func (*Processor) GetState 

func (x *Processor) GetState() Processor_ProcessorState

func (*Processor) GetSupportedAnnotationTypes 

func (x *Processor) GetSupportedAnnotationTypes() []StreamAnnotationType

func (*Processor) GetSupportsPostProcessing 

func (x *Processor) GetSupportsPostProcessing() bool

func (*Processor) GetUpdateTime 

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

func (*Processor) HasCreateTime 

func (x *Processor) HasCreateTime() bool

func (*Processor) HasCustomProcessorSourceInfo 

func (x *Processor) HasCustomProcessorSourceInfo() bool

func (*Processor) HasProcessorIoSpec 

func (x *Processor) HasProcessorIoSpec() bool

func (*Processor) HasUpdateTime 

func (x *Processor) HasUpdateTime() bool

func (*Processor) ProtoMessage 

func (*Processor) ProtoMessage()

func (*Processor) ProtoReflect 

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

func (*Processor) Reset 

func (x *Processor) Reset()

func (*Processor) SetConfigurationTypeurl 

func (x *Processor) SetConfigurationTypeurl(v string)

func (*Processor) SetCreateTime 

func (x *Processor) SetCreateTime(v *timestamppb.Timestamp)

func (*Processor) SetCustomProcessorSourceInfo 

func (x *Processor) SetCustomProcessorSourceInfo(v *CustomProcessorSourceInfo)

func (*Processor) SetDescription 

func (x *Processor) SetDescription(v string)

func (*Processor) SetDisplayName 

func (x *Processor) SetDisplayName(v string)

func (*Processor) SetLabels 

func (x *Processor) SetLabels(v map[string]string)

func (*Processor) SetModelType 

func (x *Processor) SetModelType(v ModelType)

func (*Processor) SetName 

func (x *Processor) SetName(v string)

func (*Processor) SetProcessorIoSpec 

func (x *Processor) SetProcessorIoSpec(v *ProcessorIOSpec)

func (*Processor) SetProcessorType 

func (x *Processor) SetProcessorType(v Processor_ProcessorType)

func (*Processor) SetState 

func (x *Processor) SetState(v Processor_ProcessorState)

func (*Processor) SetSupportedAnnotationTypes 

func (x *Processor) SetSupportedAnnotationTypes(v []StreamAnnotationType)

func (*Processor) SetSupportsPostProcessing 

func (x *Processor) SetSupportsPostProcessing(v bool)

func (*Processor) SetUpdateTime 

func (x *Processor) SetUpdateTime(v *timestamppb.Timestamp)

func (*Processor) String 

func (x *Processor) String() string

type ProcessorConfig 

type ProcessorConfig struct {

	// Types that are valid to be assigned to ProcessorConfig:
	//
	//	*ProcessorConfig_VideoStreamInputConfig
	//	*ProcessorConfig_AiEnabledDevicesInputConfig
	//	*ProcessorConfig_MediaWarehouseConfig
	//	*ProcessorConfig_PersonBlurConfig
	//	*ProcessorConfig_OccupancyCountConfig
	//	*ProcessorConfig_PersonVehicleDetectionConfig
	//	*ProcessorConfig_VertexAutomlVisionConfig
	//	*ProcessorConfig_VertexAutomlVideoConfig
	//	*ProcessorConfig_VertexCustomConfig
	//	*ProcessorConfig_GeneralObjectDetectionConfig
	//	*ProcessorConfig_BigQueryConfig
	//	*ProcessorConfig_PersonalProtectiveEquipmentDetectionConfig
	ProcessorConfig isProcessorConfig_ProcessorConfig `protobuf_oneof:"processor_config"`
	// contains filtered or unexported fields
}

Next ID: 29

func (*ProcessorConfig) ClearAiEnabledDevicesInputConfig 

func (x *ProcessorConfig) ClearAiEnabledDevicesInputConfig()

func (*ProcessorConfig) ClearBigQueryConfig 

func (x *ProcessorConfig) ClearBigQueryConfig()

func (*ProcessorConfig) ClearGeneralObjectDetectionConfig 

func (x *ProcessorConfig) ClearGeneralObjectDetectionConfig()

func (*ProcessorConfig) ClearMediaWarehouseConfig 

func (x *ProcessorConfig) ClearMediaWarehouseConfig()

func (*ProcessorConfig) ClearOccupancyCountConfig 

func (x *ProcessorConfig) ClearOccupancyCountConfig()

func (*ProcessorConfig) ClearPersonBlurConfig 

func (x *ProcessorConfig) ClearPersonBlurConfig()

func (*ProcessorConfig) ClearPersonVehicleDetectionConfig 

func (x *ProcessorConfig) ClearPersonVehicleDetectionConfig()

func (*ProcessorConfig) ClearPersonalProtectiveEquipmentDetectionConfig 

func (x *ProcessorConfig) ClearPersonalProtectiveEquipmentDetectionConfig()

func (*ProcessorConfig) ClearProcessorConfig 

func (x *ProcessorConfig) ClearProcessorConfig()

func (*ProcessorConfig) ClearVertexAutomlVideoConfig 

func (x *ProcessorConfig) ClearVertexAutomlVideoConfig()

func (*ProcessorConfig) ClearVertexAutomlVisionConfig 

func (x *ProcessorConfig) ClearVertexAutomlVisionConfig()

func (*ProcessorConfig) ClearVertexCustomConfig 

func (x *ProcessorConfig) ClearVertexCustomConfig()

func (*ProcessorConfig) ClearVideoStreamInputConfig 

func (x *ProcessorConfig) ClearVideoStreamInputConfig()

func (*ProcessorConfig) GetAiEnabledDevicesInputConfig 

func (x *ProcessorConfig) GetAiEnabledDevicesInputConfig() *AIEnabledDevicesInputConfig

func (*ProcessorConfig) GetBigQueryConfig 

func (x *ProcessorConfig) GetBigQueryConfig() *BigQueryConfig

func (*ProcessorConfig) GetGeneralObjectDetectionConfig 

func (x *ProcessorConfig) GetGeneralObjectDetectionConfig() *GeneralObjectDetectionConfig

func (*ProcessorConfig) GetMediaWarehouseConfig 

func (x *ProcessorConfig) GetMediaWarehouseConfig() *MediaWarehouseConfig

func (*ProcessorConfig) GetOccupancyCountConfig 

func (x *ProcessorConfig) GetOccupancyCountConfig() *OccupancyCountConfig

func (*ProcessorConfig) GetPersonBlurConfig 

func (x *ProcessorConfig) GetPersonBlurConfig() *PersonBlurConfig

func (*ProcessorConfig) GetPersonVehicleDetectionConfig 

func (x *ProcessorConfig) GetPersonVehicleDetectionConfig() *PersonVehicleDetectionConfig

func (*ProcessorConfig) GetPersonalProtectiveEquipmentDetectionConfig 

func (x *ProcessorConfig) GetPersonalProtectiveEquipmentDetectionConfig() *PersonalProtectiveEquipmentDetectionConfig

func (*ProcessorConfig) GetProcessorConfig 

func (x *ProcessorConfig) GetProcessorConfig() isProcessorConfig_ProcessorConfig

func (*ProcessorConfig) GetVertexAutomlVideoConfig 

func (x *ProcessorConfig) GetVertexAutomlVideoConfig() *VertexAutoMLVideoConfig

func (*ProcessorConfig) GetVertexAutomlVisionConfig 

func (x *ProcessorConfig) GetVertexAutomlVisionConfig() *VertexAutoMLVisionConfig

func (*ProcessorConfig) GetVertexCustomConfig 

func (x *ProcessorConfig) GetVertexCustomConfig() *VertexCustomConfig

func (*ProcessorConfig) GetVideoStreamInputConfig 

func (x *ProcessorConfig) GetVideoStreamInputConfig() *VideoStreamInputConfig

func (*ProcessorConfig) HasAiEnabledDevicesInputConfig 

func (x *ProcessorConfig) HasAiEnabledDevicesInputConfig() bool

func (*ProcessorConfig) HasBigQueryConfig 

func (x *ProcessorConfig) HasBigQueryConfig() bool

func (*ProcessorConfig) HasGeneralObjectDetectionConfig 

func (x *ProcessorConfig) HasGeneralObjectDetectionConfig() bool

func (*ProcessorConfig) HasMediaWarehouseConfig 

func (x *ProcessorConfig) HasMediaWarehouseConfig() bool

func (*ProcessorConfig) HasOccupancyCountConfig 

func (x *ProcessorConfig) HasOccupancyCountConfig() bool

func (*ProcessorConfig) HasPersonBlurConfig 

func (x *ProcessorConfig) HasPersonBlurConfig() bool

func (*ProcessorConfig) HasPersonVehicleDetectionConfig 

func (x *ProcessorConfig) HasPersonVehicleDetectionConfig() bool

func (*ProcessorConfig) HasPersonalProtectiveEquipmentDetectionConfig 

func (x *ProcessorConfig) HasPersonalProtectiveEquipmentDetectionConfig() bool

func (*ProcessorConfig) HasProcessorConfig 

func (x *ProcessorConfig) HasProcessorConfig() bool

func (*ProcessorConfig) HasVertexAutomlVideoConfig 

func (x *ProcessorConfig) HasVertexAutomlVideoConfig() bool

func (*ProcessorConfig) HasVertexAutomlVisionConfig 

func (x *ProcessorConfig) HasVertexAutomlVisionConfig() bool

func (*ProcessorConfig) HasVertexCustomConfig 

func (x *ProcessorConfig) HasVertexCustomConfig() bool

func (*ProcessorConfig) HasVideoStreamInputConfig 

func (x *ProcessorConfig) HasVideoStreamInputConfig() bool

func (*ProcessorConfig) ProtoMessage 

func (*ProcessorConfig) ProtoMessage()

func (*ProcessorConfig) ProtoReflect 

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

func (*ProcessorConfig) Reset 

func (x *ProcessorConfig) Reset()

func (*ProcessorConfig) SetAiEnabledDevicesInputConfig 

func (x *ProcessorConfig) SetAiEnabledDevicesInputConfig(v *AIEnabledDevicesInputConfig)

func (*ProcessorConfig) SetBigQueryConfig 

func (x *ProcessorConfig) SetBigQueryConfig(v *BigQueryConfig)

func (*ProcessorConfig) SetGeneralObjectDetectionConfig 

func (x *ProcessorConfig) SetGeneralObjectDetectionConfig(v *GeneralObjectDetectionConfig)

func (*ProcessorConfig) SetMediaWarehouseConfig 

func (x *ProcessorConfig) SetMediaWarehouseConfig(v *MediaWarehouseConfig)

func (*ProcessorConfig) SetOccupancyCountConfig 

func (x *ProcessorConfig) SetOccupancyCountConfig(v *OccupancyCountConfig)

func (*ProcessorConfig) SetPersonBlurConfig 

func (x *ProcessorConfig) SetPersonBlurConfig(v *PersonBlurConfig)

func (*ProcessorConfig) SetPersonVehicleDetectionConfig 

func (x *ProcessorConfig) SetPersonVehicleDetectionConfig(v *PersonVehicleDetectionConfig)

func (*ProcessorConfig) SetPersonalProtectiveEquipmentDetectionConfig 

func (x *ProcessorConfig) SetPersonalProtectiveEquipmentDetectionConfig(v *PersonalProtectiveEquipmentDetectionConfig)

func (*ProcessorConfig) SetVertexAutomlVideoConfig 

func (x *ProcessorConfig) SetVertexAutomlVideoConfig(v *VertexAutoMLVideoConfig)

func (*ProcessorConfig) SetVertexAutomlVisionConfig 

func (x *ProcessorConfig) SetVertexAutomlVisionConfig(v *VertexAutoMLVisionConfig)

func (*ProcessorConfig) SetVertexCustomConfig 

func (x *ProcessorConfig) SetVertexCustomConfig(v *VertexCustomConfig)

func (*ProcessorConfig) SetVideoStreamInputConfig 

func (x *ProcessorConfig) SetVideoStreamInputConfig(v *VideoStreamInputConfig)

func (*ProcessorConfig) String 

func (x *ProcessorConfig) String() string

func (*ProcessorConfig) WhichProcessorConfig 

func (x *ProcessorConfig) WhichProcessorConfig() case_ProcessorConfig_ProcessorConfig

type ProcessorConfig_AiEnabledDevicesInputConfig 

type ProcessorConfig_AiEnabledDevicesInputConfig struct {
	// Config of AI-enabled input devices.
	AiEnabledDevicesInputConfig *AIEnabledDevicesInputConfig `protobuf:"bytes,20,opt,name=ai_enabled_devices_input_config,json=aiEnabledDevicesInputConfig,proto3,oneof"`
}

type ProcessorConfig_BigQueryConfig 

type ProcessorConfig_BigQueryConfig struct {
	// Configs of BigQuery processor.
	BigQueryConfig *BigQueryConfig `protobuf:"bytes,19,opt,name=big_query_config,json=bigQueryConfig,proto3,oneof"`
}

type ProcessorConfig_GeneralObjectDetectionConfig 

type ProcessorConfig_GeneralObjectDetectionConfig struct {
	// Configs of General Object Detection processor.
	GeneralObjectDetectionConfig *GeneralObjectDetectionConfig `protobuf:"bytes,18,opt,name=general_object_detection_config,json=generalObjectDetectionConfig,proto3,oneof"`
}

type ProcessorConfig_MediaWarehouseConfig 

type ProcessorConfig_MediaWarehouseConfig struct {
	// Configs of media warehouse processor.
	MediaWarehouseConfig *MediaWarehouseConfig `protobuf:"bytes,10,opt,name=media_warehouse_config,json=mediaWarehouseConfig,proto3,oneof"`
}

type ProcessorConfig_OccupancyCountConfig 

type ProcessorConfig_OccupancyCountConfig struct {
	// Configs of occupancy count processor.
	OccupancyCountConfig *OccupancyCountConfig `protobuf:"bytes,12,opt,name=occupancy_count_config,json=occupancyCountConfig,proto3,oneof"`
}

type ProcessorConfig_PersonBlurConfig 

type ProcessorConfig_PersonBlurConfig struct {
	// Configs of person blur processor.
	PersonBlurConfig *PersonBlurConfig `protobuf:"bytes,11,opt,name=person_blur_config,json=personBlurConfig,proto3,oneof"`
}

type ProcessorConfig_PersonVehicleDetectionConfig 

type ProcessorConfig_PersonVehicleDetectionConfig struct {
	// Configs of Person Vehicle Detection processor.
	PersonVehicleDetectionConfig *PersonVehicleDetectionConfig `protobuf:"bytes,15,opt,name=person_vehicle_detection_config,json=personVehicleDetectionConfig,proto3,oneof"`
}

type ProcessorConfig_PersonalProtectiveEquipmentDetectionConfig 

type ProcessorConfig_PersonalProtectiveEquipmentDetectionConfig struct {
	// Configs of personal_protective_equipment_detection_config
	PersonalProtectiveEquipmentDetectionConfig *PersonalProtectiveEquipmentDetectionConfig `` /* 136-byte string literal not displayed */
}

type ProcessorConfig_VertexAutomlVideoConfig 

type ProcessorConfig_VertexAutomlVideoConfig struct {
	// Configs of Vertex AutoML video processor.
	VertexAutomlVideoConfig *VertexAutoMLVideoConfig `protobuf:"bytes,14,opt,name=vertex_automl_video_config,json=vertexAutomlVideoConfig,proto3,oneof"`
}

type ProcessorConfig_VertexAutomlVisionConfig 

type ProcessorConfig_VertexAutomlVisionConfig struct {
	// Configs of Vertex AutoML vision processor.
	VertexAutomlVisionConfig *VertexAutoMLVisionConfig `protobuf:"bytes,13,opt,name=vertex_automl_vision_config,json=vertexAutomlVisionConfig,proto3,oneof"`
}

type ProcessorConfig_VertexCustomConfig 

type ProcessorConfig_VertexCustomConfig struct {
	// Configs of Vertex Custom processor.
	VertexCustomConfig *VertexCustomConfig `protobuf:"bytes,17,opt,name=vertex_custom_config,json=vertexCustomConfig,proto3,oneof"`
}

type ProcessorConfig_VideoStreamInputConfig 

type ProcessorConfig_VideoStreamInputConfig struct {
	// Configs of stream input processor.
	VideoStreamInputConfig *VideoStreamInputConfig `protobuf:"bytes,9,opt,name=video_stream_input_config,json=videoStreamInputConfig,proto3,oneof"`
}

type ProcessorConfig_builder 

type ProcessorConfig_builder struct {

	// Fields of oneof ProcessorConfig:
	// Configs of stream input processor.
	VideoStreamInputConfig *VideoStreamInputConfig
	// Config of AI-enabled input devices.
	AiEnabledDevicesInputConfig *AIEnabledDevicesInputConfig
	// Configs of media warehouse processor.
	MediaWarehouseConfig *MediaWarehouseConfig
	// Configs of person blur processor.
	PersonBlurConfig *PersonBlurConfig
	// Configs of occupancy count processor.
	OccupancyCountConfig *OccupancyCountConfig
	// Configs of Person Vehicle Detection processor.
	PersonVehicleDetectionConfig *PersonVehicleDetectionConfig
	// Configs of Vertex AutoML vision processor.
	VertexAutomlVisionConfig *VertexAutoMLVisionConfig
	// Configs of Vertex AutoML video processor.
	VertexAutomlVideoConfig *VertexAutoMLVideoConfig
	// Configs of Vertex Custom processor.
	VertexCustomConfig *VertexCustomConfig
	// Configs of General Object Detection processor.
	GeneralObjectDetectionConfig *GeneralObjectDetectionConfig
	// Configs of BigQuery processor.
	BigQueryConfig *BigQueryConfig
	// Configs of personal_protective_equipment_detection_config
	PersonalProtectiveEquipmentDetectionConfig *PersonalProtectiveEquipmentDetectionConfig
	// contains filtered or unexported fields
}

func (ProcessorConfig_builder) Build 

func (b0 ProcessorConfig_builder) Build() *ProcessorConfig

type ProcessorCreatedEvent 

type ProcessorCreatedEvent struct {

	// The data associated with the event.
	Data *ProcessorEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Processor is created.

func (*ProcessorCreatedEvent) ClearData 

func (x *ProcessorCreatedEvent) ClearData()

func (*ProcessorCreatedEvent) GetData 

func (x *ProcessorCreatedEvent) GetData() *ProcessorEventData

func (*ProcessorCreatedEvent) HasData 

func (x *ProcessorCreatedEvent) HasData() bool

func (*ProcessorCreatedEvent) ProtoMessage 

func (*ProcessorCreatedEvent) ProtoMessage()

func (*ProcessorCreatedEvent) ProtoReflect 

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

func (*ProcessorCreatedEvent) Reset 

func (x *ProcessorCreatedEvent) Reset()

func (*ProcessorCreatedEvent) SetData 

func (x *ProcessorCreatedEvent) SetData(v *ProcessorEventData)

func (*ProcessorCreatedEvent) String 

func (x *ProcessorCreatedEvent) String() string

type ProcessorCreatedEvent_builder 

type ProcessorCreatedEvent_builder struct {

	// The data associated with the event.
	Data *ProcessorEventData
	// contains filtered or unexported fields
}

func (ProcessorCreatedEvent_builder) Build 

func (b0 ProcessorCreatedEvent_builder) Build() *ProcessorCreatedEvent

type ProcessorDeletedEvent 

type ProcessorDeletedEvent struct {

	// The data associated with the event.
	Data *ProcessorEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Processor is deleted.

func (*ProcessorDeletedEvent) ClearData 

func (x *ProcessorDeletedEvent) ClearData()

func (*ProcessorDeletedEvent) GetData 

func (x *ProcessorDeletedEvent) GetData() *ProcessorEventData

func (*ProcessorDeletedEvent) HasData 

func (x *ProcessorDeletedEvent) HasData() bool

func (*ProcessorDeletedEvent) ProtoMessage 

func (*ProcessorDeletedEvent) ProtoMessage()

func (*ProcessorDeletedEvent) ProtoReflect 

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

func (*ProcessorDeletedEvent) Reset 

func (x *ProcessorDeletedEvent) Reset()

func (*ProcessorDeletedEvent) SetData 

func (x *ProcessorDeletedEvent) SetData(v *ProcessorEventData)

func (*ProcessorDeletedEvent) String 

func (x *ProcessorDeletedEvent) String() string

type ProcessorDeletedEvent_builder 

type ProcessorDeletedEvent_builder struct {

	// The data associated with the event.
	Data *ProcessorEventData
	// contains filtered or unexported fields
}

func (ProcessorDeletedEvent_builder) Build 

func (b0 ProcessorDeletedEvent_builder) Build() *ProcessorDeletedEvent

type ProcessorEventData 

type ProcessorEventData struct {

	// Optional. The Processor event payload. Unset for deletion events.
	Payload *Processor `protobuf:"bytes,1,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The data within all Processor events.

func (*ProcessorEventData) ClearPayload 

func (x *ProcessorEventData) ClearPayload()

func (*ProcessorEventData) GetPayload 

func (x *ProcessorEventData) GetPayload() *Processor

func (*ProcessorEventData) HasPayload 

func (x *ProcessorEventData) HasPayload() bool

func (*ProcessorEventData) ProtoMessage 

func (*ProcessorEventData) ProtoMessage()

func (*ProcessorEventData) ProtoReflect 

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

func (*ProcessorEventData) Reset 

func (x *ProcessorEventData) Reset()

func (*ProcessorEventData) SetPayload 

func (x *ProcessorEventData) SetPayload(v *Processor)

func (*ProcessorEventData) String 

func (x *ProcessorEventData) String() string

type ProcessorEventData_builder 

type ProcessorEventData_builder struct {

	// Optional. The Processor event payload. Unset for deletion events.
	Payload *Processor
	// contains filtered or unexported fields
}

func (ProcessorEventData_builder) Build 

func (b0 ProcessorEventData_builder) Build() *ProcessorEventData

type ProcessorIOSpec 

type ProcessorIOSpec struct {

	// For processors with input_channel_specs, the processor must be explicitly
	// connected to another processor.
	GraphInputChannelSpecs []*ProcessorIOSpec_GraphInputChannelSpec `` /* 131-byte string literal not displayed */
	// The output artifact specifications for the current processor.
	GraphOutputChannelSpecs []*ProcessorIOSpec_GraphOutputChannelSpec `` /* 134-byte string literal not displayed */
	// The input resource that needs to be fed from the application instance.
	InstanceResourceInputBindingSpecs []*ProcessorIOSpec_InstanceResourceInputBindingSpec `` /* 166-byte string literal not displayed */
	// The output resource that the processor will generate per instance.
	// Other than the explicitly listed output bindings here, all the processors'
	// GraphOutputChannels can be binded to stream resource. The bind name then is
	// the same as the GraphOutputChannel's name.
	InstanceResourceOutputBindingSpecs []*ProcessorIOSpec_InstanceResourceOutputBindingSpec `` /* 169-byte string literal not displayed */
	// contains filtered or unexported fields
}

Message describing the input / output specifications of a processor.

func (*ProcessorIOSpec) GetGraphInputChannelSpecs 

func (x *ProcessorIOSpec) GetGraphInputChannelSpecs() []*ProcessorIOSpec_GraphInputChannelSpec

func (*ProcessorIOSpec) GetGraphOutputChannelSpecs 

func (x *ProcessorIOSpec) GetGraphOutputChannelSpecs() []*ProcessorIOSpec_GraphOutputChannelSpec

func (*ProcessorIOSpec) GetInstanceResourceInputBindingSpecs 

func (x *ProcessorIOSpec) GetInstanceResourceInputBindingSpecs() []*ProcessorIOSpec_InstanceResourceInputBindingSpec

func (*ProcessorIOSpec) GetInstanceResourceOutputBindingSpecs 

func (x *ProcessorIOSpec) GetInstanceResourceOutputBindingSpecs() []*ProcessorIOSpec_InstanceResourceOutputBindingSpec

func (*ProcessorIOSpec) ProtoMessage 

func (*ProcessorIOSpec) ProtoMessage()

func (*ProcessorIOSpec) ProtoReflect 

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

func (*ProcessorIOSpec) Reset 

func (x *ProcessorIOSpec) Reset()

func (*ProcessorIOSpec) SetGraphInputChannelSpecs 

func (x *ProcessorIOSpec) SetGraphInputChannelSpecs(v []*ProcessorIOSpec_GraphInputChannelSpec)

func (*ProcessorIOSpec) SetGraphOutputChannelSpecs 

func (x *ProcessorIOSpec) SetGraphOutputChannelSpecs(v []*ProcessorIOSpec_GraphOutputChannelSpec)

func (*ProcessorIOSpec) SetInstanceResourceInputBindingSpecs 

func (x *ProcessorIOSpec) SetInstanceResourceInputBindingSpecs(v []*ProcessorIOSpec_InstanceResourceInputBindingSpec)

func (*ProcessorIOSpec) SetInstanceResourceOutputBindingSpecs 

func (x *ProcessorIOSpec) SetInstanceResourceOutputBindingSpecs(v []*ProcessorIOSpec_InstanceResourceOutputBindingSpec)

func (*ProcessorIOSpec) String 

func (x *ProcessorIOSpec) String() string

type ProcessorIOSpec_GraphInputChannelSpec 

type ProcessorIOSpec_GraphInputChannelSpec struct {

	// The name of the current input channel.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The data types of the current input channel.
	// When this field has more than 1 value, it means this input channel can be
	// connected to either of these different data types.
	DataType DataType `` /* 132-byte string literal not displayed */
	// If specified, only those detailed data types can be connected to the
	// processor. For example, jpeg stream for MEDIA, or PredictionResult proto
	// for PROTO type. If unspecified, then any proto is accepted.
	AcceptedDataTypeUris []string `protobuf:"bytes,5,rep,name=accepted_data_type_uris,json=acceptedDataTypeUris,proto3" json:"accepted_data_type_uris,omitempty"`
	// Whether the current input channel is required by the processor.
	// For example, for a processor with required video input and optional audio
	// input, if video input is missing, the application will be rejected while
	// the audio input can be missing as long as the video input exists.
	Required bool `protobuf:"varint,3,opt,name=required,proto3" json:"required,omitempty"`
	// How many input edges can be connected to this input channel. 0 means
	// unlimited.
	MaxConnectionAllowed int64 `protobuf:"varint,4,opt,name=max_connection_allowed,json=maxConnectionAllowed,proto3" json:"max_connection_allowed,omitempty"`
	// contains filtered or unexported fields
}

Message for input channel specification.

func (*ProcessorIOSpec_GraphInputChannelSpec) GetAcceptedDataTypeUris 

func (x *ProcessorIOSpec_GraphInputChannelSpec) GetAcceptedDataTypeUris() []string

func (*ProcessorIOSpec_GraphInputChannelSpec) GetDataType 

func (x *ProcessorIOSpec_GraphInputChannelSpec) GetDataType() DataType

func (*ProcessorIOSpec_GraphInputChannelSpec) GetMaxConnectionAllowed 

func (x *ProcessorIOSpec_GraphInputChannelSpec) GetMaxConnectionAllowed() int64

func (*ProcessorIOSpec_GraphInputChannelSpec) GetName 

func (x *ProcessorIOSpec_GraphInputChannelSpec) GetName() string

func (*ProcessorIOSpec_GraphInputChannelSpec) GetRequired 

func (x *ProcessorIOSpec_GraphInputChannelSpec) GetRequired() bool

func (*ProcessorIOSpec_GraphInputChannelSpec) ProtoMessage 

func (*ProcessorIOSpec_GraphInputChannelSpec) ProtoMessage()

func (*ProcessorIOSpec_GraphInputChannelSpec) ProtoReflect 

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

func (*ProcessorIOSpec_GraphInputChannelSpec) Reset 

func (x *ProcessorIOSpec_GraphInputChannelSpec) Reset()

func (*ProcessorIOSpec_GraphInputChannelSpec) SetAcceptedDataTypeUris 

func (x *ProcessorIOSpec_GraphInputChannelSpec) SetAcceptedDataTypeUris(v []string)

func (*ProcessorIOSpec_GraphInputChannelSpec) SetDataType 

func (x *ProcessorIOSpec_GraphInputChannelSpec) SetDataType(v DataType)

func (*ProcessorIOSpec_GraphInputChannelSpec) SetMaxConnectionAllowed 

func (x *ProcessorIOSpec_GraphInputChannelSpec) SetMaxConnectionAllowed(v int64)

func (*ProcessorIOSpec_GraphInputChannelSpec) SetName 

func (x *ProcessorIOSpec_GraphInputChannelSpec) SetName(v string)

func (*ProcessorIOSpec_GraphInputChannelSpec) SetRequired 

func (x *ProcessorIOSpec_GraphInputChannelSpec) SetRequired(v bool)

func (*ProcessorIOSpec_GraphInputChannelSpec) String 

func (x *ProcessorIOSpec_GraphInputChannelSpec) String() string

type ProcessorIOSpec_GraphInputChannelSpec_builder 

type ProcessorIOSpec_GraphInputChannelSpec_builder struct {

	// The name of the current input channel.
	Name string
	// The data types of the current input channel.
	// When this field has more than 1 value, it means this input channel can be
	// connected to either of these different data types.
	DataType DataType
	// If specified, only those detailed data types can be connected to the
	// processor. For example, jpeg stream for MEDIA, or PredictionResult proto
	// for PROTO type. If unspecified, then any proto is accepted.
	AcceptedDataTypeUris []string
	// Whether the current input channel is required by the processor.
	// For example, for a processor with required video input and optional audio
	// input, if video input is missing, the application will be rejected while
	// the audio input can be missing as long as the video input exists.
	Required bool
	// How many input edges can be connected to this input channel. 0 means
	// unlimited.
	MaxConnectionAllowed int64
	// contains filtered or unexported fields
}

func (ProcessorIOSpec_GraphInputChannelSpec_builder) Build 

func (b0 ProcessorIOSpec_GraphInputChannelSpec_builder) Build() *ProcessorIOSpec_GraphInputChannelSpec

type ProcessorIOSpec_GraphOutputChannelSpec 

type ProcessorIOSpec_GraphOutputChannelSpec struct {

	// The name of the current output channel.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The data type of the current output channel.
	DataType    DataType `` /* 132-byte string literal not displayed */
	DataTypeUri string   `protobuf:"bytes,3,opt,name=data_type_uri,json=dataTypeUri,proto3" json:"data_type_uri,omitempty"`
	// contains filtered or unexported fields
}

Message for output channel specification.

func (*ProcessorIOSpec_GraphOutputChannelSpec) GetDataType 

func (x *ProcessorIOSpec_GraphOutputChannelSpec) GetDataType() DataType

func (*ProcessorIOSpec_GraphOutputChannelSpec) GetDataTypeUri 

func (x *ProcessorIOSpec_GraphOutputChannelSpec) GetDataTypeUri() string

func (*ProcessorIOSpec_GraphOutputChannelSpec) GetName 

func (x *ProcessorIOSpec_GraphOutputChannelSpec) GetName() string

func (*ProcessorIOSpec_GraphOutputChannelSpec) ProtoMessage 

func (*ProcessorIOSpec_GraphOutputChannelSpec) ProtoMessage()

func (*ProcessorIOSpec_GraphOutputChannelSpec) ProtoReflect 

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

func (*ProcessorIOSpec_GraphOutputChannelSpec) Reset 

func (x *ProcessorIOSpec_GraphOutputChannelSpec) Reset()

func (*ProcessorIOSpec_GraphOutputChannelSpec) SetDataType 

func (x *ProcessorIOSpec_GraphOutputChannelSpec) SetDataType(v DataType)

func (*ProcessorIOSpec_GraphOutputChannelSpec) SetDataTypeUri 

func (x *ProcessorIOSpec_GraphOutputChannelSpec) SetDataTypeUri(v string)

func (*ProcessorIOSpec_GraphOutputChannelSpec) SetName 

func (x *ProcessorIOSpec_GraphOutputChannelSpec) SetName(v string)

func (*ProcessorIOSpec_GraphOutputChannelSpec) String 

func (x *ProcessorIOSpec_GraphOutputChannelSpec) String() string

type ProcessorIOSpec_GraphOutputChannelSpec_builder 

type ProcessorIOSpec_GraphOutputChannelSpec_builder struct {

	// The name of the current output channel.
	Name string
	// The data type of the current output channel.
	DataType    DataType
	DataTypeUri string
	// contains filtered or unexported fields
}

func (ProcessorIOSpec_GraphOutputChannelSpec_builder) Build 

func (b0 ProcessorIOSpec_GraphOutputChannelSpec_builder) Build() *ProcessorIOSpec_GraphOutputChannelSpec

type ProcessorIOSpec_InstanceResourceInputBindingSpec 

type ProcessorIOSpec_InstanceResourceInputBindingSpec struct {

	// Types that are valid to be assigned to ResourceType:
	//
	//	*ProcessorIOSpec_InstanceResourceInputBindingSpec_ConfigTypeUri
	//	*ProcessorIOSpec_InstanceResourceInputBindingSpec_ResourceTypeUri
	ResourceType isProcessorIOSpec_InstanceResourceInputBindingSpec_ResourceType `protobuf_oneof:"resource_type"`
	// Name of the input binding, unique within the processor.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

Message for instance resource channel specification. External resources are virtual nodes which are not expressed in the application graph. Each processor expresses its out-graph spec, so customer is able to override the external source or destinations to the

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) ClearConfigTypeUri 

func (x *ProcessorIOSpec_InstanceResourceInputBindingSpec) ClearConfigTypeUri()

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) ClearResourceType 

func (x *ProcessorIOSpec_InstanceResourceInputBindingSpec) ClearResourceType()

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) ClearResourceTypeUri 

func (x *ProcessorIOSpec_InstanceResourceInputBindingSpec) ClearResourceTypeUri()

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) GetConfigTypeUri 

func (x *ProcessorIOSpec_InstanceResourceInputBindingSpec) GetConfigTypeUri() string

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) GetName 

func (x *ProcessorIOSpec_InstanceResourceInputBindingSpec) GetName() string

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) GetResourceType 

func (x *ProcessorIOSpec_InstanceResourceInputBindingSpec) GetResourceType() isProcessorIOSpec_InstanceResourceInputBindingSpec_ResourceType

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) GetResourceTypeUri 

func (x *ProcessorIOSpec_InstanceResourceInputBindingSpec) GetResourceTypeUri() string

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) HasConfigTypeUri 

func (x *ProcessorIOSpec_InstanceResourceInputBindingSpec) HasConfigTypeUri() bool

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) HasResourceType 

func (x *ProcessorIOSpec_InstanceResourceInputBindingSpec) HasResourceType() bool

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) HasResourceTypeUri 

func (x *ProcessorIOSpec_InstanceResourceInputBindingSpec) HasResourceTypeUri() bool

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) ProtoMessage 

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) ProtoMessage()

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) ProtoReflect 

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

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) Reset 

func (x *ProcessorIOSpec_InstanceResourceInputBindingSpec) Reset()

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) SetConfigTypeUri 

func (x *ProcessorIOSpec_InstanceResourceInputBindingSpec) SetConfigTypeUri(v string)

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) SetName 

func (x *ProcessorIOSpec_InstanceResourceInputBindingSpec) SetName(v string)

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) SetResourceTypeUri 

func (x *ProcessorIOSpec_InstanceResourceInputBindingSpec) SetResourceTypeUri(v string)

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) String 

func (x *ProcessorIOSpec_InstanceResourceInputBindingSpec) String() string

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) WhichResourceType 

func (x *ProcessorIOSpec_InstanceResourceInputBindingSpec) WhichResourceType() case_ProcessorIOSpec_InstanceResourceInputBindingSpec_ResourceType

type ProcessorIOSpec_InstanceResourceInputBindingSpec_ConfigTypeUri 

type ProcessorIOSpec_InstanceResourceInputBindingSpec_ConfigTypeUri struct {
	// The configuration proto that includes the Googleapis resources. I.e.
	// type.googleapis.com/google.cloud.vision.v1.StreamWithAnnotation
	ConfigTypeUri string `protobuf:"bytes,2,opt,name=config_type_uri,json=configTypeUri,proto3,oneof"`
}

type ProcessorIOSpec_InstanceResourceInputBindingSpec_ResourceTypeUri 

type ProcessorIOSpec_InstanceResourceInputBindingSpec_ResourceTypeUri struct {
	// The direct type url of Googleapis resource. i.e.
	// type.googleapis.com/google.cloud.vision.v1.Asset
	ResourceTypeUri string `protobuf:"bytes,3,opt,name=resource_type_uri,json=resourceTypeUri,proto3,oneof"`
}

type ProcessorIOSpec_InstanceResourceInputBindingSpec_builder 

type ProcessorIOSpec_InstanceResourceInputBindingSpec_builder struct {

	// Fields of oneof ResourceType:
	// The configuration proto that includes the Googleapis resources. I.e.
	// type.googleapis.com/google.cloud.vision.v1.StreamWithAnnotation
	ConfigTypeUri *string
	// The direct type url of Googleapis resource. i.e.
	// type.googleapis.com/google.cloud.vision.v1.Asset
	ResourceTypeUri *string
	// -- end of ResourceType
	// Name of the input binding, unique within the processor.
	Name string
	// contains filtered or unexported fields
}

func (ProcessorIOSpec_InstanceResourceInputBindingSpec_builder) Build 

func (b0 ProcessorIOSpec_InstanceResourceInputBindingSpec_builder) Build() *ProcessorIOSpec_InstanceResourceInputBindingSpec

type ProcessorIOSpec_InstanceResourceOutputBindingSpec 

type ProcessorIOSpec_InstanceResourceOutputBindingSpec struct {

	// Name of the output binding, unique within the processor.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The resource type uri of the acceptable output resource.
	ResourceTypeUri string `protobuf:"bytes,2,opt,name=resource_type_uri,json=resourceTypeUri,proto3" json:"resource_type_uri,omitempty"`
	// Whether the output resource needs to be explicitly set in the instance.
	// If it is false, the processor will automatically generate it if required.
	Explicit bool `protobuf:"varint,3,opt,name=explicit,proto3" json:"explicit,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessorIOSpec_InstanceResourceOutputBindingSpec) GetExplicit 

func (x *ProcessorIOSpec_InstanceResourceOutputBindingSpec) GetExplicit() bool

func (*ProcessorIOSpec_InstanceResourceOutputBindingSpec) GetName 

func (x *ProcessorIOSpec_InstanceResourceOutputBindingSpec) GetName() string

func (*ProcessorIOSpec_InstanceResourceOutputBindingSpec) GetResourceTypeUri 

func (x *ProcessorIOSpec_InstanceResourceOutputBindingSpec) GetResourceTypeUri() string

func (*ProcessorIOSpec_InstanceResourceOutputBindingSpec) ProtoMessage 

func (*ProcessorIOSpec_InstanceResourceOutputBindingSpec) ProtoMessage()

func (*ProcessorIOSpec_InstanceResourceOutputBindingSpec) ProtoReflect 

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

func (*ProcessorIOSpec_InstanceResourceOutputBindingSpec) Reset 

func (x *ProcessorIOSpec_InstanceResourceOutputBindingSpec) Reset()

func (*ProcessorIOSpec_InstanceResourceOutputBindingSpec) SetExplicit 

func (x *ProcessorIOSpec_InstanceResourceOutputBindingSpec) SetExplicit(v bool)

func (*ProcessorIOSpec_InstanceResourceOutputBindingSpec) SetName 

func (x *ProcessorIOSpec_InstanceResourceOutputBindingSpec) SetName(v string)

func (*ProcessorIOSpec_InstanceResourceOutputBindingSpec) SetResourceTypeUri 

func (x *ProcessorIOSpec_InstanceResourceOutputBindingSpec) SetResourceTypeUri(v string)

func (*ProcessorIOSpec_InstanceResourceOutputBindingSpec) String 

func (x *ProcessorIOSpec_InstanceResourceOutputBindingSpec) String() string

type ProcessorIOSpec_InstanceResourceOutputBindingSpec_builder 

type ProcessorIOSpec_InstanceResourceOutputBindingSpec_builder struct {

	// Name of the output binding, unique within the processor.
	Name string
	// The resource type uri of the acceptable output resource.
	ResourceTypeUri string
	// Whether the output resource needs to be explicitly set in the instance.
	// If it is false, the processor will automatically generate it if required.
	Explicit bool
	// contains filtered or unexported fields
}

func (ProcessorIOSpec_InstanceResourceOutputBindingSpec_builder) Build 

func (b0 ProcessorIOSpec_InstanceResourceOutputBindingSpec_builder) Build() *ProcessorIOSpec_InstanceResourceOutputBindingSpec

type ProcessorIOSpec_builder 

type ProcessorIOSpec_builder struct {

	// For processors with input_channel_specs, the processor must be explicitly
	// connected to another processor.
	GraphInputChannelSpecs []*ProcessorIOSpec_GraphInputChannelSpec
	// The output artifact specifications for the current processor.
	GraphOutputChannelSpecs []*ProcessorIOSpec_GraphOutputChannelSpec
	// The input resource that needs to be fed from the application instance.
	InstanceResourceInputBindingSpecs []*ProcessorIOSpec_InstanceResourceInputBindingSpec
	// The output resource that the processor will generate per instance.
	// Other than the explicitly listed output bindings here, all the processors'
	// GraphOutputChannels can be binded to stream resource. The bind name then is
	// the same as the GraphOutputChannel's name.
	InstanceResourceOutputBindingSpecs []*ProcessorIOSpec_InstanceResourceOutputBindingSpec
	// contains filtered or unexported fields
}

func (ProcessorIOSpec_builder) Build 

func (b0 ProcessorIOSpec_builder) Build() *ProcessorIOSpec

type ProcessorUpdatedEvent 

type ProcessorUpdatedEvent struct {

	// The data associated with the event.
	Data *ProcessorEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Processor is updated.

func (*ProcessorUpdatedEvent) ClearData 

func (x *ProcessorUpdatedEvent) ClearData()

func (*ProcessorUpdatedEvent) GetData 

func (x *ProcessorUpdatedEvent) GetData() *ProcessorEventData

func (*ProcessorUpdatedEvent) HasData 

func (x *ProcessorUpdatedEvent) HasData() bool

func (*ProcessorUpdatedEvent) ProtoMessage 

func (*ProcessorUpdatedEvent) ProtoMessage()

func (*ProcessorUpdatedEvent) ProtoReflect 

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

func (*ProcessorUpdatedEvent) Reset 

func (x *ProcessorUpdatedEvent) Reset()

func (*ProcessorUpdatedEvent) SetData 

func (x *ProcessorUpdatedEvent) SetData(v *ProcessorEventData)

func (*ProcessorUpdatedEvent) String 

func (x *ProcessorUpdatedEvent) String() string

type ProcessorUpdatedEvent_builder 

type ProcessorUpdatedEvent_builder struct {

	// The data associated with the event.
	Data *ProcessorEventData
	// contains filtered or unexported fields
}

func (ProcessorUpdatedEvent_builder) Build 

func (b0 ProcessorUpdatedEvent_builder) Build() *ProcessorUpdatedEvent

type Processor_ProcessorState 

type Processor_ProcessorState int32
const (
	// Unspecified Processor state.
	Processor_PROCESSOR_STATE_UNSPECIFIED Processor_ProcessorState = 0
	// Processor is being created (not ready for use).
	Processor_CREATING Processor_ProcessorState = 1
	// Processor is and ready for use.
	Processor_ACTIVE Processor_ProcessorState = 2
	// Processor is being deleted (not ready for use).
	Processor_DELETING Processor_ProcessorState = 3
	// Processor deleted or creation failed .
	Processor_FAILED Processor_ProcessorState = 4
)

func (Processor_ProcessorState) Descriptor 

func (Processor_ProcessorState) Descriptor() protoreflect.EnumDescriptor

func (Processor_ProcessorState) Enum 

func (x Processor_ProcessorState) Enum() *Processor_ProcessorState

func (Processor_ProcessorState) Number 

func (x Processor_ProcessorState) Number() protoreflect.EnumNumber

func (Processor_ProcessorState) String 

func (x Processor_ProcessorState) String() string

func (Processor_ProcessorState) Type 

func (Processor_ProcessorState) Type() protoreflect.EnumType

type Processor_ProcessorType 

type Processor_ProcessorType int32

Type 

const (
	// Processor Type UNSPECIFIED.
	Processor_PROCESSOR_TYPE_UNSPECIFIED Processor_ProcessorType = 0
	// Processor Type PRETRAINED.
	// Pretrained processor is developed by Vision AI App Platform with
	// state-of-the-art vision data processing functionality, like occupancy
	// counting or person blur. Pretrained processor is usually publicly
	// available.
	Processor_PRETRAINED Processor_ProcessorType = 1
	// Processor Type CUSTOM.
	// Custom processors are specialized processors which are either uploaded by
	// customers or imported from other GCP platform (for example Vertex AI).
	// Custom processor is only visible to the creator.
	Processor_CUSTOM Processor_ProcessorType = 2
	// Processor Type CONNECTOR.
	// Connector processors are special processors which perform I/O for the
	// application, they do not processing the data but either deliver the data
	// to other processors or receive data from other processors.
	Processor_CONNECTOR Processor_ProcessorType = 3
)

func (Processor_ProcessorType) Descriptor 

func (Processor_ProcessorType) Descriptor() protoreflect.EnumDescriptor

func (Processor_ProcessorType) Enum 

func (x Processor_ProcessorType) Enum() *Processor_ProcessorType

func (Processor_ProcessorType) Number 

func (x Processor_ProcessorType) Number() protoreflect.EnumNumber

func (Processor_ProcessorType) String 

func (x Processor_ProcessorType) String() string

func (Processor_ProcessorType) Type 

func (Processor_ProcessorType) Type() protoreflect.EnumType

type Processor_builder 

type Processor_builder struct {

	// name of resource.
	Name string
	// Output only. [Output only] Create timestamp.
	CreateTime *timestamppb.Timestamp
	// Output only. [Output only] Update timestamp.
	UpdateTime *timestamppb.Timestamp
	// Labels as key value pairs.
	Labels map[string]string
	// Required. A user friendly display name for the processor.
	DisplayName string
	// Illustrative sentences for describing the functionality of the processor.
	Description string
	// Output only. Processor Type.
	ProcessorType Processor_ProcessorType
	// Model Type.
	ModelType ModelType
	// Source info for customer created processor.
	CustomProcessorSourceInfo *CustomProcessorSourceInfo
	// Output only. State of the Processor.
	State Processor_ProcessorState
	// Output only. [Output only] The input / output specifications of a
	// processor, each type of processor has fixed input / output specs which
	// cannot be altered by customer.
	ProcessorIoSpec *ProcessorIOSpec
	// Output only. The corresponding configuration can be used in the Application
	// to customize the behavior of the processor.
	ConfigurationTypeurl     string
	SupportedAnnotationTypes []StreamAnnotationType
	// Indicates if the processor supports post processing.
	SupportsPostProcessing bool
	// contains filtered or unexported fields
}

func (Processor_builder) Build 

func (b0 Processor_builder) Build() *Processor

type RunMode 

type RunMode int32

RunMode represents the mode to launch the Process on. 

const (
	// Mode is unspecified.
	RunMode_RUN_MODE_UNSPECIFIED RunMode = 0
	// Live mode. Meaning the Process is launched to handle live video
	// source, and possible packet drops are expected.
	RunMode_LIVE RunMode = 1
	// Submission mode. Meaning the Process is launched to handle bounded video
	// files, with no packet drop. Completion status is tracked.
	RunMode_SUBMISSION RunMode = 2
)

func (RunMode) Descriptor 

func (RunMode) Descriptor() protoreflect.EnumDescriptor

func (RunMode) Enum 

func (x RunMode) Enum() *RunMode

func (RunMode) Number 

func (x RunMode) Number() protoreflect.EnumNumber

func (RunMode) String 

func (x RunMode) String() string

func (RunMode) Type 

func (RunMode) Type() protoreflect.EnumType

type RunStatus 

type RunStatus struct {

	// The state of the Process.
	State RunStatus_State `protobuf:"varint,1,opt,name=state,proto3,enum=google.events.cloud.visionai.v1.RunStatus_State" json:"state,omitempty"`
	// The reason of becoming the state.
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

Message describing the status of the Process.

func (*RunStatus) GetReason 

func (x *RunStatus) GetReason() string

func (*RunStatus) GetState 

func (x *RunStatus) GetState() RunStatus_State

func (*RunStatus) ProtoMessage 

func (*RunStatus) ProtoMessage()

func (*RunStatus) ProtoReflect 

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

func (*RunStatus) Reset 

func (x *RunStatus) Reset()

func (*RunStatus) SetReason 

func (x *RunStatus) SetReason(v string)

func (*RunStatus) SetState 

func (x *RunStatus) SetState(v RunStatus_State)

func (*RunStatus) String 

func (x *RunStatus) String() string

type RunStatus_State 

type RunStatus_State int32

State represents the running status of the Process. 

const (
	// State is unspecified.
	RunStatus_STATE_UNSPECIFIED RunStatus_State = 0
	// INITIALIZING means the Process is scheduled but yet ready to handle
	// real traffic.
	RunStatus_INITIALIZING RunStatus_State = 1
	// RUNNING means the Process is up running and handling traffic.
	RunStatus_RUNNING RunStatus_State = 2
	// COMPLETED means the Process has completed the processing, especially
	// for non-streaming use case.
	RunStatus_COMPLETED RunStatus_State = 3
	// FAILED means the Process failed to complete the processing.
	RunStatus_FAILED RunStatus_State = 4
	// PENDING means the Process is created but yet to be scheduled.
	RunStatus_PENDING RunStatus_State = 5
)

func (RunStatus_State) Descriptor 

func (RunStatus_State) Descriptor() protoreflect.EnumDescriptor

func (RunStatus_State) Enum 

func (x RunStatus_State) Enum() *RunStatus_State

func (RunStatus_State) Number 

func (x RunStatus_State) Number() protoreflect.EnumNumber

func (RunStatus_State) String 

func (x RunStatus_State) String() string

func (RunStatus_State) Type 

func (RunStatus_State) Type() protoreflect.EnumType

type RunStatus_builder 

type RunStatus_builder struct {

	// The state of the Process.
	State RunStatus_State
	// The reason of becoming the state.
	Reason string
	// contains filtered or unexported fields
}

func (RunStatus_builder) Build 

func (b0 RunStatus_builder) Build() *RunStatus

type Series 

type Series struct {

	// Name of the resource.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. The create timestamp.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The update timestamp.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Labels as key value pairs.
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// Annotations to allow clients to store small amounts of arbitrary data.
	Annotations map[string]string `` /* 149-byte string literal not displayed */
	// Required. Stream that is associated with this series.
	Stream string `protobuf:"bytes,6,opt,name=stream,proto3" json:"stream,omitempty"`
	// Required. Event that is associated with this series.
	Event string `protobuf:"bytes,7,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

Message describing the Series object.

func (*Series) ClearCreateTime 

func (x *Series) ClearCreateTime()

func (*Series) ClearUpdateTime 

func (x *Series) ClearUpdateTime()

func (*Series) GetAnnotations 

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

func (*Series) GetCreateTime 

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

func (*Series) GetEvent 

func (x *Series) GetEvent() string

func (*Series) GetLabels 

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

func (*Series) GetName 

func (x *Series) GetName() string

func (*Series) GetStream 

func (x *Series) GetStream() string

func (*Series) GetUpdateTime 

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

func (*Series) HasCreateTime 

func (x *Series) HasCreateTime() bool

func (*Series) HasUpdateTime 

func (x *Series) HasUpdateTime() bool

func (*Series) ProtoMessage 

func (*Series) ProtoMessage()

func (*Series) ProtoReflect 

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

func (*Series) Reset 

func (x *Series) Reset()

func (*Series) SetAnnotations 

func (x *Series) SetAnnotations(v map[string]string)

func (*Series) SetCreateTime 

func (x *Series) SetCreateTime(v *timestamppb.Timestamp)

func (*Series) SetEvent 

func (x *Series) SetEvent(v string)

func (*Series) SetLabels 

func (x *Series) SetLabels(v map[string]string)

func (*Series) SetName 

func (x *Series) SetName(v string)

func (*Series) SetStream 

func (x *Series) SetStream(v string)

func (*Series) SetUpdateTime 

func (x *Series) SetUpdateTime(v *timestamppb.Timestamp)

func (*Series) String 

func (x *Series) String() string

type SeriesCreatedEvent 

type SeriesCreatedEvent struct {

	// The data associated with the event.
	Data *SeriesEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Series is created.

func (*SeriesCreatedEvent) ClearData 

func (x *SeriesCreatedEvent) ClearData()

func (*SeriesCreatedEvent) GetData 

func (x *SeriesCreatedEvent) GetData() *SeriesEventData

func (*SeriesCreatedEvent) HasData 

func (x *SeriesCreatedEvent) HasData() bool

func (*SeriesCreatedEvent) ProtoMessage 

func (*SeriesCreatedEvent) ProtoMessage()

func (*SeriesCreatedEvent) ProtoReflect 

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

func (*SeriesCreatedEvent) Reset 

func (x *SeriesCreatedEvent) Reset()

func (*SeriesCreatedEvent) SetData 

func (x *SeriesCreatedEvent) SetData(v *SeriesEventData)

func (*SeriesCreatedEvent) String 

func (x *SeriesCreatedEvent) String() string

type SeriesCreatedEvent_builder 

type SeriesCreatedEvent_builder struct {

	// The data associated with the event.
	Data *SeriesEventData
	// contains filtered or unexported fields
}

func (SeriesCreatedEvent_builder) Build 

func (b0 SeriesCreatedEvent_builder) Build() *SeriesCreatedEvent

type SeriesDeletedEvent 

type SeriesDeletedEvent struct {

	// The data associated with the event.
	Data *SeriesEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Series is deleted.

func (*SeriesDeletedEvent) ClearData 

func (x *SeriesDeletedEvent) ClearData()

func (*SeriesDeletedEvent) GetData 

func (x *SeriesDeletedEvent) GetData() *SeriesEventData

func (*SeriesDeletedEvent) HasData 

func (x *SeriesDeletedEvent) HasData() bool

func (*SeriesDeletedEvent) ProtoMessage 

func (*SeriesDeletedEvent) ProtoMessage()

func (*SeriesDeletedEvent) ProtoReflect 

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

func (*SeriesDeletedEvent) Reset 

func (x *SeriesDeletedEvent) Reset()

func (*SeriesDeletedEvent) SetData 

func (x *SeriesDeletedEvent) SetData(v *SeriesEventData)

func (*SeriesDeletedEvent) String 

func (x *SeriesDeletedEvent) String() string

type SeriesDeletedEvent_builder 

type SeriesDeletedEvent_builder struct {

	// The data associated with the event.
	Data *SeriesEventData
	// contains filtered or unexported fields
}

func (SeriesDeletedEvent_builder) Build 

func (b0 SeriesDeletedEvent_builder) Build() *SeriesDeletedEvent

type SeriesEventData 

type SeriesEventData struct {

	// Optional. The Series event payload. Unset for deletion events.
	Payload *Series `protobuf:"bytes,1,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The data within all Series events.

func (*SeriesEventData) ClearPayload 

func (x *SeriesEventData) ClearPayload()

func (*SeriesEventData) GetPayload 

func (x *SeriesEventData) GetPayload() *Series

func (*SeriesEventData) HasPayload 

func (x *SeriesEventData) HasPayload() bool

func (*SeriesEventData) ProtoMessage 

func (*SeriesEventData) ProtoMessage()

func (*SeriesEventData) ProtoReflect 

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

func (*SeriesEventData) Reset 

func (x *SeriesEventData) Reset()

func (*SeriesEventData) SetPayload 

func (x *SeriesEventData) SetPayload(v *Series)

func (*SeriesEventData) String 

func (x *SeriesEventData) String() string

type SeriesEventData_builder 

type SeriesEventData_builder struct {

	// Optional. The Series event payload. Unset for deletion events.
	Payload *Series
	// contains filtered or unexported fields
}

func (SeriesEventData_builder) Build 

func (b0 SeriesEventData_builder) Build() *SeriesEventData

type SeriesUpdatedEvent 

type SeriesUpdatedEvent struct {

	// The data associated with the event.
	Data *SeriesEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Series is updated.

func (*SeriesUpdatedEvent) ClearData 

func (x *SeriesUpdatedEvent) ClearData()

func (*SeriesUpdatedEvent) GetData 

func (x *SeriesUpdatedEvent) GetData() *SeriesEventData

func (*SeriesUpdatedEvent) HasData 

func (x *SeriesUpdatedEvent) HasData() bool

func (*SeriesUpdatedEvent) ProtoMessage 

func (*SeriesUpdatedEvent) ProtoMessage()

func (*SeriesUpdatedEvent) ProtoReflect 

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

func (*SeriesUpdatedEvent) Reset 

func (x *SeriesUpdatedEvent) Reset()

func (*SeriesUpdatedEvent) SetData 

func (x *SeriesUpdatedEvent) SetData(v *SeriesEventData)

func (*SeriesUpdatedEvent) String 

func (x *SeriesUpdatedEvent) String() string

type SeriesUpdatedEvent_builder 

type SeriesUpdatedEvent_builder struct {

	// The data associated with the event.
	Data *SeriesEventData
	// contains filtered or unexported fields
}

func (SeriesUpdatedEvent_builder) Build 

func (b0 SeriesUpdatedEvent_builder) Build() *SeriesUpdatedEvent

type Series_builder 

type Series_builder struct {

	// Name of the resource.
	Name string
	// Output only. The create timestamp.
	CreateTime *timestamppb.Timestamp
	// Output only. The update timestamp.
	UpdateTime *timestamppb.Timestamp
	// Labels as key value pairs.
	Labels map[string]string
	// Annotations to allow clients to store small amounts of arbitrary data.
	Annotations map[string]string
	// Required. Stream that is associated with this series.
	Stream string
	// Required. Event that is associated with this series.
	Event string
	// contains filtered or unexported fields
}

func (Series_builder) Build 

func (b0 Series_builder) Build() *Series

type Stream 

type Stream struct {

	// Name of the resource.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Output only. The create timestamp.
	CreateTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=create_time,json=createTime,proto3" json:"create_time,omitempty"`
	// Output only. The update timestamp.
	UpdateTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// Labels as key value pairs.
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// Annotations to allow clients to store small amounts of arbitrary data.
	Annotations map[string]string `` /* 149-byte string literal not displayed */
	// The display name for the stream resource.
	DisplayName string `protobuf:"bytes,6,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// Whether to enable the HLS playback service on this stream.
	EnableHlsPlayback bool `protobuf:"varint,7,opt,name=enable_hls_playback,json=enableHlsPlayback,proto3" json:"enable_hls_playback,omitempty"`
	// The name of the media warehouse asset for long term storage of stream data.
	// Format: projects/${p_id}/locations/${l_id}/corpora/${c_id}/assets/${a_id}
	// Remain empty if the media warehouse storage is not needed for the stream.
	MediaWarehouseAsset string `protobuf:"bytes,8,opt,name=media_warehouse_asset,json=mediaWarehouseAsset,proto3" json:"media_warehouse_asset,omitempty"`
	// contains filtered or unexported fields
}

Message describing the Stream object. The Stream and the Event resources are many to many; i.e., each Stream resource can associate to many Event resources and each Event resource can associate to many Stream resources.

func (*Stream) ClearCreateTime 

func (x *Stream) ClearCreateTime()

func (*Stream) ClearUpdateTime 

func (x *Stream) ClearUpdateTime()

func (*Stream) GetAnnotations 

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

func (*Stream) GetCreateTime 

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

func (*Stream) GetDisplayName 

func (x *Stream) GetDisplayName() string

func (*Stream) GetEnableHlsPlayback 

func (x *Stream) GetEnableHlsPlayback() bool

func (*Stream) GetLabels 

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

func (*Stream) GetMediaWarehouseAsset 

func (x *Stream) GetMediaWarehouseAsset() string

func (*Stream) GetName 

func (x *Stream) GetName() string

func (*Stream) GetUpdateTime 

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

func (*Stream) HasCreateTime 

func (x *Stream) HasCreateTime() bool

func (*Stream) HasUpdateTime 

func (x *Stream) HasUpdateTime() bool

func (*Stream) ProtoMessage 

func (*Stream) ProtoMessage()

func (*Stream) ProtoReflect 

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

func (*Stream) Reset 

func (x *Stream) Reset()

func (*Stream) SetAnnotations 

func (x *Stream) SetAnnotations(v map[string]string)

func (*Stream) SetCreateTime 

func (x *Stream) SetCreateTime(v *timestamppb.Timestamp)

func (*Stream) SetDisplayName 

func (x *Stream) SetDisplayName(v string)

func (*Stream) SetEnableHlsPlayback 

func (x *Stream) SetEnableHlsPlayback(v bool)

func (*Stream) SetLabels 

func (x *Stream) SetLabels(v map[string]string)

func (*Stream) SetMediaWarehouseAsset 

func (x *Stream) SetMediaWarehouseAsset(v string)

func (*Stream) SetName 

func (x *Stream) SetName(v string)

func (*Stream) SetUpdateTime 

func (x *Stream) SetUpdateTime(v *timestamppb.Timestamp)

func (*Stream) String 

func (x *Stream) String() string

type StreamAnnotation 

type StreamAnnotation struct {

	// Types that are valid to be assigned to AnnotationPayload:
	//
	//	*StreamAnnotation_ActiveZone
	//	*StreamAnnotation_CrossingLine
	AnnotationPayload isStreamAnnotation_AnnotationPayload `protobuf_oneof:"annotation_payload"`
	// ID of the annotation. It must be unique when used in the certain context.
	// For example, all the annotations to one input streams of a Vision AI
	// application.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// User-friendly name for the annotation.
	DisplayName string `protobuf:"bytes,2,opt,name=display_name,json=displayName,proto3" json:"display_name,omitempty"`
	// The Vision AI stream resource name.
	SourceStream string `protobuf:"bytes,3,opt,name=source_stream,json=sourceStream,proto3" json:"source_stream,omitempty"`
	// The actual type of Annotation.
	Type StreamAnnotationType `protobuf:"varint,4,opt,name=type,proto3,enum=google.events.cloud.visionai.v1.StreamAnnotationType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

message about annotations about Vision AI stream resource.

func (*StreamAnnotation) ClearActiveZone 

func (x *StreamAnnotation) ClearActiveZone()

func (*StreamAnnotation) ClearAnnotationPayload 

func (x *StreamAnnotation) ClearAnnotationPayload()

func (*StreamAnnotation) ClearCrossingLine 

func (x *StreamAnnotation) ClearCrossingLine()

func (*StreamAnnotation) GetActiveZone 

func (x *StreamAnnotation) GetActiveZone() *NormalizedPolygon

func (*StreamAnnotation) GetAnnotationPayload 

func (x *StreamAnnotation) GetAnnotationPayload() isStreamAnnotation_AnnotationPayload

func (*StreamAnnotation) GetCrossingLine 

func (x *StreamAnnotation) GetCrossingLine() *NormalizedPolyline

func (*StreamAnnotation) GetDisplayName 

func (x *StreamAnnotation) GetDisplayName() string

func (*StreamAnnotation) GetId 

func (x *StreamAnnotation) GetId() string

func (*StreamAnnotation) GetSourceStream 

func (x *StreamAnnotation) GetSourceStream() string

func (*StreamAnnotation) GetType 

func (x *StreamAnnotation) GetType() StreamAnnotationType

func (*StreamAnnotation) HasActiveZone 

func (x *StreamAnnotation) HasActiveZone() bool

func (*StreamAnnotation) HasAnnotationPayload 

func (x *StreamAnnotation) HasAnnotationPayload() bool

func (*StreamAnnotation) HasCrossingLine 

func (x *StreamAnnotation) HasCrossingLine() bool

func (*StreamAnnotation) ProtoMessage 

func (*StreamAnnotation) ProtoMessage()

func (*StreamAnnotation) ProtoReflect 

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

func (*StreamAnnotation) Reset 

func (x *StreamAnnotation) Reset()

func (*StreamAnnotation) SetActiveZone 

func (x *StreamAnnotation) SetActiveZone(v *NormalizedPolygon)

func (*StreamAnnotation) SetCrossingLine 

func (x *StreamAnnotation) SetCrossingLine(v *NormalizedPolyline)

func (*StreamAnnotation) SetDisplayName 

func (x *StreamAnnotation) SetDisplayName(v string)

func (*StreamAnnotation) SetId 

func (x *StreamAnnotation) SetId(v string)

func (*StreamAnnotation) SetSourceStream 

func (x *StreamAnnotation) SetSourceStream(v string)

func (*StreamAnnotation) SetType 

func (x *StreamAnnotation) SetType(v StreamAnnotationType)

func (*StreamAnnotation) String 

func (x *StreamAnnotation) String() string

func (*StreamAnnotation) WhichAnnotationPayload 

func (x *StreamAnnotation) WhichAnnotationPayload() case_StreamAnnotation_AnnotationPayload

type StreamAnnotationType 

type StreamAnnotationType int32

Enum describing all possible types of a stream annotation. 

const (
	// Type UNSPECIFIED.
	StreamAnnotationType_STREAM_ANNOTATION_TYPE_UNSPECIFIED StreamAnnotationType = 0
	// active_zone annotation defines a polygon on top of the content from an
	// image/video based stream, following processing will only focus on the
	// content inside the active zone.
	StreamAnnotationType_STREAM_ANNOTATION_TYPE_ACTIVE_ZONE StreamAnnotationType = 1
	// crossing_line annotation defines a polyline on top of the content from an
	// image/video based Vision AI stream, events happening across the line will
	// be captured. For example, the counts of people who goes acroos the line
	// in Occupancy Analytic Processor.
	StreamAnnotationType_STREAM_ANNOTATION_TYPE_CROSSING_LINE StreamAnnotationType = 2
)

func (StreamAnnotationType) Descriptor 

func (StreamAnnotationType) Descriptor() protoreflect.EnumDescriptor

func (StreamAnnotationType) Enum 

func (x StreamAnnotationType) Enum() *StreamAnnotationType

func (StreamAnnotationType) Number 

func (x StreamAnnotationType) Number() protoreflect.EnumNumber

func (StreamAnnotationType) String 

func (x StreamAnnotationType) String() string

func (StreamAnnotationType) Type 

func (StreamAnnotationType) Type() protoreflect.EnumType

type StreamAnnotation_ActiveZone 

type StreamAnnotation_ActiveZone struct {
	// Annotation for type ACTIVE_ZONE
	ActiveZone *NormalizedPolygon `protobuf:"bytes,5,opt,name=active_zone,json=activeZone,proto3,oneof"`
}

type StreamAnnotation_CrossingLine 

type StreamAnnotation_CrossingLine struct {
	// Annotation for type CROSSING_LINE
	CrossingLine *NormalizedPolyline `protobuf:"bytes,6,opt,name=crossing_line,json=crossingLine,proto3,oneof"`
}

type StreamAnnotation_builder 

type StreamAnnotation_builder struct {

	// Fields of oneof AnnotationPayload:
	// Annotation for type ACTIVE_ZONE
	ActiveZone *NormalizedPolygon
	// Annotation for type CROSSING_LINE
	CrossingLine *NormalizedPolyline
	// -- end of AnnotationPayload
	// ID of the annotation. It must be unique when used in the certain context.
	// For example, all the annotations to one input streams of a Vision AI
	// application.
	Id string
	// User-friendly name for the annotation.
	DisplayName string
	// The Vision AI stream resource name.
	SourceStream string
	// The actual type of Annotation.
	Type StreamAnnotationType
	// contains filtered or unexported fields
}

func (StreamAnnotation_builder) Build 

func (b0 StreamAnnotation_builder) Build() *StreamAnnotation

type StreamCreatedEvent 

type StreamCreatedEvent struct {

	// The data associated with the event.
	Data *StreamEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Stream is created.

func (*StreamCreatedEvent) ClearData 

func (x *StreamCreatedEvent) ClearData()

func (*StreamCreatedEvent) GetData 

func (x *StreamCreatedEvent) GetData() *StreamEventData

func (*StreamCreatedEvent) HasData 

func (x *StreamCreatedEvent) HasData() bool

func (*StreamCreatedEvent) ProtoMessage 

func (*StreamCreatedEvent) ProtoMessage()

func (*StreamCreatedEvent) ProtoReflect 

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

func (*StreamCreatedEvent) Reset 

func (x *StreamCreatedEvent) Reset()

func (*StreamCreatedEvent) SetData 

func (x *StreamCreatedEvent) SetData(v *StreamEventData)

func (*StreamCreatedEvent) String 

func (x *StreamCreatedEvent) String() string

type StreamCreatedEvent_builder 

type StreamCreatedEvent_builder struct {

	// The data associated with the event.
	Data *StreamEventData
	// contains filtered or unexported fields
}

func (StreamCreatedEvent_builder) Build 

func (b0 StreamCreatedEvent_builder) Build() *StreamCreatedEvent

type StreamDeletedEvent 

type StreamDeletedEvent struct {

	// The data associated with the event.
	Data *StreamEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Stream is deleted.

func (*StreamDeletedEvent) ClearData 

func (x *StreamDeletedEvent) ClearData()

func (*StreamDeletedEvent) GetData 

func (x *StreamDeletedEvent) GetData() *StreamEventData

func (*StreamDeletedEvent) HasData 

func (x *StreamDeletedEvent) HasData() bool

func (*StreamDeletedEvent) ProtoMessage 

func (*StreamDeletedEvent) ProtoMessage()

func (*StreamDeletedEvent) ProtoReflect 

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

func (*StreamDeletedEvent) Reset 

func (x *StreamDeletedEvent) Reset()

func (*StreamDeletedEvent) SetData 

func (x *StreamDeletedEvent) SetData(v *StreamEventData)

func (*StreamDeletedEvent) String 

func (x *StreamDeletedEvent) String() string

type StreamDeletedEvent_builder 

type StreamDeletedEvent_builder struct {

	// The data associated with the event.
	Data *StreamEventData
	// contains filtered or unexported fields
}

func (StreamDeletedEvent_builder) Build 

func (b0 StreamDeletedEvent_builder) Build() *StreamDeletedEvent

type StreamEventData 

type StreamEventData struct {

	// Optional. The Stream event payload. Unset for deletion events.
	Payload *Stream `protobuf:"bytes,1,opt,name=payload,proto3,oneof" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The data within all Stream events.

func (*StreamEventData) ClearPayload 

func (x *StreamEventData) ClearPayload()

func (*StreamEventData) GetPayload 

func (x *StreamEventData) GetPayload() *Stream

func (*StreamEventData) HasPayload 

func (x *StreamEventData) HasPayload() bool

func (*StreamEventData) ProtoMessage 

func (*StreamEventData) ProtoMessage()

func (*StreamEventData) ProtoReflect 

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

func (*StreamEventData) Reset 

func (x *StreamEventData) Reset()

func (*StreamEventData) SetPayload 

func (x *StreamEventData) SetPayload(v *Stream)

func (*StreamEventData) String 

func (x *StreamEventData) String() string

type StreamEventData_builder 

type StreamEventData_builder struct {

	// Optional. The Stream event payload. Unset for deletion events.
	Payload *Stream
	// contains filtered or unexported fields
}

func (StreamEventData_builder) Build 

func (b0 StreamEventData_builder) Build() *StreamEventData

type StreamUpdatedEvent 

type StreamUpdatedEvent struct {

	// The data associated with the event.
	Data *StreamEventData `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

The CloudEvent raised when a Stream is updated.

func (*StreamUpdatedEvent) ClearData 

func (x *StreamUpdatedEvent) ClearData()

func (*StreamUpdatedEvent) GetData 

func (x *StreamUpdatedEvent) GetData() *StreamEventData

func (*StreamUpdatedEvent) HasData 

func (x *StreamUpdatedEvent) HasData() bool

func (*StreamUpdatedEvent) ProtoMessage 

func (*StreamUpdatedEvent) ProtoMessage()

func (*StreamUpdatedEvent) ProtoReflect 

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

func (*StreamUpdatedEvent) Reset 

func (x *StreamUpdatedEvent) Reset()

func (*StreamUpdatedEvent) SetData 

func (x *StreamUpdatedEvent) SetData(v *StreamEventData)

func (*StreamUpdatedEvent) String 

func (x *StreamUpdatedEvent) String() string

type StreamUpdatedEvent_builder 

type StreamUpdatedEvent_builder struct {

	// The data associated with the event.
	Data *StreamEventData
	// contains filtered or unexported fields
}

func (StreamUpdatedEvent_builder) Build 

func (b0 StreamUpdatedEvent_builder) Build() *StreamUpdatedEvent

type StreamWithAnnotation 

type StreamWithAnnotation struct {

	// Vision AI Stream resource name.
	Stream string `protobuf:"bytes,1,opt,name=stream,proto3" json:"stream,omitempty"`
	// Annotations that will be applied to the whole application.
	ApplicationAnnotations []*StreamAnnotation `` /* 127-byte string literal not displayed */
	// Annotations that will be applied to the specific node of the application.
	// If the same type of the annotations is applied to both application and
	// node, the node annotation will be added in addition to the global
	// application one.
	// For example, if there is one active zone annotation for the whole
	// application and one active zone annotation for the Occupancy Analytic
	// processor, then the Occupancy Analytic processor will have two active zones
	// defined.
	NodeAnnotations []*StreamWithAnnotation_NodeAnnotation `protobuf:"bytes,3,rep,name=node_annotations,json=nodeAnnotations,proto3" json:"node_annotations,omitempty"`
	// contains filtered or unexported fields
}

Message describing Vision AI stream with application specific annotations. All the StreamAnnotation object inside this message MUST have unique id.

func (*StreamWithAnnotation) GetApplicationAnnotations 

func (x *StreamWithAnnotation) GetApplicationAnnotations() []*StreamAnnotation

func (*StreamWithAnnotation) GetNodeAnnotations 

func (x *StreamWithAnnotation) GetNodeAnnotations() []*StreamWithAnnotation_NodeAnnotation

func (*StreamWithAnnotation) GetStream 

func (x *StreamWithAnnotation) GetStream() string

func (*StreamWithAnnotation) ProtoMessage 

func (*StreamWithAnnotation) ProtoMessage()

func (*StreamWithAnnotation) ProtoReflect 

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

func (*StreamWithAnnotation) Reset 

func (x *StreamWithAnnotation) Reset()

func (*StreamWithAnnotation) SetApplicationAnnotations 

func (x *StreamWithAnnotation) SetApplicationAnnotations(v []*StreamAnnotation)

func (*StreamWithAnnotation) SetNodeAnnotations 

func (x *StreamWithAnnotation) SetNodeAnnotations(v []*StreamWithAnnotation_NodeAnnotation)

func (*StreamWithAnnotation) SetStream 

func (x *StreamWithAnnotation) SetStream(v string)

func (*StreamWithAnnotation) String 

func (x *StreamWithAnnotation) String() string

type StreamWithAnnotation_NodeAnnotation 

type StreamWithAnnotation_NodeAnnotation 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.

func (*StreamWithAnnotation_NodeAnnotation) GetAnnotations 

func (x *StreamWithAnnotation_NodeAnnotation) GetAnnotations() []*StreamAnnotation

func (*StreamWithAnnotation_NodeAnnotation) GetNode 

func (x *StreamWithAnnotation_NodeAnnotation) GetNode() string

func (*StreamWithAnnotation_NodeAnnotation) ProtoMessage 

func (*StreamWithAnnotation_NodeAnnotation) ProtoMessage()

func (*StreamWithAnnotation_NodeAnnotation) ProtoReflect 

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

func (*StreamWithAnnotation_NodeAnnotation) Reset 

func (x *StreamWithAnnotation_NodeAnnotation) Reset()

func (*StreamWithAnnotation_NodeAnnotation) SetAnnotations 

func (x *StreamWithAnnotation_NodeAnnotation) SetAnnotations(v []*StreamAnnotation)

func (*StreamWithAnnotation_NodeAnnotation) SetNode 

func (x *StreamWithAnnotation_NodeAnnotation) SetNode(v string)

func (*StreamWithAnnotation_NodeAnnotation) String 

func (x *StreamWithAnnotation_NodeAnnotation) String() string

type StreamWithAnnotation_NodeAnnotation_builder 

type StreamWithAnnotation_NodeAnnotation_builder struct {

	// The node name of the application graph.
	Node string
	// The node specific stream annotations.
	Annotations []*StreamAnnotation
	// contains filtered or unexported fields
}

func (StreamWithAnnotation_NodeAnnotation_builder) Build 

func (b0 StreamWithAnnotation_NodeAnnotation_builder) Build() *StreamWithAnnotation_NodeAnnotation

type StreamWithAnnotation_builder 

type StreamWithAnnotation_builder struct {

	// Vision AI Stream resource name.
	Stream string
	// Annotations that will be applied to the whole application.
	ApplicationAnnotations []*StreamAnnotation
	// Annotations that will be applied to the specific node of the application.
	// If the same type of the annotations is applied to both application and
	// node, the node annotation will be added in addition to the global
	// application one.
	// For example, if there is one active zone annotation for the whole
	// application and one active zone annotation for the Occupancy Analytic
	// processor, then the Occupancy Analytic processor will have two active zones
	// defined.
	NodeAnnotations []*StreamWithAnnotation_NodeAnnotation
	// contains filtered or unexported fields
}

func (StreamWithAnnotation_builder) Build 

func (b0 StreamWithAnnotation_builder) Build() *StreamWithAnnotation

type Stream_builder 

type Stream_builder struct {

	// Name of the resource.
	Name string
	// Output only. The create timestamp.
	CreateTime *timestamppb.Timestamp
	// Output only. The update timestamp.
	UpdateTime *timestamppb.Timestamp
	// Labels as key value pairs.
	Labels map[string]string
	// Annotations to allow clients to store small amounts of arbitrary data.
	Annotations map[string]string
	// The display name for the stream resource.
	DisplayName string
	// Whether to enable the HLS playback service on this stream.
	EnableHlsPlayback bool
	// The name of the media warehouse asset for long term storage of stream data.
	// Format: projects/${p_id}/locations/${l_id}/corpora/${c_id}/assets/${a_id}
	// Remain empty if the media warehouse storage is not needed for the stream.
	MediaWarehouseAsset string
	// contains filtered or unexported fields
}

func (Stream_builder) Build 

func (b0 Stream_builder) Build() *Stream

type VertexAutoMLVideoConfig 

type VertexAutoMLVideoConfig struct {

	// Only entities with higher score than the threshold will be returned.
	// Value 0.0 means returns all the detected entities.
	ConfidenceThreshold float32 `protobuf:"fixed32,1,opt,name=confidence_threshold,json=confidenceThreshold,proto3" json:"confidence_threshold,omitempty"`
	// Labels specified in this field won't be returned.
	BlockedLabels []string `protobuf:"bytes,2,rep,name=blocked_labels,json=blockedLabels,proto3" json:"blocked_labels,omitempty"`
	// At most this many predictions will be returned per output frame.
	// Value 0 means to return all the detected entities.
	MaxPredictions int32 `protobuf:"varint,3,opt,name=max_predictions,json=maxPredictions,proto3" json:"max_predictions,omitempty"`
	// Only Bounding Box whose size is larger than this limit will be returned.
	// Object Tracking only.
	// Value 0.0 means to return all the detected entities.
	BoundingBoxSizeLimit float32 `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

Message describing VertexAutoMLVideoConfig.

func (*VertexAutoMLVideoConfig) GetBlockedLabels 

func (x *VertexAutoMLVideoConfig) GetBlockedLabels() []string

func (*VertexAutoMLVideoConfig) GetBoundingBoxSizeLimit 

func (x *VertexAutoMLVideoConfig) GetBoundingBoxSizeLimit() float32

func (*VertexAutoMLVideoConfig) GetConfidenceThreshold 

func (x *VertexAutoMLVideoConfig) GetConfidenceThreshold() float32

func (*VertexAutoMLVideoConfig) GetMaxPredictions 

func (x *VertexAutoMLVideoConfig) GetMaxPredictions() int32

func (*VertexAutoMLVideoConfig) ProtoMessage 

func (*VertexAutoMLVideoConfig) ProtoMessage()

func (*VertexAutoMLVideoConfig) ProtoReflect 

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

func (*VertexAutoMLVideoConfig) Reset 

func (x *VertexAutoMLVideoConfig) Reset()

func (*VertexAutoMLVideoConfig) SetBlockedLabels 

func (x *VertexAutoMLVideoConfig) SetBlockedLabels(v []string)

func (*VertexAutoMLVideoConfig) SetBoundingBoxSizeLimit 

func (x *VertexAutoMLVideoConfig) SetBoundingBoxSizeLimit(v float32)

func (*VertexAutoMLVideoConfig) SetConfidenceThreshold 

func (x *VertexAutoMLVideoConfig) SetConfidenceThreshold(v float32)

func (*VertexAutoMLVideoConfig) SetMaxPredictions 

func (x *VertexAutoMLVideoConfig) SetMaxPredictions(v int32)

func (*VertexAutoMLVideoConfig) String 

func (x *VertexAutoMLVideoConfig) String() string

type VertexAutoMLVideoConfig_builder 

type VertexAutoMLVideoConfig_builder struct {

	// Only entities with higher score than the threshold will be returned.
	// Value 0.0 means returns all the detected entities.
	ConfidenceThreshold float32
	// Labels specified in this field won't be returned.
	BlockedLabels []string
	// At most this many predictions will be returned per output frame.
	// Value 0 means to return all the detected entities.
	MaxPredictions int32
	// Only Bounding Box whose size is larger than this limit will be returned.
	// Object Tracking only.
	// Value 0.0 means to return all the detected entities.
	BoundingBoxSizeLimit float32
	// contains filtered or unexported fields
}

func (VertexAutoMLVideoConfig_builder) Build 

func (b0 VertexAutoMLVideoConfig_builder) Build() *VertexAutoMLVideoConfig

type VertexAutoMLVisionConfig 

type VertexAutoMLVisionConfig struct {

	// Only entities with higher score than the threshold will be returned.
	// Value 0.0 means to return all the detected entities.
	ConfidenceThreshold float32 `protobuf:"fixed32,1,opt,name=confidence_threshold,json=confidenceThreshold,proto3" json:"confidence_threshold,omitempty"`
	// At most this many predictions will be returned per output frame.
	// Value 0 means to return all the detected entities.
	MaxPredictions int32 `protobuf:"varint,2,opt,name=max_predictions,json=maxPredictions,proto3" json:"max_predictions,omitempty"`
	// contains filtered or unexported fields
}

Message of configurations of Vertex AutoML Vision Processors.

func (*VertexAutoMLVisionConfig) GetConfidenceThreshold 

func (x *VertexAutoMLVisionConfig) GetConfidenceThreshold() float32

func (*VertexAutoMLVisionConfig) GetMaxPredictions 

func (x *VertexAutoMLVisionConfig) GetMaxPredictions() int32

func (*VertexAutoMLVisionConfig) ProtoMessage 

func (*VertexAutoMLVisionConfig) ProtoMessage()

func (*VertexAutoMLVisionConfig) ProtoReflect 

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

func (*VertexAutoMLVisionConfig) Reset 

func (x *VertexAutoMLVisionConfig) Reset()

func (*VertexAutoMLVisionConfig) SetConfidenceThreshold 

func (x *VertexAutoMLVisionConfig) SetConfidenceThreshold(v float32)

func (*VertexAutoMLVisionConfig) SetMaxPredictions 

func (x *VertexAutoMLVisionConfig) SetMaxPredictions(v int32)

func (*VertexAutoMLVisionConfig) String 

func (x *VertexAutoMLVisionConfig) String() string

type VertexAutoMLVisionConfig_builder 

type VertexAutoMLVisionConfig_builder struct {

	// Only entities with higher score than the threshold will be returned.
	// Value 0.0 means to return all the detected entities.
	ConfidenceThreshold float32
	// At most this many predictions will be returned per output frame.
	// Value 0 means to return all the detected entities.
	MaxPredictions int32
	// contains filtered or unexported fields
}

func (VertexAutoMLVisionConfig_builder) Build 

func (b0 VertexAutoMLVisionConfig_builder) Build() *VertexAutoMLVisionConfig

type VertexCustomConfig 

type VertexCustomConfig struct {

	// The max prediction frame per second. This attribute sets how fast the
	// operator sends prediction requests to Vertex AI endpoint. Default value is
	// 0, which means there is no max prediction fps limit. The operator sends
	// prediction requests at input fps.
	MaxPredictionFps int32 `protobuf:"varint,1,opt,name=max_prediction_fps,json=maxPredictionFps,proto3" json:"max_prediction_fps,omitempty"`
	// A description of resources that are dedicated to the DeployedModel, and
	// that need a higher degree of manual configuration.
	DedicatedResources *DedicatedResources `protobuf:"bytes,2,opt,name=dedicated_resources,json=dedicatedResources,proto3" json:"dedicated_resources,omitempty"`
	// If not empty, the prediction result will be sent to the specified cloud
	// function for post processing.
	// * The cloud function will receive AppPlatformCloudFunctionRequest where
	// the annotations field will be the json format of proto PredictResponse.
	// * The cloud function should return AppPlatformCloudFunctionResponse with
	// PredictResponse stored in the annotations field.
	// * To drop the prediction output, simply clear the payload field in the
	// returned AppPlatformCloudFunctionResponse.
	PostProcessingCloudFunction string `` /* 146-byte string literal not displayed */
	// If true, the prediction request received by custom model will also contain
	// metadata with the following schema:
	//
	//	'appPlatformMetadata': {
	//	      'ingestionTime': DOUBLE; (UNIX timestamp)
	//	      'application': STRING;
	//	      'instanceId': STRING;
	//	      'node': STRING;
	//	      'processor': STRING;
	//	 }
	AttachApplicationMetadata bool `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

Message describing VertexCustomConfig.

func (*VertexCustomConfig) ClearDedicatedResources 

func (x *VertexCustomConfig) ClearDedicatedResources()

func (*VertexCustomConfig) GetAttachApplicationMetadata 

func (x *VertexCustomConfig) GetAttachApplicationMetadata() bool

func (*VertexCustomConfig) GetDedicatedResources 

func (x *VertexCustomConfig) GetDedicatedResources() *DedicatedResources

func (*VertexCustomConfig) GetMaxPredictionFps 

func (x *VertexCustomConfig) GetMaxPredictionFps() int32

func (*VertexCustomConfig) GetPostProcessingCloudFunction 

func (x *VertexCustomConfig) GetPostProcessingCloudFunction() string

func (*VertexCustomConfig) HasDedicatedResources 

func (x *VertexCustomConfig) HasDedicatedResources() bool

func (*VertexCustomConfig) ProtoMessage 

func (*VertexCustomConfig) ProtoMessage()

func (*VertexCustomConfig) ProtoReflect 

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

func (*VertexCustomConfig) Reset 

func (x *VertexCustomConfig) Reset()

func (*VertexCustomConfig) SetAttachApplicationMetadata 

func (x *VertexCustomConfig) SetAttachApplicationMetadata(v bool)

func (*VertexCustomConfig) SetDedicatedResources 

func (x *VertexCustomConfig) SetDedicatedResources(v *DedicatedResources)

func (*VertexCustomConfig) SetMaxPredictionFps 

func (x *VertexCustomConfig) SetMaxPredictionFps(v int32)

func (*VertexCustomConfig) SetPostProcessingCloudFunction 

func (x *VertexCustomConfig) SetPostProcessingCloudFunction(v string)

func (*VertexCustomConfig) String 

func (x *VertexCustomConfig) String() string

type VertexCustomConfig_builder 

type VertexCustomConfig_builder struct {

	// The max prediction frame per second. This attribute sets how fast the
	// operator sends prediction requests to Vertex AI endpoint. Default value is
	// 0, which means there is no max prediction fps limit. The operator sends
	// prediction requests at input fps.
	MaxPredictionFps int32
	// A description of resources that are dedicated to the DeployedModel, and
	// that need a higher degree of manual configuration.
	DedicatedResources *DedicatedResources
	// If not empty, the prediction result will be sent to the specified cloud
	// function for post processing.
	// * The cloud function will receive AppPlatformCloudFunctionRequest where
	// the annotations field will be the json format of proto PredictResponse.
	// * The cloud function should return AppPlatformCloudFunctionResponse with
	// PredictResponse stored in the annotations field.
	// * To drop the prediction output, simply clear the payload field in the
	// returned AppPlatformCloudFunctionResponse.
	PostProcessingCloudFunction string
	// If true, the prediction request received by custom model will also contain
	// metadata with the following schema:
	//
	//	'appPlatformMetadata': {
	//	      'ingestionTime': DOUBLE; (UNIX timestamp)
	//	      'application': STRING;
	//	      'instanceId': STRING;
	//	      'node': STRING;
	//	      'processor': STRING;
	//	 }
	AttachApplicationMetadata bool
	// contains filtered or unexported fields
}

func (VertexCustomConfig_builder) Build 

func (b0 VertexCustomConfig_builder) Build() *VertexCustomConfig

type VideoStreamInputConfig 

type VideoStreamInputConfig struct {
	Streams               []string                `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"`
	StreamsWithAnnotation []*StreamWithAnnotation `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

Message describing Video Stream Input Config. This message should only be used as a placeholder for builtin:stream-input processor, actual stream binding should be specified using corresponding API.

func (*VideoStreamInputConfig) GetStreams 

func (x *VideoStreamInputConfig) GetStreams() []string

func (*VideoStreamInputConfig) GetStreamsWithAnnotation 

func (x *VideoStreamInputConfig) GetStreamsWithAnnotation() []*StreamWithAnnotation

func (*VideoStreamInputConfig) ProtoMessage 

func (*VideoStreamInputConfig) ProtoMessage()

func (*VideoStreamInputConfig) ProtoReflect 

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

func (*VideoStreamInputConfig) Reset 

func (x *VideoStreamInputConfig) Reset()

func (*VideoStreamInputConfig) SetStreams 

func (x *VideoStreamInputConfig) SetStreams(v []string)

func (*VideoStreamInputConfig) SetStreamsWithAnnotation 

func (x *VideoStreamInputConfig) SetStreamsWithAnnotation(v []*StreamWithAnnotation)

func (*VideoStreamInputConfig) String 

func (x *VideoStreamInputConfig) String() string

type VideoStreamInputConfig_builder 

type VideoStreamInputConfig_builder struct {
	Streams               []string
	StreamsWithAnnotation []*StreamWithAnnotation
	// contains filtered or unexported fields
}

func (VideoStreamInputConfig_builder) Build 

func (b0 VideoStreamInputConfig_builder) Build() *VideoStreamInputConfig

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.