clusterproto

Documentation

Overview

Package clusterproto contains the generate gRPC code

Index

• func RegisterClusterLeaderServiceServer(s *grpc.Server, srv ClusterLeaderServiceServer)
• type ClusterLeaderServiceClient
  • func NewClusterLeaderServiceClient(cc *grpc.ClientConn) ClusterLeaderServiceClient
• type ClusterLeaderServiceServer
• type CommitShardMapMessage
  • func (*CommitShardMapMessage) Descriptor() ([]byte, []int)
  • func (m *CommitShardMapMessage) GetNodes() []string
  • func (m *CommitShardMapMessage) GetShardMapLogIndex() int64
  • func (*CommitShardMapMessage) ProtoMessage()
  • func (m *CommitShardMapMessage) Reset()
  • func (m *CommitShardMapMessage) String() string
  • func (m *CommitShardMapMessage) XXX_DiscardUnknown()
  • func (m *CommitShardMapMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *CommitShardMapMessage) XXX_Merge(src proto.Message)
  • func (m *CommitShardMapMessage) XXX_Size() int
  • func (m *CommitShardMapMessage) XXX_Unmarshal(b []byte) error
• type ConfirmShardMapRequest
  • func (*ConfirmShardMapRequest) Descriptor() ([]byte, []int)
  • func (m *ConfirmShardMapRequest) GetLogIndex() int64
  • func (m *ConfirmShardMapRequest) GetNodeID() string
  • func (*ConfirmShardMapRequest) ProtoMessage()
  • func (m *ConfirmShardMapRequest) Reset()
  • func (m *ConfirmShardMapRequest) String() string
  • func (m *ConfirmShardMapRequest) XXX_DiscardUnknown()
  • func (m *ConfirmShardMapRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ConfirmShardMapRequest) XXX_Merge(src proto.Message)
  • func (m *ConfirmShardMapRequest) XXX_Size() int
  • func (m *ConfirmShardMapRequest) XXX_Unmarshal(b []byte) error
• type ConfirmShardMapResponse
  • func (*ConfirmShardMapResponse) Descriptor() ([]byte, []int)
  • func (m *ConfirmShardMapResponse) GetCurrentIndex() int64
  • func (m *ConfirmShardMapResponse) GetSuccess() bool
  • func (*ConfirmShardMapResponse) ProtoMessage()
  • func (m *ConfirmShardMapResponse) Reset()
  • func (m *ConfirmShardMapResponse) String() string
  • func (m *ConfirmShardMapResponse) XXX_DiscardUnknown()
  • func (m *ConfirmShardMapResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ConfirmShardMapResponse) XXX_Merge(src proto.Message)
  • func (m *ConfirmShardMapResponse) XXX_Size() int
  • func (m *ConfirmShardMapResponse) XXX_Unmarshal(b []byte) error

Functions

func RegisterClusterLeaderServiceServer

func RegisterClusterLeaderServiceServer(s *grpc.Server, srv ClusterLeaderServiceServer)

Types

type ClusterLeaderServiceClient

type ClusterLeaderServiceClient interface {
	ConfirmShardMap(ctx context.Context, in *ConfirmShardMapRequest, opts ...grpc.CallOption) (*ConfirmShardMapResponse, error)
}

ClusterLeaderServiceClient is the client API for ClusterLeaderService service.

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

func NewClusterLeaderServiceClient

func NewClusterLeaderServiceClient(cc *grpc.ClientConn) ClusterLeaderServiceClient

type ClusterLeaderServiceServer

type ClusterLeaderServiceServer interface {
	ConfirmShardMap(context.Context, *ConfirmShardMapRequest) (*ConfirmShardMapResponse, error)
}

ClusterLeaderServiceServer is the server API for ClusterLeaderService service.

type CommitShardMapMessage

