Documentation ¶
Index ¶
- Variables
- func RegisterReplicaServiceServer(s *grpc.Server, srv ReplicaServiceServer)
- type GetReplicaAckIndexRequest
- func (*GetReplicaAckIndexRequest) Descriptor() ([]byte, []int)
- func (m *GetReplicaAckIndexRequest) GetDatabase() string
- func (m *GetReplicaAckIndexRequest) GetFamilyTime() int64
- func (m *GetReplicaAckIndexRequest) GetLeader() int32
- func (m *GetReplicaAckIndexRequest) GetShard() int32
- func (m *GetReplicaAckIndexRequest) Marshal() (dAtA []byte, err error)
- func (m *GetReplicaAckIndexRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetReplicaAckIndexRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetReplicaAckIndexRequest) ProtoMessage()
- func (m *GetReplicaAckIndexRequest) Reset()
- func (m *GetReplicaAckIndexRequest) Size() (n int)
- func (m *GetReplicaAckIndexRequest) String() string
- func (m *GetReplicaAckIndexRequest) Unmarshal(dAtA []byte) error
- func (m *GetReplicaAckIndexRequest) XXX_DiscardUnknown()
- func (m *GetReplicaAckIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetReplicaAckIndexRequest) XXX_Merge(src proto.Message)
- func (m *GetReplicaAckIndexRequest) XXX_Size() int
- func (m *GetReplicaAckIndexRequest) XXX_Unmarshal(b []byte) error
- type GetReplicaAckIndexResponse
- func (*GetReplicaAckIndexResponse) Descriptor() ([]byte, []int)
- func (m *GetReplicaAckIndexResponse) GetAckIndex() int64
- func (m *GetReplicaAckIndexResponse) Marshal() (dAtA []byte, err error)
- func (m *GetReplicaAckIndexResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetReplicaAckIndexResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetReplicaAckIndexResponse) ProtoMessage()
- func (m *GetReplicaAckIndexResponse) Reset()
- func (m *GetReplicaAckIndexResponse) Size() (n int)
- func (m *GetReplicaAckIndexResponse) String() string
- func (m *GetReplicaAckIndexResponse) Unmarshal(dAtA []byte) error
- func (m *GetReplicaAckIndexResponse) XXX_DiscardUnknown()
- func (m *GetReplicaAckIndexResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetReplicaAckIndexResponse) XXX_Merge(src proto.Message)
- func (m *GetReplicaAckIndexResponse) XXX_Size() int
- func (m *GetReplicaAckIndexResponse) XXX_Unmarshal(b []byte) error
- type ReplicaRequest
- func (*ReplicaRequest) Descriptor() ([]byte, []int)
- func (m *ReplicaRequest) GetRecord() []byte
- func (m *ReplicaRequest) GetReplicaIndex() int64
- func (m *ReplicaRequest) Marshal() (dAtA []byte, err error)
- func (m *ReplicaRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ReplicaRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReplicaRequest) ProtoMessage()
- func (m *ReplicaRequest) Reset()
- func (m *ReplicaRequest) Size() (n int)
- func (m *ReplicaRequest) String() string
- func (m *ReplicaRequest) Unmarshal(dAtA []byte) error
- func (m *ReplicaRequest) XXX_DiscardUnknown()
- func (m *ReplicaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReplicaRequest) XXX_Merge(src proto.Message)
- func (m *ReplicaRequest) XXX_Size() int
- func (m *ReplicaRequest) XXX_Unmarshal(b []byte) error
- type ReplicaResponse
- func (*ReplicaResponse) Descriptor() ([]byte, []int)
- func (m *ReplicaResponse) GetAckIndex() int64
- func (m *ReplicaResponse) GetDatabase() string
- func (m *ReplicaResponse) GetErr() string
- func (m *ReplicaResponse) GetLeader() int32
- func (m *ReplicaResponse) GetReplicaIndex() int64
- func (m *ReplicaResponse) GetResponseTime() int64
- func (m *ReplicaResponse) GetShard() int32
- func (m *ReplicaResponse) Marshal() (dAtA []byte, err error)
- func (m *ReplicaResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ReplicaResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReplicaResponse) ProtoMessage()
- func (m *ReplicaResponse) Reset()
- func (m *ReplicaResponse) Size() (n int)
- func (m *ReplicaResponse) String() string
- func (m *ReplicaResponse) Unmarshal(dAtA []byte) error
- func (m *ReplicaResponse) XXX_DiscardUnknown()
- func (m *ReplicaResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReplicaResponse) XXX_Merge(src proto.Message)
- func (m *ReplicaResponse) XXX_Size() int
- func (m *ReplicaResponse) XXX_Unmarshal(b []byte) error
- type ReplicaServiceClient
- type ReplicaServiceServer
- type ReplicaService_ReplicaClient
- type ReplicaService_ReplicaServer
- type ResetIndexRequest
- func (*ResetIndexRequest) Descriptor() ([]byte, []int)
- func (m *ResetIndexRequest) GetAppendIndex() int64
- func (m *ResetIndexRequest) GetDatabase() string
- func (m *ResetIndexRequest) GetFamilyTime() int64
- func (m *ResetIndexRequest) GetLeader() int32
- func (m *ResetIndexRequest) GetShard() int32
- func (m *ResetIndexRequest) Marshal() (dAtA []byte, err error)
- func (m *ResetIndexRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ResetIndexRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ResetIndexRequest) ProtoMessage()
- func (m *ResetIndexRequest) Reset()
- func (m *ResetIndexRequest) Size() (n int)
- func (m *ResetIndexRequest) String() string
- func (m *ResetIndexRequest) Unmarshal(dAtA []byte) error
- func (m *ResetIndexRequest) XXX_DiscardUnknown()
- func (m *ResetIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ResetIndexRequest) XXX_Merge(src proto.Message)
- func (m *ResetIndexRequest) XXX_Size() int
- func (m *ResetIndexRequest) XXX_Unmarshal(b []byte) error
- type ResetIndexResponse
- func (*ResetIndexResponse) Descriptor() ([]byte, []int)
- func (m *ResetIndexResponse) Marshal() (dAtA []byte, err error)
- func (m *ResetIndexResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ResetIndexResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ResetIndexResponse) ProtoMessage()
- func (m *ResetIndexResponse) Reset()
- func (m *ResetIndexResponse) Size() (n int)
- func (m *ResetIndexResponse) String() string
- func (m *ResetIndexResponse) Unmarshal(dAtA []byte) error
- func (m *ResetIndexResponse) XXX_DiscardUnknown()
- func (m *ResetIndexResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ResetIndexResponse) XXX_Merge(src proto.Message)
- func (m *ResetIndexResponse) XXX_Size() int
- func (m *ResetIndexResponse) XXX_Unmarshal(b []byte) error
- type UnimplementedReplicaServiceServer
- func (*UnimplementedReplicaServiceServer) GetReplicaAckIndex(ctx context.Context, req *GetReplicaAckIndexRequest) (*GetReplicaAckIndexResponse, error)
- func (*UnimplementedReplicaServiceServer) Replica(srv ReplicaService_ReplicaServer) error
- func (*UnimplementedReplicaServiceServer) Reset(ctx context.Context, req *ResetIndexRequest) (*ResetIndexResponse, error)
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func RegisterReplicaServiceServer ¶
func RegisterReplicaServiceServer(s *grpc.Server, srv ReplicaServiceServer)
Types ¶
type GetReplicaAckIndexRequest ¶
type GetReplicaAckIndexRequest struct { Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"` Shard int32 `protobuf:"varint,2,opt,name=shard,proto3" json:"shard,omitempty"` Leader int32 `protobuf:"varint,3,opt,name=leader,proto3" json:"leader,omitempty"` FamilyTime int64 `protobuf:"varint,4,opt,name=familyTime,proto3" json:"familyTime,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetReplicaAckIndexRequest) Descriptor ¶
func (*GetReplicaAckIndexRequest) Descriptor() ([]byte, []int)
func (*GetReplicaAckIndexRequest) GetDatabase ¶
func (m *GetReplicaAckIndexRequest) GetDatabase() string
func (*GetReplicaAckIndexRequest) GetFamilyTime ¶
func (m *GetReplicaAckIndexRequest) GetFamilyTime() int64
func (*GetReplicaAckIndexRequest) GetLeader ¶
func (m *GetReplicaAckIndexRequest) GetLeader() int32
func (*GetReplicaAckIndexRequest) GetShard ¶
func (m *GetReplicaAckIndexRequest) GetShard() int32
func (*GetReplicaAckIndexRequest) Marshal ¶
func (m *GetReplicaAckIndexRequest) Marshal() (dAtA []byte, err error)
func (*GetReplicaAckIndexRequest) MarshalTo ¶
func (m *GetReplicaAckIndexRequest) MarshalTo(dAtA []byte) (int, error)
func (*GetReplicaAckIndexRequest) MarshalToSizedBuffer ¶
func (m *GetReplicaAckIndexRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetReplicaAckIndexRequest) ProtoMessage ¶
func (*GetReplicaAckIndexRequest) ProtoMessage()
func (*GetReplicaAckIndexRequest) Reset ¶
func (m *GetReplicaAckIndexRequest) Reset()
func (*GetReplicaAckIndexRequest) Size ¶
func (m *GetReplicaAckIndexRequest) Size() (n int)
func (*GetReplicaAckIndexRequest) String ¶
func (m *GetReplicaAckIndexRequest) String() string
func (*GetReplicaAckIndexRequest) Unmarshal ¶
func (m *GetReplicaAckIndexRequest) Unmarshal(dAtA []byte) error
func (*GetReplicaAckIndexRequest) XXX_DiscardUnknown ¶
func (m *GetReplicaAckIndexRequest) XXX_DiscardUnknown()
func (*GetReplicaAckIndexRequest) XXX_Marshal ¶
func (m *GetReplicaAckIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetReplicaAckIndexRequest) XXX_Merge ¶
func (m *GetReplicaAckIndexRequest) XXX_Merge(src proto.Message)
func (*GetReplicaAckIndexRequest) XXX_Size ¶
func (m *GetReplicaAckIndexRequest) XXX_Size() int
func (*GetReplicaAckIndexRequest) XXX_Unmarshal ¶
func (m *GetReplicaAckIndexRequest) XXX_Unmarshal(b []byte) error
type GetReplicaAckIndexResponse ¶
type GetReplicaAckIndexResponse struct { AckIndex int64 `protobuf:"varint,5,opt,name=ackIndex,proto3" json:"ackIndex,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*GetReplicaAckIndexResponse) Descriptor ¶
func (*GetReplicaAckIndexResponse) Descriptor() ([]byte, []int)
func (*GetReplicaAckIndexResponse) GetAckIndex ¶
func (m *GetReplicaAckIndexResponse) GetAckIndex() int64
func (*GetReplicaAckIndexResponse) Marshal ¶
func (m *GetReplicaAckIndexResponse) Marshal() (dAtA []byte, err error)
func (*GetReplicaAckIndexResponse) MarshalTo ¶
func (m *GetReplicaAckIndexResponse) MarshalTo(dAtA []byte) (int, error)
func (*GetReplicaAckIndexResponse) MarshalToSizedBuffer ¶
func (m *GetReplicaAckIndexResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetReplicaAckIndexResponse) ProtoMessage ¶
func (*GetReplicaAckIndexResponse) ProtoMessage()
func (*GetReplicaAckIndexResponse) Reset ¶
func (m *GetReplicaAckIndexResponse) Reset()
func (*GetReplicaAckIndexResponse) Size ¶
func (m *GetReplicaAckIndexResponse) Size() (n int)
func (*GetReplicaAckIndexResponse) String ¶
func (m *GetReplicaAckIndexResponse) String() string
func (*GetReplicaAckIndexResponse) Unmarshal ¶
func (m *GetReplicaAckIndexResponse) Unmarshal(dAtA []byte) error
func (*GetReplicaAckIndexResponse) XXX_DiscardUnknown ¶
func (m *GetReplicaAckIndexResponse) XXX_DiscardUnknown()
func (*GetReplicaAckIndexResponse) XXX_Marshal ¶
func (m *GetReplicaAckIndexResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetReplicaAckIndexResponse) XXX_Merge ¶
func (m *GetReplicaAckIndexResponse) XXX_Merge(src proto.Message)
func (*GetReplicaAckIndexResponse) XXX_Size ¶
func (m *GetReplicaAckIndexResponse) XXX_Size() int
func (*GetReplicaAckIndexResponse) XXX_Unmarshal ¶
func (m *GetReplicaAckIndexResponse) XXX_Unmarshal(b []byte) error
type ReplicaRequest ¶
type ReplicaRequest struct { ReplicaIndex int64 `protobuf:"varint,4,opt,name=replicaIndex,proto3" json:"replicaIndex,omitempty"` Record []byte `protobuf:"bytes,5,opt,name=record,proto3" json:"record,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ReplicaRequest) Descriptor ¶
func (*ReplicaRequest) Descriptor() ([]byte, []int)
func (*ReplicaRequest) GetRecord ¶
func (m *ReplicaRequest) GetRecord() []byte
func (*ReplicaRequest) GetReplicaIndex ¶
func (m *ReplicaRequest) GetReplicaIndex() int64
func (*ReplicaRequest) Marshal ¶
func (m *ReplicaRequest) Marshal() (dAtA []byte, err error)
func (*ReplicaRequest) MarshalToSizedBuffer ¶
func (m *ReplicaRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaRequest) ProtoMessage ¶
func (*ReplicaRequest) ProtoMessage()
func (*ReplicaRequest) Reset ¶
func (m *ReplicaRequest) Reset()
func (*ReplicaRequest) Size ¶
func (m *ReplicaRequest) Size() (n int)
func (*ReplicaRequest) String ¶
func (m *ReplicaRequest) String() string
func (*ReplicaRequest) Unmarshal ¶
func (m *ReplicaRequest) Unmarshal(dAtA []byte) error
func (*ReplicaRequest) XXX_DiscardUnknown ¶
func (m *ReplicaRequest) XXX_DiscardUnknown()
func (*ReplicaRequest) XXX_Marshal ¶
func (m *ReplicaRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReplicaRequest) XXX_Merge ¶
func (m *ReplicaRequest) XXX_Merge(src proto.Message)
func (*ReplicaRequest) XXX_Size ¶
func (m *ReplicaRequest) XXX_Size() int
func (*ReplicaRequest) XXX_Unmarshal ¶
func (m *ReplicaRequest) XXX_Unmarshal(b []byte) error
type ReplicaResponse ¶
type ReplicaResponse struct { Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"` Shard int32 `protobuf:"varint,2,opt,name=shard,proto3" json:"shard,omitempty"` Leader int32 `protobuf:"varint,3,opt,name=leader,proto3" json:"leader,omitempty"` ReplicaIndex int64 `protobuf:"varint,4,opt,name=replicaIndex,proto3" json:"replicaIndex,omitempty"` AckIndex int64 `protobuf:"varint,5,opt,name=ackIndex,proto3" json:"ackIndex,omitempty"` ResponseTime int64 `protobuf:"varint,6,opt,name=responseTime,proto3" json:"responseTime,omitempty"` Err string `protobuf:"bytes,7,opt,name=err,proto3" json:"err,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ReplicaResponse) Descriptor ¶
func (*ReplicaResponse) Descriptor() ([]byte, []int)
func (*ReplicaResponse) GetAckIndex ¶
func (m *ReplicaResponse) GetAckIndex() int64
func (*ReplicaResponse) GetDatabase ¶
func (m *ReplicaResponse) GetDatabase() string
func (*ReplicaResponse) GetErr ¶
func (m *ReplicaResponse) GetErr() string
func (*ReplicaResponse) GetLeader ¶
func (m *ReplicaResponse) GetLeader() int32
func (*ReplicaResponse) GetReplicaIndex ¶
func (m *ReplicaResponse) GetReplicaIndex() int64
func (*ReplicaResponse) GetResponseTime ¶
func (m *ReplicaResponse) GetResponseTime() int64
func (*ReplicaResponse) GetShard ¶
func (m *ReplicaResponse) GetShard() int32
func (*ReplicaResponse) Marshal ¶
func (m *ReplicaResponse) Marshal() (dAtA []byte, err error)
func (*ReplicaResponse) MarshalToSizedBuffer ¶
func (m *ReplicaResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReplicaResponse) ProtoMessage ¶
func (*ReplicaResponse) ProtoMessage()
func (*ReplicaResponse) Reset ¶
func (m *ReplicaResponse) Reset()
func (*ReplicaResponse) Size ¶
func (m *ReplicaResponse) Size() (n int)
func (*ReplicaResponse) String ¶
func (m *ReplicaResponse) String() string
func (*ReplicaResponse) Unmarshal ¶
func (m *ReplicaResponse) Unmarshal(dAtA []byte) error
func (*ReplicaResponse) XXX_DiscardUnknown ¶
func (m *ReplicaResponse) XXX_DiscardUnknown()
func (*ReplicaResponse) XXX_Marshal ¶
func (m *ReplicaResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReplicaResponse) XXX_Merge ¶
func (m *ReplicaResponse) XXX_Merge(src proto.Message)
func (*ReplicaResponse) XXX_Size ¶
func (m *ReplicaResponse) XXX_Size() int
func (*ReplicaResponse) XXX_Unmarshal ¶
func (m *ReplicaResponse) XXX_Unmarshal(b []byte) error
type ReplicaServiceClient ¶
type ReplicaServiceClient interface { Reset(ctx context.Context, in *ResetIndexRequest, opts ...grpc.CallOption) (*ResetIndexResponse, error) GetReplicaAckIndex(ctx context.Context, in *GetReplicaAckIndexRequest, opts ...grpc.CallOption) (*GetReplicaAckIndexResponse, error) Replica(ctx context.Context, opts ...grpc.CallOption) (ReplicaService_ReplicaClient, error) }
ReplicaServiceClient is the client API for ReplicaService service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewReplicaServiceClient ¶
func NewReplicaServiceClient(cc *grpc.ClientConn) ReplicaServiceClient
type ReplicaServiceServer ¶
type ReplicaServiceServer interface { Reset(context.Context, *ResetIndexRequest) (*ResetIndexResponse, error) GetReplicaAckIndex(context.Context, *GetReplicaAckIndexRequest) (*GetReplicaAckIndexResponse, error) Replica(ReplicaService_ReplicaServer) error }
ReplicaServiceServer is the server API for ReplicaService service.
type ReplicaService_ReplicaClient ¶
type ReplicaService_ReplicaClient interface { Send(*ReplicaRequest) error Recv() (*ReplicaResponse, error) grpc.ClientStream }
type ReplicaService_ReplicaServer ¶
type ReplicaService_ReplicaServer interface { Send(*ReplicaResponse) error Recv() (*ReplicaRequest, error) grpc.ServerStream }
type ResetIndexRequest ¶
type ResetIndexRequest struct { Database string `protobuf:"bytes,1,opt,name=database,proto3" json:"database,omitempty"` Shard int32 `protobuf:"varint,2,opt,name=shard,proto3" json:"shard,omitempty"` Leader int32 `protobuf:"varint,3,opt,name=leader,proto3" json:"leader,omitempty"` FamilyTime int64 `protobuf:"varint,4,opt,name=familyTime,proto3" json:"familyTime,omitempty"` AppendIndex int64 `protobuf:"varint,5,opt,name=appendIndex,proto3" json:"appendIndex,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ResetIndexRequest) Descriptor ¶
func (*ResetIndexRequest) Descriptor() ([]byte, []int)
func (*ResetIndexRequest) GetAppendIndex ¶
func (m *ResetIndexRequest) GetAppendIndex() int64
func (*ResetIndexRequest) GetDatabase ¶
func (m *ResetIndexRequest) GetDatabase() string
func (*ResetIndexRequest) GetFamilyTime ¶
func (m *ResetIndexRequest) GetFamilyTime() int64
func (*ResetIndexRequest) GetLeader ¶
func (m *ResetIndexRequest) GetLeader() int32
func (*ResetIndexRequest) GetShard ¶
func (m *ResetIndexRequest) GetShard() int32
func (*ResetIndexRequest) Marshal ¶
func (m *ResetIndexRequest) Marshal() (dAtA []byte, err error)
func (*ResetIndexRequest) MarshalTo ¶
func (m *ResetIndexRequest) MarshalTo(dAtA []byte) (int, error)
func (*ResetIndexRequest) MarshalToSizedBuffer ¶
func (m *ResetIndexRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResetIndexRequest) ProtoMessage ¶
func (*ResetIndexRequest) ProtoMessage()
func (*ResetIndexRequest) Reset ¶
func (m *ResetIndexRequest) Reset()
func (*ResetIndexRequest) Size ¶
func (m *ResetIndexRequest) Size() (n int)
func (*ResetIndexRequest) String ¶
func (m *ResetIndexRequest) String() string
func (*ResetIndexRequest) Unmarshal ¶
func (m *ResetIndexRequest) Unmarshal(dAtA []byte) error
func (*ResetIndexRequest) XXX_DiscardUnknown ¶
func (m *ResetIndexRequest) XXX_DiscardUnknown()
func (*ResetIndexRequest) XXX_Marshal ¶
func (m *ResetIndexRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResetIndexRequest) XXX_Merge ¶
func (m *ResetIndexRequest) XXX_Merge(src proto.Message)
func (*ResetIndexRequest) XXX_Size ¶
func (m *ResetIndexRequest) XXX_Size() int
func (*ResetIndexRequest) XXX_Unmarshal ¶
func (m *ResetIndexRequest) XXX_Unmarshal(b []byte) error
type ResetIndexResponse ¶
type ResetIndexResponse struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*ResetIndexResponse) Descriptor ¶
func (*ResetIndexResponse) Descriptor() ([]byte, []int)
func (*ResetIndexResponse) Marshal ¶
func (m *ResetIndexResponse) Marshal() (dAtA []byte, err error)
func (*ResetIndexResponse) MarshalTo ¶
func (m *ResetIndexResponse) MarshalTo(dAtA []byte) (int, error)
func (*ResetIndexResponse) MarshalToSizedBuffer ¶
func (m *ResetIndexResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResetIndexResponse) ProtoMessage ¶
func (*ResetIndexResponse) ProtoMessage()
func (*ResetIndexResponse) Reset ¶
func (m *ResetIndexResponse) Reset()
func (*ResetIndexResponse) Size ¶
func (m *ResetIndexResponse) Size() (n int)
func (*ResetIndexResponse) String ¶
func (m *ResetIndexResponse) String() string
func (*ResetIndexResponse) Unmarshal ¶
func (m *ResetIndexResponse) Unmarshal(dAtA []byte) error
func (*ResetIndexResponse) XXX_DiscardUnknown ¶
func (m *ResetIndexResponse) XXX_DiscardUnknown()
func (*ResetIndexResponse) XXX_Marshal ¶
func (m *ResetIndexResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResetIndexResponse) XXX_Merge ¶
func (m *ResetIndexResponse) XXX_Merge(src proto.Message)
func (*ResetIndexResponse) XXX_Size ¶
func (m *ResetIndexResponse) XXX_Size() int
func (*ResetIndexResponse) XXX_Unmarshal ¶
func (m *ResetIndexResponse) XXX_Unmarshal(b []byte) error
type UnimplementedReplicaServiceServer ¶
type UnimplementedReplicaServiceServer struct { }
UnimplementedReplicaServiceServer can be embedded to have forward compatible implementations.
func (*UnimplementedReplicaServiceServer) GetReplicaAckIndex ¶
func (*UnimplementedReplicaServiceServer) GetReplicaAckIndex(ctx context.Context, req *GetReplicaAckIndexRequest) (*GetReplicaAckIndexResponse, error)
func (*UnimplementedReplicaServiceServer) Replica ¶
func (*UnimplementedReplicaServiceServer) Replica(srv ReplicaService_ReplicaServer) error
func (*UnimplementedReplicaServiceServer) Reset ¶
func (*UnimplementedReplicaServiceServer) Reset(ctx context.Context, req *ResetIndexRequest) (*ResetIndexResponse, error)
Click to show internal directories.
Click to hide internal directories.