visionaidata

package
v0.8.0 Latest Latest
Warning

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

Go to latest
Published: Mar 29, 2024 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Overview

Package visionaidata provides Vision AI type definitions for CloudEvent data payloads.

Supported CloudEvent Types

  • google.cloud.visionai.analysis.v1.created
  • google.cloud.visionai.analysis.v1.updated
  • google.cloud.visionai.analysis.v1.deleted
  • google.cloud.visionai.process.v1.created
  • google.cloud.visionai.process.v1.updated
  • google.cloud.visionai.process.v1.deleted
  • google.cloud.visionai.application.v1.created
  • google.cloud.visionai.application.v1.updated
  • google.cloud.visionai.application.v1.deleted
  • google.cloud.visionai.draft.v1.created
  • google.cloud.visionai.draft.v1.updated
  • google.cloud.visionai.draft.v1.deleted
  • google.cloud.visionai.processor.v1.created
  • google.cloud.visionai.processor.v1.updated
  • google.cloud.visionai.processor.v1.deleted
  • google.cloud.visionai.cluster.v1.created
  • google.cloud.visionai.cluster.v1.updated
  • google.cloud.visionai.cluster.v1.deleted
  • google.cloud.visionai.stream.v1.created
  • google.cloud.visionai.stream.v1.updated
  • google.cloud.visionai.stream.v1.deleted
  • google.cloud.visionai.event.v1.created
  • google.cloud.visionai.event.v1.updated
  • google.cloud.visionai.event.v1.deleted
  • google.cloud.visionai.series.v1.created
  • google.cloud.visionai.series.v1.updated
  • google.cloud.visionai.series.v1.deleted

Index

Constants

This section is empty.

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_cloud_visionai_v1_data_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) Descriptor deprecated

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

Deprecated: Use AIEnabledDevicesInputConfig.ProtoReflect.Descriptor instead.

func (*AIEnabledDevicesInputConfig) ProtoMessage

func (*AIEnabledDevicesInputConfig) ProtoMessage()

func (*AIEnabledDevicesInputConfig) ProtoReflect

func (*AIEnabledDevicesInputConfig) Reset

func (x *AIEnabledDevicesInputConfig) Reset()

func (*AIEnabledDevicesInputConfig) String

func (x *AIEnabledDevicesInputConfig) String() string

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

func (x AcceleratorType) Enum() *AcceleratorType

func (AcceleratorType) EnumDescriptor deprecated

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

Deprecated: Use AcceleratorType.Descriptor instead.

func (AcceleratorType) Number

func (AcceleratorType) String

func (x AcceleratorType) String() string

