fidias

package module

Go to main page

Versions in this module

v0

v0.1.9

Oct 7, 2017

v0.1.8

Oct 7, 2017

Changes in this version

type Config

+ UIDir string

+ Version string

type Status

+ Version string

v0.1.7

Oct 7, 2017

v0.1.6

Oct 3, 2017

Changes in this version

type Status

+ DHT *chord.Status

+ Hash hexatype.HashAlgorithm

v0.1.5

Sep 28, 2017

Changes in this version

type File

+ func (file *File) Versions() *VersionedFile

type FileSystem

+ func (fs *FileSystem) GetVersions(name string) (*VersionedFile, error)

+ func (fs *FileSystem) Mkdir(name string) error

type FileVersion

+ func (ver *FileVersion) MarshalJSON() ([]byte, error)

type VersionedFile

+ func (f *VersionedFile) MarshalJSON() ([]byte, error)

v0.1.4

Sep 23, 2017

Changes in this version

+ const OpFsDel

+ const OpFsSet

+ var ErrVersionExists = errors.New("version exists")

+ var ErrVersionNotFound = errors.New("version not found")

type Config

+ FileSystemNamespace string

+ KeyValueNamespace string

+ type DHT interface

+ LookupReplicated func(key []byte, replicas int) (hexaring.LocationSet, error)

+ LookupReplicatedHash func(hash []byte, replicas int) (hexaring.LocationSet, error)

+ ScourReplicatedKey func(key []byte, replicas int, cb func(*chord.Vnode) error) (int, error)

+ type FSM struct

+ func NewFSM(kvprefix, fsprefix string) *FSM

+ func (fsm *FSM) Apply(entryID []byte, entry *hexatype.Entry) interface{}

+ func (fsm *FSM) Close() error

+ func (fsm *FSM) GetKey(key []byte) (*KeyValuePair, error)

+ func (fsm *FSM) GetPath(name string) (*VersionedFile, error)

+ func (fsm *FSM) Open() error

+ type Fetcher struct

+ func NewFetcher(idx store.IndexStore, ent store.EntryStore, replicas, bufSize int, ...) *Fetcher

+ func (fet *Fetcher) RegisterBlockTransport(blks blox.Transport)

+ func (fet *Fetcher) RegisterDHT(dht DHT)

+ func (fet *Fetcher) RegisterHealer(healer Healer)

+ func (fet *Fetcher) RegisterTransport(trans FetcherTransport)

+ type FetcherTransport interface

+ FetchKeylog func(host string, entry *hexatype.Entry, opts *hexatype.RequestOptions) (*hexalog.FutureEntry, error)

type Fidias

+ func (fidias *Fidias) FileSystem() *FileSystem

type FidiasRPCClient

+ GetPathRPC func(ctx context.Context, in *PathRPC, opts ...grpc.CallOption) (*PathRPC, error)

+ RelocateBlocksRPC func(ctx context.Context, opts ...grpc.CallOption) (FidiasRPC_RelocateBlocksRPCClient, error)

type FidiasRPCServer

+ GetPathRPC func(context.Context, *PathRPC) (*PathRPC, error)

+ RelocateBlocksRPC func(FidiasRPC_RelocateBlocksRPCServer) error

+ type FidiasRPC_RelocateBlocksRPCClient interface

+ Recv func() (*KeyLocation, error)

+ Send func(*KeyLocation) error

+ type FidiasRPC_RelocateBlocksRPCServer interface

+ Recv func() (*KeyLocation, error)

+ Send func(*KeyLocation) error

+ type File struct

+ func (file *File) Close() error

+ func (file *File) Name() string

+ type FileSystem struct

+ func NewFileSystem(host, namespace string, dev *RingDevice, hexlog *Hexalog, ...) *FileSystem

+ func (fs *FileSystem) Create(name string) (*File, error)

+ func (fs *FileSystem) Open(name string) (*File, error)

+ func (fs *FileSystem) RegisterDHT(dht DHT)

+ func (fs *FileSystem) RegisterTransport(remote FileSystemTransport)

+ func (fs *FileSystem) Stat(name string) (os.FileInfo, error)

+ type FileSystemFSM interface

+ ApplyDelete func(entry *hexatype.Entry) error

+ ApplySet func(entryID []byte, entry *hexatype.Entry, value []byte) error

+ Get func(name string) (*VersionedFile, error)

+ type FileSystemTransport interface

+ GetPath func(ctx context.Context, host string, name string) (*VersionedFile, error)

+ type FileVersion struct

+ Alias string

