api

package
v1.25.8 Latest Latest
Warning

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

 Go to latest Published: Jul 18, 2024 License: BSD-3-Clause Imports: 11 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	ClusterService_RemovePeer_FullMethodName = "/weaviate.internal.cluster.ClusterService/RemovePeer"
	ClusterService_JoinPeer_FullMethodName   = "/weaviate.internal.cluster.ClusterService/JoinPeer"
	ClusterService_NotifyPeer_FullMethodName = "/weaviate.internal.cluster.ClusterService/NotifyPeer"
	ClusterService_Apply_FullMethodName      = "/weaviate.internal.cluster.ClusterService/Apply"
	ClusterService_Query_FullMethodName      = "/weaviate.internal.cluster.ClusterService/Query"
)

Variables

View Source 
var (
	ApplyRequest_Type_name = map[int32]string{
		0:  "TYPE_UNSPECIFIED",
		1:  "TYPE_ADD_CLASS",
		2:  "TYPE_UPDATE_CLASS",
		3:  "TYPE_DELETE_CLASS",
		4:  "TYPE_RESTORE_CLASS",
		5:  "TYPE_ADD_PROPERTY",
		10: "TYPE_UPDATE_SHARD_STATUS",
		16: "TYPE_ADD_TENANT",
		17: "TYPE_UPDATE_TENANT",
		18: "TYPE_DELETE_TENANT",
		99: "TYPE_STORE_SCHEMA_V1",
	}
	ApplyRequest_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED":         0,
		"TYPE_ADD_CLASS":           1,
		"TYPE_UPDATE_CLASS":        2,
		"TYPE_DELETE_CLASS":        3,
		"TYPE_RESTORE_CLASS":       4,
		"TYPE_ADD_PROPERTY":        5,
		"TYPE_UPDATE_SHARD_STATUS": 10,
		"TYPE_ADD_TENANT":          16,
		"TYPE_UPDATE_TENANT":       17,
		"TYPE_DELETE_TENANT":       18,
		"TYPE_STORE_SCHEMA_V1":     99,
	}
)

Enum value maps for ApplyRequest_Type.

View Source 
var (
	QueryRequest_Type_name = map[int32]string{
		0: "TYPE_UNSPECIFIED",
		1: "TYPE_GET_CLASSES",
		2: "TYPE_GET_SCHEMA",
		3: "TYPE_GET_TENANTS",
		4: "TYPE_GET_SHARD_OWNER",
		5: "TYPE_GET_TENANTS_SHARDS",
		6: "TYPE_GET_SHARDING_STATE",
	}
	QueryRequest_Type_value = map[string]int32{
		"TYPE_UNSPECIFIED":        0,
		"TYPE_GET_CLASSES":        1,
		"TYPE_GET_SCHEMA":         2,
		"TYPE_GET_TENANTS":        3,
		"TYPE_GET_SHARD_OWNER":    4,
		"TYPE_GET_TENANTS_SHARDS": 5,
		"TYPE_GET_SHARDING_STATE": 6,
	}
)

Enum value maps for QueryRequest_Type.

View Source 
var ClusterService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "weaviate.internal.cluster.ClusterService",
	HandlerType: (*ClusterServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RemovePeer",
			Handler:    _ClusterService_RemovePeer_Handler,
		},
		{
			MethodName: "JoinPeer",
			Handler:    _ClusterService_JoinPeer_Handler,
		},
		{
			MethodName: "NotifyPeer",
			Handler:    _ClusterService_NotifyPeer_Handler,
		},
		{
			MethodName: "Apply",
			Handler:    _ClusterService_Apply_Handler,
		},
		{
			MethodName: "Query",
			Handler:    _ClusterService_Query_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "api/message.proto",
}

ClusterService_ServiceDesc is the grpc.ServiceDesc for ClusterService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_api_message_proto protoreflect.FileDescriptor

Functions

func RegisterClusterServiceServer 

func RegisterClusterServiceServer(s grpc.ServiceRegistrar, srv ClusterServiceServer)

Types

type AddClassRequest 

type AddClassRequest struct {
	Class *models.Class
	State *sharding.State
}

type AddPropertyRequest 

type AddPropertyRequest struct {
	Properties []*models.Property
}

type AddTenantsRequest 

type AddTenantsRequest struct {
	ClusterNodes []string  `protobuf:"bytes,1,rep,name=cluster_nodes,json=clusterNodes,proto3" json:"cluster_nodes,omitempty"`
	Tenants      []*Tenant `protobuf:"bytes,2,rep,name=tenants,proto3" json:"tenants,omitempty"`
	// contains filtered or unexported fields
}

