payload

package
v1.7.12 Latest Latest
Warning

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

 Go to latest Published: Feb 22, 2024 License: Apache-2.0 Imports: 12 Imported by: 4

Documentation

Overview

Copyright (C) 2019-2024 vdaas.org vald team <vald@vdaas.org>

Licensed under the Apache License, Version 2.0 (the "License"); You may not use this file except in compliance with the License. You may obtain a copy of the License at 

https://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

Constants

This section is empty.

Variables

View Source 
var (
	Search_AggregationAlgorithm_name = map[int32]string{
		0: "Unknown",
		1: "ConcurrentQueue",
		2: "SortSlice",
		3: "SortPoolSlice",
		4: "PairingHeap",
	}
	Search_AggregationAlgorithm_value = map[string]int32{
		"Unknown":         0,
		"ConcurrentQueue": 1,
		"SortSlice":       2,
		"SortPoolSlice":   3,
		"PairingHeap":     4,
	}
)

Enum value maps for Search_AggregationAlgorithm.

View Source 
var (
	Remove_Timestamp_Operator_name = map[int32]string{
		0: "Eq",
		1: "Ne",
		2: "Ge",
		3: "Gt",
		4: "Le",
		5: "Lt",
	}
	Remove_Timestamp_Operator_value = map[string]int32{
		"Eq": 0,
		"Ne": 1,
		"Ge": 2,
		"Gt": 3,
		"Le": 4,
		"Lt": 5,
	}
)

Enum value maps for Remove_Timestamp_Operator.

View Source 
var File_v1_payload_payload_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type Control 

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

Control related messages.

func (*Control) CloneMessageVT added in v1.7.7 

func (m *Control) CloneMessageVT() proto.Message

func (*Control) CloneVT added in v1.7.7 

func (m *Control) CloneVT() *Control

func (*Control) Descriptor deprecated 

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

Deprecated: Use Control.ProtoReflect.Descriptor instead.

func (*Control) EqualMessageVT added in v1.7.6 

func (this *Control) EqualMessageVT(thatMsg proto.Message) bool

func (*Control) EqualVT added in v1.7.6 

func (this *Control) EqualVT(that *Control) bool

func (*Control) MarshalToSizedBufferVT added in v1.2.2 

func (m *Control) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Control) MarshalToVT added in v1.2.2 

func (m *Control) MarshalToVT(dAtA []byte) (int, error)

func (*Control) MarshalVT added in v1.2.2 

func (m *Control) MarshalVT() (dAtA []byte, err error)

func (*Control) ProtoMessage 

func (*Control) ProtoMessage()

func (*Control) ProtoReflect added in v1.2.2 

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

func (*Control) Reset 

func (x *Control) Reset()

func (*Control) SizeVT added in v1.2.2 

func (m *Control) SizeVT() (n int)

func (*Control) String 

func (x *Control) String() string

func (*Control) UnmarshalVT added in v1.2.2 

func (m *Control) UnmarshalVT(dAtA []byte) error

type Control_CreateIndexRequest 

type Control_CreateIndexRequest struct {

	// The pool size of the create index operation.
	PoolSize uint32 `protobuf:"varint,1,opt,name=pool_size,json=poolSize,proto3" json:"pool_size,omitempty"`
	// contains filtered or unexported fields
}

Represent the create index request.

func (*Control_CreateIndexRequest) CloneMessageVT added in v1.7.7 

func (m *Control_CreateIndexRequest) CloneMessageVT() proto.Message

func (*Control_CreateIndexRequest) CloneVT added in v1.7.7 

func (m *Control_CreateIndexRequest) CloneVT() *Control_CreateIndexRequest

func (*Control_CreateIndexRequest) Descriptor deprecated 

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

Deprecated: Use Control_CreateIndexRequest.ProtoReflect.Descriptor instead.

func (*Control_CreateIndexRequest) EqualMessageVT added in v1.7.6 

func (this *Control_CreateIndexRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*Control_CreateIndexRequest) EqualVT added in v1.7.6 

func (this *Control_CreateIndexRequest) EqualVT(that *Control_CreateIndexRequest) bool

func (*Control_CreateIndexRequest) GetPoolSize 

func (x *Control_CreateIndexRequest) GetPoolSize() uint32

func (*Control_CreateIndexRequest) MarshalToSizedBufferVT added in v1.2.2 

func (m *Control_CreateIndexRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Control_CreateIndexRequest) MarshalToVT added in v1.2.2 

func (m *Control_CreateIndexRequest) MarshalToVT(dAtA []byte) (int, error)

func (*Control_CreateIndexRequest) MarshalVT added in v1.2.2 

func (m *Control_CreateIndexRequest) MarshalVT() (dAtA []byte, err error)

func (*Control_CreateIndexRequest) ProtoMessage 

func (*Control_CreateIndexRequest) ProtoMessage()

func (*Control_CreateIndexRequest) ProtoReflect added in v1.2.2 

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

func (*Control_CreateIndexRequest) Reset 

func (x *Control_CreateIndexRequest) Reset()

func (*Control_CreateIndexRequest) SizeVT added in v1.2.2 

func (m *Control_CreateIndexRequest) SizeVT() (n int)

func (*Control_CreateIndexRequest) String 

func (x *Control_CreateIndexRequest) String() string

func (*Control_CreateIndexRequest) UnmarshalVT added in v1.2.2 

func (m *Control_CreateIndexRequest) UnmarshalVT(dAtA []byte) error

type Discoverer 

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

Discoverer related messages.

func (*Discoverer) CloneMessageVT added in v1.7.7 

func (m *Discoverer) CloneMessageVT() proto.Message

func (*Discoverer) CloneVT added in v1.7.7 

func (m *Discoverer) CloneVT() *Discoverer

func (*Discoverer) Descriptor deprecated 

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

Deprecated: Use Discoverer.ProtoReflect.Descriptor instead.

func (*Discoverer) EqualMessageVT added in v1.7.6 

func (this *Discoverer) EqualMessageVT(thatMsg proto.Message) bool

func (*Discoverer) EqualVT added in v1.7.6 

func (this *Discoverer) EqualVT(that *Discoverer) bool

func (*Discoverer) MarshalToSizedBufferVT added in v1.2.2 

func (m *Discoverer) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Discoverer) MarshalToVT added in v1.2.2 

func (m *Discoverer) MarshalToVT(dAtA []byte) (int, error)

func (*Discoverer) MarshalVT added in v1.2.2 

func (m *Discoverer) MarshalVT() (dAtA []byte, err error)

func (*Discoverer) ProtoMessage 

func (*Discoverer) ProtoMessage()

func (*Discoverer) ProtoReflect added in v1.2.2 

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

func (*Discoverer) Reset 

func (x *Discoverer) Reset()

func (*Discoverer) SizeVT added in v1.2.2 

func (m *Discoverer) SizeVT() (n int)

func (*Discoverer) String 

func (x *Discoverer) String() string

func (*Discoverer) UnmarshalVT added in v1.2.2 

func (m *Discoverer) UnmarshalVT(dAtA []byte) error

type Discoverer_Request 

