partition

package

v0.0.0-...-d807755 Latest Latest Go to latest Published: May 7, 2014 License: GPL-2.0 Imports: 9 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/maxwelldergosits/edht

Links

Open Source Insights

Documentation ¶

Index ¶

func AbortPartition(id uint64, dest RemoteServer) (bool, error)
func CommitPartition(id uint64, dest RemoteServer) (bool, error)
func PreCommitPartition(r Ranges, id uint64, dest RemoteServer) (bool, error)
type Diff
- func GenerateDiffs(oldPS, newPS PartitionSet) []Diff
type PartitionDelegate
type PartitionSet
- func MakeKeySpace(n int, del PartitionDelegate) *PartitionSet
- func MakePartitionSet(ns []ShardCopy, del PartitionDelegate) *PartitionSet
type PreCommitRequest
type Shard

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func AbortPartition ¶

func AbortPartition(id uint64, dest RemoteServer) (bool, error)

func CommitPartition ¶

func CommitPartition(id uint64, dest RemoteServer) (bool, error)

func PreCommitPartition ¶

func PreCommitPartition(r Ranges, id uint64, dest RemoteServer) (bool, error)

Types ¶

type Diff ¶

type Diff struct {
	From  int
	To    int
	Start uint64
	End   uint64
}

func GenerateDiffs ¶

func GenerateDiffs(oldPS, newPS PartitionSet) []Diff

type PartitionDelegate ¶

type PartitionDelegate interface {
	GetDaemon(uint64) RemoteServer
	DeleteDaemon(uint64)
	GetLocalID() uint64
	Logger() *mlog.MLog
}

type PartitionSet ¶

type PartitionSet struct {
	Shards []Shard
	// contains filtered or unexported fields
}

func MakeKeySpace ¶

func MakeKeySpace(n int, del PartitionDelegate) *PartitionSet

n must be a postive power of two, 2 4 8 16 32 etc

func MakePartitionSet ¶

func MakePartitionSet(ns []ShardCopy, del PartitionDelegate) *PartitionSet

func (*PartitionSet) Abort ¶

func (pts *PartitionSet) Abort(updateID uint64) bool

func (*PartitionSet) AddDaemon ¶

func (t *PartitionSet) AddDaemon(id uint64)

function that gets called when a new daemon is commited to the system. Argument : id of the daemon

func (*PartitionSet) ApplyCopyDiffs ¶

func (pts *PartitionSet) ApplyCopyDiffs(diffs []Diff) bool

func (*PartitionSet) CalculateDiffs ¶

func (ps *PartitionSet) CalculateDiffs(keys []uint) ([]Diff, *PartitionSet)

func (*PartitionSet) CanCommit ¶

func (t *PartitionSet) CanCommit() bool

func (*PartitionSet) Commit ¶

func (pts *PartitionSet) Commit(updateID uint64) bool

func (*PartitionSet) Copy ¶

func (t *PartitionSet) Copy() PartitionSet

func (*PartitionSet) GarbageCollect ¶

func (pts *PartitionSet) GarbageCollect()

func (*PartitionSet) Get ¶

func (pts *PartitionSet) Get(key string) (string, error)

func (*PartitionSet) GetNKeysForEachShard ¶

func (pts *PartitionSet) GetNKeysForEachShard() ([]uint, error)

func (*PartitionSet) GetShardCopies ¶

func (pts *PartitionSet) GetShardCopies() []ShardCopy

func (*PartitionSet) GetShardForKey ¶

func (t *PartitionSet) GetShardForKey(key string) Shard

func (*PartitionSet) IDs ¶

func (pts *PartitionSet) IDs() [][]uint64

func (*PartitionSet) IntRanges ¶

func (ps *PartitionSet) IntRanges() []uint64

func (*PartitionSet) PreCommit ¶

func (pts *PartitionSet) PreCommit(r Ranges, updateID uint64) bool

func (*PartitionSet) Put ¶

func (pts *PartitionSet) Put(key, value string, options map[string]bool) (error, map[string]string)

func (*PartitionSet) Ranges ¶

func (ps *PartitionSet) Ranges() []Range

func (*PartitionSet) Recalc ¶

func (o *PartitionSet) Recalc(keys []uint) PartitionSet

func (*PartitionSet) Verify ¶

func (ps *PartitionSet) Verify() bool

type PreCommitRequest ¶

type PreCommitRequest struct {
	R  Ranges
	Id uint64
}

type Shard ¶

type Shard struct {
	Start   uint64
	End     uint64
	Daemons map[uint64]bool
	Keys    uint
	// contains filtered or unexported fields
}

func (*Shard) Copy ¶

func (self *Shard) Copy() *Shard

func (*Shard) CopyKVs ¶

func (shard *Shard) CopyKVs(otherShard Shard, start, end uint64) bool

func (*Shard) GarbageCollect ¶

func (shard *Shard) GarbageCollect()

func (*Shard) GetDaemons ¶

func (t *Shard) GetDaemons() map[uint64]bool

func (*Shard) GetInfoForShard ¶

func (shard *Shard) GetInfoForShard() (error, uint)

func (*Shard) IDs ¶

func (shard *Shard) IDs() []uint64

func (*Shard) Put ¶

func (shard *Shard) Put(key, value string, options map[string]bool) (error, map[string]string)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL