Documentation ¶
Index ¶
- Constants
- Variables
- type AppSummaryRepository
- type ApplicationFromSummary
- type ApplicationSummaries
- type BuildpackBitsRepository
- type BuildpackRepository
- type 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
- type CloudControllerBuildpackBitsRepository
- type 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
- type 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
- 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
- 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
- type 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
- 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
- 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
- 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
- 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
- type 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
- type DomainRepository
- type DomainSummary
- type EndpointRepository
- type LastOperationSummary
- type LoggregatorLogsRepository
- type 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
- type NoaaConsumer
- type OldLogsRepository
- type RemoteEndpointRepository
- type 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) SetAppEventsRepository(repo app_events.AppEventsRepository) RepositoryLocator
- func (locator RepositoryLocator) SetAppFileRepository(repo api_app_files.AppFilesRepository) RepositoryLocator
- func (locator RepositoryLocator) SetAppInstancesRepository(repo app_instances.AppInstancesRepository) RepositoryLocator
- func (locator RepositoryLocator) SetAppSummaryRepository(repo AppSummaryRepository) RepositoryLocator
- func (locator RepositoryLocator) SetApplicationRepository(repo applications.ApplicationRepository) RepositoryLocator
- func (locator RepositoryLocator) SetAuthenticationRepository(repo authentication.AuthenticationRepository) RepositoryLocator
- func (locator RepositoryLocator) SetBuildpackBitsRepository(repo BuildpackBitsRepository) RepositoryLocator
- func (locator RepositoryLocator) SetBuildpackRepository(repo BuildpackRepository) RepositoryLocator
- func (locator RepositoryLocator) SetCopyApplicationSourceRepository(repo copy_application_source.CopyApplicationSourceRepository) RepositoryLocator
- func (locator RepositoryLocator) SetCurlRepository(repo CurlRepository) RepositoryLocator
- func (locator RepositoryLocator) SetDomainRepository(repo DomainRepository) RepositoryLocator
- func (locator RepositoryLocator) SetEndpointRepository(e EndpointRepository) RepositoryLocator
- func (locator RepositoryLocator) SetEnvironmentVariableGroupsRepository(repo environment_variable_groups.EnvironmentVariableGroupsRepository) RepositoryLocator
- func (locator RepositoryLocator) SetFeatureFlagRepository(repo feature_flags.FeatureFlagRepository) RepositoryLocator
- func (locator RepositoryLocator) SetLogsNoaaRepository(repo LogsNoaaRepository) RepositoryLocator
- func (locator RepositoryLocator) SetOldLogsRepository(repo OldLogsRepository) RepositoryLocator
- func (locator RepositoryLocator) SetOrganizationRepository(repo organizations.OrganizationRepository) RepositoryLocator
- func (locator RepositoryLocator) SetPasswordRepository(repo password.PasswordRepository) RepositoryLocator
- func (locator RepositoryLocator) SetQuotaRepository(repo quotas.QuotaRepository) RepositoryLocator
- func (locator RepositoryLocator) SetRouteRepository(repo RouteRepository) RepositoryLocator
- func (locator RepositoryLocator) SetRunningSecurityGroupRepository(repo running.RunningSecurityGroupsRepo) RepositoryLocator
- func (locator RepositoryLocator) SetSecurityGroupRepository(repo security_groups.SecurityGroupRepo) RepositoryLocator
- func (locator RepositoryLocator) SetSecurityGroupSpaceBinder(repo securitygroupspaces.SecurityGroupSpaceBinder) RepositoryLocator
- func (locator RepositoryLocator) SetServiceAuthTokenRepository(repo ServiceAuthTokenRepository) RepositoryLocator
- func (locator RepositoryLocator) SetServiceBindingRepository(repo ServiceBindingRepository) RepositoryLocator
- func (locator RepositoryLocator) SetServiceBrokerRepository(repo ServiceBrokerRepository) RepositoryLocator
- func (locator RepositoryLocator) SetServiceKeyRepository(repo ServiceKeyRepository) RepositoryLocator
- func (locator RepositoryLocator) SetServiceRepository(repo ServiceRepository) 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) SetStackRepository(repo stacks.StackRepository) RepositoryLocator
- func (locator RepositoryLocator) SetStagingSecurityGroupRepository(repo staging.StagingSecurityGroupsRepo) RepositoryLocator
- func (locator RepositoryLocator) SetUserProvidedServiceInstanceRepository(repo UserProvidedServiceInstanceRepository) RepositoryLocator
- func (locator RepositoryLocator) SetUserRepository(repo UserRepository) RepositoryLocator
- type RouteRepository
- type RouteSummary
- type ServiceAuthTokenRepository
- type ServiceBindingRepository
- type ServiceBrokerRepository
- type ServiceInstanceSummary
- type ServiceInstanceSummaryApp
- type ServiceInstancesSummaries
- type ServiceKeyRepository
- type ServiceOfferingSummary
- type ServicePlanRepository
- type ServicePlanSummary
- type ServicePlanVisibilityRepository
- type ServiceRepository
- type ServiceSummaryRepository
- type 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
- type UserRepository
Constants ¶
View Source
const MAX_INT64 int64 = 1<<63 - 1
Variables ¶
View Source
var BufferTime time.Duration = 5 * time.Second
Functions ¶
This section is empty.
Types ¶
type AppSummaryRepository ¶
type AppSummaryRepository interface { GetSummariesInCurrentSpace() (apps []models.Application, apiErr error) GetSummary(appGuid string) (summary models.Application, apiErr error) }
type ApplicationFromSummary ¶
type ApplicationFromSummary struct { Guid string Name string Routes []RouteSummary Services []ServicePlanSummary Diego bool `json:"diego,omitempty"` RunningInstances int `json:"running_instances"` Memory int64 Instances int DiskQuota int64 `json:"disk_quota"` Urls []string EnvironmentVars map[string]interface{} `json:"environment_json,omitempty"` HealthCheckTimeout int `json:"health_check_timeout"` State string SpaceGuid string `json:"space_guid"` Command string `json:"command"` PackageUpdatedAt *time.Time `json:"package_updated_at"` Buildpack string }
func (ApplicationFromSummary) ToFields ¶
func (resource ApplicationFromSummary) ToFields() (app models.ApplicationFields)
func (ApplicationFromSummary) ToModel ¶
func (resource ApplicationFromSummary) ToModel() (app models.Application)
type ApplicationSummaries ¶
type ApplicationSummaries struct {
Apps []ApplicationFromSummary
}
func (ApplicationSummaries) ToModels ¶
func (resource ApplicationSummaries) ToModels() (apps []models.ApplicationFields)
type BuildpackBitsRepository ¶
type BuildpackRepository ¶
type BuildpackRepository interface { FindByName(name string) (buildpack models.Buildpack, apiErr error) ListBuildpacks(func(models.Buildpack) bool) error Create(name string, position *int, enabled *bool, locked *bool) (createdBuildpack models.Buildpack, apiErr error) Delete(buildpackGuid string) (apiErr error) Update(buildpack models.Buildpack) (updatedBuildpack models.Buildpack, apiErr error) }
type CCUserProvidedServiceInstanceRepository ¶
type CCUserProvidedServiceInstanceRepository struct {
// contains filtered or unexported fields
}
func NewCCUserProvidedServiceInstanceRepository ¶
func NewCCUserProvidedServiceInstanceRepository(config core_config.Reader, gateway net.Gateway) (repo CCUserProvidedServiceInstanceRepository)
func (CCUserProvidedServiceInstanceRepository) Create ¶
func (repo CCUserProvidedServiceInstanceRepository) Create(name, drainUrl string, params map[string]interface{}) (apiErr error)
func (CCUserProvidedServiceInstanceRepository) GetSummaries ¶
func (repo CCUserProvidedServiceInstanceRepository) GetSummaries() (models.UserProvidedServiceSummary, error)
func (CCUserProvidedServiceInstanceRepository) Update ¶
func (repo CCUserProvidedServiceInstanceRepository) Update(serviceInstanceFields models.ServiceInstanceFields) (apiErr error)
type CloudControllerAppSummaryRepository ¶
type CloudControllerAppSummaryRepository struct {
// contains filtered or unexported fields
}
func NewCloudControllerAppSummaryRepository ¶
func NewCloudControllerAppSummaryRepository(config core_config.Reader, gateway net.Gateway) (repo CloudControllerAppSummaryRepository)
func (CloudControllerAppSummaryRepository) GetSummariesInCurrentSpace ¶
func (repo CloudControllerAppSummaryRepository) GetSummariesInCurrentSpace() (apps []models.Application, apiErr error)
func (CloudControllerAppSummaryRepository) GetSummary ¶
func (repo CloudControllerAppSummaryRepository) GetSummary(appGuid string) (summary models.Application, apiErr error)
type CloudControllerBuildpackBitsRepository ¶
type CloudControllerBuildpackBitsRepository struct { TrustedCerts []tls.Certificate // contains filtered or unexported fields }
func NewCloudControllerBuildpackBitsRepository ¶
func NewCloudControllerBuildpackBitsRepository(config core_config.Reader, gateway net.Gateway, zipper app_files.Zipper) (repo CloudControllerBuildpackBitsRepository)
func (CloudControllerBuildpackBitsRepository) UploadBuildpack ¶
func (repo CloudControllerBuildpackBitsRepository) UploadBuildpack(buildpack models.Buildpack, buildpackLocation string) (apiErr error)
type CloudControllerBuildpackRepository ¶
type CloudControllerBuildpackRepository struct {
// contains filtered or unexported fields
}
func NewCloudControllerBuildpackRepository ¶
func NewCloudControllerBuildpackRepository(config core_config.Reader, gateway net.Gateway) (repo CloudControllerBuildpackRepository)
func (CloudControllerBuildpackRepository) Delete ¶
func (repo CloudControllerBuildpackRepository) Delete(buildpackGuid string) (apiErr error)
func (CloudControllerBuildpackRepository) FindByName ¶
func (repo CloudControllerBuildpackRepository) FindByName(name string) (buildpack models.Buildpack, apiErr error)
func (CloudControllerBuildpackRepository) ListBuildpacks ¶
func (repo CloudControllerBuildpackRepository) ListBuildpacks(cb func(models.Buildpack) bool) error
type CloudControllerCurlRepository ¶
type CloudControllerCurlRepository struct {
// contains filtered or unexported fields
}
func NewCloudControllerCurlRepository ¶
func NewCloudControllerCurlRepository(config core_config.Reader, gateway net.Gateway) (repo CloudControllerCurlRepository)
type CloudControllerDomainRepository ¶
type CloudControllerDomainRepository struct {
// contains filtered or unexported fields
}
func NewCloudControllerDomainRepository ¶
func NewCloudControllerDomainRepository(config core_config.Reader, gateway net.Gateway, strategy strategy.EndpointStrategy) CloudControllerDomainRepository
func (CloudControllerDomainRepository) Create ¶
func (repo CloudControllerDomainRepository) Create(domainName string, owningOrgGuid string) (createdDomain models.DomainFields, err error)
func (CloudControllerDomainRepository) CreateSharedDomain ¶
func (repo CloudControllerDomainRepository) CreateSharedDomain(domainName string) (apiErr error)
func (CloudControllerDomainRepository) Delete ¶
func (repo CloudControllerDomainRepository) Delete(domainGuid string) error
func (CloudControllerDomainRepository) DeleteSharedDomain ¶
func (repo CloudControllerDomainRepository) DeleteSharedDomain(domainGuid string) error
func (CloudControllerDomainRepository) FindByNameInOrg ¶
func (repo CloudControllerDomainRepository) FindByNameInOrg(name string, orgGuid string) (domain models.DomainFields, apiErr error)
func (CloudControllerDomainRepository) FindPrivateByName ¶
func (repo CloudControllerDomainRepository) FindPrivateByName(name string) (domain models.DomainFields, apiErr error)
func (CloudControllerDomainRepository) FindSharedByName ¶
func (repo CloudControllerDomainRepository) FindSharedByName(name string) (domain models.DomainFields, apiErr error)
func (CloudControllerDomainRepository) FirstOrDefault ¶
func (repo CloudControllerDomainRepository) FirstOrDefault(orgGuid string, name *string) (domain models.DomainFields, error error)
func (CloudControllerDomainRepository) ListDomainsForOrg ¶
func (repo CloudControllerDomainRepository) ListDomainsForOrg(orgGuid string, cb func(models.DomainFields) bool) error
type CloudControllerRouteRepository ¶
type CloudControllerRouteRepository struct {
// contains filtered or unexported fields
}
func NewCloudControllerRouteRepository ¶
func NewCloudControllerRouteRepository(config core_config.Reader, gateway net.Gateway) (repo CloudControllerRouteRepository)
func (CloudControllerRouteRepository) Bind ¶
func (repo CloudControllerRouteRepository) Bind(routeGuid, appGuid string) (apiErr error)
func (CloudControllerRouteRepository) CheckIfExists ¶
func (repo CloudControllerRouteRepository) CheckIfExists(host string, domain models.DomainFields) (found bool, apiErr error)
func (CloudControllerRouteRepository) Create ¶
func (repo CloudControllerRouteRepository) Create(host string, domain models.DomainFields) (createdRoute models.Route, apiErr error)
func (CloudControllerRouteRepository) CreateInSpace ¶
func (repo CloudControllerRouteRepository) CreateInSpace(host, domainGuid, spaceGuid string) (createdRoute models.Route, apiErr error)
func (CloudControllerRouteRepository) Delete ¶
func (repo CloudControllerRouteRepository) Delete(routeGuid string) (apiErr error)
func (CloudControllerRouteRepository) FindByHostAndDomain ¶
func (repo CloudControllerRouteRepository) FindByHostAndDomain(host string, domain models.DomainFields) (route models.Route, apiErr error)
func (CloudControllerRouteRepository) ListAllRoutes ¶
func (repo CloudControllerRouteRepository) ListAllRoutes(cb func(models.Route) bool) (apiErr error)
func (CloudControllerRouteRepository) ListRoutes ¶
func (repo CloudControllerRouteRepository) ListRoutes(cb func(models.Route) bool) (apiErr error)
func (CloudControllerRouteRepository) Unbind ¶
func (repo CloudControllerRouteRepository) Unbind(routeGuid, appGuid string) (apiErr error)
type CloudControllerServiceAuthTokenRepository ¶
type CloudControllerServiceAuthTokenRepository struct {
// contains filtered or unexported fields
}
func NewCloudControllerServiceAuthTokenRepository ¶
func NewCloudControllerServiceAuthTokenRepository(config core_config.Reader, gateway net.Gateway) (repo CloudControllerServiceAuthTokenRepository)
func (CloudControllerServiceAuthTokenRepository) Create ¶
func (repo CloudControllerServiceAuthTokenRepository) Create(authToken models.ServiceAuthTokenFields) (apiErr error)
func (CloudControllerServiceAuthTokenRepository) Delete ¶
func (repo CloudControllerServiceAuthTokenRepository) Delete(authToken models.ServiceAuthTokenFields) (apiErr error)
func (CloudControllerServiceAuthTokenRepository) FindAll ¶
func (repo CloudControllerServiceAuthTokenRepository) FindAll() (authTokens []models.ServiceAuthTokenFields, apiErr error)
func (CloudControllerServiceAuthTokenRepository) FindByLabelAndProvider ¶
func (repo CloudControllerServiceAuthTokenRepository) FindByLabelAndProvider(label, provider string) (authToken models.ServiceAuthTokenFields, apiErr error)
func (CloudControllerServiceAuthTokenRepository) Update ¶
func (repo CloudControllerServiceAuthTokenRepository) Update(authToken models.ServiceAuthTokenFields) (apiErr error)
type CloudControllerServiceBindingRepository ¶
type CloudControllerServiceBindingRepository struct {
// contains filtered or unexported fields
}
func NewCloudControllerServiceBindingRepository ¶
func NewCloudControllerServiceBindingRepository(config core_config.Reader, gateway net.Gateway) (repo CloudControllerServiceBindingRepository)
func (CloudControllerServiceBindingRepository) Create ¶
func (repo CloudControllerServiceBindingRepository) Create(instanceGuid, appGuid string, paramsMap map[string]interface{}) (apiErr error)
func (CloudControllerServiceBindingRepository) Delete ¶
func (repo CloudControllerServiceBindingRepository) Delete(instance models.ServiceInstance, appGuid string) (found bool, apiErr error)
type CloudControllerServiceBrokerRepository ¶
type CloudControllerServiceBrokerRepository struct {
// contains filtered or unexported fields
}
func NewCloudControllerServiceBrokerRepository ¶
func NewCloudControllerServiceBrokerRepository(config core_config.Reader, gateway net.Gateway) (repo CloudControllerServiceBrokerRepository)
func (CloudControllerServiceBrokerRepository) Create ¶
func (repo CloudControllerServiceBrokerRepository) Create(name, url, username, password string) (apiErr error)
func (CloudControllerServiceBrokerRepository) Delete ¶
func (repo CloudControllerServiceBrokerRepository) Delete(guid string) (apiErr error)
func (CloudControllerServiceBrokerRepository) FindByGuid ¶
func (repo CloudControllerServiceBrokerRepository) FindByGuid(guid string) (serviceBroker models.ServiceBroker, apiErr error)
func (CloudControllerServiceBrokerRepository) FindByName ¶
func (repo CloudControllerServiceBrokerRepository) FindByName(name string) (serviceBroker models.ServiceBroker, apiErr error)
func (CloudControllerServiceBrokerRepository) ListServiceBrokers ¶
func (repo CloudControllerServiceBrokerRepository) ListServiceBrokers(callback func(models.ServiceBroker) bool) error
func (CloudControllerServiceBrokerRepository) Rename ¶
func (repo CloudControllerServiceBrokerRepository) Rename(guid, name string) (apiErr error)
func (CloudControllerServiceBrokerRepository) Update ¶
func (repo CloudControllerServiceBrokerRepository) Update(serviceBroker models.ServiceBroker) (apiErr error)
type CloudControllerServiceKeyRepository ¶
type CloudControllerServiceKeyRepository struct {
// contains filtered or unexported fields
}
func NewCloudControllerServiceKeyRepository ¶
func NewCloudControllerServiceKeyRepository(config core_config.Reader, gateway net.Gateway) (repo CloudControllerServiceKeyRepository)
func (CloudControllerServiceKeyRepository) CreateServiceKey ¶
func (c CloudControllerServiceKeyRepository) CreateServiceKey(instanceGuid string, keyName string, params map[string]interface{}) error
func (CloudControllerServiceKeyRepository) DeleteServiceKey ¶
func (c CloudControllerServiceKeyRepository) DeleteServiceKey(serviceKeyGuid string) error
func (CloudControllerServiceKeyRepository) GetServiceKey ¶
func (c CloudControllerServiceKeyRepository) GetServiceKey(instanceGuid string, keyName string) (models.ServiceKey, error)
func (CloudControllerServiceKeyRepository) ListServiceKeys ¶
func (c CloudControllerServiceKeyRepository) ListServiceKeys(instanceGuid string) ([]models.ServiceKey, error)
type CloudControllerServicePlanRepository ¶
type CloudControllerServicePlanRepository struct {
// contains filtered or unexported fields
}
func NewCloudControllerServicePlanRepository ¶
func NewCloudControllerServicePlanRepository(config core_config.Reader, gateway net.Gateway) CloudControllerServicePlanRepository
func (CloudControllerServicePlanRepository) ListPlansFromManyServices ¶
func (repo CloudControllerServicePlanRepository) ListPlansFromManyServices(serviceGuids []string) ([]models.ServicePlanFields, error)
func (CloudControllerServicePlanRepository) Search ¶
func (repo CloudControllerServicePlanRepository) Search(queryParams map[string]string) (plans []models.ServicePlanFields, err error)
func (CloudControllerServicePlanRepository) Update ¶
func (repo CloudControllerServicePlanRepository) Update(servicePlan models.ServicePlanFields, serviceGuid string, public bool) error
type CloudControllerServicePlanVisibilityRepository ¶
type CloudControllerServicePlanVisibilityRepository struct {
// contains filtered or unexported fields
}
func NewCloudControllerServicePlanVisibilityRepository ¶
func NewCloudControllerServicePlanVisibilityRepository(config core_config.Reader, gateway net.Gateway) CloudControllerServicePlanVisibilityRepository
func (CloudControllerServicePlanVisibilityRepository) Create ¶
func (repo CloudControllerServicePlanVisibilityRepository) Create(serviceGuid, orgGuid string) error
func (CloudControllerServicePlanVisibilityRepository) Delete ¶
func (repo CloudControllerServicePlanVisibilityRepository) Delete(servicePlanGuid string) error
func (CloudControllerServicePlanVisibilityRepository) List ¶
func (repo CloudControllerServicePlanVisibilityRepository) List() (visibilities []models.ServicePlanVisibilityFields, err error)
func (CloudControllerServicePlanVisibilityRepository) Search ¶
func (repo CloudControllerServicePlanVisibilityRepository) Search(queryParams map[string]string) ([]models.ServicePlanVisibilityFields, error)
type CloudControllerServiceRepository ¶
type CloudControllerServiceRepository struct {
// contains filtered or unexported fields
}
func NewCloudControllerServiceRepository ¶
func NewCloudControllerServiceRepository(config core_config.Reader, gateway net.Gateway) (repo CloudControllerServiceRepository)
func (CloudControllerServiceRepository) CreateServiceInstance ¶
func (repo CloudControllerServiceRepository) CreateServiceInstance(name, planGuid string, params map[string]interface{}, tags []string) (err error)
func (CloudControllerServiceRepository) DeleteService ¶
func (repo CloudControllerServiceRepository) DeleteService(instance models.ServiceInstance) (apiErr error)
func (CloudControllerServiceRepository) FindInstanceByName ¶
func (repo CloudControllerServiceRepository) FindInstanceByName(name string) (instance models.ServiceInstance, apiErr error)
func (CloudControllerServiceRepository) FindServiceOfferingByLabelAndProvider ¶
func (repo CloudControllerServiceRepository) FindServiceOfferingByLabelAndProvider(label, provider string) (models.ServiceOffering, error)
func (CloudControllerServiceRepository) FindServiceOfferingsByLabel ¶
func (repo CloudControllerServiceRepository) FindServiceOfferingsByLabel(label string) (models.ServiceOfferings, error)
func (CloudControllerServiceRepository) FindServiceOfferingsForSpaceByLabel ¶
func (repo CloudControllerServiceRepository) FindServiceOfferingsForSpaceByLabel(spaceGuid, name string) (offerings models.ServiceOfferings, err error)
func (CloudControllerServiceRepository) FindServicePlanByDescription ¶
func (repo CloudControllerServiceRepository) FindServicePlanByDescription(planDescription resources.ServicePlanDescription) (string, error)
func (CloudControllerServiceRepository) GetAllServiceOfferings ¶
func (repo CloudControllerServiceRepository) GetAllServiceOfferings() (models.ServiceOfferings, error)
func (CloudControllerServiceRepository) GetServiceInstanceCountForServicePlan ¶
func (repo CloudControllerServiceRepository) GetServiceInstanceCountForServicePlan(v1PlanGuid string) (count int, apiErr error)
func (CloudControllerServiceRepository) GetServiceOfferingByGuid ¶
func (repo CloudControllerServiceRepository) GetServiceOfferingByGuid(serviceGuid string) (models.ServiceOffering, error)
func (CloudControllerServiceRepository) GetServiceOfferingsForSpace ¶
func (repo CloudControllerServiceRepository) GetServiceOfferingsForSpace(spaceGuid string) (models.ServiceOfferings, error)
func (CloudControllerServiceRepository) ListServicesFromBroker ¶
func (repo CloudControllerServiceRepository) ListServicesFromBroker(brokerGuid string) (offerings []models.ServiceOffering, err error)
func (CloudControllerServiceRepository) ListServicesFromManyBrokers ¶
func (repo CloudControllerServiceRepository) ListServicesFromManyBrokers(brokerGuids []string) ([]models.ServiceOffering, error)
func (CloudControllerServiceRepository) MigrateServicePlanFromV1ToV2 ¶
func (repo CloudControllerServiceRepository) MigrateServicePlanFromV1ToV2(v1PlanGuid, v2PlanGuid string) (changedCount int, apiErr error)
func (CloudControllerServiceRepository) PurgeServiceOffering ¶
func (repo CloudControllerServiceRepository) PurgeServiceOffering(offering models.ServiceOffering) error
func (CloudControllerServiceRepository) RenameService ¶
func (repo CloudControllerServiceRepository) RenameService(instance models.ServiceInstance, newName string) (apiErr error)
func (CloudControllerServiceRepository) UpdateServiceInstance ¶
func (repo CloudControllerServiceRepository) UpdateServiceInstance(instanceGuid, planGuid string, params map[string]interface{}, tags []string) (err error)
type CloudControllerServiceSummaryRepository ¶
type CloudControllerServiceSummaryRepository struct {
// contains filtered or unexported fields
}
func NewCloudControllerServiceSummaryRepository ¶
func NewCloudControllerServiceSummaryRepository(config core_config.Reader, gateway net.Gateway) (repo CloudControllerServiceSummaryRepository)
func (CloudControllerServiceSummaryRepository) GetSummariesInCurrentSpace ¶
func (repo CloudControllerServiceSummaryRepository) GetSummariesInCurrentSpace() (instances []models.ServiceInstance, apiErr error)
type CloudControllerUserRepository ¶
type CloudControllerUserRepository struct {
// contains filtered or unexported fields
}
func NewCloudControllerUserRepository ¶
func NewCloudControllerUserRepository(config core_config.Reader, uaaGateway net.Gateway, ccGateway net.Gateway) (repo CloudControllerUserRepository)
func (CloudControllerUserRepository) Create ¶
func (repo CloudControllerUserRepository) Create(username, password string) (err error)
func (CloudControllerUserRepository) Delete ¶
func (repo CloudControllerUserRepository) Delete(userGuid string) (apiErr error)
func (CloudControllerUserRepository) FindByUsername ¶
func (repo CloudControllerUserRepository) FindByUsername(username string) (models.UserFields, error)
func (CloudControllerUserRepository) ListUsersInOrgForRole ¶
func (repo CloudControllerUserRepository) ListUsersInOrgForRole(orgGuid string, roleName string) (users []models.UserFields, apiErr error)
func (CloudControllerUserRepository) ListUsersInOrgForRoleWithNoUAA ¶
func (repo CloudControllerUserRepository) ListUsersInOrgForRoleWithNoUAA(orgGuid string, roleName string) (users []models.UserFields, apiErr error)
func (CloudControllerUserRepository) ListUsersInSpaceForRole ¶
func (repo CloudControllerUserRepository) ListUsersInSpaceForRole(spaceGuid string, roleName string) (users []models.UserFields, apiErr error)
func (CloudControllerUserRepository) ListUsersInSpaceForRoleWithNoUAA ¶
func (repo CloudControllerUserRepository) ListUsersInSpaceForRoleWithNoUAA(spaceGuid string, roleName string) (users []models.UserFields, apiErr error)
func (CloudControllerUserRepository) SetOrgRole ¶
func (repo CloudControllerUserRepository) SetOrgRole(userGuid string, orgGuid string, role string) (apiErr error)
func (CloudControllerUserRepository) SetSpaceRole ¶
func (repo CloudControllerUserRepository) SetSpaceRole(userGuid, spaceGuid, orgGuid, role string) (apiErr error)
func (CloudControllerUserRepository) UnsetOrgRole ¶
func (repo CloudControllerUserRepository) UnsetOrgRole(userGuid, orgGuid, role string) (apiErr error)
func (CloudControllerUserRepository) UnsetSpaceRole ¶
func (repo CloudControllerUserRepository) UnsetSpaceRole(userGuid, spaceGuid, role string) (apiErr error)
type CurlRepository ¶
type DomainRepository ¶
type DomainRepository interface { ListDomainsForOrg(orgGuid string, cb func(models.DomainFields) bool) error FindPrivateByName(name string) (domain models.DomainFields, apiErr error) FindByNameInOrg(name string, owningOrgGuid string) (domain models.DomainFields, apiErr error) Create(domainName string, owningOrgGuid string) (createdDomain models.DomainFields, apiErr error) Delete(domainGuid string) (apiErr error) FirstOrDefault(orgGuid string, name *string) (domain models.DomainFields, error error) }
type DomainSummary ¶
type EndpointRepository ¶
type EndpointRepository interface {
UpdateEndpoint(endpoint string) (finalEndpoint string, apiErr error)
}
func NewEndpointRepository ¶
func NewEndpointRepository(config core_config.ReadWriter, gateway net.Gateway) EndpointRepository
type LastOperationSummary ¶
type LoggregatorLogsRepository ¶
type LoggregatorLogsRepository struct {
// contains filtered or unexported fields
}
func (*LoggregatorLogsRepository) Close ¶
func (repo *LoggregatorLogsRepository) Close()
func (*LoggregatorLogsRepository) RecentLogsFor ¶
func (repo *LoggregatorLogsRepository) RecentLogsFor(appGuid string) ([]*logmessage.LogMessage, error)
func (*LoggregatorLogsRepository) TailLogsFor ¶
func (repo *LoggregatorLogsRepository) TailLogsFor(appGuid string, onConnect func(), onMessage func(*logmessage.LogMessage)) error
type Loggregator_SortedMessageQueue ¶
type Loggregator_SortedMessageQueue struct {
// contains filtered or unexported fields
}
func NewLoggregator_SortedMessageQueue ¶
func NewLoggregator_SortedMessageQueue(printTimeBuffer time.Duration, clock func() time.Time) *Loggregator_SortedMessageQueue
func (*Loggregator_SortedMessageQueue) Len ¶
func (pq *Loggregator_SortedMessageQueue) Len() int
func (*Loggregator_SortedMessageQueue) Less ¶
func (pq *Loggregator_SortedMessageQueue) Less(i, j int) bool
implement sort interface so we can sort messages as we receive them in PushMessage
func (*Loggregator_SortedMessageQueue) NextTimestamp ¶
func (pq *Loggregator_SortedMessageQueue) NextTimestamp() int64
func (*Loggregator_SortedMessageQueue) PopMessage ¶
func (pq *Loggregator_SortedMessageQueue) PopMessage() *logmessage.LogMessage
func (*Loggregator_SortedMessageQueue) PushMessage ¶
func (pq *Loggregator_SortedMessageQueue) PushMessage(message *logmessage.LogMessage)
func (*Loggregator_SortedMessageQueue) Swap ¶
func (pq *Loggregator_SortedMessageQueue) Swap(i, j int)
type LogsNoaaRepository ¶
type LogsNoaaRepository interface { GetContainerMetrics(string, []models.AppInstanceFields) ([]models.AppInstanceFields, error) RecentLogsFor(appGuid string) ([]*events.LogMessage, error) TailNoaaLogsFor(appGuid string, onConnect func(), onMessage func(*events.LogMessage)) error Close() }
func NewLogsNoaaRepository ¶
func NewLogsNoaaRepository(config core_config.Reader, consumer NoaaConsumer, tr authentication.TokenRefresher) LogsNoaaRepository
type NoaaConsumer ¶
type NoaaConsumer interface { GetContainerMetrics(string, string) ([]*events.ContainerMetric, error) RecentLogs(string, string) ([]*events.LogMessage, error) TailingLogs(string, string, chan<- *events.LogMessage, chan<- error) SetOnConnectCallback(func()) Close() error }
func NewNoaaConsumer ¶
func NewNoaaConsumer(consumer *noaa.Consumer) NoaaConsumer
type OldLogsRepository ¶
type OldLogsRepository interface { RecentLogsFor(appGuid string) ([]*logmessage.LogMessage, error) TailLogsFor(appGuid string, onConnect func(), onMessage func(*logmessage.LogMessage)) error Close() }
func NewLoggregatorLogsRepository ¶
func NewLoggregatorLogsRepository(config core_config.Reader, consumer consumer.LoggregatorConsumer, refresher authentication.TokenRefresher) OldLogsRepository
type RemoteEndpointRepository ¶
type RemoteEndpointRepository struct {
// contains filtered or unexported fields
}
func (RemoteEndpointRepository) UpdateEndpoint ¶
func (repo RemoteEndpointRepository) UpdateEndpoint(endpoint string) (finalEndpoint string, apiErr error)
type RepositoryLocator ¶
type RepositoryLocator struct {
// contains filtered or unexported fields
}
func NewRepositoryLocator ¶
func NewRepositoryLocator(config core_config.ReadWriter, gatewaysByName map[string]net.Gateway) (loc RepositoryLocator)
func (RepositoryLocator) GetAppEventsRepository ¶
func (locator RepositoryLocator) GetAppEventsRepository() app_events.AppEventsRepository
func (RepositoryLocator) GetAppFilesRepository ¶
func (locator RepositoryLocator) GetAppFilesRepository() api_app_files.AppFilesRepository
func (RepositoryLocator) GetAppInstancesRepository ¶
func (locator RepositoryLocator) GetAppInstancesRepository() app_instances.AppInstancesRepository
func (RepositoryLocator) GetAppSummaryRepository ¶
func (locator RepositoryLocator) GetAppSummaryRepository() AppSummaryRepository
func (RepositoryLocator) GetApplicationBitsRepository ¶
func (locator RepositoryLocator) GetApplicationBitsRepository() application_bits.ApplicationBitsRepository
func (RepositoryLocator) GetApplicationRepository ¶
func (locator RepositoryLocator) GetApplicationRepository() applications.ApplicationRepository
func (RepositoryLocator) GetAuthenticationRepository ¶
func (locator RepositoryLocator) GetAuthenticationRepository() authentication.AuthenticationRepository
func (RepositoryLocator) GetBuildpackBitsRepository ¶
func (locator RepositoryLocator) GetBuildpackBitsRepository() BuildpackBitsRepository
func (RepositoryLocator) GetBuildpackRepository ¶
func (locator RepositoryLocator) GetBuildpackRepository() BuildpackRepository
func (RepositoryLocator) GetCopyApplicationSourceRepository ¶
func (locator RepositoryLocator) GetCopyApplicationSourceRepository() copy_application_source.CopyApplicationSourceRepository
func (RepositoryLocator) GetCurlRepository ¶
func (locator RepositoryLocator) GetCurlRepository() CurlRepository
func (RepositoryLocator) GetDomainRepository ¶
func (locator RepositoryLocator) GetDomainRepository() DomainRepository
func (RepositoryLocator) GetEndpointRepository ¶
func (locator RepositoryLocator) GetEndpointRepository() EndpointRepository
func (RepositoryLocator) GetEnvironmentVariableGroupsRepository ¶
func (locator RepositoryLocator) GetEnvironmentVariableGroupsRepository() environment_variable_groups.EnvironmentVariableGroupsRepository
func (RepositoryLocator) GetFeatureFlagRepository ¶
func (locator RepositoryLocator) GetFeatureFlagRepository() feature_flags.FeatureFlagRepository
func (RepositoryLocator) GetLogsNoaaRepository ¶
func (locator RepositoryLocator) GetLogsNoaaRepository() LogsNoaaRepository
func (RepositoryLocator) GetOldLogsRepository ¶
func (locator RepositoryLocator) GetOldLogsRepository() OldLogsRepository
func (RepositoryLocator) GetOrganizationRepository ¶
func (locator RepositoryLocator) GetOrganizationRepository() organizations.OrganizationRepository
func (RepositoryLocator) GetPasswordRepository ¶
func (locator RepositoryLocator) GetPasswordRepository() password.PasswordRepository
func (RepositoryLocator) GetQuotaRepository ¶
func (locator RepositoryLocator) GetQuotaRepository() quotas.QuotaRepository
func (RepositoryLocator) GetRouteRepository ¶
func (locator RepositoryLocator) GetRouteRepository() RouteRepository
func (RepositoryLocator) GetRunningSecurityGroupsRepository ¶
func (locator RepositoryLocator) GetRunningSecurityGroupsRepository() running.RunningSecurityGroupsRepo
func (RepositoryLocator) GetSecurityGroupRepository ¶
func (locator RepositoryLocator) GetSecurityGroupRepository() security_groups.SecurityGroupRepo
func (RepositoryLocator) GetSecurityGroupSpaceBinder ¶
func (locator RepositoryLocator) GetSecurityGroupSpaceBinder() securitygroupspaces.SecurityGroupSpaceBinder
func (RepositoryLocator) GetServiceAuthTokenRepository ¶
func (locator RepositoryLocator) GetServiceAuthTokenRepository() ServiceAuthTokenRepository
func (RepositoryLocator) GetServiceBindingRepository ¶
func (locator RepositoryLocator) GetServiceBindingRepository() ServiceBindingRepository
func (RepositoryLocator) GetServiceBrokerRepository ¶
func (locator RepositoryLocator) GetServiceBrokerRepository() ServiceBrokerRepository
func (RepositoryLocator) GetServiceKeyRepository ¶
func (locator RepositoryLocator) GetServiceKeyRepository() ServiceKeyRepository
func (RepositoryLocator) GetServicePlanRepository ¶
func (locator RepositoryLocator) GetServicePlanRepository() ServicePlanRepository
func (RepositoryLocator) GetServicePlanVisibilityRepository ¶
func (locator RepositoryLocator) GetServicePlanVisibilityRepository() ServicePlanVisibilityRepository
func (RepositoryLocator) GetServiceRepository ¶
func (locator RepositoryLocator) GetServiceRepository() ServiceRepository
func (RepositoryLocator) GetServiceSummaryRepository ¶
func (locator RepositoryLocator) GetServiceSummaryRepository() ServiceSummaryRepository
func (RepositoryLocator) GetSpaceQuotaRepository ¶
func (locator RepositoryLocator) GetSpaceQuotaRepository() space_quotas.SpaceQuotaRepository
func (RepositoryLocator) GetSpaceRepository ¶
func (locator RepositoryLocator) GetSpaceRepository() spaces.SpaceRepository
func (RepositoryLocator) GetStackRepository ¶
func (locator RepositoryLocator) GetStackRepository() stacks.StackRepository
func (RepositoryLocator) GetStagingSecurityGroupsRepository ¶
func (locator RepositoryLocator) GetStagingSecurityGroupsRepository() staging.StagingSecurityGroupsRepo
func (RepositoryLocator) GetUserProvidedServiceInstanceRepository ¶
func (locator RepositoryLocator) GetUserProvidedServiceInstanceRepository() UserProvidedServiceInstanceRepository
func (RepositoryLocator) GetUserRepository ¶
func (locator RepositoryLocator) GetUserRepository() UserRepository
func (RepositoryLocator) SetAppEventsRepository ¶
func (locator RepositoryLocator) SetAppEventsRepository(repo app_events.AppEventsRepository) RepositoryLocator
func (RepositoryLocator) SetAppFileRepository ¶
func (locator RepositoryLocator) SetAppFileRepository(repo api_app_files.AppFilesRepository) RepositoryLocator
func (RepositoryLocator) SetAppInstancesRepository ¶
func (locator RepositoryLocator) SetAppInstancesRepository(repo app_instances.AppInstancesRepository) RepositoryLocator
func (RepositoryLocator) SetAppSummaryRepository ¶
func (locator RepositoryLocator) SetAppSummaryRepository(repo AppSummaryRepository) RepositoryLocator
func (RepositoryLocator) SetApplicationRepository ¶
func (locator RepositoryLocator) SetApplicationRepository(repo applications.ApplicationRepository) RepositoryLocator
func (RepositoryLocator) SetAuthenticationRepository ¶
func (locator RepositoryLocator) SetAuthenticationRepository(repo authentication.AuthenticationRepository) RepositoryLocator
func (RepositoryLocator) SetBuildpackBitsRepository ¶
func (locator RepositoryLocator) SetBuildpackBitsRepository(repo BuildpackBitsRepository) RepositoryLocator
func (RepositoryLocator) SetBuildpackRepository ¶
func (locator RepositoryLocator) SetBuildpackRepository(repo BuildpackRepository) RepositoryLocator
func (RepositoryLocator) SetCopyApplicationSourceRepository ¶
func (locator RepositoryLocator) SetCopyApplicationSourceRepository(repo copy_application_source.CopyApplicationSourceRepository) RepositoryLocator
func (RepositoryLocator) SetCurlRepository ¶
func (locator RepositoryLocator) SetCurlRepository(repo CurlRepository) RepositoryLocator
func (RepositoryLocator) SetDomainRepository ¶
func (locator RepositoryLocator) SetDomainRepository(repo DomainRepository) RepositoryLocator
func (RepositoryLocator) SetEndpointRepository ¶
func (locator RepositoryLocator) SetEndpointRepository(e EndpointRepository) RepositoryLocator
func (RepositoryLocator) SetEnvironmentVariableGroupsRepository ¶
func (locator RepositoryLocator) SetEnvironmentVariableGroupsRepository(repo environment_variable_groups.EnvironmentVariableGroupsRepository) RepositoryLocator
func (RepositoryLocator) SetFeatureFlagRepository ¶
func (locator RepositoryLocator) SetFeatureFlagRepository(repo feature_flags.FeatureFlagRepository) RepositoryLocator
func (RepositoryLocator) SetLogsNoaaRepository ¶
func (locator RepositoryLocator) SetLogsNoaaRepository(repo LogsNoaaRepository) RepositoryLocator
func (RepositoryLocator) SetOldLogsRepository ¶
func (locator RepositoryLocator) SetOldLogsRepository(repo OldLogsRepository) RepositoryLocator
func (RepositoryLocator) SetOrganizationRepository ¶
func (locator RepositoryLocator) SetOrganizationRepository(repo organizations.OrganizationRepository) RepositoryLocator
func (RepositoryLocator) SetPasswordRepository ¶
func (locator RepositoryLocator) SetPasswordRepository(repo password.PasswordRepository) RepositoryLocator
func (RepositoryLocator) SetQuotaRepository ¶
func (locator RepositoryLocator) SetQuotaRepository(repo quotas.QuotaRepository) RepositoryLocator
func (RepositoryLocator) SetRouteRepository ¶
func (locator RepositoryLocator) SetRouteRepository(repo RouteRepository) RepositoryLocator
func (RepositoryLocator) SetRunningSecurityGroupRepository ¶
func (locator RepositoryLocator) SetRunningSecurityGroupRepository(repo running.RunningSecurityGroupsRepo) RepositoryLocator
func (RepositoryLocator) SetSecurityGroupRepository ¶
func (locator RepositoryLocator) SetSecurityGroupRepository(repo security_groups.SecurityGroupRepo) RepositoryLocator
func (RepositoryLocator) SetSecurityGroupSpaceBinder ¶
func (locator RepositoryLocator) SetSecurityGroupSpaceBinder(repo securitygroupspaces.SecurityGroupSpaceBinder) RepositoryLocator
func (RepositoryLocator) SetServiceAuthTokenRepository ¶
func (locator RepositoryLocator) SetServiceAuthTokenRepository(repo ServiceAuthTokenRepository) RepositoryLocator
func (RepositoryLocator) SetServiceBindingRepository ¶
func (locator RepositoryLocator) SetServiceBindingRepository(repo ServiceBindingRepository) RepositoryLocator
func (RepositoryLocator) SetServiceBrokerRepository ¶
func (locator RepositoryLocator) SetServiceBrokerRepository(repo ServiceBrokerRepository) RepositoryLocator
func (RepositoryLocator) SetServiceKeyRepository ¶
func (locator RepositoryLocator) SetServiceKeyRepository(repo ServiceKeyRepository) RepositoryLocator
func (RepositoryLocator) SetServiceRepository ¶
func (locator RepositoryLocator) SetServiceRepository(repo ServiceRepository) RepositoryLocator
func (RepositoryLocator) SetServiceSummaryRepository ¶
func (locator RepositoryLocator) SetServiceSummaryRepository(repo ServiceSummaryRepository) RepositoryLocator
func (RepositoryLocator) SetSpaceQuotaRepository ¶
func (locator RepositoryLocator) SetSpaceQuotaRepository(repo space_quotas.SpaceQuotaRepository) RepositoryLocator
func (RepositoryLocator) SetSpaceRepository ¶
func (locator RepositoryLocator) SetSpaceRepository(repo spaces.SpaceRepository) RepositoryLocator
func (RepositoryLocator) SetStackRepository ¶
func (locator RepositoryLocator) SetStackRepository(repo stacks.StackRepository) RepositoryLocator
func (RepositoryLocator) SetStagingSecurityGroupRepository ¶
func (locator RepositoryLocator) SetStagingSecurityGroupRepository(repo staging.StagingSecurityGroupsRepo) RepositoryLocator
func (RepositoryLocator) SetUserProvidedServiceInstanceRepository ¶
func (locator RepositoryLocator) SetUserProvidedServiceInstanceRepository(repo UserProvidedServiceInstanceRepository) RepositoryLocator
func (RepositoryLocator) SetUserRepository ¶
func (locator RepositoryLocator) SetUserRepository(repo UserRepository) RepositoryLocator
type RouteRepository ¶
type RouteRepository interface { ListRoutes(cb func(models.Route) bool) (apiErr error) ListAllRoutes(cb func(models.Route) bool) (apiErr error) FindByHostAndDomain(host string, domain models.DomainFields) (route models.Route, apiErr error) Create(host string, domain models.DomainFields) (createdRoute models.Route, apiErr error) CheckIfExists(host string, domain models.DomainFields) (found bool, apiErr error) CreateInSpace(host, domainGuid, spaceGuid string) (createdRoute models.Route, apiErr error) Bind(routeGuid, appGuid string) (apiErr error) Unbind(routeGuid, appGuid string) (apiErr error) Delete(routeGuid string) (apiErr error) }
type RouteSummary ¶
type RouteSummary struct { Guid string Host string Domain DomainSummary }
func (RouteSummary) ToModel ¶
func (resource RouteSummary) ToModel() (route models.RouteSummary)
type ServiceAuthTokenRepository ¶
type ServiceAuthTokenRepository interface { FindAll() (authTokens []models.ServiceAuthTokenFields, apiErr error) FindByLabelAndProvider(label, provider string) (authToken models.ServiceAuthTokenFields, apiErr error) Create(authToken models.ServiceAuthTokenFields) (apiErr error) Update(authToken models.ServiceAuthTokenFields) (apiErr error) Delete(authToken models.ServiceAuthTokenFields) (apiErr error) }
type ServiceBrokerRepository ¶
type ServiceBrokerRepository interface { ListServiceBrokers(callback func(models.ServiceBroker) bool) error FindByName(name string) (serviceBroker models.ServiceBroker, apiErr error) FindByGuid(guid string) (serviceBroker models.ServiceBroker, apiErr error) Create(name, url, username, password string) (apiErr error) Update(serviceBroker models.ServiceBroker) (apiErr error) Rename(guid, name string) (apiErr error) Delete(guid string) (apiErr error) }
type ServiceInstanceSummary ¶
type ServiceInstanceSummary struct { Name string LastOperation LastOperationSummary `json:"last_operation"` ServicePlan ServicePlanSummary `json:"service_plan"` }
type ServiceInstancesSummaries ¶
type ServiceInstancesSummaries struct { Apps []ServiceInstanceSummaryApp ServiceInstances []ServiceInstanceSummary `json:"services"` }
func (ServiceInstancesSummaries) ToModels ¶
func (resource ServiceInstancesSummaries) ToModels() (instances []models.ServiceInstance)
type ServiceKeyRepository ¶
type ServiceKeyRepository interface { CreateServiceKey(serviceKeyGuid string, keyName string, params map[string]interface{}) error ListServiceKeys(serviceKeyGuid string) ([]models.ServiceKey, error) GetServiceKey(serviceKeyGuid string, keyName string) (models.ServiceKey, error) DeleteServiceKey(serviceKeyGuid string) error }
type ServiceOfferingSummary ¶
type ServicePlanRepository ¶
type ServicePlanRepository interface { Search(searchParameters map[string]string) ([]models.ServicePlanFields, error) Update(models.ServicePlanFields, string, bool) error ListPlansFromManyServices(serviceGuids []string) ([]models.ServicePlanFields, error) }
type ServicePlanSummary ¶
type ServicePlanSummary struct { Name string Guid string ServiceOffering ServiceOfferingSummary `json:"service"` }
func (ServicePlanSummary) ToModel ¶
func (resource ServicePlanSummary) ToModel() (route models.ServicePlanSummary)
type ServiceRepository ¶
type ServiceRepository interface { PurgeServiceOffering(offering models.ServiceOffering) error GetServiceOfferingByGuid(serviceGuid string) (offering models.ServiceOffering, apiErr error) FindServiceOfferingsByLabel(name string) (offering models.ServiceOfferings, apiErr error) FindServiceOfferingByLabelAndProvider(name, provider string) (offering models.ServiceOffering, apiErr error) FindServiceOfferingsForSpaceByLabel(spaceGuid, name string) (offering models.ServiceOfferings, apiErr error) GetAllServiceOfferings() (offerings models.ServiceOfferings, apiErr error) GetServiceOfferingsForSpace(spaceGuid string) (offerings models.ServiceOfferings, apiErr error) FindInstanceByName(name string) (instance models.ServiceInstance, apiErr error) CreateServiceInstance(name, planGuid string, params map[string]interface{}, tags []string) (apiErr error) UpdateServiceInstance(instanceGuid, planGuid string, params map[string]interface{}, tags []string) (apiErr error) RenameService(instance models.ServiceInstance, newName string) (apiErr error) DeleteService(instance models.ServiceInstance) (apiErr error) FindServicePlanByDescription(planDescription resources.ServicePlanDescription) (planGuid string, apiErr error) ListServicesFromBroker(brokerGuid string) (services []models.ServiceOffering, err error) ListServicesFromManyBrokers(brokerGuids []string) (services []models.ServiceOffering, err error) GetServiceInstanceCountForServicePlan(v1PlanGuid string) (count int, apiErr error) MigrateServicePlanFromV1ToV2(v1PlanGuid, v2PlanGuid string) (changedCount int, apiErr error) }
type ServiceSummaryRepository ¶
type ServiceSummaryRepository interface {
GetSummariesInCurrentSpace() (instances []models.ServiceInstance, apiErr error)
}
type SortedMessageQueue ¶
type SortedMessageQueue struct {
// contains filtered or unexported fields
}
func NewSortedMessageQueue ¶
func NewSortedMessageQueue(printTimeBuffer time.Duration, clock func() time.Time) *SortedMessageQueue
func (*SortedMessageQueue) Len ¶
func (pq *SortedMessageQueue) Len() int
func (*SortedMessageQueue) Less ¶
func (pq *SortedMessageQueue) Less(i, j int) bool
implement sort interface so we can sort messages as we receive them in PushMessage
func (*SortedMessageQueue) NextTimestamp ¶
func (pq *SortedMessageQueue) NextTimestamp() int64
func (*SortedMessageQueue) PopMessage ¶
func (pq *SortedMessageQueue) PopMessage() *events.LogMessage
func (*SortedMessageQueue) PushMessage ¶
func (pq *SortedMessageQueue) PushMessage(message *events.LogMessage)
func (*SortedMessageQueue) Swap ¶
func (pq *SortedMessageQueue) Swap(i, j int)
type UserProvidedServiceInstanceRepository ¶
type UserProvidedServiceInstanceRepository interface { Create(name, drainUrl string, params map[string]interface{}) (apiErr error) Update(serviceInstanceFields models.ServiceInstanceFields) (apiErr error) GetSummaries() (models.UserProvidedServiceSummary, error) }
type UserRepository ¶
type UserRepository interface { FindByUsername(username string) (user models.UserFields, apiErr error) ListUsersInOrgForRole(orgGuid string, role string) ([]models.UserFields, error) ListUsersInOrgForRoleWithNoUAA(orgGuid string, role string) ([]models.UserFields, error) ListUsersInSpaceForRole(spaceGuid string, role string) ([]models.UserFields, error) ListUsersInSpaceForRoleWithNoUAA(spaceGuid string, role string) ([]models.UserFields, error) Create(username, password string) (apiErr error) Delete(userGuid string) (apiErr error) SetOrgRole(userGuid, orgGuid, role string) (apiErr error) UnsetOrgRole(userGuid, orgGuid, role string) (apiErr error) SetSpaceRole(userGuid, spaceGuid, orgGuid, role string) (apiErr error) UnsetSpaceRole(userGuid, spaceGuid, role string) (apiErr error) }
Source Files ¶
- app_summary.go
- buildpack_bits.go
- buildpacks.go
- curl.go
- domains.go
- endpoints.go
- log_message_queue_noaa.go
- log_message_queue_old_loggregator.go
- logs_noaa.go
- logs_old_consumer.go
- noaaConsumer.go
- repository_locator.go
- resource.go
- routes.go
- service_auth_tokens.go
- service_bindings.go
- service_brokers.go
- service_keys.go
- service_plan.go
- service_plan_visibility.go
- service_summary.go
- services.go
- user_provided_service_instances.go
- users.go
Directories ¶
Path | Synopsis |
---|---|
fakes
This file was generated by counterfeiter
|
This file was generated by counterfeiter |
fakes
This file was generated by counterfeiter
|
This file was generated by counterfeiter |
fakes
This file was generated by counterfeiter
|
This file was generated by counterfeiter |
fakes
This file was generated by counterfeiter
|
This file was generated by counterfeiter |
fakes
This file was generated by counterfeiter
|
This file was generated by counterfeiter |
fakes
This file was generated by counterfeiter
|
This file was generated by counterfeiter |
This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter
|
This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter This file was generated by counterfeiter |
fakes
This file was generated by counterfeiter
|
This file was generated by counterfeiter |
fakes
This file was generated by counterfeiter
|
This file was generated by counterfeiter |
fakes
This file was generated by counterfeiter
|
This file was generated by counterfeiter |
defaults/running/fakes
This file was generated by counterfeiter
|
This file was generated by counterfeiter |
defaults/staging/fakes
This file was generated by counterfeiter
|
This file was generated by counterfeiter |
fakes
This file was generated by counterfeiter
|
This file was generated by counterfeiter |
spaces/fakes
This file was generated by counterfeiter
|
This file was generated by counterfeiter |
fakes
This file was generated by counterfeiter
|
This file was generated by counterfeiter |
fakes
This file was generated by counterfeiter
|
This file was generated by counterfeiter |
Click to show internal directories.
Click to hide internal directories.