type Discoverer_Request struct {

	// The agent name to be discovered.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The namespace to be discovered.
	Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// The node to be discovered.
	Node string `protobuf:"bytes,3,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

Represent the dicoverer request.

func (*Discoverer_Request) CloneMessageVT added in v1.7.7 

func (m *Discoverer_Request) CloneMessageVT() proto.Message

func (*Discoverer_Request) CloneVT added in v1.7.7 

func (m *Discoverer_Request) CloneVT() *Discoverer_Request

func (*Discoverer_Request) Descriptor deprecated 

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

Deprecated: Use Discoverer_Request.ProtoReflect.Descriptor instead.

func (*Discoverer_Request) EqualMessageVT added in v1.7.6 

func (this *Discoverer_Request) EqualMessageVT(thatMsg proto.Message) bool

func (*Discoverer_Request) EqualVT added in v1.7.6 

func (this *Discoverer_Request) EqualVT(that *Discoverer_Request) bool

func (*Discoverer_Request) GetName 

func (x *Discoverer_Request) GetName() string

func (*Discoverer_Request) GetNamespace 

func (x *Discoverer_Request) GetNamespace() string

func (*Discoverer_Request) GetNode 

func (x *Discoverer_Request) GetNode() string

func (*Discoverer_Request) MarshalToSizedBufferVT added in v1.2.2 

func (m *Discoverer_Request) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Discoverer_Request) MarshalToVT added in v1.2.2 

func (m *Discoverer_Request) MarshalToVT(dAtA []byte) (int, error)

func (*Discoverer_Request) MarshalVT added in v1.2.2 

func (m *Discoverer_Request) MarshalVT() (dAtA []byte, err error)

func (*Discoverer_Request) ProtoMessage 

func (*Discoverer_Request) ProtoMessage()

func (*Discoverer_Request) ProtoReflect added in v1.2.2 

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

func (*Discoverer_Request) Reset 

func (x *Discoverer_Request) Reset()

func (*Discoverer_Request) SizeVT added in v1.2.2 

func (m *Discoverer_Request) SizeVT() (n int)

func (*Discoverer_Request) String 

func (x *Discoverer_Request) String() string

func (*Discoverer_Request) UnmarshalVT added in v1.2.2 

func (m *Discoverer_Request) UnmarshalVT(dAtA []byte) error

type Empty 

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

Represent an empty message.

func (*Empty) CloneMessageVT added in v1.7.7 

func (m *Empty) CloneMessageVT() proto.Message

func (*Empty) CloneVT added in v1.7.7 

func (m *Empty) CloneVT() *Empty

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) EqualMessageVT added in v1.7.6 

func (this *Empty) EqualMessageVT(thatMsg proto.Message) bool

func (*Empty) EqualVT added in v1.7.6 

func (this *Empty) EqualVT(that *Empty) bool

func (*Empty) MarshalToSizedBufferVT added in v1.2.2 

func (m *Empty) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Empty) MarshalToVT added in v1.2.2 

func (m *Empty) MarshalToVT(dAtA []byte) (int, error)

func (*Empty) MarshalVT added in v1.2.2 

func (m *Empty) MarshalVT() (dAtA []byte, err error)

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect added in v1.2.2 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) SizeVT added in v1.2.2 

func (m *Empty) SizeVT() (n int)

func (*Empty) String 

func (x *Empty) String() string

func (*Empty) UnmarshalVT added in v1.2.2 

func (m *Empty) UnmarshalVT(dAtA []byte) error

type Filter 

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

Filter related messages.

func (*Filter) CloneMessageVT added in v1.7.7 

func (m *Filter) CloneMessageVT() proto.Message

func (*Filter) CloneVT added in v1.7.7 

func (m *Filter) CloneVT() *Filter

func (*Filter) Descriptor deprecated 

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

Deprecated: Use Filter.ProtoReflect.Descriptor instead.

func (*Filter) EqualMessageVT added in v1.7.6 

func (this *Filter) EqualMessageVT(thatMsg proto.Message) bool

func (*Filter) EqualVT added in v1.7.6 

func (this *Filter) EqualVT(that *Filter) bool

func (*Filter) MarshalToSizedBufferVT added in v1.2.2 

func (m *Filter) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Filter) MarshalToVT added in v1.2.2 

func (m *Filter) MarshalToVT(dAtA []byte) (int, error)

func (*Filter) MarshalVT added in v1.2.2 

func (m *Filter) MarshalVT() (dAtA []byte, err error)

func (*Filter) ProtoMessage 

func (*Filter) ProtoMessage()

func (*Filter) ProtoReflect added in v1.2.2 

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

func (*Filter) Reset 

func (x *Filter) Reset()

func (*Filter) SizeVT added in v1.2.2 

func (m *Filter) SizeVT() (n int)

func (*Filter) String 

func (x *Filter) String() string

func (*Filter) UnmarshalVT added in v1.2.2 

func (m *Filter) UnmarshalVT(dAtA []byte) error

type Filter_Config 

type Filter_Config struct {

	// Represent the filter target configuration.
	Targets []*Filter_Target `protobuf:"bytes,1,rep,name=targets,proto3" json:"targets,omitempty"`
	// contains filtered or unexported fields
}

Represent filter configuration.

func (*Filter_Config) CloneMessageVT added in v1.7.7 

func (m *Filter_Config) CloneMessageVT() proto.Message

func (*Filter_Config) CloneVT added in v1.7.7 

func (m *Filter_Config) CloneVT() *Filter_Config

func (*Filter_Config) Descriptor deprecated 

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

Deprecated: Use Filter_Config.ProtoReflect.Descriptor instead.

func (*Filter_Config) EqualMessageVT added in v1.7.6 

func (this *Filter_Config) EqualMessageVT(thatMsg proto.Message) bool

func (*Filter_Config) EqualVT added in v1.7.6 

func (this *Filter_Config) EqualVT(that *Filter_Config) bool

func (*Filter_Config) GetTargets 

func (x *Filter_Config) GetTargets() []*Filter_Target

func (*Filter_Config) MarshalToSizedBufferVT added in v1.2.2 

func (m *Filter_Config) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Filter_Config) MarshalToVT added in v1.2.2 

func (m *Filter_Config) MarshalToVT(dAtA []byte) (int, error)

func (*Filter_Config) MarshalVT added in v1.2.2 

func (m *Filter_Config) MarshalVT() (dAtA []byte, err error)

func (*Filter_Config) ProtoMessage 

func (*Filter_Config) ProtoMessage()

func (*Filter_Config) ProtoReflect added in v1.2.2 

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

func (*Filter_Config) Reset 

func (x *Filter_Config) Reset()

func (*Filter_Config) SizeVT added in v1.2.2 

func (m *Filter_Config) SizeVT() (n int)

func (*Filter_Config) String 

func (x *Filter_Config) String() string

func (*Filter_Config) UnmarshalVT added in v1.2.2 

func (m *Filter_Config) UnmarshalVT(dAtA []byte) error

type Filter_Target 

type Filter_Target struct {

	// The target hostname.
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// The target port.
	Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

Represent the target filter server.

func (*Filter_Target) CloneMessageVT added in v1.7.7 

func (m *Filter_Target) CloneMessageVT() proto.Message

func (*Filter_Target) CloneVT added in v1.7.7 

func (m *Filter_Target) CloneVT() *Filter_Target

func (*Filter_Target) Descriptor deprecated 

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

Deprecated: Use Filter_Target.ProtoReflect.Descriptor instead.

func (*Filter_Target) EqualMessageVT added in v1.7.6 

func (this *Filter_Target) EqualMessageVT(thatMsg proto.Message) bool

func (*Filter_Target) EqualVT added in v1.7.6 

func (this *Filter_Target) EqualVT(that *Filter_Target) bool

func (*Filter_Target) GetHost 

func (x *Filter_Target) GetHost() string

func (*Filter_Target) GetPort 

func (x *Filter_Target) GetPort() uint32

func (*Filter_Target) MarshalToSizedBufferVT added in v1.2.2 

func (m *Filter_Target) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Filter_Target) MarshalToVT added in v1.2.2 

func (m *Filter_Target) MarshalToVT(dAtA []byte) (int, error)

func (*Filter_Target) MarshalVT added in v1.2.2 

func (m *Filter_Target) MarshalVT() (dAtA []byte, err error)

func (*Filter_Target) ProtoMessage 

func (*Filter_Target) ProtoMessage()

func (*Filter_Target) ProtoReflect added in v1.2.2 

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

func (*Filter_Target) Reset 

func (x *Filter_Target) Reset()

func (*Filter_Target) SizeVT added in v1.2.2 

func (m *Filter_Target) SizeVT() (n int)

func (*Filter_Target) String 

func (x *Filter_Target) String() string

func (*Filter_Target) UnmarshalVT added in v1.2.2 

func (m *Filter_Target) UnmarshalVT(dAtA []byte) error

type Info 

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

Info related messages.

func (*Info) CloneMessageVT added in v1.7.7 

func (m *Info) CloneMessageVT() proto.Message

func (*Info) CloneVT added in v1.7.7 

func (m *Info) CloneVT() *Info

func (*Info) Descriptor deprecated 

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

Deprecated: Use Info.ProtoReflect.Descriptor instead.

func (*Info) EqualMessageVT added in v1.7.6 

func (this *Info) EqualMessageVT(thatMsg proto.Message) bool

func (*Info) EqualVT added in v1.7.6 

func (this *Info) EqualVT(that *Info) bool

func (*Info) MarshalToSizedBufferVT added in v1.2.2 

func (m *Info) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Info) MarshalToVT added in v1.2.2 

func (m *Info) MarshalToVT(dAtA []byte) (int, error)

func (*Info) MarshalVT added in v1.2.2 

func (m *Info) MarshalVT() (dAtA []byte, err error)

func (*Info) ProtoMessage 

func (*Info) ProtoMessage()

func (*Info) ProtoReflect added in v1.2.2 

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

func (*Info) Reset 

func (x *Info) Reset()

func (*Info) SizeVT added in v1.2.2 

func (m *Info) SizeVT() (n int)

func (*Info) String 

func (x *Info) String() string

func (*Info) UnmarshalVT added in v1.2.2 

func (m *Info) UnmarshalVT(dAtA []byte) error

type Info_Annotations added in v1.7.10 

type Info_Annotations struct {
	Annotations map[string]string `` /* 163-byte string literal not displayed */
	// contains filtered or unexported fields
}

Represent the kubernetes annotations.

func (*Info_Annotations) CloneMessageVT added in v1.7.10 

func (m *Info_Annotations) CloneMessageVT() proto.Message

func (*Info_Annotations) CloneVT added in v1.7.10 

func (m *Info_Annotations) CloneVT() *Info_Annotations

func (*Info_Annotations) Descriptor deprecated added in v1.7.10 

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

Deprecated: Use Info_Annotations.ProtoReflect.Descriptor instead.

func (*Info_Annotations) EqualMessageVT added in v1.7.10 

func (this *Info_Annotations) EqualMessageVT(thatMsg proto.Message) bool

func (*Info_Annotations) EqualVT added in v1.7.10 

func (this *Info_Annotations) EqualVT(that *Info_Annotations) bool

func (*Info_Annotations) GetAnnotations added in v1.7.10 

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

func (*Info_Annotations) MarshalToSizedBufferVT added in v1.7.10 

func (m *Info_Annotations) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Info_Annotations) MarshalToVT added in v1.7.10 

func (m *Info_Annotations) MarshalToVT(dAtA []byte) (int, error)

func (*Info_Annotations) MarshalVT added in v1.7.10 

func (m *Info_Annotations) MarshalVT() (dAtA []byte, err error)

func (*Info_Annotations) ProtoMessage added in v1.7.10 

func (*Info_Annotations) ProtoMessage()

func (*Info_Annotations) ProtoReflect added in v1.7.10 

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

func (*Info_Annotations) Reset added in v1.7.10 

func (x *Info_Annotations) Reset()

func (*Info_Annotations) SizeVT added in v1.7.10 

func (m *Info_Annotations) SizeVT() (n int)

func (*Info_Annotations) String added in v1.7.10 

func (x *Info_Annotations) String() string

func (*Info_Annotations) UnmarshalVT added in v1.7.10 

func (m *Info_Annotations) UnmarshalVT(dAtA []byte) error

type Info_CPU 

type Info_CPU struct {

	// The CPU resource limit.
	Limit float64 `protobuf:"fixed64,1,opt,name=limit,proto3" json:"limit,omitempty"`
	// The CPU resource requested.
	Request float64 `protobuf:"fixed64,2,opt,name=request,proto3" json:"request,omitempty"`
	// The CPU usage.
	Usage float64 `protobuf:"fixed64,3,opt,name=usage,proto3" json:"usage,omitempty"`
	// contains filtered or unexported fields
}

Represent the CPU information message.

func (*Info_CPU) CloneMessageVT added in v1.7.7 

func (m *Info_CPU) CloneMessageVT() proto.Message

func (*Info_CPU) CloneVT added in v1.7.7 

func (m *Info_CPU) CloneVT() *Info_CPU

func (*Info_CPU) Descriptor deprecated 

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

Deprecated: Use Info_CPU.ProtoReflect.Descriptor instead.

func (*Info_CPU) EqualMessageVT added in v1.7.6 

func (this *Info_CPU) EqualMessageVT(thatMsg proto.Message) bool

func (*Info_CPU) EqualVT added in v1.7.6 

func (this *Info_CPU) EqualVT(that *Info_CPU) bool

func (*Info_CPU) GetLimit 

func (x *Info_CPU) GetLimit() float64

func (*Info_CPU) GetRequest 

func (x *Info_CPU) GetRequest() float64

func (*Info_CPU) GetUsage 

func (x *Info_CPU) GetUsage() float64

func (*Info_CPU) MarshalToSizedBufferVT added in v1.2.2 

func (m *Info_CPU) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Info_CPU) MarshalToVT added in v1.2.2 

func (m *Info_CPU) MarshalToVT(dAtA []byte) (int, error)

func (*Info_CPU) MarshalVT added in v1.2.2 

func (m *Info_CPU) MarshalVT() (dAtA []byte, err error)

func (*Info_CPU) ProtoMessage 

func (*Info_CPU) ProtoMessage()

func (*Info_CPU) ProtoReflect added in v1.2.2 

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

func (*Info_CPU) Reset 

func (x *Info_CPU) Reset()

func (*Info_CPU) SizeVT added in v1.2.2 

func (m *Info_CPU) SizeVT() (n int)

func (*Info_CPU) String 

func (x *Info_CPU) String() string

func (*Info_CPU) UnmarshalVT added in v1.2.2 

func (m *Info_CPU) UnmarshalVT(dAtA []byte) error

type Info_IPs 

type Info_IPs struct {
	Ip []string `protobuf:"bytes,1,rep,name=ip,proto3" json:"ip,omitempty"`
	// contains filtered or unexported fields
}

Represent the multiple IP message.

func (*Info_IPs) CloneMessageVT added in v1.7.7 

func (m *Info_IPs) CloneMessageVT() proto.Message

func (*Info_IPs) CloneVT added in v1.7.7 

func (m *Info_IPs) CloneVT() *Info_IPs

func (*Info_IPs) Descriptor deprecated 

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

Deprecated: Use Info_IPs.ProtoReflect.Descriptor instead.

func (*Info_IPs) EqualMessageVT added in v1.7.6 

func (this *Info_IPs) EqualMessageVT(thatMsg proto.Message) bool

func (*Info_IPs) EqualVT added in v1.7.6 

func (this *Info_IPs) EqualVT(that *Info_IPs) bool

func (*Info_IPs) GetIp 

func (x *Info_IPs) GetIp() []string

func (*Info_IPs) MarshalToSizedBufferVT added in v1.2.2 

func (m *Info_IPs) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Info_IPs) MarshalToVT added in v1.2.2 

func (m *Info_IPs) MarshalToVT(dAtA []byte) (int, error)

func (*Info_IPs) MarshalVT added in v1.2.2 

func (m *Info_IPs) MarshalVT() (dAtA []byte, err error)

func (*Info_IPs) ProtoMessage 

func (*Info_IPs) ProtoMessage()

func (*Info_IPs) ProtoReflect added in v1.2.2 

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

func (*Info_IPs) Reset 

func (x *Info_IPs) Reset()

func (*Info_IPs) SizeVT added in v1.2.2 

func (m *Info_IPs) SizeVT() (n int)

func (*Info_IPs) String 

func (x *Info_IPs) String() string

func (*Info_IPs) UnmarshalVT added in v1.2.2 

func (m *Info_IPs) UnmarshalVT(dAtA []byte) error

type Info_Index 

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

Represent the index information messages.

func (*Info_Index) CloneMessageVT added in v1.7.7 

func (m *Info_Index) CloneMessageVT() proto.Message

func (*Info_Index) CloneVT added in v1.7.7 

func (m *Info_Index) CloneVT() *Info_Index

func (*Info_Index) Descriptor deprecated 

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

Deprecated: Use Info_Index.ProtoReflect.Descriptor instead.

func (*Info_Index) EqualMessageVT added in v1.7.6 

func (this *Info_Index) EqualMessageVT(thatMsg proto.Message) bool

func (*Info_Index) EqualVT added in v1.7.6 

func (this *Info_Index) EqualVT(that *Info_Index) bool

func (*Info_Index) MarshalToSizedBufferVT added in v1.2.2 

func (m *Info_Index) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Info_Index) MarshalToVT added in v1.2.2 

func (m *Info_Index) MarshalToVT(dAtA []byte) (int, error)

func (*Info_Index) MarshalVT added in v1.2.2 

func (m *Info_Index) MarshalVT() (dAtA []byte, err error)

func (*Info_Index) ProtoMessage 

func (*Info_Index) ProtoMessage()

func (*Info_Index) ProtoReflect added in v1.2.2 

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

func (*Info_Index) Reset 

func (x *Info_Index) Reset()

func (*Info_Index) SizeVT added in v1.2.2 

func (m *Info_Index) SizeVT() (n int)

func (*Info_Index) String 

func (x *Info_Index) String() string

func (*Info_Index) UnmarshalVT added in v1.2.2 

func (m *Info_Index) UnmarshalVT(dAtA []byte) error

type Info_Index_Count 

type Info_Index_Count struct {

	// The stored index count.
	Stored uint32 `protobuf:"varint,1,opt,name=stored,proto3" json:"stored,omitempty"`
	// The uncommitted index count.
	Uncommitted uint32 `protobuf:"varint,2,opt,name=uncommitted,proto3" json:"uncommitted,omitempty"`
	// The indexing index count.
	Indexing bool `protobuf:"varint,3,opt,name=indexing,proto3" json:"indexing,omitempty"`
	// The saving index count.
	Saving bool `protobuf:"varint,4,opt,name=saving,proto3" json:"saving,omitempty"`
	// contains filtered or unexported fields
}

Represent the index count message.

func (*Info_Index_Count) CloneMessageVT added in v1.7.7 

func (m *Info_Index_Count) CloneMessageVT() proto.Message

func (*Info_Index_Count) CloneVT added in v1.7.7 

func (m *Info_Index_Count) CloneVT() *Info_Index_Count

func (*Info_Index_Count) Descriptor deprecated 

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

Deprecated: Use Info_Index_Count.ProtoReflect.Descriptor instead.

func (*Info_Index_Count) EqualMessageVT added in v1.7.6 

func (this *Info_Index_Count) EqualMessageVT(thatMsg proto.Message) bool

func (*Info_Index_Count) EqualVT added in v1.7.6 

func (this *Info_Index_Count) EqualVT(that *Info_Index_Count) bool

func (*Info_Index_Count) GetIndexing 

func (x *Info_Index_Count) GetIndexing() bool

func (*Info_Index_Count) GetSaving added in v1.1.0 

func (x *Info_Index_Count) GetSaving() bool

func (*Info_Index_Count) GetStored 

func (x *Info_Index_Count) GetStored() uint32

func (*Info_Index_Count) GetUncommitted 

func (x *Info_Index_Count) GetUncommitted() uint32

func (*Info_Index_Count) MarshalToSizedBufferVT added in v1.2.2 

func (m *Info_Index_Count) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Info_Index_Count) MarshalToVT added in v1.2.2 

func (m *Info_Index_Count) MarshalToVT(dAtA []byte) (int, error)

func (*Info_Index_Count) MarshalVT added in v1.2.2 

func (m *Info_Index_Count) MarshalVT() (dAtA []byte, err error)

func (*Info_Index_Count) ProtoMessage 

func (*Info_Index_Count) ProtoMessage()

func (*Info_Index_Count) ProtoReflect added in v1.2.2 

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

func (*Info_Index_Count) Reset 

func (x *Info_Index_Count) Reset()

func (*Info_Index_Count) SizeVT added in v1.2.2 

func (m *Info_Index_Count) SizeVT() (n int)

func (*Info_Index_Count) String 

func (x *Info_Index_Count) String() string

func (*Info_Index_Count) UnmarshalVT added in v1.2.2 

func (m *Info_Index_Count) UnmarshalVT(dAtA []byte) error

type Info_Index_UUID 

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

Represent the UUID message.

func (*Info_Index_UUID) CloneMessageVT added in v1.7.7 

func (m *Info_Index_UUID) CloneMessageVT() proto.Message

func (*Info_Index_UUID) CloneVT added in v1.7.7 

func (m *Info_Index_UUID) CloneVT() *Info_Index_UUID

func (*Info_Index_UUID) Descriptor deprecated 

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

Deprecated: Use Info_Index_UUID.ProtoReflect.Descriptor instead.

func (*Info_Index_UUID) EqualMessageVT added in v1.7.6 

func (this *Info_Index_UUID) EqualMessageVT(thatMsg proto.Message) bool

func (*Info_Index_UUID) EqualVT added in v1.7.6 

func (this *Info_Index_UUID) EqualVT(that *Info_Index_UUID) bool

func (*Info_Index_UUID) MarshalToSizedBufferVT added in v1.2.2 

func (m *Info_Index_UUID) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Info_Index_UUID) MarshalToVT added in v1.2.2 

func (m *Info_Index_UUID) MarshalToVT(dAtA []byte) (int, error)

func (*Info_Index_UUID) MarshalVT added in v1.2.2 

func (m *Info_Index_UUID) MarshalVT() (dAtA []byte, err error)

func (*Info_Index_UUID) ProtoMessage 

func (*Info_Index_UUID) ProtoMessage()

func (*Info_Index_UUID) ProtoReflect added in v1.2.2 

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

func (*Info_Index_UUID) Reset 

func (x *Info_Index_UUID) Reset()

func (*Info_Index_UUID) SizeVT added in v1.2.2 

func (m *Info_Index_UUID) SizeVT() (n int)

func (*Info_Index_UUID) String 

func (x *Info_Index_UUID) String() string

func (*Info_Index_UUID) UnmarshalVT added in v1.2.2 

func (m *Info_Index_UUID) UnmarshalVT(dAtA []byte) error

type Info_Index_UUID_Committed 

type Info_Index_UUID_Committed struct {
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// contains filtered or unexported fields
}

The committed UUID.

func (*Info_Index_UUID_Committed) CloneMessageVT added in v1.7.7 

func (m *Info_Index_UUID_Committed) CloneMessageVT() proto.Message

func (*Info_Index_UUID_Committed) CloneVT added in v1.7.7 

func (m *Info_Index_UUID_Committed) CloneVT() *Info_Index_UUID_Committed

func (*Info_Index_UUID_Committed) Descriptor deprecated 

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

Deprecated: Use Info_Index_UUID_Committed.ProtoReflect.Descriptor instead.

func (*Info_Index_UUID_Committed) EqualMessageVT added in v1.7.6 

func (this *Info_Index_UUID_Committed) EqualMessageVT(thatMsg proto.Message) bool

func (*Info_Index_UUID_Committed) EqualVT added in v1.7.6 

func (this *Info_Index_UUID_Committed) EqualVT(that *Info_Index_UUID_Committed) bool

func (*Info_Index_UUID_Committed) GetUuid 

func (x *Info_Index_UUID_Committed) GetUuid() string

func (*Info_Index_UUID_Committed) MarshalToSizedBufferVT added in v1.2.2 

func (m *Info_Index_UUID_Committed) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Info_Index_UUID_Committed) MarshalToVT added in v1.2.2 

func (m *Info_Index_UUID_Committed) MarshalToVT(dAtA []byte) (int, error)

func (*Info_Index_UUID_Committed) MarshalVT added in v1.2.2 

func (m *Info_Index_UUID_Committed) MarshalVT() (dAtA []byte, err error)

func (*Info_Index_UUID_Committed) ProtoMessage 

func (*Info_Index_UUID_Committed) ProtoMessage()

func (*Info_Index_UUID_Committed) ProtoReflect added in v1.2.2 

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

func (*Info_Index_UUID_Committed) Reset 

func (x *Info_Index_UUID_Committed) Reset()

func (*Info_Index_UUID_Committed) SizeVT added in v1.2.2 

func (m *Info_Index_UUID_Committed) SizeVT() (n int)

func (*Info_Index_UUID_Committed) String 

func (x *Info_Index_UUID_Committed) String() string

func (*Info_Index_UUID_Committed) UnmarshalVT added in v1.2.2 

func (m *Info_Index_UUID_Committed) UnmarshalVT(dAtA []byte) error

type Info_Index_UUID_Uncommitted 

type Info_Index_UUID_Uncommitted struct {
	Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// contains filtered or unexported fields
}

The uncommitted UUID.

func (*Info_Index_UUID_Uncommitted) CloneMessageVT added in v1.7.7 

func (m *Info_Index_UUID_Uncommitted) CloneMessageVT() proto.Message

func (*Info_Index_UUID_Uncommitted) CloneVT added in v1.7.7 

func (m *Info_Index_UUID_Uncommitted) CloneVT() *Info_Index_UUID_Uncommitted

func (*Info_Index_UUID_Uncommitted) Descriptor deprecated 

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

Deprecated: Use Info_Index_UUID_Uncommitted.ProtoReflect.Descriptor instead.

func (*Info_Index_UUID_Uncommitted) EqualMessageVT added in v1.7.6 

func (this *Info_Index_UUID_Uncommitted) EqualMessageVT(thatMsg proto.Message) bool

func (*Info_Index_UUID_Uncommitted) EqualVT added in v1.7.6 

func (this *Info_Index_UUID_Uncommitted) EqualVT(that *Info_Index_UUID_Uncommitted) bool

func (*Info_Index_UUID_Uncommitted) GetUuid 

func (x *Info_Index_UUID_Uncommitted) GetUuid() string

func (*Info_Index_UUID_Uncommitted) MarshalToSizedBufferVT added in v1.2.2 

func (m *Info_Index_UUID_Uncommitted) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Info_Index_UUID_Uncommitted) MarshalToVT added in v1.2.2 

func (m *Info_Index_UUID_Uncommitted) MarshalToVT(dAtA []byte) (int, error)

func (*Info_Index_UUID_Uncommitted) MarshalVT added in v1.2.2 

func (m *Info_Index_UUID_Uncommitted) MarshalVT() (dAtA []byte, err error)

func (*Info_Index_UUID_Uncommitted) ProtoMessage 

func (*Info_Index_UUID_Uncommitted) ProtoMessage()

func (*Info_Index_UUID_Uncommitted) ProtoReflect added in v1.2.2 

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

func (*Info_Index_UUID_Uncommitted) Reset 

func (x *Info_Index_UUID_Uncommitted) Reset()

func (*Info_Index_UUID_Uncommitted) SizeVT added in v1.2.2 

func (m *Info_Index_UUID_Uncommitted) SizeVT() (n int)

func (*Info_Index_UUID_Uncommitted) String 

func (x *Info_Index_UUID_Uncommitted) String() string

func (*Info_Index_UUID_Uncommitted) UnmarshalVT added in v1.2.2 

func (m *Info_Index_UUID_Uncommitted) UnmarshalVT(dAtA []byte) error

type Info_Labels added in v1.7.10 

type Info_Labels struct {
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

Represent the kubernetes labels.

func (*Info_Labels) CloneMessageVT added in v1.7.10 

func (m *Info_Labels) CloneMessageVT() proto.Message

func (*Info_Labels) CloneVT added in v1.7.10 

func (m *Info_Labels) CloneVT() *Info_Labels

func (*Info_Labels) Descriptor deprecated added in v1.7.10 

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

Deprecated: Use Info_Labels.ProtoReflect.Descriptor instead.

func (*Info_Labels) EqualMessageVT added in v1.7.10 

func (this *Info_Labels) EqualMessageVT(thatMsg proto.Message) bool

func (*Info_Labels) EqualVT added in v1.7.10 

func (this *Info_Labels) EqualVT(that *Info_Labels) bool

func (*Info_Labels) GetLabels added in v1.7.10 

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

func (*Info_Labels) MarshalToSizedBufferVT added in v1.7.10 

func (m *Info_Labels) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Info_Labels) MarshalToVT added in v1.7.10 

func (m *Info_Labels) MarshalToVT(dAtA []byte) (int, error)

func (*Info_Labels) MarshalVT added in v1.7.10 

func (m *Info_Labels) MarshalVT() (dAtA []byte, err error)

func (*Info_Labels) ProtoMessage added in v1.7.10 

func (*Info_Labels) ProtoMessage()

func (*Info_Labels) ProtoReflect added in v1.7.10 

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

func (*Info_Labels) Reset added in v1.7.10 

func (x *Info_Labels) Reset()

func (*Info_Labels) SizeVT added in v1.7.10 

func (m *Info_Labels) SizeVT() (n int)

func (*Info_Labels) String added in v1.7.10 

func (x *Info_Labels) String() string

func (*Info_Labels) UnmarshalVT added in v1.7.10 

func (m *Info_Labels) UnmarshalVT(dAtA []byte) error

type Info_Memory 

type Info_Memory struct {

	// The memory limit.
	Limit float64 `protobuf:"fixed64,1,opt,name=limit,proto3" json:"limit,omitempty"`
	// The memory requested.
	Request float64 `protobuf:"fixed64,2,opt,name=request,proto3" json:"request,omitempty"`
	// The memory usage.
	Usage float64 `protobuf:"fixed64,3,opt,name=usage,proto3" json:"usage,omitempty"`
	// contains filtered or unexported fields
}

Represent the memory information message.

func (*Info_Memory) CloneMessageVT added in v1.7.7 

func (m *Info_Memory) CloneMessageVT() proto.Message

func (*Info_Memory) CloneVT added in v1.7.7 

func (m *Info_Memory) CloneVT() *Info_Memory

func (*Info_Memory) Descriptor deprecated 

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

Deprecated: Use Info_Memory.ProtoReflect.Descriptor instead.

func (*Info_Memory) EqualMessageVT added in v1.7.6 

func (this *Info_Memory) EqualMessageVT(thatMsg proto.Message) bool

func (*Info_Memory) EqualVT added in v1.7.6 

func (this *Info_Memory) EqualVT(that *Info_Memory) bool

func (*Info_Memory) GetLimit 

func (x *Info_Memory) GetLimit() float64

func (*Info_Memory) GetRequest 

func (x *Info_Memory) GetRequest() float64

func (*Info_Memory) GetUsage 

func (x *Info_Memory) GetUsage() float64

func (*Info_Memory) MarshalToSizedBufferVT added in v1.2.2 

func (m *Info_Memory) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Info_Memory) MarshalToVT added in v1.2.2 

func (m *Info_Memory) MarshalToVT(dAtA []byte) (int, error)

func (*Info_Memory) MarshalVT added in v1.2.2 

func (m *Info_Memory) MarshalVT() (dAtA []byte, err error)

func (*Info_Memory) ProtoMessage 

func (*Info_Memory) ProtoMessage()

func (*Info_Memory) ProtoReflect added in v1.2.2 

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

func (*Info_Memory) Reset 

func (x *Info_Memory) Reset()

func (*Info_Memory) SizeVT added in v1.2.2 

func (m *Info_Memory) SizeVT() (n int)

func (*Info_Memory) String 

func (x *Info_Memory) String() string

func (*Info_Memory) UnmarshalVT added in v1.2.2 

func (m *Info_Memory) UnmarshalVT(dAtA []byte) error

type Info_Node 

type Info_Node struct {

	// The name of the node.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The internal IP address of the node.
	InternalAddr string `protobuf:"bytes,2,opt,name=internal_addr,json=internalAddr,proto3" json:"internal_addr,omitempty"`
	// The external IP address of the node.
	ExternalAddr string `protobuf:"bytes,3,opt,name=external_addr,json=externalAddr,proto3" json:"external_addr,omitempty"`
	// The CPU information of the node.
	Cpu *Info_CPU `protobuf:"bytes,4,opt,name=cpu,proto3" json:"cpu,omitempty"`
	// The memory information of the node.
	Memory *Info_Memory `protobuf:"bytes,5,opt,name=memory,proto3" json:"memory,omitempty"`
	// The pod information of the node.
	Pods *Info_Pods `protobuf:"bytes,6,opt,name=Pods,proto3" json:"Pods,omitempty"`
	// contains filtered or unexported fields
}

Represent the node information message.

func (*Info_Node) CloneMessageVT added in v1.7.7 

func (m *Info_Node) CloneMessageVT() proto.Message

func (*Info_Node) CloneVT added in v1.7.7 

func (m *Info_Node) CloneVT() *Info_Node

func (*Info_Node) Descriptor deprecated 

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

Deprecated: Use Info_Node.ProtoReflect.Descriptor instead.

func (*Info_Node) EqualMessageVT added in v1.7.6 

func (this *Info_Node) EqualMessageVT(thatMsg proto.Message) bool

func (*Info_Node) EqualVT added in v1.7.6 

func (this *Info_Node) EqualVT(that *Info_Node) bool

func (*Info_Node) GetCpu 

func (x *Info_Node) GetCpu() *Info_CPU

func (*Info_Node) GetExternalAddr 

func (x *Info_Node) GetExternalAddr() string

func (*Info_Node) GetInternalAddr 

func (x *Info_Node) GetInternalAddr() string

func (*Info_Node) GetMemory 

func (x *Info_Node) GetMemory() *Info_Memory

func (*Info_Node) GetName 

func (x *Info_Node) GetName() string

func (*Info_Node) GetPods 

func (x *Info_Node) GetPods() *Info_Pods

func (*Info_Node) MarshalToSizedBufferVT added in v1.2.2 

func (m *Info_Node) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Info_Node) MarshalToVT added in v1.2.2 

func (m *Info_Node) MarshalToVT(dAtA []byte) (int, error)

func (*Info_Node) MarshalVT added in v1.2.2 

func (m *Info_Node) MarshalVT() (dAtA []byte, err error)

func (*Info_Node) ProtoMessage 

func (*Info_Node) ProtoMessage()

func (*Info_Node) ProtoReflect added in v1.2.2 

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

func (*Info_Node) Reset 

func (x *Info_Node) Reset()

func (*Info_Node) SizeVT added in v1.2.2 

func (m *Info_Node) SizeVT() (n int)

func (*Info_Node) String 

func (x *Info_Node) String() string

func (*Info_Node) UnmarshalVT added in v1.2.2 

func (m *Info_Node) UnmarshalVT(dAtA []byte) error

type Info_Nodes 

type Info_Nodes struct {

	// The multiple node information.
	Nodes []*Info_Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

Represent the multiple node information message.

func (*Info_Nodes) CloneMessageVT added in v1.7.7 

func (m *Info_Nodes) CloneMessageVT() proto.Message

func (*Info_Nodes) CloneVT added in v1.7.7 

func (m *Info_Nodes) CloneVT() *Info_Nodes

func (*Info_Nodes) Descriptor deprecated 

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

Deprecated: Use Info_Nodes.ProtoReflect.Descriptor instead.

func (*Info_Nodes) EqualMessageVT added in v1.7.6 

func (this *Info_Nodes) EqualMessageVT(thatMsg proto.Message) bool

func (*Info_Nodes) EqualVT added in v1.7.6 

func (this *Info_Nodes) EqualVT(that *Info_Nodes) bool

func (*Info_Nodes) GetNodes 

func (x *Info_Nodes) GetNodes() []*Info_Node

func (*Info_Nodes) MarshalToSizedBufferVT added in v1.2.2 

func (m *Info_Nodes) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Info_Nodes) MarshalToVT added in v1.2.2 

func (m *Info_Nodes) MarshalToVT(dAtA []byte) (int, error)

func (*Info_Nodes) MarshalVT added in v1.2.2 

func (m *Info_Nodes) MarshalVT() (dAtA []byte, err error)

func (*Info_Nodes) ProtoMessage 

func (*Info_Nodes) ProtoMessage()

func (*Info_Nodes) ProtoReflect added in v1.2.2 

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

func (*Info_Nodes) Reset 

func (x *Info_Nodes) Reset()

func (*Info_Nodes) SizeVT added in v1.2.2 

func (m *Info_Nodes) SizeVT() (n int)

func (*Info_Nodes) String 

func (x *Info_Nodes) String() string

func (*Info_Nodes) UnmarshalVT added in v1.2.2 

func (m *Info_Nodes) UnmarshalVT(dAtA []byte) error

type Info_Pod 

type Info_Pod struct {

	// The app name of the pod on the label.
	AppName string `protobuf:"bytes,1,opt,name=app_name,json=appName,proto3" json:"app_name,omitempty"`
	// The name of the pod.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// The namespace of the pod.
	Namespace string `protobuf:"bytes,3,opt,name=namespace,proto3" json:"namespace,omitempty"`
	// The IP of the pod.
	Ip string `protobuf:"bytes,4,opt,name=ip,proto3" json:"ip,omitempty"`
	// The CPU information of the pod.
	Cpu *Info_CPU `protobuf:"bytes,5,opt,name=cpu,proto3" json:"cpu,omitempty"`
	// The memory information of the pod.
	Memory *Info_Memory `protobuf:"bytes,6,opt,name=memory,proto3" json:"memory,omitempty"`
	// The node information of the pod.
	Node *Info_Node `protobuf:"bytes,7,opt,name=node,proto3" json:"node,omitempty"`
	// contains filtered or unexported fields
}

Represent the pod information message.

func (*Info_Pod) CloneMessageVT added in v1.7.7 

func (m *Info_Pod) CloneMessageVT() proto.Message

func (*Info_Pod) CloneVT added in v1.7.7 

func (m *Info_Pod) CloneVT() *Info_Pod

func (*Info_Pod) Descriptor deprecated 

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

Deprecated: Use Info_Pod.ProtoReflect.Descriptor instead.

func (*Info_Pod) EqualMessageVT added in v1.7.6 

func (this *Info_Pod) EqualMessageVT(thatMsg proto.Message) bool

func (*Info_Pod) EqualVT added in v1.7.6 

func (this *Info_Pod) EqualVT(that *Info_Pod) bool

func (*Info_Pod) GetAppName 

func (x *Info_Pod) GetAppName() string

func (*Info_Pod) GetCpu 

func (x *Info_Pod) GetCpu() *Info_CPU

func (*Info_Pod) GetIp 

func (x *Info_Pod) GetIp() string

func (*Info_Pod) GetMemory 

func (x *Info_Pod) GetMemory() *Info_Memory

func (*Info_Pod) GetName 

func (x *Info_Pod) GetName() string

func (*Info_Pod) GetNamespace 

func (x *Info_Pod) GetNamespace() string

func (*Info_Pod) GetNode 

func (x *Info_Pod) GetNode() *Info_Node

func (*Info_Pod) MarshalToSizedBufferVT added in v1.2.2 

func (m *Info_Pod) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Info_Pod) MarshalToVT added in v1.2.2 

func (m *Info_Pod) MarshalToVT(dAtA []byte) (int, error)

func (*Info_Pod) MarshalVT added in v1.2.2 

func (m *Info_Pod) MarshalVT() (dAtA []byte, err error)

func (*Info_Pod) ProtoMessage 

func (*Info_Pod) ProtoMessage()

func (*Info_Pod) ProtoReflect added in v1.2.2 

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

func (*Info_Pod) Reset 

func (x *Info_Pod) Reset()

func (*Info_Pod) SizeVT added in v1.2.2 

func (m *Info_Pod) SizeVT() (n int)

func (*Info_Pod) String 

func (x *Info_Pod) String() string

func (*Info_Pod) UnmarshalVT added in v1.2.2 

func (m *Info_Pod) UnmarshalVT(dAtA []byte) error

type Info_Pods 

type Info_Pods struct {

	// The multiple pod information.
	Pods []*Info_Pod `protobuf:"bytes,1,rep,name=pods,proto3" json:"pods,omitempty"`
	// contains filtered or unexported fields
}

Represent the multiple pod information message.

func (*Info_Pods) CloneMessageVT added in v1.7.7 

func (m *Info_Pods) CloneMessageVT() proto.Message

func (*Info_Pods) CloneVT added in v1.7.7 

func (m *Info_Pods) CloneVT() *Info_Pods

func (*Info_Pods) Descriptor deprecated 

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

Deprecated: Use Info_Pods.ProtoReflect.Descriptor instead.

func (*Info_Pods) EqualMessageVT added in v1.7.6 

func (this *Info_Pods) EqualMessageVT(thatMsg proto.Message) bool

func (*Info_Pods) EqualVT added in v1.7.6 

func (this *Info_Pods) EqualVT(that *Info_Pods) bool

func (*Info_Pods) GetPods 

func (x *Info_Pods) GetPods() []*Info_Pod

func (*Info_Pods) MarshalToSizedBufferVT added in v1.2.2 

func (m *Info_Pods) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Info_Pods) MarshalToVT added in v1.2.2 

func (m *Info_Pods) MarshalToVT(dAtA []byte) (int, error)

func (*Info_Pods) MarshalVT added in v1.2.2 

func (m *Info_Pods) MarshalVT() (dAtA []byte, err error)

func (*Info_Pods) ProtoMessage 

func (*Info_Pods) ProtoMessage()

func (*Info_Pods) ProtoReflect added in v1.2.2 

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

func (*Info_Pods) Reset 

func (x *Info_Pods) Reset()

func (*Info_Pods) SizeVT added in v1.2.2 

func (m *Info_Pods) SizeVT() (n int)

func (*Info_Pods) String 

func (x *Info_Pods) String() string

func (*Info_Pods) UnmarshalVT added in v1.2.2 

func (m *Info_Pods) UnmarshalVT(dAtA []byte) error

type Info_Service added in v1.7.10 

type Info_Service struct {

	// The name of the svc.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The cluster ip of the svc.
	ClusterIp string `protobuf:"bytes,2,opt,name=cluster_ip,json=clusterIp,proto3" json:"cluster_ip,omitempty"`
	// The cluster ips of the svc.
	ClusterIps []string `protobuf:"bytes,3,rep,name=cluster_ips,json=clusterIps,proto3" json:"cluster_ips,omitempty"`
	// The port of the svc.
	Ports []*Info_ServicePort `protobuf:"bytes,4,rep,name=ports,proto3" json:"ports,omitempty"`
	// The labels of the service.
	Labels *Info_Labels `protobuf:"bytes,5,opt,name=labels,proto3" json:"labels,omitempty"`
	// The annotations of the service.
	Annotations *Info_Annotations `protobuf:"bytes,6,opt,name=annotations,proto3" json:"annotations,omitempty"`
	// contains filtered or unexported fields
}

Represent the service information message.

func (*Info_Service) CloneMessageVT added in v1.7.10 

func (m *Info_Service) CloneMessageVT() proto.Message

func (*Info_Service) CloneVT added in v1.7.10 

func (m *Info_Service) CloneVT() *Info_Service

func (*Info_Service) Descriptor deprecated added in v1.7.10 

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

Deprecated: Use Info_Service.ProtoReflect.Descriptor instead.

func (*Info_Service) EqualMessageVT added in v1.7.10 

func (this *Info_Service) EqualMessageVT(thatMsg proto.Message) bool

func (*Info_Service) EqualVT added in v1.7.10 

func (this *Info_Service) EqualVT(that *Info_Service) bool

func (*Info_Service) GetAnnotations added in v1.7.10 

func (x *Info_Service) GetAnnotations() *Info_Annotations

func (*Info_Service) GetClusterIp added in v1.7.10 

func (x *Info_Service) GetClusterIp() string

func (*Info_Service) GetClusterIps added in v1.7.10 

func (x *Info_Service) GetClusterIps() []string

func (*Info_Service) GetLabels added in v1.7.10 

func (x *Info_Service) GetLabels() *Info_Labels

func (*Info_Service) GetName added in v1.7.10 

func (x *Info_Service) GetName() string

func (*Info_Service) GetPorts added in v1.7.10 

func (x *Info_Service) GetPorts() []*Info_ServicePort

func (*Info_Service) MarshalToSizedBufferVT added in v1.7.10 

func (m *Info_Service) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Info_Service) MarshalToVT added in v1.7.10 

func (m *Info_Service) MarshalToVT(dAtA []byte) (int, error)

func (*Info_Service) MarshalVT added in v1.7.10 

func (m *Info_Service) MarshalVT() (dAtA []byte, err error)

func (*Info_Service) ProtoMessage added in v1.7.10 

func (*Info_Service) ProtoMessage()

func (*Info_Service) ProtoReflect added in v1.7.10 

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

func (*Info_Service) Reset added in v1.7.10 

func (x *Info_Service) Reset()

func (*Info_Service) SizeVT added in v1.7.10 

func (m *Info_Service) SizeVT() (n int)

func (*Info_Service) String added in v1.7.10 

func (x *Info_Service) String() string

func (*Info_Service) UnmarshalVT added in v1.7.10 

func (m *Info_Service) UnmarshalVT(dAtA []byte) error

type Info_ServicePort added in v1.7.10 

type Info_ServicePort struct {

	// The name of the port.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The port number
	Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

Represets the service port information message.

func (*Info_ServicePort) CloneMessageVT added in v1.7.10 

func (m *Info_ServicePort) CloneMessageVT() proto.Message

func (*Info_ServicePort) CloneVT added in v1.7.10 

func (m *Info_ServicePort) CloneVT() *Info_ServicePort

func (*Info_ServicePort) Descriptor deprecated added in v1.7.10 

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

Deprecated: Use Info_ServicePort.ProtoReflect.Descriptor instead.

func (*Info_ServicePort) EqualMessageVT added in v1.7.10 

func (this *Info_ServicePort) EqualMessageVT(thatMsg proto.Message) bool

func (*Info_ServicePort) EqualVT added in v1.7.10 

func (this *Info_ServicePort) EqualVT(that *Info_ServicePort) bool

func (*Info_ServicePort) GetName added in v1.7.10 

func (x *Info_ServicePort) GetName() string

func (*Info_ServicePort) GetPort added in v1.7.10 

func (x *Info_ServicePort) GetPort() int32

func (*Info_ServicePort) MarshalToSizedBufferVT added in v1.7.10 

func (m *Info_ServicePort) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Info_ServicePort) MarshalToVT added in v1.7.10 

func (m *Info_ServicePort) MarshalToVT(dAtA []byte) (int, error)

func (*Info_ServicePort) MarshalVT added in v1.7.10 

func (m *Info_ServicePort) MarshalVT() (dAtA []byte, err error)

func (*Info_ServicePort) ProtoMessage added in v1.7.10 

func (*Info_ServicePort) ProtoMessage()

func (*Info_ServicePort) ProtoReflect added in v1.7.10 

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

func (*Info_ServicePort) Reset added in v1.7.10 

func (x *Info_ServicePort) Reset()

func (*Info_ServicePort) SizeVT added in v1.7.10 

func (m *Info_ServicePort) SizeVT() (n int)

func (*Info_ServicePort) String added in v1.7.10 

func (x *Info_ServicePort) String() string

func (*Info_ServicePort) UnmarshalVT added in v1.7.10 

func (m *Info_ServicePort) UnmarshalVT(dAtA []byte) error

type Info_Services added in v1.7.10 

type Info_Services struct {

	// The multiple service information.
	Services []*Info_Service `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	// contains filtered or unexported fields
}

