api

package
v6.5.0+incompatible Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 25, 2014 License: Apache-2.0 Imports: 45 Imported by: 747

Documentation

Index

Constants

View Source 
const (
	DefaultAppUploadBitsTimeout = 15 * time.Minute
)
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 AppEventsRepository 

type AppEventsRepository interface {
	RecentEvents(appGuid string, limit int64) ([]models.EventFields, error)
}

type AppFilesRepository 

type AppFilesRepository interface {
	ListFiles(appGuid string, instance int, path string) (files string, apiErr error)
}

type AppInstancesRepository 

type AppInstancesRepository interface {
	GetInstances(appGuid string) (instances []models.AppInstanceFields, apiErr error)
}

type AppSummaryRepository 

type AppSummaryRepository interface {
	GetSummariesInCurrentSpace() (apps []models.Application, apiErr error)
	GetSummary(appGuid string) (summary models.Application, apiErr error)
}

type ApplicationBitsRepository 

type ApplicationBitsRepository interface {
	UploadApp(appGuid, dir string, cb func(path string, zipSize, fileCount int64)) (apiErr error)
}

type ApplicationFromSummary 

type ApplicationFromSummary struct {
	Guid             string
	Name             string
	Routes           []RouteSummary
	RunningInstances int `json:"running_instances"`
	Memory           int64
	Instances        int
	DiskQuota        int64 `json:"disk_quota"`
	Urls             []string
	State            string
	SpaceGuid        string `json:"space_guid"`
}

func (ApplicationFromSummary) ToFields 

func (resource ApplicationFromSummary) ToFields() (app models.ApplicationFields)

func (ApplicationFromSummary) ToModel 

func (resource ApplicationFromSummary) ToModel() (app models.Application)

type ApplicationRepository 

type ApplicationRepository interface {
	Create(params models.AppParams) (createdApp models.Application, apiErr error)
	Read(name string) (app models.Application, apiErr error)
	Update(appGuid string, params models.AppParams) (updatedApp models.Application, apiErr error)
	Delete(appGuid string) (apiErr error)
	ReadEnv(guid string) (userEnv map[string]string, vcapServices string, err error)
	CreateRestageRequest(guid string) (apiErr error)
}

type ApplicationSummaries 

type ApplicationSummaries struct {
	Apps []ApplicationFromSummary
}

func (ApplicationSummaries) ToModels 

func (resource ApplicationSummaries) ToModels() (apps []models.ApplicationFields)

type BuildpackBitsRepository 

type BuildpackBitsRepository interface {
	UploadBuildpack(buildpack models.Buildpack, dir string) (apiErr error)
}

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 configuration.Reader, gateway net.Gateway) (repo CCUserProvidedServiceInstanceRepository)

func (CCUserProvidedServiceInstanceRepository) Create 

func (repo CCUserProvidedServiceInstanceRepository) Create(name, drainUrl string, params map[string]interface{}) (apiErr error)

func (CCUserProvidedServiceInstanceRepository) Update 

func (repo CCUserProvidedServiceInstanceRepository) Update(serviceInstanceFields models.ServiceInstanceFields) (apiErr error)

type CloudControllerAppEventsRepository 

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

func NewCloudControllerAppEventsRepository 

func NewCloudControllerAppEventsRepository(config configuration.Reader, gateway net.Gateway, strategy strategy.EndpointStrategy) CloudControllerAppEventsRepository

func (CloudControllerAppEventsRepository) RecentEvents 

func (repo CloudControllerAppEventsRepository) RecentEvents(appGuid string, limit int64) ([]models.EventFields, error)

type CloudControllerAppFilesRepository 

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

func NewCloudControllerAppFilesRepository 

func NewCloudControllerAppFilesRepository(config configuration.Reader, gateway net.Gateway) (repo CloudControllerAppFilesRepository)

func (CloudControllerAppFilesRepository) ListFiles 

func (repo CloudControllerAppFilesRepository) ListFiles(appGuid string, instance int, path string) (files string, apiErr error)

