datastore

package

Go to main page

Versions in this module

v0

v0.8.18

Jul 18, 2018

Changes in this version

+ func LogRepoOpToKafka(uuid dvid.UUID, b []byte) error

type Data

+ func (d *Data) IsDeleted() bool

+ func (d *Data) SetDeleted(deleted bool)

+ type DataStorageMap struct

+ KVStores storage.DataMap

+ LogStores storage.DataMap

v0.8.17

Apr 21, 2018

Changes in this version

+ func GetAncestry(v dvid.VersionID) ([]dvid.VersionID, error)

+ func GetBlobStore(d dvid.Data) (store storage.BlobStore, err error)

+ func GetGraphDB(d dvid.Data) (db storage.GraphDB, err error)

+ func GetKeyValueBatcher(d dvid.Data) (db storage.KeyValueBatcher, err error)

+ func GetKeyValueDB(d dvid.Data) (db storage.KeyValueDB, err error)

+ func GetOrderedKeyValueDB(d dvid.Data) (db storage.OrderedKeyValueDB, err error)

+ func ProduceKafkaMsg(uuid dvid.UUID, b []byte) error

+ type BlobService interface

+ GetBlob func(ref string) (data []byte, err error)

+ PutBlob func(data []byte) (ref string, err error)

type Data

+ func (d *Data) GetBlob(ref string) (data []byte, err error)

+ func (d *Data) GetReadLog() storage.ReadLog

+ func (d *Data) ProduceKafkaMsg(b []byte) error

+ func (d *Data) PutBlob(b []byte) (ref string, err error)

+ func (d *Data) Tags() map[string]string

type DataTxInit

+ Tags map[string]string

+ type Initializer interface

+ Initialize func()

v0.8.16

Nov 28, 2017

v0.8.15

Nov 21, 2017

v0.8.14

Nov 20, 2017

v0.8.13

Sep 20, 2017

Changes in this version

+ const DataShutdownTime

+ const ServerLockKey

+ var ErrBranchUnique = errors.New("branch already exists with given name")

+ func MetadataUniversalLock() error

+ func MetadataUniversalUnlock()

type Data

+ func (d *Data) DAGRootUUID() (dvid.UUID, error)

+ func (d *Data) GetWriteLog() storage.WriteLog

+ func (d *Data) KVStore() (dvid.Store, error)

+ func (d *Data) LogStore() (storage.WriteLog, error)

+ func (d *Data) SetKVStore(kvStore dvid.Store)

+ func (d *Data) SetLogStore(logStore storage.WriteLog)

+ type MutationMutexer interface

+ MutAdd func(mutID uint64) (newOp bool)

+ MutDelete func(mutID uint64)

+ MutDone func(mutID uint64)

+ MutWait func(mutID uint64)

type VersionedCtx

+ func (vctx *VersionedCtx) Head() bool

+ func (vctx *VersionedCtx) MasterVersion(version dvid.VersionID) bool

+ func (vctx *VersionedCtx) NumVersions() int32

+ func (vctx *VersionedCtx) RepoRoot() (dvid.UUID, error)

v0.8.12

Apr 25, 2017

v0.8.11

Apr 5, 2017

v0.8.10

Apr 5, 2017

v0.8.9

Apr 3, 2017

v0.8.8

Mar 30, 2017

v0.8.7

Mar 24, 2017

Changes in this version

+ func GetNodeNote(uuid dvid.UUID) (string, error)

type Data

+ func (d *Data) RootVersionID() (dvid.VersionID, error)

v0.8.6

Jan 5, 2017

v0.8.5

Nov 21, 2016

Changes in this version

+ func GetStorageBreakdown() (string, error)

type Data

+ func (d *Data) IsMutationRequest(action, endpoint string) bool

+ func (d *Data) MutAdd(mutID uint64) (newOp bool)

+ func (d *Data) MutDelete(mutID uint64)

+ func (d *Data) MutDone(mutID uint64)

+ func (d *Data) MutWait(mutID uint64)

+ func (d *Data) NewMutationID() uint64

+ func (d *Data) SyncPending() bool

+ type DataInitializer interface

+ InitDataHandlers func() error

type DataService

+ IsMutationRequest func(action, endpoint string) bool

type PushSession

+ Filter storage.FilterSpec

+ Versions map[dvid.VersionID]struct{}

+ func (p *PushSession) EndInstancePush() error

+ func (p *PushSession) SendKV(kv *storage.KeyValue) error

+ func (p *PushSession) StartInstancePush(d dvid.Data) error

+ type Shutdowner interface

+ Shutdown func()

type SyncMessage

+ Event string

type Syncer

+ SyncPending func() bool

v0.8.4

Aug 22, 2016

Changes in this version

+ var ErrExistingDataName = errors.New("data name already exists")