Represent the multiple service information message.

func (*Info_Services) CloneMessageVT added in v1.7.10 

func (m *Info_Services) CloneMessageVT() proto.Message

func (*Info_Services) CloneVT added in v1.7.10 

func (m *Info_Services) CloneVT() *Info_Services

func (*Info_Services) Descriptor deprecated added in v1.7.10 

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

Deprecated: Use Info_Services.ProtoReflect.Descriptor instead.

func (*Info_Services) EqualMessageVT added in v1.7.10 

func (this *Info_Services) EqualMessageVT(thatMsg proto.Message) bool

func (*Info_Services) EqualVT added in v1.7.10 

func (this *Info_Services) EqualVT(that *Info_Services) bool

func (*Info_Services) GetServices added in v1.7.10 

func (x *Info_Services) GetServices() []*Info_Service

func (*Info_Services) MarshalToSizedBufferVT added in v1.7.10 

func (m *Info_Services) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Info_Services) MarshalToVT added in v1.7.10 

func (m *Info_Services) MarshalToVT(dAtA []byte) (int, error)

func (*Info_Services) MarshalVT added in v1.7.10 

func (m *Info_Services) MarshalVT() (dAtA []byte, err error)

func (*Info_Services) ProtoMessage added in v1.7.10 

func (*Info_Services) ProtoMessage()

func (*Info_Services) ProtoReflect added in v1.7.10 

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

func (*Info_Services) Reset added in v1.7.10 

func (x *Info_Services) Reset()

func (*Info_Services) SizeVT added in v1.7.10 

func (m *Info_Services) SizeVT() (n int)

func (*Info_Services) String added in v1.7.10 

func (x *Info_Services) String() string

func (*Info_Services) UnmarshalVT added in v1.7.10 

func (m *Info_Services) UnmarshalVT(dAtA []byte) error

type Insert 

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

Insert related messages.

func (*Insert) CloneMessageVT added in v1.7.7 

func (m *Insert) CloneMessageVT() proto.Message

func (*Insert) CloneVT added in v1.7.7 

func (m *Insert) CloneVT() *Insert

func (*Insert) Descriptor deprecated 

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

Deprecated: Use Insert.ProtoReflect.Descriptor instead.

func (*Insert) EqualMessageVT added in v1.7.6 

func (this *Insert) EqualMessageVT(thatMsg proto.Message) bool

func (*Insert) EqualVT added in v1.7.6 

func (this *Insert) EqualVT(that *Insert) bool

func (*Insert) MarshalToSizedBufferVT added in v1.2.2 

func (m *Insert) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Insert) MarshalToVT added in v1.2.2 

func (m *Insert) MarshalToVT(dAtA []byte) (int, error)

func (*Insert) MarshalVT added in v1.2.2 

func (m *Insert) MarshalVT() (dAtA []byte, err error)

func (*Insert) ProtoMessage 

func (*Insert) ProtoMessage()

func (*Insert) ProtoReflect added in v1.2.2 

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

func (*Insert) Reset 

func (x *Insert) Reset()

func (*Insert) SizeVT added in v1.2.2 

func (m *Insert) SizeVT() (n int)

func (*Insert) String 

func (x *Insert) String() string

func (*Insert) UnmarshalVT added in v1.2.2 

func (m *Insert) UnmarshalVT(dAtA []byte) error

type Insert_Config 

type Insert_Config struct {

	// A flag to skip exist check during insert operation.
	SkipStrictExistCheck bool `` /* 126-byte string literal not displayed */
	// Filter configurations.
	Filters *Filter_Config `protobuf:"bytes,2,opt,name=filters,proto3" json:"filters,omitempty"`
	// Insert timestamp.
	Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

Represent insert configurations.

func (*Insert_Config) CloneMessageVT added in v1.7.7 

func (m *Insert_Config) CloneMessageVT() proto.Message

func (*Insert_Config) CloneVT added in v1.7.7 

func (m *Insert_Config) CloneVT() *Insert_Config

func (*Insert_Config) Descriptor deprecated 

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

Deprecated: Use Insert_Config.ProtoReflect.Descriptor instead.

func (*Insert_Config) EqualMessageVT added in v1.7.6 

func (this *Insert_Config) EqualMessageVT(thatMsg proto.Message) bool

func (*Insert_Config) EqualVT added in v1.7.6 

func (this *Insert_Config) EqualVT(that *Insert_Config) bool

func (*Insert_Config) GetFilters 

func (x *Insert_Config) GetFilters() *Filter_Config

func (*Insert_Config) GetSkipStrictExistCheck 

func (x *Insert_Config) GetSkipStrictExistCheck() bool

func (*Insert_Config) GetTimestamp added in v1.1.0 

func (x *Insert_Config) GetTimestamp() int64

func (*Insert_Config) MarshalToSizedBufferVT added in v1.2.2 

func (m *Insert_Config) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Insert_Config) MarshalToVT added in v1.2.2 

func (m *Insert_Config) MarshalToVT(dAtA []byte) (int, error)

func (*Insert_Config) MarshalVT added in v1.2.2 

func (m *Insert_Config) MarshalVT() (dAtA []byte, err error)

func (*Insert_Config) ProtoMessage 

func (*Insert_Config) ProtoMessage()

func (*Insert_Config) ProtoReflect added in v1.2.2 

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

func (*Insert_Config) Reset 

func (x *Insert_Config) Reset()

func (*Insert_Config) SizeVT added in v1.2.2 

func (m *Insert_Config) SizeVT() (n int)

func (*Insert_Config) String 

func (x *Insert_Config) String() string

func (*Insert_Config) UnmarshalVT added in v1.2.2 

func (m *Insert_Config) UnmarshalVT(dAtA []byte) error

type Insert_MultiObjectRequest 

type Insert_MultiObjectRequest struct {

	// Represent multiple insert by object content.
	Requests []*Insert_ObjectRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

Represent the multiple insert by binary object request.

func (*Insert_MultiObjectRequest) CloneMessageVT added in v1.7.7 

func (m *Insert_MultiObjectRequest) CloneMessageVT() proto.Message

func (*Insert_MultiObjectRequest) CloneVT added in v1.7.7 

func (m *Insert_MultiObjectRequest) CloneVT() *Insert_MultiObjectRequest

func (*Insert_MultiObjectRequest) Descriptor deprecated 

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

Deprecated: Use Insert_MultiObjectRequest.ProtoReflect.Descriptor instead.

func (*Insert_MultiObjectRequest) EqualMessageVT added in v1.7.6 

func (this *Insert_MultiObjectRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*Insert_MultiObjectRequest) EqualVT added in v1.7.6 

func (this *Insert_MultiObjectRequest) EqualVT(that *Insert_MultiObjectRequest) bool

func (*Insert_MultiObjectRequest) GetRequests 

func (x *Insert_MultiObjectRequest) GetRequests() []*Insert_ObjectRequest

func (*Insert_MultiObjectRequest) MarshalToSizedBufferVT added in v1.2.2 

func (m *Insert_MultiObjectRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Insert_MultiObjectRequest) MarshalToVT added in v1.2.2 

func (m *Insert_MultiObjectRequest) MarshalToVT(dAtA []byte) (int, error)

func (*Insert_MultiObjectRequest) MarshalVT added in v1.2.2 

func (m *Insert_MultiObjectRequest) MarshalVT() (dAtA []byte, err error)

func (*Insert_MultiObjectRequest) ProtoMessage 

func (*Insert_MultiObjectRequest) ProtoMessage()

func (*Insert_MultiObjectRequest) ProtoReflect added in v1.2.2 

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

func (*Insert_MultiObjectRequest) Reset 

func (x *Insert_MultiObjectRequest) Reset()

func (*Insert_MultiObjectRequest) SizeVT added in v1.2.2 

func (m *Insert_MultiObjectRequest) SizeVT() (n int)

func (*Insert_MultiObjectRequest) String 

func (x *Insert_MultiObjectRequest) String() string

func (*Insert_MultiObjectRequest) UnmarshalVT added in v1.2.2 

func (m *Insert_MultiObjectRequest) UnmarshalVT(dAtA []byte) error

type Insert_MultiRequest 

type Insert_MultiRequest struct {

	// Represent multiple insert request content.
	Requests []*Insert_Request `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

Represent the multiple insert request.

func (*Insert_MultiRequest) CloneMessageVT added in v1.7.7 

func (m *Insert_MultiRequest) CloneMessageVT() proto.Message

func (*Insert_MultiRequest) CloneVT added in v1.7.7 

func (m *Insert_MultiRequest) CloneVT() *Insert_MultiRequest

func (*Insert_MultiRequest) Descriptor deprecated 

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

Deprecated: Use Insert_MultiRequest.ProtoReflect.Descriptor instead.

func (*Insert_MultiRequest) EqualMessageVT added in v1.7.6 

func (this *Insert_MultiRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*Insert_MultiRequest) EqualVT added in v1.7.6 

func (this *Insert_MultiRequest) EqualVT(that *Insert_MultiRequest) bool

func (*Insert_MultiRequest) GetRequests 

func (x *Insert_MultiRequest) GetRequests() []*Insert_Request

func (*Insert_MultiRequest) MarshalToSizedBufferVT added in v1.2.2 

func (m *Insert_MultiRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Insert_MultiRequest) MarshalToVT added in v1.2.2 

func (m *Insert_MultiRequest) MarshalToVT(dAtA []byte) (int, error)

func (*Insert_MultiRequest) MarshalVT added in v1.2.2 

func (m *Insert_MultiRequest) MarshalVT() (dAtA []byte, err error)

func (*Insert_MultiRequest) ProtoMessage 

func (*Insert_MultiRequest) ProtoMessage()

func (*Insert_MultiRequest) ProtoReflect added in v1.2.2 

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

func (*Insert_MultiRequest) Reset 

func (x *Insert_MultiRequest) Reset()

func (*Insert_MultiRequest) SizeVT added in v1.2.2 

func (m *Insert_MultiRequest) SizeVT() (n int)

func (*Insert_MultiRequest) String 

func (x *Insert_MultiRequest) String() string

func (*Insert_MultiRequest) UnmarshalVT added in v1.2.2 

func (m *Insert_MultiRequest) UnmarshalVT(dAtA []byte) error

type Insert_ObjectRequest 

type Insert_ObjectRequest struct {

	// The binary object to be inserted.
	Object *Object_Blob `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	// The configuration of the insert request.
	Config *Insert_Config `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// Filter configurations.
	Vectorizer *Filter_Target `protobuf:"bytes,3,opt,name=vectorizer,proto3" json:"vectorizer,omitempty"`
	// contains filtered or unexported fields
}

Represent the insert by binary object request.

func (*Insert_ObjectRequest) CloneMessageVT added in v1.7.7 

func (m *Insert_ObjectRequest) CloneMessageVT() proto.Message

func (*Insert_ObjectRequest) CloneVT added in v1.7.7 

func (m *Insert_ObjectRequest) CloneVT() *Insert_ObjectRequest

func (*Insert_ObjectRequest) Descriptor deprecated 

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

Deprecated: Use Insert_ObjectRequest.ProtoReflect.Descriptor instead.

func (*Insert_ObjectRequest) EqualMessageVT added in v1.7.6 

func (this *Insert_ObjectRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*Insert_ObjectRequest) EqualVT added in v1.7.6 

func (this *Insert_ObjectRequest) EqualVT(that *Insert_ObjectRequest) bool

func (*Insert_ObjectRequest) GetConfig 

func (x *Insert_ObjectRequest) GetConfig() *Insert_Config

func (*Insert_ObjectRequest) GetObject 

func (x *Insert_ObjectRequest) GetObject() *Object_Blob

func (*Insert_ObjectRequest) GetVectorizer 

func (x *Insert_ObjectRequest) GetVectorizer() *Filter_Target

func (*Insert_ObjectRequest) MarshalToSizedBufferVT added in v1.2.2 

func (m *Insert_ObjectRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Insert_ObjectRequest) MarshalToVT added in v1.2.2 

func (m *Insert_ObjectRequest) MarshalToVT(dAtA []byte) (int, error)

func (*Insert_ObjectRequest) MarshalVT added in v1.2.2 

func (m *Insert_ObjectRequest) MarshalVT() (dAtA []byte, err error)

func (*Insert_ObjectRequest) ProtoMessage 

func (*Insert_ObjectRequest) ProtoMessage()

func (*Insert_ObjectRequest) ProtoReflect added in v1.2.2 

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

func (*Insert_ObjectRequest) Reset 

func (x *Insert_ObjectRequest) Reset()

func (*Insert_ObjectRequest) SizeVT added in v1.2.2 

func (m *Insert_ObjectRequest) SizeVT() (n int)

func (*Insert_ObjectRequest) String 

func (x *Insert_ObjectRequest) String() string

func (*Insert_ObjectRequest) UnmarshalVT added in v1.2.2 

func (m *Insert_ObjectRequest) UnmarshalVT(dAtA []byte) error

type Insert_Request 

type Insert_Request struct {

	// The vector to be inserted.
	Vector *Object_Vector `protobuf:"bytes,1,opt,name=vector,proto3" json:"vector,omitempty"`
	// The configuration of the insert request.
	Config *Insert_Config `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

Represent the insert request.

func (*Insert_Request) CloneMessageVT added in v1.7.7 

func (m *Insert_Request) CloneMessageVT() proto.Message

func (*Insert_Request) CloneVT added in v1.7.7 

func (m *Insert_Request) CloneVT() *Insert_Request

func (*Insert_Request) Descriptor deprecated 

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

Deprecated: Use Insert_Request.ProtoReflect.Descriptor instead.

func (*Insert_Request) EqualMessageVT added in v1.7.6 

func (this *Insert_Request) EqualMessageVT(thatMsg proto.Message) bool

func (*Insert_Request) EqualVT added in v1.7.6 

func (this *Insert_Request) EqualVT(that *Insert_Request) bool

func (*Insert_Request) GetConfig 

func (x *Insert_Request) GetConfig() *Insert_Config

func (*Insert_Request) GetVector 

func (x *Insert_Request) GetVector() *Object_Vector

func (*Insert_Request) MarshalToSizedBufferVT added in v1.2.2 

func (m *Insert_Request) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Insert_Request) MarshalToVT added in v1.2.2 

func (m *Insert_Request) MarshalToVT(dAtA []byte) (int, error)

func (*Insert_Request) MarshalVT added in v1.2.2 

func (m *Insert_Request) MarshalVT() (dAtA []byte, err error)

func (*Insert_Request) ProtoMessage 

func (*Insert_Request) ProtoMessage()

func (*Insert_Request) ProtoReflect added in v1.2.2 

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

func (*Insert_Request) Reset 

func (x *Insert_Request) Reset()

func (*Insert_Request) SizeVT added in v1.2.2 

func (m *Insert_Request) SizeVT() (n int)

func (*Insert_Request) String 

func (x *Insert_Request) String() string

func (*Insert_Request) UnmarshalVT added in v1.2.2 

func (m *Insert_Request) UnmarshalVT(dAtA []byte) error

type Mirror added in v1.7.11 

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

Mirror related messages.

func (*Mirror) CloneMessageVT added in v1.7.11 

func (m *Mirror) CloneMessageVT() proto.Message

func (*Mirror) CloneVT added in v1.7.11 

func (m *Mirror) CloneVT() *Mirror

func (*Mirror) Descriptor deprecated added in v1.7.11 

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

Deprecated: Use Mirror.ProtoReflect.Descriptor instead.

func (*Mirror) EqualMessageVT added in v1.7.11 

func (this *Mirror) EqualMessageVT(thatMsg proto.Message) bool

func (*Mirror) EqualVT added in v1.7.11 

func (this *Mirror) EqualVT(that *Mirror) bool

func (*Mirror) MarshalToSizedBufferVT added in v1.7.11 

func (m *Mirror) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Mirror) MarshalToVT added in v1.7.11 

func (m *Mirror) MarshalToVT(dAtA []byte) (int, error)

func (*Mirror) MarshalVT added in v1.7.11 

func (m *Mirror) MarshalVT() (dAtA []byte, err error)

func (*Mirror) ProtoMessage added in v1.7.11 

func (*Mirror) ProtoMessage()

func (*Mirror) ProtoReflect added in v1.7.11 

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

func (*Mirror) Reset added in v1.7.11 

func (x *Mirror) Reset()

func (*Mirror) SizeVT added in v1.7.11 

func (m *Mirror) SizeVT() (n int)

func (*Mirror) String added in v1.7.11 

func (x *Mirror) String() string

func (*Mirror) UnmarshalVT added in v1.7.11 

func (m *Mirror) UnmarshalVT(dAtA []byte) error

type Mirror_Target added in v1.7.11 

type Mirror_Target struct {

	// The target hostname.
	Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	// The target port.
	Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

Represent server information.

func (*Mirror_Target) CloneMessageVT added in v1.7.11 

func (m *Mirror_Target) CloneMessageVT() proto.Message

func (*Mirror_Target) CloneVT added in v1.7.11 

func (m *Mirror_Target) CloneVT() *Mirror_Target

func (*Mirror_Target) Descriptor deprecated added in v1.7.11 

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

Deprecated: Use Mirror_Target.ProtoReflect.Descriptor instead.

func (*Mirror_Target) EqualMessageVT added in v1.7.11 

func (this *Mirror_Target) EqualMessageVT(thatMsg proto.Message) bool

func (*Mirror_Target) EqualVT added in v1.7.11 

func (this *Mirror_Target) EqualVT(that *Mirror_Target) bool

func (*Mirror_Target) GetHost added in v1.7.11 

func (x *Mirror_Target) GetHost() string

func (*Mirror_Target) GetPort added in v1.7.11 

func (x *Mirror_Target) GetPort() uint32

func (*Mirror_Target) MarshalToSizedBufferVT added in v1.7.11 

func (m *Mirror_Target) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Mirror_Target) MarshalToVT added in v1.7.11 

func (m *Mirror_Target) MarshalToVT(dAtA []byte) (int, error)

func (*Mirror_Target) MarshalVT added in v1.7.11 

func (m *Mirror_Target) MarshalVT() (dAtA []byte, err error)

func (*Mirror_Target) ProtoMessage added in v1.7.11 

func (*Mirror_Target) ProtoMessage()

func (*Mirror_Target) ProtoReflect added in v1.7.11 

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

func (*Mirror_Target) Reset added in v1.7.11 

func (x *Mirror_Target) Reset()

func (*Mirror_Target) SizeVT added in v1.7.11 

func (m *Mirror_Target) SizeVT() (n int)

func (*Mirror_Target) String added in v1.7.11 

func (x *Mirror_Target) String() string

func (*Mirror_Target) UnmarshalVT added in v1.7.11 

func (m *Mirror_Target) UnmarshalVT(dAtA []byte) error

type Mirror_Targets added in v1.7.11 

type Mirror_Targets struct {

	// The multiple target information.
	Targets []*Mirror_Target `protobuf:"bytes,1,rep,name=targets,proto3" json:"targets,omitempty"`
	// contains filtered or unexported fields
}

Represent the multiple Target message.

func (*Mirror_Targets) CloneMessageVT added in v1.7.11 

func (m *Mirror_Targets) CloneMessageVT() proto.Message

func (*Mirror_Targets) CloneVT added in v1.7.11 

func (m *Mirror_Targets) CloneVT() *Mirror_Targets

func (*Mirror_Targets) Descriptor deprecated added in v1.7.11 

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

Deprecated: Use Mirror_Targets.ProtoReflect.Descriptor instead.

