Versions in this module Expand all Collapse all v0 v0.1.0 Mar 11, 2020 Changes in this version + func RegisterControllerServiceServer(s *grpc.Server, srv ControllerServiceServer) + type Cluster struct + ID *ClusterId + Partitions []*PartitionId + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Cluster) Descriptor() ([]byte, []int) + func (*Cluster) ProtoMessage() + func (m *Cluster) GetID() *ClusterId + func (m *Cluster) GetPartitions() []*PartitionId + func (m *Cluster) Reset() + func (m *Cluster) String() string + func (m *Cluster) XXX_DiscardUnknown() + func (m *Cluster) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Cluster) XXX_Merge(src proto.Message) + func (m *Cluster) XXX_Size() int + func (m *Cluster) XXX_Unmarshal(b []byte) error + type ClusterConfig struct + Members []*MemberConfig + Partitions []*PartitionId + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ClusterConfig) Descriptor() ([]byte, []int) + func (*ClusterConfig) ProtoMessage() + func (m *ClusterConfig) GetMembers() []*MemberConfig + func (m *ClusterConfig) GetPartitions() []*PartitionId + func (m *ClusterConfig) Reset() + func (m *ClusterConfig) String() string + func (m *ClusterConfig) XXX_DiscardUnknown() + func (m *ClusterConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ClusterConfig) XXX_Merge(src proto.Message) + func (m *ClusterConfig) XXX_Size() int + func (m *ClusterConfig) XXX_Unmarshal(b []byte) error + type ClusterId struct + DatabaseID *DatabaseId + ID int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ClusterId) Descriptor() ([]byte, []int) + func (*ClusterId) ProtoMessage() + func (m *ClusterId) GetDatabaseID() *DatabaseId + func (m *ClusterId) GetID() int32 + func (m *ClusterId) Reset() + func (m *ClusterId) String() string + func (m *ClusterId) XXX_DiscardUnknown() + func (m *ClusterId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ClusterId) XXX_Merge(src proto.Message) + func (m *ClusterId) XXX_Size() int + func (m *ClusterId) XXX_Unmarshal(b []byte) error + type ControllerServiceClient interface + CreatePartitionGroup func(ctx context.Context, in *CreatePartitionGroupRequest, opts ...grpc.CallOption) (*CreatePartitionGroupResponse, error) + DeletePartitionGroup func(ctx context.Context, in *DeletePartitionGroupRequest, opts ...grpc.CallOption) (*DeletePartitionGroupResponse, error) + EnterElection func(ctx context.Context, in *PartitionElectionRequest, opts ...grpc.CallOption) (ControllerService_EnterElectionClient, error) + GetDatabases func(ctx context.Context, in *GetDatabasesRequest, opts ...grpc.CallOption) (*GetDatabasesResponse, error) + GetPartitionGroups func(ctx context.Context, in *GetPartitionGroupsRequest, opts ...grpc.CallOption) (*GetPartitionGroupsResponse, error) + func NewControllerServiceClient(cc *grpc.ClientConn) ControllerServiceClient + type ControllerServiceServer interface + CreatePartitionGroup func(context.Context, *CreatePartitionGroupRequest) (*CreatePartitionGroupResponse, error) + DeletePartitionGroup func(context.Context, *DeletePartitionGroupRequest) (*DeletePartitionGroupResponse, error) + EnterElection func(*PartitionElectionRequest, ControllerService_EnterElectionServer) error + GetDatabases func(context.Context, *GetDatabasesRequest) (*GetDatabasesResponse, error) + GetPartitionGroups func(context.Context, *GetPartitionGroupsRequest) (*GetPartitionGroupsResponse, error) + type ControllerService_EnterElectionClient interface + Recv func() (*PartitionElectionResponse, error) + type ControllerService_EnterElectionServer interface + Send func(*PartitionElectionResponse) error + type CreatePartitionGroupRequest struct + ID *PartitionGroupId + Spec *PartitionGroupSpec + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreatePartitionGroupRequest) Descriptor() ([]byte, []int) + func (*CreatePartitionGroupRequest) ProtoMessage() + func (m *CreatePartitionGroupRequest) GetID() *PartitionGroupId + func (m *CreatePartitionGroupRequest) GetSpec() *PartitionGroupSpec + func (m *CreatePartitionGroupRequest) Reset() + func (m *CreatePartitionGroupRequest) String() string + func (m *CreatePartitionGroupRequest) XXX_DiscardUnknown() + func (m *CreatePartitionGroupRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreatePartitionGroupRequest) XXX_Merge(src proto.Message) + func (m *CreatePartitionGroupRequest) XXX_Size() int + func (m *CreatePartitionGroupRequest) XXX_Unmarshal(b []byte) error + type CreatePartitionGroupResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*CreatePartitionGroupResponse) Descriptor() ([]byte, []int) + func (*CreatePartitionGroupResponse) ProtoMessage() + func (m *CreatePartitionGroupResponse) Reset() + func (m *CreatePartitionGroupResponse) String() string + func (m *CreatePartitionGroupResponse) XXX_DiscardUnknown() + func (m *CreatePartitionGroupResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *CreatePartitionGroupResponse) XXX_Merge(src proto.Message) + func (m *CreatePartitionGroupResponse) XXX_Size() int + func (m *CreatePartitionGroupResponse) XXX_Unmarshal(b []byte) error + type Database struct + ID *DatabaseId + Partitions []*Partition + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Database) Descriptor() ([]byte, []int) + func (*Database) ProtoMessage() + func (m *Database) GetID() *DatabaseId + func (m *Database) GetPartitions() []*Partition + func (m *Database) Reset() + func (m *Database) String() string + 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 DatabaseId struct + Name string + Namespace string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DatabaseId) Descriptor() ([]byte, []int) + func (*DatabaseId) ProtoMessage() + func (m *DatabaseId) GetName() string + func (m *DatabaseId) GetNamespace() string + func (m *DatabaseId) Reset() + func (m *DatabaseId) String() string + 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 DeletePartitionGroupRequest struct + ID *PartitionGroupId + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeletePartitionGroupRequest) Descriptor() ([]byte, []int) + func (*DeletePartitionGroupRequest) ProtoMessage() + func (m *DeletePartitionGroupRequest) GetID() *PartitionGroupId + func (m *DeletePartitionGroupRequest) Reset() + func (m *DeletePartitionGroupRequest) String() string + func (m *DeletePartitionGroupRequest) XXX_DiscardUnknown() + func (m *DeletePartitionGroupRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeletePartitionGroupRequest) XXX_Merge(src proto.Message) + func (m *DeletePartitionGroupRequest) XXX_Size() int + func (m *DeletePartitionGroupRequest) XXX_Unmarshal(b []byte) error + type DeletePartitionGroupResponse struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*DeletePartitionGroupResponse) Descriptor() ([]byte, []int) + func (*DeletePartitionGroupResponse) ProtoMessage() + func (m *DeletePartitionGroupResponse) Reset() + func (m *DeletePartitionGroupResponse) String() string + func (m *DeletePartitionGroupResponse) XXX_DiscardUnknown() + func (m *DeletePartitionGroupResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *DeletePartitionGroupResponse) XXX_Merge(src proto.Message) + func (m *DeletePartitionGroupResponse) XXX_Size() int + func (m *DeletePartitionGroupResponse) XXX_Unmarshal(b []byte) error + type GetDatabasesRequest struct + ID *DatabaseId + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetDatabasesRequest) Descriptor() ([]byte, []int) + func (*GetDatabasesRequest) ProtoMessage() + func (m *GetDatabasesRequest) GetID() *DatabaseId + func (m *GetDatabasesRequest) Reset() + func (m *GetDatabasesRequest) String() string + 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 struct + Databases []*Database + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetDatabasesResponse) Descriptor() ([]byte, []int) + func (*GetDatabasesResponse) ProtoMessage() + func (m *GetDatabasesResponse) GetDatabases() []*Database + func (m *GetDatabasesResponse) Reset() + func (m *GetDatabasesResponse) String() string + 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 GetPartitionGroupsRequest struct + ID *PartitionGroupId + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetPartitionGroupsRequest) Descriptor() ([]byte, []int) + func (*GetPartitionGroupsRequest) ProtoMessage() + func (m *GetPartitionGroupsRequest) GetID() *PartitionGroupId + func (m *GetPartitionGroupsRequest) Reset() + func (m *GetPartitionGroupsRequest) String() string + func (m *GetPartitionGroupsRequest) XXX_DiscardUnknown() + func (m *GetPartitionGroupsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetPartitionGroupsRequest) XXX_Merge(src proto.Message) + func (m *GetPartitionGroupsRequest) XXX_Size() int + func (m *GetPartitionGroupsRequest) XXX_Unmarshal(b []byte) error + type GetPartitionGroupsResponse struct + Groups []*PartitionGroup + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*GetPartitionGroupsResponse) Descriptor() ([]byte, []int) + func (*GetPartitionGroupsResponse) ProtoMessage() + func (m *GetPartitionGroupsResponse) GetGroups() []*PartitionGroup + func (m *GetPartitionGroupsResponse) Reset() + func (m *GetPartitionGroupsResponse) String() string + func (m *GetPartitionGroupsResponse) XXX_DiscardUnknown() + func (m *GetPartitionGroupsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *GetPartitionGroupsResponse) XXX_Merge(src proto.Message) + func (m *GetPartitionGroupsResponse) XXX_Size() int + func (m *GetPartitionGroupsResponse) XXX_Unmarshal(b []byte) error + type MemberConfig struct + APIPort int32 + Host string + ID string + ProtocolPort int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MemberConfig) Descriptor() ([]byte, []int) + func (*MemberConfig) ProtoMessage() + func (m *MemberConfig) GetAPIPort() int32 + func (m *MemberConfig) GetHost() string + func (m *MemberConfig) GetID() string + func (m *MemberConfig) GetProtocolPort() int32 + func (m *MemberConfig) Reset() + func (m *MemberConfig) String() string + func (m *MemberConfig) XXX_DiscardUnknown() + func (m *MemberConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MemberConfig) XXX_Merge(src proto.Message) + func (m *MemberConfig) XXX_Size() int + func (m *MemberConfig) XXX_Unmarshal(b []byte) error + type NodeConfig struct + APIPort int32 + Host string + ID string + Port int32 + ProtocolPort int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*NodeConfig) Descriptor() ([]byte, []int) + func (*NodeConfig) ProtoMessage() + func (m *NodeConfig) GetAPIPort() int32 + func (m *NodeConfig) GetHost() string + func (m *NodeConfig) GetID() string + func (m *NodeConfig) GetPort() int32 + func (m *NodeConfig) GetProtocolPort() int32 + func (m *NodeConfig) Reset() + func (m *NodeConfig) String() string + func (m *NodeConfig) XXX_DiscardUnknown() + func (m *NodeConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *NodeConfig) XXX_Merge(src proto.Message) + func (m *NodeConfig) XXX_Size() int + func (m *NodeConfig) XXX_Unmarshal(b []byte) error + type Partition struct + Endpoints []*PartitionEndpoint + PartitionID int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Partition) Descriptor() ([]byte, []int) + func (*Partition) ProtoMessage() + func (m *Partition) GetEndpoints() []*PartitionEndpoint + func (m *Partition) GetPartitionID() int32 + func (m *Partition) Reset() + func (m *Partition) String() string + 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 PartitionConfig struct + Controller *NodeConfig + Members []*NodeConfig + Partition *PartitionId + Partitions []*PartitionId + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PartitionConfig) Descriptor() ([]byte, []int) + func (*PartitionConfig) ProtoMessage() + func (m *PartitionConfig) GetController() *NodeConfig + func (m *PartitionConfig) GetMembers() []*NodeConfig + func (m *PartitionConfig) GetPartition() *PartitionId + func (m *PartitionConfig) GetPartitions() []*PartitionId + func (m *PartitionConfig) Reset() + func (m *PartitionConfig) String() string + func (m *PartitionConfig) XXX_DiscardUnknown() + func (m *PartitionConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PartitionConfig) XXX_Merge(src proto.Message) + func (m *PartitionConfig) XXX_Size() int + func (m *PartitionConfig) XXX_Unmarshal(b []byte) error + type PartitionElectionRequest struct + Member string + PartitionID *PartitionId + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PartitionElectionRequest) Descriptor() ([]byte, []int) + func (*PartitionElectionRequest) ProtoMessage() + func (m *PartitionElectionRequest) GetMember() string + func (m *PartitionElectionRequest) GetPartitionID() *PartitionId + func (m *PartitionElectionRequest) Reset() + func (m *PartitionElectionRequest) String() string + func (m *PartitionElectionRequest) XXX_DiscardUnknown() + func (m *PartitionElectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PartitionElectionRequest) XXX_Merge(src proto.Message) + func (m *PartitionElectionRequest) XXX_Size() int + func (m *PartitionElectionRequest) XXX_Unmarshal(b []byte) error + type PartitionElectionResponse struct + Term *PrimaryTerm + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PartitionElectionResponse) Descriptor() ([]byte, []int) + func (*PartitionElectionResponse) ProtoMessage() + func (m *PartitionElectionResponse) GetTerm() *PrimaryTerm + func (m *PartitionElectionResponse) Reset() + func (m *PartitionElectionResponse) String() string + func (m *PartitionElectionResponse) XXX_DiscardUnknown() + func (m *PartitionElectionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PartitionElectionResponse) XXX_Merge(src proto.Message) + func (m *PartitionElectionResponse) XXX_Size() int + func (m *PartitionElectionResponse) XXX_Unmarshal(b []byte) error + type PartitionEndpoint struct + Host string + Port int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PartitionEndpoint) Descriptor() ([]byte, []int) + func (*PartitionEndpoint) ProtoMessage() + func (m *PartitionEndpoint) GetHost() string + func (m *PartitionEndpoint) GetPort() int32 + func (m *PartitionEndpoint) Reset() + func (m *PartitionEndpoint) String() string + 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 PartitionGroup struct + ID *PartitionGroupId + Partitions []*Partition + Spec *PartitionGroupSpec + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PartitionGroup) Descriptor() ([]byte, []int) + func (*PartitionGroup) ProtoMessage() + func (m *PartitionGroup) GetID() *PartitionGroupId + func (m *PartitionGroup) GetPartitions() []*Partition + func (m *PartitionGroup) GetSpec() *PartitionGroupSpec + func (m *PartitionGroup) Reset() + func (m *PartitionGroup) String() string + func (m *PartitionGroup) XXX_DiscardUnknown() + func (m *PartitionGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PartitionGroup) XXX_Merge(src proto.Message) + func (m *PartitionGroup) XXX_Size() int + func (m *PartitionGroup) XXX_Unmarshal(b []byte) error + type PartitionGroupId struct + Name string + Namespace string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PartitionGroupId) Descriptor() ([]byte, []int) + func (*PartitionGroupId) ProtoMessage() + func (m *PartitionGroupId) GetName() string + func (m *PartitionGroupId) GetNamespace() string + func (m *PartitionGroupId) Reset() + func (m *PartitionGroupId) String() string + func (m *PartitionGroupId) XXX_DiscardUnknown() + func (m *PartitionGroupId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PartitionGroupId) XXX_Merge(src proto.Message) + func (m *PartitionGroupId) XXX_Size() int + func (m *PartitionGroupId) XXX_Unmarshal(b []byte) error + type PartitionGroupSpec struct + PartitionSize uint32 + Partitions uint32 + Protocol *types.Any + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PartitionGroupSpec) Descriptor() ([]byte, []int) + func (*PartitionGroupSpec) ProtoMessage() + func (m *PartitionGroupSpec) GetPartitionSize() uint32 + func (m *PartitionGroupSpec) GetPartitions() uint32 + func (m *PartitionGroupSpec) GetProtocol() *types.Any + func (m *PartitionGroupSpec) Reset() + func (m *PartitionGroupSpec) String() string + func (m *PartitionGroupSpec) XXX_DiscardUnknown() + func (m *PartitionGroupSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PartitionGroupSpec) XXX_Merge(src proto.Message) + func (m *PartitionGroupSpec) XXX_Size() int + func (m *PartitionGroupSpec) XXX_Unmarshal(b []byte) error + type PartitionId struct + Cluster *ClusterId + Group *PartitionGroupId + Partition int32 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PartitionId) Descriptor() ([]byte, []int) + func (*PartitionId) ProtoMessage() + func (m *PartitionId) GetCluster() *ClusterId + func (m *PartitionId) GetGroup() *PartitionGroupId + func (m *PartitionId) GetPartition() int32 + func (m *PartitionId) Reset() + func (m *PartitionId) String() string + 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 PrimaryTerm struct + Candidates []string + Primary string + Term int64 + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*PrimaryTerm) Descriptor() ([]byte, []int) + func (*PrimaryTerm) ProtoMessage() + func (m *PrimaryTerm) GetCandidates() []string + func (m *PrimaryTerm) GetPrimary() string + func (m *PrimaryTerm) GetTerm() int64 + func (m *PrimaryTerm) Reset() + func (m *PrimaryTerm) String() string + func (m *PrimaryTerm) XXX_DiscardUnknown() + func (m *PrimaryTerm) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *PrimaryTerm) XXX_Merge(src proto.Message) + func (m *PrimaryTerm) XXX_Size() int + func (m *PrimaryTerm) XXX_Unmarshal(b []byte) error + type UnimplementedControllerServiceServer struct + func (*UnimplementedControllerServiceServer) CreatePartitionGroup(ctx context.Context, req *CreatePartitionGroupRequest) (*CreatePartitionGroupResponse, error) + func (*UnimplementedControllerServiceServer) DeletePartitionGroup(ctx context.Context, req *DeletePartitionGroupRequest) (*DeletePartitionGroupResponse, error) + func (*UnimplementedControllerServiceServer) EnterElection(req *PartitionElectionRequest, srv ControllerService_EnterElectionServer) error + func (*UnimplementedControllerServiceServer) GetDatabases(ctx context.Context, req *GetDatabasesRequest) (*GetDatabasesResponse, error) + func (*UnimplementedControllerServiceServer) GetPartitionGroups(ctx context.Context, req *GetPartitionGroupsRequest) (*GetPartitionGroupsResponse, error)