controller

package
v0.0.0-...-4e5fb1c Latest Latest
Warning

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

 Go to latest Published: Jan 23, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterControllerServiceServer 

func RegisterControllerServiceServer(s *grpc.Server, srv ControllerServiceServer)

Types

type ControllerServiceClient 

type ControllerServiceClient interface {
	// Creates a partition group
	CreatePartitionGroup(ctx context.Context, in *CreatePartitionGroupRequest, opts ...grpc.CallOption) (*CreatePartitionGroupResponse, error)
	// Deletes a partition group
	DeletePartitionGroup(ctx context.Context, in *DeletePartitionGroupRequest, opts ...grpc.CallOption) (*DeletePartitionGroupResponse, error)
	// Gets a list of active partition groups
	GetPartitionGroups(ctx context.Context, in *GetPartitionGroupsRequest, opts ...grpc.CallOption) (*GetPartitionGroupsResponse, error)
	// Enters a primary election for a specific partition
	EnterElection(ctx context.Context, in *PartitionElectionRequest, opts ...grpc.CallOption) (ControllerService_EnterElectionClient, error)
}

ControllerServiceClient is the client API for ControllerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewControllerServiceClient 

func NewControllerServiceClient(cc *grpc.ClientConn) ControllerServiceClient

type ControllerServiceServer 

type ControllerServiceServer interface {
	// Creates a partition group
	CreatePartitionGroup(context.Context, *CreatePartitionGroupRequest) (*CreatePartitionGroupResponse, error)
	// Deletes a partition group
	DeletePartitionGroup(context.Context, *DeletePartitionGroupRequest) (*DeletePartitionGroupResponse, error)
	// Gets a list of active partition groups
	GetPartitionGroups(context.Context, *GetPartitionGroupsRequest) (*GetPartitionGroupsResponse, error)
	// Enters a primary election for a specific partition
	EnterElection(*PartitionElectionRequest, ControllerService_EnterElectionServer) error
}

ControllerServiceServer is the server API for ControllerService service.

type ControllerService_EnterElectionClient 

type ControllerService_EnterElectionClient interface {
	Recv() (*PartitionElectionResponse, error)
	grpc.ClientStream
}

type ControllerService_EnterElectionServer 

type ControllerService_EnterElectionServer interface {
	Send(*PartitionElectionResponse) error
	grpc.ServerStream
}

type CreatePartitionGroupRequest 

