Documentation ¶
Index ¶
- Variables
- func RegisterGossipProtocolServer(s *grpc.Server, srv GossipProtocolServer)
- func RegisterGossipServer(server *grpc.Server, manager *Manager)
- func RegisterPrimitiveServer(server *grpc.Server)
- type Advertise
- func (*Advertise) Descriptor() ([]byte, []int)
- func (m *Advertise) GetHeader() GossipHeader
- func (m *Advertise) GetKey() string
- func (m *Advertise) Marshal() (dAtA []byte, err error)
- func (m *Advertise) MarshalTo(dAtA []byte) (int, error)
- func (m *Advertise) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Advertise) ProtoMessage()
- func (m *Advertise) Reset()
- func (m *Advertise) Size() (n int)
- func (m *Advertise) String() string
- func (m *Advertise) Unmarshal(dAtA []byte) error
- func (m *Advertise) XXX_DiscardUnknown()
- func (m *Advertise) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Advertise) XXX_Merge(src proto.Message)
- func (m *Advertise) XXX_Size() int
- func (m *Advertise) XXX_Unmarshal(b []byte) error
- type GossipHeader
- func (*GossipHeader) Descriptor() ([]byte, []int)
- func (m *GossipHeader) GetTimestamp() meta.Timestamp
- func (m *GossipHeader) Marshal() (dAtA []byte, err error)
- func (m *GossipHeader) MarshalTo(dAtA []byte) (int, error)
- func (m *GossipHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GossipHeader) ProtoMessage()
- func (m *GossipHeader) Reset()
- func (m *GossipHeader) Size() (n int)
- func (m *GossipHeader) String() string
- func (m *GossipHeader) Unmarshal(dAtA []byte) error
- func (m *GossipHeader) XXX_DiscardUnknown()
- func (m *GossipHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GossipHeader) XXX_Merge(src proto.Message)
- func (m *GossipHeader) XXX_Size() int
- func (m *GossipHeader) XXX_Unmarshal(b []byte) error
- type GossipMessage
- func (*GossipMessage) Descriptor() ([]byte, []int)
- func (m *GossipMessage) GetAdvertise() *Advertise
- func (m *GossipMessage) GetInitialize() *Initialize
- func (m *GossipMessage) GetMessage() isGossipMessage_Message
- func (m *GossipMessage) GetUpdate() *Update
- func (m *GossipMessage) Marshal() (dAtA []byte, err error)
- func (m *GossipMessage) MarshalTo(dAtA []byte) (int, error)
- func (m *GossipMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GossipMessage) ProtoMessage()
- func (m *GossipMessage) Reset()
- func (m *GossipMessage) Size() (n int)
- func (m *GossipMessage) String() string
- func (m *GossipMessage) Unmarshal(dAtA []byte) error
- func (m *GossipMessage) XXX_DiscardUnknown()
- func (m *GossipMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GossipMessage) XXX_Merge(src proto.Message)
- func (*GossipMessage) XXX_OneofWrappers() []interface{}
- func (m *GossipMessage) XXX_Size() int
- func (m *GossipMessage) XXX_Unmarshal(b []byte) error
- type GossipMessage_Advertise
- type GossipMessage_Initialize
- type GossipMessage_Update
- type GossipProtocolClient
- type GossipProtocolServer
- type GossipProtocol_GossipClient
- type GossipProtocol_GossipServer
- type GossipProtocol_ReadAllClient
- type GossipProtocol_ReadAllServer
- type GossipServer
- type Initialize
- func (*Initialize) Descriptor() ([]byte, []int)
- func (m *Initialize) GetHeader() RequestHeader
- func (m *Initialize) Marshal() (dAtA []byte, err error)
- func (m *Initialize) MarshalTo(dAtA []byte) (int, error)
- func (m *Initialize) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Initialize) ProtoMessage()
- func (m *Initialize) Reset()
- func (m *Initialize) Size() (n int)
- func (m *Initialize) String() string
- func (m *Initialize) Unmarshal(dAtA []byte) error
- func (m *Initialize) XXX_DiscardUnknown()
- func (m *Initialize) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Initialize) XXX_Merge(src proto.Message)
- func (m *Initialize) XXX_Size() int
- func (m *Initialize) XXX_Unmarshal(b []byte) error
- type Manager
- type MemberID
- type NewServiceFunc
- type Node
- type Object
- func (*Object) Descriptor() ([]byte, []int)
- func (m *Object) GetKey() string
- func (m *Object) GetValue() []byte
- func (m *Object) Marshal() (dAtA []byte, err error)
- func (m *Object) MarshalTo(dAtA []byte) (int, error)
- func (m *Object) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Object) ProtoMessage()
- func (m *Object) Reset()
- func (m *Object) Size() (n int)
- func (m *Object) String() string
- func (m *Object) Unmarshal(dAtA []byte) error
- func (m *Object) XXX_DiscardUnknown()
- func (m *Object) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Object) XXX_Merge(src proto.Message)
- func (m *Object) XXX_Size() int
- func (m *Object) XXX_Unmarshal(b []byte) error
- type Partition
- type PartitionID
- type Peer
- type PeerGroup
- func (g *PeerGroup) Advertise(ctx context.Context, key string, digest meta.ObjectMeta)
- func (g *PeerGroup) Close()
- func (g *PeerGroup) MemberID() MemberID
- func (g *PeerGroup) Peer(id PeerID) *Peer
- func (g *PeerGroup) Peers() []*Peer
- func (g *PeerGroup) Read(ctx context.Context, key string) ([]Object, error)
- func (g *PeerGroup) ReadAll(ctx context.Context, ch chan<- Object) error
- func (g *PeerGroup) Update(ctx context.Context, object *Object)
- type PeerID
- type PrimitiveServer
- func (s *PrimitiveServer) Close(ctx context.Context, request *primitiveapi.CloseRequest) (*primitiveapi.CloseResponse, error)
- func (s *PrimitiveServer) Create(ctx context.Context, request *primitiveapi.CreateRequest) (*primitiveapi.CreateResponse, error)
- func (s *PrimitiveServer) Delete(ctx context.Context, request *primitiveapi.DeleteRequest) (*primitiveapi.DeleteResponse, error)
- type ReadAllRequest
- func (*ReadAllRequest) Descriptor() ([]byte, []int)
- func (m *ReadAllRequest) GetHeader() RequestHeader
- func (m *ReadAllRequest) Marshal() (dAtA []byte, err error)
- func (m *ReadAllRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ReadAllRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReadAllRequest) ProtoMessage()
- func (m *ReadAllRequest) Reset()
- func (m *ReadAllRequest) Size() (n int)
- func (m *ReadAllRequest) String() string
- func (m *ReadAllRequest) Unmarshal(dAtA []byte) error
- func (m *ReadAllRequest) XXX_DiscardUnknown()
- func (m *ReadAllRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadAllRequest) XXX_Merge(src proto.Message)
- func (m *ReadAllRequest) XXX_Size() int
- func (m *ReadAllRequest) XXX_Unmarshal(b []byte) error
- type ReadAllResponse
- func (*ReadAllResponse) Descriptor() ([]byte, []int)
- func (m *ReadAllResponse) GetHeader() ResponseHeader
- func (m *ReadAllResponse) GetObject() Object
- func (m *ReadAllResponse) Marshal() (dAtA []byte, err error)
- func (m *ReadAllResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ReadAllResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReadAllResponse) ProtoMessage()
- func (m *ReadAllResponse) Reset()
- func (m *ReadAllResponse) Size() (n int)
- func (m *ReadAllResponse) String() string
- func (m *ReadAllResponse) Unmarshal(dAtA []byte) error
- func (m *ReadAllResponse) XXX_DiscardUnknown()
- func (m *ReadAllResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadAllResponse) XXX_Merge(src proto.Message)
- func (m *ReadAllResponse) XXX_Size() int
- func (m *ReadAllResponse) XXX_Unmarshal(b []byte) error
- type ReadRequest
- func (*ReadRequest) Descriptor() ([]byte, []int)
- func (m *ReadRequest) GetHeader() RequestHeader
- func (m *ReadRequest) GetKey() string
- func (m *ReadRequest) Marshal() (dAtA []byte, err error)
- func (m *ReadRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ReadRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReadRequest) ProtoMessage()
- func (m *ReadRequest) Reset()
- func (m *ReadRequest) Size() (n int)
- func (m *ReadRequest) String() string
- func (m *ReadRequest) Unmarshal(dAtA []byte) error
- func (m *ReadRequest) XXX_DiscardUnknown()
- func (m *ReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadRequest) XXX_Merge(src proto.Message)
- func (m *ReadRequest) XXX_Size() int
- func (m *ReadRequest) XXX_Unmarshal(b []byte) error
- type ReadResponse
- func (*ReadResponse) Descriptor() ([]byte, []int)
- func (m *ReadResponse) GetHeader() ResponseHeader
- func (m *ReadResponse) GetObject() *Object
- func (m *ReadResponse) Marshal() (dAtA []byte, err error)
- func (m *ReadResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ReadResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ReadResponse) ProtoMessage()
- func (m *ReadResponse) Reset()
- func (m *ReadResponse) Size() (n int)
- func (m *ReadResponse) String() string
- func (m *ReadResponse) Unmarshal(dAtA []byte) error
- func (m *ReadResponse) XXX_DiscardUnknown()
- func (m *ReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ReadResponse) XXX_Merge(src proto.Message)
- func (m *ReadResponse) XXX_Size() int
- func (m *ReadResponse) XXX_Unmarshal(b []byte) error
- type RegisterServerFunc
- type Registry
- func (r *Registry) GetServers() []RegisterServerFunc
- func (r *Registry) GetServiceFunc(t ServiceType) (NewServiceFunc, error)
- func (r *Registry) GetServiceFuncs() map[ServiceType]NewServiceFunc
- func (r *Registry) RegisterServer(f RegisterServerFunc)
- func (r *Registry) RegisterService(t ServiceType, f NewServiceFunc)
- type Replica
- type RequestHeader
- func (*RequestHeader) Descriptor() ([]byte, []int)
- func (m *RequestHeader) GetMemberID() MemberID
- func (m *RequestHeader) GetPartitionID() PartitionID
- func (m *RequestHeader) GetServiceID() ServiceId
- func (m *RequestHeader) GetTimestamp() meta.Timestamp
- func (m *RequestHeader) Marshal() (dAtA []byte, err error)
- func (m *RequestHeader) MarshalTo(dAtA []byte) (int, error)
- func (m *RequestHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*RequestHeader) ProtoMessage()
- func (m *RequestHeader) Reset()
- func (m *RequestHeader) Size() (n int)
- func (m *RequestHeader) String() string
- func (m *RequestHeader) Unmarshal(dAtA []byte) error
- func (m *RequestHeader) XXX_DiscardUnknown()
- func (m *RequestHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RequestHeader) XXX_Merge(src proto.Message)
- func (m *RequestHeader) XXX_Size() int
- func (m *RequestHeader) XXX_Unmarshal(b []byte) error
- type ResponseHeader
- func (*ResponseHeader) Descriptor() ([]byte, []int)
- func (m *ResponseHeader) GetTimestamp() meta.Timestamp
- func (m *ResponseHeader) Marshal() (dAtA []byte, err error)
- func (m *ResponseHeader) MarshalTo(dAtA []byte) (int, error)
- func (m *ResponseHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ResponseHeader) ProtoMessage()
- func (m *ResponseHeader) Reset()
- func (m *ResponseHeader) Size() (n int)
- func (m *ResponseHeader) String() string
- func (m *ResponseHeader) Unmarshal(dAtA []byte) error
- func (m *ResponseHeader) XXX_DiscardUnknown()
- func (m *ResponseHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ResponseHeader) XXX_Merge(src proto.Message)
- func (m *ResponseHeader) XXX_Size() int
- func (m *ResponseHeader) XXX_Unmarshal(b []byte) error
- type Service
- type ServiceId
- func (*ServiceId) Descriptor() ([]byte, []int)
- func (m *ServiceId) GetCluster() string
- func (m *ServiceId) GetName() string
- func (m *ServiceId) GetType() ServiceType
- func (m *ServiceId) Marshal() (dAtA []byte, err error)
- func (m *ServiceId) MarshalTo(dAtA []byte) (int, error)
- func (m *ServiceId) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ServiceId) ProtoMessage()
- func (m *ServiceId) Reset()
- func (m *ServiceId) Size() (n int)
- func (m *ServiceId) String() string
- func (m *ServiceId) Unmarshal(dAtA []byte) error
- func (m *ServiceId) XXX_DiscardUnknown()
- func (m *ServiceId) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ServiceId) XXX_Merge(src proto.Message)
- func (m *ServiceId) XXX_Size() int
- func (m *ServiceId) XXX_Unmarshal(b []byte) error
- type ServiceType
- type UnimplementedGossipProtocolServer
- func (*UnimplementedGossipProtocolServer) Gossip(srv GossipProtocol_GossipServer) error
- func (*UnimplementedGossipProtocolServer) Read(ctx context.Context, req *ReadRequest) (*ReadResponse, error)
- func (*UnimplementedGossipProtocolServer) ReadAll(req *ReadAllRequest, srv GossipProtocol_ReadAllServer) error
- type Update
- func (*Update) Descriptor() ([]byte, []int)
- func (m *Update) GetHeader() GossipHeader
- func (m *Update) GetObject() Object
- func (m *Update) Marshal() (dAtA []byte, err error)
- func (m *Update) MarshalTo(dAtA []byte) (int, error)
- func (m *Update) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Update) ProtoMessage()
- func (m *Update) Reset()
- func (m *Update) Size() (n int)
- func (m *Update) String() string
- func (m *Update) Unmarshal(dAtA []byte) error
- func (m *Update) XXX_DiscardUnknown()
- func (m *Update) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Update) XXX_Merge(src proto.Message)
- func (m *Update) XXX_Size() int
- func (m *Update) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
Functions ¶
func RegisterGossipProtocolServer ¶
func RegisterGossipProtocolServer(s *grpc.Server, srv GossipProtocolServer)
func RegisterGossipServer ¶
func RegisterPrimitiveServer ¶
Types ¶
type Advertise ¶
type Advertise struct { Header GossipHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"` meta.ObjectMeta `protobuf:"bytes,2,opt,name=meta,proto3,embedded=meta" json:"meta"` Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"` }
func (*Advertise) Descriptor ¶
func (*Advertise) GetHeader ¶
func (m *Advertise) GetHeader() GossipHeader
func (*Advertise) MarshalToSizedBuffer ¶
func (*Advertise) ProtoMessage ¶
func (*Advertise) ProtoMessage()
func (*Advertise) XXX_DiscardUnknown ¶
func (m *Advertise) XXX_DiscardUnknown()
func (*Advertise) XXX_Marshal ¶
func (*Advertise) XXX_Unmarshal ¶
type GossipHeader ¶
type GossipHeader struct {
Timestamp meta.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp"`
}
func (*GossipHeader) Descriptor ¶
func (*GossipHeader) Descriptor() ([]byte, []int)
func (*GossipHeader) GetTimestamp ¶
func (m *GossipHeader) GetTimestamp() meta.Timestamp
func (*GossipHeader) Marshal ¶
func (m *GossipHeader) Marshal() (dAtA []byte, err error)
func (*GossipHeader) MarshalToSizedBuffer ¶
func (m *GossipHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GossipHeader) ProtoMessage ¶
func (*GossipHeader) ProtoMessage()
func (*GossipHeader) Reset ¶
func (m *GossipHeader) Reset()
func (*GossipHeader) Size ¶
func (m *GossipHeader) Size() (n int)
func (*GossipHeader) String ¶
func (m *GossipHeader) String() string
func (*GossipHeader) Unmarshal ¶
func (m *GossipHeader) Unmarshal(dAtA []byte) error
func (*GossipHeader) XXX_DiscardUnknown ¶
func (m *GossipHeader) XXX_DiscardUnknown()
func (*GossipHeader) XXX_Marshal ¶
func (m *GossipHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GossipHeader) XXX_Merge ¶
func (m *GossipHeader) XXX_Merge(src proto.Message)
func (*GossipHeader) XXX_Size ¶
func (m *GossipHeader) XXX_Size() int
func (*GossipHeader) XXX_Unmarshal ¶
func (m *GossipHeader) XXX_Unmarshal(b []byte) error
type GossipMessage ¶
type GossipMessage struct { // Types that are valid to be assigned to Message: // *GossipMessage_Initialize // *GossipMessage_Advertise // *GossipMessage_Update Message isGossipMessage_Message `protobuf_oneof:"message"` }
func (*GossipMessage) Descriptor ¶
func (*GossipMessage) Descriptor() ([]byte, []int)
func (*GossipMessage) GetAdvertise ¶
func (m *GossipMessage) GetAdvertise() *Advertise
func (*GossipMessage) GetInitialize ¶
func (m *GossipMessage) GetInitialize() *Initialize
func (*GossipMessage) GetMessage ¶
func (m *GossipMessage) GetMessage() isGossipMessage_Message
func (*GossipMessage) GetUpdate ¶
func (m *GossipMessage) GetUpdate() *Update
func (*GossipMessage) Marshal ¶
func (m *GossipMessage) Marshal() (dAtA []byte, err error)
func (*GossipMessage) MarshalToSizedBuffer ¶
func (m *GossipMessage) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GossipMessage) ProtoMessage ¶
func (*GossipMessage) ProtoMessage()
func (*GossipMessage) Reset ¶
func (m *GossipMessage) Reset()
func (*GossipMessage) Size ¶
func (m *GossipMessage) Size() (n int)
func (*GossipMessage) String ¶
func (m *GossipMessage) String() string
func (*GossipMessage) Unmarshal ¶
func (m *GossipMessage) Unmarshal(dAtA []byte) error
func (*GossipMessage) XXX_DiscardUnknown ¶
func (m *GossipMessage) XXX_DiscardUnknown()
func (*GossipMessage) XXX_Marshal ¶
func (m *GossipMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GossipMessage) XXX_Merge ¶
func (m *GossipMessage) XXX_Merge(src proto.Message)
func (*GossipMessage) XXX_OneofWrappers ¶
func (*GossipMessage) XXX_OneofWrappers() []interface{}
XXX_OneofWrappers is for the internal use of the proto package.
func (*GossipMessage) XXX_Size ¶
func (m *GossipMessage) XXX_Size() int
func (*GossipMessage) XXX_Unmarshal ¶
func (m *GossipMessage) XXX_Unmarshal(b []byte) error
type GossipMessage_Advertise ¶
type GossipMessage_Advertise struct {
Advertise *Advertise `protobuf:"bytes,2,opt,name=advertise,proto3,oneof" json:"advertise,omitempty"`
}
func (*GossipMessage_Advertise) MarshalTo ¶
func (m *GossipMessage_Advertise) MarshalTo(dAtA []byte) (int, error)
func (*GossipMessage_Advertise) MarshalToSizedBuffer ¶
func (m *GossipMessage_Advertise) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GossipMessage_Advertise) Size ¶
func (m *GossipMessage_Advertise) Size() (n int)
type GossipMessage_Initialize ¶
type GossipMessage_Initialize struct {
Initialize *Initialize `protobuf:"bytes,1,opt,name=initialize,proto3,oneof" json:"initialize,omitempty"`
}
func (*GossipMessage_Initialize) MarshalTo ¶
func (m *GossipMessage_Initialize) MarshalTo(dAtA []byte) (int, error)
func (*GossipMessage_Initialize) MarshalToSizedBuffer ¶
func (m *GossipMessage_Initialize) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GossipMessage_Initialize) Size ¶
func (m *GossipMessage_Initialize) Size() (n int)
type GossipMessage_Update ¶
type GossipMessage_Update struct {
Update *Update `protobuf:"bytes,3,opt,name=update,proto3,oneof" json:"update,omitempty"`
}
func (*GossipMessage_Update) MarshalTo ¶
func (m *GossipMessage_Update) MarshalTo(dAtA []byte) (int, error)
func (*GossipMessage_Update) MarshalToSizedBuffer ¶
func (m *GossipMessage_Update) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GossipMessage_Update) Size ¶
func (m *GossipMessage_Update) Size() (n int)
type GossipProtocolClient ¶
type GossipProtocolClient interface { ReadAll(ctx context.Context, in *ReadAllRequest, opts ...grpc.CallOption) (GossipProtocol_ReadAllClient, error) Read(ctx context.Context, in *ReadRequest, opts ...grpc.CallOption) (*ReadResponse, error) Gossip(ctx context.Context, opts ...grpc.CallOption) (GossipProtocol_GossipClient, error) }
GossipProtocolClient is the client API for GossipProtocol service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewGossipProtocolClient ¶
func NewGossipProtocolClient(cc *grpc.ClientConn) GossipProtocolClient
type GossipProtocolServer ¶
type GossipProtocolServer interface { ReadAll(*ReadAllRequest, GossipProtocol_ReadAllServer) error Read(context.Context, *ReadRequest) (*ReadResponse, error) Gossip(GossipProtocol_GossipServer) error }
GossipProtocolServer is the server API for GossipProtocol service.
type GossipProtocol_GossipClient ¶
type GossipProtocol_GossipClient interface { Send(*GossipMessage) error Recv() (*GossipMessage, error) grpc.ClientStream }
type GossipProtocol_GossipServer ¶
type GossipProtocol_GossipServer interface { Send(*GossipMessage) error Recv() (*GossipMessage, error) grpc.ServerStream }
type GossipProtocol_ReadAllClient ¶
type GossipProtocol_ReadAllClient interface { Recv() (*ReadAllResponse, error) grpc.ClientStream }
type GossipProtocol_ReadAllServer ¶
type GossipProtocol_ReadAllServer interface { Send(*ReadAllResponse) error grpc.ServerStream }
type GossipServer ¶
type GossipServer struct {
// contains filtered or unexported fields
}
func (*GossipServer) Gossip ¶
func (s *GossipServer) Gossip(stream GossipProtocol_GossipServer) error
func (*GossipServer) Read ¶
func (s *GossipServer) Read(ctx context.Context, request *ReadRequest) (*ReadResponse, error)
func (*GossipServer) ReadAll ¶
func (s *GossipServer) ReadAll(request *ReadAllRequest, stream GossipProtocol_ReadAllServer) error
type Initialize ¶
type Initialize struct {
Header RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
}
func (*Initialize) Descriptor ¶
func (*Initialize) Descriptor() ([]byte, []int)
func (*Initialize) GetHeader ¶
func (m *Initialize) GetHeader() RequestHeader
func (*Initialize) Marshal ¶
func (m *Initialize) Marshal() (dAtA []byte, err error)
func (*Initialize) MarshalToSizedBuffer ¶
func (m *Initialize) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*Initialize) ProtoMessage ¶
func (*Initialize) ProtoMessage()
func (*Initialize) Reset ¶
func (m *Initialize) Reset()
func (*Initialize) Size ¶
func (m *Initialize) Size() (n int)
func (*Initialize) String ¶
func (m *Initialize) String() string
func (*Initialize) Unmarshal ¶
func (m *Initialize) Unmarshal(dAtA []byte) error
func (*Initialize) XXX_DiscardUnknown ¶
func (m *Initialize) XXX_DiscardUnknown()
func (*Initialize) XXX_Marshal ¶
func (m *Initialize) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*Initialize) XXX_Merge ¶
func (m *Initialize) XXX_Merge(src proto.Message)
func (*Initialize) XXX_Size ¶
func (m *Initialize) XXX_Size() int
func (*Initialize) XXX_Unmarshal ¶
func (m *Initialize) XXX_Unmarshal(b []byte) error
type Manager ¶
Manager is a manager for CRDT primitives
func (*Manager) Partition ¶
func (m *Manager) Partition(partitionID PartitionID) (*Partition, error)
func (*Manager) PartitionBy ¶
func (*Manager) PartitionFor ¶
type NewServiceFunc ¶
type NewServiceFunc func(ctx context.Context, serviceID ServiceId, partition *Partition, clock time.Clock, replicas int) (Service, error)
NewServiceFunc is a function for creating a replica
type Node ¶
Node is an Atomix node
func (*Node) RegisterServer ¶
func (n *Node) RegisterServer(f RegisterServerFunc)
RegisterServer registers a server
func (*Node) RegisterService ¶
func (n *Node) RegisterService(t ServiceType, f NewServiceFunc)
RegisterService registers a service type
type Object ¶
type Object struct { meta.ObjectMeta `protobuf:"bytes,1,opt,name=meta,proto3,embedded=meta" json:"meta"` Key string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"` Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` }
func (*Object) Descriptor ¶
func (*Object) MarshalToSizedBuffer ¶
func (*Object) ProtoMessage ¶
func (*Object) ProtoMessage()
func (*Object) XXX_DiscardUnknown ¶
func (m *Object) XXX_DiscardUnknown()
func (*Object) XXX_Marshal ¶
func (*Object) XXX_Unmarshal ¶
type Partition ¶
type Partition struct { cluster.Partition ID PartitionID // contains filtered or unexported fields }
Partition is a proxy partition
func NewPartition ¶
NewPartition creates a new proxy partition
func (*Partition) GetService ¶
func (*Partition) RegisterReplica ¶
type Peer ¶
type Peer struct { ID PeerID // contains filtered or unexported fields }
type PeerGroup ¶
type PeerGroup struct {
// contains filtered or unexported fields
}
func NewPeerGroup ¶
type PrimitiveServer ¶
type PrimitiveServer struct {
// contains filtered or unexported fields
}
func (*PrimitiveServer) Close ¶
func (s *PrimitiveServer) Close(ctx context.Context, request *primitiveapi.CloseRequest) (*primitiveapi.CloseResponse, error)
func (*PrimitiveServer) Create ¶
func (s *PrimitiveServer) Create(ctx context.Context, request *primitiveapi.CreateRequest) (*primitiveapi.CreateResponse, error)
func (*PrimitiveServer) Delete ¶
func (s *PrimitiveServer) Delete(ctx context.Context, request *primitiveapi.DeleteRequest) (*primitiveapi.DeleteResponse, error)
type ReadAllRequest ¶
type ReadAllRequest struct {
Header RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"`
}
func (*ReadAllRequest) Descriptor ¶
func (*ReadAllRequest) Descriptor() ([]byte, []int)
func (*ReadAllRequest) GetHeader ¶
func (m *ReadAllRequest) GetHeader() RequestHeader
func (*ReadAllRequest) Marshal ¶
func (m *ReadAllRequest) Marshal() (dAtA []byte, err error)
func (*ReadAllRequest) MarshalToSizedBuffer ¶
func (m *ReadAllRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReadAllRequest) ProtoMessage ¶
func (*ReadAllRequest) ProtoMessage()
func (*ReadAllRequest) Reset ¶
func (m *ReadAllRequest) Reset()
func (*ReadAllRequest) Size ¶
func (m *ReadAllRequest) Size() (n int)
func (*ReadAllRequest) String ¶
func (m *ReadAllRequest) String() string
func (*ReadAllRequest) Unmarshal ¶
func (m *ReadAllRequest) Unmarshal(dAtA []byte) error
func (*ReadAllRequest) XXX_DiscardUnknown ¶
func (m *ReadAllRequest) XXX_DiscardUnknown()
func (*ReadAllRequest) XXX_Marshal ¶
func (m *ReadAllRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReadAllRequest) XXX_Merge ¶
func (m *ReadAllRequest) XXX_Merge(src proto.Message)
func (*ReadAllRequest) XXX_Size ¶
func (m *ReadAllRequest) XXX_Size() int
func (*ReadAllRequest) XXX_Unmarshal ¶
func (m *ReadAllRequest) XXX_Unmarshal(b []byte) error
type ReadAllResponse ¶
type ReadAllResponse struct { Header ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"` Object Object `protobuf:"bytes,2,opt,name=object,proto3" json:"object"` }
func (*ReadAllResponse) Descriptor ¶
func (*ReadAllResponse) Descriptor() ([]byte, []int)
func (*ReadAllResponse) GetHeader ¶
func (m *ReadAllResponse) GetHeader() ResponseHeader
func (*ReadAllResponse) GetObject ¶
func (m *ReadAllResponse) GetObject() Object
func (*ReadAllResponse) Marshal ¶
func (m *ReadAllResponse) Marshal() (dAtA []byte, err error)
func (*ReadAllResponse) MarshalToSizedBuffer ¶
func (m *ReadAllResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReadAllResponse) ProtoMessage ¶
func (*ReadAllResponse) ProtoMessage()
func (*ReadAllResponse) Reset ¶
func (m *ReadAllResponse) Reset()
func (*ReadAllResponse) Size ¶
func (m *ReadAllResponse) Size() (n int)
func (*ReadAllResponse) String ¶
func (m *ReadAllResponse) String() string
func (*ReadAllResponse) Unmarshal ¶
func (m *ReadAllResponse) Unmarshal(dAtA []byte) error
func (*ReadAllResponse) XXX_DiscardUnknown ¶
func (m *ReadAllResponse) XXX_DiscardUnknown()
func (*ReadAllResponse) XXX_Marshal ¶
func (m *ReadAllResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReadAllResponse) XXX_Merge ¶
func (m *ReadAllResponse) XXX_Merge(src proto.Message)
func (*ReadAllResponse) XXX_Size ¶
func (m *ReadAllResponse) XXX_Size() int
func (*ReadAllResponse) XXX_Unmarshal ¶
func (m *ReadAllResponse) XXX_Unmarshal(b []byte) error
type ReadRequest ¶
type ReadRequest struct { Header RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"` meta.ObjectMeta `protobuf:"bytes,2,opt,name=meta,proto3,embedded=meta" json:"meta"` Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"` }
func (*ReadRequest) Descriptor ¶
func (*ReadRequest) Descriptor() ([]byte, []int)
func (*ReadRequest) GetHeader ¶
func (m *ReadRequest) GetHeader() RequestHeader
func (*ReadRequest) GetKey ¶
func (m *ReadRequest) GetKey() string
func (*ReadRequest) Marshal ¶
func (m *ReadRequest) Marshal() (dAtA []byte, err error)
func (*ReadRequest) MarshalToSizedBuffer ¶
func (m *ReadRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReadRequest) ProtoMessage ¶
func (*ReadRequest) ProtoMessage()
func (*ReadRequest) Reset ¶
func (m *ReadRequest) Reset()
func (*ReadRequest) Size ¶
func (m *ReadRequest) Size() (n int)
func (*ReadRequest) String ¶
func (m *ReadRequest) String() string
func (*ReadRequest) Unmarshal ¶
func (m *ReadRequest) Unmarshal(dAtA []byte) error
func (*ReadRequest) XXX_DiscardUnknown ¶
func (m *ReadRequest) XXX_DiscardUnknown()
func (*ReadRequest) XXX_Marshal ¶
func (m *ReadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReadRequest) XXX_Merge ¶
func (m *ReadRequest) XXX_Merge(src proto.Message)
func (*ReadRequest) XXX_Size ¶
func (m *ReadRequest) XXX_Size() int
func (*ReadRequest) XXX_Unmarshal ¶
func (m *ReadRequest) XXX_Unmarshal(b []byte) error
type ReadResponse ¶
type ReadResponse struct { Header ResponseHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"` Object *Object `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"` }
func (*ReadResponse) Descriptor ¶
func (*ReadResponse) Descriptor() ([]byte, []int)
func (*ReadResponse) GetHeader ¶
func (m *ReadResponse) GetHeader() ResponseHeader
func (*ReadResponse) GetObject ¶
func (m *ReadResponse) GetObject() *Object
func (*ReadResponse) Marshal ¶
func (m *ReadResponse) Marshal() (dAtA []byte, err error)
func (*ReadResponse) MarshalToSizedBuffer ¶
func (m *ReadResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ReadResponse) ProtoMessage ¶
func (*ReadResponse) ProtoMessage()
func (*ReadResponse) Reset ¶
func (m *ReadResponse) Reset()
func (*ReadResponse) Size ¶
func (m *ReadResponse) Size() (n int)
func (*ReadResponse) String ¶
func (m *ReadResponse) String() string
func (*ReadResponse) Unmarshal ¶
func (m *ReadResponse) Unmarshal(dAtA []byte) error
func (*ReadResponse) XXX_DiscardUnknown ¶
func (m *ReadResponse) XXX_DiscardUnknown()
func (*ReadResponse) XXX_Marshal ¶
func (m *ReadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ReadResponse) XXX_Merge ¶
func (m *ReadResponse) XXX_Merge(src proto.Message)
func (*ReadResponse) XXX_Size ¶
func (m *ReadResponse) XXX_Size() int
func (*ReadResponse) XXX_Unmarshal ¶
func (m *ReadResponse) XXX_Unmarshal(b []byte) error
type RegisterServerFunc ¶
RegisterServerFunc is a function for registering a server
type Registry ¶
type Registry struct {
// contains filtered or unexported fields
}
Registry is the default primitive registry
func (*Registry) GetServers ¶
func (r *Registry) GetServers() []RegisterServerFunc
func (*Registry) GetServiceFunc ¶
func (r *Registry) GetServiceFunc(t ServiceType) (NewServiceFunc, error)
func (*Registry) GetServiceFuncs ¶
func (r *Registry) GetServiceFuncs() map[ServiceType]NewServiceFunc
func (*Registry) RegisterServer ¶
func (r *Registry) RegisterServer(f RegisterServerFunc)
func (*Registry) RegisterService ¶
func (r *Registry) RegisterService(t ServiceType, f NewServiceFunc)
type Replica ¶
type Replica interface { ID() ServiceId Clock() time.Clock Read(ctx context.Context, key string) (*Object, error) ReadAll(ctx context.Context, ch chan<- Object) error Update(ctx context.Context, object *Object) error }
Replica is a service replica interface
type RequestHeader ¶
type RequestHeader struct { PartitionID PartitionID `protobuf:"varint,1,opt,name=partition_id,json=partitionId,proto3,casttype=PartitionID" json:"partition_id,omitempty"` ServiceID ServiceId `protobuf:"bytes,2,opt,name=service_id,json=serviceId,proto3" json:"service_id"` MemberID MemberID `protobuf:"bytes,3,opt,name=member_id,json=memberId,proto3,casttype=MemberID" json:"member_id,omitempty"` Timestamp meta.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp"` }
func (*RequestHeader) Descriptor ¶
func (*RequestHeader) Descriptor() ([]byte, []int)
func (*RequestHeader) GetMemberID ¶
func (m *RequestHeader) GetMemberID() MemberID
func (*RequestHeader) GetPartitionID ¶
func (m *RequestHeader) GetPartitionID() PartitionID
func (*RequestHeader) GetServiceID ¶
func (m *RequestHeader) GetServiceID() ServiceId
func (*RequestHeader) GetTimestamp ¶
func (m *RequestHeader) GetTimestamp() meta.Timestamp
func (*RequestHeader) Marshal ¶
func (m *RequestHeader) Marshal() (dAtA []byte, err error)
func (*RequestHeader) MarshalToSizedBuffer ¶
func (m *RequestHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*RequestHeader) ProtoMessage ¶
func (*RequestHeader) ProtoMessage()
func (*RequestHeader) Reset ¶
func (m *RequestHeader) Reset()
func (*RequestHeader) Size ¶
func (m *RequestHeader) Size() (n int)
func (*RequestHeader) String ¶
func (m *RequestHeader) String() string
func (*RequestHeader) Unmarshal ¶
func (m *RequestHeader) Unmarshal(dAtA []byte) error
func (*RequestHeader) XXX_DiscardUnknown ¶
func (m *RequestHeader) XXX_DiscardUnknown()
func (*RequestHeader) XXX_Marshal ¶
func (m *RequestHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RequestHeader) XXX_Merge ¶
func (m *RequestHeader) XXX_Merge(src proto.Message)
func (*RequestHeader) XXX_Size ¶
func (m *RequestHeader) XXX_Size() int
func (*RequestHeader) XXX_Unmarshal ¶
func (m *RequestHeader) XXX_Unmarshal(b []byte) error
type ResponseHeader ¶
type ResponseHeader struct {
Timestamp meta.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp"`
}
func (*ResponseHeader) Descriptor ¶
func (*ResponseHeader) Descriptor() ([]byte, []int)
func (*ResponseHeader) GetTimestamp ¶
func (m *ResponseHeader) GetTimestamp() meta.Timestamp
func (*ResponseHeader) Marshal ¶
func (m *ResponseHeader) Marshal() (dAtA []byte, err error)
func (*ResponseHeader) MarshalToSizedBuffer ¶
func (m *ResponseHeader) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ResponseHeader) ProtoMessage ¶
func (*ResponseHeader) ProtoMessage()
func (*ResponseHeader) Reset ¶
func (m *ResponseHeader) Reset()
func (*ResponseHeader) Size ¶
func (m *ResponseHeader) Size() (n int)
func (*ResponseHeader) String ¶
func (m *ResponseHeader) String() string
func (*ResponseHeader) Unmarshal ¶
func (m *ResponseHeader) Unmarshal(dAtA []byte) error
func (*ResponseHeader) XXX_DiscardUnknown ¶
func (m *ResponseHeader) XXX_DiscardUnknown()
func (*ResponseHeader) XXX_Marshal ¶
func (m *ResponseHeader) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ResponseHeader) XXX_Merge ¶
func (m *ResponseHeader) XXX_Merge(src proto.Message)
func (*ResponseHeader) XXX_Size ¶
func (m *ResponseHeader) XXX_Size() int
func (*ResponseHeader) XXX_Unmarshal ¶
func (m *ResponseHeader) XXX_Unmarshal(b []byte) error
type ServiceId ¶
type ServiceId struct { Type ServiceType `protobuf:"bytes,1,opt,name=type,proto3,casttype=ServiceType" json:"type,omitempty"` Cluster string `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"` Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"` }
func (*ServiceId) Descriptor ¶
func (*ServiceId) GetCluster ¶ added in v0.6.2
func (*ServiceId) GetType ¶
func (m *ServiceId) GetType() ServiceType
func (*ServiceId) MarshalToSizedBuffer ¶
func (*ServiceId) ProtoMessage ¶
func (*ServiceId) ProtoMessage()
func (*ServiceId) XXX_DiscardUnknown ¶
func (m *ServiceId) XXX_DiscardUnknown()
func (*ServiceId) XXX_Marshal ¶
func (*ServiceId) XXX_Unmarshal ¶
type UnimplementedGossipProtocolServer ¶
type UnimplementedGossipProtocolServer struct { }
UnimplementedGossipProtocolServer can be embedded to have forward compatible implementations.
func (*UnimplementedGossipProtocolServer) Gossip ¶
func (*UnimplementedGossipProtocolServer) Gossip(srv GossipProtocol_GossipServer) error
func (*UnimplementedGossipProtocolServer) Read ¶
func (*UnimplementedGossipProtocolServer) Read(ctx context.Context, req *ReadRequest) (*ReadResponse, error)
func (*UnimplementedGossipProtocolServer) ReadAll ¶
func (*UnimplementedGossipProtocolServer) ReadAll(req *ReadAllRequest, srv GossipProtocol_ReadAllServer) error
type Update ¶
type Update struct { Header GossipHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header"` Object Object `protobuf:"bytes,2,opt,name=object,proto3" json:"object"` }
func (*Update) Descriptor ¶
func (*Update) GetHeader ¶
func (m *Update) GetHeader() GossipHeader
func (*Update) MarshalToSizedBuffer ¶
func (*Update) ProtoMessage ¶
func (*Update) ProtoMessage()
func (*Update) XXX_DiscardUnknown ¶
func (m *Update) XXX_DiscardUnknown()
func (*Update) XXX_Marshal ¶
func (*Update) XXX_Unmarshal ¶
Source Files ¶
Directories ¶
Path | Synopsis |
---|---|
Code generated by atomix-go-framework.
|
Code generated by atomix-go-framework. |
Code generated by atomix-go-framework.
|
Code generated by atomix-go-framework. |
Code generated by atomix-go-framework.
|
Code generated by atomix-go-framework. |
Code generated by atomix-go-framework.
|
Code generated by atomix-go-framework. |