type CommitShardMapMessage struct {
	ShardMapLogIndex     int64    `protobuf:"varint,1,opt,name=ShardMapLogIndex,proto3" json:"ShardMapLogIndex,omitempty"`
	Nodes                []string `protobuf:"bytes,2,rep,name=Nodes,proto3" json:"Nodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CommitShardMapMessage is sent when the shard map is committed by the leader and all nodes have acknowledged the new shard map. The message contains the nodes in the cluster for the commited map.

func (*CommitShardMapMessage) Descriptor

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

func (*CommitShardMapMessage) GetNodes

func (m *CommitShardMapMessage) GetNodes() []string

func (*CommitShardMapMessage) GetShardMapLogIndex

func (m *CommitShardMapMessage) GetShardMapLogIndex() int64

func (*CommitShardMapMessage) ProtoMessage

func (*CommitShardMapMessage) ProtoMessage()

func (*CommitShardMapMessage) Reset

func (m *CommitShardMapMessage) Reset()

func (*CommitShardMapMessage) String

func (m *CommitShardMapMessage) String() string

func (*CommitShardMapMessage) XXX_DiscardUnknown

func (m *CommitShardMapMessage) XXX_DiscardUnknown()

func (*CommitShardMapMessage) XXX_Marshal

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

func (*CommitShardMapMessage) XXX_Merge

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

func (*CommitShardMapMessage) XXX_Size

func (m *CommitShardMapMessage) XXX_Size() int

func (*CommitShardMapMessage) XXX_Unmarshal

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

type ConfirmShardMapRequest

type ConfirmShardMapRequest struct {
	LogIndex             int64    `protobuf:"varint,1,opt,name=LogIndex,proto3" json:"LogIndex,omitempty"`
	NodeID               string   `protobuf:"bytes,2,opt,name=NodeID,proto3" json:"NodeID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ConfirmShardMapRequest is sent by followers to the leader to signal readyness with the new shard map

func (*ConfirmShardMapRequest) Descriptor

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

func (*ConfirmShardMapRequest) GetLogIndex

func (m *ConfirmShardMapRequest) GetLogIndex() int64

func (*ConfirmShardMapRequest) GetNodeID

func (m *ConfirmShardMapRequest) GetNodeID() string

func (*ConfirmShardMapRequest) ProtoMessage

func (*ConfirmShardMapRequest) ProtoMessage()

func (*ConfirmShardMapRequest) Reset

func (m *ConfirmShardMapRequest) Reset()

func (*ConfirmShardMapRequest) String

func (m *ConfirmShardMapRequest) String() string

func (*ConfirmShardMapRequest) XXX_DiscardUnknown

func (m *ConfirmShardMapRequest) XXX_DiscardUnknown()

func (*ConfirmShardMapRequest) XXX_Marshal

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

func (*ConfirmShardMapRequest) XXX_Merge

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

func (*ConfirmShardMapRequest) XXX_Size

func (m *ConfirmShardMapRequest) XXX_Size() int

func (*ConfirmShardMapRequest) XXX_Unmarshal

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

type ConfirmShardMapResponse

type ConfirmShardMapResponse struct {
	Success              bool     `protobuf:"varint,1,opt,name=Success,proto3" json:"Success,omitempty"`
	CurrentIndex         int64    `protobuf:"varint,2,opt,name=CurrentIndex,proto3" json:"CurrentIndex,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ConfirmShardMapResponse is sent as a response from the leader to the followers.

func (*ConfirmShardMapResponse) Descriptor

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

func (*ConfirmShardMapResponse) GetCurrentIndex

func (m *ConfirmShardMapResponse) GetCurrentIndex() int64

func (*ConfirmShardMapResponse) GetSuccess

func (m *ConfirmShardMapResponse) GetSuccess() bool

func (*ConfirmShardMapResponse) ProtoMessage

func (*ConfirmShardMapResponse) ProtoMessage()

func (*ConfirmShardMapResponse) Reset

func (m *ConfirmShardMapResponse) Reset()

func (*ConfirmShardMapResponse) String

func (m *ConfirmShardMapResponse) String() string

func (*ConfirmShardMapResponse) XXX_DiscardUnknown

func (m *ConfirmShardMapResponse) XXX_DiscardUnknown()

func (*ConfirmShardMapResponse) XXX_Marshal

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

func (*ConfirmShardMapResponse) XXX_Merge

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

func (*ConfirmShardMapResponse) XXX_Size

func (m *ConfirmShardMapResponse) XXX_Size() int

func (*ConfirmShardMapResponse) XXX_Unmarshal

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