+ ID []byte

+ func (*FileVersion) Descriptor() ([]byte, []int)

+ func (*FileVersion) ProtoMessage()

+ func (m *FileVersion) GetAlias() string

+ func (m *FileVersion) GetID() []byte

+ func (m *FileVersion) Reset()

+ func (m *FileVersion) String() string

+ func (ver *FileVersion) Text() string

+ type Healer interface

+ Heal func(key []byte, opts *hexatype.RequestOptions) error

+ type Hexalog struct

+ func NewHexalog(conf *Config, logstore *hexalog.LogStore, stable hexalog.StableStore, f *FSM, ...) (*Hexalog, error)

+ func (hexlog *Hexalog) GetEntry(key, id []byte) (entry *hexatype.Entry, meta *ReMeta, err error)

+ func (hexlog *Hexalog) Heal(key []byte, opts *hexatype.RequestOptions) error

+ func (hexlog *Hexalog) Leader(key []byte, locs hexaring.LocationSet) (*hexalog.KeyLeader, error)

+ func (hexlog *Hexalog) MinVotes() int

+ func (hexlog *Hexalog) NewEntry(key []byte) (*hexatype.Entry, *hexatype.RequestOptions, error)

+ func (hexlog *Hexalog) NewEntryFrom(entry *hexatype.Entry) (*hexatype.Entry, *hexatype.RequestOptions, error)

+ func (hexlog *Hexalog) ProposeEntry(entry *hexatype.Entry, opts *hexatype.RequestOptions) (ballot *hexalog.Ballot, err error)

+ func (hexlog *Hexalog) RegisterDHT(dht DHT)

type InMemKeyValueFSM

+ func (fsm *InMemKeyValueFSM) ApplyDelete(entry *hexatype.Entry) error

+ func (fsm *InMemKeyValueFSM) ApplySet(entryID []byte, entry *hexatype.Entry, value []byte) error

+ type InMemVersionedFileFSM struct

+ func NewInMemVersionedFileFSM(prefix string) *InMemVersionedFileFSM

+ func (store *InMemVersionedFileFSM) ApplyDelete(entry *hexatype.Entry) error

+ func (store *InMemVersionedFileFSM) ApplySet(entryID []byte, entry *hexatype.Entry, value []byte) error

+ func (store *InMemVersionedFileFSM) Get(name string) (*VersionedFile, error)

type KeyValueFSM

+ ApplyDelete func(entry *hexatype.Entry) error

+ ApplySet func(entryID []byte, entry *hexatype.Entry, value []byte) error

type KeyValuePair

+ func (kvp KeyValuePair) MarshalJSON() ([]byte, error)

type KeyValueStore

+ GetKey func(key []byte) (*KeyValuePair, error)

+ type KeyValueTransport interface

+ GetKey func(ctx context.Context, host string, key []byte) (*KeyValuePair, error)

+ type Keyvs struct

+ func NewKeyvs(namespace string, hexlog *Hexalog, kvs KeyValueStore) *Keyvs

+ func (kv *Keyvs) GetKey(key []byte) (kvp *KeyValuePair, opt *hexatype.RequestOptions, err error)

+ func (kv *Keyvs) RegisterDHT(dht DHT)

+ func (kv *Keyvs) RegisterTransport(remote KeyValueTransport)

+ func (kv *Keyvs) RemoveKey(basekey []byte) (*hexalog.FutureEntry, *hexatype.RequestOptions, error)

+ func (kv *Keyvs) SetKey(basekey, val []byte) (*hexalog.FutureEntry, *hexatype.RequestOptions, error)

+ type LocalStore interface

type NetTransport

+ func (trans *NetTransport) GetPath(ctx context.Context, host string, name string) (*VersionedFile, error)

+ func (trans *NetTransport) GetPathRPC(ctx context.Context, in *PathRPC) (*PathRPC, error)

+ func (trans *NetTransport) GetRelocateBlocksStream(local, remote *chord.Vnode) (*RelocateBlocksStream, error)

+ func (trans *NetTransport) RelocateBlocksRPC(stream FidiasRPC_RelocateBlocksRPCServer) error

+ type PathRPC struct

+ Entry *hexatype.Entry

+ Name string

+ Versions []*FileVersion

+ func (*PathRPC) Descriptor() ([]byte, []int)

+ func (*PathRPC) ProtoMessage()

+ func (m *PathRPC) GetEntry() *hexatype.Entry

+ func (m *PathRPC) GetName() string

+ func (m *PathRPC) GetVersions() []*FileVersion

