cassandra

README

1. create a keyspace

CREATE KEYSPACE seaweedfs WITH replication = {'class':'SimpleStrategy', 'replication_factor' : 1};

2. create filemeta table

 USE seaweedfs;

 CREATE TABLE filemeta (
    directory varchar,
    name varchar,
    meta blob,
    PRIMARY KEY (directory, name)
 ) WITH CLUSTERING ORDER BY (name ASC);

Documentation

Index

• type CassandraStore
  • func (store *CassandraStore) BeginTransaction(ctx context.Context) (context.Context, error)
  • func (store *CassandraStore) CommitTransaction(ctx context.Context) error
  • func (store *CassandraStore) DeleteEntry(ctx context.Context, fullpath util.FullPath) error
  • func (store *CassandraStore) DeleteFolderChildren(ctx context.Context, fullpath util.FullPath) error
  • func (store *CassandraStore) FindEntry(ctx context.Context, fullpath util.FullPath) (entry *filer.Entry, err error)
  • func (store *CassandraStore) GetName() string
  • func (store *CassandraStore) Initialize(configuration util.Configuration, prefix string) (err error)
  • func (store *CassandraStore) InsertEntry(ctx context.Context, entry *filer.Entry) (err error)
  • func (store *CassandraStore) KvDelete(ctx context.Context, key []byte) (err error)
  • func (store *CassandraStore) KvGet(ctx context.Context, key []byte) (data []byte, err error)
  • func (store *CassandraStore) KvPut(ctx context.Context, key []byte, value []byte) (err error)
  • func (store *CassandraStore) ListDirectoryEntries(ctx context.Context, fullpath util.FullPath, startFileName string, ...) (entries []*filer.Entry, err error)
  • func (store *CassandraStore) ListDirectoryPrefixedEntries(ctx context.Context, fullpath util.FullPath, startFileName string, ...) (entries []*filer.Entry, err error)
  • func (store *CassandraStore) RollbackTransaction(ctx context.Context) error
  • func (store *CassandraStore) Shutdown()
  • func (store *CassandraStore) UpdateEntry(ctx context.Context, entry *filer.Entry) (err error)

Types

type CassandraStore

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

func (*CassandraStore) BeginTransaction

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

func (*CassandraStore) CommitTransaction

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

func (*CassandraStore) DeleteEntry

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

func (*CassandraStore) DeleteFolderChildren

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

func (*CassandraStore) FindEntry

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

func (*CassandraStore) GetName

func (store *CassandraStore) GetName() string

func (*CassandraStore) Initialize

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

func (*CassandraStore) InsertEntry

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

func (*CassandraStore) KvDelete

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

func (*CassandraStore) KvGet

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

func (*CassandraStore) KvPut

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

func (*CassandraStore) ListDirectoryEntries

func (store *CassandraStore) ListDirectoryEntries(ctx context.Context, fullpath util.FullPath, startFileName string, inclusive bool,
	limit int) (entries []*filer.Entry, err error)

func (*CassandraStore) ListDirectoryPrefixedEntries

func (store *CassandraStore) ListDirectoryPrefixedEntries(ctx context.Context, fullpath util.FullPath, startFileName string, inclusive bool, limit int, prefix string) (entries []*filer.Entry, err error)

func (*CassandraStore) RollbackTransaction

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

func (*CassandraStore) Shutdown

func (store *CassandraStore) Shutdown()

func (*CassandraStore) UpdateEntry

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