func (*AddTenantsRequest) Descriptor deprecated 

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

Deprecated: Use AddTenantsRequest.ProtoReflect.Descriptor instead.

func (*AddTenantsRequest) GetClusterNodes 

func (x *AddTenantsRequest) GetClusterNodes() []string

func (*AddTenantsRequest) GetTenants 

func (x *AddTenantsRequest) GetTenants() []*Tenant

func (*AddTenantsRequest) ProtoMessage 

func (*AddTenantsRequest) ProtoMessage()

func (*AddTenantsRequest) ProtoReflect 

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

func (*AddTenantsRequest) Reset 

func (x *AddTenantsRequest) Reset()

func (*AddTenantsRequest) String 

func (x *AddTenantsRequest) String() string

type ApplyRequest 

type ApplyRequest struct {
	Type       ApplyRequest_Type `protobuf:"varint,1,opt,name=type,proto3,enum=weaviate.internal.cluster.ApplyRequest_Type" json:"type,omitempty"`
	Class      string            `protobuf:"bytes,2,opt,name=class,proto3" json:"class,omitempty"`
	Version    uint64            `protobuf:"varint,3,opt,name=version,proto3" json:"version,omitempty"`
	SubCommand []byte            `protobuf:"bytes,4,opt,name=sub_command,json=subCommand,proto3" json:"sub_command,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyRequest) Descriptor deprecated 

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

Deprecated: Use ApplyRequest.ProtoReflect.Descriptor instead.

func (*ApplyRequest) GetClass 

func (x *ApplyRequest) GetClass() string

func (*ApplyRequest) GetSubCommand 

func (x *ApplyRequest) GetSubCommand() []byte

func (*ApplyRequest) GetType 

func (x *ApplyRequest) GetType() ApplyRequest_Type

func (*ApplyRequest) GetVersion 

func (x *ApplyRequest) GetVersion() uint64

func (*ApplyRequest) ProtoMessage 

func (*ApplyRequest) ProtoMessage()

func (*ApplyRequest) ProtoReflect 

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

func (*ApplyRequest) Reset 

func (x *ApplyRequest) Reset()

func (*ApplyRequest) String 

func (x *ApplyRequest) String() string

type ApplyRequest_Type 

type ApplyRequest_Type int32
const (
	ApplyRequest_TYPE_UNSPECIFIED         ApplyRequest_Type = 0
	ApplyRequest_TYPE_ADD_CLASS           ApplyRequest_Type = 1
	ApplyRequest_TYPE_UPDATE_CLASS        ApplyRequest_Type = 2
	ApplyRequest_TYPE_DELETE_CLASS        ApplyRequest_Type = 3
	ApplyRequest_TYPE_RESTORE_CLASS       ApplyRequest_Type = 4
	ApplyRequest_TYPE_ADD_PROPERTY        ApplyRequest_Type = 5
	ApplyRequest_TYPE_UPDATE_SHARD_STATUS ApplyRequest_Type = 10
	ApplyRequest_TYPE_ADD_TENANT          ApplyRequest_Type = 16
	ApplyRequest_TYPE_UPDATE_TENANT       ApplyRequest_Type = 17
	ApplyRequest_TYPE_DELETE_TENANT       ApplyRequest_Type = 18
	ApplyRequest_TYPE_STORE_SCHEMA_V1     ApplyRequest_Type = 99
)

func (ApplyRequest_Type) Descriptor 

func (ApplyRequest_Type) Descriptor() protoreflect.EnumDescriptor

func (ApplyRequest_Type) Enum 

func (x ApplyRequest_Type) Enum() *ApplyRequest_Type

func (ApplyRequest_Type) EnumDescriptor deprecated 

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

Deprecated: Use ApplyRequest_Type.Descriptor instead.

func (ApplyRequest_Type) Number 

func (x ApplyRequest_Type) Number() protoreflect.EnumNumber

func (ApplyRequest_Type) String 

func (x ApplyRequest_Type) String() string

func (ApplyRequest_Type) Type 

func (ApplyRequest_Type) Type() protoreflect.EnumType

type ApplyResponse 

type ApplyResponse struct {
	Version uint64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Leader  string `protobuf:"bytes,2,opt,name=leader,proto3" json:"leader,omitempty"`
	// contains filtered or unexported fields
}

func (*ApplyResponse) Descriptor deprecated 

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

Deprecated: Use ApplyResponse.ProtoReflect.Descriptor instead.

func (*ApplyResponse) GetLeader 

func (x *ApplyResponse) GetLeader() string

func (*ApplyResponse) GetVersion 

func (x *ApplyResponse) GetVersion() uint64

func (*ApplyResponse) ProtoMessage 

func (*ApplyResponse) ProtoMessage()

func (*ApplyResponse) ProtoReflect 

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

func (*ApplyResponse) Reset 

func (x *ApplyResponse) Reset()

func (*ApplyResponse) String 

func (x *ApplyResponse) String() string

type ClusterServiceClient 

type ClusterServiceClient interface {
	RemovePeer(ctx context.Context, in *RemovePeerRequest, opts ...grpc.CallOption) (*RemovePeerResponse, error)
	JoinPeer(ctx context.Context, in *JoinPeerRequest, opts ...grpc.CallOption) (*JoinPeerResponse, error)
	NotifyPeer(ctx context.Context, in *NotifyPeerRequest, opts ...grpc.CallOption) (*NotifyPeerResponse, error)
	Apply(ctx context.Context, in *ApplyRequest, opts ...grpc.CallOption) (*ApplyResponse, error)
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
}

ClusterServiceClient is the client API for ClusterService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewClusterServiceClient 

func NewClusterServiceClient(cc grpc.ClientConnInterface) ClusterServiceClient

type ClusterServiceServer 

type ClusterServiceServer interface {
	RemovePeer(context.Context, *RemovePeerRequest) (*RemovePeerResponse, error)
	JoinPeer(context.Context, *JoinPeerRequest) (*JoinPeerResponse, error)
	NotifyPeer(context.Context, *NotifyPeerRequest) (*NotifyPeerResponse, error)
	Apply(context.Context, *ApplyRequest) (*ApplyResponse, error)
	Query(context.Context, *QueryRequest) (*QueryResponse, error)
}

ClusterServiceServer is the server API for ClusterService service. All implementations should embed UnimplementedClusterServiceServer for forward compatibility

type DeleteClassRequest 

type DeleteClassRequest struct {
	Name string
}

type DeleteTenantsRequest 

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

func (*DeleteTenantsRequest) Descriptor deprecated 

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

Deprecated: Use DeleteTenantsRequest.ProtoReflect.Descriptor instead.

func (*DeleteTenantsRequest) GetTenants 

func (x *DeleteTenantsRequest) GetTenants() []string

func (*DeleteTenantsRequest) ProtoMessage 

func (*DeleteTenantsRequest) ProtoMessage()

func (*DeleteTenantsRequest) ProtoReflect 

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

func (*DeleteTenantsRequest) Reset 

func (x *DeleteTenantsRequest) Reset()

func (*DeleteTenantsRequest) String 

func (x *DeleteTenantsRequest) String() string

type JoinPeerRequest 

type JoinPeerRequest struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Voter   bool   `protobuf:"varint,3,opt,name=voter,proto3" json:"voter,omitempty"`
	// contains filtered or unexported fields
}

func (*JoinPeerRequest) Descriptor deprecated 

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

Deprecated: Use JoinPeerRequest.ProtoReflect.Descriptor instead.

func (*JoinPeerRequest) GetAddress 

func (x *JoinPeerRequest) GetAddress() string

func (*JoinPeerRequest) GetId 

func (x *JoinPeerRequest) GetId() string

func (*JoinPeerRequest) GetVoter 

func (x *JoinPeerRequest) GetVoter() bool

func (*JoinPeerRequest) ProtoMessage 

func (*JoinPeerRequest) ProtoMessage()

func (*JoinPeerRequest) ProtoReflect 

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

func (*JoinPeerRequest) Reset 

func (x *JoinPeerRequest) Reset()

func (*JoinPeerRequest) String 

func (x *JoinPeerRequest) String() string

type JoinPeerResponse 

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

func (*JoinPeerResponse) Descriptor deprecated 

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

Deprecated: Use JoinPeerResponse.ProtoReflect.Descriptor instead.

func (*JoinPeerResponse) GetLeader 

func (x *JoinPeerResponse) GetLeader() string

func (*JoinPeerResponse) ProtoMessage 

func (*JoinPeerResponse) ProtoMessage()

func (*JoinPeerResponse) ProtoReflect 

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

func (*JoinPeerResponse) Reset 

func (x *JoinPeerResponse) Reset()

func (*JoinPeerResponse) String 

func (x *JoinPeerResponse) String() string

type NotifyPeerRequest 

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

func (*NotifyPeerRequest) Descriptor deprecated 

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

Deprecated: Use NotifyPeerRequest.ProtoReflect.Descriptor instead.

func (*NotifyPeerRequest) GetAddress 

func (x *NotifyPeerRequest) GetAddress() string

func (*NotifyPeerRequest) GetId 

func (x *NotifyPeerRequest) GetId() string

func (*NotifyPeerRequest) ProtoMessage 

func (*NotifyPeerRequest) ProtoMessage()

func (*NotifyPeerRequest) ProtoReflect 

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

func (*NotifyPeerRequest) Reset 

func (x *NotifyPeerRequest) Reset()

func (*NotifyPeerRequest) String 

func (x *NotifyPeerRequest) String() string

type NotifyPeerResponse 

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

func (*NotifyPeerResponse) Descriptor deprecated 

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

Deprecated: Use NotifyPeerResponse.ProtoReflect.Descriptor instead.

func (*NotifyPeerResponse) ProtoMessage 

func (*NotifyPeerResponse) ProtoMessage()

func (*NotifyPeerResponse) ProtoReflect 

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

func (*NotifyPeerResponse) Reset 

func (x *NotifyPeerResponse) Reset()

func (*NotifyPeerResponse) String 

func (x *NotifyPeerResponse) String() string

type QueryReadOnlyClassResponse 

type QueryReadOnlyClassResponse struct {
	Classes map[string]versioned.Class
}

type QueryReadOnlyClassesRequest 

type QueryReadOnlyClassesRequest struct {
	Classes []string
}

type QueryRequest 

type QueryRequest struct {
	Type       QueryRequest_Type `protobuf:"varint,1,opt,name=type,proto3,enum=weaviate.internal.cluster.QueryRequest_Type" json:"type,omitempty"`
	SubCommand []byte            `protobuf:"bytes,2,opt,name=sub_command,json=subCommand,proto3" json:"sub_command,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryRequest) Descriptor deprecated 

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

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetSubCommand 

func (x *QueryRequest) GetSubCommand() []byte

func (*QueryRequest) GetType 

func (x *QueryRequest) GetType() QueryRequest_Type

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect 

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

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) String 