+ func BlockOnUpdating(uuid dvid.UUID, name dvid.InstanceName) error

+ type TypeUpgrader interface

+ UpgradeData func() (upgraded bool, err error)

v0.8.3

Jul 18, 2016

Changes in this version

+ var ErrInvalidDataUUID = errors.New("invalid data instance UUID")

+ func DeleteDataByName(uuid dvid.UUID, name dvid.InstanceName, passcode string) error

+ func ModifyDataConfigByName(uuid dvid.UUID, name dvid.InstanceName, c dvid.Config) error

+ func RenameData(uuid dvid.UUID, oldname, newname dvid.InstanceName, passcode string) error

+ func SetSyncByJSON(d dvid.Data, uuid dvid.UUID, in io.ReadCloser) error

+ func SetSyncData(data dvid.Data, syncs dvid.UUIDSet) error

type Data

+ func (d *Data) DataUUID() dvid.UUID

+ func (d *Data) RootUUID() dvid.UUID

+ func (d *Data) SetDataUUID(uuid dvid.UUID)

+ func (d *Data) SetName(name dvid.InstanceName)

+ func (d *Data) SetRootUUID(uuid dvid.UUID)

+ func (d *Data) SyncedData() dvid.UUIDSet

type DataService

+ func GetDataByDataUUID(dataUUID dvid.UUID) (DataService, error)

+ func GetDataByUUIDName(uuid dvid.UUID, name dvid.InstanceName) (DataService, error)

+ func GetDataByVersionName(v dvid.VersionID, name dvid.InstanceName) (DataService, error)

type SyncEvent

+ Data dvid.UUID

type Syncer

+ SyncedData func() dvid.UUIDSet

v0.8.2

May 12, 2016

Changes in this version

+ func CopyInstance(uuid dvid.UUID, source, target dvid.InstanceName, c dvid.Config) error

+ func MigrateInstance(uuid dvid.UUID, source dvid.InstanceName, oldStore dvid.Store, c dvid.Config) error

+ func PushData(d dvid.Data, p *PushSession) error

+ func PushRepo(uuid dvid.UUID, target string, config dvid.Config) error

type Data

+ func (d *Data) PushData(p *PushSession) error

type DataService

+ PushData func(*PushSession) error

+ type PropertyCopier interface

+ CopyPropertiesFrom func(DataService, storage.FilterSpec) error

+ type PushSession struct

+ type VersionRemapper interface

+ RemapVersions func(dvid.VersionMap) error

v0.8.1

Apr 6, 2016

Changes in this version

+ const MaxBatchSize

+ const PutKVMsg

+ const StartDataMsg

+ var ErrInvalidDataInstance = errors.New("invalid data instance id")

+ var ErrInvalidStore = errors.New("invalid data store")

+ func Push(uuid dvid.UUID, target string, config dvid.Config) error

type Data

+ func (d *Data) BackendStore() (dvid.Store, error)

+ func (d *Data) GetGraphDB() (storage.GraphDB, error)

+ func (d *Data) GetKeyValueBatcher() (storage.KeyValueBatcher, error)

+ func (d *Data) GetKeyValueDB() (storage.KeyValueDB, error)

+ func (d *Data) GetOrderedKeyValueDB() (storage.OrderedKeyValueDB, error)

+ func (d *Data) Send(s rpc.Session, transmit rpc.Transmit, filter string, ...) error

+ func (d *Data) SetBackendStore(store dvid.Store)

+ func (d *Data) SetUUID(uuid dvid.UUID)

+ func (d *Data) UUID() dvid.UUID

+ type DataTxInit struct

+ DataName dvid.InstanceName

+ InstanceID dvid.InstanceID

+ Session rpc.SessionID

+ TypeName dvid.TypeString

+ type KVMessage struct

+ KV storage.KeyValue

+ Session rpc.SessionID

+ Terminate bool

type VersionedCtx

+ func (vctx *VersionedCtx) GetGraphDB() (storage.GraphDB, error)

+ func (vctx *VersionedCtx) GetKeyValueDB() (storage.KeyValueDB, error)

+ func (vctx *VersionedCtx) GetOrderedKeyValueDB() (storage.OrderedKeyValueDB, error)

v0.8.0

Mar 11, 2016

Changes in this version

+ func CompiledTypes() map[dvid.TypeString]TypeService

+ func ReloadMetadata() error

+ func SyncData(uuid dvid.UUID, name dvid.InstanceName, syncedNames ...string) error

type Data

+ func (d *Data) CloneToType(typename dvid.TypeString, typeurl dvid.URLString, typeversion string) *Data

+ func (d *Data) SetSync(uuid dvid.UUID, in io.ReadCloser) error

+ type SyncSubs []SyncSub

+ func (subs SyncSubs) Add(added SyncSub) SyncSubs

type Syncer

