Documentation ¶
Index ¶
- type CassandraMetaStore
- func (self *CassandraMetaStore) AddProject(name string) error
- func (self *CassandraMetaStore) AddUser(user, pass string) error
- func (self *CassandraMetaStore) Authenticate(user, pass string) (bool, error)
- func (self *CassandraMetaStore) Close()
- func (self *CassandraMetaStore) Commit(v *meta.RequestVars) (*meta.Object, error)
- func (self *CassandraMetaStore) DeleteUser(user string) error
- func (self *CassandraMetaStore) Get(v *meta.RequestVars) (*meta.Object, error)
- func (self *CassandraMetaStore) GetPending(v *meta.RequestVars) (*meta.Object, error)
- func (self *CassandraMetaStore) Objects() ([]*meta.Object, error)
- func (self *CassandraMetaStore) Projects() ([]*meta.Project, error)
- func (self *CassandraMetaStore) Put(v *meta.RequestVars) (*meta.Object, error)
- func (self *CassandraMetaStore) Users() ([]*meta.User, error)
- type CassandraService
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
type CassandraService ¶
func NewCassandraSession ¶
func NewCassandraSession(cfg *config.CassandraConfig) (*CassandraService, error)
TODO: Add auth for cassandra
Click to show internal directories.
Click to hide internal directories.