Versions in this module Expand all Collapse all v0 v0.4.5 Jun 23, 2023 v0.4.4 Jan 12, 2023 Changes in this version + func Dump(nodes []*node) string + func NewMailBox(localID MailBoxID, locker sync.Locker, dataFile string) (*mailBox, error) + type Addr int32 + type Allocator []*node + func NewAllocatorByNodeCnt(nodeCnt int) (Allocator, error) + func NewAllocatorBySize(size int32) (Allocator, error) + func (nodes *Allocator) Alloc(size int32) (Addr, error) + func (nodes *Allocator) Free(addr Addr) error + type Channel uint8 + type DiskRpc interface + Handle func(ctx context.Context) error + Invoke func(ctx context.Context, nodeID MailBoxID, targetID Channel, method string, ...) error + Register func(channel Channel, handler interface{}) error + func NewDiskRpc(mb MailBox) (DiskRpc, error) + type MailBox interface + LocalID func() MailBoxID + Recv func() ([]*Message, error) + Send func(msg *Message) error + type MailBoxID uint16 + type Message struct + Payload []byte + Recipient MailBoxID + Sender MailBoxID