type CreatePartitionGroupRequest struct {
	ID                   *PartitionGroupId   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Spec                 *PartitionGroupSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

Creates a new partition group

func (*CreatePartitionGroupRequest) Descriptor 

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

func (*CreatePartitionGroupRequest) GetID 

func (m *CreatePartitionGroupRequest) GetID() *PartitionGroupId

func (*CreatePartitionGroupRequest) GetSpec 

func (m *CreatePartitionGroupRequest) GetSpec() *PartitionGroupSpec

func (*CreatePartitionGroupRequest) ProtoMessage 

func (*CreatePartitionGroupRequest) ProtoMessage()

func (*CreatePartitionGroupRequest) Reset 

func (m *CreatePartitionGroupRequest) Reset()

func (*CreatePartitionGroupRequest) String 

func (m *CreatePartitionGroupRequest) String() string

func (*CreatePartitionGroupRequest) XXX_DiscardUnknown 

func (m *CreatePartitionGroupRequest) XXX_DiscardUnknown()

func (*CreatePartitionGroupRequest) XXX_Marshal 

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

func (*CreatePartitionGroupRequest) XXX_Merge 

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

func (*CreatePartitionGroupRequest) XXX_Size 

func (m *CreatePartitionGroupRequest) XXX_Size() int

func (*CreatePartitionGroupRequest) XXX_Unmarshal 

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

type CreatePartitionGroupResponse 

type CreatePartitionGroupResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Returns the status of a partition group

func (*CreatePartitionGroupResponse) Descriptor 

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

func (*CreatePartitionGroupResponse) ProtoMessage 

func (*CreatePartitionGroupResponse) ProtoMessage()

func (*CreatePartitionGroupResponse) Reset 

func (m *CreatePartitionGroupResponse) Reset()

func (*CreatePartitionGroupResponse) String 

func (m *CreatePartitionGroupResponse) String() string

func (*CreatePartitionGroupResponse) XXX_DiscardUnknown 

func (m *CreatePartitionGroupResponse) XXX_DiscardUnknown()

func (*CreatePartitionGroupResponse) XXX_Marshal 

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

func (*CreatePartitionGroupResponse) XXX_Merge 

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

func (*CreatePartitionGroupResponse) XXX_Size 

func (m *CreatePartitionGroupResponse) XXX_Size() int

func (*CreatePartitionGroupResponse) XXX_Unmarshal 

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

type DeletePartitionGroupRequest 

type DeletePartitionGroupRequest struct {
	ID                   *PartitionGroupId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Deletes a partition group

func (*DeletePartitionGroupRequest) Descriptor 

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

func (*DeletePartitionGroupRequest) GetID 

func (m *DeletePartitionGroupRequest) GetID() *PartitionGroupId

func (*DeletePartitionGroupRequest) ProtoMessage 

func (*DeletePartitionGroupRequest) ProtoMessage()

func (*DeletePartitionGroupRequest) Reset 

func (m *DeletePartitionGroupRequest) Reset()

func (*DeletePartitionGroupRequest) String 

func (m *DeletePartitionGroupRequest) String() string

func (*DeletePartitionGroupRequest) XXX_DiscardUnknown 

func (m *DeletePartitionGroupRequest) XXX_DiscardUnknown()

func (*DeletePartitionGroupRequest) XXX_Marshal 

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

func (*DeletePartitionGroupRequest) XXX_Merge 

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

func (*DeletePartitionGroupRequest) XXX_Size 

func (m *DeletePartitionGroupRequest) XXX_Size() int

func (*DeletePartitionGroupRequest) XXX_Unmarshal 

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

type DeletePartitionGroupResponse 

type DeletePartitionGroupResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Returns the result of deleting a partition group

func (*DeletePartitionGroupResponse) Descriptor 

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

func (*DeletePartitionGroupResponse) ProtoMessage 

func (*DeletePartitionGroupResponse) ProtoMessage()

func (*DeletePartitionGroupResponse) Reset 

func (m *DeletePartitionGroupResponse) Reset()

func (*DeletePartitionGroupResponse) String 

func (m *DeletePartitionGroupResponse) String() string

func (*DeletePartitionGroupResponse) XXX_DiscardUnknown 

func (m *DeletePartitionGroupResponse) XXX_DiscardUnknown()

func (*DeletePartitionGroupResponse) XXX_Marshal 

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

func (*DeletePartitionGroupResponse) XXX_Merge 

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

func (*DeletePartitionGroupResponse) XXX_Size 

func (m *DeletePartitionGroupResponse) XXX_Size() int

func (*DeletePartitionGroupResponse) XXX_Unmarshal 

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

type GetPartitionGroupsRequest 

type GetPartitionGroupsRequest struct {
	ID                   *PartitionGroupId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Gets a list of partition groups in the given namespace

func (*GetPartitionGroupsRequest) Descriptor 

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

func (*GetPartitionGroupsRequest) GetID 

func (m *GetPartitionGroupsRequest) GetID() *PartitionGroupId

func (*GetPartitionGroupsRequest) ProtoMessage 

func (*GetPartitionGroupsRequest) ProtoMessage()

func (*GetPartitionGroupsRequest) Reset 

func (m *GetPartitionGroupsRequest) Reset()

func (*GetPartitionGroupsRequest) String 

func (m *GetPartitionGroupsRequest) String() string

func (*GetPartitionGroupsRequest) XXX_DiscardUnknown 

func (m *GetPartitionGroupsRequest) XXX_DiscardUnknown()

func (*GetPartitionGroupsRequest) XXX_Marshal 

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

func (*GetPartitionGroupsRequest) XXX_Merge 

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

func (*GetPartitionGroupsRequest) XXX_Size 

func (m *GetPartitionGroupsRequest) XXX_Size() int

func (*GetPartitionGroupsRequest) XXX_Unmarshal 

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

type GetPartitionGroupsResponse 

type GetPartitionGroupsResponse struct {
	Groups               []*PartitionGroup `protobuf:"bytes,1,rep,name=groups,proto3" json:"groups,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Returns a list of partition groups

func (*GetPartitionGroupsResponse) Descriptor 

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

func (*GetPartitionGroupsResponse) GetGroups 

func (m *GetPartitionGroupsResponse) GetGroups() []*PartitionGroup

func (*GetPartitionGroupsResponse) ProtoMessage 

func (*GetPartitionGroupsResponse) ProtoMessage()

func (*GetPartitionGroupsResponse) Reset 

func (m *GetPartitionGroupsResponse) Reset()

func (*GetPartitionGroupsResponse) String 

func (m *GetPartitionGroupsResponse) String() string

func (*GetPartitionGroupsResponse) XXX_DiscardUnknown 

func (m *GetPartitionGroupsResponse) XXX_DiscardUnknown()

func (*GetPartitionGroupsResponse) XXX_Marshal 

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

func (*GetPartitionGroupsResponse) XXX_Merge 

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

func (*GetPartitionGroupsResponse) XXX_Size 

func (m *GetPartitionGroupsResponse) XXX_Size() int

func (*GetPartitionGroupsResponse) XXX_Unmarshal 

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

type NodeConfig 

type NodeConfig struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Host                 string   `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	Port                 int32    `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	APIPort              int32    `protobuf:"varint,4,opt,name=api_port,json=apiPort,proto3" json:"apiPort"`
	ProtocolPort         int32    `protobuf:"varint,5,opt,name=protocol_port,json=protocolPort,proto3" json:"protocolPort"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Node configuration

func (*NodeConfig) Descriptor 

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

func (*NodeConfig) GetAPIPort 

func (m *NodeConfig) GetAPIPort() int32

func (*NodeConfig) GetHost 

func (m *NodeConfig) GetHost() string

func (*NodeConfig) GetID 

func (m *NodeConfig) GetID() string

func (*NodeConfig) GetPort 

func (m *NodeConfig) GetPort() int32

func (*NodeConfig) GetProtocolPort 

func (m *NodeConfig) GetProtocolPort() int32

func (*NodeConfig) ProtoMessage 

func (*NodeConfig) ProtoMessage()

func (*NodeConfig) Reset 

func (m *NodeConfig) Reset()

func (*NodeConfig) String 

func (m *NodeConfig) String() string

func (*NodeConfig) XXX_DiscardUnknown 

func (m *NodeConfig) XXX_DiscardUnknown()

func (*NodeConfig) XXX_Marshal 

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

func (*NodeConfig) XXX_Merge 

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

func (*NodeConfig) XXX_Size 

func (m *NodeConfig) XXX_Size() int

func (*NodeConfig) XXX_Unmarshal 

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

type Partition 

type Partition struct {
	PartitionID          int32                `protobuf:"varint,1,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	Endpoints            []*PartitionEndpoint `protobuf:"bytes,2,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Partition info

func (*Partition) Descriptor 

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

func (*Partition) GetEndpoints 

func (m *Partition) GetEndpoints() []*PartitionEndpoint

func (*Partition) GetPartitionID 

func (m *Partition) GetPartitionID() int32

func (*Partition) ProtoMessage 

func (*Partition) ProtoMessage()

func (*Partition) Reset 

func (m *Partition) Reset()

func (*Partition) String 

func (m *Partition) String() string

func (*Partition) XXX_DiscardUnknown 

func (m *Partition) XXX_DiscardUnknown()

func (*Partition) XXX_Marshal 

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

func (*Partition) XXX_Merge 

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

func (*Partition) XXX_Size 

func (m *Partition) XXX_Size() int

func (*Partition) XXX_Unmarshal 

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

type PartitionConfig 

type PartitionConfig struct {
	Partition            *PartitionId  `protobuf:"bytes,1,opt,name=partition,proto3" json:"partition,omitempty"`
	Controller           *NodeConfig   `protobuf:"bytes,2,opt,name=controller,proto3" json:"controller,omitempty"`
	Members              []*NodeConfig `protobuf:"bytes,3,rep,name=members,proto3" json:"members,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

Partition configuration

func (*PartitionConfig) Descriptor 

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

func (*PartitionConfig) GetController 

func (m *PartitionConfig) GetController() *NodeConfig

func (*PartitionConfig) GetMembers 

func (m *PartitionConfig) GetMembers() []*NodeConfig

func (*PartitionConfig) GetPartition 

func (m *PartitionConfig) GetPartition() *PartitionId

func (*PartitionConfig) ProtoMessage 

func (*PartitionConfig) ProtoMessage()

func (*PartitionConfig) Reset 

func (m *PartitionConfig) Reset()

func (*PartitionConfig) String 

func (m *PartitionConfig) String() string

func (*PartitionConfig) XXX_DiscardUnknown 

func (m *PartitionConfig) XXX_DiscardUnknown()

func (*PartitionConfig) XXX_Marshal 

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

func (*PartitionConfig) XXX_Merge 

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

func (*PartitionConfig) XXX_Size 

func (m *PartitionConfig) XXX_Size() int

func (*PartitionConfig) XXX_Unmarshal 

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

type PartitionElectionRequest 

type PartitionElectionRequest struct {
	PartitionID          *PartitionId `protobuf:"bytes,1,opt,name=partition_id,json=partitionId,proto3" json:"partition_id,omitempty"`
	Member               string       `protobuf:"bytes,2,opt,name=member,proto3" json:"member,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Enters a primary election

func (*PartitionElectionRequest) Descriptor 

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

func (*PartitionElectionRequest) GetMember 

func (m *PartitionElectionRequest) GetMember() string

func (*PartitionElectionRequest) GetPartitionID 

func (m *PartitionElectionRequest) GetPartitionID() *PartitionId

func (*PartitionElectionRequest) ProtoMessage 

func (*PartitionElectionRequest) ProtoMessage()

func (*PartitionElectionRequest) Reset 

func (m *PartitionElectionRequest) Reset()

func (*PartitionElectionRequest) String 

func (m *PartitionElectionRequest) String() string

func (*PartitionElectionRequest) XXX_DiscardUnknown 

func (m *PartitionElectionRequest) XXX_DiscardUnknown()

func (*PartitionElectionRequest) XXX_Marshal 

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

func (*PartitionElectionRequest) XXX_Merge 

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

func (*PartitionElectionRequest) XXX_Size 

func (m *PartitionElectionRequest) XXX_Size() int

func (*PartitionElectionRequest) XXX_Unmarshal 

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

type PartitionElectionResponse 

type PartitionElectionResponse struct {
	Term                 *PrimaryTerm `protobuf:"bytes,1,opt,name=term,proto3" json:"term,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Enter response

func (*PartitionElectionResponse) Descriptor 

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

func (*PartitionElectionResponse) GetTerm 

func (m *PartitionElectionResponse) GetTerm() *PrimaryTerm

func (*PartitionElectionResponse) ProtoMessage 

func (*PartitionElectionResponse) ProtoMessage()

func (*PartitionElectionResponse) Reset 

func (m *PartitionElectionResponse) Reset()

func (*PartitionElectionResponse) String 

func (m *PartitionElectionResponse) String() string

func (*PartitionElectionResponse) XXX_DiscardUnknown 

func (m *PartitionElectionResponse) XXX_DiscardUnknown()

func (*PartitionElectionResponse) XXX_Marshal 

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

func (*PartitionElectionResponse) XXX_Merge 

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

func (*PartitionElectionResponse) XXX_Size 

func (m *PartitionElectionResponse) XXX_Size() int

func (*PartitionElectionResponse) XXX_Unmarshal 

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

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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) ProtoMessage 

func (*PartitionEndpoint) ProtoMessage()

func (*PartitionEndpoint) Reset 

func (m *PartitionEndpoint) Reset()

func (*PartitionEndpoint) String 

func (m *PartitionEndpoint) String() string

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 PartitionGroup 

type PartitionGroup struct {
	ID                   *PartitionGroupId   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Spec                 *PartitionGroupSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
	Partitions           []*Partition        `protobuf:"bytes,3,rep,name=partitions,proto3" json:"partitions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

Partition group info

func (*PartitionGroup) Descriptor 

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

func (*PartitionGroup) GetID 

func (m *PartitionGroup) GetID() *PartitionGroupId

func (*PartitionGroup) GetPartitions 

func (m *PartitionGroup) GetPartitions() []*Partition

func (*PartitionGroup) GetSpec 

func (m *PartitionGroup) GetSpec() *PartitionGroupSpec

func (*PartitionGroup) ProtoMessage 

func (*PartitionGroup) ProtoMessage()

func (*PartitionGroup) Reset 

func (m *PartitionGroup) Reset()

func (*PartitionGroup) String 

func (m *PartitionGroup) String() string

func (*PartitionGroup) XXX_DiscardUnknown 

func (m *PartitionGroup) XXX_DiscardUnknown()

func (*PartitionGroup) XXX_Marshal 

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

func (*PartitionGroup) XXX_Merge 

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

func (*PartitionGroup) XXX_Size 

func (m *PartitionGroup) XXX_Size() int

func (*PartitionGroup) XXX_Unmarshal 

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

type PartitionGroupId 

type PartitionGroupId struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Namespace            string   `protobuf:"bytes,2,opt,name=namespace,proto3" json:"namespace,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Partition group name

func (*PartitionGroupId) Descriptor 

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

func (*PartitionGroupId) GetName 

func (m *PartitionGroupId) GetName() string

func (*PartitionGroupId) GetNamespace 

func (m *PartitionGroupId) GetNamespace() string

func (*PartitionGroupId) ProtoMessage 

func (*PartitionGroupId) ProtoMessage()

func (*PartitionGroupId) Reset 

func (m *PartitionGroupId) Reset()

func (*PartitionGroupId) String 

func (m *PartitionGroupId) String() string

func (*PartitionGroupId) XXX_DiscardUnknown 

func (m *PartitionGroupId) XXX_DiscardUnknown()

func (*PartitionGroupId) XXX_Marshal 

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

func (*PartitionGroupId) XXX_Merge 

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

func (*PartitionGroupId) XXX_Size 

func (m *PartitionGroupId) XXX_Size() int

func (*PartitionGroupId) XXX_Unmarshal 

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

type PartitionGroupSpec 

type PartitionGroupSpec struct {
	Partitions           uint32     `protobuf:"varint,1,opt,name=partitions,proto3" json:"partitions,omitempty"`
	PartitionSize        uint32     `protobuf:"varint,2,opt,name=partition_size,json=partitionSize,proto3" json:"partition_size,omitempty"`
	Protocol             *types.Any `protobuf:"bytes,3,opt,name=protocol,proto3" json:"protocol,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

Partition group specification

func (*PartitionGroupSpec) Descriptor 

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

func (*PartitionGroupSpec) GetPartitionSize 

func (m *PartitionGroupSpec) GetPartitionSize() uint32

func (*PartitionGroupSpec) GetPartitions 

func (m *PartitionGroupSpec) GetPartitions() uint32

func (*PartitionGroupSpec) GetProtocol 

func (m *PartitionGroupSpec) GetProtocol() *types.Any

func (*PartitionGroupSpec) ProtoMessage 

func (*PartitionGroupSpec) ProtoMessage()

func (*PartitionGroupSpec) Reset 

func (m *PartitionGroupSpec) Reset()

func (*PartitionGroupSpec) String 

func (m *PartitionGroupSpec) String() string

func (*PartitionGroupSpec) XXX_DiscardUnknown 

func (m *PartitionGroupSpec) XXX_DiscardUnknown()

func (*PartitionGroupSpec) XXX_Marshal 

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

func (*PartitionGroupSpec) XXX_Merge 

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

func (*PartitionGroupSpec) XXX_Size 

func (m *PartitionGroupSpec) XXX_Size() int

func (*PartitionGroupSpec) XXX_Unmarshal 

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

type PartitionId 

type PartitionId struct {
	Partition            int32             `protobuf:"varint,1,opt,name=partition,proto3" json:"partition,omitempty"`
	Group                *PartitionGroupId `protobuf:"bytes,2,opt,name=group,proto3" json:"group,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

Partition identifier

func (*PartitionId) Descriptor 

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

func (*PartitionId) GetGroup 

func (m *PartitionId) GetGroup() *PartitionGroupId

func (*PartitionId) GetPartition 

func (m *PartitionId) GetPartition() int32

func (*PartitionId) ProtoMessage 

func (*PartitionId) ProtoMessage()

func (*PartitionId) Reset 

func (m *PartitionId) Reset()

func (*PartitionId) String 

func (m *PartitionId) String() string

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 PrimaryTerm 

type PrimaryTerm struct {
	Term                 int64    `protobuf:"varint,1,opt,name=term,proto3" json:"term,omitempty"`
	Primary              string   `protobuf:"bytes,2,opt,name=primary,proto3" json:"primary,omitempty"`
	Candidates           []string `protobuf:"bytes,3,rep,name=candidates,proto3" json:"candidates,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Primary term

func (*PrimaryTerm) Descriptor 

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

func (*PrimaryTerm) GetCandidates 

func (m *PrimaryTerm) GetCandidates() []string

func (*PrimaryTerm) GetPrimary 

func (m *PrimaryTerm) GetPrimary() string

func (*PrimaryTerm) GetTerm 

func (m *PrimaryTerm) GetTerm() int64

func (*PrimaryTerm) ProtoMessage 

func (*PrimaryTerm) ProtoMessage()

func (*PrimaryTerm) Reset 

func (m *PrimaryTerm) Reset()

func (*PrimaryTerm) String 

func (m *PrimaryTerm) String() string

func (*PrimaryTerm) XXX_DiscardUnknown 

func (m *PrimaryTerm) XXX_DiscardUnknown()

func (*PrimaryTerm) XXX_Marshal 

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

func (*PrimaryTerm) XXX_Merge 

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

func (*PrimaryTerm) XXX_Size 

func (m *PrimaryTerm) XXX_Size() int

func (*PrimaryTerm) XXX_Unmarshal 

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

type UnimplementedControllerServiceServer 

type UnimplementedControllerServiceServer struct {
}

UnimplementedControllerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedControllerServiceServer) CreatePartitionGroup 

func (*UnimplementedControllerServiceServer) CreatePartitionGroup(ctx context.Context, req *CreatePartitionGroupRequest) (*CreatePartitionGroupResponse, error)

func (*UnimplementedControllerServiceServer) DeletePartitionGroup 

func (*UnimplementedControllerServiceServer) DeletePartitionGroup(ctx context.Context, req *DeletePartitionGroupRequest) (*DeletePartitionGroupResponse, error)

func (*UnimplementedControllerServiceServer) EnterElection 

func (*UnimplementedControllerServiceServer) EnterElection(req *PartitionElectionRequest, srv ControllerService_EnterElectionServer) error

func (*UnimplementedControllerServiceServer) GetPartitionGroups 

func (*UnimplementedControllerServiceServer) GetPartitionGroups(ctx context.Context, req *GetPartitionGroupsRequest) (*GetPartitionGroupsResponse, 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.