func (*Mirror_Targets) EqualMessageVT added in v1.7.11 

func (this *Mirror_Targets) EqualMessageVT(thatMsg proto.Message) bool

func (*Mirror_Targets) EqualVT added in v1.7.11 

func (this *Mirror_Targets) EqualVT(that *Mirror_Targets) bool

func (*Mirror_Targets) GetTargets added in v1.7.11 

func (x *Mirror_Targets) GetTargets() []*Mirror_Target

func (*Mirror_Targets) MarshalToSizedBufferVT added in v1.7.11 

func (m *Mirror_Targets) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Mirror_Targets) MarshalToVT added in v1.7.11 

func (m *Mirror_Targets) MarshalToVT(dAtA []byte) (int, error)

func (*Mirror_Targets) MarshalVT added in v1.7.11 

func (m *Mirror_Targets) MarshalVT() (dAtA []byte, err error)

func (*Mirror_Targets) ProtoMessage added in v1.7.11 

func (*Mirror_Targets) ProtoMessage()

func (*Mirror_Targets) ProtoReflect added in v1.7.11 

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

func (*Mirror_Targets) Reset added in v1.7.11 

func (x *Mirror_Targets) Reset()

func (*Mirror_Targets) SizeVT added in v1.7.11 

func (m *Mirror_Targets) SizeVT() (n int)

func (*Mirror_Targets) String added in v1.7.11 

func (x *Mirror_Targets) String() string

func (*Mirror_Targets) UnmarshalVT added in v1.7.11 

func (m *Mirror_Targets) UnmarshalVT(dAtA []byte) error

type Object 

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

Common messages.

func (*Object) CloneMessageVT added in v1.7.7 

func (m *Object) CloneMessageVT() proto.Message

func (*Object) CloneVT added in v1.7.7 

func (m *Object) CloneVT() *Object

func (*Object) Descriptor deprecated 

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

Deprecated: Use Object.ProtoReflect.Descriptor instead.

func (*Object) EqualMessageVT added in v1.7.6 

func (this *Object) EqualMessageVT(thatMsg proto.Message) bool

func (*Object) EqualVT added in v1.7.6 

func (this *Object) EqualVT(that *Object) bool

func (*Object) MarshalToSizedBufferVT added in v1.2.2 

func (m *Object) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object) MarshalToVT added in v1.2.2 

func (m *Object) MarshalToVT(dAtA []byte) (int, error)

func (*Object) MarshalVT added in v1.2.2 

func (m *Object) MarshalVT() (dAtA []byte, err error)

func (*Object) ProtoMessage 

func (*Object) ProtoMessage()

func (*Object) ProtoReflect added in v1.2.2 

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

func (*Object) Reset 

func (x *Object) Reset()

func (*Object) SizeVT added in v1.2.2 

func (m *Object) SizeVT() (n int)

func (*Object) String 

func (x *Object) String() string

func (*Object) UnmarshalVT added in v1.2.2 

func (m *Object) UnmarshalVT(dAtA []byte) error

type Object_Blob 

type Object_Blob struct {

	// The object ID.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The binary object.
	Object []byte `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

Represent the binary object.

func (*Object_Blob) CloneMessageVT added in v1.7.7 

func (m *Object_Blob) CloneMessageVT() proto.Message

func (*Object_Blob) CloneVT added in v1.7.7 

func (m *Object_Blob) CloneVT() *Object_Blob

func (*Object_Blob) Descriptor deprecated 

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

Deprecated: Use Object_Blob.ProtoReflect.Descriptor instead.

func (*Object_Blob) EqualMessageVT added in v1.7.6 

func (this *Object_Blob) EqualMessageVT(thatMsg proto.Message) bool

func (*Object_Blob) EqualVT added in v1.7.6 

func (this *Object_Blob) EqualVT(that *Object_Blob) bool

func (*Object_Blob) GetId 

func (x *Object_Blob) GetId() string

func (*Object_Blob) GetObject 

func (x *Object_Blob) GetObject() []byte

func (*Object_Blob) MarshalToSizedBufferVT added in v1.2.2 

func (m *Object_Blob) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_Blob) MarshalToVT added in v1.2.2 

func (m *Object_Blob) MarshalToVT(dAtA []byte) (int, error)

func (*Object_Blob) MarshalVT added in v1.2.2 

func (m *Object_Blob) MarshalVT() (dAtA []byte, err error)

func (*Object_Blob) ProtoMessage 

func (*Object_Blob) ProtoMessage()

func (*Object_Blob) ProtoReflect added in v1.2.2 

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

func (*Object_Blob) Reset 

func (x *Object_Blob) Reset()

func (*Object_Blob) SizeVT added in v1.2.2 

func (m *Object_Blob) SizeVT() (n int)

func (*Object_Blob) String 

func (x *Object_Blob) String() string

func (*Object_Blob) UnmarshalVT added in v1.2.2 

func (m *Object_Blob) UnmarshalVT(dAtA []byte) error

type Object_Distance 

type Object_Distance struct {

	// The vector ID.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The distance.
	Distance float32 `protobuf:"fixed32,2,opt,name=distance,proto3" json:"distance,omitempty"`
	// contains filtered or unexported fields
}

Represent the ID and distance pair.

func (*Object_Distance) CloneMessageVT added in v1.7.7 

func (m *Object_Distance) CloneMessageVT() proto.Message

func (*Object_Distance) CloneVT added in v1.7.7 

func (m *Object_Distance) CloneVT() *Object_Distance

func (*Object_Distance) Descriptor deprecated 

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

Deprecated: Use Object_Distance.ProtoReflect.Descriptor instead.

func (*Object_Distance) EqualMessageVT added in v1.7.6 

func (this *Object_Distance) EqualMessageVT(thatMsg proto.Message) bool

func (*Object_Distance) EqualVT added in v1.7.6 

func (this *Object_Distance) EqualVT(that *Object_Distance) bool

func (*Object_Distance) GetDistance 

func (x *Object_Distance) GetDistance() float32

func (*Object_Distance) GetId 

func (x *Object_Distance) GetId() string

func (*Object_Distance) MarshalToSizedBufferVT added in v1.2.2 

func (m *Object_Distance) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_Distance) MarshalToVT added in v1.2.2 

func (m *Object_Distance) MarshalToVT(dAtA []byte) (int, error)

func (*Object_Distance) MarshalVT added in v1.2.2 

func (m *Object_Distance) MarshalVT() (dAtA []byte, err error)

func (*Object_Distance) ProtoMessage 

func (*Object_Distance) ProtoMessage()

func (*Object_Distance) ProtoReflect added in v1.2.2 

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

func (*Object_Distance) Reset 

func (x *Object_Distance) Reset()

func (*Object_Distance) SizeVT added in v1.2.2 

func (m *Object_Distance) SizeVT() (n int)

func (*Object_Distance) String 

func (x *Object_Distance) String() string

func (*Object_Distance) UnmarshalVT added in v1.2.2 

func (m *Object_Distance) UnmarshalVT(dAtA []byte) error

type Object_GetTimestampRequest added in v1.7.9 

type Object_GetTimestampRequest struct {

	// The vector ID to be fetched.
	Id *Object_ID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

Represent a request to fetch vector meta data.

func (*Object_GetTimestampRequest) CloneMessageVT added in v1.7.9 

func (m *Object_GetTimestampRequest) CloneMessageVT() proto.Message

func (*Object_GetTimestampRequest) CloneVT added in v1.7.9 

func (m *Object_GetTimestampRequest) CloneVT() *Object_GetTimestampRequest

func (*Object_GetTimestampRequest) Descriptor deprecated added in v1.7.9 

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

Deprecated: Use Object_GetTimestampRequest.ProtoReflect.Descriptor instead.

func (*Object_GetTimestampRequest) EqualMessageVT added in v1.7.9 

func (this *Object_GetTimestampRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*Object_GetTimestampRequest) EqualVT added in v1.7.9 

func (this *Object_GetTimestampRequest) EqualVT(that *Object_GetTimestampRequest) bool

func (*Object_GetTimestampRequest) GetId added in v1.7.9 

func (x *Object_GetTimestampRequest) GetId() *Object_ID

func (*Object_GetTimestampRequest) MarshalToSizedBufferVT added in v1.7.9 

func (m *Object_GetTimestampRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_GetTimestampRequest) MarshalToVT added in v1.7.9 

func (m *Object_GetTimestampRequest) MarshalToVT(dAtA []byte) (int, error)

func (*Object_GetTimestampRequest) MarshalVT added in v1.7.9 

func (m *Object_GetTimestampRequest) MarshalVT() (dAtA []byte, err error)

func (*Object_GetTimestampRequest) ProtoMessage added in v1.7.9 

func (*Object_GetTimestampRequest) ProtoMessage()

func (*Object_GetTimestampRequest) ProtoReflect added in v1.7.9 

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

func (*Object_GetTimestampRequest) Reset added in v1.7.9 

func (x *Object_GetTimestampRequest) Reset()

func (*Object_GetTimestampRequest) SizeVT added in v1.7.9 

func (m *Object_GetTimestampRequest) SizeVT() (n int)

func (*Object_GetTimestampRequest) String added in v1.7.9 

func (x *Object_GetTimestampRequest) String() string

func (*Object_GetTimestampRequest) UnmarshalVT added in v1.7.9 

func (m *Object_GetTimestampRequest) UnmarshalVT(dAtA []byte) error

type Object_ID 

type Object_ID struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

Represent the vector ID.

func (*Object_ID) CloneMessageVT added in v1.7.7 

func (m *Object_ID) CloneMessageVT() proto.Message

func (*Object_ID) CloneVT added in v1.7.7 

func (m *Object_ID) CloneVT() *Object_ID

func (*Object_ID) Descriptor deprecated 

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

Deprecated: Use Object_ID.ProtoReflect.Descriptor instead.

func (*Object_ID) EqualMessageVT added in v1.7.6 

func (this *Object_ID) EqualMessageVT(thatMsg proto.Message) bool

func (*Object_ID) EqualVT added in v1.7.6 

func (this *Object_ID) EqualVT(that *Object_ID) bool

func (*Object_ID) GetId 

func (x *Object_ID) GetId() string

func (*Object_ID) MarshalToSizedBufferVT added in v1.2.2 

func (m *Object_ID) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_ID) MarshalToVT added in v1.2.2 

func (m *Object_ID) MarshalToVT(dAtA []byte) (int, error)

func (*Object_ID) MarshalVT added in v1.2.2 

func (m *Object_ID) MarshalVT() (dAtA []byte, err error)

func (*Object_ID) ProtoMessage 

func (*Object_ID) ProtoMessage()

func (*Object_ID) ProtoReflect added in v1.2.2 

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

func (*Object_ID) Reset 

func (x *Object_ID) Reset()

func (*Object_ID) SizeVT added in v1.2.2 

func (m *Object_ID) SizeVT() (n int)

func (*Object_ID) String 

func (x *Object_ID) String() string

func (*Object_ID) UnmarshalVT added in v1.2.2 

func (m *Object_ID) UnmarshalVT(dAtA []byte) error

type Object_IDs 

type Object_IDs struct {
	Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

Represent multiple vector IDs.

func (*Object_IDs) CloneMessageVT added in v1.7.7 

func (m *Object_IDs) CloneMessageVT() proto.Message

func (*Object_IDs) CloneVT added in v1.7.7 

func (m *Object_IDs) CloneVT() *Object_IDs

func (*Object_IDs) Descriptor deprecated 

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

Deprecated: Use Object_IDs.ProtoReflect.Descriptor instead.

func (*Object_IDs) EqualMessageVT added in v1.7.6 

func (this *Object_IDs) EqualMessageVT(thatMsg proto.Message) bool

func (*Object_IDs) EqualVT added in v1.7.6 

func (this *Object_IDs) EqualVT(that *Object_IDs) bool

func (*Object_IDs) GetIds 

func (x *Object_IDs) GetIds() []string

func (*Object_IDs) MarshalToSizedBufferVT added in v1.2.2 

func (m *Object_IDs) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_IDs) MarshalToVT added in v1.2.2 

func (m *Object_IDs) MarshalToVT(dAtA []byte) (int, error)

func (*Object_IDs) MarshalVT added in v1.2.2 

func (m *Object_IDs) MarshalVT() (dAtA []byte, err error)

func (*Object_IDs) ProtoMessage 

func (*Object_IDs) ProtoMessage()

func (*Object_IDs) ProtoReflect added in v1.2.2 

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

func (*Object_IDs) Reset 

func (x *Object_IDs) Reset()

func (*Object_IDs) SizeVT added in v1.2.2 

func (m *Object_IDs) SizeVT() (n int)

func (*Object_IDs) String 

func (x *Object_IDs) String() string

func (*Object_IDs) UnmarshalVT added in v1.2.2 

func (m *Object_IDs) UnmarshalVT(dAtA []byte) error

type Object_List added in v1.7.7 

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

Represent the list object vector stream request and response.

func (*Object_List) CloneMessageVT added in v1.7.7 

func (m *Object_List) CloneMessageVT() proto.Message

func (*Object_List) CloneVT added in v1.7.7 

func (m *Object_List) CloneVT() *Object_List

func (*Object_List) Descriptor deprecated added in v1.7.7 

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

Deprecated: Use Object_List.ProtoReflect.Descriptor instead.

func (*Object_List) EqualMessageVT added in v1.7.7 

func (this *Object_List) EqualMessageVT(thatMsg proto.Message) bool

func (*Object_List) EqualVT added in v1.7.7 

func (this *Object_List) EqualVT(that *Object_List) bool

func (*Object_List) MarshalToSizedBufferVT added in v1.7.7 

func (m *Object_List) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_List) MarshalToVT added in v1.7.7 

func (m *Object_List) MarshalToVT(dAtA []byte) (int, error)

func (*Object_List) MarshalVT added in v1.7.7 

func (m *Object_List) MarshalVT() (dAtA []byte, err error)

func (*Object_List) ProtoMessage added in v1.7.7 

func (*Object_List) ProtoMessage()

func (*Object_List) ProtoReflect added in v1.7.7 

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

func (*Object_List) Reset added in v1.7.7 

func (x *Object_List) Reset()

func (*Object_List) SizeVT added in v1.7.7 

func (m *Object_List) SizeVT() (n int)

func (*Object_List) String added in v1.7.7 

func (x *Object_List) String() string

func (*Object_List) UnmarshalVT added in v1.7.7 

func (m *Object_List) UnmarshalVT(dAtA []byte) error

type Object_List_Request added in v1.7.7 

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

func (*Object_List_Request) CloneMessageVT added in v1.7.7 

func (m *Object_List_Request) CloneMessageVT() proto.Message

func (*Object_List_Request) CloneVT added in v1.7.7 

func (m *Object_List_Request) CloneVT() *Object_List_Request

func (*Object_List_Request) Descriptor deprecated added in v1.7.7 

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

Deprecated: Use Object_List_Request.ProtoReflect.Descriptor instead.

func (*Object_List_Request) EqualMessageVT added in v1.7.7 

func (this *Object_List_Request) EqualMessageVT(thatMsg proto.Message) bool

func (*Object_List_Request) EqualVT added in v1.7.7 

func (this *Object_List_Request) EqualVT(that *Object_List_Request) bool

func (*Object_List_Request) MarshalToSizedBufferVT added in v1.7.7 

func (m *Object_List_Request) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_List_Request) MarshalToVT added in v1.7.7 

func (m *Object_List_Request) MarshalToVT(dAtA []byte) (int, error)

func (*Object_List_Request) MarshalVT added in v1.7.7 

func (m *Object_List_Request) MarshalVT() (dAtA []byte, err error)

func (*Object_List_Request) ProtoMessage added in v1.7.7 

func (*Object_List_Request) ProtoMessage()

func (*Object_List_Request) ProtoReflect added in v1.7.7 

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

func (*Object_List_Request) Reset added in v1.7.7 

func (x *Object_List_Request) Reset()

func (*Object_List_Request) SizeVT added in v1.7.7 

func (m *Object_List_Request) SizeVT() (n int)

func (*Object_List_Request) String added in v1.7.7 

func (x *Object_List_Request) String() string

func (*Object_List_Request) UnmarshalVT added in v1.7.7 

func (m *Object_List_Request) UnmarshalVT(dAtA []byte) error

type Object_List_Response added in v1.7.7 

type Object_List_Response struct {

	// Types that are assignable to Payload:
	//
	//	*Object_List_Response_Vector
	//	*Object_List_Response_Status
	Payload isObject_List_Response_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*Object_List_Response) CloneMessageVT added in v1.7.7 

func (m *Object_List_Response) CloneMessageVT() proto.Message

func (*Object_List_Response) CloneVT added in v1.7.7 

func (m *Object_List_Response) CloneVT() *Object_List_Response

func (*Object_List_Response) Descriptor deprecated added in v1.7.7 

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

Deprecated: Use Object_List_Response.ProtoReflect.Descriptor instead.

func (*Object_List_Response) EqualMessageVT added in v1.7.7 

func (this *Object_List_Response) EqualMessageVT(thatMsg proto.Message) bool

func (*Object_List_Response) EqualVT added in v1.7.7 

func (this *Object_List_Response) EqualVT(that *Object_List_Response) bool

func (*Object_List_Response) GetPayload added in v1.7.7 

func (m *Object_List_Response) GetPayload() isObject_List_Response_Payload

func (*Object_List_Response) GetStatus added in v1.7.7 

func (x *Object_List_Response) GetStatus() *status.Status

func (*Object_List_Response) GetVector added in v1.7.7 

func (x *Object_List_Response) GetVector() *Object_Vector

func (*Object_List_Response) MarshalToSizedBufferVT added in v1.7.7 

func (m *Object_List_Response) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_List_Response) MarshalToVT added in v1.7.7 

func (m *Object_List_Response) MarshalToVT(dAtA []byte) (int, error)

func (*Object_List_Response) MarshalVT added in v1.7.7 

func (m *Object_List_Response) MarshalVT() (dAtA []byte, err error)

func (*Object_List_Response) ProtoMessage added in v1.7.7 

func (*Object_List_Response) ProtoMessage()

func (*Object_List_Response) ProtoReflect added in v1.7.7 

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

func (*Object_List_Response) Reset added in v1.7.7 

func (x *Object_List_Response) Reset()

func (*Object_List_Response) SizeVT added in v1.7.7 

func (m *Object_List_Response) SizeVT() (n int)

func (*Object_List_Response) String added in v1.7.7 

func (x *Object_List_Response) String() string

func (*Object_List_Response) UnmarshalVT added in v1.7.7 

func (m *Object_List_Response) UnmarshalVT(dAtA []byte) error

type Object_List_Response_Status added in v1.7.7 

type Object_List_Response_Status struct {
	// The RPC error status.
	Status *status.Status `protobuf:"bytes,2,opt,name=status,proto3,oneof"`
}

func (*Object_List_Response_Status) CloneVT added in v1.7.7 

func (m *Object_List_Response_Status) CloneVT() isObject_List_Response_Payload

func (*Object_List_Response_Status) EqualVT added in v1.7.7 

func (this *Object_List_Response_Status) EqualVT(thatIface isObject_List_Response_Payload) bool

func (*Object_List_Response_Status) MarshalToSizedBufferVT added in v1.7.7 

func (m *Object_List_Response_Status) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_List_Response_Status) MarshalToVT added in v1.7.7 

func (m *Object_List_Response_Status) MarshalToVT(dAtA []byte) (int, error)

func (*Object_List_Response_Status) SizeVT added in v1.7.7 

func (m *Object_List_Response_Status) SizeVT() (n int)

type Object_List_Response_Vector added in v1.7.7 

type Object_List_Response_Vector struct {
	// The vector
	Vector *Object_Vector `protobuf:"bytes,1,opt,name=vector,proto3,oneof"`
}

func (*Object_List_Response_Vector) CloneVT added in v1.7.7 

func (m *Object_List_Response_Vector) CloneVT() isObject_List_Response_Payload

func (*Object_List_Response_Vector) EqualVT added in v1.7.7 

func (this *Object_List_Response_Vector) EqualVT(thatIface isObject_List_Response_Payload) bool

func (*Object_List_Response_Vector) MarshalToSizedBufferVT added in v1.7.7 

func (m *Object_List_Response_Vector) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_List_Response_Vector) MarshalToVT added in v1.7.7 

func (m *Object_List_Response_Vector) MarshalToVT(dAtA []byte) (int, error)

func (*Object_List_Response_Vector) SizeVT added in v1.7.7 

func (m *Object_List_Response_Vector) SizeVT() (n int)

type Object_Location 

type Object_Location struct {

	// The name of the location.
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// The UUID of the vector.
	Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// The IP list.
	Ips []string `protobuf:"bytes,3,rep,name=ips,proto3" json:"ips,omitempty"`
	// contains filtered or unexported fields
}

Represent the vector location.

func (*Object_Location) CloneMessageVT added in v1.7.7 

func (m *Object_Location) CloneMessageVT() proto.Message

func (*Object_Location) CloneVT added in v1.7.7 

func (m *Object_Location) CloneVT() *Object_Location

func (*Object_Location) Descriptor deprecated 

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

Deprecated: Use Object_Location.ProtoReflect.Descriptor instead.

func (*Object_Location) EqualMessageVT added in v1.7.6 

func (this *Object_Location) EqualMessageVT(thatMsg proto.Message) bool

func (*Object_Location) EqualVT added in v1.7.6 

func (this *Object_Location) EqualVT(that *Object_Location) bool

func (*Object_Location) GetIps 

func (x *Object_Location) GetIps() []string

func (*Object_Location) GetName 

func (x *Object_Location) GetName() string

func (*Object_Location) GetUuid 

func (x *Object_Location) GetUuid() string

func (*Object_Location) MarshalToSizedBufferVT added in v1.2.2 

func (m *Object_Location) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_Location) MarshalToVT added in v1.2.2 

func (m *Object_Location) MarshalToVT(dAtA []byte) (int, error)

func (*Object_Location) MarshalVT added in v1.2.2 

func (m *Object_Location) MarshalVT() (dAtA []byte, err error)

func (*Object_Location) ProtoMessage 

func (*Object_Location) ProtoMessage()

func (*Object_Location) ProtoReflect added in v1.2.2 

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

func (*Object_Location) Reset 

func (x *Object_Location) Reset()

func (*Object_Location) SizeVT added in v1.2.2 

func (m *Object_Location) SizeVT() (n int)

func (*Object_Location) String 

func (x *Object_Location) String() string

func (*Object_Location) UnmarshalVT added in v1.2.2 

func (m *Object_Location) UnmarshalVT(dAtA []byte) error

type Object_Locations 

type Object_Locations struct {
	Locations []*Object_Location `protobuf:"bytes,1,rep,name=locations,proto3" json:"locations,omitempty"`
	// contains filtered or unexported fields
}

Represent multiple vector locations.

func (*Object_Locations) CloneMessageVT added in v1.7.7 

func (m *Object_Locations) CloneMessageVT() proto.Message

func (*Object_Locations) CloneVT added in v1.7.7 

func (m *Object_Locations) CloneVT() *Object_Locations

func (*Object_Locations) Descriptor deprecated 

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

Deprecated: Use Object_Locations.ProtoReflect.Descriptor instead.

func (*Object_Locations) EqualMessageVT added in v1.7.6 

func (this *Object_Locations) EqualMessageVT(thatMsg proto.Message) bool

func (*Object_Locations) EqualVT added in v1.7.6 

func (this *Object_Locations) EqualVT(that *Object_Locations) bool

func (*Object_Locations) GetLocations 

func (x *Object_Locations) GetLocations() []*Object_Location

func (*Object_Locations) MarshalToSizedBufferVT added in v1.2.2 

func (m *Object_Locations) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_Locations) MarshalToVT added in v1.2.2 

func (m *Object_Locations) MarshalToVT(dAtA []byte) (int, error)

func (*Object_Locations) MarshalVT added in v1.2.2 

func (m *Object_Locations) MarshalVT() (dAtA []byte, err error)

func (*Object_Locations) ProtoMessage 

func (*Object_Locations) ProtoMessage()

func (*Object_Locations) ProtoReflect added in v1.2.2 

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

func (*Object_Locations) Reset 

func (x *Object_Locations) Reset()

func (*Object_Locations) SizeVT added in v1.2.2 

func (m *Object_Locations) SizeVT() (n int)

func (*Object_Locations) String 

func (x *Object_Locations) String() string

func (*Object_Locations) UnmarshalVT added in v1.2.2 

func (m *Object_Locations) UnmarshalVT(dAtA []byte) error

type Object_ReshapeVector added in v1.4.0 

type Object_ReshapeVector struct {

	// The binary object.
	Object []byte `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	// The new shape.
	Shape []int32 `protobuf:"varint,2,rep,packed,name=shape,proto3" json:"shape,omitempty"`
	// contains filtered or unexported fields
}

