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        = 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