server

Documentation

Index

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

Variables

var (
	// ErrIDSet is used when ID is set.
	ErrIDSet = errors.New("pachyderm.pps.persist.server: ID set")
	// ErrIDNotSet is used when ID is not set.
	ErrIDNotSet = errors.New("pachyderm.pps.persist.server: ID not set")
	// ErrTimestampSet is used when Timestamp is 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
}

APIServer represents Pachyderm's interface to a persistence server such as rethinkdb.

func NewRethinkAPIServer

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

NewRethinkAPIServer creates an APIServer which connects to rethinkdb on the given address and database.

type Index

type Index string

An Index is a rethinkdb index.

type PipelineChangeFeed

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

PipelineChangeFeed is used to subscribe to rethinkdb's changefeed

type PrimaryKey

type PrimaryKey string

A PrimaryKey is a rethinkdb primary key identifier.

type Table

type Table string

A Table is a rethinkdb table name.