Documentation ¶
Index ¶
- Constants
- Variables
- type D
- func (m *D) AE(loc *soty.Loc, peer string, ring Ringerizer) (bool, int64, int64)
- func (m *D) Add(key string, ver uint64, loc *soty.Loc, shard uint32, fixme bool)
- func (m *D) Close()
- func (m *D) Del(key string, ver uint64, loc *soty.Loc)
- func (m *D) FixLeaf(ver uint64, treeid uint16)
- func (m *D) GetResponse(level int, treeid uint16, ver uint64) []*Result
- func (m *D) IterVersion(treeid uint16, startVer uint64, endVer uint64, ...)
- func (m *D) Move(key string, ver uint64, shard uint32, oldLoc *soty.Loc, newLoc *soty.Loc)
- func (m *D) RemoveTree(ring Ringerizer, loc *soty.Loc, peer string)
- func (m *D) Repartition(ring Ringerizer, loc *soty.Loc, ver uint64) (bool, uint64)
- func (m *D) Xfer(key string, ver uint64, oldLoc *soty.Loc, newLoc *soty.Loc)
- type LeafSave
- func (*LeafSave) Descriptor() ([]byte, []int)
- func (this *LeafSave) Equal(that interface{}) bool
- func (m *LeafSave) GetKey() string
- func (m *LeafSave) GetShard() uint32
- func (m *LeafSave) GetVersion() uint64
- func (this *LeafSave) GoString() string
- func (m *LeafSave) Marshal() (dAtA []byte, err error)
- func (m *LeafSave) MarshalTo(dAtA []byte) (int, error)
- func (m *LeafSave) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LeafSave) ProtoMessage()
- func (m *LeafSave) Reset()
- func (m *LeafSave) Size() (n int)
- func (this *LeafSave) String() string
- func (m *LeafSave) Unmarshal(dAtA []byte) error
- func (m *LeafSave) XXX_DiscardUnknown()
- func (m *LeafSave) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LeafSave) XXX_Merge(src proto.Message)
- func (m *LeafSave) XXX_Size() int
- func (m *LeafSave) XXX_Unmarshal(b []byte) error
- type LeafSaves
- func (*LeafSaves) Descriptor() ([]byte, []int)
- func (this *LeafSaves) Equal(that interface{}) bool
- func (m *LeafSaves) GetSave() []*LeafSave
- func (this *LeafSaves) GoString() string
- func (l *LeafSaves) Len() int
- func (l *LeafSaves) Less(i int, j int) bool
- func (m *LeafSaves) Marshal() (dAtA []byte, err error)
- func (m *LeafSaves) MarshalTo(dAtA []byte) (int, error)
- func (m *LeafSaves) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*LeafSaves) ProtoMessage()
- func (m *LeafSaves) Reset()
- func (m *LeafSaves) Size() (n int)
- func (this *LeafSaves) String() string
- func (l *LeafSaves) Swap(i int, j int)
- func (m *LeafSaves) Unmarshal(dAtA []byte) error
- func (m *LeafSaves) XXX_DiscardUnknown()
- func (m *LeafSaves) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *LeafSaves) XXX_Merge(src proto.Message)
- func (m *LeafSaves) XXX_Size() int
- func (m *LeafSaves) XXX_Unmarshal(b []byte) error
- type MStorer
- type NodeSave
- func (*NodeSave) Descriptor() ([]byte, []int)
- func (this *NodeSave) Equal(that interface{}) bool
- func (m *NodeSave) GetChildren() int32
- func (m *NodeSave) GetHash() []byte
- func (m *NodeSave) GetKeyCount() int64
- func (m *NodeSave) GetSlot() int32
- func (this *NodeSave) GoString() string
- func (m *NodeSave) Marshal() (dAtA []byte, err error)
- func (m *NodeSave) MarshalTo(dAtA []byte) (int, error)
- func (m *NodeSave) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NodeSave) ProtoMessage()
- func (m *NodeSave) Reset()
- func (m *NodeSave) Size() (n int)
- func (this *NodeSave) String() string
- func (m *NodeSave) Unmarshal(dAtA []byte) error
- func (m *NodeSave) XXX_DiscardUnknown()
- func (m *NodeSave) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NodeSave) XXX_Merge(src proto.Message)
- func (m *NodeSave) XXX_Size() int
- func (m *NodeSave) XXX_Unmarshal(b []byte) error
- type NodeSaves
- func (*NodeSaves) Descriptor() ([]byte, []int)
- func (this *NodeSaves) Equal(that interface{}) bool
- func (m *NodeSaves) GetSave() []*NodeSave
- func (this *NodeSaves) GoString() string
- func (l *NodeSaves) Len() int
- func (l *NodeSaves) Less(i int, j int) bool
- func (m *NodeSaves) Marshal() (dAtA []byte, err error)
- func (m *NodeSaves) MarshalTo(dAtA []byte) (int, error)
- func (m *NodeSaves) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*NodeSaves) ProtoMessage()
- func (m *NodeSaves) Reset()
- func (m *NodeSaves) Size() (n int)
- func (this *NodeSaves) String() string
- func (l *NodeSaves) Swap(i int, j int)
- func (m *NodeSaves) Unmarshal(dAtA []byte) error
- func (m *NodeSaves) XXX_DiscardUnknown()
- func (m *NodeSaves) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NodeSaves) XXX_Merge(src proto.Message)
- func (m *NodeSaves) XXX_Size() int
- func (m *NodeSaves) XXX_Unmarshal(b []byte) error
- type Result
- type Ringerizer
Constants ¶
View Source
const ( MAXAE = 20 BUFSZ = 1000 MINBUF = 4 MAXFETCH = 256 TIMEOUT = 30 * time.Second TOONEW = uint64(60 * time.Second) )
View Source
const ( F16 = 0xFFFFFFFFFFFFFFFF HEIGHT = 10 NLOCK = 137 HASHLEN = 16 CHQLEN = 10000 MAXTODO = 1000 MAXREPART = 10240 )
Variables ¶
Functions ¶
This section is empty.
Types ¶
type D ¶
type D struct {
// contains filtered or unexported fields
}
func (*D) IterVersion ¶
func (*D) RemoveTree ¶
func (m *D) RemoveTree(ring Ringerizer, loc *soty.Loc, peer string)
func (*D) Repartition ¶
type LeafSave ¶
type LeafSave struct { Version uint64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"` Shard uint32 `protobuf:"varint,2,opt,name=shard,proto3" json:"shard,omitempty"` Key string `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"` }
func (*LeafSave) Descriptor ¶
func (*LeafSave) GetVersion ¶
func (*LeafSave) MarshalToSizedBuffer ¶
func (*LeafSave) ProtoMessage ¶
func (*LeafSave) ProtoMessage()
func (*LeafSave) XXX_DiscardUnknown ¶
func (m *LeafSave) XXX_DiscardUnknown()
func (*LeafSave) XXX_Marshal ¶
func (*LeafSave) XXX_Unmarshal ¶
type LeafSaves ¶
type LeafSaves struct {
Save []*LeafSave `protobuf:"bytes,1,rep,name=save,proto3" json:"save,omitempty"`
}
func (*LeafSaves) Descriptor ¶
func (*LeafSaves) MarshalToSizedBuffer ¶
func (*LeafSaves) ProtoMessage ¶
func (*LeafSaves) ProtoMessage()
func (*LeafSaves) XXX_DiscardUnknown ¶
func (m *LeafSaves) XXX_DiscardUnknown()
func (*LeafSaves) XXX_Marshal ¶
func (*LeafSaves) XXX_Unmarshal ¶
type MStorer ¶
type MStorer interface { Get(rec *acproto.ACPY2MapDatum) (bool, error) Put(rec *acproto.ACPY2MapDatum) (int, *soty.Loc) Del(rec *acproto.ACPY2MapDatum) error MGet(string) ([]byte, bool) MPut(string, []byte) MDel(string) Range(string, string, string, func(string, []byte) bool) DistribLocal(*soty.Loc, *acproto.ACPY2DistRequest, func(int)) }
type NodeSave ¶
type NodeSave struct { KeyCount int64 `protobuf:"varint,1,opt,name=key_count,json=keyCount,proto3" json:"key_count,omitempty"` Slot int32 `protobuf:"varint,2,opt,name=slot,proto3" json:"slot,omitempty"` Children int32 `protobuf:"varint,3,opt,name=children,proto3" json:"children,omitempty"` Hash []byte `protobuf:"bytes,4,opt,name=hash,proto3" json:"hash,omitempty"` }
func (*NodeSave) Descriptor ¶
func (*NodeSave) GetChildren ¶
func (*NodeSave) GetKeyCount ¶
func (*NodeSave) MarshalToSizedBuffer ¶
func (*NodeSave) ProtoMessage ¶
func (*NodeSave) ProtoMessage()
func (*NodeSave) XXX_DiscardUnknown ¶
func (m *NodeSave) XXX_DiscardUnknown()
func (*NodeSave) XXX_Marshal ¶
func (*NodeSave) XXX_Unmarshal ¶
type NodeSaves ¶
type NodeSaves struct {
Save []*NodeSave `protobuf:"bytes,1,rep,name=save,proto3" json:"save,omitempty"`
}
func (*NodeSaves) Descriptor ¶
func (*NodeSaves) MarshalToSizedBuffer ¶
func (*NodeSaves) ProtoMessage ¶
func (*NodeSaves) ProtoMessage()
func (*NodeSaves) XXX_DiscardUnknown ¶
func (m *NodeSaves) XXX_DiscardUnknown()
func (*NodeSaves) XXX_Marshal ¶
func (*NodeSaves) XXX_Unmarshal ¶
Click to show internal directories.
Click to hide internal directories.