+ func (m *PathRPC) Reset()

+ func (m *PathRPC) String() string

+ type RelocateBlocksStream struct

+ func (rs RelocateBlocksStream) Recycle()

type Relocator

+ func (reb *Relocator) RegisterBlockJournal(journal device.Journal)

+ func (reb *Relocator) RegisterKeylogIndex(idx store.IndexStore)

+ func (reb *Relocator) RegisterTransport(trans RelocatorTransport)

type RelocatorTransport

+ GetRelocateBlocksStream func(local, remote *chord.Vnode) (*RelocateBlocksStream, error)

+ type RingDevice struct

+ func NewRingDevice(replicas int, hasher hexatype.Hasher, trans blox.Transport) *RingDevice

+ func (dev *RingDevice) Close() error

+ func (dev *RingDevice) GetBlock(id []byte) (block.Block, error)

+ func (dev *RingDevice) Hasher() hexatype.Hasher

+ func (dev *RingDevice) RegisterDHT(dht DHT)

+ func (dev *RingDevice) RemoveBlock(id []byte) error

+ func (dev *RingDevice) SetBlock(blk block.Block) ([]byte, error)

+ type VersionedFile struct

+ func NewVersionedFile(name string) *VersionedFile

+ func (f *VersionedFile) AddVersion(version *FileVersion) error

+ func (f *VersionedFile) GetVersion(alias string) (*FileVersion, error)

+ func (f *VersionedFile) MarshalBinary() ([]byte, error)

+ func (f *VersionedFile) String() string

+ func (f *VersionedFile) UnmarshalBinary(b []byte) error

+ func (f *VersionedFile) UpdateVersion(version *FileVersion) error

+ func (f *VersionedFile) Version() *FileVersion

+ type VersionedFileStore interface

+ GetPath func(name string) (*VersionedFile, error)

v0.1.3

Sep 1, 2017

Changes in this version

+ type BadgerKeyValueFSM struct

+ func NewBadgerKeyValueFSM(dataDir string) *BadgerKeyValueFSM

+ func (fsm *BadgerKeyValueFSM) Apply(entryID []byte, entry *hexatype.Entry) interface{}

+ func (fsm *BadgerKeyValueFSM) Close() error

+ func (fsm *BadgerKeyValueFSM) Get(key []byte) (*hexatype.KeyValuePair, error)

+ func (fsm *BadgerKeyValueFSM) Open() (err error)

type DummyFSM

+ func (fsm *DummyFSM) Close() error

+ func (fsm *DummyFSM) Open() error

type InMemKeyValueFSM

+ func (fsm *InMemKeyValueFSM) Close() error

+ func (fsm *InMemKeyValueFSM) Open() error

type KeyValueFSM

+ Close func() error

+ Open func() error

v0.1.2

Aug 29, 2017

Changes in this version

type Config

+ RelocateBufSize int

+ RetryInterval time.Duration

+ func (conf *Config) Hasher() hexatype.Hasher

type Fidias

+ func (fidias *Fidias) Leader(key []byte, locs hexaring.LocationSet) (*hexalog.KeyLeader, error)

type FidiasRPCClient

+ RelocateRPC func(ctx context.Context, opts ...grpc.CallOption) (FidiasRPC_RelocateRPCClient, error)

type FidiasRPCServer

+ RelocateRPC func(FidiasRPC_RelocateRPCServer) error

+ type FidiasRPC_RelocateRPCClient interface

+ Recv func() (*KeyLocation, error)

+ Send func(*KeyLocation) error

+ type FidiasRPC_RelocateRPCServer interface

+ Recv func() (*KeyLocation, error)

+ Send func(*KeyLocation) error

+ type KeyLocation struct

+ Height uint32

+ Key []byte

+ Marker []byte

+ func (*KeyLocation) Descriptor() ([]byte, []int)

+ func (*KeyLocation) ProtoMessage()

+ func (m *KeyLocation) GetHeight() uint32

+ func (m *KeyLocation) GetKey() []byte

+ func (m *KeyLocation) GetMarker() []byte

+ func (m *KeyLocation) Reset()

+ func (m *KeyLocation) String() string

type NetTransport

+ func NewNetTransport(kvs KeyValueStore, idx store.IndexStore, reapInterval, maxIdle time.Duration, ...) *NetTransport

+ func (trans *NetTransport) GetRelocateStream(local, remote *chord.Vnode) (*RelocateStream, error)

+ func (trans *NetTransport) Register(ch chan<- *relocateReq)