type CloudControllerAppInstancesRepository 

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

func NewCloudControllerAppInstancesRepository 

func NewCloudControllerAppInstancesRepository(config configuration.Reader, gateway net.Gateway) (repo CloudControllerAppInstancesRepository)

func (CloudControllerAppInstancesRepository) GetInstances 

func (repo CloudControllerAppInstancesRepository) GetInstances(appGuid string) (instances []models.AppInstanceFields, err error)

type CloudControllerAppSummaryRepository 

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

func NewCloudControllerAppSummaryRepository 

func NewCloudControllerAppSummaryRepository(config configuration.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 CloudControllerApplicationBitsRepository 

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

func NewCloudControllerApplicationBitsRepository 

func NewCloudControllerApplicationBitsRepository(config configuration.Reader, gateway net.Gateway, zipper app_files.Zipper) (repo CloudControllerApplicationBitsRepository)

func (CloudControllerApplicationBitsRepository) UploadApp 

func (repo CloudControllerApplicationBitsRepository) UploadApp(appGuid string, appDir string, fileSizePrinter func(path string, zipSize, fileCount int64)) (apiErr error)

type CloudControllerApplicationRepository 

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

func NewCloudControllerApplicationRepository 

func NewCloudControllerApplicationRepository(config configuration.Reader, gateway net.Gateway) (repo CloudControllerApplicationRepository)

func (CloudControllerApplicationRepository) Create 

func (repo CloudControllerApplicationRepository) Create(params models.AppParams) (createdApp models.Application, apiErr error)

func (CloudControllerApplicationRepository) CreateRestageRequest 

func (repo CloudControllerApplicationRepository) CreateRestageRequest(guid string) error

func (CloudControllerApplicationRepository) Delete 

func (repo CloudControllerApplicationRepository) Delete(appGuid string) (apiErr error)

func (CloudControllerApplicationRepository) Read 

func (repo CloudControllerApplicationRepository) Read(name string) (app models.Application, apiErr error)

func (CloudControllerApplicationRepository) ReadEnv 

func (repo CloudControllerApplicationRepository) ReadEnv(guid string) (map[string]string, string, error)

func (CloudControllerApplicationRepository) Update 

func (repo CloudControllerApplicationRepository) Update(appGuid string, params models.AppParams) (updatedApp models.Application, apiErr error)

type CloudControllerBuildpackBitsRepository 

type CloudControllerBuildpackBitsRepository struct {
	TrustedCerts []tls.Certificate
	// contains filtered or unexported fields
}

func NewCloudControllerBuildpackBitsRepository 

func NewCloudControllerBuildpackBitsRepository(config configuration.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 configuration.Reader, gateway net.Gateway) (repo CloudControllerBuildpackRepository)

func (CloudControllerBuildpackRepository) Create 

func (repo CloudControllerBuildpackRepository) Create(name string, position *int, enabled *bool, locked *bool) (createdBuildpack models.Buildpack, apiErr error)

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

func (CloudControllerBuildpackRepository) Update 

func (repo CloudControllerBuildpackRepository) Update(buildpack models.Buildpack) (updatedBuildpack models.Buildpack, apiErr error)

type CloudControllerCurlRepository 

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

func NewCloudControllerCurlRepository 

func NewCloudControllerCurlRepository(config configuration.Reader, gateway net.Gateway) (repo CloudControllerCurlRepository)

func (CloudControllerCurlRepository) Request 

func (repo CloudControllerCurlRepository) Request(method, path, headerString, body string) (resHeaders, resBody string, err error)

type CloudControllerDomainRepository 

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

func NewCloudControllerDomainRepository 

func NewCloudControllerDomainRepository(config configuration.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) FindByName 

func (repo CloudControllerDomainRepository) FindByName(name string) (domain models.DomainFields, apiErr error)

func (CloudControllerDomainRepository) FindByNameInOrg 

func (repo CloudControllerDomainRepository) FindByNameInOrg(name string, orgGuid 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 CloudControllerOrganizationRepository 

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

func NewCloudControllerOrganizationRepository 

func NewCloudControllerOrganizationRepository(config configuration.Reader, gateway net.Gateway) (repo CloudControllerOrganizationRepository)

func (CloudControllerOrganizationRepository) Create 

func (repo CloudControllerOrganizationRepository) Create(name string) (apiErr error)

func (CloudControllerOrganizationRepository) Delete 

func (repo CloudControllerOrganizationRepository) Delete(orgGuid string) (apiErr error)

func (CloudControllerOrganizationRepository) FindByName 

func (repo CloudControllerOrganizationRepository) FindByName(name string) (org models.Organization, apiErr error)

func (CloudControllerOrganizationRepository) ListOrgs 

func (repo CloudControllerOrganizationRepository) ListOrgs(cb func(models.Organization) bool) (apiErr error)

func (CloudControllerOrganizationRepository) Rename 

func (repo CloudControllerOrganizationRepository) Rename(orgGuid string, name string) (apiErr error)

type CloudControllerPasswordRepository 

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

func NewCloudControllerPasswordRepository 

func NewCloudControllerPasswordRepository(config configuration.Reader, gateway net.Gateway) (repo CloudControllerPasswordRepository)

func (CloudControllerPasswordRepository) UpdatePassword 

func (repo CloudControllerPasswordRepository) UpdatePassword(old string, new string) error

type CloudControllerRouteRepository 

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

func NewCloudControllerRouteRepository 

func NewCloudControllerRouteRepository(config configuration.Reader, gateway net.Gateway) (repo CloudControllerRouteRepository)

func (CloudControllerRouteRepository) Bind 

func (repo CloudControllerRouteRepository) Bind(routeGuid, appGuid string) (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) 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 configuration.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 configuration.Reader, gateway net.Gateway) (repo CloudControllerServiceBindingRepository)

func (CloudControllerServiceBindingRepository) Create 

func (repo CloudControllerServiceBindingRepository) Create(instanceGuid, appGuid string) (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 configuration.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 CloudControllerServicePlanRepository 

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

func NewCloudControllerServicePlanRepository 

func NewCloudControllerServicePlanRepository(config configuration.Reader, gateway net.Gateway) CloudControllerServicePlanRepository

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 configuration.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 configuration.Reader, gateway net.Gateway) (repo CloudControllerServiceRepository)

func (CloudControllerServiceRepository) CreateServiceInstance 

func (repo CloudControllerServiceRepository) CreateServiceInstance(name, planGuid 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) FindServiceOfferingByLabel 

func (repo CloudControllerServiceRepository) FindServiceOfferingByLabel(label string) (models.ServiceOffering, error)

func (CloudControllerServiceRepository) FindServiceOfferingByLabelAndProvider 

func (repo CloudControllerServiceRepository) FindServiceOfferingByLabelAndProvider(label, provider string) (models.ServiceOffering, 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) 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)

