Documentation ¶
Index ¶
- Variables
- func RegisterDatabaseServiceServer(s *grpc.Server, srv DatabaseServiceServer)
- type Database
- func (*Database) Descriptor() ([]byte, []int)
- func (m *Database) GetID() DatabaseId
- func (m *Database) GetPartitions() []Partition
- func (m *Database) Marshal() (dAtA []byte, err error)
- func (m *Database) MarshalTo(dAtA []byte) (int, error)
- func (m *Database) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Database) ProtoMessage()
- func (m *Database) Reset()
- func (m *Database) Size() (n int)
- func (m *Database) String() string
- func (m *Database) Unmarshal(dAtA []byte) error
- func (m *Database) XXX_DiscardUnknown()
- func (m *Database) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Database) XXX_Merge(src proto.Message)
- func (m *Database) XXX_Size() int
- func (m *Database) XXX_Unmarshal(b []byte) error
- type DatabaseConfig
- func (*DatabaseConfig) Descriptor() ([]byte, []int)
- func (m *DatabaseConfig) GetPartitions() []PartitionId
- func (m *DatabaseConfig) GetReplicas() []ReplicaConfig
- func (m *DatabaseConfig) Marshal() (dAtA []byte, err error)
- func (m *DatabaseConfig) MarshalTo(dAtA []byte) (int, error)
- func (m *DatabaseConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DatabaseConfig) ProtoMessage()
- func (m *DatabaseConfig) Reset()
- func (m *DatabaseConfig) Size() (n int)
- func (m *DatabaseConfig) String() string
- func (m *DatabaseConfig) Unmarshal(dAtA []byte) error
- func (m *DatabaseConfig) XXX_DiscardUnknown()
- func (m *DatabaseConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseConfig) XXX_Merge(src proto.Message)
- func (m *DatabaseConfig) XXX_Size() int
- func (m *DatabaseConfig) XXX_Unmarshal(b []byte) error
- type DatabaseId
- func (*DatabaseId) Descriptor() ([]byte, []int)
- func (m *DatabaseId) GetName() string
- func (m *DatabaseId) GetNamespace() string
- func (m *DatabaseId) Marshal() (dAtA []byte, err error)
- func (m *DatabaseId) MarshalTo(dAtA []byte) (int, error)
- func (m *DatabaseId) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*DatabaseId) ProtoMessage()
- func (m *DatabaseId) Reset()
- func (m *DatabaseId) Size() (n int)
- func (m *DatabaseId) String() string
- func (m *DatabaseId) Unmarshal(dAtA []byte) error
- func (m *DatabaseId) XXX_DiscardUnknown()
- func (m *DatabaseId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DatabaseId) XXX_Merge(src proto.Message)
- func (m *DatabaseId) XXX_Size() int
- func (m *DatabaseId) XXX_Unmarshal(b []byte) error
- type DatabaseServiceClient
- type DatabaseServiceServer
- type GetDatabaseRequest
- func (*GetDatabaseRequest) Descriptor() ([]byte, []int)
- func (m *GetDatabaseRequest) GetID() DatabaseId
- func (m *GetDatabaseRequest) Marshal() (dAtA []byte, err error)
- func (m *GetDatabaseRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetDatabaseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetDatabaseRequest) ProtoMessage()
- func (m *GetDatabaseRequest) Reset()
- func (m *GetDatabaseRequest) Size() (n int)
- func (m *GetDatabaseRequest) String() string
- func (m *GetDatabaseRequest) Unmarshal(dAtA []byte) error
- func (m *GetDatabaseRequest) XXX_DiscardUnknown()
- func (m *GetDatabaseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetDatabaseRequest) XXX_Merge(src proto.Message)
- func (m *GetDatabaseRequest) XXX_Size() int
- func (m *GetDatabaseRequest) XXX_Unmarshal(b []byte) error
- type GetDatabaseResponse
- func (*GetDatabaseResponse) Descriptor() ([]byte, []int)
- func (m *GetDatabaseResponse) GetDatabase() *Database
- func (m *GetDatabaseResponse) Marshal() (dAtA []byte, err error)
- func (m *GetDatabaseResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetDatabaseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetDatabaseResponse) ProtoMessage()
- func (m *GetDatabaseResponse) Reset()
- func (m *GetDatabaseResponse) Size() (n int)
- func (m *GetDatabaseResponse) String() string
- func (m *GetDatabaseResponse) Unmarshal(dAtA []byte) error
- func (m *GetDatabaseResponse) XXX_DiscardUnknown()
- func (m *GetDatabaseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetDatabaseResponse) XXX_Merge(src proto.Message)
- func (m *GetDatabaseResponse) XXX_Size() int
- func (m *GetDatabaseResponse) XXX_Unmarshal(b []byte) error
- type GetDatabasesRequest
- func (*GetDatabasesRequest) Descriptor() ([]byte, []int)
- func (m *GetDatabasesRequest) GetNamespace() string
- func (m *GetDatabasesRequest) Marshal() (dAtA []byte, err error)
- func (m *GetDatabasesRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetDatabasesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetDatabasesRequest) ProtoMessage()
- func (m *GetDatabasesRequest) Reset()
- func (m *GetDatabasesRequest) Size() (n int)
- func (m *GetDatabasesRequest) String() string
- func (m *GetDatabasesRequest) Unmarshal(dAtA []byte) error
- func (m *GetDatabasesRequest) XXX_DiscardUnknown()
- func (m *GetDatabasesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetDatabasesRequest) XXX_Merge(src proto.Message)
- func (m *GetDatabasesRequest) XXX_Size() int
- func (m *GetDatabasesRequest) XXX_Unmarshal(b []byte) error
- type GetDatabasesResponse
- func (*GetDatabasesResponse) Descriptor() ([]byte, []int)
- func (m *GetDatabasesResponse) GetDatabases() []Database
- func (m *GetDatabasesResponse) Marshal() (dAtA []byte, err error)
- func (m *GetDatabasesResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetDatabasesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetDatabasesResponse) ProtoMessage()
- func (m *GetDatabasesResponse) Reset()
- func (m *GetDatabasesResponse) Size() (n int)
- func (m *GetDatabasesResponse) String() string
- func (m *GetDatabasesResponse) Unmarshal(dAtA []byte) error
- func (m *GetDatabasesResponse) XXX_DiscardUnknown()
- func (m *GetDatabasesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetDatabasesResponse) XXX_Merge(src proto.Message)
- func (m *GetDatabasesResponse) XXX_Size() int
- func (m *GetDatabasesResponse) XXX_Unmarshal(b []byte) error
- type Partition
- func (*Partition) Descriptor() ([]byte, []int)
- func (m *Partition) GetEndpoints() []PartitionEndpoint
- func (m *Partition) GetPartitionID() PartitionId
- func (m *Partition) Marshal() (dAtA []byte, err error)
- func (m *Partition) MarshalTo(dAtA []byte) (int, error)
- func (m *Partition) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Partition) ProtoMessage()
- func (m *Partition) Reset()
- func (m *Partition) Size() (n int)
- func (m *Partition) String() string
- func (m *Partition) Unmarshal(dAtA []byte) error
- func (m *Partition) XXX_DiscardUnknown()
- func (m *Partition) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Partition) XXX_Merge(src proto.Message)
- func (m *Partition) XXX_Size() int
- func (m *Partition) XXX_Unmarshal(b []byte) error
- type PartitionEndpoint
- func (*PartitionEndpoint) Descriptor() ([]byte, []int)
- func (m *PartitionEndpoint) GetHost() string
- func (m *PartitionEndpoint) GetPort() int32
- func (m *PartitionEndpoint) Marshal() (dAtA []byte, err error)
- func (m *PartitionEndpoint) MarshalTo(dAtA []byte) (int, error)
- func (m *PartitionEndpoint) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PartitionEndpoint) ProtoMessage()
- func (m *PartitionEndpoint) Reset()
- func (m *PartitionEndpoint) Size() (n int)
- func (m *PartitionEndpoint) String() string
- func (m *PartitionEndpoint) Unmarshal(dAtA []byte) error
- func (m *PartitionEndpoint) XXX_DiscardUnknown()
- func (m *PartitionEndpoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PartitionEndpoint) XXX_Merge(src proto.Message)
- func (m *PartitionEndpoint) XXX_Size() int
- func (m *PartitionEndpoint) XXX_Unmarshal(b []byte) error
- type PartitionId
- func (*PartitionId) Descriptor() ([]byte, []int)
- func (m *PartitionId) GetPartition() int32
- func (m *PartitionId) Marshal() (dAtA []byte, err error)
- func (m *PartitionId) MarshalTo(dAtA []byte) (int, error)
- func (m *PartitionId) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PartitionId) ProtoMessage()
- func (m *PartitionId) Reset()
- func (m *PartitionId) Size() (n int)
- func (m *PartitionId) String() string
- func (m *PartitionId) Unmarshal(dAtA []byte) error
- func (m *PartitionId) XXX_DiscardUnknown()
- func (m *PartitionId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PartitionId) XXX_Merge(src proto.Message)
- func (m *PartitionId) XXX_Size() int
- func (m *PartitionId) XXX_Unmarshal(b []byte) error
- type ReplicaConfig
- func (*ReplicaConfig) Descriptor() ([]byte, []int)
- func (m *ReplicaConfig) GetAPIPort() int32
- func (m *ReplicaConfig) GetHost() string
- func (m *ReplicaConfig) GetID() string
- func (m *ReplicaConfig) GetProtocolPort() int32
- func (m *ReplicaConfig) Marshal() (dAtA []byte, err error)
- func (m *ReplicaConfig) MarshalTo(dAtA []byte) (int, error)
- func (m *ReplicaConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReplicaConfig) ProtoMessage()
- func (m *ReplicaConfig) Reset()
- func (m *ReplicaConfig) Size() (n int)
- func (m *ReplicaConfig) String() string
- func (m *ReplicaConfig) Unmarshal(dAtA []byte) error
- func (m *ReplicaConfig) XXX_DiscardUnknown()
- func (m *ReplicaConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReplicaConfig) XXX_Merge(src proto.Message)
- func (m *ReplicaConfig) XXX_Size() int
- func (m *ReplicaConfig) XXX_Unmarshal(b []byte) error
- type UnimplementedDatabaseServiceServer
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func RegisterDatabaseServiceServer ¶
func RegisterDatabaseServiceServer(s *grpc.Server, srv DatabaseServiceServer)
Types ¶
type Database ¶
type Database struct { // id is the database identifier ID DatabaseId `protobuf:"bytes,1,opt,name=id,proto3" json:"id"` // partitions is a list of partitions in the cluster Partitions []Partition `protobuf:"bytes,2,rep,name=partitions,proto3" json:"partitions"` }
Database configuration
func (*Database) Descriptor ¶
func (*Database) GetID ¶
func (m *Database) GetID() DatabaseId
func (*Database) GetPartitions ¶
func (*Database) MarshalToSizedBuffer ¶
func (*Database) ProtoMessage ¶
func (*Database) ProtoMessage()
func (*Database) XXX_DiscardUnknown ¶
func (m *Database) XXX_DiscardUnknown()
func (*Database) XXX_Marshal ¶
func (*Database) XXX_Unmarshal ¶
type DatabaseConfig ¶
type DatabaseConfig struct { // nodes is a list of database replicas Replicas []ReplicaConfig `protobuf:"bytes,1,rep,name=replicas,proto3" json:"replicas"` // partitions is a list of partitions owned by the replicas Partitions []PartitionId `protobuf:"bytes,2,rep,name=partitions,proto3" json:"partitions"` }
Database configuration
func (*DatabaseConfig) Descriptor ¶
func (*DatabaseConfig) Descriptor() ([]byte, []int)
func (*DatabaseConfig) GetPartitions ¶
func (m *DatabaseConfig) GetPartitions() []PartitionId
func (*DatabaseConfig) GetReplicas ¶
func (m *DatabaseConfig) GetReplicas() []ReplicaConfig
func (*DatabaseConfig) Marshal ¶
func (m *DatabaseConfig) Marshal() (dAtA []byte, err error)
func (*DatabaseConfig) MarshalToSizedBuffer ¶
func (m *DatabaseConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DatabaseConfig) ProtoMessage ¶
func (*DatabaseConfig) ProtoMessage()
func (*DatabaseConfig) Reset ¶
func (m *DatabaseConfig) Reset()
func (*DatabaseConfig) Size ¶
func (m *DatabaseConfig) Size() (n int)
func (*DatabaseConfig) String ¶
func (m *DatabaseConfig) String() string
func (*DatabaseConfig) Unmarshal ¶
func (m *DatabaseConfig) Unmarshal(dAtA []byte) error
func (*DatabaseConfig) XXX_DiscardUnknown ¶
func (m *DatabaseConfig) XXX_DiscardUnknown()
func (*DatabaseConfig) XXX_Marshal ¶
func (m *DatabaseConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DatabaseConfig) XXX_Merge ¶
func (m *DatabaseConfig) XXX_Merge(src proto.Message)
func (*DatabaseConfig) XXX_Size ¶
func (m *DatabaseConfig) XXX_Size() int
func (*DatabaseConfig) XXX_Unmarshal ¶
func (m *DatabaseConfig) XXX_Unmarshal(b []byte) error
type DatabaseId ¶
type DatabaseId struct { // name is the name of the database Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // namespace is the namespace to which the database belongs Namespace string `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"` }
Database identifier
func (*DatabaseId) Descriptor ¶
func (*DatabaseId) Descriptor() ([]byte, []int)
func (*DatabaseId) GetName ¶
func (m *DatabaseId) GetName() string
func (*DatabaseId) GetNamespace ¶
func (m *DatabaseId) GetNamespace() string
func (*DatabaseId) Marshal ¶
func (m *DatabaseId) Marshal() (dAtA []byte, err error)
func (*DatabaseId) MarshalToSizedBuffer ¶
func (m *DatabaseId) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*DatabaseId) ProtoMessage ¶
func (*DatabaseId) ProtoMessage()
func (*DatabaseId) Reset ¶
func (m *DatabaseId) Reset()
func (*DatabaseId) Size ¶
func (m *DatabaseId) Size() (n int)
func (*DatabaseId) String ¶
func (m *DatabaseId) String() string
func (*DatabaseId) Unmarshal ¶
func (m *DatabaseId) Unmarshal(dAtA []byte) error
func (*DatabaseId) XXX_DiscardUnknown ¶
func (m *DatabaseId) XXX_DiscardUnknown()
func (*DatabaseId) XXX_Marshal ¶
func (m *DatabaseId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DatabaseId) XXX_Merge ¶
func (m *DatabaseId) XXX_Merge(src proto.Message)
func (*DatabaseId) XXX_Size ¶
func (m *DatabaseId) XXX_Size() int
func (*DatabaseId) XXX_Unmarshal ¶
func (m *DatabaseId) XXX_Unmarshal(b []byte) error
type DatabaseServiceClient ¶
type DatabaseServiceClient interface { // GetDatabase gets a database controlled by the controller GetDatabase(ctx context.Context, in *GetDatabaseRequest, opts ...grpc.CallOption) (*GetDatabaseResponse, error) // GetDatabases gets a list of databases controlled by the controller GetDatabases(ctx context.Context, in *GetDatabasesRequest, opts ...grpc.CallOption) (*GetDatabasesResponse, error) }
DatabaseServiceClient is the client API for DatabaseService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewDatabaseServiceClient ¶
func NewDatabaseServiceClient(cc *grpc.ClientConn) DatabaseServiceClient
type DatabaseServiceServer ¶
type DatabaseServiceServer interface { // GetDatabase gets a database controlled by the controller GetDatabase(context.Context, *GetDatabaseRequest) (*GetDatabaseResponse, error) // GetDatabases gets a list of databases controlled by the controller GetDatabases(context.Context, *GetDatabasesRequest) (*GetDatabasesResponse, error) }
DatabaseServiceServer is the server API for DatabaseService service.
type GetDatabaseRequest ¶
type GetDatabaseRequest struct {
ID DatabaseId `protobuf:"bytes,1,opt,name=id,proto3" json:"id"`
}
Gets a database in a namespace
func (*GetDatabaseRequest) Descriptor ¶
func (*GetDatabaseRequest) Descriptor() ([]byte, []int)
func (*GetDatabaseRequest) GetID ¶
func (m *GetDatabaseRequest) GetID() DatabaseId
func (*GetDatabaseRequest) Marshal ¶
func (m *GetDatabaseRequest) Marshal() (dAtA []byte, err error)
func (*GetDatabaseRequest) MarshalTo ¶
func (m *GetDatabaseRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetDatabaseRequest) MarshalToSizedBuffer ¶
func (m *GetDatabaseRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetDatabaseRequest) ProtoMessage ¶
func (*GetDatabaseRequest) ProtoMessage()
func (*GetDatabaseRequest) Reset ¶
func (m *GetDatabaseRequest) Reset()
func (*GetDatabaseRequest) Size ¶
func (m *GetDatabaseRequest) Size() (n int)
func (*GetDatabaseRequest) String ¶
func (m *GetDatabaseRequest) String() string
func (*GetDatabaseRequest) Unmarshal ¶
func (m *GetDatabaseRequest) Unmarshal(dAtA []byte) error
func (*GetDatabaseRequest) XXX_DiscardUnknown ¶
func (m *GetDatabaseRequest) XXX_DiscardUnknown()
func (*GetDatabaseRequest) XXX_Marshal ¶
func (m *GetDatabaseRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetDatabaseRequest) XXX_Merge ¶
func (m *GetDatabaseRequest) XXX_Merge(src proto.Message)
func (*GetDatabaseRequest) XXX_Size ¶
func (m *GetDatabaseRequest) XXX_Size() int
func (*GetDatabaseRequest) XXX_Unmarshal ¶
func (m *GetDatabaseRequest) XXX_Unmarshal(b []byte) error
type GetDatabaseResponse ¶
type GetDatabaseResponse struct {
Database *Database `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"`
}
Returns a database in a namespace
func (*GetDatabaseResponse) Descriptor ¶
func (*GetDatabaseResponse) Descriptor() ([]byte, []int)
func (*GetDatabaseResponse) GetDatabase ¶
func (m *GetDatabaseResponse) GetDatabase() *Database
func (*GetDatabaseResponse) Marshal ¶
func (m *GetDatabaseResponse) Marshal() (dAtA []byte, err error)
func (*GetDatabaseResponse) MarshalTo ¶
func (m *GetDatabaseResponse) MarshalTo(dAtA []byte) (int, error)
func (*GetDatabaseResponse) MarshalToSizedBuffer ¶
func (m *GetDatabaseResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetDatabaseResponse) ProtoMessage ¶
func (*GetDatabaseResponse) ProtoMessage()
func (*GetDatabaseResponse) Reset ¶
func (m *GetDatabaseResponse) Reset()
func (*GetDatabaseResponse) Size ¶
func (m *GetDatabaseResponse) Size() (n int)
func (*GetDatabaseResponse) String ¶
func (m *GetDatabaseResponse) String() string
func (*GetDatabaseResponse) Unmarshal ¶
func (m *GetDatabaseResponse) Unmarshal(dAtA []byte) error
func (*GetDatabaseResponse) XXX_DiscardUnknown ¶
func (m *GetDatabaseResponse) XXX_DiscardUnknown()
func (*GetDatabaseResponse) XXX_Marshal ¶
func (m *GetDatabaseResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetDatabaseResponse) XXX_Merge ¶
func (m *GetDatabaseResponse) XXX_Merge(src proto.Message)
func (*GetDatabaseResponse) XXX_Size ¶
func (m *GetDatabaseResponse) XXX_Size() int
func (*GetDatabaseResponse) XXX_Unmarshal ¶
func (m *GetDatabaseResponse) XXX_Unmarshal(b []byte) error
type GetDatabasesRequest ¶
type GetDatabasesRequest struct {
Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
}
Gets a list of databases in a namespace
func (*GetDatabasesRequest) Descriptor ¶
func (*GetDatabasesRequest) Descriptor() ([]byte, []int)
func (*GetDatabasesRequest) GetNamespace ¶
func (m *GetDatabasesRequest) GetNamespace() string
func (*GetDatabasesRequest) Marshal ¶
func (m *GetDatabasesRequest) Marshal() (dAtA []byte, err error)
func (*GetDatabasesRequest) MarshalTo ¶
func (m *GetDatabasesRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetDatabasesRequest) MarshalToSizedBuffer ¶
func (m *GetDatabasesRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetDatabasesRequest) ProtoMessage ¶
func (*GetDatabasesRequest) ProtoMessage()
func (*GetDatabasesRequest) Reset ¶
func (m *GetDatabasesRequest) Reset()
func (*GetDatabasesRequest) Size ¶
func (m *GetDatabasesRequest) Size() (n int)
func (*GetDatabasesRequest) String ¶
func (m *GetDatabasesRequest) String() string
func (*GetDatabasesRequest) Unmarshal ¶
func (m *GetDatabasesRequest) Unmarshal(dAtA []byte) error
func (*GetDatabasesRequest) XXX_DiscardUnknown ¶
func (m *GetDatabasesRequest) XXX_DiscardUnknown()
func (*GetDatabasesRequest) XXX_Marshal ¶
func (m *GetDatabasesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetDatabasesRequest) XXX_Merge ¶
func (m *GetDatabasesRequest) XXX_Merge(src proto.Message)
func (*GetDatabasesRequest) XXX_Size ¶
func (m *GetDatabasesRequest) XXX_Size() int
func (*GetDatabasesRequest) XXX_Unmarshal ¶
func (m *GetDatabasesRequest) XXX_Unmarshal(b []byte) error
type GetDatabasesResponse ¶
type GetDatabasesResponse struct {
Databases []Database `protobuf:"bytes,1,rep,name=databases,proto3" json:"databases"`
}
Returns a list of databases in a namespace
func (*GetDatabasesResponse) Descriptor ¶
func (*GetDatabasesResponse) Descriptor() ([]byte, []int)
func (*GetDatabasesResponse) GetDatabases ¶
func (m *GetDatabasesResponse) GetDatabases() []Database
func (*GetDatabasesResponse) Marshal ¶
func (m *GetDatabasesResponse) Marshal() (dAtA []byte, err error)
func (*GetDatabasesResponse) MarshalTo ¶
func (m *GetDatabasesResponse) MarshalTo(dAtA []byte) (int, error)
func (*GetDatabasesResponse) MarshalToSizedBuffer ¶
func (m *GetDatabasesResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetDatabasesResponse) ProtoMessage ¶
func (*GetDatabasesResponse) ProtoMessage()
func (*GetDatabasesResponse) Reset ¶
func (m *GetDatabasesResponse) Reset()
func (*GetDatabasesResponse) Size ¶
func (m *GetDatabasesResponse) Size() (n int)
func (*GetDatabasesResponse) String ¶
func (m *GetDatabasesResponse) String() string
func (*GetDatabasesResponse) Unmarshal ¶
func (m *GetDatabasesResponse) Unmarshal(dAtA []byte) error
func (*GetDatabasesResponse) XXX_DiscardUnknown ¶
func (m *GetDatabasesResponse) XXX_DiscardUnknown()
func (*GetDatabasesResponse) XXX_Marshal ¶
func (m *GetDatabasesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetDatabasesResponse) XXX_Merge ¶
func (m *GetDatabasesResponse) XXX_Merge(src proto.Message)
func (*GetDatabasesResponse) XXX_Size ¶
func (m *GetDatabasesResponse) XXX_Size() int
func (*GetDatabasesResponse) XXX_Unmarshal ¶
func (m *GetDatabasesResponse) XXX_Unmarshal(b []byte) error
type Partition ¶
type Partition struct { PartitionID PartitionId `protobuf:"bytes,1,opt,name=partition_id,json=partitionId,proto3" json:"partition_id"` Endpoints []PartitionEndpoint `protobuf:"bytes,2,rep,name=endpoints,proto3" json:"endpoints"` }
Partition info
func (*Partition) Descriptor ¶
func (*Partition) GetEndpoints ¶
func (m *Partition) GetEndpoints() []PartitionEndpoint
func (*Partition) GetPartitionID ¶
func (m *Partition) GetPartitionID() PartitionId
func (*Partition) MarshalToSizedBuffer ¶
func (*Partition) ProtoMessage ¶
func (*Partition) ProtoMessage()
func (*Partition) XXX_DiscardUnknown ¶
func (m *Partition) XXX_DiscardUnknown()
func (*Partition) XXX_Marshal ¶
func (*Partition) XXX_Unmarshal ¶
type PartitionEndpoint ¶
type PartitionEndpoint struct { Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"` Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"` }
Partition endpoint
func (*PartitionEndpoint) Descriptor ¶
func (*PartitionEndpoint) Descriptor() ([]byte, []int)
func (*PartitionEndpoint) GetHost ¶
func (m *PartitionEndpoint) GetHost() string
func (*PartitionEndpoint) GetPort ¶
func (m *PartitionEndpoint) GetPort() int32
func (*PartitionEndpoint) Marshal ¶
func (m *PartitionEndpoint) Marshal() (dAtA []byte, err error)
func (*PartitionEndpoint) MarshalTo ¶
func (m *PartitionEndpoint) MarshalTo(dAtA []byte) (int, error)
func (*PartitionEndpoint) MarshalToSizedBuffer ¶
func (m *PartitionEndpoint) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PartitionEndpoint) ProtoMessage ¶
func (*PartitionEndpoint) ProtoMessage()
func (*PartitionEndpoint) Reset ¶
func (m *PartitionEndpoint) Reset()
func (*PartitionEndpoint) Size ¶
func (m *PartitionEndpoint) Size() (n int)
func (*PartitionEndpoint) String ¶
func (m *PartitionEndpoint) String() string
func (*PartitionEndpoint) Unmarshal ¶
func (m *PartitionEndpoint) Unmarshal(dAtA []byte) error
func (*PartitionEndpoint) XXX_DiscardUnknown ¶
func (m *PartitionEndpoint) XXX_DiscardUnknown()
func (*PartitionEndpoint) XXX_Marshal ¶
func (m *PartitionEndpoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PartitionEndpoint) XXX_Merge ¶
func (m *PartitionEndpoint) XXX_Merge(src proto.Message)
func (*PartitionEndpoint) XXX_Size ¶
func (m *PartitionEndpoint) XXX_Size() int
func (*PartitionEndpoint) XXX_Unmarshal ¶
func (m *PartitionEndpoint) XXX_Unmarshal(b []byte) error
type PartitionId ¶
type PartitionId struct {
Partition int32 `protobuf:"varint,1,opt,name=partition,proto3" json:"partition,omitempty"`
}
Partition identifier
func (*PartitionId) Descriptor ¶
func (*PartitionId) Descriptor() ([]byte, []int)
func (*PartitionId) GetPartition ¶
func (m *PartitionId) GetPartition() int32
func (*PartitionId) Marshal ¶
func (m *PartitionId) Marshal() (dAtA []byte, err error)
func (*PartitionId) MarshalToSizedBuffer ¶
func (m *PartitionId) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PartitionId) ProtoMessage ¶
func (*PartitionId) ProtoMessage()
func (*PartitionId) Reset ¶
func (m *PartitionId) Reset()
func (*PartitionId) Size ¶
func (m *PartitionId) Size() (n int)
func (*PartitionId) String ¶
func (m *PartitionId) String() string
func (*PartitionId) Unmarshal ¶
func (m *PartitionId) Unmarshal(dAtA []byte) error
func (*PartitionId) XXX_DiscardUnknown ¶
func (m *PartitionId) XXX_DiscardUnknown()
func (*PartitionId) XXX_Marshal ¶
func (m *PartitionId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PartitionId) XXX_Merge ¶
func (m *PartitionId) XXX_Merge(src proto.Message)
func (*PartitionId) XXX_Size ¶
func (m *PartitionId) XXX_Size() int
func (*PartitionId) XXX_Unmarshal ¶
func (m *PartitionId) XXX_Unmarshal(b []byte) error
type ReplicaConfig ¶
type ReplicaConfig struct { // id is the unique member identifier ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // host is the member host Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"` // api_port is the port to use for the client API APIPort int32 `protobuf:"varint,3,opt,name=api_port,json=apiPort,proto3" json:"apiPort"` // protocol_port is the port to use for intra-cluster communication ProtocolPort int32 `protobuf:"varint,4,opt,name=protocol_port,json=protocolPort,proto3" json:"protocolPort"` }
Replica configuration
func (*ReplicaConfig) Descriptor ¶
func (*ReplicaConfig) Descriptor() ([]byte, []int)
func (*ReplicaConfig) GetAPIPort ¶
func (m *ReplicaConfig) GetAPIPort() int32
func (*ReplicaConfig) GetHost ¶
func (m *ReplicaConfig) GetHost() string
func (*ReplicaConfig) GetID ¶
func (m *ReplicaConfig) GetID() string
func (*ReplicaConfig) GetProtocolPort ¶
func (m *ReplicaConfig) GetProtocolPort() int32
func (*ReplicaConfig) Marshal ¶
func (m *ReplicaConfig) Marshal() (dAtA []byte, err error)
func (*ReplicaConfig) MarshalToSizedBuffer ¶
func (m *ReplicaConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaConfig) ProtoMessage ¶
func (*ReplicaConfig) ProtoMessage()
func (*ReplicaConfig) Reset ¶
func (m *ReplicaConfig) Reset()
func (*ReplicaConfig) Size ¶
func (m *ReplicaConfig) Size() (n int)
func (*ReplicaConfig) String ¶
func (m *ReplicaConfig) String() string
func (*ReplicaConfig) Unmarshal ¶
func (m *ReplicaConfig) Unmarshal(dAtA []byte) error
func (*ReplicaConfig) XXX_DiscardUnknown ¶
func (m *ReplicaConfig) XXX_DiscardUnknown()
func (*ReplicaConfig) XXX_Marshal ¶
func (m *ReplicaConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReplicaConfig) XXX_Merge ¶
func (m *ReplicaConfig) XXX_Merge(src proto.Message)
func (*ReplicaConfig) XXX_Size ¶
func (m *ReplicaConfig) XXX_Size() int
func (*ReplicaConfig) XXX_Unmarshal ¶
func (m *ReplicaConfig) XXX_Unmarshal(b []byte) error
type UnimplementedDatabaseServiceServer ¶
type UnimplementedDatabaseServiceServer struct { }
UnimplementedDatabaseServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedDatabaseServiceServer) GetDatabase ¶
func (*UnimplementedDatabaseServiceServer) GetDatabase(ctx context.Context, req *GetDatabaseRequest) (*GetDatabaseResponse, error)
func (*UnimplementedDatabaseServiceServer) GetDatabases ¶
func (*UnimplementedDatabaseServiceServer) GetDatabases(ctx context.Context, req *GetDatabasesRequest) (*GetDatabasesResponse, error)
Click to show internal directories.
Click to hide internal directories.