Documentation ¶
Overview ¶
Code generated by atomix-go-framework. DO NOT EDIT.
Code generated by atomix-go-framework. DO NOT EDIT.
Code generated by atomix-go-framework. DO NOT EDIT.
Index ¶
- Constants
- Variables
- func RegisterServer(node *gossip.Node)
- func RegisterService(node *gossip.Node)
- type GossipClient
- type GossipEngine
- type GossipGroup
- type GossipHandler
- type GossipMember
- type GossipMemberID
- type GossipProtocol
- type GossipServer
- type MapEntry
- func (*MapEntry) Descriptor() ([]byte, []int)
- func (m *MapEntry) GetKey() MapKey
- func (m *MapEntry) GetValue() *MapValue
- func (m *MapEntry) Marshal() (dAtA []byte, err error)
- func (m *MapEntry) MarshalTo(dAtA []byte) (int, error)
- func (m *MapEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MapEntry) ProtoMessage()
- func (m *MapEntry) Reset()
- func (m *MapEntry) Size() (n int)
- func (m *MapEntry) String() string
- func (m *MapEntry) Unmarshal(dAtA []byte) error
- func (m *MapEntry) XXX_DiscardUnknown()
- func (m *MapEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MapEntry) XXX_Merge(src proto.Message)
- func (m *MapEntry) XXX_Size() int
- func (m *MapEntry) XXX_Unmarshal(b []byte) error
- type MapKey
- func (*MapKey) Descriptor() ([]byte, []int)
- func (m *MapKey) GetKey() string
- func (m *MapKey) Marshal() (dAtA []byte, err error)
- func (m *MapKey) MarshalTo(dAtA []byte) (int, error)
- func (m *MapKey) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MapKey) ProtoMessage()
- func (m *MapKey) Reset()
- func (m *MapKey) Size() (n int)
- func (m *MapKey) String() string
- func (m *MapKey) Unmarshal(dAtA []byte) error
- func (m *MapKey) XXX_DiscardUnknown()
- func (m *MapKey) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MapKey) XXX_Merge(src proto.Message)
- func (m *MapKey) XXX_Size() int
- func (m *MapKey) XXX_Unmarshal(b []byte) error
- type MapValue
- func (*MapValue) Descriptor() ([]byte, []int)
- func (m *MapValue) GetTTL() *time.Duration
- func (m *MapValue) GetValue() []byte
- func (m *MapValue) Marshal() (dAtA []byte, err error)
- func (m *MapValue) MarshalTo(dAtA []byte) (int, error)
- func (m *MapValue) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*MapValue) ProtoMessage()
- func (m *MapValue) Reset()
- func (m *MapValue) Size() (n int)
- func (m *MapValue) String() string
- func (m *MapValue) Unmarshal(dAtA []byte) error
- func (m *MapValue) XXX_DiscardUnknown()
- func (m *MapValue) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MapValue) XXX_Merge(src proto.Message)
- func (m *MapValue) XXX_Size() int
- func (m *MapValue) XXX_Unmarshal(b []byte) error
- type Server
- func (s *Server) Clear(ctx context.Context, request *_map.ClearRequest) (*_map.ClearResponse, error)
- func (s *Server) Entries(request *_map.EntriesRequest, srv _map.MapService_EntriesServer) error
- func (s *Server) Events(request *_map.EventsRequest, srv _map.MapService_EventsServer) error
- func (s *Server) Get(ctx context.Context, request *_map.GetRequest) (*_map.GetResponse, error)
- func (s *Server) Put(ctx context.Context, request *_map.PutRequest) (*_map.PutResponse, error)
- func (s *Server) Remove(ctx context.Context, request *_map.RemoveRequest) (*_map.RemoveResponse, error)
- func (s *Server) Size(ctx context.Context, request *_map.SizeRequest) (*_map.SizeResponse, error)
- type Service
Constants ¶
View Source
const ServiceType gossip.ServiceType = "Map"
Variables ¶
Functions ¶
func RegisterServer ¶
RegisterServer registers the primitive on the given node
func RegisterService ¶
RegisterService registers the service on the given node
Types ¶
type GossipClient ¶
type GossipEngine ¶
type GossipEngine interface {
// contains filtered or unexported methods
}
type GossipGroup ¶
type GossipGroup interface { GossipClient MemberID() GossipMemberID Members() []GossipMember Member(GossipMemberID) GossipMember }
type GossipHandler ¶
type GossipMember ¶
type GossipMember interface { GossipClient ID() GossipMemberID Client() *gossip.Peer }
type GossipMemberID ¶
func (GossipMemberID) String ¶
func (i GossipMemberID) String() string
type GossipProtocol ¶
type GossipProtocol interface { Clock() atime.Clock Group() GossipGroup Server() GossipServer }
type GossipServer ¶
type GossipServer interface { Register(GossipHandler) error // contains filtered or unexported methods }
type MapEntry ¶
type MapEntry struct { Key MapKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key"` Value *MapValue `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"` }
func (*MapEntry) Descriptor ¶
func (*MapEntry) MarshalToSizedBuffer ¶
func (*MapEntry) ProtoMessage ¶
func (*MapEntry) ProtoMessage()
func (*MapEntry) XXX_DiscardUnknown ¶
func (m *MapEntry) XXX_DiscardUnknown()
func (*MapEntry) XXX_Marshal ¶
func (*MapEntry) XXX_Unmarshal ¶
type MapKey ¶
type MapKey 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"` }
func (*MapKey) Descriptor ¶
func (*MapKey) MarshalToSizedBuffer ¶
func (*MapKey) ProtoMessage ¶
func (*MapKey) ProtoMessage()
func (*MapKey) XXX_DiscardUnknown ¶
func (m *MapKey) XXX_DiscardUnknown()
func (*MapKey) XXX_Marshal ¶
func (*MapKey) XXX_Unmarshal ¶
type MapValue ¶
type MapValue struct { Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` TTL *time.Duration `protobuf:"bytes,2,opt,name=ttl,proto3,stdduration" json:"ttl,omitempty"` }
func (*MapValue) Descriptor ¶
func (*MapValue) MarshalToSizedBuffer ¶
func (*MapValue) ProtoMessage ¶
func (*MapValue) ProtoMessage()
func (*MapValue) XXX_DiscardUnknown ¶
func (m *MapValue) XXX_DiscardUnknown()
func (*MapValue) XXX_Marshal ¶
func (*MapValue) XXX_Unmarshal ¶
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
func (*Server) Clear ¶
func (s *Server) Clear(ctx context.Context, request *_map.ClearRequest) (*_map.ClearResponse, error)
func (*Server) Entries ¶
func (s *Server) Entries(request *_map.EntriesRequest, srv _map.MapService_EntriesServer) error
func (*Server) Events ¶
func (s *Server) Events(request *_map.EventsRequest, srv _map.MapService_EventsServer) error
func (*Server) Get ¶
func (s *Server) Get(ctx context.Context, request *_map.GetRequest) (*_map.GetResponse, error)
func (*Server) Put ¶
func (s *Server) Put(ctx context.Context, request *_map.PutRequest) (*_map.PutResponse, error)
func (*Server) Remove ¶
func (s *Server) Remove(ctx context.Context, request *_map.RemoveRequest) (*_map.RemoveResponse, error)
func (*Server) Size ¶
func (s *Server) Size(ctx context.Context, request *_map.SizeRequest) (*_map.SizeResponse, error)
type Service ¶
type Service interface { gossip.Service // Size returns the size of the map Size(context.Context, *_map.SizeRequest) (*_map.SizeResponse, error) // Put puts an entry into the map Put(context.Context, *_map.PutRequest) (*_map.PutResponse, error) // Get gets the entry for a key Get(context.Context, *_map.GetRequest) (*_map.GetResponse, error) // Remove removes an entry from the map Remove(context.Context, *_map.RemoveRequest) (*_map.RemoveResponse, error) // Clear removes all entries from the map Clear(context.Context, *_map.ClearRequest) (*_map.ClearResponse, error) // Events listens for change events Events(context.Context, *_map.EventsRequest, chan<- _map.EventsResponse) error // Entries lists all entries in the map Entries(context.Context, *_map.EntriesRequest, chan<- _map.EntriesResponse) error }
Click to show internal directories.
Click to hide internal directories.