arangodb

README

##arangodb

database: https://github.com/arangodb/arangodb go driver: https://github.com/arangodb/go-driver

options:

[arangodb]
enabled=true
db_name="seaweedfs"
servers=["http://localhost:8529"]
#basic auth
user="root"
pass="test"

# tls settings
insecure_skip_verify=true

i test using this dev database: docker run -p 8529:8529 -e ARANGO_ROOT_PASSWORD=test arangodb/arangodb:3.9.0

features i don't personally need but are missing

[ ] provide tls cert to arango [ ] authentication that is not basic auth [ ] synchronise endpoint interval config [ ] automatic creation of custom index [ ] configure default arangodb collection sharding rules [ ] configure default arangodb collection replication rules

complexity

ok, so if https://www.arangodb.com/docs/stable/indexing-index-basics.html#persistent-index is correct

O(1)

• InsertEntry
• UpdateEntry
• FindEntry
• DeleteEntry
• KvPut
• KvGet
• KvDelete

O(log(BUCKET_SIZE))

• DeleteFolderChildren

O(log(DIRECTORY_SIZE))

• ListDirectoryEntries
• ListDirectoryPrefixedEntries

Documentation

Index

• Variables
• type ArangodbStore
  • func (store *ArangodbStore) BeginTransaction(ctx context.Context) (context.Context, error)
  • func (store *ArangodbStore) CanDropWholeBucket() bool
  • func (store *ArangodbStore) CommitTransaction(ctx context.Context) error
  • func (store *ArangodbStore) DeleteEntry(ctx context.Context, fullpath util.FullPath) (err error)
  • func (store *ArangodbStore) DeleteFolderChildren(ctx context.Context, fullpath util.FullPath) (err error)
  • func (store *ArangodbStore) FindEntry(ctx context.Context, fullpath util.FullPath) (entry *filer.Entry, err error)
  • func (store *ArangodbStore) GetName() string
  • func (store *ArangodbStore) Initialize(configuration util.Configuration, prefix string) (err error)
  • func (store *ArangodbStore) InsertEntry(ctx context.Context, entry *filer.Entry) (err error)
  • func (store *ArangodbStore) KvDelete(ctx context.Context, key []byte) (err error)
  • func (store *ArangodbStore) KvGet(ctx context.Context, key []byte) (value []byte, err error)
  • func (store *ArangodbStore) KvPut(ctx context.Context, key []byte, value []byte) (err error)
  • func (store *ArangodbStore) ListDirectoryEntries(ctx context.Context, dirPath util.FullPath, startFileName string, ...) (lastFileName string, err error)
  • func (store *ArangodbStore) ListDirectoryPrefixedEntries(ctx context.Context, dirPath util.FullPath, startFileName string, ...) (lastFileName string, err error)
  • func (store *ArangodbStore) OnBucketCreation(bucket string)
  • func (store *ArangodbStore) OnBucketDeletion(bucket string)
  • func (store *ArangodbStore) RollbackTransaction(ctx context.Context) error
  • func (store *ArangodbStore) Shutdown()
  • func (store *ArangodbStore) UpdateEntry(ctx context.Context, entry *filer.Entry) (err error)
• type Model

Variables

var (
	BUCKET_PREFIX      = "/buckets"
	DEFAULT_COLLECTION = "seaweed_no_bucket"
	KVMETA_COLLECTION  = "seaweed_kvmeta"
)

Types

type ArangodbStore

type ArangodbStore struct {
	// contains filtered or unexported fields
}

func (*ArangodbStore) BeginTransaction

func (store *ArangodbStore) BeginTransaction(ctx context.Context) (context.Context, error)

func (*ArangodbStore) CanDropWholeBucket

func (store *ArangodbStore) CanDropWholeBucket() bool

func (*ArangodbStore) CommitTransaction

func (store *ArangodbStore) CommitTransaction(ctx context.Context) error

func (*ArangodbStore) DeleteEntry

func (store *ArangodbStore) DeleteEntry(ctx context.Context, fullpath util.FullPath) (err error)

func (*ArangodbStore) DeleteFolderChildren

func (store *ArangodbStore) DeleteFolderChildren(ctx context.Context, fullpath util.FullPath) (err error)

this runs in log time

func (*ArangodbStore) FindEntry

func (store *ArangodbStore) FindEntry(ctx context.Context, fullpath util.FullPath) (entry *filer.Entry, err error)

func (*ArangodbStore) GetName

func (store *ArangodbStore) GetName() string

func (*ArangodbStore) Initialize

func (store *ArangodbStore) Initialize(configuration util.Configuration, prefix string) (err error)

func (*ArangodbStore) InsertEntry

func (store *ArangodbStore) InsertEntry(ctx context.Context, entry *filer.Entry) (err error)

func (*ArangodbStore) KvDelete

func (store *ArangodbStore) KvDelete(ctx context.Context, key []byte) (err error)

func (*ArangodbStore) KvGet

func (store *ArangodbStore) KvGet(ctx context.Context, key []byte) (value []byte, err error)

func (*ArangodbStore) KvPut

func (store *ArangodbStore) KvPut(ctx context.Context, key []byte, value []byte) (err error)

func (*ArangodbStore) ListDirectoryEntries

func (store *ArangodbStore) ListDirectoryEntries(ctx context.Context, dirPath util.FullPath, startFileName string, includeStartFile bool, limit int64, eachEntryFunc filer.ListEachEntryFunc) (lastFileName string, err error)

func (*ArangodbStore) ListDirectoryPrefixedEntries

func (store *ArangodbStore) ListDirectoryPrefixedEntries(ctx context.Context, dirPath util.FullPath, startFileName string, includeStartFile bool, limit int64, prefix string, eachEntryFunc filer.ListEachEntryFunc) (lastFileName string, err error)

func (*ArangodbStore) OnBucketCreation

func (store *ArangodbStore) OnBucketCreation(bucket string)

func (*ArangodbStore) OnBucketDeletion

func (store *ArangodbStore) OnBucketDeletion(bucket string)

func (*ArangodbStore) RollbackTransaction

func (store *ArangodbStore) RollbackTransaction(ctx context.Context) error

func (*ArangodbStore) Shutdown

func (store *ArangodbStore) Shutdown()

func (*ArangodbStore) UpdateEntry

func (store *ArangodbStore) UpdateEntry(ctx context.Context, entry *filer.Entry) (err error)

type Model

type Model struct {
	Key       string `json:"_key"`
	Directory string `json:"directory,omitempty"`
	Name      string `json:"name,omitempty"`
	Ttl       string `json:"ttl,omitempty"`

	//arangodb does not support binary blobs
	//we encode byte slice into uint64 slice
	//see helpers.go
	Meta []uint64 `json:"meta"`
}