type CloudControllerServiceSummaryRepository 

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

func NewCloudControllerServiceSummaryRepository 

func NewCloudControllerServiceSummaryRepository(config configuration.Reader, gateway net.Gateway) (repo CloudControllerServiceSummaryRepository)

func (CloudControllerServiceSummaryRepository) GetSummariesInCurrentSpace 

func (repo CloudControllerServiceSummaryRepository) GetSummariesInCurrentSpace() (instances []models.ServiceInstance, apiErr error)

type CloudControllerStackRepository 

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

func NewCloudControllerStackRepository 

func NewCloudControllerStackRepository(config configuration.Reader, gateway net.Gateway) (repo CloudControllerStackRepository)

func (CloudControllerStackRepository) FindAll 

func (repo CloudControllerStackRepository) FindAll() (stacks []models.Stack, apiErr error)

func (CloudControllerStackRepository) FindByName 

func (repo CloudControllerStackRepository) FindByName(name string) (stack models.Stack, apiErr error)

type CloudControllerUserRepository 

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

func NewCloudControllerUserRepository 

func NewCloudControllerUserRepository(config configuration.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) (user models.UserFields, apiErr error)

func (CloudControllerUserRepository) ListUsersInOrgForRole 

func (repo CloudControllerUserRepository) ListUsersInOrgForRole(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) 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 CurlRepository interface {
	Request(method, path, header, body string) (resHeaders, resBody string, apiErr error)
}