Represent reshape vector.

func (*Object_ReshapeVector) CloneMessageVT added in v1.7.7 

func (m *Object_ReshapeVector) CloneMessageVT() proto.Message

func (*Object_ReshapeVector) CloneVT added in v1.7.7 

func (m *Object_ReshapeVector) CloneVT() *Object_ReshapeVector

func (*Object_ReshapeVector) Descriptor deprecated added in v1.4.0 

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

Deprecated: Use Object_ReshapeVector.ProtoReflect.Descriptor instead.

func (*Object_ReshapeVector) EqualMessageVT added in v1.7.6 

func (this *Object_ReshapeVector) EqualMessageVT(thatMsg proto.Message) bool

func (*Object_ReshapeVector) EqualVT added in v1.7.6 

func (this *Object_ReshapeVector) EqualVT(that *Object_ReshapeVector) bool

func (*Object_ReshapeVector) GetObject added in v1.4.0 

func (x *Object_ReshapeVector) GetObject() []byte

func (*Object_ReshapeVector) GetShape added in v1.4.0 

func (x *Object_ReshapeVector) GetShape() []int32

func (*Object_ReshapeVector) MarshalToSizedBufferVT added in v1.4.0 

func (m *Object_ReshapeVector) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_ReshapeVector) MarshalToVT added in v1.4.0 

func (m *Object_ReshapeVector) MarshalToVT(dAtA []byte) (int, error)

func (*Object_ReshapeVector) MarshalVT added in v1.4.0 

func (m *Object_ReshapeVector) MarshalVT() (dAtA []byte, err error)

func (*Object_ReshapeVector) ProtoMessage added in v1.4.0 

func (*Object_ReshapeVector) ProtoMessage()

func (*Object_ReshapeVector) ProtoReflect added in v1.4.0 

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

func (*Object_ReshapeVector) Reset added in v1.4.0 

func (x *Object_ReshapeVector) Reset()

func (*Object_ReshapeVector) SizeVT added in v1.4.0 

func (m *Object_ReshapeVector) SizeVT() (n int)

func (*Object_ReshapeVector) String added in v1.4.0 

func (x *Object_ReshapeVector) String() string

func (*Object_ReshapeVector) UnmarshalVT added in v1.4.0 

func (m *Object_ReshapeVector) UnmarshalVT(dAtA []byte) error

type Object_StreamBlob 

type Object_StreamBlob struct {

	// Types that are assignable to Payload:
	//
	//	*Object_StreamBlob_Blob
	//	*Object_StreamBlob_Status
	Payload isObject_StreamBlob_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

Represent stream response of binary objects.

func (*Object_StreamBlob) CloneMessageVT added in v1.7.7 

func (m *Object_StreamBlob) CloneMessageVT() proto.Message

func (*Object_StreamBlob) CloneVT added in v1.7.7 

func (m *Object_StreamBlob) CloneVT() *Object_StreamBlob

func (*Object_StreamBlob) Descriptor deprecated 

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

Deprecated: Use Object_StreamBlob.ProtoReflect.Descriptor instead.

func (*Object_StreamBlob) EqualMessageVT added in v1.7.6 

func (this *Object_StreamBlob) EqualMessageVT(thatMsg proto.Message) bool

func (*Object_StreamBlob) EqualVT added in v1.7.6 

func (this *Object_StreamBlob) EqualVT(that *Object_StreamBlob) bool

func (*Object_StreamBlob) GetBlob 

func (x *Object_StreamBlob) GetBlob() *Object_Blob

func (*Object_StreamBlob) GetPayload 

func (m *Object_StreamBlob) GetPayload() isObject_StreamBlob_Payload

func (*Object_StreamBlob) GetStatus 

func (x *Object_StreamBlob) GetStatus() *status.Status

func (*Object_StreamBlob) MarshalToSizedBufferVT added in v1.2.2 

func (m *Object_StreamBlob) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_StreamBlob) MarshalToVT added in v1.2.2 

func (m *Object_StreamBlob) MarshalToVT(dAtA []byte) (int, error)

func (*Object_StreamBlob) MarshalVT added in v1.2.2 

func (m *Object_StreamBlob) MarshalVT() (dAtA []byte, err error)

func (*Object_StreamBlob) ProtoMessage 

func (*Object_StreamBlob) ProtoMessage()

func (*Object_StreamBlob) ProtoReflect added in v1.2.2 

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

func (*Object_StreamBlob) Reset 

func (x *Object_StreamBlob) Reset()

func (*Object_StreamBlob) SizeVT added in v1.2.2 

func (m *Object_StreamBlob) SizeVT() (n int)

func (*Object_StreamBlob) String 

func (x *Object_StreamBlob) String() string

func (*Object_StreamBlob) UnmarshalVT added in v1.2.2 

func (m *Object_StreamBlob) UnmarshalVT(dAtA []byte) error

type Object_StreamBlob_Blob 

type Object_StreamBlob_Blob struct {
	// The binary object.
	Blob *Object_Blob `protobuf:"bytes,1,opt,name=blob,proto3,oneof"`
}

func (*Object_StreamBlob_Blob) CloneVT added in v1.7.7 

func (m *Object_StreamBlob_Blob) CloneVT() isObject_StreamBlob_Payload

func (*Object_StreamBlob_Blob) EqualVT added in v1.7.6 

func (this *Object_StreamBlob_Blob) EqualVT(thatIface isObject_StreamBlob_Payload) bool

func (*Object_StreamBlob_Blob) MarshalToSizedBufferVT added in v1.2.2 

func (m *Object_StreamBlob_Blob) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_StreamBlob_Blob) MarshalToVT added in v1.2.2 

func (m *Object_StreamBlob_Blob) MarshalToVT(dAtA []byte) (int, error)

func (*Object_StreamBlob_Blob) SizeVT added in v1.2.2 

func (m *Object_StreamBlob_Blob) SizeVT() (n int)

type Object_StreamBlob_Status 

type Object_StreamBlob_Status struct {
	// The RPC error status.
	Status *status.Status `protobuf:"bytes,2,opt,name=status,proto3,oneof"`
}

func (*Object_StreamBlob_Status) CloneVT added in v1.7.7 

func (m *Object_StreamBlob_Status) CloneVT() isObject_StreamBlob_Payload

func (*Object_StreamBlob_Status) EqualVT added in v1.7.6 

func (this *Object_StreamBlob_Status) EqualVT(thatIface isObject_StreamBlob_Payload) bool

func (*Object_StreamBlob_Status) MarshalToSizedBufferVT added in v1.2.2 

func (m *Object_StreamBlob_Status) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_StreamBlob_Status) MarshalToVT added in v1.2.2 

func (m *Object_StreamBlob_Status) MarshalToVT(dAtA []byte) (int, error)

func (*Object_StreamBlob_Status) SizeVT added in v1.2.2 

func (m *Object_StreamBlob_Status) SizeVT() (n int)

type Object_StreamDistance 

type Object_StreamDistance struct {

	// Types that are assignable to Payload:
	//
	//	*Object_StreamDistance_Distance
	//	*Object_StreamDistance_Status
	Payload isObject_StreamDistance_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

Represent stream response of distances.

func (*Object_StreamDistance) CloneMessageVT added in v1.7.7 

func (m *Object_StreamDistance) CloneMessageVT() proto.Message

func (*Object_StreamDistance) CloneVT added in v1.7.7 

func (m *Object_StreamDistance) CloneVT() *Object_StreamDistance

func (*Object_StreamDistance) Descriptor deprecated 

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

Deprecated: Use Object_StreamDistance.ProtoReflect.Descriptor instead.

func (*Object_StreamDistance) EqualMessageVT added in v1.7.6 

func (this *Object_StreamDistance) EqualMessageVT(thatMsg proto.Message) bool

func (*Object_StreamDistance) EqualVT added in v1.7.6 

func (this *Object_StreamDistance) EqualVT(that *Object_StreamDistance) bool

func (*Object_StreamDistance) GetDistance 

func (x *Object_StreamDistance) GetDistance() *Object_Distance

func (*Object_StreamDistance) GetPayload 

func (m *Object_StreamDistance) GetPayload() isObject_StreamDistance_Payload

func (*Object_StreamDistance) GetStatus 

func (x *Object_StreamDistance) GetStatus() *status.Status

func (*Object_StreamDistance) MarshalToSizedBufferVT added in v1.2.2 

func (m *Object_StreamDistance) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_StreamDistance) MarshalToVT added in v1.2.2 

func (m *Object_StreamDistance) MarshalToVT(dAtA []byte) (int, error)

func (*Object_StreamDistance) MarshalVT added in v1.2.2 

func (m *Object_StreamDistance) MarshalVT() (dAtA []byte, err error)

func (*Object_StreamDistance) ProtoMessage 

func (*Object_StreamDistance) ProtoMessage()

func (*Object_StreamDistance) ProtoReflect added in v1.2.2 

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

func (*Object_StreamDistance) Reset 

func (x *Object_StreamDistance) Reset()

func (*Object_StreamDistance) SizeVT added in v1.2.2 

func (m *Object_StreamDistance) SizeVT() (n int)

func (*Object_StreamDistance) String 

func (x *Object_StreamDistance) String() string

func (*Object_StreamDistance) UnmarshalVT added in v1.2.2 

func (m *Object_StreamDistance) UnmarshalVT(dAtA []byte) error

type Object_StreamDistance_Distance 

type Object_StreamDistance_Distance struct {
	// The distance.
	Distance *Object_Distance `protobuf:"bytes,1,opt,name=distance,proto3,oneof"`
}

func (*Object_StreamDistance_Distance) CloneVT added in v1.7.7 

func (m *Object_StreamDistance_Distance) CloneVT() isObject_StreamDistance_Payload

func (*Object_StreamDistance_Distance) EqualVT added in v1.7.6 

func (this *Object_StreamDistance_Distance) EqualVT(thatIface isObject_StreamDistance_Payload) bool

func (*Object_StreamDistance_Distance) MarshalToSizedBufferVT added in v1.2.2 

func (m *Object_StreamDistance_Distance) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_StreamDistance_Distance) MarshalToVT added in v1.2.2 

func (m *Object_StreamDistance_Distance) MarshalToVT(dAtA []byte) (int, error)

func (*Object_StreamDistance_Distance) SizeVT added in v1.2.2 

func (m *Object_StreamDistance_Distance) SizeVT() (n int)

type Object_StreamDistance_Status 

type Object_StreamDistance_Status struct {
	// The RPC error status.
	Status *status.Status `protobuf:"bytes,2,opt,name=status,proto3,oneof"`
}

func (*Object_StreamDistance_Status) CloneVT added in v1.7.7 

func (m *Object_StreamDistance_Status) CloneVT() isObject_StreamDistance_Payload

func (*Object_StreamDistance_Status) EqualVT added in v1.7.6 

func (this *Object_StreamDistance_Status) EqualVT(thatIface isObject_StreamDistance_Payload) bool

func (*Object_StreamDistance_Status) MarshalToSizedBufferVT added in v1.2.2 

func (m *Object_StreamDistance_Status) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_StreamDistance_Status) MarshalToVT added in v1.2.2 

func (m *Object_StreamDistance_Status) MarshalToVT(dAtA []byte) (int, error)

func (*Object_StreamDistance_Status) SizeVT added in v1.2.2 

func (m *Object_StreamDistance_Status) SizeVT() (n int)

type Object_StreamLocation 

type Object_StreamLocation struct {

	// Types that are assignable to Payload:
	//
	//	*Object_StreamLocation_Location
	//	*Object_StreamLocation_Status
	Payload isObject_StreamLocation_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

Represent the stream response of the vector location.

func (*Object_StreamLocation) CloneMessageVT added in v1.7.7 

func (m *Object_StreamLocation) CloneMessageVT() proto.Message

func (*Object_StreamLocation) CloneVT added in v1.7.7 

func (m *Object_StreamLocation) CloneVT() *Object_StreamLocation

func (*Object_StreamLocation) Descriptor deprecated 

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

Deprecated: Use Object_StreamLocation.ProtoReflect.Descriptor instead.

func (*Object_StreamLocation) EqualMessageVT added in v1.7.6 

func (this *Object_StreamLocation) EqualMessageVT(thatMsg proto.Message) bool

func (*Object_StreamLocation) EqualVT added in v1.7.6 

func (this *Object_StreamLocation) EqualVT(that *Object_StreamLocation) bool

func (*Object_StreamLocation) GetLocation 

func (x *Object_StreamLocation) GetLocation() *Object_Location

func (*Object_StreamLocation) GetPayload 

func (m *Object_StreamLocation) GetPayload() isObject_StreamLocation_Payload

func (*Object_StreamLocation) GetStatus 

func (x *Object_StreamLocation) GetStatus() *status.Status

func (*Object_StreamLocation) MarshalToSizedBufferVT added in v1.2.2 

func (m *Object_StreamLocation) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_StreamLocation) MarshalToVT added in v1.2.2 

func (m *Object_StreamLocation) MarshalToVT(dAtA []byte) (int, error)

func (*Object_StreamLocation) MarshalVT added in v1.2.2 

func (m *Object_StreamLocation) MarshalVT() (dAtA []byte, err error)

func (*Object_StreamLocation) ProtoMessage 

func (*Object_StreamLocation) ProtoMessage()

func (*Object_StreamLocation) ProtoReflect added in v1.2.2 

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

func (*Object_StreamLocation) Reset 

func (x *Object_StreamLocation) Reset()

func (*Object_StreamLocation) SizeVT added in v1.2.2 

func (m *Object_StreamLocation) SizeVT() (n int)

func (*Object_StreamLocation) String 

func (x *Object_StreamLocation) String() string

func (*Object_StreamLocation) UnmarshalVT added in v1.2.2 

func (m *Object_StreamLocation) UnmarshalVT(dAtA []byte) error

type Object_StreamLocation_Location 

type Object_StreamLocation_Location struct {
	// The vector location.
	Location *Object_Location `protobuf:"bytes,1,opt,name=location,proto3,oneof"`
}

func (*Object_StreamLocation_Location) CloneVT added in v1.7.7 

func (m *Object_StreamLocation_Location) CloneVT() isObject_StreamLocation_Payload

func (*Object_StreamLocation_Location) EqualVT added in v1.7.6 

func (this *Object_StreamLocation_Location) EqualVT(thatIface isObject_StreamLocation_Payload) bool

func (*Object_StreamLocation_Location) MarshalToSizedBufferVT added in v1.2.2 

func (m *Object_StreamLocation_Location) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_StreamLocation_Location) MarshalToVT added in v1.2.2 

func (m *Object_StreamLocation_Location) MarshalToVT(dAtA []byte) (int, error)

func (*Object_StreamLocation_Location) SizeVT added in v1.2.2 

func (m *Object_StreamLocation_Location) SizeVT() (n int)

type Object_StreamLocation_Status 

type Object_StreamLocation_Status struct {
	// The RPC error status.
	Status *status.Status `protobuf:"bytes,2,opt,name=status,proto3,oneof"`
}

func (*Object_StreamLocation_Status) CloneVT added in v1.7.7 

func (m *Object_StreamLocation_Status) CloneVT() isObject_StreamLocation_Payload

func (*Object_StreamLocation_Status) EqualVT added in v1.7.6 

func (this *Object_StreamLocation_Status) EqualVT(thatIface isObject_StreamLocation_Payload) bool

func (*Object_StreamLocation_Status) MarshalToSizedBufferVT added in v1.2.2 

func (m *Object_StreamLocation_Status) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_StreamLocation_Status) MarshalToVT added in v1.2.2 

func (m *Object_StreamLocation_Status) MarshalToVT(dAtA []byte) (int, error)

func (*Object_StreamLocation_Status) SizeVT added in v1.2.2 

func (m *Object_StreamLocation_Status) SizeVT() (n int)

type Object_StreamVector 

type Object_StreamVector struct {

	// Types that are assignable to Payload:
	//
	//	*Object_StreamVector_Vector
	//	*Object_StreamVector_Status
	Payload isObject_StreamVector_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

Represent stream response of the vector.

func (*Object_StreamVector) CloneMessageVT added in v1.7.7 

func (m *Object_StreamVector) CloneMessageVT() proto.Message

func (*Object_StreamVector) CloneVT added in v1.7.7 

func (m *Object_StreamVector) CloneVT() *Object_StreamVector

func (*Object_StreamVector) Descriptor deprecated 

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

Deprecated: Use Object_StreamVector.ProtoReflect.Descriptor instead.

func (*Object_StreamVector) EqualMessageVT added in v1.7.6 

func (this *Object_StreamVector) EqualMessageVT(thatMsg proto.Message) bool

func (*Object_StreamVector) EqualVT added in v1.7.6 

func (this *Object_StreamVector) EqualVT(that *Object_StreamVector) bool

func (*Object_StreamVector) GetPayload 

func (m *Object_StreamVector) GetPayload() isObject_StreamVector_Payload

func (*Object_StreamVector) GetStatus 

func (x *Object_StreamVector) GetStatus() *status.Status

func (*Object_StreamVector) GetVector 

func (x *Object_StreamVector) GetVector() *Object_Vector

func (*Object_StreamVector) MarshalToSizedBufferVT added in v1.2.2 

func (m *Object_StreamVector) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_StreamVector) MarshalToVT added in v1.2.2 

func (m *Object_StreamVector) MarshalToVT(dAtA []byte) (int, error)

func (*Object_StreamVector) MarshalVT added in v1.2.2 

func (m *Object_StreamVector) MarshalVT() (dAtA []byte, err error)

func (*Object_StreamVector) ProtoMessage 

func (*Object_StreamVector) ProtoMessage()

func (*Object_StreamVector) ProtoReflect added in v1.2.2 

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

func (*Object_StreamVector) Reset 

func (x *Object_StreamVector) Reset()

func (*Object_StreamVector) SizeVT added in v1.2.2 

func (m *Object_StreamVector) SizeVT() (n int)

func (*Object_StreamVector) String 

func (x *Object_StreamVector) String() string

func (*Object_StreamVector) UnmarshalVT added in v1.2.2 

func (m *Object_StreamVector) UnmarshalVT(dAtA []byte) error

type Object_StreamVector_Status 

type Object_StreamVector_Status struct {
	// The RPC error status.
	Status *status.Status `protobuf:"bytes,2,opt,name=status,proto3,oneof"`
}

func (*Object_StreamVector_Status) CloneVT added in v1.7.7 

func (m *Object_StreamVector_Status) CloneVT() isObject_StreamVector_Payload

func (*Object_StreamVector_Status) EqualVT added in v1.7.6 

func (this *Object_StreamVector_Status) EqualVT(thatIface isObject_StreamVector_Payload) bool

func (*Object_StreamVector_Status) MarshalToSizedBufferVT added in v1.2.2 

func (m *Object_StreamVector_Status) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_StreamVector_Status) MarshalToVT added in v1.2.2 

func (m *Object_StreamVector_Status) MarshalToVT(dAtA []byte) (int, error)

func (*Object_StreamVector_Status) SizeVT added in v1.2.2 

func (m *Object_StreamVector_Status) SizeVT() (n int)

type Object_StreamVector_Vector 

type Object_StreamVector_Vector struct {
	// The vector.
	Vector *Object_Vector `protobuf:"bytes,1,opt,name=vector,proto3,oneof"`
}

func (*Object_StreamVector_Vector) CloneVT added in v1.7.7 

func (m *Object_StreamVector_Vector) CloneVT() isObject_StreamVector_Payload

func (*Object_StreamVector_Vector) EqualVT added in v1.7.6 

func (this *Object_StreamVector_Vector) EqualVT(thatIface isObject_StreamVector_Payload) bool

func (*Object_StreamVector_Vector) MarshalToSizedBufferVT added in v1.2.2 

func (m *Object_StreamVector_Vector) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_StreamVector_Vector) MarshalToVT added in v1.2.2 

func (m *Object_StreamVector_Vector) MarshalToVT(dAtA []byte) (int, error)

func (*Object_StreamVector_Vector) SizeVT added in v1.2.2 

func (m *Object_StreamVector_Vector) SizeVT() (n int)

type Object_Timestamp added in v1.7.9 

