db

Documentation

Index

• Constants
• Variables
• func LookupPortByService(ports map[string]int, service string) int
• type DB
  • func New(driverName, dsn string) (*DB, error)
  • func (d *DB) APIKeys() (string, string, error)
  • func (d *DB) Checkin(member Member, i int) error
  • func (d *DB) Delete(uuid string) error
  • func (d *DB) Members() ([]Member, error)
  • func (d *DB) Migrate() error
  • func (d *DB) SaveIndex(indexes map[int]Member) error
• type Member
• type Members
  • func (a Members) Len() int
  • func (a Members) Less(i, j int) bool
  • func (a Members) Swap(i, j int)
• type NullStringWrapper
  • func (n *NullStringWrapper) Scan(value interface{}) error

Constants

const (
	Swarm        = "swarm"
	PPHTTP       = "pp-http"
	PPHTTPS      = "pp-https"
	HTTP         = "http"
	HTTPS        = "https"
	Redis        = "redis"
	Zk           = "zk"
	ZkQuorumPort = "zk-quorum"
	ZkLeaderPort = "zk-leader"
	ZkClientPort = "zk-client"

	RedisPortBase     = 6379
	ZkPortBase        = 2888
	ZkPortBase2       = 3888
	ZkPortBaseClient  = 2181
	RancherServerPort = 18080
)

Variables

var (
	ServicePorts        = []string{Redis, ZkQuorumPort, ZkLeaderPort, ZkClientPort}
	DefaultServicePorts = map[string]int{
		Swarm:        2376,
		PPHTTP:       81,
		PPHTTPS:      444,
		HTTP:         80,
		HTTPS:        443,
		Redis:        RedisPortBase,
		ZkQuorumPort: ZkPortBase,
		ZkLeaderPort: ZkPortBase2,
		ZkClientPort: ZkPortBaseClient,
	}
)

Functions

func LookupPortByService

func LookupPortByService(ports map[string]int, service string) int

Types

type DB

type DB struct {
	// contains filtered or unexported fields
}

func New

func New(driverName, dsn string) (*DB, error)

func (*DB) APIKeys

func (d *DB) APIKeys() (string, string, error)

func (*DB) Checkin

func (d *DB) Checkin(member Member, i int) error

func (*DB) Delete

func (d *DB) Delete(uuid string) error

func (*DB) Members

func (d *DB) Members() ([]Member, error)

func (*DB) Migrate

func (d *DB) Migrate() error

func (*DB) SaveIndex

func (d *DB) SaveIndex(indexes map[int]Member) error

type Member

type Member struct {
	ID             int
	Name           string
	UUID           string
	IP             string
	Ports          map[string]int
	RequestedIndex int
	Heartbeat      int
	Index          int
}

type Members

type Members []Member

func (Members) Len

func (a Members) Len() int

func (Members) Less

func (a Members) Less(i, j int) bool

func (Members) Swap

func (a Members) Swap(i, j int)

type NullStringWrapper

type NullStringWrapper struct {
	sql.NullString
	String *string
}

func (*NullStringWrapper) Scan

func (n *NullStringWrapper) Scan(value interface{}) error