actors

Documentation

Index

• func NewRouteActor(ui terminal.UI, routeRepo api.RouteRepository, domainRepo api.DomainRepository) routeActor
• type PlanAccess
• type PushActor
  • func NewPushActor(appBitsRepo applicationbits.Repository, zipper appfiles.Zipper, ...) PushActor
• type PushActorImpl
  • func (actor PushActorImpl) GatherFiles(localFiles []models.AppFileFields, appDir string, uploadDir string) ([]resources.AppFileResource, bool, error)
  • func (actor PushActorImpl) MapManifestRoute(routeName string, app models.Application, ...) error
  • func (actor PushActorImpl) ProcessPath(dirOrZipFile string, f func(string) error) error
  • func (actor PushActorImpl) UploadApp(appGUID string, zipFile *os.File, presentFiles []resources.AppFileResource) error
  • func (actor PushActorImpl) ValidateAppParams(apps []models.AppParams) []error
• type RouteActor
• type ServiceAccess
• type ServiceActor
• type ServiceHandler
  • func NewServiceHandler(org organizations.OrganizationRepository, ...) ServiceHandler
  • func (actor ServiceHandler) FilterBrokers(brokerFlag string, serviceFlag string, orgFlag string) ([]models.ServiceBroker, error)
• type ServicePlanActor
• type ServicePlanHandler
  • func NewServicePlanHandler(plan api.ServicePlanRepository, vis api.ServicePlanVisibilityRepository, ...) ServicePlanHandler
  • func (actor ServicePlanHandler) FindServiceAccess(serviceName string, orgName string) (ServiceAccess, error)
  • func (actor ServicePlanHandler) UpdateAllPlansForService(serviceName string, setPlanVisibility bool) error
  • func (actor ServicePlanHandler) UpdateOrgForService(serviceName string, orgName string, setPlanVisibility bool) error
  • func (actor ServicePlanHandler) UpdatePlanAndOrgForService(serviceName, planName, orgName string, setPlanVisibility bool) error
  • func (actor ServicePlanHandler) UpdateSinglePlanForService(serviceName string, planName string, setPlanVisibility bool) error

Functions

func NewRouteActor

func NewRouteActor(ui terminal.UI, routeRepo api.RouteRepository, domainRepo api.DomainRepository) routeActor

Types

type PlanAccess

type PlanAccess int

const (
	PlanAccessError PlanAccess = iota
	All
	Limited
	None
)

type PushActor

type PushActor interface {
	UploadApp(appGUID string, zipFile *os.File, presentFiles []resources.AppFileResource) error
	ProcessPath(dirOrZipFile string, f func(string) error) error
	GatherFiles(localFiles []models.AppFileFields, appDir string, uploadDir string) ([]resources.AppFileResource, bool, error)
	ValidateAppParams(apps []models.AppParams) []error
	MapManifestRoute(routeName string, app models.Application, appParamsFromContext models.AppParams) error
}

func NewPushActor

func NewPushActor(appBitsRepo applicationbits.Repository, zipper appfiles.Zipper, appfiles appfiles.AppFiles, routeActor RouteActor) PushActor

type PushActorImpl

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

func (PushActorImpl) GatherFiles

func (actor PushActorImpl) GatherFiles(localFiles []models.AppFileFields, appDir string, uploadDir string) ([]resources.AppFileResource, bool, error)

func (PushActorImpl) MapManifestRoute

func (actor PushActorImpl) MapManifestRoute(routeName string, app models.Application, appParamsFromContext models.AppParams) error

func (PushActorImpl) ProcessPath

func (actor PushActorImpl) ProcessPath(dirOrZipFile string, f func(string) error) error

ProcessPath takes in a director of app files or a zip file which contains the app files. If given a zip file, it will extract the zip to a temporary location, call the provided callback with that location, and then clean up the location after the callback has been executed.

This was done so that the caller of ProcessPath wouldn't need to know if it was a zip file or an app dir that it was given, and the caller would not be responsible for cleaning up the temporary directory ProcessPath creates when given a zip.

func (PushActorImpl) UploadApp

func (actor PushActorImpl) UploadApp(appGUID string, zipFile *os.File, presentFiles []resources.AppFileResource) error

func (PushActorImpl) ValidateAppParams

func (actor PushActorImpl) ValidateAppParams(apps []models.AppParams) []error

type RouteActor

type RouteActor interface {
	CreateRandomTCPRoute(domain models.DomainFields) (models.Route, error)
	FindOrCreateRoute(hostname string, domain models.DomainFields, path string, port int, useRandomPort bool) (models.Route, error)
	BindRoute(app models.Application, route models.Route) error
	UnbindAll(app models.Application) error
	FindDomain(routeName string) (string, models.DomainFields, error)
	FindPath(routeName string) (string, string)
	FindPort(routeName string) (string, int, error)
	FindAndBindRoute(routeName string, app models.Application, appParamsFromContext models.AppParams) error
}

type ServiceAccess

type ServiceAccess int

const (
	ServiceAccessError ServiceAccess = iota
	AllPlansArePublic
	AllPlansArePrivate
	AllPlansAreLimited
	SomePlansArePublicSomeAreLimited
	SomePlansArePublicSomeArePrivate
	SomePlansAreLimitedSomeArePrivate
	SomePlansArePublicSomeAreLimitedSomeArePrivate
)

type ServiceActor

type ServiceActor interface {
	FilterBrokers(brokerFlag string, serviceFlag string, orgFlag string) ([]models.ServiceBroker, error)
}

type ServiceHandler

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

func NewServiceHandler

func NewServiceHandler(org organizations.OrganizationRepository, brokerBuilder brokerbuilder.BrokerBuilder, serviceBuilder servicebuilder.ServiceBuilder) ServiceHandler

func (ServiceHandler) FilterBrokers

func (actor ServiceHandler) FilterBrokers(brokerFlag string, serviceFlag string, orgFlag string) ([]models.ServiceBroker, error)

type ServicePlanActor

type ServicePlanActor interface {
	FindServiceAccess(string, string) (ServiceAccess, error)
	UpdateAllPlansForService(string, bool) error
	UpdateOrgForService(string, string, bool) error
	UpdateSinglePlanForService(string, string, bool) error
	UpdatePlanAndOrgForService(string, string, string, bool) error
}

type ServicePlanHandler

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

func NewServicePlanHandler

func NewServicePlanHandler(plan api.ServicePlanRepository, vis api.ServicePlanVisibilityRepository, org organizations.OrganizationRepository, planBuilder planbuilder.PlanBuilder, serviceBuilder servicebuilder.ServiceBuilder) ServicePlanHandler

func (ServicePlanHandler) FindServiceAccess

func (actor ServicePlanHandler) FindServiceAccess(serviceName string, orgName string) (ServiceAccess, error)

func (ServicePlanHandler) UpdateAllPlansForService

func (actor ServicePlanHandler) UpdateAllPlansForService(serviceName string, setPlanVisibility bool) error

func (ServicePlanHandler) UpdateOrgForService

func (actor ServicePlanHandler) UpdateOrgForService(serviceName string, orgName string, setPlanVisibility bool) error

func (ServicePlanHandler) UpdatePlanAndOrgForService

func (actor ServicePlanHandler) UpdatePlanAndOrgForService(serviceName, planName, orgName string, setPlanVisibility bool) error

func (ServicePlanHandler) UpdateSinglePlanForService

func (actor ServicePlanHandler) UpdateSinglePlanForService(serviceName string, planName string, setPlanVisibility bool) error