func (AcceleratorType) Type

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 `` /* 153-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 `` /* 208-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 `` /* 211-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) Descriptor deprecated

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

Deprecated: Use Analysis.ProtoReflect.Descriptor instead.

func (*Analysis) GetAnalysisDefinition

func (x *Analysis) GetAnalysisDefinition() *AnalysisDefinition

func (*Analysis) GetCreateTime

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

func (*Analysis) GetDisableEventWatch

func (x *Analysis) GetDisableEventWatch() bool

func (*Analysis) GetInputStreamsMapping

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

func (*Analysis) GetLabels

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

func (*Analysis) GetName

func (x *Analysis) GetName() string

func (*Analysis) GetOutputStreamsMapping

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

func (*Analysis) GetUpdateTime

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

func (*Analysis) ProtoMessage

func (*Analysis) ProtoMessage()

func (*Analysis) ProtoReflect

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

func (*Analysis) Reset

func (x *Analysis) Reset()

func (*Analysis) String

func (x *Analysis) String() string

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

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

Deprecated: Use AnalysisDefinition.ProtoReflect.Descriptor instead.

func (*AnalysisDefinition) GetAnalyzers

func (x *AnalysisDefinition) GetAnalyzers() []*AnalyzerDefinition

func (*AnalysisDefinition) ProtoMessage

func (*AnalysisDefinition) ProtoMessage()

func (*AnalysisDefinition) ProtoReflect

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

func (*AnalysisDefinition) Reset

func (x *AnalysisDefinition) Reset()

func (*AnalysisDefinition) String

func (x *AnalysisDefinition) String() string

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

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

Deprecated: Use AnalysisEventData.ProtoReflect.Descriptor instead.

func (*AnalysisEventData) GetPayload

func (x *AnalysisEventData) GetPayload() *Analysis

func (*AnalysisEventData) ProtoMessage

func (*AnalysisEventData) ProtoMessage()

func (*AnalysisEventData) ProtoReflect

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

func (*AnalysisEventData) Reset

func (x *AnalysisEventData) Reset()

func (*AnalysisEventData) String

func (x *AnalysisEventData) String() string

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 `` /* 151-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) Descriptor deprecated

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

Deprecated: Use AnalyzerDefinition.ProtoReflect.Descriptor instead.

func (*AnalyzerDefinition) GetAnalyzer

func (x *AnalyzerDefinition) GetAnalyzer() string

func (*AnalyzerDefinition) GetAttrs

func (x *AnalyzerDefinition) GetAttrs() map[string]*AttributeValue

func (*AnalyzerDefinition) GetDebugOptions

func (*AnalyzerDefinition) GetInputs

func (*AnalyzerDefinition) GetOperator

func (x *AnalyzerDefinition) GetOperator() string

func (*AnalyzerDefinition) ProtoMessage

func (*AnalyzerDefinition) ProtoMessage()

func (*AnalyzerDefinition) ProtoReflect

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

func (*AnalyzerDefinition) Reset

func (x *AnalyzerDefinition) Reset()

func (*AnalyzerDefinition) String

func (x *AnalyzerDefinition) String() string

type AnalyzerDefinition_DebugOptions

type AnalyzerDefinition_DebugOptions struct {

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

Options available for debugging purposes only.

func (*AnalyzerDefinition_DebugOptions) Descriptor deprecated

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

Deprecated: Use AnalyzerDefinition_DebugOptions.ProtoReflect.Descriptor instead.

func (*AnalyzerDefinition_DebugOptions) GetEnvironmentVariables

func (x *AnalyzerDefinition_DebugOptions) GetEnvironmentVariables() map[string]string

func (*AnalyzerDefinition_DebugOptions) ProtoMessage

func (*AnalyzerDefinition_DebugOptions) ProtoMessage()

func (*AnalyzerDefinition_DebugOptions) ProtoReflect

func (*AnalyzerDefinition_DebugOptions) Reset

func (*AnalyzerDefinition_DebugOptions) String

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

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

Deprecated: Use AnalyzerDefinition_StreamInput.ProtoReflect.Descriptor instead.

func (*AnalyzerDefinition_StreamInput) GetInput

func (x *AnalyzerDefinition_StreamInput) GetInput() string

func (*AnalyzerDefinition_StreamInput) ProtoMessage

func (*AnalyzerDefinition_StreamInput) ProtoMessage()

func (*AnalyzerDefinition_StreamInput) ProtoReflect

func (*AnalyzerDefinition_StreamInput) Reset

func (x *AnalyzerDefinition_StreamInput) Reset()

func (*AnalyzerDefinition_StreamInput) String

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 `` /* 153-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) Descriptor deprecated

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

Deprecated: Use Application.ProtoReflect.Descriptor instead.

func (*Application) GetApplicationConfigs

func (x *Application) GetApplicationConfigs() *ApplicationConfigs

func (*Application) GetBillingMode

func (x *Application) GetBillingMode() Application_BillingMode

func (*Application) GetCreateTime

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

func (*Application) GetDescription

func (x *Application) GetDescription() string

func (*Application) GetDisplayName

func (x *Application) GetDisplayName() string

func (*Application) GetLabels

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

func (*Application) GetName

func (x *Application) GetName() string

func (*Application) GetRuntimeInfo

func (x *Application) GetRuntimeInfo() *Application_ApplicationRuntimeInfo

func (*Application) GetState

func (x *Application) GetState() Application_State

func (*Application) GetUpdateTime

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

func (*Application) ProtoMessage

func (*Application) ProtoMessage()

func (*Application) ProtoReflect

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

func (*Application) Reset

func (x *Application) Reset()

func (*Application) String

func (x *Application) String() string

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

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

Deprecated: Use ApplicationConfigs.ProtoReflect.Descriptor instead.

func (*ApplicationConfigs) GetNodes

func (x *ApplicationConfigs) GetNodes() []*Node

func (*ApplicationConfigs) ProtoMessage

func (*ApplicationConfigs) ProtoMessage()

func (*ApplicationConfigs) ProtoReflect

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

func (*ApplicationConfigs) Reset

func (x *ApplicationConfigs) Reset()

func (*ApplicationConfigs) String

func (x *ApplicationConfigs) String() string

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

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

Deprecated: Use ApplicationEventData.ProtoReflect.Descriptor instead.

func (*ApplicationEventData) GetPayload

func (x *ApplicationEventData) GetPayload() *Application

func (*ApplicationEventData) ProtoMessage

func (*ApplicationEventData) ProtoMessage()

func (*ApplicationEventData) ProtoReflect

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

func (*ApplicationEventData) Reset

func (x *ApplicationEventData) Reset()

func (*ApplicationEventData) String

func (x *ApplicationEventData) String() string

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

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

Deprecated: Use Application_ApplicationRuntimeInfo.ProtoReflect.Descriptor instead.

func (*Application_ApplicationRuntimeInfo) GetDeployTime

func (*Application_ApplicationRuntimeInfo) GetGlobalOutputResources

func (*Application_ApplicationRuntimeInfo) GetMonitoringConfig

func (*Application_ApplicationRuntimeInfo) ProtoMessage

func (*Application_ApplicationRuntimeInfo) ProtoMessage()

func (*Application_ApplicationRuntimeInfo) ProtoReflect

func (*Application_ApplicationRuntimeInfo) Reset

func (*Application_ApplicationRuntimeInfo) String

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

Deprecated: Use Application_ApplicationRuntimeInfo_GlobalOutputResource.ProtoReflect.Descriptor instead.

func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) GetKey

func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) GetOutputResource

func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) GetProducerNode

func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) ProtoMessage

func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) ProtoReflect

func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) Reset

func (*Application_ApplicationRuntimeInfo_GlobalOutputResource) String

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

Deprecated: Use Application_ApplicationRuntimeInfo_MonitoringConfig.ProtoReflect.Descriptor instead.

func (*Application_ApplicationRuntimeInfo_MonitoringConfig) GetEnabled

func (*Application_ApplicationRuntimeInfo_MonitoringConfig) ProtoMessage

func (*Application_ApplicationRuntimeInfo_MonitoringConfig) ProtoReflect

func (*Application_ApplicationRuntimeInfo_MonitoringConfig) Reset

func (*Application_ApplicationRuntimeInfo_MonitoringConfig) String

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

func (Application_BillingMode) EnumDescriptor deprecated

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

Deprecated: Use Application_BillingMode.Descriptor instead.

func (Application_BillingMode) Number

func (Application_BillingMode) String

func (x Application_BillingMode) String() string

func (Application_BillingMode) Type

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

func (Application_State) EnumDescriptor deprecated

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

Deprecated: Use Application_State.Descriptor instead.

func (Application_State) Number

func (Application_State) String

func (x Application_State) String() string

func (Application_State) Type

type AttributeValue

type AttributeValue struct {

	// Attribute value.
	//
	// Types that are assignable 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) Descriptor deprecated

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

Deprecated: Use AttributeValue.ProtoReflect.Descriptor instead.

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 (m *AttributeValue) GetValue() isAttributeValue_Value

func (*AttributeValue) ProtoMessage

func (*AttributeValue) ProtoMessage()

func (*AttributeValue) ProtoReflect

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

func (*AttributeValue) Reset

func (x *AttributeValue) Reset()

func (*AttributeValue) String

func (x *AttributeValue) String() string

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

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

Deprecated: Use AutoscalingMetricSpec.ProtoReflect.Descriptor instead.

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

func (x *AutoscalingMetricSpec) String() string

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 `` /* 211-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) Descriptor deprecated

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

Deprecated: Use BigQueryConfig.ProtoReflect.Descriptor instead.

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

func (x *BigQueryConfig) String() string

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 `` /* 153-byte string literal not displayed */
	// Annotations to allow clients to store small amounts of arbitrary data.
	Annotations map[string]string `` /* 163-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) Descriptor deprecated

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

Deprecated: Use Cluster.ProtoReflect.Descriptor instead.

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

func (*Cluster) ProtoMessage()

func (*Cluster) ProtoReflect

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

func (*Cluster) Reset

func (x *Cluster) Reset()

func (*Cluster) String

func (x *Cluster) String() string

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

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

Deprecated: Use ClusterEventData.ProtoReflect.Descriptor instead.

func (*ClusterEventData) GetPayload

func (x *ClusterEventData) GetPayload() *Cluster

func (*ClusterEventData) ProtoMessage

func (*ClusterEventData) ProtoMessage()

func (*ClusterEventData) ProtoReflect

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

func (*ClusterEventData) Reset

func (x *ClusterEventData) Reset()

func (*ClusterEventData) String

func (x *ClusterEventData) String() string

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

func (x Cluster_State) Enum() *Cluster_State

func (Cluster_State) EnumDescriptor deprecated

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

Deprecated: Use Cluster_State.Descriptor instead.

func (Cluster_State) Number

func (Cluster_State) String

func (x Cluster_State) String() string

func (Cluster_State) Type

type CustomProcessorSourceInfo

type CustomProcessorSourceInfo struct {

	// The path where App Platform loads the artifacts for the custom processor.
	//
	// Types that are assignable 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 `` /* 191-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) Descriptor deprecated

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

Deprecated: Use CustomProcessorSourceInfo.ProtoReflect.Descriptor instead.

func (*CustomProcessorSourceInfo) GetAdditionalInfo

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

func (*CustomProcessorSourceInfo) GetArtifactPath

func (m *CustomProcessorSourceInfo) GetArtifactPath() isCustomProcessorSourceInfo_ArtifactPath

func (*CustomProcessorSourceInfo) GetModelSchema

func (*CustomProcessorSourceInfo) GetSourceType

func (*CustomProcessorSourceInfo) GetVertexModel

func (x *CustomProcessorSourceInfo) GetVertexModel() string

func (*CustomProcessorSourceInfo) ProtoMessage

func (*CustomProcessorSourceInfo) ProtoMessage()

func (*CustomProcessorSourceInfo) ProtoReflect

func (*CustomProcessorSourceInfo) Reset

func (x *CustomProcessorSourceInfo) Reset()

func (*CustomProcessorSourceInfo) String

func (x *CustomProcessorSourceInfo) String() string

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

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

Deprecated: Use CustomProcessorSourceInfo_ModelSchema.ProtoReflect.Descriptor instead.

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

func (*CustomProcessorSourceInfo_ModelSchema) ProtoMessage()

func (*CustomProcessorSourceInfo_ModelSchema) ProtoReflect

func (*CustomProcessorSourceInfo_ModelSchema) Reset

func (*CustomProcessorSourceInfo_ModelSchema) String

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

func (CustomProcessorSourceInfo_SourceType) EnumDescriptor deprecated

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

Deprecated: Use CustomProcessorSourceInfo_SourceType.Descriptor instead.

func (CustomProcessorSourceInfo_SourceType) Number

func (CustomProcessorSourceInfo_SourceType) String

func (CustomProcessorSourceInfo_SourceType) Type

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

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

Deprecated: Use DataType.Descriptor instead.

func (DataType) Number

func (x DataType) Number() protoreflect.EnumNumber

func (DataType) String

func (x DataType) String() string

func (DataType) Type

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

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

Deprecated: Use DedicatedResources.ProtoReflect.Descriptor instead.

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

func (*DedicatedResources) ProtoMessage()

func (*DedicatedResources) ProtoReflect

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

func (*DedicatedResources) Reset

func (x *DedicatedResources) Reset()

func (*DedicatedResources) String

func (x *DedicatedResources) String() string

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 `` /* 153-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) Descriptor deprecated

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

Deprecated: Use Draft.ProtoReflect.Descriptor instead.

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

func (*Draft) ProtoMessage()

func (*Draft) ProtoReflect

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

func (*Draft) Reset

func (x *Draft) Reset()

func (*Draft) String

func (x *Draft) String() string

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

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

Deprecated: Use DraftEventData.ProtoReflect.Descriptor instead.

func (*DraftEventData) GetPayload

func (x *DraftEventData) GetPayload() *Draft

func (*DraftEventData) ProtoMessage

func (*DraftEventData) ProtoMessage()

func (*DraftEventData) ProtoReflect

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

func (*DraftEventData) Reset

func (x *DraftEventData) Reset()

func (*DraftEventData) String

func (x *DraftEventData) String() string

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 `` /* 153-byte string literal not displayed */
	// Annotations to allow clients to store small amounts of arbitrary data.
	Annotations map[string]string `` /* 163-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) Descriptor deprecated

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

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

func (*Event) ProtoMessage()

func (*Event) ProtoReflect

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

func (*Event) Reset

func (x *Event) Reset()

func (*Event) String

func (x *Event) String() string

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

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

Deprecated: Use EventEventData.ProtoReflect.Descriptor instead.

func (*EventEventData) GetPayload

func (x *EventEventData) GetPayload() *Event

func (*EventEventData) ProtoMessage

func (*EventEventData) ProtoMessage()

func (*EventEventData) ProtoReflect

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

func (*EventEventData) Reset

func (x *EventEventData) Reset()

func (*EventEventData) String

func (x *EventEventData) String() string

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

func (x Event_Clock) Enum() *Event_Clock

func (Event_Clock) EnumDescriptor deprecated

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

Deprecated: Use Event_Clock.Descriptor instead.

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

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

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

Deprecated: Use GcsSource.ProtoReflect.Descriptor instead.

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

func (x *GcsSource) String() string

type GeneralObjectDetectionConfig

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

Message of configurations for General Object Detection processor.

func (*GeneralObjectDetectionConfig) Descriptor deprecated

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

Deprecated: Use GeneralObjectDetectionConfig.ProtoReflect.Descriptor instead.

func (*GeneralObjectDetectionConfig) ProtoMessage

func (*GeneralObjectDetectionConfig) ProtoMessage()

func (*GeneralObjectDetectionConfig) ProtoReflect

func (*GeneralObjectDetectionConfig) Reset

func (x *GeneralObjectDetectionConfig) Reset()

func (*GeneralObjectDetectionConfig) String

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

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

Deprecated: Use MachineSpec.ProtoReflect.Descriptor instead.

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

func (x *MachineSpec) String() string

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

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

Deprecated: Use MediaWarehouseConfig.ProtoReflect.Descriptor instead.

func (*MediaWarehouseConfig) GetCorpus

func (x *MediaWarehouseConfig) GetCorpus() string

func (*MediaWarehouseConfig) GetRegion

func (x *MediaWarehouseConfig) GetRegion() string

func (*MediaWarehouseConfig) GetTtl

func (*MediaWarehouseConfig) ProtoMessage

func (*MediaWarehouseConfig) ProtoMessage()

func (*MediaWarehouseConfig) ProtoReflect

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

func (*MediaWarehouseConfig) Reset

func (x *MediaWarehouseConfig) Reset()

func (*MediaWarehouseConfig) String

func (x *MediaWarehouseConfig) String() string

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

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

Deprecated: Use ModelType.Descriptor instead.

func (ModelType) Number

func (x ModelType) Number() protoreflect.EnumNumber

func (ModelType) String

func (x ModelType) String() string

func (ModelType) Type

type Node

type Node struct {

	// Types that are assignable 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) Descriptor deprecated

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

Deprecated: Use Node.ProtoReflect.Descriptor instead.

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 (m *Node) GetStreamOutputConfig() isNode_StreamOutputConfig

func (*Node) ProtoMessage

func (*Node) ProtoMessage()

func (*Node) ProtoReflect

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

func (*Node) Reset

func (x *Node) Reset()

func (*Node) String

func (x *Node) String() string

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

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

Deprecated: Use Node_InputEdge.ProtoReflect.Descriptor instead.

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

func (x *Node_InputEdge) String() string

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

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

Deprecated: Use NormalizedPolygon.ProtoReflect.Descriptor instead.

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

func (x *NormalizedPolygon) String() string

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

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

Deprecated: Use NormalizedPolyline.ProtoReflect.Descriptor instead.

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

func (x *NormalizedPolyline) String() string

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

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

Deprecated: Use NormalizedVertex.ProtoReflect.Descriptor instead.

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

func (x *NormalizedVertex) String() string

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

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

Deprecated: Use OccupancyCountConfig.ProtoReflect.Descriptor instead.

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

func (x *OccupancyCountConfig) String() string

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

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

Deprecated: Use PersonBlurConfig.ProtoReflect.Descriptor instead.

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

func (PersonBlurConfig_PersonBlurType) EnumDescriptor deprecated

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

Deprecated: Use PersonBlurConfig_PersonBlurType.Descriptor instead.

func (PersonBlurConfig_PersonBlurType) Number

func (PersonBlurConfig_PersonBlurType) String

func (PersonBlurConfig_PersonBlurType) Type

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

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

Deprecated: Use PersonVehicleDetectionConfig.ProtoReflect.Descriptor instead.

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

func (x *PersonVehicleDetectionConfig) Reset()

func (*PersonVehicleDetectionConfig) String

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

Deprecated: Use PersonalProtectiveEquipmentDetectionConfig.ProtoReflect.Descriptor instead.

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

func (*PersonalProtectiveEquipmentDetectionConfig) Reset

func (*PersonalProtectiveEquipmentDetectionConfig) String

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

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

Deprecated: Use Process.ProtoReflect.Descriptor instead.

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

func (*Process) ProtoMessage()

func (*Process) ProtoReflect

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

func (*Process) Reset

func (x *Process) Reset()

func (*Process) String

func (x *Process) String() string

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

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

Deprecated: Use ProcessEventData.ProtoReflect.Descriptor instead.

func (*ProcessEventData) GetPayload

func (x *ProcessEventData) GetPayload() *Process

func (*ProcessEventData) ProtoMessage

func (*ProcessEventData) ProtoMessage()

func (*ProcessEventData) ProtoReflect

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

func (*ProcessEventData) Reset

func (x *ProcessEventData) Reset()

func (*ProcessEventData) String

func (x *ProcessEventData) String() string

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 `` /* 153-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) Descriptor deprecated

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

Deprecated: Use Processor.ProtoReflect.Descriptor instead.

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

func (*Processor) ProtoMessage()

func (*Processor) ProtoReflect

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

func (*Processor) Reset

func (x *Processor) Reset()

func (*Processor) String

func (x *Processor) String() string

type ProcessorConfig

type ProcessorConfig struct {

	// Types that are assignable 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) Descriptor deprecated

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

Deprecated: Use ProcessorConfig.ProtoReflect.Descriptor instead.

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 (m *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) ProtoMessage

func (*ProcessorConfig) ProtoMessage()

func (*ProcessorConfig) ProtoReflect

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

func (*ProcessorConfig) Reset

func (x *ProcessorConfig) Reset()

func (*ProcessorConfig) String

func (x *ProcessorConfig) String() string

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

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

Deprecated: Use ProcessorEventData.ProtoReflect.Descriptor instead.

func (*ProcessorEventData) GetPayload

func (x *ProcessorEventData) GetPayload() *Processor

func (*ProcessorEventData) ProtoMessage

func (*ProcessorEventData) ProtoMessage()

func (*ProcessorEventData) ProtoReflect

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

func (*ProcessorEventData) Reset

func (x *ProcessorEventData) Reset()

func (*ProcessorEventData) String

func (x *ProcessorEventData) String() string

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

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

Deprecated: Use ProcessorIOSpec.ProtoReflect.Descriptor instead.

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

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

Deprecated: Use ProcessorIOSpec_GraphInputChannelSpec.ProtoReflect.Descriptor instead.

func (*ProcessorIOSpec_GraphInputChannelSpec) GetAcceptedDataTypeUris

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

func (*ProcessorIOSpec_GraphInputChannelSpec) GetDataType

func (*ProcessorIOSpec_GraphInputChannelSpec) GetMaxConnectionAllowed

func (x *ProcessorIOSpec_GraphInputChannelSpec) GetMaxConnectionAllowed() int64

func (*ProcessorIOSpec_GraphInputChannelSpec) GetName

func (*ProcessorIOSpec_GraphInputChannelSpec) GetRequired

func (*ProcessorIOSpec_GraphInputChannelSpec) ProtoMessage

func (*ProcessorIOSpec_GraphInputChannelSpec) ProtoMessage()

func (*ProcessorIOSpec_GraphInputChannelSpec) ProtoReflect

func (*ProcessorIOSpec_GraphInputChannelSpec) Reset

func (*ProcessorIOSpec_GraphInputChannelSpec) String

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

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

Deprecated: Use ProcessorIOSpec_GraphOutputChannelSpec.ProtoReflect.Descriptor instead.

func (*ProcessorIOSpec_GraphOutputChannelSpec) GetDataType

func (*ProcessorIOSpec_GraphOutputChannelSpec) GetDataTypeUri

func (x *ProcessorIOSpec_GraphOutputChannelSpec) GetDataTypeUri() string

func (*ProcessorIOSpec_GraphOutputChannelSpec) GetName

func (*ProcessorIOSpec_GraphOutputChannelSpec) ProtoMessage

func (*ProcessorIOSpec_GraphOutputChannelSpec) ProtoReflect

func (*ProcessorIOSpec_GraphOutputChannelSpec) Reset

func (*ProcessorIOSpec_GraphOutputChannelSpec) String

type ProcessorIOSpec_InstanceResourceInputBindingSpec

type ProcessorIOSpec_InstanceResourceInputBindingSpec struct {

	// Types that are assignable 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) Descriptor deprecated

Deprecated: Use ProcessorIOSpec_InstanceResourceInputBindingSpec.ProtoReflect.Descriptor instead.

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) GetConfigTypeUri

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) GetName

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) GetResourceType

func (m *ProcessorIOSpec_InstanceResourceInputBindingSpec) GetResourceType() isProcessorIOSpec_InstanceResourceInputBindingSpec_ResourceType

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) GetResourceTypeUri

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) ProtoMessage

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) ProtoReflect

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) Reset

func (*ProcessorIOSpec_InstanceResourceInputBindingSpec) String

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_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) Descriptor deprecated

Deprecated: Use ProcessorIOSpec_InstanceResourceOutputBindingSpec.ProtoReflect.Descriptor instead.

func (*ProcessorIOSpec_InstanceResourceOutputBindingSpec) GetExplicit

func (*ProcessorIOSpec_InstanceResourceOutputBindingSpec) GetName

func (*ProcessorIOSpec_InstanceResourceOutputBindingSpec) GetResourceTypeUri

func (*ProcessorIOSpec_InstanceResourceOutputBindingSpec) ProtoMessage

func (*ProcessorIOSpec_InstanceResourceOutputBindingSpec) ProtoReflect

func (*ProcessorIOSpec_InstanceResourceOutputBindingSpec) Reset

func (*ProcessorIOSpec_InstanceResourceOutputBindingSpec) String

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

func (Processor_ProcessorState) EnumDescriptor deprecated

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

Deprecated: Use Processor_ProcessorState.Descriptor instead.

func (Processor_ProcessorState) Number

func (Processor_ProcessorState) String

func (x Processor_ProcessorState) String() string

func (Processor_ProcessorState) Type

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

func (Processor_ProcessorType) EnumDescriptor deprecated

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

Deprecated: Use Processor_ProcessorType.Descriptor instead.

func (Processor_ProcessorType) Number

func (Processor_ProcessorType) String

func (x Processor_ProcessorType) String() string

func (Processor_ProcessorType) Type

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

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

Deprecated: Use RunMode.Descriptor instead.

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

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

Deprecated: Use RunStatus.ProtoReflect.Descriptor instead.

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

func (x RunStatus_State) Enum() *RunStatus_State

func (RunStatus_State) EnumDescriptor deprecated

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

Deprecated: Use RunStatus_State.Descriptor instead.

func (RunStatus_State) Number

func (RunStatus_State) String

func (x RunStatus_State) String() string

func (RunStatus_State) Type

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 `` /* 153-byte string literal not displayed */
	// Annotations to allow clients to store small amounts of arbitrary data.
	Annotations map[string]string `` /* 163-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) Descriptor deprecated

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

Deprecated: Use Series.ProtoReflect.Descriptor instead.

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

func (*Series) ProtoMessage()

func (*Series) ProtoReflect

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

func (*Series) Reset

func (x *Series) Reset()

func (*Series) String

func (x *Series) String() string

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

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

Deprecated: Use SeriesEventData.ProtoReflect.Descriptor instead.

func (*SeriesEventData) GetPayload

func (x *SeriesEventData) GetPayload() *Series

func (*SeriesEventData) ProtoMessage

func (*SeriesEventData) ProtoMessage()

func (*SeriesEventData) ProtoReflect

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

func (*SeriesEventData) Reset

func (x *SeriesEventData) Reset()

func (*SeriesEventData) String

func (x *SeriesEventData) String() string

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 `` /* 153-byte string literal not displayed */
	// Annotations to allow clients to store small amounts of arbitrary data.
	Annotations map[string]string `` /* 163-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) Descriptor deprecated

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

Deprecated: Use Stream.ProtoReflect.Descriptor instead.

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

func (*Stream) ProtoMessage()

func (*Stream) ProtoReflect

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

func (*Stream) Reset

func (x *Stream) Reset()

func (*Stream) String

func (x *Stream) String() string

type StreamAnnotation

type StreamAnnotation struct {

	// Types that are assignable 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) Descriptor deprecated

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

Deprecated: Use StreamAnnotation.ProtoReflect.Descriptor instead.

func (*StreamAnnotation) GetActiveZone

func (x *StreamAnnotation) GetActiveZone() *NormalizedPolygon

func (*StreamAnnotation) GetAnnotationPayload

func (m *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 (*StreamAnnotation) ProtoMessage

func (*StreamAnnotation) ProtoMessage()

func (*StreamAnnotation) ProtoReflect

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

func (*StreamAnnotation) Reset

func (x *StreamAnnotation) Reset()

func (*StreamAnnotation) String

func (x *StreamAnnotation) String() string

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

func (StreamAnnotationType) EnumDescriptor deprecated

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

Deprecated: Use StreamAnnotationType.Descriptor instead.

func (StreamAnnotationType) Number

func (StreamAnnotationType) String

func (x StreamAnnotationType) String() string

func (StreamAnnotationType) Type

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

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

Deprecated: Use StreamEventData.ProtoReflect.Descriptor instead.

func (*StreamEventData) GetPayload

func (x *StreamEventData) GetPayload() *Stream

func (*StreamEventData) ProtoMessage

func (*StreamEventData) ProtoMessage()

func (*StreamEventData) ProtoReflect

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

func (*StreamEventData) Reset

func (x *StreamEventData) Reset()

func (*StreamEventData) String

func (x *StreamEventData) String() string

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

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

Deprecated: Use StreamWithAnnotation.ProtoReflect.Descriptor instead.

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

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

Deprecated: Use StreamWithAnnotation_NodeAnnotation.ProtoReflect.Descriptor instead.

func (*StreamWithAnnotation_NodeAnnotation) GetAnnotations

func (*StreamWithAnnotation_NodeAnnotation) GetNode

func (*StreamWithAnnotation_NodeAnnotation) ProtoMessage

func (*StreamWithAnnotation_NodeAnnotation) ProtoMessage()

func (*StreamWithAnnotation_NodeAnnotation) ProtoReflect

func (*StreamWithAnnotation_NodeAnnotation) Reset

func (*StreamWithAnnotation_NodeAnnotation) String

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

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

Deprecated: Use VertexAutoMLVideoConfig.ProtoReflect.Descriptor instead.

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

func (x *VertexAutoMLVideoConfig) String() string

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

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

Deprecated: Use VertexAutoMLVisionConfig.ProtoReflect.Descriptor instead.

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

func (x *VertexAutoMLVisionConfig) String() string

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

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

Deprecated: Use VertexCustomConfig.ProtoReflect.Descriptor instead.

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

func (*VertexCustomConfig) ProtoMessage()

func (*VertexCustomConfig) ProtoReflect

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

func (*VertexCustomConfig) Reset

func (x *VertexCustomConfig) Reset()

func (*VertexCustomConfig) String

func (x *VertexCustomConfig) String() string

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

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

Deprecated: Use VideoStreamInputConfig.ProtoReflect.Descriptor instead.

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

func (x *VideoStreamInputConfig) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL