db

Documentation

Index

• Constants
• func NewETCD(nodeURLs []string, maxWorkers uint) (*etcd, error)
• type DB
• type DBError
  • func (err DBError) Error() string
• type Route
• type RouterGroup
• type RouterGroupType
• type TcpRoute
• type TcpRouteMapping
  • func NewTcpRouteMapping(routerGroupGuid string, externalPort uint16, hostIP string, hostPort uint16) TcpRouteMapping
  • func (m TcpRouteMapping) String() string

Constants

const (
	TCP_MAPPING_BASE_KEY string = "/v1/tcp_routes/router_groups"
	HTTP_ROUTE_BASE_KEY  string = "/routes"
)

const (
	KeyNotFound = "KeyNotFound"
)

Functions

func NewETCD

func NewETCD(nodeURLs []string, maxWorkers uint) (*etcd, error)

Types

type DB

type DB interface {
	ReadRoutes() ([]Route, error)
	SaveRoute(route Route) error
	DeleteRoute(route Route) error

	ReadTcpRouteMappings() ([]TcpRouteMapping, error)
	SaveTcpRouteMapping(tcpMapping TcpRouteMapping) error
	DeleteTcpRouteMapping(tcpMapping TcpRouteMapping) error

	Connect() error
	Disconnect() error
	WatchRouteChanges(filter string) (<-chan storeadapter.WatchEvent, chan<- bool, <-chan error)
}

type DBError

type DBError struct {
	Type    string
	Message string
}

func (DBError) Error

func (err DBError) Error() string

type Route

type Route struct {
	Route           string `json:"route"`
	Port            uint16 `json:"port"`
	IP              string `json:"ip"`
	TTL             int    `json:"ttl"`
	LogGuid         string `json:"log_guid"`
	RouteServiceUrl string `json:"route_service_url,omitempty"`
}

type RouterGroup

type RouterGroup struct {
	Guid string          `json:"guid"`
	Name string          `json:"name"`
	Type RouterGroupType `json:"type"`
}

type RouterGroupType

type RouterGroupType string

type TcpRoute

type TcpRoute struct {
	RouterGroupGuid string `json:"router_group_guid"`
	ExternalPort    uint16 `json:"port"`
}

type TcpRouteMapping

type TcpRouteMapping struct {
	TcpRoute
	HostPort uint16 `json:"backend_port"`
	HostIP   string `json:"backend_ip"`
}

func NewTcpRouteMapping

func NewTcpRouteMapping(routerGroupGuid string, externalPort uint16, hostIP string, hostPort uint16) TcpRouteMapping

func (TcpRouteMapping) String

func (m TcpRouteMapping) String() string