server

Documentation

Index

• Variables
• func InitDBs(address string, databaseName string) error
• type APIServer
  • func NewRethinkAPIServer(address string, databaseName string) (APIServer, error)
• type Index
• type PrimaryKey
• type Table

Variables

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 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. InitDBs is idempotent (unless rethink dies in the middle of the function)

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 PrimaryKey

type PrimaryKey string

type Table

type Table string