type DomainRepository 

type DomainRepository interface {
	ListDomainsForOrg(orgGuid string, cb func(models.DomainFields) bool) error
	FindByName(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)
	CreateSharedDomain(domainName string) (apiErr error)
	Delete(domainGuid string) (apiErr error)
	DeleteSharedDomain(domainGuid string) (apiErr error)
	FirstOrDefault(orgGuid string, name *string) (domain models.DomainFields, error error)
}

type DomainSummary 

type DomainSummary struct {
	Guid                   string
	Name                   string
	OwningOrganizationGuid string
}

type EndpointRepository 

type EndpointRepository interface {
	UpdateEndpoint(endpoint string) (finalEndpoint string, apiErr error)
}

type InstanceApiResponse 

type InstanceApiResponse struct {
	State string
	Since float64
}

type InstanceStatsApiResponse 

type InstanceStatsApiResponse struct {
	Stats struct {
		DiskQuota int64 `json:"disk_quota"`
		MemQuota  int64 `json:"mem_quota"`
		Usage     struct {
			Cpu  float64
			Disk int64
			Mem  int64
		}
	}
}

type InstancesApiResponse 

type InstancesApiResponse map[string]InstanceApiResponse

type LoggregatorLogsRepository 

type LoggregatorLogsRepository struct {
	TrustedCerts []tls.Certificate
	// 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 LogsRepository 

type LogsRepository interface {
	RecentLogsFor(appGuid string) ([]*logmessage.LogMessage, error)
	TailLogsFor(appGuid string, onConnect func(), onMessage func(*logmessage.LogMessage)) error
	Close()
}

func NewLoggregatorLogsRepository 

func NewLoggregatorLogsRepository(config configuration.Reader, consumer consumer.LoggregatorConsumer, refresher authentication.TokenRefresher) LogsRepository

type OrganizationRepository 

type OrganizationRepository interface {
	ListOrgs(func(models.Organization) bool) (apiErr error)
	FindByName(name string) (org models.Organization, apiErr error)
	Create(name string) (apiErr error)
	Rename(orgGuid string, name string) (apiErr error)
	Delete(orgGuid string) (apiErr error)
}

type PasswordRepository 

type PasswordRepository interface {
	UpdatePassword(old string, new string) error
}

type RemoteEndpointRepository 

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

func NewEndpointRepository 

func NewEndpointRepository(config configuration.ReadWriter, gateway net.Gateway) (repo RemoteEndpointRepository)

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 configuration.ReadWriter, gatewaysByName map[string]net.Gateway) (loc RepositoryLocator)

func (RepositoryLocator) GetAppEventsRepository 

func (locator RepositoryLocator) GetAppEventsRepository() AppEventsRepository

func (RepositoryLocator) GetAppFilesRepository 

func (locator RepositoryLocator) GetAppFilesRepository() AppFilesRepository

func (RepositoryLocator) GetAppInstancesRepository 

func (locator RepositoryLocator) GetAppInstancesRepository() AppInstancesRepository

func (RepositoryLocator) GetAppSummaryRepository 

func (locator RepositoryLocator) GetAppSummaryRepository() AppSummaryRepository

func (RepositoryLocator) GetApplicationBitsRepository 

func (locator RepositoryLocator) GetApplicationBitsRepository() ApplicationBitsRepository

func (RepositoryLocator) GetApplicationRepository 

func (locator RepositoryLocator) GetApplicationRepository() 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) GetCurlRepository 

func (locator RepositoryLocator) GetCurlRepository() CurlRepository

