Ydb_PersQueue_ClusterDiscovery

package
v2.4.0 Latest Latest
Warning

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

 Go to latest Published: Aug 24, 2021 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var WriteSessionClusters_SelectionReason_name = map[int32]string{
	0: "SELECTION_REASON_UNSPECIFIED",
	1: "CLIENT_PREFERENCE",
	2: "CLIENT_LOCATION",
	3: "CONSISTENT_DISTRIBUTION",
}
View Source 
var WriteSessionClusters_SelectionReason_value = map[string]int32{
	"SELECTION_REASON_UNSPECIFIED": 0,
	"CLIENT_PREFERENCE":            1,
	"CLIENT_LOCATION":              2,
	"CONSISTENT_DISTRIBUTION":      3,
}

Functions

This section is empty.

Types

type ClusterInfo 

type ClusterInfo struct {
	// A host discovery endpoint to use at the next step.
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// An official cluster name.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Is the cluster available right now?
	Available            bool     `protobuf:"varint,3,opt,name=available,proto3" json:"available,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ClusterInfo) Descriptor 

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

func (*ClusterInfo) GetAvailable 

func (m *ClusterInfo) GetAvailable() bool

func (*ClusterInfo) GetEndpoint 

func (m *ClusterInfo) GetEndpoint() string

func (*ClusterInfo) GetName 

func (m *ClusterInfo) GetName() string

func (*ClusterInfo) ProtoMessage 

func (*ClusterInfo) ProtoMessage()

func (*ClusterInfo) Reset 

func (m *ClusterInfo) Reset()

func (*ClusterInfo) String 

func (m *ClusterInfo) String() string

func (*ClusterInfo) XXX_DiscardUnknown 

func (m *ClusterInfo) XXX_DiscardUnknown()

func (*ClusterInfo) XXX_Marshal 

func (m *ClusterInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClusterInfo) XXX_Merge 

func (m *ClusterInfo) XXX_Merge(src proto.Message)

func (*ClusterInfo) XXX_Size 

func (m *ClusterInfo) XXX_Size() int

func (*ClusterInfo) XXX_Unmarshal 

func (m *ClusterInfo) XXX_Unmarshal(b []byte) error

type DiscoverClustersRequest 

type DiscoverClustersRequest struct {
	OperationParams *Ydb_Operations.OperationParams `protobuf:"bytes,1,opt,name=operation_params,json=operationParams,proto3" json:"operation_params,omitempty"`
	// Clusters will be discovered separately for each element of the list.
	WriteSessions []*WriteSessionParams `protobuf:"bytes,2,rep,name=write_sessions,json=writeSessions,proto3" json:"write_sessions,omitempty"`
	ReadSessions  []*ReadSessionParams  `protobuf:"bytes,3,rep,name=read_sessions,json=readSessions,proto3" json:"read_sessions,omitempty"`
	// Latest clusters status version known to the client application. Use 0 by default.
	MinimalVersion       int64    `protobuf:"varint,4,opt,name=minimal_version,json=minimalVersion,proto3" json:"minimal_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DiscoverClustersRequest) Descriptor 

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

func (*DiscoverClustersRequest) GetMinimalVersion 

func (m *DiscoverClustersRequest) GetMinimalVersion() int64

func (*DiscoverClustersRequest) GetOperationParams 

func (m *DiscoverClustersRequest) GetOperationParams() *Ydb_Operations.OperationParams

func (*DiscoverClustersRequest) GetReadSessions 

func (m *DiscoverClustersRequest) GetReadSessions() []*ReadSessionParams

func (*DiscoverClustersRequest) GetWriteSessions 

func (m *DiscoverClustersRequest) GetWriteSessions() []*WriteSessionParams

func (*DiscoverClustersRequest) ProtoMessage 

func (*DiscoverClustersRequest) ProtoMessage()

func (*DiscoverClustersRequest) Reset 

func (m *DiscoverClustersRequest) Reset()

func (*DiscoverClustersRequest) SetOperationParams 

func (m *DiscoverClustersRequest) SetOperationParams(v *Ydb_Operations.OperationParams)

SetOperationParams implements ydb generic interface for setting operation parameters inside driver implementation.

func (*DiscoverClustersRequest) String 

func (m *DiscoverClustersRequest) String() string

func (*DiscoverClustersRequest) XXX_DiscardUnknown 

func (m *DiscoverClustersRequest) XXX_DiscardUnknown()

func (*DiscoverClustersRequest) XXX_Marshal 

func (m *DiscoverClustersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiscoverClustersRequest) XXX_Merge 

func (m *DiscoverClustersRequest) XXX_Merge(src proto.Message)

func (*DiscoverClustersRequest) XXX_Size 

func (m *DiscoverClustersRequest) XXX_Size() int

func (*DiscoverClustersRequest) XXX_Unmarshal 

func (m *DiscoverClustersRequest) XXX_Unmarshal(b []byte) error

type DiscoverClustersResponse 

type DiscoverClustersResponse struct {
	// Operation contains the result of the request. Check the ydb_operation.proto.
	Operation            *Ydb_Operations.Operation `protobuf:"bytes,1,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*DiscoverClustersResponse) Descriptor 

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

func (*DiscoverClustersResponse) GetOperation 

func (m *DiscoverClustersResponse) GetOperation() *Ydb_Operations.Operation

func (*DiscoverClustersResponse) ProtoMessage 

func (*DiscoverClustersResponse) ProtoMessage()

func (*DiscoverClustersResponse) Reset 

func (m *DiscoverClustersResponse) Reset()

func (*DiscoverClustersResponse) String 

func (m *DiscoverClustersResponse) String() string

func (*DiscoverClustersResponse) XXX_DiscardUnknown 

func (m *DiscoverClustersResponse) XXX_DiscardUnknown()

func (*DiscoverClustersResponse) XXX_Marshal 

func (m *DiscoverClustersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiscoverClustersResponse) XXX_Merge 

func (m *DiscoverClustersResponse) XXX_Merge(src proto.Message)

func (*DiscoverClustersResponse) XXX_Size 

func (m *DiscoverClustersResponse) XXX_Size() int

func (*DiscoverClustersResponse) XXX_Unmarshal 

func (m *DiscoverClustersResponse) XXX_Unmarshal(b []byte) error

type DiscoverClustersResult 

type DiscoverClustersResult struct {
	// Discovered per-session clusters.
	WriteSessionsClusters []*WriteSessionClusters `` /* 126-byte string literal not displayed */
	ReadSessionsClusters  []*ReadSessionClusters  `protobuf:"bytes,2,rep,name=read_sessions_clusters,json=readSessionsClusters,proto3" json:"read_sessions_clusters,omitempty"`
	// Latest clusters status version known to the cluster discovery service.
	Version              int64    `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DiscoverClustersResult) Descriptor 

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

func (*DiscoverClustersResult) GetReadSessionsClusters 

func (m *DiscoverClustersResult) GetReadSessionsClusters() []*ReadSessionClusters

func (*DiscoverClustersResult) GetVersion 

func (m *DiscoverClustersResult) GetVersion() int64

func (*DiscoverClustersResult) GetWriteSessionsClusters 

func (m *DiscoverClustersResult) GetWriteSessionsClusters() []*WriteSessionClusters

func (*DiscoverClustersResult) ProtoMessage 

func (*DiscoverClustersResult) ProtoMessage()

func (*DiscoverClustersResult) Reset 

func (m *DiscoverClustersResult) Reset()

func (*DiscoverClustersResult) String 

func (m *DiscoverClustersResult) String() string

func (*DiscoverClustersResult) XXX_DiscardUnknown 

func (m *DiscoverClustersResult) XXX_DiscardUnknown()

func (*DiscoverClustersResult) XXX_Marshal 

func (m *DiscoverClustersResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DiscoverClustersResult) XXX_Merge 

func (m *DiscoverClustersResult) XXX_Merge(src proto.Message)

func (*DiscoverClustersResult) XXX_Size 

func (m *DiscoverClustersResult) XXX_Size() int

func (*DiscoverClustersResult) XXX_Unmarshal 

func (m *DiscoverClustersResult) XXX_Unmarshal(b []byte) error

type ReadSessionClusters 

type ReadSessionClusters struct {
	// Ordered clusters with statuses.
	Clusters             []*ClusterInfo `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*ReadSessionClusters) Descriptor 

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

func (*ReadSessionClusters) GetClusters 

func (m *ReadSessionClusters) GetClusters() []*ClusterInfo

func (*ReadSessionClusters) ProtoMessage 

func (*ReadSessionClusters) ProtoMessage()

func (*ReadSessionClusters) Reset 

func (m *ReadSessionClusters) Reset()

func (*ReadSessionClusters) String 

func (m *ReadSessionClusters) String() string

func (*ReadSessionClusters) XXX_DiscardUnknown 

func (m *ReadSessionClusters) XXX_DiscardUnknown()

func (*ReadSessionClusters) XXX_Marshal 

func (m *ReadSessionClusters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadSessionClusters) XXX_Merge 

func (m *ReadSessionClusters) XXX_Merge(src proto.Message)

func (*ReadSessionClusters) XXX_Size 

func (m *ReadSessionClusters) XXX_Size() int

func (*ReadSessionClusters) XXX_Unmarshal 

func (m *ReadSessionClusters) XXX_Unmarshal(b []byte) error

type ReadSessionParams 

type ReadSessionParams struct {
	// Path to the topic to read from.
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// Read mode is set according to the read rule.
	//
	// Types that are valid to be assigned to ReadRule:
	//	*ReadSessionParams_MirrorToCluster
	//	*ReadSessionParams_AllOriginal
	ReadRule             isReadSessionParams_ReadRule `protobuf_oneof:"read_rule"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*ReadSessionParams) Descriptor 

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

func (*ReadSessionParams) GetAllOriginal 

func (m *ReadSessionParams) GetAllOriginal() *emptypb.Empty

func (*ReadSessionParams) GetMirrorToCluster 

func (m *ReadSessionParams) GetMirrorToCluster() string

func (*ReadSessionParams) GetReadRule 

func (m *ReadSessionParams) GetReadRule() isReadSessionParams_ReadRule

func (*ReadSessionParams) GetTopic 

func (m *ReadSessionParams) GetTopic() string

func (*ReadSessionParams) ProtoMessage 

func (*ReadSessionParams) ProtoMessage()

func (*ReadSessionParams) Reset 

func (m *ReadSessionParams) Reset()

func (*ReadSessionParams) String 

func (m *ReadSessionParams) String() string

func (*ReadSessionParams) XXX_DiscardUnknown 

func (m *ReadSessionParams) XXX_DiscardUnknown()

func (*ReadSessionParams) XXX_Marshal 

func (m *ReadSessionParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReadSessionParams) XXX_Merge 

func (m *ReadSessionParams) XXX_Merge(src proto.Message)

func (*ReadSessionParams) XXX_OneofWrappers 

func (*ReadSessionParams) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*ReadSessionParams) XXX_Size 