type Object_Timestamp struct {

	// The vector ID.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// timestamp represents when this vector inserted.
	Timestamp int64 `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

Represent a vector meta data.

func (*Object_Timestamp) CloneMessageVT added in v1.7.9 

func (m *Object_Timestamp) CloneMessageVT() proto.Message

func (*Object_Timestamp) CloneVT added in v1.7.9 

func (m *Object_Timestamp) CloneVT() *Object_Timestamp

func (*Object_Timestamp) Descriptor deprecated added in v1.7.9 

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

Deprecated: Use Object_Timestamp.ProtoReflect.Descriptor instead.

func (*Object_Timestamp) EqualMessageVT added in v1.7.9 

func (this *Object_Timestamp) EqualMessageVT(thatMsg proto.Message) bool

func (*Object_Timestamp) EqualVT added in v1.7.9 

func (this *Object_Timestamp) EqualVT(that *Object_Timestamp) bool

func (*Object_Timestamp) GetId added in v1.7.9 

func (x *Object_Timestamp) GetId() string

func (*Object_Timestamp) GetTimestamp added in v1.7.9 

func (x *Object_Timestamp) GetTimestamp() int64

func (*Object_Timestamp) MarshalToSizedBufferVT added in v1.7.9 

func (m *Object_Timestamp) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_Timestamp) MarshalToVT added in v1.7.9 

func (m *Object_Timestamp) MarshalToVT(dAtA []byte) (int, error)

func (*Object_Timestamp) MarshalVT added in v1.7.9 

func (m *Object_Timestamp) MarshalVT() (dAtA []byte, err error)

func (*Object_Timestamp) ProtoMessage added in v1.7.9 

func (*Object_Timestamp) ProtoMessage()

func (*Object_Timestamp) ProtoReflect added in v1.7.9 

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

func (*Object_Timestamp) Reset added in v1.7.9 

func (x *Object_Timestamp) Reset()

func (*Object_Timestamp) SizeVT added in v1.7.9 

func (m *Object_Timestamp) SizeVT() (n int)

func (*Object_Timestamp) String added in v1.7.9 

func (x *Object_Timestamp) String() string

func (*Object_Timestamp) UnmarshalVT added in v1.7.9 

func (m *Object_Timestamp) UnmarshalVT(dAtA []byte) error

type Object_Vector 

type Object_Vector struct {

	// The vector ID.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The vector.
	Vector []float32 `protobuf:"fixed32,2,rep,packed,name=vector,proto3" json:"vector,omitempty"`
	// timestamp represents when this vector inserted.
	Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

Represent a vector.

func (*Object_Vector) CloneMessageVT added in v1.7.7 

func (m *Object_Vector) CloneMessageVT() proto.Message

func (*Object_Vector) CloneVT added in v1.7.7 

func (m *Object_Vector) CloneVT() *Object_Vector

func (*Object_Vector) Descriptor deprecated 

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

Deprecated: Use Object_Vector.ProtoReflect.Descriptor instead.

func (*Object_Vector) EqualMessageVT added in v1.7.6 

func (this *Object_Vector) EqualMessageVT(thatMsg proto.Message) bool

func (*Object_Vector) EqualVT added in v1.7.6 

func (this *Object_Vector) EqualVT(that *Object_Vector) bool

func (*Object_Vector) GetId 

func (x *Object_Vector) GetId() string

func (*Object_Vector) GetTimestamp added in v1.7.7 

func (x *Object_Vector) GetTimestamp() int64

func (*Object_Vector) GetVector 

func (x *Object_Vector) GetVector() []float32

func (*Object_Vector) MarshalToSizedBufferVT added in v1.2.2 

func (m *Object_Vector) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_Vector) MarshalToVT added in v1.2.2 

func (m *Object_Vector) MarshalToVT(dAtA []byte) (int, error)

func (*Object_Vector) MarshalVT added in v1.2.2 

func (m *Object_Vector) MarshalVT() (dAtA []byte, err error)

func (*Object_Vector) ProtoMessage 

func (*Object_Vector) ProtoMessage()

func (*Object_Vector) ProtoReflect added in v1.2.2 

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

func (*Object_Vector) Reset 

func (x *Object_Vector) Reset()

func (*Object_Vector) SizeVT added in v1.2.2 

func (m *Object_Vector) SizeVT() (n int)

func (*Object_Vector) String 

func (x *Object_Vector) String() string

func (*Object_Vector) UnmarshalVT added in v1.2.2 

func (m *Object_Vector) UnmarshalVT(dAtA []byte) error

type Object_VectorRequest 

type Object_VectorRequest struct {

	// The vector ID to be fetched.
	Id *Object_ID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// Filter configurations.
	Filters *Filter_Config `protobuf:"bytes,2,opt,name=filters,proto3" json:"filters,omitempty"`
	// contains filtered or unexported fields
}

Represent a request to fetch raw vector.

func (*Object_VectorRequest) CloneMessageVT added in v1.7.7 

func (m *Object_VectorRequest) CloneMessageVT() proto.Message

func (*Object_VectorRequest) CloneVT added in v1.7.7 

func (m *Object_VectorRequest) CloneVT() *Object_VectorRequest

func (*Object_VectorRequest) Descriptor deprecated 

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

Deprecated: Use Object_VectorRequest.ProtoReflect.Descriptor instead.

func (*Object_VectorRequest) EqualMessageVT added in v1.7.6 

func (this *Object_VectorRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*Object_VectorRequest) EqualVT added in v1.7.6 

func (this *Object_VectorRequest) EqualVT(that *Object_VectorRequest) bool

func (*Object_VectorRequest) GetFilters 

func (x *Object_VectorRequest) GetFilters() *Filter_Config

func (*Object_VectorRequest) GetId 

func (x *Object_VectorRequest) GetId() *Object_ID

func (*Object_VectorRequest) MarshalToSizedBufferVT added in v1.2.2 

func (m *Object_VectorRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_VectorRequest) MarshalToVT added in v1.2.2 

func (m *Object_VectorRequest) MarshalToVT(dAtA []byte) (int, error)

func (*Object_VectorRequest) MarshalVT added in v1.2.2 

func (m *Object_VectorRequest) MarshalVT() (dAtA []byte, err error)

func (*Object_VectorRequest) ProtoMessage 

func (*Object_VectorRequest) ProtoMessage()

func (*Object_VectorRequest) ProtoReflect added in v1.2.2 

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

func (*Object_VectorRequest) Reset 

func (x *Object_VectorRequest) Reset()

func (*Object_VectorRequest) SizeVT added in v1.2.2 

func (m *Object_VectorRequest) SizeVT() (n int)

func (*Object_VectorRequest) String 

func (x *Object_VectorRequest) String() string

func (*Object_VectorRequest) UnmarshalVT added in v1.2.2 

func (m *Object_VectorRequest) UnmarshalVT(dAtA []byte) error

type Object_Vectors 

type Object_Vectors struct {
	Vectors []*Object_Vector `protobuf:"bytes,1,rep,name=vectors,proto3" json:"vectors,omitempty"`
	// contains filtered or unexported fields
}

Represent multiple vectors.

func (*Object_Vectors) CloneMessageVT added in v1.7.7 

func (m *Object_Vectors) CloneMessageVT() proto.Message

func (*Object_Vectors) CloneVT added in v1.7.7 

func (m *Object_Vectors) CloneVT() *Object_Vectors

func (*Object_Vectors) Descriptor deprecated 

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

Deprecated: Use Object_Vectors.ProtoReflect.Descriptor instead.

func (*Object_Vectors) EqualMessageVT added in v1.7.6 

func (this *Object_Vectors) EqualMessageVT(thatMsg proto.Message) bool

func (*Object_Vectors) EqualVT added in v1.7.6 

func (this *Object_Vectors) EqualVT(that *Object_Vectors) bool

func (*Object_Vectors) GetVectors 

func (x *Object_Vectors) GetVectors() []*Object_Vector

func (*Object_Vectors) MarshalToSizedBufferVT added in v1.2.2 

func (m *Object_Vectors) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Object_Vectors) MarshalToVT added in v1.2.2 

func (m *Object_Vectors) MarshalToVT(dAtA []byte) (int, error)

func (*Object_Vectors) MarshalVT added in v1.2.2 

func (m *Object_Vectors) MarshalVT() (dAtA []byte, err error)

func (*Object_Vectors) ProtoMessage 

func (*Object_Vectors) ProtoMessage()

func (*Object_Vectors) ProtoReflect added in v1.2.2 

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

func (*Object_Vectors) Reset 

func (x *Object_Vectors) Reset()

func (*Object_Vectors) SizeVT added in v1.2.2 

func (m *Object_Vectors) SizeVT() (n int)

func (*Object_Vectors) String 

func (x *Object_Vectors) String() string

func (*Object_Vectors) UnmarshalVT added in v1.2.2 

func (m *Object_Vectors) UnmarshalVT(dAtA []byte) error

type Payload added in v1.2.2 

type Payload interface {
	Reset()
	String() string
	ProtoMessage()
	ProtoReflect() protoreflect.Message
	Descriptor() ([]byte, []int)
	MarshalToSizedBufferVT(dAtA []byte) (int, error)
	MarshalToVT(dAtA []byte) (int, error)
	MarshalVT() (dAtA []byte, err error)
	SizeVT() (n int)
	UnmarshalVT(dAtA []byte) error
}

type Remove 

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

Remove related messages.

func (*Remove) CloneMessageVT added in v1.7.7 

func (m *Remove) CloneMessageVT() proto.Message

func (*Remove) CloneVT added in v1.7.7 

func (m *Remove) CloneVT() *Remove

func (*Remove) Descriptor deprecated 

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

Deprecated: Use Remove.ProtoReflect.Descriptor instead.

func (*Remove) EqualMessageVT added in v1.7.6 

func (this *Remove) EqualMessageVT(thatMsg proto.Message) bool

func (*Remove) EqualVT added in v1.7.6 

func (this *Remove) EqualVT(that *Remove) bool

func (*Remove) MarshalToSizedBufferVT added in v1.2.2 

func (m *Remove) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Remove) MarshalToVT added in v1.2.2 

func (m *Remove) MarshalToVT(dAtA []byte) (int, error)

func (*Remove) MarshalVT added in v1.2.2 

func (m *Remove) MarshalVT() (dAtA []byte, err error)

func (*Remove) ProtoMessage 

func (*Remove) ProtoMessage()

func (*Remove) ProtoReflect added in v1.2.2 

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

func (*Remove) Reset 

func (x *Remove) Reset()

func (*Remove) SizeVT added in v1.2.2 

func (m *Remove) SizeVT() (n int)

func (*Remove) String 

func (x *Remove) String() string

func (*Remove) UnmarshalVT added in v1.2.2 

func (m *Remove) UnmarshalVT(dAtA []byte) error

type Remove_Config 

type Remove_Config struct {

	// A flag to skip exist check during upsert operation.
	SkipStrictExistCheck bool `` /* 126-byte string literal not displayed */
	// Remove timestamp.
	Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

Represent the remove configuration.

func (*Remove_Config) CloneMessageVT added in v1.7.7 

func (m *Remove_Config) CloneMessageVT() proto.Message

func (*Remove_Config) CloneVT added in v1.7.7 

func (m *Remove_Config) CloneVT() *Remove_Config

func (*Remove_Config) Descriptor deprecated 

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

Deprecated: Use Remove_Config.ProtoReflect.Descriptor instead.

func (*Remove_Config) EqualMessageVT added in v1.7.6 

func (this *Remove_Config) EqualMessageVT(thatMsg proto.Message) bool

func (*Remove_Config) EqualVT added in v1.7.6 

func (this *Remove_Config) EqualVT(that *Remove_Config) bool

func (*Remove_Config) GetSkipStrictExistCheck 

func (x *Remove_Config) GetSkipStrictExistCheck() bool

func (*Remove_Config) GetTimestamp added in v1.1.0 

func (x *Remove_Config) GetTimestamp() int64

func (*Remove_Config) MarshalToSizedBufferVT added in v1.2.2 

func (m *Remove_Config) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Remove_Config) MarshalToVT added in v1.2.2 

func (m *Remove_Config) MarshalToVT(dAtA []byte) (int, error)

func (*Remove_Config) MarshalVT added in v1.2.2 

func (m *Remove_Config) MarshalVT() (dAtA []byte, err error)

func (*Remove_Config) ProtoMessage 

func (*Remove_Config) ProtoMessage()

func (*Remove_Config) ProtoReflect added in v1.2.2 

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

func (*Remove_Config) Reset 

func (x *Remove_Config) Reset()

func (*Remove_Config) SizeVT added in v1.2.2 

func (m *Remove_Config) SizeVT() (n int)

func (*Remove_Config) String 

func (x *Remove_Config) String() string

func (*Remove_Config) UnmarshalVT added in v1.2.2 

func (m *Remove_Config) UnmarshalVT(dAtA []byte) error

type Remove_MultiRequest 

type Remove_MultiRequest struct {

	// Represent the multiple remove request content.
	Requests []*Remove_Request `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

Represent the multiple remove request.

func (*Remove_MultiRequest) CloneMessageVT added in v1.7.7 

func (m *Remove_MultiRequest) CloneMessageVT() proto.Message

func (*Remove_MultiRequest) CloneVT added in v1.7.7 

func (m *Remove_MultiRequest) CloneVT() *Remove_MultiRequest

func (*Remove_MultiRequest) Descriptor deprecated 

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

Deprecated: Use Remove_MultiRequest.ProtoReflect.Descriptor instead.

func (*Remove_MultiRequest) EqualMessageVT added in v1.7.6 

func (this *Remove_MultiRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*Remove_MultiRequest) EqualVT added in v1.7.6 

func (this *Remove_MultiRequest) EqualVT(that *Remove_MultiRequest) bool

func (*Remove_MultiRequest) GetRequests 

func (x *Remove_MultiRequest) GetRequests() []*Remove_Request

func (*Remove_MultiRequest) MarshalToSizedBufferVT added in v1.2.2 

func (m *Remove_MultiRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Remove_MultiRequest) MarshalToVT added in v1.2.2 

func (m *Remove_MultiRequest) MarshalToVT(dAtA []byte) (int, error)

func (*Remove_MultiRequest) MarshalVT added in v1.2.2 

func (m *Remove_MultiRequest) MarshalVT() (dAtA []byte, err error)

func (*Remove_MultiRequest) ProtoMessage 

func (*Remove_MultiRequest) ProtoMessage()

func (*Remove_MultiRequest) ProtoReflect added in v1.2.2 

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

func (*Remove_MultiRequest) Reset 

func (x *Remove_MultiRequest) Reset()

func (*Remove_MultiRequest) SizeVT added in v1.2.2 

func (m *Remove_MultiRequest) SizeVT() (n int)

func (*Remove_MultiRequest) String 

func (x *Remove_MultiRequest) String() string

func (*Remove_MultiRequest) UnmarshalVT added in v1.2.2 

func (m *Remove_MultiRequest) UnmarshalVT(dAtA []byte) error

type Remove_Request 

type Remove_Request struct {

	// The object ID to be removed.
	Id *Object_ID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The configuration of the remove request.
	Config *Remove_Config `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

Represent the remove request.

func (*Remove_Request) CloneMessageVT added in v1.7.7 

func (m *Remove_Request) CloneMessageVT() proto.Message

func (*Remove_Request) CloneVT added in v1.7.7 

func (m *Remove_Request) CloneVT() *Remove_Request

func (*Remove_Request) Descriptor deprecated 

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

Deprecated: Use Remove_Request.ProtoReflect.Descriptor instead.

func (*Remove_Request) EqualMessageVT added in v1.7.6 

func (this *Remove_Request) EqualMessageVT(thatMsg proto.Message) bool

func (*Remove_Request) EqualVT added in v1.7.6 

func (this *Remove_Request) EqualVT(that *Remove_Request) bool

func (*Remove_Request) GetConfig 

func (x *Remove_Request) GetConfig() *Remove_Config

func (*Remove_Request) GetId 

func (x *Remove_Request) GetId() *Object_ID

func (*Remove_Request) MarshalToSizedBufferVT added in v1.2.2 

func (m *Remove_Request) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Remove_Request) MarshalToVT added in v1.2.2 

func (m *Remove_Request) MarshalToVT(dAtA []byte) (int, error)

func (*Remove_Request) MarshalVT added in v1.2.2 

func (m *Remove_Request) MarshalVT() (dAtA []byte, err error)

func (*Remove_Request) ProtoMessage 

func (*Remove_Request) ProtoMessage()

func (*Remove_Request) ProtoReflect added in v1.2.2 

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

func (*Remove_Request) Reset 

func (x *Remove_Request) Reset()

func (*Remove_Request) SizeVT added in v1.2.2 

func (m *Remove_Request) SizeVT() (n int)

func (*Remove_Request) String 

func (x *Remove_Request) String() string

func (*Remove_Request) UnmarshalVT added in v1.2.2 

func (m *Remove_Request) UnmarshalVT(dAtA []byte) error

type Remove_Timestamp added in v1.7.7 

type Remove_Timestamp struct {

	// The timestamp.
	Timestamp int64 `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// The conditional operator.
	Operator Remove_Timestamp_Operator `protobuf:"varint,2,opt,name=operator,proto3,enum=payload.v1.Remove_Timestamp_Operator" json:"operator,omitempty"`
	// contains filtered or unexported fields
}

Represent the timestamp comparison.

func (*Remove_Timestamp) CloneMessageVT added in v1.7.7 

func (m *Remove_Timestamp) CloneMessageVT() proto.Message

func (*Remove_Timestamp) CloneVT added in v1.7.7 

func (m *Remove_Timestamp) CloneVT() *Remove_Timestamp

func (*Remove_Timestamp) Descriptor deprecated added in v1.7.7 

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

Deprecated: Use Remove_Timestamp.ProtoReflect.Descriptor instead.

func (*Remove_Timestamp) EqualMessageVT added in v1.7.7 

func (this *Remove_Timestamp) EqualMessageVT(thatMsg proto.Message) bool

func (*Remove_Timestamp) EqualVT added in v1.7.7 

func (this *Remove_Timestamp) EqualVT(that *Remove_Timestamp) bool

func (*Remove_Timestamp) GetOperator added in v1.7.7 

func (x *Remove_Timestamp) GetOperator() Remove_Timestamp_Operator

func (*Remove_Timestamp) GetTimestamp added in v1.7.7 

func (x *Remove_Timestamp) GetTimestamp() int64

func (*Remove_Timestamp) MarshalToSizedBufferVT added in v1.7.7 

func (m *Remove_Timestamp) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Remove_Timestamp) MarshalToVT added in v1.7.7 

func (m *Remove_Timestamp) MarshalToVT(dAtA []byte) (int, error)

func (*Remove_Timestamp) MarshalVT added in v1.7.7 

func (m *Remove_Timestamp) MarshalVT() (dAtA []byte, err error)

func (*Remove_Timestamp) ProtoMessage added in v1.7.7 

func (*Remove_Timestamp) ProtoMessage()

func (*Remove_Timestamp) ProtoReflect added in v1.7.7 

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

func (*Remove_Timestamp) Reset added in v1.7.7 

func (x *Remove_Timestamp) Reset()

func (*Remove_Timestamp) SizeVT added in v1.7.7 

func (m *Remove_Timestamp) SizeVT() (n int)

func (*Remove_Timestamp) String added in v1.7.7 

func (x *Remove_Timestamp) String() string

func (*Remove_Timestamp) UnmarshalVT added in v1.7.7 

func (m *Remove_Timestamp) UnmarshalVT(dAtA []byte) error

type Remove_TimestampRequest added in v1.7.7 

type Remove_TimestampRequest struct {

	// The timestamp comparison list. If more than one is specified, the `AND` search is applied.
	Timestamps []*Remove_Timestamp `protobuf:"bytes,1,rep,name=timestamps,proto3" json:"timestamps,omitempty"`
	// contains filtered or unexported fields
}

Represent the remove request based on timestamp.

func (*Remove_TimestampRequest) CloneMessageVT added in v1.7.7 

func (m *Remove_TimestampRequest) CloneMessageVT() proto.Message

func (*Remove_TimestampRequest) CloneVT added in v1.7.7 

func (m *Remove_TimestampRequest) CloneVT() *Remove_TimestampRequest

func (*Remove_TimestampRequest) Descriptor deprecated added in v1.7.7 

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

Deprecated: Use Remove_TimestampRequest.ProtoReflect.Descriptor instead.

func (*Remove_TimestampRequest) EqualMessageVT added in v1.7.7 

func (this *Remove_TimestampRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*Remove_TimestampRequest) EqualVT added in v1.7.7 

func (this *Remove_TimestampRequest) EqualVT(that *Remove_TimestampRequest) bool

func (*Remove_TimestampRequest) GetTimestamps added in v1.7.7 

func (x *Remove_TimestampRequest) GetTimestamps() []*Remove_Timestamp

func (*Remove_TimestampRequest) MarshalToSizedBufferVT added in v1.7.7 

func (m *Remove_TimestampRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Remove_TimestampRequest) MarshalToVT added in v1.7.7 

func (m *Remove_TimestampRequest) MarshalToVT(dAtA []byte) (int, error)

func (*Remove_TimestampRequest) MarshalVT added in v1.7.7 

func (m *Remove_TimestampRequest) MarshalVT() (dAtA []byte, err error)

func (*Remove_TimestampRequest) ProtoMessage added in v1.7.7 

func (*Remove_TimestampRequest) ProtoMessage()

func (*Remove_TimestampRequest) ProtoReflect added in v1.7.7 

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

func (*Remove_TimestampRequest) Reset added in v1.7.7 

func (x *Remove_TimestampRequest) Reset()

func (*Remove_TimestampRequest) SizeVT added in v1.7.7 

func (m *Remove_TimestampRequest) SizeVT() (n int)

func (*Remove_TimestampRequest) String added in v1.7.7 

func (x *Remove_TimestampRequest) String() string

func (*Remove_TimestampRequest) UnmarshalVT added in v1.7.7 

func (m *Remove_TimestampRequest) UnmarshalVT(dAtA []byte) error

type Remove_Timestamp_Operator added in v1.7.7 

type Remove_Timestamp_Operator int32

Operator is enum of each conditional operator. 

const (
	// The timestamp is equal to the specified value in the request.
	Remove_Timestamp_Eq Remove_Timestamp_Operator = 0
	// The timestamp is not equal to the specified value in the request.
	Remove_Timestamp_Ne Remove_Timestamp_Operator = 1
	// The timestamp is greater than or equal to the specified value in the request.
	Remove_Timestamp_Ge Remove_Timestamp_Operator = 2
	// The timestamp is greater than the specified value in the request.
	Remove_Timestamp_Gt Remove_Timestamp_Operator = 3
	// The timestamp is less than or equal to the specified value in the request.
	Remove_Timestamp_Le Remove_Timestamp_Operator = 4
	// The timestamp is less than the specified value in the request.
	Remove_Timestamp_Lt Remove_Timestamp_Operator = 5
)

func (Remove_Timestamp_Operator) Descriptor added in v1.7.7 

func (Remove_Timestamp_Operator) Descriptor() protoreflect.EnumDescriptor

func (Remove_Timestamp_Operator) Enum added in v1.7.7 

func (x Remove_Timestamp_Operator) Enum() *Remove_Timestamp_Operator

func (Remove_Timestamp_Operator) EnumDescriptor deprecated added in v1.7.7 

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

Deprecated: Use Remove_Timestamp_Operator.Descriptor instead.

func (Remove_Timestamp_Operator) Number added in v1.7.7 

func (x Remove_Timestamp_Operator) Number() protoreflect.EnumNumber

func (Remove_Timestamp_Operator) String added in v1.7.7 

func (x Remove_Timestamp_Operator) String() string

func (Remove_Timestamp_Operator) Type added in v1.7.7 

func (Remove_Timestamp_Operator) Type() protoreflect.EnumType
type Search struct {
	// contains filtered or unexported fields
}

Search related messages.

func (*Search) CloneMessageVT added in v1.7.7 

func (m *Search) CloneMessageVT() proto.Message

func (*Search) CloneVT added in v1.7.7 

func (m *Search) CloneVT() *Search

func (*Search) Descriptor deprecated 

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

Deprecated: Use Search.ProtoReflect.Descriptor instead.

func (*Search) EqualMessageVT added in v1.7.6 

func (this *Search) EqualMessageVT(thatMsg proto.Message) bool

func (*Search) EqualVT added in v1.7.6 

func (this *Search) EqualVT(that *Search) bool

func (*Search) MarshalToSizedBufferVT added in v1.2.2 

func (m *Search) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Search) MarshalToVT added in v1.2.2 

func (m *Search) MarshalToVT(dAtA []byte) (int, error)

func (*Search) MarshalVT added in v1.2.2 

func (m *Search) MarshalVT() (dAtA []byte, err error)

func (*Search) ProtoMessage 

func (*Search) ProtoMessage()

func (*Search) ProtoReflect added in v1.2.2 

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

func (*Search) Reset 

func (x *Search) Reset()

func (*Search) SizeVT added in v1.2.2 

func (m *Search) SizeVT() (n int)

func (*Search) String 

func (x *Search) String() string

func (*Search) UnmarshalVT added in v1.2.2 

func (m *Search) UnmarshalVT(dAtA []byte) error

type Search_AggregationAlgorithm added in v1.7.6 

type Search_AggregationAlgorithm int32

AggregationAlgorithm is enum of each aggregation algorithms 

const (
	Search_Unknown         Search_AggregationAlgorithm = 0
	Search_ConcurrentQueue Search_AggregationAlgorithm = 1
	Search_SortSlice       Search_AggregationAlgorithm = 2
	Search_SortPoolSlice   Search_AggregationAlgorithm = 3
	Search_PairingHeap     Search_AggregationAlgorithm = 4
)

func (Search_AggregationAlgorithm) Descriptor added in v1.7.6 

func (Search_AggregationAlgorithm) Descriptor() protoreflect.EnumDescriptor

func (Search_AggregationAlgorithm) Enum added in v1.7.6 

func (x Search_AggregationAlgorithm) Enum() *Search_AggregationAlgorithm

func (Search_AggregationAlgorithm) EnumDescriptor deprecated added in v1.7.6 

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

Deprecated: Use Search_AggregationAlgorithm.Descriptor instead.

func (Search_AggregationAlgorithm) Number added in v1.7.6 

func (x Search_AggregationAlgorithm) Number() protoreflect.EnumNumber

func (Search_AggregationAlgorithm) String added in v1.7.6 

func (x Search_AggregationAlgorithm) String() string

func (Search_AggregationAlgorithm) Type added in v1.7.6 

func (Search_AggregationAlgorithm) Type() protoreflect.EnumType

type Search_Config 

type Search_Config struct {

	// Unique request ID.
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Maximum number of result to be returned.
	Num uint32 `protobuf:"varint,2,opt,name=num,proto3" json:"num,omitempty"`
	// Search radius.
	Radius float32 `protobuf:"fixed32,3,opt,name=radius,proto3" json:"radius,omitempty"`
	// Search coefficient.
	Epsilon float32 `protobuf:"fixed32,4,opt,name=epsilon,proto3" json:"epsilon,omitempty"`
	// Search timeout in nanoseconds.
	Timeout int64 `protobuf:"varint,5,opt,name=timeout,proto3" json:"timeout,omitempty"`
	// Ingress filter configurations.
	IngressFilters *Filter_Config `protobuf:"bytes,6,opt,name=ingress_filters,json=ingressFilters,proto3" json:"ingress_filters,omitempty"`
	// Egress filter configurations.
	EgressFilters *Filter_Config `protobuf:"bytes,7,opt,name=egress_filters,json=egressFilters,proto3" json:"egress_filters,omitempty"`
	// Minimum number of result to be returned.
	MinNum uint32 `protobuf:"varint,8,opt,name=min_num,json=minNum,proto3" json:"min_num,omitempty"`
	// Aggregation Algorithm
	AggregationAlgorithm Search_AggregationAlgorithm `` /* 166-byte string literal not displayed */
	// contains filtered or unexported fields
}

Represent search configuration.

func (*Search_Config) CloneMessageVT added in v1.7.7 

func (m *Search_Config) CloneMessageVT() proto.Message

func (*Search_Config) CloneVT added in v1.7.7 

func (m *Search_Config) CloneVT() *Search_Config

func (*Search_Config) Descriptor deprecated 

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

Deprecated: Use Search_Config.ProtoReflect.Descriptor instead.

func (*Search_Config) EqualMessageVT added in v1.7.6 

func (this *Search_Config) EqualMessageVT(thatMsg proto.Message) bool

func (*Search_Config) EqualVT added in v1.7.6 

func (this *Search_Config) EqualVT(that *Search_Config) bool

func (*Search_Config) GetAggregationAlgorithm added in v1.7.6 

func (x *Search_Config) GetAggregationAlgorithm() Search_AggregationAlgorithm

func (*Search_Config) GetEgressFilters 

func (x *Search_Config) GetEgressFilters() *Filter_Config

func (*Search_Config) GetEpsilon 

func (x *Search_Config) GetEpsilon() float32

func (*Search_Config) GetIngressFilters 

func (x *Search_Config) GetIngressFilters() *Filter_Config

func (*Search_Config) GetMinNum added in v1.4.0 

func (x *Search_Config) GetMinNum() uint32

func (*Search_Config) GetNum 

func (x *Search_Config) GetNum() uint32

func (*Search_Config) GetRadius 

func (x *Search_Config) GetRadius() float32

func (*Search_Config) GetRequestId 

