nodes

Documentation

Index

• Variables
• func Dial(ip net.IP) (*yamux.Session, error)
• func GenerateToasterAppsSubDomains(radix string) []string
• func GetAllLocalObjectdbNodes() []string
• func GetAllLocalRedisNodes() []string
• func GetConn(ip net.IP) (net.Conn, error)
• func GetToasterLocalRegionAppSubdomain(radix, localregion string) string
• func Init() error
• func PickTVS() (t net.IP)
• func PutConn(ip net.IP, conn net.Conn)
• type NodeServer
  • func StartNodeServer(listenToIP net.IP, handler func(net.Conn)) (*NodeServer, error)
  • func (ns *NodeServer) Stop() error

Variables

var LocalObjectdb []string

var LocalObjectdbMu sync.RWMutex

var LocalRedis []string

var LocalRedisMu sync.RWMutex

var LocalTVS []net.IP

var LocalTVSMu sync.RWMutex

var Regions []string

var RegionsMu sync.RWMutex

Functions

func Dial

func Dial(ip net.IP) (*yamux.Session, error)

func GenerateToasterAppsSubDomains

func GenerateToasterAppsSubDomains(radix string) []string

func GetAllLocalObjectdbNodes

func GetAllLocalObjectdbNodes() []string

func GetAllLocalRedisNodes

func GetAllLocalRedisNodes() []string

func GetConn

func GetConn(ip net.IP) (net.Conn, error)

GetConn add.pool must not be nil

func GetToasterLocalRegionAppSubdomain

func GetToasterLocalRegionAppSubdomain(radix, localregion string) string

func Init

func Init() error

func PickTVS

func PickTVS() (t net.IP)

func PutConn

func PutConn(ip net.IP, conn net.Conn)

Types

type NodeServer

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

func StartNodeServer

func StartNodeServer(listenToIP net.IP, handler func(net.Conn)) (*NodeServer, error)

TODO: generalize StartNodeServer to start a server for each node that shares runner comm and discovery auth and registration in addition of dns discovery

func (*NodeServer) Stop

func (ns *NodeServer) Stop() error