func (RepositoryLocator) GetDomainRepository 

func (locator RepositoryLocator) GetDomainRepository() DomainRepository

func (RepositoryLocator) GetEndpointRepository 

func (locator RepositoryLocator) GetEndpointRepository() EndpointRepository

func (RepositoryLocator) GetLogsRepository 

func (locator RepositoryLocator) GetLogsRepository() LogsRepository

func (RepositoryLocator) GetOrganizationRepository 

func (locator RepositoryLocator) GetOrganizationRepository() OrganizationRepository

func (RepositoryLocator) GetPasswordRepository 

func (locator RepositoryLocator) GetPasswordRepository() 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) 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() 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

type RouteRepository 

type RouteRepository interface {
	ListRoutes(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)
	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 ServiceBindingRepository 

type ServiceBindingRepository interface {
	Create(instanceGuid, appGuid string) (apiErr error)
	Delete(instance models.ServiceInstance, appGuid string) (found bool, 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
	ServicePlan ServicePlanSummary `json:"service_plan"`
}

type ServiceInstanceSummaryApp 

type ServiceInstanceSummaryApp struct {
	Name         string
	ServiceNames []string `json:"service_names"`
}

type ServiceInstancesSummaries 

type ServiceInstancesSummaries struct {
	Apps             []ServiceInstanceSummaryApp
	ServiceInstances []ServiceInstanceSummary `json:"services"`
}

func (ServiceInstancesSummaries) ToModels 

func (resource ServiceInstancesSummaries) ToModels() (instances []models.ServiceInstance)

type ServiceOfferingSummary 

type ServiceOfferingSummary struct {
	Label    string
	Provider string
	Version  string
}

type ServicePlanRepository 

type ServicePlanRepository interface {
	Search(searchParameters map[string]string) ([]models.ServicePlanFields, error)
	Update(models.ServicePlanFields, string, bool) error
}

type ServicePlanSummary 

type ServicePlanSummary struct {
	Name            string
	Guid            string
	ServiceOffering ServiceOfferingSummary `json:"service"`
}

type ServicePlanVisibilityRepository 

type ServicePlanVisibilityRepository interface {
	Create(string, string) error
	List() ([]models.ServicePlanVisibilityFields, error)
	Delete(string) error
	Search(map[string]string) ([]models.ServicePlanVisibilityFields, error)
}

type ServiceRepository 

type ServiceRepository interface {
	PurgeServiceOffering(offering models.ServiceOffering) error
	GetServiceOfferingByGuid(serviceGuid string) (offering models.ServiceOffering, apiErr error)
	FindServiceOfferingByLabel(name string) (offering models.ServiceOffering, 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) (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)
	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() *logmessage.LogMessage

func (*SortedMessageQueue) PushMessage 

func (pq *SortedMessageQueue) PushMessage(message *logmessage.LogMessage)

func (*SortedMessageQueue) Swap 

func (pq *SortedMessageQueue) Swap(i, j int)

type StackRepository 

type StackRepository interface {
	FindByName(name string) (stack models.Stack, apiErr error)
	FindAll() (stacks []models.Stack, apiErr error)
}

type StatsApiResponse 

type StatsApiResponse map[string]InstanceStatsApiResponse

type UserProvidedServiceInstanceRepository 

type UserProvidedServiceInstanceRepository interface {
	Create(name, drainUrl string, params map[string]interface{}) (apiErr error)
	Update(serviceInstanceFields models.ServiceInstanceFields) (apiErr error)
}

type UserRepository 

type UserRepository interface {
	FindByUsername(username string) (user models.UserFields, apiErr error)
	ListUsersInOrgForRole(orgGuid string, role string) ([]models.UserFields, error)
	ListUsersInSpaceForRole(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

View all Source files

Directories

Path Synopsis
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
defaults
defaults/running
defaults/running/fakes
This file was generated by counterfeiter
 This file was generated by counterfeiter
defaults/staging
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
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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.