models

Documentation

Index

• Constants
• type BBSEventer
• type Backend
• type BackendSet
• type BackendSetRepo
  • func NewBackendSetRepo(bbs BBSEventer, logger lager.Logger, tChan <-chan time.Time) BackendSetRepo
• type CAPIDiegoProcessAssociation
• type CAPIDiegoProcessAssociationsRepo
  • func (c *CAPIDiegoProcessAssociationsRepo) Delete(capiProcessGUID *CAPIProcessGUID)
  • func (c *CAPIDiegoProcessAssociationsRepo) Get(capiProcessGUID *CAPIProcessGUID) *CAPIDiegoProcessAssociation
  • func (c *CAPIDiegoProcessAssociationsRepo) List() map[CAPIProcessGUID]*DiegoProcessGUIDs
  • func (c *CAPIDiegoProcessAssociationsRepo) Sync(capiDiegoProcessAssociations []*CAPIDiegoProcessAssociation)
  • func (c *CAPIDiegoProcessAssociationsRepo) Upsert(capiDiegoProcessAssociation *CAPIDiegoProcessAssociation)
• type CAPIProcessGUID
• type DiegoBackendSetRepo
  • func (b *DiegoBackendSetRepo) Get(guid DiegoProcessGUID) *BackendSet
  • func (b *DiegoBackendSetRepo) GetInternalBackends(guid DiegoProcessGUID) *BackendSet
  • func (b *DiegoBackendSetRepo) Run(signals <-chan os.Signal, ready chan<- struct{}) error
• type DiegoProcessGUID
• type DiegoProcessGUIDs
  • func DiegoProcessGUIDsFromStringSlice(diegoProcessGUIDs []string) DiegoProcessGUIDs
  • func (p DiegoProcessGUIDs) ToStringSlice() []string
• type NoopBackendSetRepo
  • func (b *NoopBackendSetRepo) Get(guid DiegoProcessGUID) *BackendSet
  • func (b *NoopBackendSetRepo) GetInternalBackends(guid DiegoProcessGUID) *BackendSet
  • func (b *NoopBackendSetRepo) Run(signals <-chan os.Signal, ready chan<- struct{}) error
• type Route
  • func (r *Route) GetPath() string
  • func (r *Route) Hostname() string
• type RouteGUID
• type RouteMapping
  • func (r *RouteMapping) Key() string
• type RouteMappingsRepo
  • func NewRouteMappingsRepo() *RouteMappingsRepo
  • func (r *RouteMappingsRepo) GetCalculatedWeight(rm *RouteMapping) int32
  • func (m *RouteMappingsRepo) List() map[string]*RouteMapping
  • func (m *RouteMappingsRepo) Map(rm *RouteMapping)
  • func (m *RouteMappingsRepo) Sync(routeMappings []*RouteMapping)
  • func (m *RouteMappingsRepo) Unmap(rm *RouteMapping)
• type RouteWithBackends
• type RoutesRepo
  • func NewRoutesRepo() *RoutesRepo
  • func (r *RoutesRepo) Delete(guid RouteGUID)
  • func (r *RoutesRepo) Get(guid RouteGUID) (*Route, bool)
  • func (r *RoutesRepo) GetVIPByName(hostname string) (string, bool)
  • func (r *RoutesRepo) List() map[string]string
  • func (r *RoutesRepo) Sync(routes []*Route)
  • func (r *RoutesRepo) Upsert(route *Route)

Constants

const CF_APP_SSH_PORT = 2222

Types

type BBSEventer

type BBSEventer interface {
	SubscribeToInstanceEvents(logger lager.Logger) (events.EventSource, error)
	ActualLRPs(lager.Logger, bbsmodels.ActualLRPFilter) ([]*bbsmodels.ActualLRP, error)
}

type Backend

type Backend struct {
	Address       string
	Port          uint32
	ContainerPort uint32
}

type BackendSet

type BackendSet struct {
	Backends []*Backend
}

type BackendSetRepo

type BackendSetRepo interface {
	Run(signals <-chan os.Signal, ready chan<- struct{}) error
	Get(guid DiegoProcessGUID) *BackendSet
	GetInternalBackends(guid DiegoProcessGUID) *BackendSet
}

func NewBackendSetRepo

func NewBackendSetRepo(bbs BBSEventer, logger lager.Logger, tChan <-chan time.Time) BackendSetRepo

type CAPIDiegoProcessAssociation

type CAPIDiegoProcessAssociation struct {
	CAPIProcessGUID   CAPIProcessGUID
	DiegoProcessGUIDs DiegoProcessGUIDs
}

type CAPIDiegoProcessAssociationsRepo

type CAPIDiegoProcessAssociationsRepo struct {
	Repo map[CAPIProcessGUID]*CAPIDiegoProcessAssociation
	sync.Mutex
}

func (*CAPIDiegoProcessAssociationsRepo) Delete

