database

package
v0.0.0-...-c2c271f Latest Latest
Warning

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

Go to latest
Published: Nov 1, 2016 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Adapter

type Adapter interface {
	AddNode(string) error
	FormCluster() error
	Connect() error
	Cluster() *riak.Cluster
	Close() error
}

type Database

type Database struct {
	Cluster RiakCluster
	Config  *config.Config
	Logger  *logger.Logger
	Riak    Adapter
}

func New

func New(r Adapter, c *config.Config, l *logger.Logger) (*Database, error)

func (*Database) Close

func (d *Database) Close() error

type Riak

type Riak struct {
	Nodes []*riak.Node
	// contains filtered or unexported fields
}

func (*Riak) AddNode

func (r *Riak) AddNode(nodeAddress string) error

func (*Riak) Close

func (r *Riak) Close() error

func (*Riak) Cluster

func (r *Riak) Cluster() *riak.Cluster

func (*Riak) Connect

func (r *Riak) Connect() error

func (*Riak) FormCluster

func (r *Riak) FormCluster() error

type RiakCluster

type RiakCluster interface {
	Execute(riak.Command) error
	Start() error
	Stop() error
}

Jump to

Keyboard shortcuts

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