func (m *ReadSessionParams) XXX_Size() int

func (*ReadSessionParams) XXX_Unmarshal 

func (m *ReadSessionParams) XXX_Unmarshal(b []byte) error

type ReadSessionParams_AllOriginal 

type ReadSessionParams_AllOriginal struct {
	AllOriginal *emptypb.Empty `protobuf:"bytes,3,opt,name=all_original,json=allOriginal,proto3,oneof"`
}

type ReadSessionParams_MirrorToCluster 

type ReadSessionParams_MirrorToCluster struct {
	MirrorToCluster string `protobuf:"bytes,2,opt,name=mirror_to_cluster,json=mirrorToCluster,proto3,oneof"`
}

type WriteSessionClusters 

type WriteSessionClusters struct {
	// Ordered clusters with statuses.
	Clusters []*ClusterInfo `protobuf:"bytes,1,rep,name=clusters,proto3" json:"clusters,omitempty"`
	// The reason why a particular cluster was prioritized.
	PrimaryClusterSelectionReason WriteSessionClusters_SelectionReason `` /* 226-byte string literal not displayed */
	XXX_NoUnkeyedLiteral          struct{}                             `json:"-"`
	XXX_unrecognized              []byte                               `json:"-"`
	XXX_sizecache                 int32                                `json:"-"`
}