func (x *QueryRequest) String() string

type QueryRequest_Type 

type QueryRequest_Type int32
const (
	QueryRequest_TYPE_UNSPECIFIED        QueryRequest_Type = 0
	QueryRequest_TYPE_GET_CLASSES        QueryRequest_Type = 1
	QueryRequest_TYPE_GET_SCHEMA         QueryRequest_Type = 2
	QueryRequest_TYPE_GET_TENANTS        QueryRequest_Type = 3
	QueryRequest_TYPE_GET_SHARD_OWNER    QueryRequest_Type = 4
	QueryRequest_TYPE_GET_TENANTS_SHARDS QueryRequest_Type = 5
	QueryRequest_TYPE_GET_SHARDING_STATE QueryRequest_Type = 6
)

func (QueryRequest_Type) Descriptor 

func (QueryRequest_Type) Descriptor() protoreflect.EnumDescriptor

func (QueryRequest_Type) Enum 

func (x QueryRequest_Type) Enum() *QueryRequest_Type

func (QueryRequest_Type) EnumDescriptor deprecated 

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

Deprecated: Use QueryRequest_Type.Descriptor instead.

func (QueryRequest_Type) Number 

func (x QueryRequest_Type) Number() protoreflect.EnumNumber

func (QueryRequest_Type) String 