+ GetSyncSubs func(dvid.Data) SyncSubs

+ SetSync func(uuid dvid.UUID, in io.ReadCloser) error

type Type

+ func (t *Type) Do(cmd Request, reply *Response) error

+ type TypeMigrator interface

+ MigrateData func() (DataService, error)

type TypeService

+ Do func(Request, *Response) error

v0.7.1

Nov 17, 2015

Changes in this version

+ type Updater struct

+ func (u *Updater) StartUpdate()

+ func (u *Updater) StopUpdate()

+ func (u *Updater) Updating() bool

v0.7.0

Oct 13, 2015

Changes in this version

+ const RPCAddress

+ const RepoFormatVersion

+ const Version

+ const WebAddress

+ const WebClientDir

+ var Compiled map[dvid.URLString]TypeService

+ var ErrBadMergeType = errors.New("bad merge type")

+ var ErrBranchUnlockedNode = errors.New("can't branch an unlocked node")

+ var ErrExistingUUID = errors.New("UUID already exists in datastore")

+ var ErrInvalidDataName = errors.New("invalid data instance name")

+ var ErrInvalidRepoID = errors.New("server-specific repo id is invalid")

+ var ErrInvalidUUID = errors.New("UUID is not present in datastore")

+ var ErrInvalidVersion = errors.New("server-specific version id is invalid")

+ var ErrManagerNotInitialized = errors.New("datastore repo manager not initialized")

+ var ErrModifyLockedNode = errors.New("can't modify locked node")

+ func AddToNodeLog(uuid dvid.UUID, msgs []string) error

+ func AddToRepoLog(uuid dvid.UUID, msgs []string) error

+ func Close() error

+ func CloseReopenTest()

+ func CloseTest()

+ func Commit(uuid dvid.UUID, note string, log []string) error

+ func CompiledChart() string

+ func CompiledNames() string

+ func CompiledURLs() string

+ func DeleteConflicts(uuid dvid.UUID, data DataService, oldParents, newParents []dvid.UUID) error

+ func DeleteDataByUUID(uuid dvid.UUID, name dvid.InstanceName) error

+ func DeleteDataByVersion(v dvid.VersionID, name dvid.InstanceName) error

+ func DeleteRepo(uuid dvid.UUID) error

+ func GetChildrenByVersion(v dvid.VersionID) ([]dvid.VersionID, error)

+ func GetNodeLog(uuid dvid.UUID) ([]string, error)

+ func GetParentsByVersion(v dvid.VersionID) ([]dvid.VersionID, error)

+ func GetRepoAlias(uuid dvid.UUID) (string, error)

+ func GetRepoDescription(uuid dvid.UUID) (string, error)

+ func GetRepoJSON(uuid dvid.UUID) (string, error)

+ func GetRepoLog(uuid dvid.UUID) ([]string, error)

+ func GetRepoRoot(uuid dvid.UUID) (dvid.UUID, error)

+ func GetRepoRootVersion(v dvid.VersionID) (dvid.VersionID, error)

+ func GetTestStoreConfig() (*dvid.StoreConfig, error)

+ func Initialize(initMetadata bool, iconfig *InstanceConfig) error

+ func LockedUUID(uuid dvid.UUID) (bool, error)

+ func LockedVersion(v dvid.VersionID) (bool, error)

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

+ func MatchingUUID(uuidStr string) (dvid.UUID, dvid.VersionID, error)

+ func Merge(parents []dvid.UUID, note string, mt MergeType) (dvid.UUID, error)

+ func ModifyDataConfigByUUID(uuid dvid.UUID, name dvid.InstanceName, c dvid.Config) error

+ func NewInstanceID() (dvid.InstanceID, error)

+ func NewRepo(alias, description string, assign *dvid.UUID) (dvid.UUID, error)

+ func NewRepoID() (dvid.RepoID, error)

+ func NewTestRepo() (dvid.UUID, dvid.VersionID)

+ func NewUUID(assign *dvid.UUID) (dvid.UUID, dvid.VersionID, error)

+ func NewVersion(parent dvid.UUID, note string, assign *dvid.UUID) (dvid.UUID, error)

+ func NotifySubscribers(e SyncEvent, m SyncMessage) error

+ func OpenTest()

+ func Register(t TypeService)

+ func RegisterAsyncMigration(f MigrationFunc, desc string)

+ func SaveDataByUUID(uuid dvid.UUID, data DataService) error

+ func SaveDataByVersion(v dvid.VersionID, data DataService) error

+ func SetNodeNote(uuid dvid.UUID, note string) error

+ func SetRepoAlias(uuid dvid.UUID, alias string) error

+ func SetRepoDescription(uuid dvid.UUID, desc string) error

+ func Shutdown()

+ func Types() (map[dvid.URLString]TypeService, error)