func (c *CAPIDiegoProcessAssociationsRepo) Delete(capiProcessGUID *CAPIProcessGUID)

func (*CAPIDiegoProcessAssociationsRepo) Get

func (c *CAPIDiegoProcessAssociationsRepo) Get(capiProcessGUID *CAPIProcessGUID) *CAPIDiegoProcessAssociation

func (*CAPIDiegoProcessAssociationsRepo) List

func (c *CAPIDiegoProcessAssociationsRepo) List() map[CAPIProcessGUID]*DiegoProcessGUIDs

func (*CAPIDiegoProcessAssociationsRepo) Sync

func (c *CAPIDiegoProcessAssociationsRepo) Sync(capiDiegoProcessAssociations []*CAPIDiegoProcessAssociation)

func (*CAPIDiegoProcessAssociationsRepo) Upsert

func (c *CAPIDiegoProcessAssociationsRepo) Upsert(capiDiegoProcessAssociation *CAPIDiegoProcessAssociation)

type CAPIProcessGUID

type CAPIProcessGUID string

type DiegoBackendSetRepo

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

func (*DiegoBackendSetRepo) Get

func (b *DiegoBackendSetRepo) Get(guid DiegoProcessGUID) *BackendSet

func (*DiegoBackendSetRepo) GetInternalBackends

func (b *DiegoBackendSetRepo) GetInternalBackends(guid DiegoProcessGUID) *BackendSet

func (*DiegoBackendSetRepo) Run

func (b *DiegoBackendSetRepo) Run(signals <-chan os.Signal, ready chan<- struct{}) error

type DiegoProcessGUID

type DiegoProcessGUID string

type DiegoProcessGUIDs

type DiegoProcessGUIDs []DiegoProcessGUID

func DiegoProcessGUIDsFromStringSlice

func DiegoProcessGUIDsFromStringSlice(diegoProcessGUIDs []string) DiegoProcessGUIDs

func (DiegoProcessGUIDs) ToStringSlice

func (p DiegoProcessGUIDs) ToStringSlice() []string

type NoopBackendSetRepo

type NoopBackendSetRepo struct{}

func (*NoopBackendSetRepo) Get

func (b *NoopBackendSetRepo) Get(guid DiegoProcessGUID) *BackendSet

func (*NoopBackendSetRepo) GetInternalBackends

func (b *NoopBackendSetRepo) GetInternalBackends(guid DiegoProcessGUID) *BackendSet

func (*NoopBackendSetRepo) Run

func (b *NoopBackendSetRepo) Run(signals <-chan os.Signal, ready chan<- struct{}) error

type Route

type Route struct {
	GUID     RouteGUID
	Host     string
	Path     string
	Internal bool
	VIP      string
}

func (*Route) GetPath

func (r *Route) GetPath() string

func (*Route) Hostname

func (r *Route) Hostname() string

type RouteGUID

type RouteGUID string

type RouteMapping

type RouteMapping struct {
	RouteGUID       RouteGUID
	CAPIProcessGUID CAPIProcessGUID
	RouteWeight     uint32
}

func (*RouteMapping) Key

func (r *RouteMapping) Key() string

type RouteMappingsRepo

type RouteMappingsRepo struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewRouteMappingsRepo

func NewRouteMappingsRepo() *RouteMappingsRepo

func (*RouteMappingsRepo) GetCalculatedWeight

func (r *RouteMappingsRepo) GetCalculatedWeight(rm *RouteMapping) int32

func (*RouteMappingsRepo) List

func (m *RouteMappingsRepo) List() map[string]*RouteMapping

func (*RouteMappingsRepo) Map

func (m *RouteMappingsRepo) Map(rm *RouteMapping)

func (*RouteMappingsRepo) Sync

func (m *RouteMappingsRepo) Sync(routeMappings []*RouteMapping)

func (*RouteMappingsRepo) Unmap

func (m *RouteMappingsRepo) Unmap(rm *RouteMapping)

type RouteWithBackends

type RouteWithBackends struct {
	Hostname        string
	Path            string
	Backends        BackendSet
	CapiProcessGUID string
	RouteWeight     int32
	Internal        bool
	VIP             string
}

type RoutesRepo

type RoutesRepo struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewRoutesRepo

func NewRoutesRepo() *RoutesRepo

func (*RoutesRepo) Delete

func (r *RoutesRepo) Delete(guid RouteGUID)

func (*RoutesRepo) Get

func (r *RoutesRepo) Get(guid RouteGUID) (*Route, bool)

func (*RoutesRepo) GetVIPByName

func (r *RoutesRepo) GetVIPByName(hostname string) (string, bool)

func (*RoutesRepo) List

func (r *RoutesRepo) List() map[string]string

TODO: probably remove or clean this up, currently using for debugging

func (*RoutesRepo) Sync

func (r *RoutesRepo) Sync(routes []*Route)

func (*RoutesRepo) Upsert

func (r *RoutesRepo) Upsert(route *Route)