func (x QueryRequest_Type) String() string

func (QueryRequest_Type) Type 

func (QueryRequest_Type) Type() protoreflect.EnumType

type QueryResponse 

type QueryResponse struct {
	Payload []byte `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryResponse) Descriptor deprecated 

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

Deprecated: Use QueryResponse.ProtoReflect.Descriptor instead.

func (*QueryResponse) GetPayload 

func (x *QueryResponse) GetPayload() []byte

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) ProtoReflect 

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

func (*QueryResponse) Reset 

func (x *QueryResponse) Reset()

func (*QueryResponse) String 

func (x *QueryResponse) String() string

type QuerySchemaResponse 

type QuerySchemaResponse struct {
	Schema models.Schema
}

type QueryShardOwnerRequest 

type QueryShardOwnerRequest struct {
	Class, Shard string
}

type QueryShardOwnerResponse 

type QueryShardOwnerResponse struct {
	ShardVersion uint64
	Owner        string
}

type QueryShardingStateRequest 

type QueryShardingStateRequest struct {
	Class string
}

type QueryShardingStateResponse 

type QueryShardingStateResponse struct {
	State   *sharding.State
	Version uint64
}

type QueryTenantsRequest 

type QueryTenantsRequest struct {
	Class   string
	Tenants []string // If empty, all tenants are returned
}

type QueryTenantsResponse 

type QueryTenantsResponse struct {
	ShardVersion uint64
	Tenants      []*models.Tenant
}

type QueryTenantsShardsRequest 

type QueryTenantsShardsRequest struct {
	Class   string
	Tenants []string
}

type QueryTenantsShardsResponse 

type QueryTenantsShardsResponse struct {
	TenantsActivityStatus map[string]string // map[tenant]status
	SchemaVersion         uint64
}

type RemovePeerRequest 

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

func (*RemovePeerRequest) Descriptor deprecated 

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

Deprecated: Use RemovePeerRequest.ProtoReflect.Descriptor instead.

func (*RemovePeerRequest) GetId 

func (x *RemovePeerRequest) GetId() string

func (*RemovePeerRequest) ProtoMessage 

func (*RemovePeerRequest) ProtoMessage()

func (*RemovePeerRequest) ProtoReflect 

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

func (*RemovePeerRequest) Reset 

func (x *RemovePeerRequest) Reset()

func (*RemovePeerRequest) String 

func (x *RemovePeerRequest) String() string

type RemovePeerResponse 

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

func (*RemovePeerResponse) Descriptor deprecated 

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

Deprecated: Use RemovePeerResponse.ProtoReflect.Descriptor instead.

func (*RemovePeerResponse) GetLeader 

func (x *RemovePeerResponse) GetLeader() string

func (*RemovePeerResponse) ProtoMessage 

func (*RemovePeerResponse) ProtoMessage()

func (*RemovePeerResponse) ProtoReflect 

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

func (*RemovePeerResponse) Reset 

func (x *RemovePeerResponse) Reset()

func (*RemovePeerResponse) String 

func (x *RemovePeerResponse) String() string

type Tenant 

type Tenant struct {
	Name   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Status string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*Tenant) Descriptor deprecated 

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

Deprecated: Use Tenant.ProtoReflect.Descriptor instead.

func (*Tenant) GetName 

func (x *Tenant) GetName() string

func (*Tenant) GetStatus 

func (x *Tenant) GetStatus() string

func (*Tenant) ProtoMessage 

func (*Tenant) ProtoMessage()

func (*Tenant) ProtoReflect 

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

func (*Tenant) Reset 

func (x *Tenant) Reset()

func (*Tenant) String 

func (x *Tenant) String() string

type TenantWithVersion 

type TenantWithVersion struct {
	ShardVersion uint64
	Tenant       *models.Tenant
}

type UnimplementedClusterServiceServer 

type UnimplementedClusterServiceServer struct {
}

UnimplementedClusterServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedClusterServiceServer) Apply 

func (UnimplementedClusterServiceServer) Apply(context.Context, *ApplyRequest) (*ApplyResponse, error)

func (UnimplementedClusterServiceServer) JoinPeer 

func (UnimplementedClusterServiceServer) JoinPeer(context.Context, *JoinPeerRequest) (*JoinPeerResponse, error)

func (UnimplementedClusterServiceServer) NotifyPeer 

func (UnimplementedClusterServiceServer) NotifyPeer(context.Context, *NotifyPeerRequest) (*NotifyPeerResponse, error)

func (UnimplementedClusterServiceServer) Query 

func (UnimplementedClusterServiceServer) Query(context.Context, *QueryRequest) (*QueryResponse, error)

func (UnimplementedClusterServiceServer) RemovePeer 

func (UnimplementedClusterServiceServer) RemovePeer(context.Context, *RemovePeerRequest) (*RemovePeerResponse, error)

type UnsafeClusterServiceServer 

type UnsafeClusterServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeClusterServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ClusterServiceServer will result in compilation errors.

type UpdateClassRequest 

type UpdateClassRequest struct {
	Class *models.Class
	State *sharding.State
}

type UpdateShardStatusRequest 

type UpdateShardStatusRequest struct {
	Class, Shard, Status string
	SchemaVersion        uint64
}

type UpdateTenantsRequest 

type UpdateTenantsRequest struct {
	Tenants []*Tenant `protobuf:"bytes,1,rep,name=tenants,proto3" json:"tenants,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateTenantsRequest) Descriptor deprecated 

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

Deprecated: Use UpdateTenantsRequest.ProtoReflect.Descriptor instead.

func (*UpdateTenantsRequest) GetTenants 

func (x *UpdateTenantsRequest) GetTenants() []*Tenant

func (*UpdateTenantsRequest) ProtoMessage 

func (*UpdateTenantsRequest) ProtoMessage()

func (*UpdateTenantsRequest) ProtoReflect 

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

func (*UpdateTenantsRequest) Reset 

func (x *UpdateTenantsRequest) Reset()

func (*UpdateTenantsRequest) String 

func (x *UpdateTenantsRequest) String() string

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.