protocol/

Aug 3, 2021

Changes in this version

type ProtocolPartition

+ ReadReplicas []string

+ func (m *ProtocolPartition) GetReadReplicas() []string

Jun 29, 2021

Changes in this version

type ProtocolPartition

+ APIPort int32

+ Host string

+ func (m *ProtocolPartition) GetAPIPort() int32

+ func (m *ProtocolPartition) GetHost() string

Jun 21, 2021

Changes in this version

type ProtocolReplica

+ ReadOnly bool

+ func (m *ProtocolReplica) GetReadOnly() bool

Apr 29, 2021

Changes in this version

+ var ErrIntOverflowProtocol = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthProtocol = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupProtocol = fmt.Errorf("proto: unexpected end of group")

+ func RegisterProtocolConfigServiceServer(s *grpc.Server, srv ProtocolConfigServiceServer)

+ type ProtocolConfig struct

+ Partitions []ProtocolPartition

+ Replicas []ProtocolReplica

+ func (*ProtocolConfig) Descriptor() ([]byte, []int)

+ func (*ProtocolConfig) ProtoMessage()

+ func (m *ProtocolConfig) GetPartitions() []ProtocolPartition

+ func (m *ProtocolConfig) GetReplicas() []ProtocolReplica

+ func (m *ProtocolConfig) Marshal() (dAtA []byte, err error)

+ func (m *ProtocolConfig) MarshalTo(dAtA []byte) (int, error)

+ func (m *ProtocolConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ProtocolConfig) Reset()

+ func (m *ProtocolConfig) Size() (n int)

+ func (m *ProtocolConfig) String() string

+ func (m *ProtocolConfig) Unmarshal(dAtA []byte) error

+ func (m *ProtocolConfig) XXX_DiscardUnknown()

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

+ func (m *ProtocolConfig) XXX_Merge(src proto.Message)

+ func (m *ProtocolConfig) XXX_Size() int

+ func (m *ProtocolConfig) XXX_Unmarshal(b []byte) error

+ type ProtocolConfigServiceClient interface

+ UpdateConfig func(ctx context.Context, in *UpdateConfigRequest, opts ...grpc.CallOption) (*UpdateConfigResponse, error)

+ func NewProtocolConfigServiceClient(cc *grpc.ClientConn) ProtocolConfigServiceClient

+ type ProtocolConfigServiceServer interface

+ UpdateConfig func(context.Context, *UpdateConfigRequest) (*UpdateConfigResponse, error)

+ type ProtocolPartition struct

+ PartitionID uint32

+ Replicas []string

+ func (*ProtocolPartition) Descriptor() ([]byte, []int)

+ func (*ProtocolPartition) ProtoMessage()

+ func (m *ProtocolPartition) GetPartitionID() uint32

+ func (m *ProtocolPartition) GetReplicas() []string

+ func (m *ProtocolPartition) Marshal() (dAtA []byte, err error)

+ func (m *ProtocolPartition) MarshalTo(dAtA []byte) (int, error)

+ func (m *ProtocolPartition) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ProtocolPartition) Reset()

+ func (m *ProtocolPartition) Size() (n int)

+ func (m *ProtocolPartition) String() string

+ func (m *ProtocolPartition) Unmarshal(dAtA []byte) error

+ func (m *ProtocolPartition) XXX_DiscardUnknown()

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

+ func (m *ProtocolPartition) XXX_Merge(src proto.Message)

+ func (m *ProtocolPartition) XXX_Size() int

+ func (m *ProtocolPartition) XXX_Unmarshal(b []byte) error

+ type ProtocolReplica struct

+ APIPort int32

+ ExtraPorts map[string]int32

+ Host string

+ ID string

+ NodeID string

+ func (*ProtocolReplica) Descriptor() ([]byte, []int)

+ func (*ProtocolReplica) ProtoMessage()

+ func (m *ProtocolReplica) GetAPIPort() int32

+ func (m *ProtocolReplica) GetExtraPorts() map[string]int32

+ func (m *ProtocolReplica) GetHost() string

+ func (m *ProtocolReplica) GetID() string

+ func (m *ProtocolReplica) GetNodeID() string

+ func (m *ProtocolReplica) Marshal() (dAtA []byte, err error)

+ func (m *ProtocolReplica) MarshalTo(dAtA []byte) (int, error)

+ func (m *ProtocolReplica) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *ProtocolReplica) Reset()

+ func (m *ProtocolReplica) Size() (n int)

+ func (m *ProtocolReplica) String() string

+ func (m *ProtocolReplica) Unmarshal(dAtA []byte) error

+ func (m *ProtocolReplica) XXX_DiscardUnknown()

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

+ func (m *ProtocolReplica) XXX_Merge(src proto.Message)

+ func (m *ProtocolReplica) XXX_Size() int

+ func (m *ProtocolReplica) XXX_Unmarshal(b []byte) error

+ type UnimplementedProtocolConfigServiceServer struct

+ func (*UnimplementedProtocolConfigServiceServer) UpdateConfig(ctx context.Context, req *UpdateConfigRequest) (*UpdateConfigResponse, error)

+ type UpdateConfigRequest struct

+ Config ProtocolConfig

+ func (*UpdateConfigRequest) Descriptor() ([]byte, []int)

+ func (*UpdateConfigRequest) ProtoMessage()

+ func (m *UpdateConfigRequest) GetConfig() ProtocolConfig

+ func (m *UpdateConfigRequest) Marshal() (dAtA []byte, err error)

+ func (m *UpdateConfigRequest) MarshalTo(dAtA []byte) (int, error)

+ func (m *UpdateConfigRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *UpdateConfigRequest) Reset()

+ func (m *UpdateConfigRequest) Size() (n int)

+ func (m *UpdateConfigRequest) String() string

+ func (m *UpdateConfigRequest) Unmarshal(dAtA []byte) error

+ func (m *UpdateConfigRequest) XXX_DiscardUnknown()

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

+ func (m *UpdateConfigRequest) XXX_Merge(src proto.Message)

+ func (m *UpdateConfigRequest) XXX_Size() int

+ func (m *UpdateConfigRequest) XXX_Unmarshal(b []byte) error

+ type UpdateConfigResponse struct

+ func (*UpdateConfigResponse) Descriptor() ([]byte, []int)

+ func (*UpdateConfigResponse) ProtoMessage()

+ func (m *UpdateConfigResponse) Marshal() (dAtA []byte, err error)

+ func (m *UpdateConfigResponse) MarshalTo(dAtA []byte) (int, error)

+ func (m *UpdateConfigResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

+ func (m *UpdateConfigResponse) Reset()

+ func (m *UpdateConfigResponse) Size() (n int)

+ func (m *UpdateConfigResponse) String() string

+ func (m *UpdateConfigResponse) Unmarshal(dAtA []byte) error

+ func (m *UpdateConfigResponse) XXX_DiscardUnknown()

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

+ func (m *UpdateConfigResponse) XXX_Merge(src proto.Message)

+ func (m *UpdateConfigResponse) XXX_Size() int

+ func (m *UpdateConfigResponse) XXX_Unmarshal(b []byte) error