protoReplicaV1

package
v0.3.1 Latest Latest
Warning

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

 Go to latest Published: Apr 21, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthReplica        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowReplica          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupReplica = fmt.Errorf("proto: unexpected end of group")
)

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

func (m *ReplicaRequest) MarshalTo(dAtA []byte) (int, 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) MarshalTo 

func (m *ReplicaResponse) MarshalTo(dAtA []byte) (int, 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)

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.