func (*WriteSessionClusters) Descriptor 

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

func (*WriteSessionClusters) GetClusters 

func (m *WriteSessionClusters) GetClusters() []*ClusterInfo

func (*WriteSessionClusters) GetPrimaryClusterSelectionReason 

func (m *WriteSessionClusters) GetPrimaryClusterSelectionReason() WriteSessionClusters_SelectionReason

func (*WriteSessionClusters) ProtoMessage 

func (*WriteSessionClusters) ProtoMessage()

func (*WriteSessionClusters) Reset 

func (m *WriteSessionClusters) Reset()

func (*WriteSessionClusters) String 

func (m *WriteSessionClusters) String() string

func (*WriteSessionClusters) XXX_DiscardUnknown 

func (m *WriteSessionClusters) XXX_DiscardUnknown()

func (*WriteSessionClusters) XXX_Marshal 

func (m *WriteSessionClusters) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteSessionClusters) XXX_Merge 

func (m *WriteSessionClusters) XXX_Merge(src proto.Message)

func (*WriteSessionClusters) XXX_Size 

func (m *WriteSessionClusters) XXX_Size() int

func (*WriteSessionClusters) XXX_Unmarshal 

func (m *WriteSessionClusters) XXX_Unmarshal(b []byte) error

type WriteSessionClusters_SelectionReason 