+ func UUIDFromVersion(v dvid.VersionID) (dvid.UUID, error)

+ func VersionFromUUID(uuid dvid.UUID) (dvid.VersionID, error)

+ type CommitSyncer interface

+ SyncOnCommit func(dvid.UUID, dvid.VersionID)

+ type Data struct

+ func NewDataService(t TypeService, uuid dvid.UUID, id dvid.InstanceID, name dvid.InstanceName, ...) (*Data, error)

+ func (d *Data) Checksum() dvid.Checksum

+ func (d *Data) Compression() dvid.Compression

+ func (d *Data) DataName() dvid.InstanceName

+ func (d *Data) Equals(d2 *Data) bool

+ func (d *Data) GetType() TypeService

+ func (d *Data) GobDecode(b []byte) error

+ func (d *Data) GobEncode() ([]byte, error)

+ func (d *Data) InstanceID() dvid.InstanceID

+ func (d *Data) IsSyncEstablished(name dvid.InstanceName) bool

+ func (d *Data) MarshalJSON() ([]byte, error)

+ func (d *Data) ModifyConfig(config dvid.Config) error

+ func (d *Data) SetInstanceID(id dvid.InstanceID)

+ func (d *Data) SyncEstablished(name dvid.InstanceName)

+ func (d *Data) SyncedNames() []dvid.InstanceName

+ func (d *Data) TypeName() dvid.TypeString

+ func (d *Data) TypeURL() dvid.URLString

+ func (d *Data) TypeVersion() string

+ func (d *Data) UnknownCommand(request Request) error

+ func (d *Data) Versioned() bool

+ type DataAvail uint8

+ const DataComplete

+ const DataDeleted

+ const DataDelta

+ const DataRoot

+ func (avail DataAvail) String() string

+ type DataService interface

+ DoRPC func(Request, *Response) error

+ GetType func() TypeService

+ Help func() string

+ ModifyConfig func(dvid.Config) error

+ Send func(s message.Socket, roiname string, uuid dvid.UUID) error

+ ServeHTTP func(dvid.UUID, *VersionedCtx, http.ResponseWriter, *http.Request)

+ func GetDataByUUID(uuid dvid.UUID, name dvid.InstanceName) (DataService, error)

+ func GetDataByVersion(v dvid.VersionID, name dvid.InstanceName) (DataService, error)

+ func NewData(uuid dvid.UUID, t TypeService, name dvid.InstanceName, c dvid.Config) (DataService, error)

+ type InstanceConfig struct

+ Gen string

+ Start dvid.InstanceID

+ type InstanceMutator interface

+ LoadMutable func(root dvid.VersionID, storedVersion, expectedVersion uint64) (saveNeeded bool, err error)

+ type MergeType uint8

+ const MergeConflictFree

+ const MergeExternalData

+ const MergeTypeSpecificAuto

+ type MigrationFunc func()

+ type Request struct

+ Input []byte

+ type Response struct

+ Output []byte

+ func (r *Response) Write(w io.Writer) error

+ type SyncEvent struct

+ Event string

+ Instance dvid.InstanceName

+ type SyncMessage struct

+ Delta interface{}

+ Version dvid.VersionID

+ type SyncSub struct

+ Ch chan SyncMessage

+ Done chan struct{}

+ Event SyncEvent

+ Notify dvid.InstanceName

+ type Syncer interface

+ InitSync func(dvid.InstanceName) []SyncSub

+ SyncedNames func() []dvid.InstanceName

+ type Type struct

+ Name dvid.TypeString

+ Requirements *storage.Requirements

+ URL dvid.URLString

+ Version string

+ func (t *Type) GetStorageRequirements() *storage.Requirements

+ func (t *Type) GetTypeName() dvid.TypeString

+ func (t *Type) GetTypeURL() dvid.URLString

+ func (t *Type) GetTypeVersion() string

+ type TypeService interface

+ GetStorageRequirements func() *storage.Requirements

+ GetTypeName func() dvid.TypeString

+ GetTypeURL func() dvid.URLString

+ GetTypeVersion func() string

+ Help func() string

+ NewDataService func(dvid.UUID, dvid.InstanceID, dvid.InstanceName, dvid.Config) (DataService, error)

+ func TypeServiceByName(name dvid.TypeString) (TypeService, error)

+ func TypeServiceByURL(url dvid.URLString) (TypeService, error)

+ type VersionInitializer interface

+ InitVersion func(dvid.UUID, dvid.VersionID) error

+ type VersionedCtx struct

+ func NewVersionedCtx(data dvid.Data, versionID dvid.VersionID) *VersionedCtx

+ func (vctx *VersionedCtx) String() string

+ func (vctx *VersionedCtx) Versioned() bool

+ func (vctx *VersionedCtx) VersionedKeyValue(values []*storage.KeyValue) (*storage.KeyValue, error)

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