server

package
v1.0.1-RCX5 Latest Latest
Warning

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

Go to latest
Published: Jun 27, 2016 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrIDSet        = errors.New("pachyderm.pps.persist.server: ID set")
	ErrIDNotSet     = errors.New("pachyderm.pps.persist.server: ID not set")
	ErrTimestampSet = errors.New("pachyderm.pps.persist.server: Timestamp set")
)

Functions

func CheckDBs

func CheckDBs(address string, databaseName string) error

CheckDBs checks that we have all the tables/indices we need

func InitDBs

func InitDBs(address string, databaseName string) error

InitDBs prepares a RethinkDB instance to be used by the rethink server. Rethink servers will error if they are pointed at databases that haven't had InitDBs run on them.

Types

type APIServer

type APIServer interface {
	persist.APIServer
	Close() error
}

func NewRethinkAPIServer

func NewRethinkAPIServer(address string, databaseName string) (APIServer, error)

type Index

type Index string

type PipelineChangeFeed

type PipelineChangeFeed struct {
	OldVal *persist.PipelineInfo `gorethink:"old_val,omitempty"`
	NewVal *persist.PipelineInfo `gorethink:"new_val,omitempty"`
}

type PrimaryKey

type PrimaryKey string

type Table

type Table string

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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