func (x *Search_Config) GetRequestId() string

func (*Search_Config) GetTimeout 

func (x *Search_Config) GetTimeout() int64

func (*Search_Config) MarshalToSizedBufferVT added in v1.2.2 

func (m *Search_Config) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Search_Config) MarshalToVT added in v1.2.2 

func (m *Search_Config) MarshalToVT(dAtA []byte) (int, error)

func (*Search_Config) MarshalVT added in v1.2.2 

func (m *Search_Config) MarshalVT() (dAtA []byte, err error)

func (*Search_Config) ProtoMessage 

func (*Search_Config) ProtoMessage()

func (*Search_Config) ProtoReflect added in v1.2.2 

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

func (*Search_Config) Reset 

func (x *Search_Config) Reset()

func (*Search_Config) SizeVT added in v1.2.2 

func (m *Search_Config) SizeVT() (n int)

func (*Search_Config) String 

func (x *Search_Config) String() string

func (*Search_Config) UnmarshalVT added in v1.2.2 

func (m *Search_Config) UnmarshalVT(dAtA []byte) error

type Search_IDRequest 

type Search_IDRequest struct {

	// The vector ID to be searched.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// The configuration of the search request.
	Config *Search_Config `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

Represent a search by ID request.

func (*Search_IDRequest) CloneMessageVT added in v1.7.7 

func (m *Search_IDRequest) CloneMessageVT() proto.Message

func (*Search_IDRequest) CloneVT added in v1.7.7 

func (m *Search_IDRequest) CloneVT() *Search_IDRequest

func (*Search_IDRequest) Descriptor deprecated 

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

Deprecated: Use Search_IDRequest.ProtoReflect.Descriptor instead.

func (*Search_IDRequest) EqualMessageVT added in v1.7.6 

func (this *Search_IDRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*Search_IDRequest) EqualVT added in v1.7.6 

func (this *Search_IDRequest) EqualVT(that *Search_IDRequest) bool

func (*Search_IDRequest) GetConfig 

func (x *Search_IDRequest) GetConfig() *Search_Config

func (*Search_IDRequest) GetId 

func (x *Search_IDRequest) GetId() string

func (*Search_IDRequest) MarshalToSizedBufferVT added in v1.2.2 

func (m *Search_IDRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Search_IDRequest) MarshalToVT added in v1.2.2 

func (m *Search_IDRequest) MarshalToVT(dAtA []byte) (int, error)

func (*Search_IDRequest) MarshalVT added in v1.2.2 

func (m *Search_IDRequest) MarshalVT() (dAtA []byte, err error)

func (*Search_IDRequest) ProtoMessage 

func (*Search_IDRequest) ProtoMessage()

func (*Search_IDRequest) ProtoReflect added in v1.2.2 

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

func (*Search_IDRequest) Reset 

func (x *Search_IDRequest) Reset()

func (*Search_IDRequest) SizeVT added in v1.2.2 

func (m *Search_IDRequest) SizeVT() (n int)

func (*Search_IDRequest) String 

func (x *Search_IDRequest) String() string

func (*Search_IDRequest) UnmarshalVT added in v1.2.2 

func (m *Search_IDRequest) UnmarshalVT(dAtA []byte) error

type Search_MultiIDRequest 

type Search_MultiIDRequest struct {

	// Represent the multiple search by ID request content.
	Requests []*Search_IDRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

Represent the multiple search by ID request.

func (*Search_MultiIDRequest) CloneMessageVT added in v1.7.7 

func (m *Search_MultiIDRequest) CloneMessageVT() proto.Message

func (*Search_MultiIDRequest) CloneVT added in v1.7.7 

func (m *Search_MultiIDRequest) CloneVT() *Search_MultiIDRequest

func (*Search_MultiIDRequest) Descriptor deprecated 

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

Deprecated: Use Search_MultiIDRequest.ProtoReflect.Descriptor instead.

func (*Search_MultiIDRequest) EqualMessageVT added in v1.7.6 

func (this *Search_MultiIDRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*Search_MultiIDRequest) EqualVT added in v1.7.6 

func (this *Search_MultiIDRequest) EqualVT(that *Search_MultiIDRequest) bool

func (*Search_MultiIDRequest) GetRequests 

func (x *Search_MultiIDRequest) GetRequests() []*Search_IDRequest

func (*Search_MultiIDRequest) MarshalToSizedBufferVT added in v1.2.2 

func (m *Search_MultiIDRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Search_MultiIDRequest) MarshalToVT added in v1.2.2 

func (m *Search_MultiIDRequest) MarshalToVT(dAtA []byte) (int, error)

func (*Search_MultiIDRequest) MarshalVT added in v1.2.2 

func (m *Search_MultiIDRequest) MarshalVT() (dAtA []byte, err error)

func (*Search_MultiIDRequest) ProtoMessage 

func (*Search_MultiIDRequest) ProtoMessage()

func (*Search_MultiIDRequest) ProtoReflect added in v1.2.2 

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

func (*Search_MultiIDRequest) Reset 

func (x *Search_MultiIDRequest) Reset()

func (*Search_MultiIDRequest) SizeVT added in v1.2.2 

func (m *Search_MultiIDRequest) SizeVT() (n int)

func (*Search_MultiIDRequest) String 

func (x *Search_MultiIDRequest) String() string

func (*Search_MultiIDRequest) UnmarshalVT added in v1.2.2 

func (m *Search_MultiIDRequest) UnmarshalVT(dAtA []byte) error

type Search_MultiObjectRequest 

type Search_MultiObjectRequest struct {

	// Represent the multiple search by binary object request content.
	Requests []*Search_ObjectRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

Represent the multiple search by binary object request.

func (*Search_MultiObjectRequest) CloneMessageVT added in v1.7.7 

func (m *Search_MultiObjectRequest) CloneMessageVT() proto.Message

func (*Search_MultiObjectRequest) CloneVT added in v1.7.7 

func (m *Search_MultiObjectRequest) CloneVT() *Search_MultiObjectRequest

func (*Search_MultiObjectRequest) Descriptor deprecated 

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

Deprecated: Use Search_MultiObjectRequest.ProtoReflect.Descriptor instead.

func (*Search_MultiObjectRequest) EqualMessageVT added in v1.7.6 

func (this *Search_MultiObjectRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*Search_MultiObjectRequest) EqualVT added in v1.7.6 

func (this *Search_MultiObjectRequest) EqualVT(that *Search_MultiObjectRequest) bool

func (*Search_MultiObjectRequest) GetRequests 

func (x *Search_MultiObjectRequest) GetRequests() []*Search_ObjectRequest

func (*Search_MultiObjectRequest) MarshalToSizedBufferVT added in v1.2.2 

func (m *Search_MultiObjectRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Search_MultiObjectRequest) MarshalToVT added in v1.2.2 

func (m *Search_MultiObjectRequest) MarshalToVT(dAtA []byte) (int, error)

func (*Search_MultiObjectRequest) MarshalVT added in v1.2.2 

func (m *Search_MultiObjectRequest) MarshalVT() (dAtA []byte, err error)

func (*Search_MultiObjectRequest) ProtoMessage 

func (*Search_MultiObjectRequest) ProtoMessage()

func (*Search_MultiObjectRequest) ProtoReflect added in v1.2.2 

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

func (*Search_MultiObjectRequest) Reset 

func (x *Search_MultiObjectRequest) Reset()

func (*Search_MultiObjectRequest) SizeVT added in v1.2.2 

func (m *Search_MultiObjectRequest) SizeVT() (n int)

func (*Search_MultiObjectRequest) String 

func (x *Search_MultiObjectRequest) String() string

func (*Search_MultiObjectRequest) UnmarshalVT added in v1.2.2 

func (m *Search_MultiObjectRequest) UnmarshalVT(dAtA []byte) error

type Search_MultiRequest 

type Search_MultiRequest struct {

	// Represent the multiple search request content.
	Requests []*Search_Request `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

Represent the multiple search request.

func (*Search_MultiRequest) CloneMessageVT added in v1.7.7 

func (m *Search_MultiRequest) CloneMessageVT() proto.Message

func (*Search_MultiRequest) CloneVT added in v1.7.7 

func (m *Search_MultiRequest) CloneVT() *Search_MultiRequest

func (*Search_MultiRequest) Descriptor deprecated 

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

Deprecated: Use Search_MultiRequest.ProtoReflect.Descriptor instead.

func (*Search_MultiRequest) EqualMessageVT added in v1.7.6 

func (this *Search_MultiRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*Search_MultiRequest) EqualVT added in v1.7.6 

func (this *Search_MultiRequest) EqualVT(that *Search_MultiRequest) bool

func (*Search_MultiRequest) GetRequests 

func (x *Search_MultiRequest) GetRequests() []*Search_Request

func (*Search_MultiRequest) MarshalToSizedBufferVT added in v1.2.2 

func (m *Search_MultiRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Search_MultiRequest) MarshalToVT added in v1.2.2 

func (m *Search_MultiRequest) MarshalToVT(dAtA []byte) (int, error)

func (*Search_MultiRequest) MarshalVT added in v1.2.2 

func (m *Search_MultiRequest) MarshalVT() (dAtA []byte, err error)

func (*Search_MultiRequest) ProtoMessage 

func (*Search_MultiRequest) ProtoMessage()

func (*Search_MultiRequest) ProtoReflect added in v1.2.2 

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

func (*Search_MultiRequest) Reset 

func (x *Search_MultiRequest) Reset()

func (*Search_MultiRequest) SizeVT added in v1.2.2 

func (m *Search_MultiRequest) SizeVT() (n int)

func (*Search_MultiRequest) String 

func (x *Search_MultiRequest) String() string

func (*Search_MultiRequest) UnmarshalVT added in v1.2.2 

func (m *Search_MultiRequest) UnmarshalVT(dAtA []byte) error

type Search_ObjectRequest 

type Search_ObjectRequest struct {

	// The binary object to be searched.
	Object []byte `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	// The configuration of the search request.
	Config *Search_Config `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// Filter configuration.
	Vectorizer *Filter_Target `protobuf:"bytes,3,opt,name=vectorizer,proto3" json:"vectorizer,omitempty"`
	// contains filtered or unexported fields
}

Represent a search by binary object request.

func (*Search_ObjectRequest) CloneMessageVT added in v1.7.7 

func (m *Search_ObjectRequest) CloneMessageVT() proto.Message

func (*Search_ObjectRequest) CloneVT added in v1.7.7 

func (m *Search_ObjectRequest) CloneVT() *Search_ObjectRequest

func (*Search_ObjectRequest) Descriptor deprecated 

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

Deprecated: Use Search_ObjectRequest.ProtoReflect.Descriptor instead.

func (*Search_ObjectRequest) EqualMessageVT added in v1.7.6 

func (this *Search_ObjectRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*Search_ObjectRequest) EqualVT added in v1.7.6 

func (this *Search_ObjectRequest) EqualVT(that *Search_ObjectRequest) bool

func (*Search_ObjectRequest) GetConfig 

func (x *Search_ObjectRequest) GetConfig() *Search_Config

func (*Search_ObjectRequest) GetObject 

func (x *Search_ObjectRequest) GetObject() []byte

func (*Search_ObjectRequest) GetVectorizer 

func (x *Search_ObjectRequest) GetVectorizer() *Filter_Target

func (*Search_ObjectRequest) MarshalToSizedBufferVT added in v1.2.2 

func (m *Search_ObjectRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Search_ObjectRequest) MarshalToVT added in v1.2.2 

func (m *Search_ObjectRequest) MarshalToVT(dAtA []byte) (int, error)

func (*Search_ObjectRequest) MarshalVT added in v1.2.2 

func (m *Search_ObjectRequest) MarshalVT() (dAtA []byte, err error)

func (*Search_ObjectRequest) ProtoMessage 

func (*Search_ObjectRequest) ProtoMessage()

func (*Search_ObjectRequest) ProtoReflect added in v1.2.2 

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

func (*Search_ObjectRequest) Reset 

func (x *Search_ObjectRequest) Reset()

func (*Search_ObjectRequest) SizeVT added in v1.2.2 

func (m *Search_ObjectRequest) SizeVT() (n int)

func (*Search_ObjectRequest) String 

func (x *Search_ObjectRequest) String() string

func (*Search_ObjectRequest) UnmarshalVT added in v1.2.2 

func (m *Search_ObjectRequest) UnmarshalVT(dAtA []byte) error

type Search_Request 

type Search_Request struct {

	// The vector to be searched.
	Vector []float32 `protobuf:"fixed32,1,rep,packed,name=vector,proto3" json:"vector,omitempty"`
	// The configuration of the search request.
	Config *Search_Config `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

Represent a search request.

func (*Search_Request) CloneMessageVT added in v1.7.7 

func (m *Search_Request) CloneMessageVT() proto.Message

func (*Search_Request) CloneVT added in v1.7.7 

func (m *Search_Request) CloneVT() *Search_Request

func (*Search_Request) Descriptor deprecated 

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

Deprecated: Use Search_Request.ProtoReflect.Descriptor instead.

func (*Search_Request) EqualMessageVT added in v1.7.6 

func (this *Search_Request) EqualMessageVT(thatMsg proto.Message) bool

func (*Search_Request) EqualVT added in v1.7.6 

func (this *Search_Request) EqualVT(that *Search_Request) bool

func (*Search_Request) GetConfig 

func (x *Search_Request) GetConfig() *Search_Config

func (*Search_Request) GetVector 

func (x *Search_Request) GetVector() []float32

func (*Search_Request) MarshalToSizedBufferVT added in v1.2.2 

func (m *Search_Request) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Search_Request) MarshalToVT added in v1.2.2 

func (m *Search_Request) MarshalToVT(dAtA []byte) (int, error)

func (*Search_Request) MarshalVT added in v1.2.2 

func (m *Search_Request) MarshalVT() (dAtA []byte, err error)

func (*Search_Request) ProtoMessage 

func (*Search_Request) ProtoMessage()

func (*Search_Request) ProtoReflect added in v1.2.2 

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

func (*Search_Request) Reset 

func (x *Search_Request) Reset()

func (*Search_Request) SizeVT added in v1.2.2 

func (m *Search_Request) SizeVT() (n int)

func (*Search_Request) String 

func (x *Search_Request) String() string

func (*Search_Request) UnmarshalVT added in v1.2.2 

func (m *Search_Request) UnmarshalVT(dAtA []byte) error

type Search_Response 

type Search_Response struct {

	// The unique request ID.
	RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Search results.
	Results []*Object_Distance `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"`
	// contains filtered or unexported fields
}

Represent a search response.

func (*Search_Response) CloneMessageVT added in v1.7.7 

func (m *Search_Response) CloneMessageVT() proto.Message

func (*Search_Response) CloneVT added in v1.7.7 

func (m *Search_Response) CloneVT() *Search_Response

func (*Search_Response) Descriptor deprecated 

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

Deprecated: Use Search_Response.ProtoReflect.Descriptor instead.

func (*Search_Response) EqualMessageVT added in v1.7.6 

func (this *Search_Response) EqualMessageVT(thatMsg proto.Message) bool

func (*Search_Response) EqualVT added in v1.7.6 

func (this *Search_Response) EqualVT(that *Search_Response) bool

func (*Search_Response) GetRequestId 

func (x *Search_Response) GetRequestId() string

func (*Search_Response) GetResults 

func (x *Search_Response) GetResults() []*Object_Distance

func (*Search_Response) MarshalToSizedBufferVT added in v1.2.2 

func (m *Search_Response) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Search_Response) MarshalToVT added in v1.2.2 

func (m *Search_Response) MarshalToVT(dAtA []byte) (int, error)

func (*Search_Response) MarshalVT added in v1.2.2 

func (m *Search_Response) MarshalVT() (dAtA []byte, err error)

func (*Search_Response) ProtoMessage 

func (*Search_Response) ProtoMessage()

func (*Search_Response) ProtoReflect added in v1.2.2 

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

func (*Search_Response) Reset 

func (x *Search_Response) Reset()

func (*Search_Response) SizeVT added in v1.2.2 

func (m *Search_Response) SizeVT() (n int)

func (*Search_Response) String 

func (x *Search_Response) String() string

func (*Search_Response) UnmarshalVT added in v1.2.2 

func (m *Search_Response) UnmarshalVT(dAtA []byte) error

type Search_Responses 

type Search_Responses struct {

	// Represent the multiple search response content.
	Responses []*Search_Response `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

Represent multiple search responses.

func (*Search_Responses) CloneMessageVT added in v1.7.7 

func (m *Search_Responses) CloneMessageVT() proto.Message

func (*Search_Responses) CloneVT added in v1.7.7 

func (m *Search_Responses) CloneVT() *Search_Responses

func (*Search_Responses) Descriptor deprecated 

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

Deprecated: Use Search_Responses.ProtoReflect.Descriptor instead.

func (*Search_Responses) EqualMessageVT added in v1.7.6 

func (this *Search_Responses) EqualMessageVT(thatMsg proto.Message) bool

func (*Search_Responses) EqualVT added in v1.7.6 

func (this *Search_Responses) EqualVT(that *Search_Responses) bool

func (*Search_Responses) GetResponses 

func (x *Search_Responses) GetResponses() []*Search_Response

func (*Search_Responses) MarshalToSizedBufferVT added in v1.2.2 

func (m *Search_Responses) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Search_Responses) MarshalToVT added in v1.2.2 

func (m *Search_Responses) MarshalToVT(dAtA []byte) (int, error)

func (*Search_Responses) MarshalVT added in v1.2.2 

func (m *Search_Responses) MarshalVT() (dAtA []byte, err error)

func (*Search_Responses) ProtoMessage 

func (*Search_Responses) ProtoMessage()

func (*Search_Responses) ProtoReflect added in v1.2.2 

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

func (*Search_Responses) Reset 

func (x *Search_Responses) Reset()

func (*Search_Responses) SizeVT added in v1.2.2 

func (m *Search_Responses) SizeVT() (n int)

func (*Search_Responses) String 

func (x *Search_Responses) String() string

func (*Search_Responses) UnmarshalVT added in v1.2.2 

func (m *Search_Responses) UnmarshalVT(dAtA []byte) error

type Search_StreamResponse 

type Search_StreamResponse struct {

	// Types that are assignable to Payload:
	//
	//	*Search_StreamResponse_Response
	//	*Search_StreamResponse_Status
	Payload isSearch_StreamResponse_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

Represent stream search response.

func (*Search_StreamResponse) CloneMessageVT added in v1.7.7 

func (m *Search_StreamResponse) CloneMessageVT() proto.Message

func (*Search_StreamResponse) CloneVT added in v1.7.7 

func (m *Search_StreamResponse) CloneVT() *Search_StreamResponse

func (*Search_StreamResponse) Descriptor deprecated 

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

Deprecated: Use Search_StreamResponse.ProtoReflect.Descriptor instead.

func (*Search_StreamResponse) EqualMessageVT added in v1.7.6 

func (this *Search_StreamResponse) EqualMessageVT(thatMsg proto.Message) bool

func (*Search_StreamResponse) EqualVT added in v1.7.6 

func (this *Search_StreamResponse) EqualVT(that *Search_StreamResponse) bool

func (*Search_StreamResponse) GetPayload 

func (m *Search_StreamResponse) GetPayload() isSearch_StreamResponse_Payload

func (*Search_StreamResponse) GetResponse 

func (x *Search_StreamResponse) GetResponse() *Search_Response

func (*Search_StreamResponse) GetStatus 

func (x *Search_StreamResponse) GetStatus() *status.Status

func (*Search_StreamResponse) MarshalToSizedBufferVT added in v1.2.2 

func (m *Search_StreamResponse) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Search_StreamResponse) MarshalToVT added in v1.2.2 

func (m *Search_StreamResponse) MarshalToVT(dAtA []byte) (int, error)

func (*Search_StreamResponse) MarshalVT added in v1.2.2 

func (m *Search_StreamResponse) MarshalVT() (dAtA []byte, err error)

func (*Search_StreamResponse) ProtoMessage 

func (*Search_StreamResponse) ProtoMessage()

func (*Search_StreamResponse) ProtoReflect added in v1.2.2 

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

func (*Search_StreamResponse) Reset 

func (x *Search_StreamResponse) Reset()

func (*Search_StreamResponse) SizeVT added in v1.2.2 

func (m *Search_StreamResponse) SizeVT() (n int)

func (*Search_StreamResponse) String 

func (x *Search_StreamResponse) String() string

func (*Search_StreamResponse) UnmarshalVT added in v1.2.2 

func (m *Search_StreamResponse) UnmarshalVT(dAtA []byte) error

type Search_StreamResponse_Response 

type Search_StreamResponse_Response struct {
	// Represent the search response.
	Response *Search_Response `protobuf:"bytes,1,opt,name=response,proto3,oneof"`
}

func (*Search_StreamResponse_Response) CloneVT added in v1.7.7 

func (m *Search_StreamResponse_Response) CloneVT() isSearch_StreamResponse_Payload

func (*Search_StreamResponse_Response) EqualVT added in v1.7.6 

func (this *Search_StreamResponse_Response) EqualVT(thatIface isSearch_StreamResponse_Payload) bool

func (*Search_StreamResponse_Response) MarshalToSizedBufferVT added in v1.2.2 

func (m *Search_StreamResponse_Response) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Search_StreamResponse_Response) MarshalToVT added in v1.2.2 

func (m *Search_StreamResponse_Response) MarshalToVT(dAtA []byte) (int, error)

func (*Search_StreamResponse_Response) SizeVT added in v1.2.2 

func (m *Search_StreamResponse_Response) SizeVT() (n int)

type Search_StreamResponse_Status 

type Search_StreamResponse_Status struct {
	// The RPC error status.
	Status *status.Status `protobuf:"bytes,2,opt,name=status,proto3,oneof"`
}

func (*Search_StreamResponse_Status) CloneVT added in v1.7.7 

func (m *Search_StreamResponse_Status) CloneVT() isSearch_StreamResponse_Payload

func (*Search_StreamResponse_Status) EqualVT added in v1.7.6 

func (this *Search_StreamResponse_Status) EqualVT(thatIface isSearch_StreamResponse_Payload) bool

func (*Search_StreamResponse_Status) MarshalToSizedBufferVT added in v1.2.2 

func (m *Search_StreamResponse_Status) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Search_StreamResponse_Status) MarshalToVT added in v1.2.2 

func (m *Search_StreamResponse_Status) MarshalToVT(dAtA []byte) (int, error)

func (*Search_StreamResponse_Status) SizeVT added in v1.2.2 

func (m *Search_StreamResponse_Status) SizeVT() (n int)

type Update 

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

Update related messages

func (*Update) CloneMessageVT added in v1.7.7 

func (m *Update) CloneMessageVT() proto.Message

func (*Update) CloneVT added in v1.7.7 

func (m *Update) CloneVT() *Update

func (*Update) Descriptor deprecated 

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

Deprecated: Use Update.ProtoReflect.Descriptor instead.

func (*Update) EqualMessageVT added in v1.7.6 

func (this *Update) EqualMessageVT(thatMsg proto.Message) bool

func (*Update) EqualVT added in v1.7.6 

func (this *Update) EqualVT(that *Update) bool

func (*Update) MarshalToSizedBufferVT added in v1.2.2 

func (m *Update) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Update) MarshalToVT added in v1.2.2 

func (m *Update) MarshalToVT(dAtA []byte) (int, error)

func (*Update) MarshalVT added in v1.2.2 

func (m *Update) MarshalVT() (dAtA []byte, err error)

func (*Update) ProtoMessage 

func (*Update) ProtoMessage()

func (*Update) ProtoReflect added in v1.2.2 

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

func (*Update) Reset 

func (x *Update) Reset()

func (*Update) SizeVT added in v1.2.2 

func (m *Update) SizeVT() (n int)

func (*Update) String 

func (x *Update) String() string

func (*Update) UnmarshalVT added in v1.2.2 

func (m *Update) UnmarshalVT(dAtA []byte) error

type Update_Config 

type Update_Config struct {

	// A flag to skip exist check during update operation.
	SkipStrictExistCheck bool `` /* 126-byte string literal not displayed */
	// Filter configuration.
	Filters *Filter_Config `protobuf:"bytes,2,opt,name=filters,proto3" json:"filters,omitempty"`
	// Update timestamp.
	Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// A flag to disable balanced update (split remove -> insert operation)
	// during update operation.
	DisableBalancedUpdate bool `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

Represent the update configuration.

func (*Update_Config) CloneMessageVT added in v1.7.7 

func (m *Update_Config) CloneMessageVT() proto.Message

func (*Update_Config) CloneVT added in v1.7.7 

func (m *Update_Config) CloneVT() *Update_Config

func (*Update_Config) Descriptor deprecated 

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

Deprecated: Use Update_Config.ProtoReflect.Descriptor instead.

func (*Update_Config) EqualMessageVT added in v1.7.6 

func (this *Update_Config) EqualMessageVT(thatMsg proto.Message) bool

func (*Update_Config) EqualVT added in v1.7.6 

func (this *Update_Config) EqualVT(that *Update_Config) bool

func (*Update_Config) GetDisableBalancedUpdate added in v1.7.3 

func (x *Update_Config) GetDisableBalancedUpdate() bool

func (*Update_Config) GetFilters 

func (x *Update_Config) GetFilters() *Filter_Config

func (*Update_Config) GetSkipStrictExistCheck 

func (x *Update_Config) GetSkipStrictExistCheck() bool

func (*Update_Config) GetTimestamp added in v1.1.0 

func (x *Update_Config) GetTimestamp() int64

func (*Update_Config) MarshalToSizedBufferVT added in v1.2.2 

func (m *Update_Config) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Update_Config) MarshalToVT added in v1.2.2 

