cassandra

package
v0.0.0-...-d8c34b0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Sep 12, 2019 License: Apache-2.0 Imports: 6 Imported by: 0

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

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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)

Jump to

Keyboard shortcuts

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