Versions in this module Expand all Collapse all v1 v1.1.0 Aug 14, 2015 Changes in this version + const MAX_INT64 + var BufferTime time.Duration = 5 * time.Second + type AppSummaryRepository interface + GetSummariesInCurrentSpace func() (apps []models.Application, apiErr error) + GetSummary func(appGuid string) (summary models.Application, apiErr error) + type ApplicationFromSummary struct + Buildpack string + Diego bool + DiskQuota int64 + EnvironmentVars map[string]interface{} + Guid string + HealthCheckTimeout int + Instances int + Memory int64 + Name string + PackageUpdatedAt *time.Time + Routes []RouteSummary + RunningInstances int + Services []ServicePlanSummary + SpaceGuid string + State string + Urls []string + func (resource ApplicationFromSummary) ToFields() (app models.ApplicationFields) + func (resource ApplicationFromSummary) ToModel() (app models.Application) + type ApplicationSummaries struct + Apps []ApplicationFromSummary + func (resource ApplicationSummaries) ToModels() (apps []models.ApplicationFields) + type BuildpackBitsRepository interface + UploadBuildpack func(buildpack models.Buildpack, dir string) (apiErr error) + type BuildpackRepository interface + Create func(name string, position *int, enabled *bool, locked *bool) (createdBuildpack models.Buildpack, apiErr error) + Delete func(buildpackGuid string) (apiErr error) + FindByName func(name string) (buildpack models.Buildpack, apiErr error) + ListBuildpacks func(func(models.Buildpack) bool) error + Update func(buildpack models.Buildpack) (updatedBuildpack models.Buildpack, apiErr error) + type CCUserProvidedServiceInstanceRepository struct + func NewCCUserProvidedServiceInstanceRepository(config core_config.Reader, gateway net.Gateway) (repo CCUserProvidedServiceInstanceRepository) + func (repo CCUserProvidedServiceInstanceRepository) Create(name, drainUrl string, params map[string]interface{}) (apiErr error) + func (repo CCUserProvidedServiceInstanceRepository) GetSummaries() (models.UserProvidedServiceSummary, error) + func (repo CCUserProvidedServiceInstanceRepository) Update(serviceInstanceFields models.ServiceInstanceFields) (apiErr error) + type CloudControllerAppSummaryRepository struct + func NewCloudControllerAppSummaryRepository(config core_config.Reader, gateway net.Gateway) (repo CloudControllerAppSummaryRepository) + func (repo CloudControllerAppSummaryRepository) GetSummariesInCurrentSpace() (apps []models.Application, apiErr error) + func (repo CloudControllerAppSummaryRepository) GetSummary(appGuid string) (summary models.Application, apiErr error) + type CloudControllerBuildpackBitsRepository struct + TrustedCerts []tls.Certificate + func NewCloudControllerBuildpackBitsRepository(config core_config.Reader, gateway net.Gateway, zipper app_files.Zipper) (repo CloudControllerBuildpackBitsRepository) + func (repo CloudControllerBuildpackBitsRepository) UploadBuildpack(buildpack models.Buildpack, buildpackLocation string) (apiErr error) + type CloudControllerBuildpackRepository struct + func NewCloudControllerBuildpackRepository(config core_config.Reader, gateway net.Gateway) (repo CloudControllerBuildpackRepository) + func (repo CloudControllerBuildpackRepository) Create(name string, position *int, enabled *bool, locked *bool) (createdBuildpack models.Buildpack, apiErr error) + func (repo CloudControllerBuildpackRepository) Delete(buildpackGuid string) (apiErr error) + func (repo CloudControllerBuildpackRepository) FindByName(name string) (buildpack models.Buildpack, apiErr error) + func (repo CloudControllerBuildpackRepository) ListBuildpacks(cb func(models.Buildpack) bool) error + func (repo CloudControllerBuildpackRepository) Update(buildpack models.Buildpack) (updatedBuildpack models.Buildpack, apiErr error) + type CloudControllerCurlRepository struct + func NewCloudControllerCurlRepository(config core_config.Reader, gateway net.Gateway) (repo CloudControllerCurlRepository) + func (repo CloudControllerCurlRepository) Request(method, path, headerString, body string) (resHeaders, resBody string, err error) + type CloudControllerDomainRepository struct + func NewCloudControllerDomainRepository(config core_config.Reader, gateway net.Gateway, ...) CloudControllerDomainRepository + func (repo CloudControllerDomainRepository) Create(domainName string, owningOrgGuid string) (createdDomain models.DomainFields, err error) + func (repo CloudControllerDomainRepository) CreateSharedDomain(domainName string) (apiErr error) + func (repo CloudControllerDomainRepository) Delete(domainGuid string) error + func (repo CloudControllerDomainRepository) DeleteSharedDomain(domainGuid string) error + func (repo CloudControllerDomainRepository) FindByNameInOrg(name string, orgGuid string) (domain models.DomainFields, apiErr error) + func (repo CloudControllerDomainRepository) FindPrivateByName(name string) (domain models.DomainFields, apiErr error) + func (repo CloudControllerDomainRepository) FindSharedByName(name string) (domain models.DomainFields, apiErr error) + func (repo CloudControllerDomainRepository) FirstOrDefault(orgGuid string, name *string) (domain models.DomainFields, error error) + func (repo CloudControllerDomainRepository) ListDomainsForOrg(orgGuid string, cb func(models.DomainFields) bool) error + type CloudControllerRouteRepository struct + func NewCloudControllerRouteRepository(config core_config.Reader, gateway net.Gateway) (repo CloudControllerRouteRepository) + func (repo CloudControllerRouteRepository) Bind(routeGuid, appGuid string) (apiErr error) + func (repo CloudControllerRouteRepository) CheckIfExists(host string, domain models.DomainFields) (found bool, apiErr error) + func (repo CloudControllerRouteRepository) Create(host string, domain models.DomainFields) (createdRoute models.Route, apiErr error) + func (repo CloudControllerRouteRepository) CreateInSpace(host, domainGuid, spaceGuid string) (createdRoute models.Route, apiErr error) + func (repo CloudControllerRouteRepository) Delete(routeGuid string) (apiErr error) + func (repo CloudControllerRouteRepository) FindByHostAndDomain(host string, domain models.DomainFields) (route models.Route, apiErr error) + func (repo CloudControllerRouteRepository) ListAllRoutes(cb func(models.Route) bool) (apiErr error) + func (repo CloudControllerRouteRepository) ListRoutes(cb func(models.Route) bool) (apiErr error) + func (repo CloudControllerRouteRepository) Unbind(routeGuid, appGuid string) (apiErr error) + type CloudControllerServiceAuthTokenRepository struct + func NewCloudControllerServiceAuthTokenRepository(config core_config.Reader, gateway net.Gateway) (repo CloudControllerServiceAuthTokenRepository) + func (repo CloudControllerServiceAuthTokenRepository) Create(authToken models.ServiceAuthTokenFields) (apiErr error) + func (repo CloudControllerServiceAuthTokenRepository) Delete(authToken models.ServiceAuthTokenFields) (apiErr error) + func (repo CloudControllerServiceAuthTokenRepository) FindAll() (authTokens []models.ServiceAuthTokenFields, apiErr error) + func (repo CloudControllerServiceAuthTokenRepository) FindByLabelAndProvider(label, provider string) (authToken models.ServiceAuthTokenFields, apiErr error) + func (repo CloudControllerServiceAuthTokenRepository) Update(authToken models.ServiceAuthTokenFields) (apiErr error) + type CloudControllerServiceBindingRepository struct + func NewCloudControllerServiceBindingRepository(config core_config.Reader, gateway net.Gateway) (repo CloudControllerServiceBindingRepository) + func (repo CloudControllerServiceBindingRepository) Create(instanceGuid, appGuid string, paramsMap map[string]interface{}) (apiErr error) + func (repo CloudControllerServiceBindingRepository) Delete(instance models.ServiceInstance, appGuid string) (found bool, apiErr error) + type CloudControllerServiceBrokerRepository struct + func NewCloudControllerServiceBrokerRepository(config core_config.Reader, gateway net.Gateway) (repo CloudControllerServiceBrokerRepository) + func (repo CloudControllerServiceBrokerRepository) Create(name, url, username, password string) (apiErr error) + func (repo CloudControllerServiceBrokerRepository) Delete(guid string) (apiErr error) + func (repo CloudControllerServiceBrokerRepository) FindByGuid(guid string) (serviceBroker models.ServiceBroker, apiErr error) + func (repo CloudControllerServiceBrokerRepository) FindByName(name string) (serviceBroker models.ServiceBroker, apiErr error) + func (repo CloudControllerServiceBrokerRepository) ListServiceBrokers(callback func(models.ServiceBroker) bool) error + func (repo CloudControllerServiceBrokerRepository) Rename(guid, name string) (apiErr error) + func (repo CloudControllerServiceBrokerRepository) Update(serviceBroker models.ServiceBroker) (apiErr error) + type CloudControllerServiceKeyRepository struct + func NewCloudControllerServiceKeyRepository(config core_config.Reader, gateway net.Gateway) (repo CloudControllerServiceKeyRepository) + func (c CloudControllerServiceKeyRepository) CreateServiceKey(instanceGuid string, keyName string, params map[string]interface{}) error + func (c CloudControllerServiceKeyRepository) DeleteServiceKey(serviceKeyGuid string) error + func (c CloudControllerServiceKeyRepository) GetServiceKey(instanceGuid string, keyName string) (models.ServiceKey, error) + func (c CloudControllerServiceKeyRepository) ListServiceKeys(instanceGuid string) ([]models.ServiceKey, error) + type CloudControllerServicePlanRepository struct + func NewCloudControllerServicePlanRepository(config core_config.Reader, gateway net.Gateway) CloudControllerServicePlanRepository + func (repo CloudControllerServicePlanRepository) ListPlansFromManyServices(serviceGuids []string) ([]models.ServicePlanFields, error) + func (repo CloudControllerServicePlanRepository) Search(queryParams map[string]string) (plans []models.ServicePlanFields, err error) + func (repo CloudControllerServicePlanRepository) Update(servicePlan models.ServicePlanFields, serviceGuid string, public bool) error + type CloudControllerServicePlanVisibilityRepository struct + func NewCloudControllerServicePlanVisibilityRepository(config core_config.Reader, gateway net.Gateway) CloudControllerServicePlanVisibilityRepository + func (repo CloudControllerServicePlanVisibilityRepository) Create(serviceGuid, orgGuid string) error + func (repo CloudControllerServicePlanVisibilityRepository) Delete(servicePlanGuid string) error + func (repo CloudControllerServicePlanVisibilityRepository) List() (visibilities []models.ServicePlanVisibilityFields, err error) + func (repo CloudControllerServicePlanVisibilityRepository) Search(queryParams map[string]string) ([]models.ServicePlanVisibilityFields, error) + type CloudControllerServiceRepository struct + func NewCloudControllerServiceRepository(config core_config.Reader, gateway net.Gateway) (repo CloudControllerServiceRepository) + func (repo CloudControllerServiceRepository) CreateServiceInstance(name, planGuid string, params map[string]interface{}, tags []string) (err error) + func (repo CloudControllerServiceRepository) DeleteService(instance models.ServiceInstance) (apiErr error) + func (repo CloudControllerServiceRepository) FindInstanceByName(name string) (instance models.ServiceInstance, apiErr error) + func (repo CloudControllerServiceRepository) FindServiceOfferingByLabelAndProvider(label, provider string) (models.ServiceOffering, error) + func (repo CloudControllerServiceRepository) FindServiceOfferingsByLabel(label string) (models.ServiceOfferings, error) + func (repo CloudControllerServiceRepository) FindServiceOfferingsForSpaceByLabel(spaceGuid, name string) (offerings models.ServiceOfferings, err error) + func (repo CloudControllerServiceRepository) FindServicePlanByDescription(planDescription resources.ServicePlanDescription) (string, error) + func (repo CloudControllerServiceRepository) GetAllServiceOfferings() (models.ServiceOfferings, error) + func (repo CloudControllerServiceRepository) GetServiceInstanceCountForServicePlan(v1PlanGuid string) (count int, apiErr error) + func (repo CloudControllerServiceRepository) GetServiceOfferingByGuid(serviceGuid string) (models.ServiceOffering, error) + func (repo CloudControllerServiceRepository) GetServiceOfferingsForSpace(spaceGuid string) (models.ServiceOfferings, error) + func (repo CloudControllerServiceRepository) ListServicesFromBroker(brokerGuid string) (offerings []models.ServiceOffering, err error) + func (repo CloudControllerServiceRepository) ListServicesFromManyBrokers(brokerGuids []string) ([]models.ServiceOffering, error) + func (repo CloudControllerServiceRepository) MigrateServicePlanFromV1ToV2(v1PlanGuid, v2PlanGuid string) (changedCount int, apiErr error) + func (repo CloudControllerServiceRepository) PurgeServiceOffering(offering models.ServiceOffering) error + func (repo CloudControllerServiceRepository) RenameService(instance models.ServiceInstance, newName string) (apiErr error) + func (repo CloudControllerServiceRepository) UpdateServiceInstance(instanceGuid, planGuid string, params map[string]interface{}, tags []string) (err error) + type CloudControllerServiceSummaryRepository struct + func NewCloudControllerServiceSummaryRepository(config core_config.Reader, gateway net.Gateway) (repo CloudControllerServiceSummaryRepository) + func (repo CloudControllerServiceSummaryRepository) GetSummariesInCurrentSpace() (instances []models.ServiceInstance, apiErr error) + type CloudControllerUserRepository struct + func NewCloudControllerUserRepository(config core_config.Reader, uaaGateway net.Gateway, ccGateway net.Gateway) (repo CloudControllerUserRepository) + func (repo CloudControllerUserRepository) Create(username, password string) (err error) + func (repo CloudControllerUserRepository) Delete(userGuid string) (apiErr error) + func (repo CloudControllerUserRepository) FindByUsername(username string) (models.UserFields, error) + func (repo CloudControllerUserRepository) ListUsersInOrgForRole(orgGuid string, roleName string) (users []models.UserFields, apiErr error) + func (repo CloudControllerUserRepository) ListUsersInOrgForRoleWithNoUAA(orgGuid string, roleName string) (users []models.UserFields, apiErr error) + func (repo CloudControllerUserRepository) ListUsersInSpaceForRole(spaceGuid string, roleName string) (users []models.UserFields, apiErr error) + func (repo CloudControllerUserRepository) ListUsersInSpaceForRoleWithNoUAA(spaceGuid string, roleName string) (users []models.UserFields, apiErr error) + func (repo CloudControllerUserRepository) SetOrgRole(userGuid string, orgGuid string, role string) (apiErr error) + func (repo CloudControllerUserRepository) SetSpaceRole(userGuid, spaceGuid, orgGuid, role string) (apiErr error) + func (repo CloudControllerUserRepository) UnsetOrgRole(userGuid, orgGuid, role string) (apiErr error) + func (repo CloudControllerUserRepository) UnsetSpaceRole(userGuid, spaceGuid, role string) (apiErr error) + type CurlRepository interface + Request func(method, path, header, body string) (resHeaders, resBody string, apiErr error) + type DomainRepository interface + Create func(domainName string, owningOrgGuid string) (createdDomain models.DomainFields, apiErr error) + CreateSharedDomain func(domainName string) (apiErr error) + Delete func(domainGuid string) (apiErr error) + DeleteSharedDomain func(domainGuid string) (apiErr error) + FindByNameInOrg func(name string, owningOrgGuid string) (domain models.DomainFields, apiErr error) + FindPrivateByName func(name string) (domain models.DomainFields, apiErr error) + FindSharedByName func(name string) (domain models.DomainFields, apiErr error) + FirstOrDefault func(orgGuid string, name *string) (domain models.DomainFields, error error) + ListDomainsForOrg func(orgGuid string, cb func(models.DomainFields) bool) error + type DomainSummary struct + Guid string + Name string + OwningOrganizationGuid string + type EndpointRepository interface + UpdateEndpoint func(endpoint string) (finalEndpoint string, apiErr error) + func NewEndpointRepository(config core_config.ReadWriter, gateway net.Gateway) EndpointRepository + type LastOperationSummary struct + Description string + State string + Type string + type LoggregatorLogsRepository struct + func (repo *LoggregatorLogsRepository) Close() + func (repo *LoggregatorLogsRepository) RecentLogsFor(appGuid string) ([]*logmessage.LogMessage, error) + func (repo *LoggregatorLogsRepository) TailLogsFor(appGuid string, onConnect func(), onMessage func(*logmessage.LogMessage)) error + type Loggregator_SortedMessageQueue struct + func NewLoggregator_SortedMessageQueue(printTimeBuffer time.Duration, clock func() time.Time) *Loggregator_SortedMessageQueue + func (pq *Loggregator_SortedMessageQueue) Len() int + func (pq *Loggregator_SortedMessageQueue) Less(i, j int) bool + func (pq *Loggregator_SortedMessageQueue) NextTimestamp() int64 + func (pq *Loggregator_SortedMessageQueue) PopMessage() *logmessage.LogMessage + func (pq *Loggregator_SortedMessageQueue) PushMessage(message *logmessage.LogMessage) + func (pq *Loggregator_SortedMessageQueue) Swap(i, j int) + type LogsNoaaRepository interface + Close func() + GetContainerMetrics func(string, []models.AppInstanceFields) ([]models.AppInstanceFields, error) + RecentLogsFor func(appGuid string) ([]*events.LogMessage, error) + TailNoaaLogsFor func(appGuid string, onConnect func(), onMessage func(*events.LogMessage)) error + func NewLogsNoaaRepository(config core_config.Reader, consumer NoaaConsumer, ...) LogsNoaaRepository + type NoaaConsumer interface + Close func() error + GetContainerMetrics func(string, string) ([]*events.ContainerMetric, error) + RecentLogs func(string, string) ([]*events.LogMessage, error) + SetOnConnectCallback func(func()) + TailingLogs func(string, string, chan<- *events.LogMessage, chan<- error) + func NewNoaaConsumer(consumer *noaa.Consumer) NoaaConsumer + type OldLogsRepository interface + Close func() + RecentLogsFor func(appGuid string) ([]*logmessage.LogMessage, error) + TailLogsFor func(appGuid string, onConnect func(), onMessage func(*logmessage.LogMessage)) error + func NewLoggregatorLogsRepository(config core_config.Reader, consumer consumer.LoggregatorConsumer, ...) OldLogsRepository + type RemoteEndpointRepository struct + func (repo RemoteEndpointRepository) UpdateEndpoint(endpoint string) (finalEndpoint string, apiErr error) + type RepositoryLocator struct + func NewRepositoryLocator(config core_config.ReadWriter, gatewaysByName map[string]net.Gateway) (loc RepositoryLocator) + func (locator RepositoryLocator) GetAppEventsRepository() app_events.AppEventsRepository + func (locator RepositoryLocator) GetAppFilesRepository() api_app_files.AppFilesRepository + func (locator RepositoryLocator) GetAppInstancesRepository() app_instances.AppInstancesRepository + func (locator RepositoryLocator) GetAppSummaryRepository() AppSummaryRepository + func (locator RepositoryLocator) GetApplicationBitsRepository() application_bits.ApplicationBitsRepository + func (locator RepositoryLocator) GetApplicationRepository() applications.ApplicationRepository + func (locator RepositoryLocator) GetAuthenticationRepository() authentication.AuthenticationRepository + func (locator RepositoryLocator) GetBuildpackBitsRepository() BuildpackBitsRepository + func (locator RepositoryLocator) GetBuildpackRepository() BuildpackRepository + func (locator RepositoryLocator) GetCopyApplicationSourceRepository() copy_application_source.CopyApplicationSourceRepository + func (locator RepositoryLocator) GetCurlRepository() CurlRepository + func (locator RepositoryLocator) GetDomainRepository() DomainRepository + func (locator RepositoryLocator) GetEndpointRepository() EndpointRepository + func (locator RepositoryLocator) GetEnvironmentVariableGroupsRepository() environment_variable_groups.EnvironmentVariableGroupsRepository + func (locator RepositoryLocator) GetFeatureFlagRepository() feature_flags.FeatureFlagRepository + func (locator RepositoryLocator) GetLogsNoaaRepository() LogsNoaaRepository + func (locator RepositoryLocator) GetOldLogsRepository() OldLogsRepository + func (locator RepositoryLocator) GetOrganizationRepository() organizations.OrganizationRepository + func (locator RepositoryLocator) GetPasswordRepository() password.PasswordRepository + func (locator RepositoryLocator) GetQuotaRepository() quotas.QuotaRepository + func (locator RepositoryLocator) GetRouteRepository() RouteRepository + func (locator RepositoryLocator) GetRunningSecurityGroupsRepository() running.RunningSecurityGroupsRepo + func (locator RepositoryLocator) GetSecurityGroupRepository() security_groups.SecurityGroupRepo + func (locator RepositoryLocator) GetSecurityGroupSpaceBinder() securitygroupspaces.SecurityGroupSpaceBinder + func (locator RepositoryLocator) GetServiceAuthTokenRepository() ServiceAuthTokenRepository + func (locator RepositoryLocator) GetServiceBindingRepository() ServiceBindingRepository + func (locator RepositoryLocator) GetServiceBrokerRepository() ServiceBrokerRepository + func (locator RepositoryLocator) GetServiceKeyRepository() ServiceKeyRepository + func (locator RepositoryLocator) GetServicePlanRepository() ServicePlanRepository + func (locator RepositoryLocator) GetServicePlanVisibilityRepository() ServicePlanVisibilityRepository + func (locator RepositoryLocator) GetServiceRepository() ServiceRepository + func (locator RepositoryLocator) GetServiceSummaryRepository() ServiceSummaryRepository + func (locator RepositoryLocator) GetSpaceQuotaRepository() space_quotas.SpaceQuotaRepository + func (locator RepositoryLocator) GetSpaceRepository() spaces.SpaceRepository + func (locator RepositoryLocator) GetStackRepository() stacks.StackRepository + func (locator RepositoryLocator) GetStagingSecurityGroupsRepository() staging.StagingSecurityGroupsRepo + func (locator RepositoryLocator) GetUserProvidedServiceInstanceRepository() UserProvidedServiceInstanceRepository + func (locator RepositoryLocator) GetUserRepository() UserRepository + func (locator RepositoryLocator) SetAppInstancesRepository(repo app_instances.AppInstancesRepository) RepositoryLocator + func (locator RepositoryLocator) SetAppSummaryRepository(repo AppSummaryRepository) RepositoryLocator + func (locator RepositoryLocator) SetEndpointRepository(e EndpointRepository) RepositoryLocator + func (locator RepositoryLocator) SetLogsNoaaRepository(repo LogsNoaaRepository) RepositoryLocator + func (locator RepositoryLocator) SetOrganizationRepository(repo organizations.OrganizationRepository) RepositoryLocator + func (locator RepositoryLocator) SetServiceSummaryRepository(repo ServiceSummaryRepository) RepositoryLocator + func (locator RepositoryLocator) SetSpaceQuotaRepository(repo space_quotas.SpaceQuotaRepository) RepositoryLocator + func (locator RepositoryLocator) SetSpaceRepository(repo spaces.SpaceRepository) RepositoryLocator + func (locator RepositoryLocator) SetUserRepository(repo UserRepository) RepositoryLocator + type RouteRepository interface + Bind func(routeGuid, appGuid string) (apiErr error) + CheckIfExists func(host string, domain models.DomainFields) (found bool, apiErr error) + Create func(host string, domain models.DomainFields) (createdRoute models.Route, apiErr error) + CreateInSpace func(host, domainGuid, spaceGuid string) (createdRoute models.Route, apiErr error) + Delete func(routeGuid string) (apiErr error) + FindByHostAndDomain func(host string, domain models.DomainFields) (route models.Route, apiErr error) + ListAllRoutes func(cb func(models.Route) bool) (apiErr error) + ListRoutes func(cb func(models.Route) bool) (apiErr error) + Unbind func(routeGuid, appGuid string) (apiErr error) + type RouteSummary struct + Domain DomainSummary + Guid string + Host string + func (resource RouteSummary) ToModel() (route models.RouteSummary) + type ServiceAuthTokenRepository interface + Create func(authToken models.ServiceAuthTokenFields) (apiErr error) + Delete func(authToken models.ServiceAuthTokenFields) (apiErr error) + FindAll func() (authTokens []models.ServiceAuthTokenFields, apiErr error) + FindByLabelAndProvider func(label, provider string) (authToken models.ServiceAuthTokenFields, apiErr error) + Update func(authToken models.ServiceAuthTokenFields) (apiErr error) + type ServiceBindingRepository interface + Create func(instanceGuid, appGuid string, paramsMap map[string]interface{}) (apiErr error) + Delete func(instance models.ServiceInstance, appGuid string) (found bool, apiErr error) + type ServiceBrokerRepository interface + Create func(name, url, username, password string) (apiErr error) + Delete func(guid string) (apiErr error) + FindByGuid func(guid string) (serviceBroker models.ServiceBroker, apiErr error) + FindByName func(name string) (serviceBroker models.ServiceBroker, apiErr error) + ListServiceBrokers func(callback func(models.ServiceBroker) bool) error + Rename func(guid, name string) (apiErr error) + Update func(serviceBroker models.ServiceBroker) (apiErr error) + type ServiceInstanceSummary struct + LastOperation LastOperationSummary + Name string + ServicePlan ServicePlanSummary + type ServiceInstanceSummaryApp struct + Name string + ServiceNames []string + type ServiceInstancesSummaries struct + Apps []ServiceInstanceSummaryApp + ServiceInstances []ServiceInstanceSummary + func (resource ServiceInstancesSummaries) ToModels() (instances []models.ServiceInstance) + type ServiceKeyRepository interface + CreateServiceKey func(serviceKeyGuid string, keyName string, params map[string]interface{}) error + DeleteServiceKey func(serviceKeyGuid string) error + GetServiceKey func(serviceKeyGuid string, keyName string) (models.ServiceKey, error) + ListServiceKeys func(serviceKeyGuid string) ([]models.ServiceKey, error) + type ServiceOfferingSummary struct + Label string + Provider string + Version string + type ServicePlanRepository interface + ListPlansFromManyServices func(serviceGuids []string) ([]models.ServicePlanFields, error) + Search func(searchParameters map[string]string) ([]models.ServicePlanFields, error) + Update func(models.ServicePlanFields, string, bool) error + type ServicePlanSummary struct + Guid string + Name string + ServiceOffering ServiceOfferingSummary + func (resource ServicePlanSummary) ToModel() (route models.ServicePlanSummary) + type ServicePlanVisibilityRepository interface + Create func(string, string) error + Delete func(string) error + List func() ([]models.ServicePlanVisibilityFields, error) + Search func(map[string]string) ([]models.ServicePlanVisibilityFields, error) + type ServiceRepository interface + CreateServiceInstance func(name, planGuid string, params map[string]interface{}, tags []string) (apiErr error) + DeleteService func(instance models.ServiceInstance) (apiErr error) + FindInstanceByName func(name string) (instance models.ServiceInstance, apiErr error) + FindServiceOfferingByLabelAndProvider func(name, provider string) (offering models.ServiceOffering, apiErr error) + FindServiceOfferingsByLabel func(name string) (offering models.ServiceOfferings, apiErr error) + FindServiceOfferingsForSpaceByLabel func(spaceGuid, name string) (offering models.ServiceOfferings, apiErr error) + FindServicePlanByDescription func(planDescription resources.ServicePlanDescription) (planGuid string, apiErr error) + GetAllServiceOfferings func() (offerings models.ServiceOfferings, apiErr error) + GetServiceInstanceCountForServicePlan func(v1PlanGuid string) (count int, apiErr error) + GetServiceOfferingByGuid func(serviceGuid string) (offering models.ServiceOffering, apiErr error) + GetServiceOfferingsForSpace func(spaceGuid string) (offerings models.ServiceOfferings, apiErr error) + ListServicesFromBroker func(brokerGuid string) (services []models.ServiceOffering, err error) + ListServicesFromManyBrokers func(brokerGuids []string) (services []models.ServiceOffering, err error) + MigrateServicePlanFromV1ToV2 func(v1PlanGuid, v2PlanGuid string) (changedCount int, apiErr error) + PurgeServiceOffering func(offering models.ServiceOffering) error + RenameService func(instance models.ServiceInstance, newName string) (apiErr error) + UpdateServiceInstance func(instanceGuid, planGuid string, params map[string]interface{}, tags []string) (apiErr error) + type ServiceSummaryRepository interface + GetSummariesInCurrentSpace func() (instances []models.ServiceInstance, apiErr error) + type SortedMessageQueue struct + func NewSortedMessageQueue(printTimeBuffer time.Duration, clock func() time.Time) *SortedMessageQueue + func (pq *SortedMessageQueue) Len() int + func (pq *SortedMessageQueue) Less(i, j int) bool + func (pq *SortedMessageQueue) NextTimestamp() int64 + func (pq *SortedMessageQueue) PopMessage() *events.LogMessage + func (pq *SortedMessageQueue) PushMessage(message *events.LogMessage) + func (pq *SortedMessageQueue) Swap(i, j int) + type UserProvidedServiceInstanceRepository interface + Create func(name, drainUrl string, params map[string]interface{}) (apiErr error) + GetSummaries func() (models.UserProvidedServiceSummary, error) + Update func(serviceInstanceFields models.ServiceInstanceFields) (apiErr error) + type UserRepository interface + Create func(username, password string) (apiErr error) + Delete func(userGuid string) (apiErr error) + FindByUsername func(username string) (user models.UserFields, apiErr error) + ListUsersInOrgForRole func(orgGuid string, role string) ([]models.UserFields, error) + ListUsersInOrgForRoleWithNoUAA func(orgGuid string, role string) ([]models.UserFields, error) + ListUsersInSpaceForRole func(spaceGuid string, role string) ([]models.UserFields, error) + ListUsersInSpaceForRoleWithNoUAA func(spaceGuid string, role string) ([]models.UserFields, error) + SetOrgRole func(userGuid, orgGuid, role string) (apiErr error) + SetSpaceRole func(userGuid, spaceGuid, orgGuid, role string) (apiErr error) + UnsetOrgRole func(userGuid, orgGuid, role string) (apiErr error) + UnsetSpaceRole func(userGuid, spaceGuid, role string) (apiErr error)