func (m *Update_Config) MarshalToVT(dAtA []byte) (int, error)

func (*Update_Config) MarshalVT added in v1.2.2 

func (m *Update_Config) MarshalVT() (dAtA []byte, err error)

func (*Update_Config) ProtoMessage 

func (*Update_Config) ProtoMessage()

func (*Update_Config) ProtoReflect added in v1.2.2 

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

func (*Update_Config) Reset 

func (x *Update_Config) Reset()

func (*Update_Config) SizeVT added in v1.2.2 

func (m *Update_Config) SizeVT() (n int)

func (*Update_Config) String 

func (x *Update_Config) String() string

func (*Update_Config) UnmarshalVT added in v1.2.2 

func (m *Update_Config) UnmarshalVT(dAtA []byte) error

type Update_MultiObjectRequest 

type Update_MultiObjectRequest struct {

	// Represent the multiple update object request content.
	Requests []*Update_ObjectRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

Represent the multiple update binary object request.

func (*Update_MultiObjectRequest) CloneMessageVT added in v1.7.7 

func (m *Update_MultiObjectRequest) CloneMessageVT() proto.Message

func (*Update_MultiObjectRequest) CloneVT added in v1.7.7 

func (m *Update_MultiObjectRequest) CloneVT() *Update_MultiObjectRequest

func (*Update_MultiObjectRequest) Descriptor deprecated 

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

Deprecated: Use Update_MultiObjectRequest.ProtoReflect.Descriptor instead.

func (*Update_MultiObjectRequest) EqualMessageVT added in v1.7.6 

func (this *Update_MultiObjectRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*Update_MultiObjectRequest) EqualVT added in v1.7.6 

func (this *Update_MultiObjectRequest) EqualVT(that *Update_MultiObjectRequest) bool

func (*Update_MultiObjectRequest) GetRequests 

func (x *Update_MultiObjectRequest) GetRequests() []*Update_ObjectRequest

func (*Update_MultiObjectRequest) MarshalToSizedBufferVT added in v1.2.2 

func (m *Update_MultiObjectRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Update_MultiObjectRequest) MarshalToVT added in v1.2.2 

func (m *Update_MultiObjectRequest) MarshalToVT(dAtA []byte) (int, error)

func (*Update_MultiObjectRequest) MarshalVT added in v1.2.2 

func (m *Update_MultiObjectRequest) MarshalVT() (dAtA []byte, err error)

func (*Update_MultiObjectRequest) ProtoMessage 

func (*Update_MultiObjectRequest) ProtoMessage()

func (*Update_MultiObjectRequest) ProtoReflect added in v1.2.2 

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

func (*Update_MultiObjectRequest) Reset 

func (x *Update_MultiObjectRequest) Reset()

func (*Update_MultiObjectRequest) SizeVT added in v1.2.2 

func (m *Update_MultiObjectRequest) SizeVT() (n int)

func (*Update_MultiObjectRequest) String 

func (x *Update_MultiObjectRequest) String() string

func (*Update_MultiObjectRequest) UnmarshalVT added in v1.2.2 

func (m *Update_MultiObjectRequest) UnmarshalVT(dAtA []byte) error

type Update_MultiRequest 

type Update_MultiRequest struct {

	// Represent the multiple update request content.
	Requests []*Update_Request `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

Represent the multiple update request.

func (*Update_MultiRequest) CloneMessageVT added in v1.7.7 

func (m *Update_MultiRequest) CloneMessageVT() proto.Message

func (*Update_MultiRequest) CloneVT added in v1.7.7 

func (m *Update_MultiRequest) CloneVT() *Update_MultiRequest

func (*Update_MultiRequest) Descriptor deprecated 

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

Deprecated: Use Update_MultiRequest.ProtoReflect.Descriptor instead.

func (*Update_MultiRequest) EqualMessageVT added in v1.7.6 

func (this *Update_MultiRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*Update_MultiRequest) EqualVT added in v1.7.6 

func (this *Update_MultiRequest) EqualVT(that *Update_MultiRequest) bool

func (*Update_MultiRequest) GetRequests 

func (x *Update_MultiRequest) GetRequests() []*Update_Request

func (*Update_MultiRequest) MarshalToSizedBufferVT added in v1.2.2 

func (m *Update_MultiRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Update_MultiRequest) MarshalToVT added in v1.2.2 

func (m *Update_MultiRequest) MarshalToVT(dAtA []byte) (int, error)

func (*Update_MultiRequest) MarshalVT added in v1.2.2 

func (m *Update_MultiRequest) MarshalVT() (dAtA []byte, err error)

func (*Update_MultiRequest) ProtoMessage 

func (*Update_MultiRequest) ProtoMessage()

func (*Update_MultiRequest) ProtoReflect added in v1.2.2 

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

func (*Update_MultiRequest) Reset 

func (x *Update_MultiRequest) Reset()

func (*Update_MultiRequest) SizeVT added in v1.2.2 

func (m *Update_MultiRequest) SizeVT() (n int)

func (*Update_MultiRequest) String 

func (x *Update_MultiRequest) String() string

func (*Update_MultiRequest) UnmarshalVT added in v1.2.2 

func (m *Update_MultiRequest) UnmarshalVT(dAtA []byte) error

type Update_ObjectRequest 

type Update_ObjectRequest struct {

	// The binary object to be updated.
	Object *Object_Blob `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	// The configuration of the update request.
	Config *Update_Config `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// Filter target.
	Vectorizer *Filter_Target `protobuf:"bytes,3,opt,name=vectorizer,proto3" json:"vectorizer,omitempty"`
	// contains filtered or unexported fields
}

Represent the update binary object request.

func (*Update_ObjectRequest) CloneMessageVT added in v1.7.7 

func (m *Update_ObjectRequest) CloneMessageVT() proto.Message

func (*Update_ObjectRequest) CloneVT added in v1.7.7 

func (m *Update_ObjectRequest) CloneVT() *Update_ObjectRequest

func (*Update_ObjectRequest) Descriptor deprecated 

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

Deprecated: Use Update_ObjectRequest.ProtoReflect.Descriptor instead.

func (*Update_ObjectRequest) EqualMessageVT added in v1.7.6 

func (this *Update_ObjectRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*Update_ObjectRequest) EqualVT added in v1.7.6 

func (this *Update_ObjectRequest) EqualVT(that *Update_ObjectRequest) bool

func (*Update_ObjectRequest) GetConfig 

func (x *Update_ObjectRequest) GetConfig() *Update_Config

func (*Update_ObjectRequest) GetObject 

func (x *Update_ObjectRequest) GetObject() *Object_Blob

func (*Update_ObjectRequest) GetVectorizer 

func (x *Update_ObjectRequest) GetVectorizer() *Filter_Target

func (*Update_ObjectRequest) MarshalToSizedBufferVT added in v1.2.2 

func (m *Update_ObjectRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Update_ObjectRequest) MarshalToVT added in v1.2.2 

func (m *Update_ObjectRequest) MarshalToVT(dAtA []byte) (int, error)

func (*Update_ObjectRequest) MarshalVT added in v1.2.2 

func (m *Update_ObjectRequest) MarshalVT() (dAtA []byte, err error)

func (*Update_ObjectRequest) ProtoMessage 

func (*Update_ObjectRequest) ProtoMessage()

func (*Update_ObjectRequest) ProtoReflect added in v1.2.2 

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

func (*Update_ObjectRequest) Reset 

func (x *Update_ObjectRequest) Reset()

func (*Update_ObjectRequest) SizeVT added in v1.2.2 

func (m *Update_ObjectRequest) SizeVT() (n int)

func (*Update_ObjectRequest) String 

func (x *Update_ObjectRequest) String() string

func (*Update_ObjectRequest) UnmarshalVT added in v1.2.2 

func (m *Update_ObjectRequest) UnmarshalVT(dAtA []byte) error

type Update_Request 

type Update_Request struct {

	// The vector to be updated.
	Vector *Object_Vector `protobuf:"bytes,1,opt,name=vector,proto3" json:"vector,omitempty"`
	// The configuration of the update request.
	Config *Update_Config `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

Represent the update request.

func (*Update_Request) CloneMessageVT added in v1.7.7 

func (m *Update_Request) CloneMessageVT() proto.Message

func (*Update_Request) CloneVT added in v1.7.7 

func (m *Update_Request) CloneVT() *Update_Request

func (*Update_Request) Descriptor deprecated 

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

Deprecated: Use Update_Request.ProtoReflect.Descriptor instead.

func (*Update_Request) EqualMessageVT added in v1.7.6 

func (this *Update_Request) EqualMessageVT(thatMsg proto.Message) bool

func (*Update_Request) EqualVT added in v1.7.6 

func (this *Update_Request) EqualVT(that *Update_Request) bool

func (*Update_Request) GetConfig 

func (x *Update_Request) GetConfig() *Update_Config

func (*Update_Request) GetVector 

func (x *Update_Request) GetVector() *Object_Vector

func (*Update_Request) MarshalToSizedBufferVT added in v1.2.2 

func (m *Update_Request) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Update_Request) MarshalToVT added in v1.2.2 

func (m *Update_Request) MarshalToVT(dAtA []byte) (int, error)

func (*Update_Request) MarshalVT added in v1.2.2 

func (m *Update_Request) MarshalVT() (dAtA []byte, err error)

func (*Update_Request) ProtoMessage 

func (*Update_Request) ProtoMessage()

func (*Update_Request) ProtoReflect added in v1.2.2 

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

func (*Update_Request) Reset 

func (x *Update_Request) Reset()

func (*Update_Request) SizeVT added in v1.2.2 

func (m *Update_Request) SizeVT() (n int)

func (*Update_Request) String 

func (x *Update_Request) String() string

func (*Update_Request) UnmarshalVT added in v1.2.2 

func (m *Update_Request) UnmarshalVT(dAtA []byte) error

type Upsert 

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

Upsert related messages.

func (*Upsert) CloneMessageVT added in v1.7.7 

func (m *Upsert) CloneMessageVT() proto.Message

func (*Upsert) CloneVT added in v1.7.7 

func (m *Upsert) CloneVT() *Upsert

func (*Upsert) Descriptor deprecated 

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

Deprecated: Use Upsert.ProtoReflect.Descriptor instead.

func (*Upsert) EqualMessageVT added in v1.7.6 

func (this *Upsert) EqualMessageVT(thatMsg proto.Message) bool

func (*Upsert) EqualVT added in v1.7.6 

func (this *Upsert) EqualVT(that *Upsert) bool

func (*Upsert) MarshalToSizedBufferVT added in v1.2.2 

func (m *Upsert) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Upsert) MarshalToVT added in v1.2.2 

func (m *Upsert) MarshalToVT(dAtA []byte) (int, error)

func (*Upsert) MarshalVT added in v1.2.2 

func (m *Upsert) MarshalVT() (dAtA []byte, err error)

func (*Upsert) ProtoMessage 

func (*Upsert) ProtoMessage()

func (*Upsert) ProtoReflect added in v1.2.2 

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

func (*Upsert) Reset 

func (x *Upsert) Reset()

func (*Upsert) SizeVT added in v1.2.2 

func (m *Upsert) SizeVT() (n int)

func (*Upsert) String 

func (x *Upsert) String() string

func (*Upsert) UnmarshalVT added in v1.2.2 

func (m *Upsert) UnmarshalVT(dAtA []byte) error

type Upsert_Config 

type Upsert_Config struct {

	// A flag to skip exist check during upsert operation.
	SkipStrictExistCheck bool `` /* 126-byte string literal not displayed */
	// Filter configuration.
	Filters *Filter_Config `protobuf:"bytes,2,opt,name=filters,proto3" json:"filters,omitempty"`
	// Upsert timestamp.
	Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// A flag to disable balanced update (split remove -> insert operation)
	// during update operation.
	DisableBalancedUpdate bool `` /* 127-byte string literal not displayed */
	// contains filtered or unexported fields
}

Represent the upsert configuration.

func (*Upsert_Config) CloneMessageVT added in v1.7.7 

func (m *Upsert_Config) CloneMessageVT() proto.Message

func (*Upsert_Config) CloneVT added in v1.7.7 

func (m *Upsert_Config) CloneVT() *Upsert_Config

func (*Upsert_Config) Descriptor deprecated 

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

Deprecated: Use Upsert_Config.ProtoReflect.Descriptor instead.

func (*Upsert_Config) EqualMessageVT added in v1.7.6 

func (this *Upsert_Config) EqualMessageVT(thatMsg proto.Message) bool

func (*Upsert_Config) EqualVT added in v1.7.6 

func (this *Upsert_Config) EqualVT(that *Upsert_Config) bool

func (*Upsert_Config) GetDisableBalancedUpdate added in v1.7.3 

func (x *Upsert_Config) GetDisableBalancedUpdate() bool

func (*Upsert_Config) GetFilters 

func (x *Upsert_Config) GetFilters() *Filter_Config

func (*Upsert_Config) GetSkipStrictExistCheck 

func (x *Upsert_Config) GetSkipStrictExistCheck() bool

func (*Upsert_Config) GetTimestamp added in v1.1.0 

func (x *Upsert_Config) GetTimestamp() int64

func (*Upsert_Config) MarshalToSizedBufferVT added in v1.2.2 

func (m *Upsert_Config) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Upsert_Config) MarshalToVT added in v1.2.2 

func (m *Upsert_Config) MarshalToVT(dAtA []byte) (int, error)

func (*Upsert_Config) MarshalVT added in v1.2.2 

func (m *Upsert_Config) MarshalVT() (dAtA []byte, err error)

func (*Upsert_Config) ProtoMessage 

func (*Upsert_Config) ProtoMessage()

func (*Upsert_Config) ProtoReflect added in v1.2.2 

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

func (*Upsert_Config) Reset 

func (x *Upsert_Config) Reset()

func (*Upsert_Config) SizeVT added in v1.2.2 

func (m *Upsert_Config) SizeVT() (n int)

func (*Upsert_Config) String 

func (x *Upsert_Config) String() string

func (*Upsert_Config) UnmarshalVT added in v1.2.2 

func (m *Upsert_Config) UnmarshalVT(dAtA []byte) error

type Upsert_MultiObjectRequest 

type Upsert_MultiObjectRequest struct {

	// Represent the multiple upsert object request content.
	Requests []*Upsert_ObjectRequest `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

Represent the multiple upsert binary object request.

func (*Upsert_MultiObjectRequest) CloneMessageVT added in v1.7.7 

func (m *Upsert_MultiObjectRequest) CloneMessageVT() proto.Message

func (*Upsert_MultiObjectRequest) CloneVT added in v1.7.7 

func (m *Upsert_MultiObjectRequest) CloneVT() *Upsert_MultiObjectRequest

func (*Upsert_MultiObjectRequest) Descriptor deprecated 

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

Deprecated: Use Upsert_MultiObjectRequest.ProtoReflect.Descriptor instead.

func (*Upsert_MultiObjectRequest) EqualMessageVT added in v1.7.6 

func (this *Upsert_MultiObjectRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*Upsert_MultiObjectRequest) EqualVT added in v1.7.6 

func (this *Upsert_MultiObjectRequest) EqualVT(that *Upsert_MultiObjectRequest) bool

func (*Upsert_MultiObjectRequest) GetRequests 

func (x *Upsert_MultiObjectRequest) GetRequests() []*Upsert_ObjectRequest

func (*Upsert_MultiObjectRequest) MarshalToSizedBufferVT added in v1.2.2 

func (m *Upsert_MultiObjectRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Upsert_MultiObjectRequest) MarshalToVT added in v1.2.2 

func (m *Upsert_MultiObjectRequest) MarshalToVT(dAtA []byte) (int, error)

func (*Upsert_MultiObjectRequest) MarshalVT added in v1.2.2 

func (m *Upsert_MultiObjectRequest) MarshalVT() (dAtA []byte, err error)

func (*Upsert_MultiObjectRequest) ProtoMessage 

func (*Upsert_MultiObjectRequest) ProtoMessage()

func (*Upsert_MultiObjectRequest) ProtoReflect added in v1.2.2 

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

func (*Upsert_MultiObjectRequest) Reset 

func (x *Upsert_MultiObjectRequest) Reset()

func (*Upsert_MultiObjectRequest) SizeVT added in v1.2.2 

func (m *Upsert_MultiObjectRequest) SizeVT() (n int)

func (*Upsert_MultiObjectRequest) String 

func (x *Upsert_MultiObjectRequest) String() string

func (*Upsert_MultiObjectRequest) UnmarshalVT added in v1.2.2 

func (m *Upsert_MultiObjectRequest) UnmarshalVT(dAtA []byte) error

type Upsert_MultiRequest 

type Upsert_MultiRequest struct {

	// Represent the multiple upsert request content.
	Requests []*Upsert_Request `protobuf:"bytes,1,rep,name=requests,proto3" json:"requests,omitempty"`
	// contains filtered or unexported fields
}

Represent mthe ultiple upsert request.

func (*Upsert_MultiRequest) CloneMessageVT added in v1.7.7 

func (m *Upsert_MultiRequest) CloneMessageVT() proto.Message

func (*Upsert_MultiRequest) CloneVT added in v1.7.7 

func (m *Upsert_MultiRequest) CloneVT() *Upsert_MultiRequest

func (*Upsert_MultiRequest) Descriptor deprecated 

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

Deprecated: Use Upsert_MultiRequest.ProtoReflect.Descriptor instead.

func (*Upsert_MultiRequest) EqualMessageVT added in v1.7.6 

func (this *Upsert_MultiRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*Upsert_MultiRequest) EqualVT added in v1.7.6 

func (this *Upsert_MultiRequest) EqualVT(that *Upsert_MultiRequest) bool

func (*Upsert_MultiRequest) GetRequests 

func (x *Upsert_MultiRequest) GetRequests() []*Upsert_Request

func (*Upsert_MultiRequest) MarshalToSizedBufferVT added in v1.2.2 

func (m *Upsert_MultiRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Upsert_MultiRequest) MarshalToVT added in v1.2.2 

func (m *Upsert_MultiRequest) MarshalToVT(dAtA []byte) (int, error)

func (*Upsert_MultiRequest) MarshalVT added in v1.2.2 

func (m *Upsert_MultiRequest) MarshalVT() (dAtA []byte, err error)

func (*Upsert_MultiRequest) ProtoMessage 

func (*Upsert_MultiRequest) ProtoMessage()

func (*Upsert_MultiRequest) ProtoReflect added in v1.2.2 

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

func (*Upsert_MultiRequest) Reset 

func (x *Upsert_MultiRequest) Reset()

func (*Upsert_MultiRequest) SizeVT added in v1.2.2 

func (m *Upsert_MultiRequest) SizeVT() (n int)

func (*Upsert_MultiRequest) String 

func (x *Upsert_MultiRequest) String() string

func (*Upsert_MultiRequest) UnmarshalVT added in v1.2.2 

func (m *Upsert_MultiRequest) UnmarshalVT(dAtA []byte) error

type Upsert_ObjectRequest 

type Upsert_ObjectRequest struct {

	// The binary object to be upserted.
	Object *Object_Blob `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
	// The configuration of the upsert request.
	Config *Upsert_Config `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// Filter target.
	Vectorizer *Filter_Target `protobuf:"bytes,3,opt,name=vectorizer,proto3" json:"vectorizer,omitempty"`
	// contains filtered or unexported fields
}

Represent the upsert binary object request.

func (*Upsert_ObjectRequest) CloneMessageVT added in v1.7.7 

func (m *Upsert_ObjectRequest) CloneMessageVT() proto.Message

func (*Upsert_ObjectRequest) CloneVT added in v1.7.7 

func (m *Upsert_ObjectRequest) CloneVT() *Upsert_ObjectRequest

func (*Upsert_ObjectRequest) Descriptor deprecated 

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

Deprecated: Use Upsert_ObjectRequest.ProtoReflect.Descriptor instead.

func (*Upsert_ObjectRequest) EqualMessageVT added in v1.7.6 

func (this *Upsert_ObjectRequest) EqualMessageVT(thatMsg proto.Message) bool

func (*Upsert_ObjectRequest) EqualVT added in v1.7.6 

func (this *Upsert_ObjectRequest) EqualVT(that *Upsert_ObjectRequest) bool

func (*Upsert_ObjectRequest) GetConfig 

func (x *Upsert_ObjectRequest) GetConfig() *Upsert_Config

func (*Upsert_ObjectRequest) GetObject 

func (x *Upsert_ObjectRequest) GetObject() *Object_Blob

func (*Upsert_ObjectRequest) GetVectorizer 

func (x *Upsert_ObjectRequest) GetVectorizer() *Filter_Target

func (*Upsert_ObjectRequest) MarshalToSizedBufferVT added in v1.2.2 

func (m *Upsert_ObjectRequest) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Upsert_ObjectRequest) MarshalToVT added in v1.2.2 

func (m *Upsert_ObjectRequest) MarshalToVT(dAtA []byte) (int, error)

func (*Upsert_ObjectRequest) MarshalVT added in v1.2.2 

func (m *Upsert_ObjectRequest) MarshalVT() (dAtA []byte, err error)

func (*Upsert_ObjectRequest) ProtoMessage 

func (*Upsert_ObjectRequest) ProtoMessage()

func (*Upsert_ObjectRequest) ProtoReflect added in v1.2.2 

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

func (*Upsert_ObjectRequest) Reset 

func (x *Upsert_ObjectRequest) Reset()

func (*Upsert_ObjectRequest) SizeVT added in v1.2.2 

func (m *Upsert_ObjectRequest) SizeVT() (n int)

func (*Upsert_ObjectRequest) String 

func (x *Upsert_ObjectRequest) String() string

func (*Upsert_ObjectRequest) UnmarshalVT added in v1.2.2 

func (m *Upsert_ObjectRequest) UnmarshalVT(dAtA []byte) error

type Upsert_Request 

type Upsert_Request struct {

	// The vector to be upserted.
	Vector *Object_Vector `protobuf:"bytes,1,opt,name=vector,proto3" json:"vector,omitempty"`
	// The configuration of the upsert request.
	Config *Upsert_Config `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

Represent the upsert request.

func (*Upsert_Request) CloneMessageVT added in v1.7.7 

func (m *Upsert_Request) CloneMessageVT() proto.Message

func (*Upsert_Request) CloneVT added in v1.7.7 

func (m *Upsert_Request) CloneVT() *Upsert_Request

func (*Upsert_Request) Descriptor deprecated 

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

Deprecated: Use Upsert_Request.ProtoReflect.Descriptor instead.

func (*Upsert_Request) EqualMessageVT added in v1.7.6 

func (this *Upsert_Request) EqualMessageVT(thatMsg proto.Message) bool

func (*Upsert_Request) EqualVT added in v1.7.6 

func (this *Upsert_Request) EqualVT(that *Upsert_Request) bool

func (*Upsert_Request) GetConfig 

func (x *Upsert_Request) GetConfig() *Upsert_Config

func (*Upsert_Request) GetVector 

func (x *Upsert_Request) GetVector() *Object_Vector

func (*Upsert_Request) MarshalToSizedBufferVT added in v1.2.2 

func (m *Upsert_Request) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*Upsert_Request) MarshalToVT added in v1.2.2 

func (m *Upsert_Request) MarshalToVT(dAtA []byte) (int, error)

func (*Upsert_Request) MarshalVT added in v1.2.2 

func (m *Upsert_Request) MarshalVT() (dAtA []byte, err error)

func (*Upsert_Request) ProtoMessage 

func (*Upsert_Request) ProtoMessage()

func (*Upsert_Request) ProtoReflect added in v1.2.2 

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

func (*Upsert_Request) Reset 

func (x *Upsert_Request) Reset()

func (*Upsert_Request) SizeVT added in v1.2.2 

func (m *Upsert_Request) SizeVT() (n int)

func (*Upsert_Request) String 

func (x *Upsert_Request) String() string

func (*Upsert_Request) UnmarshalVT added in v1.2.2 

func (m *Upsert_Request) UnmarshalVT(dAtA []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

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