+ func (trans *NetTransport) RelocateRPC(stream FidiasRPC_RelocateRPCServer) error

+ type RelocateStream struct

+ func (rs *RelocateStream) Recycle()

+ type Relocator struct

+ func NewRelocator(conf *Config, idx store.IndexStore, trans RelocatorTransport) *Relocator

+ type RelocatorTransport interface

+ GetRelocateStream func(local, remote *chord.Vnode) (*RelocateStream, error)

+ type Status struct

+ Ring *chord.Status

v0.1.1

Aug 11, 2017

v0.1.0

Aug 5, 2017

Changes in this version

+ const OpDel

+ const OpSet

+ func RegisterFidiasRPCServer(s *grpc.Server, srv FidiasRPCServer)

+ type Config struct

+ Hexalog *hexalog.Config

+ RebalanceBufSize int

+ Replicas int

+ Ring *hexaring.Config

+ StableThreshold time.Duration

+ func DefaultConfig(hostname string) *Config

+ func (conf *Config) Hostname() string

+ type DummyFSM struct

+ func (fsm *DummyFSM) Apply(entryID []byte, entry *hexalog.Entry) interface{}

+ func (fsm *DummyFSM) Get(key []byte) (*KeyValuePair, error)

+ type Fidias struct

+ func New(conf *Config, appFSM KeyValueFSM, logStore hexalog.LogStore, ...) (g *Fidias, err error)

+ func (fidias *Fidias) GetEntry(key, id []byte) (entry *hexalog.Entry, meta *ReMeta, err error)

+ func (fidias *Fidias) GetKey(key []byte) (kvp *KeyValuePair, meta *ReMeta, err error)

+ func (fidias *Fidias) Leaving(local, pred, succ *chord.Vnode)

+ func (fidias *Fidias) NewEntry(key []byte) *hexalog.Entry

+ func (fidias *Fidias) NewPredecessor(local, newPred, oldPred *chord.Vnode)

+ func (fidias *Fidias) PredecessorLeaving(local, remote *chord.Vnode)

+ func (fidias *Fidias) ProposeEntry(entry *hexalog.Entry) (*hexalog.Ballot, *ReMeta, error)

+ func (fidias *Fidias) Register(ring *hexaring.Ring)

+ func (fidias *Fidias) Shutdown()

+ func (fidias *Fidias) Status() interface{}

+ func (fidias *Fidias) SuccessorLeaving(local, remote *chord.Vnode)

+ type FidiasRPCClient interface

+ GetKeyRPC func(ctx context.Context, in *KeyValuePair, opts ...grpc.CallOption) (*KeyValuePair, error)

+ func NewFidiasRPCClient(cc *grpc.ClientConn) FidiasRPCClient

+ type FidiasRPCServer interface

+ GetKeyRPC func(context.Context, *KeyValuePair) (*KeyValuePair, error)

+ type InMemKeyValueFSM struct

+ func NewInMemKeyValueFSM() *InMemKeyValueFSM

+ func (fsm *InMemKeyValueFSM) Apply(entryID []byte, entry *hexalog.Entry) interface{}

+ func (fsm *InMemKeyValueFSM) Get(key []byte) (*KeyValuePair, error)

+ type KVNetTransport interface

+ GetKey func(host string, key []byte) (*KeyValuePair, error)

+ type KeyValueFSM interface

+ Get func(key []byte) (*KeyValuePair, error)

+ type KeyValuePair struct

+ Entry *hexalog.Entry

+ Key []byte

+ Value []byte

+ func (*KeyValuePair) Descriptor() ([]byte, []int)

+ func (*KeyValuePair) ProtoMessage()

+ func (m *KeyValuePair) GetEntry() *hexalog.Entry

+ func (m *KeyValuePair) GetKey() []byte

+ func (m *KeyValuePair) GetValue() []byte

+ func (m *KeyValuePair) Reset()

+ func (m *KeyValuePair) String() string

+ type KeyValueStore interface

+ Get func(key []byte) (*KeyValuePair, error)

+ type NetTransport struct

+ func (trans *NetTransport) GetKey(host string, key []byte) (*KeyValuePair, error)

+ func (trans *NetTransport) GetKeyRPC(ctx context.Context, in *KeyValuePair) (*KeyValuePair, error)

+ func (trans *NetTransport) Shutdown()

+ type ReMeta struct

+ PeerSet hexaring.LocationSet

+ Vnode *chord.Vnode

+ type RebalanceRequest struct

+ Dst *chord.Vnode

+ Old *chord.Vnode

+ Src *chord.Vnode

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