type WriteSessionClusters_SelectionReason int32
const (
	WriteSessionClusters_SELECTION_REASON_UNSPECIFIED WriteSessionClusters_SelectionReason = 0
	WriteSessionClusters_CLIENT_PREFERENCE            WriteSessionClusters_SelectionReason = 1
	WriteSessionClusters_CLIENT_LOCATION              WriteSessionClusters_SelectionReason = 2
	WriteSessionClusters_CONSISTENT_DISTRIBUTION      WriteSessionClusters_SelectionReason = 3
)

func (WriteSessionClusters_SelectionReason) EnumDescriptor 

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

func (WriteSessionClusters_SelectionReason) String 

func (x WriteSessionClusters_SelectionReason) String() string

type WriteSessionParams 

type WriteSessionParams struct {
	// Path to the topic to write to.
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	// Message group identifier.
	SourceId []byte `protobuf:"bytes,2,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"`
	// Partition group to write to. 0 by default.
	PartitionGroup uint32 `protobuf:"varint,3,opt,name=partition_group,json=partitionGroup,proto3" json:"partition_group,omitempty"`
	// Force the specified cluster via its name. Leave it empty by default.
	PreferredClusterName string   `protobuf:"bytes,4,opt,name=preferred_cluster_name,json=preferredClusterName,proto3" json:"preferred_cluster_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*WriteSessionParams) Descriptor 

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

func (*WriteSessionParams) GetPartitionGroup 

func (m *WriteSessionParams) GetPartitionGroup() uint32

func (*WriteSessionParams) GetPreferredClusterName 

func (m *WriteSessionParams) GetPreferredClusterName() string

func (*WriteSessionParams) GetSourceId 

func (m *WriteSessionParams) GetSourceId() []byte

func (*WriteSessionParams) GetTopic 

func (m *WriteSessionParams) GetTopic() string

func (*WriteSessionParams) ProtoMessage 

func (*WriteSessionParams) ProtoMessage()

func (*WriteSessionParams) Reset 

func (m *WriteSessionParams) Reset()

func (*WriteSessionParams) String 

func (m *WriteSessionParams) String() string

func (*WriteSessionParams) XXX_DiscardUnknown 

func (m *WriteSessionParams) XXX_DiscardUnknown()

func (*WriteSessionParams) XXX_Marshal 

func (m *WriteSessionParams) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*WriteSessionParams) XXX_Merge 

func (m *WriteSessionParams) XXX_Merge(src proto.Message)

func (*WriteSessionParams) XXX_Size 

func (m *WriteSessionParams) XXX_Size() int

func (*WriteSessionParams) XXX_Unmarshal 

func (m *WriteSessionParams) XXX_Unmarshal(b []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.