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 filer2.FullPath) error
  • func (store *CassandraStore) FindEntry(ctx context.Context, fullpath filer2.FullPath) (entry *filer2.Entry, err error)
  • func (store *CassandraStore) GetName() string
  • func (store *CassandraStore) Initialize(configuration util.Configuration) (err error)
  • func (store *CassandraStore) InsertEntry(ctx context.Context, entry *filer2.Entry) (err error)
  • func (store *CassandraStore) ListDirectoryEntries(ctx context.Context, fullpath filer2.FullPath, startFileName string, ...) (entries []*filer2.Entry, err error)
  • func (store *CassandraStore) RollbackTransaction(ctx context.Context) error
  • func (store *CassandraStore) UpdateEntry(ctx context.Context, entry *filer2.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 filer2.FullPath) error

func (*CassandraStore) FindEntry

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

func (*CassandraStore) GetName

func (store *CassandraStore) GetName() string

func (*CassandraStore) Initialize

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

func (*CassandraStore) InsertEntry

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

func (*CassandraStore) ListDirectoryEntries

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

func (*CassandraStore) RollbackTransaction

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

func (*CassandraStore) UpdateEntry

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