api

package
v6.1.0+incompatible Latest Latest
Warning

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

Go to latest
Published: Apr 10, 2014 License: Apache-2.0 Imports: 35 Imported by: 0

Documentation ¶

Index ¶

Constants ¶

View Source
const MAX_INT64 int64 = 1<<63 - 1

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type AppEventsRepository ¶

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

type AppFilesRepository ¶

type AppFilesRepository interface {
	ListFiles(appGuid, 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 uint64)) (apiErr error)
}

type ApplicationFromSummary ¶

type ApplicationFromSummary struct {
	Guid             string
	Name             string
	Routes           []RouteSummary
	RunningInstances int `json:"running_instances"`
	Memory           uint64
	Instances        int
	DiskQuota        uint64 `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)
}

type ApplicationSummaries ¶

type ApplicationSummaries struct {
	Apps []ApplicationFromSummary
}

func (ApplicationSummaries) ToModels ¶

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

type AuthenticationRepository ¶

type AuthenticationRepository interface {
	Authenticate(credentials map[string]string) (apiErr error)
	RefreshAuthToken() (updatedToken string, apiErr error)
	GetLoginPromptsAndSaveUAAServerURL() (map[string]configuration.AuthPrompt, error)
}

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]string) (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 (CloudControllerAppEventsRepository) RecentEvents ¶

func (repo CloudControllerAppEventsRepository) RecentEvents(appGuid string, limit uint64) ([]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, 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, cb func(path string, zipSize, fileCount uint64)) (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) 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) 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) 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 CloudControllerQuotaRepository ¶

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

func NewCloudControllerQuotaRepository ¶

func NewCloudControllerQuotaRepository(config configuration.Reader, gateway net.Gateway) (repo CloudControllerQuotaRepository)

func (CloudControllerQuotaRepository) FindAll ¶

func (repo CloudControllerQuotaRepository) FindAll() (quotas []models.QuotaFields, apiErr error)

func (CloudControllerQuotaRepository) FindByName ¶

func (repo CloudControllerQuotaRepository) FindByName(name string) (quota models.QuotaFields, apiErr error)

func (CloudControllerQuotaRepository) Update ¶

func (repo CloudControllerQuotaRepository) Update(orgGuid, quotaGuid string) (apiErr error)

type CloudControllerRouteRepository ¶

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

func NewCloudControllerRouteRepository ¶

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

func (CloudControllerRouteRepository) Bind ¶

func (repo CloudControllerRouteRepository) Bind(routeGuid, appGuid string) (apiErr error)

func (CloudControllerRouteRepository) Create ¶

func (repo CloudControllerRouteRepository) Create(host, domainGuid string) (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, domainName string) (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 (CloudControllerServiceAuthTokenRepository) Delete ¶

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 ¶

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) 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 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) 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) GetServiceOfferingsForSpace ¶

func (repo CloudControllerServiceRepository) GetServiceOfferingsForSpace(spaceGuid string) (models.ServiceOfferings, 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 CloudControllerSpaceRepository ¶

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

func NewCloudControllerSpaceRepository ¶

func NewCloudControllerSpaceRepository(config configuration.Reader, gateway net.Gateway) (repo CloudControllerSpaceRepository)

func (CloudControllerSpaceRepository) Create ¶

func (repo CloudControllerSpaceRepository) Create(name string, orgGuid string) (space models.Space, apiErr error)

func (CloudControllerSpaceRepository) Delete ¶

func (repo CloudControllerSpaceRepository) Delete(spaceGuid string) (apiErr error)

func (CloudControllerSpaceRepository) FindByName ¶

func (repo CloudControllerSpaceRepository) FindByName(name string) (space models.Space, apiErr error)

func (CloudControllerSpaceRepository) FindByNameInOrg ¶

func (repo CloudControllerSpaceRepository) FindByNameInOrg(name, orgGuid string) (space models.Space, apiErr error)

func (CloudControllerSpaceRepository) ListSpaces ¶

func (repo CloudControllerSpaceRepository) ListSpaces(callback func(models.Space) bool) error

func (CloudControllerSpaceRepository) Rename ¶

func (repo CloudControllerSpaceRepository) Rename(spaceGuid, newName string) (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)
}

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 uint64 `json:"disk_quota"`
		MemQuota  uint64 `json:"mem_quota"`
		Usage     struct {
			Cpu  float64
			Disk uint64
			Mem  uint64
		}
	}
}

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, bufferTime time.Duration, onConnect func(), onMessage func(*logmessage.LogMessage)) error

type LoginResource ¶

type LoginResource struct {
	Prompts map[string][]string
	Links   map[string]string
}

type LogsRepository ¶

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

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 QuotaRepository ¶

type QuotaRepository interface {
	FindAll() (quotas []models.QuotaFields, apiErr error)
	FindByName(name string) (quota models.QuotaFields, apiErr error)
	Update(orgGuid, quotaGuid string) (apiErr 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() 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() QuotaRepository

func (RepositoryLocator) GetRouteRepository ¶

func (locator RepositoryLocator) GetRouteRepository() RouteRepository

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) GetServiceRepository ¶

func (locator RepositoryLocator) GetServiceRepository() ServiceRepository

func (RepositoryLocator) GetServiceSummaryRepository ¶

func (locator RepositoryLocator) GetServiceSummaryRepository() ServiceSummaryRepository

func (RepositoryLocator) GetSpaceRepository ¶

func (locator RepositoryLocator) GetSpaceRepository() SpaceRepository

func (RepositoryLocator) GetStackRepository ¶

func (locator RepositoryLocator) GetStackRepository() StackRepository

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, domain string) (route models.Route, apiErr error)
	Create(host, domainGuid string) (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)
	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 ServicePlanSummary ¶

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

type ServiceRepository ¶

type ServiceRepository interface {
	PurgeServiceOffering(offering models.ServiceOffering) 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)
	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

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 SpaceRepository ¶

type SpaceRepository interface {
	ListSpaces(func(models.Space) bool) error
	FindByName(name string) (space models.Space, apiErr error)
	FindByNameInOrg(name, orgGuid string) (space models.Space, apiErr error)
	Create(name string, orgGuid string) (space models.Space, apiErr error)
	Rename(spaceGuid, newName string) (apiErr error)
	Delete(spaceGuid string) (apiErr error)
}

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 UAAAuthenticationRepository ¶

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

func NewUAAAuthenticationRepository ¶

func NewUAAAuthenticationRepository(gateway net.Gateway, config configuration.ReadWriter) (uaa UAAAuthenticationRepository)

func (UAAAuthenticationRepository) Authenticate ¶

func (uaa UAAAuthenticationRepository) Authenticate(credentials map[string]string) (apiErr error)

func (UAAAuthenticationRepository) GetLoginPromptsAndSaveUAAServerURL ¶

func (uaa UAAAuthenticationRepository) GetLoginPromptsAndSaveUAAServerURL() (prompts map[string]configuration.AuthPrompt, apiErr error)

func (UAAAuthenticationRepository) RefreshAuthToken ¶

func (uaa UAAAuthenticationRepository) RefreshAuthToken() (updatedToken string, apiErr error)

type UserProvidedServiceInstanceRepository ¶

type UserProvidedServiceInstanceRepository interface {
	Create(name, drainUrl string, params map[string]string) (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)
}

Directories ¶

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL