cassandra

package
v0.0.0-...-094c5f7 Latest Latest
Warning

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

Go to latest
Published: Dec 12, 2016 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CassandraMetaStore

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

func NewCassandraMetaStore

func NewCassandraMetaStore(cfg *config.CassandraConfig) (*CassandraMetaStore, error)

func (*CassandraMetaStore) AddProject

func (self *CassandraMetaStore) AddProject(name string) error

AddProject (create a new project using POST)

func (*CassandraMetaStore) AddUser

func (self *CassandraMetaStore) AddUser(user, pass string) error

Adds a user to the system

func (*CassandraMetaStore) Authenticate

func (self *CassandraMetaStore) Authenticate(user, pass string) (bool, error)

Auth routine. Requires an auth string like "Basic YWRtaW46YWRtaW4="

func (*CassandraMetaStore) Close

func (self *CassandraMetaStore) Close()

func (*CassandraMetaStore) Commit

func (self *CassandraMetaStore) Commit(v *meta.RequestVars) (*meta.Object, error)

Commit() finds uncommitted objects in the meta store using data in meta.RequestVars and commits them

func (*CassandraMetaStore) DeleteUser

func (self *CassandraMetaStore) DeleteUser(user string) error

Removes a user from the system Usage: DeleteUser("testuser")

func (*CassandraMetaStore) Get

func (self *CassandraMetaStore) Get(v *meta.RequestVars) (*meta.Object, error)

Get() retrieves meta information for a committed object given information in meta.RequestVars

func (*CassandraMetaStore) GetPending

func (self *CassandraMetaStore) GetPending(v *meta.RequestVars) (*meta.Object, error)

Same as Get() but for uncommitted objects

func (*CassandraMetaStore) Objects

func (self *CassandraMetaStore) Objects() ([]*meta.Object, error)

returns all Oids

func (*CassandraMetaStore) Projects

func (self *CassandraMetaStore) Projects() ([]*meta.Project, error)

Returns a []*meta.Project

func (*CassandraMetaStore) Put

func (self *CassandraMetaStore) Put(v *meta.RequestVars) (*meta.Object, error)

Put() creates uncommitted objects from meta.RequestVars and stores them in the meta store

func (*CassandraMetaStore) Users

func (self *CassandraMetaStore) Users() ([]*meta.User, error)

returns all users

type CassandraService

type CassandraService struct {
	Client *gocql.Session
}

func NewCassandraSession

func NewCassandraSession(cfg *config.CassandraConfig) (*CassandraService, error)

TODO: Add auth for cassandra

Jump to

Keyboard shortcuts

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