api

package
Version: v0.0.0-...-af9d2bc Latest Latest
Warning

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

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

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

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 {
	RefreshAuthToken() (updatedToken string, apiErr error)
	Authenticate(credentials map[string]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 NewCloudControllerAppEventsRepository

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

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, fileSizePrinter 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) 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 CloudControllerQuotaRepository

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

func NewCloudControllerQuotaRepository

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

func (CloudControllerQuotaRepository) AssignQuotaToOrg

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

func (CloudControllerQuotaRepository) Create

func (CloudControllerQuotaRepository) Delete

func (repo CloudControllerQuotaRepository) Delete(quotaGuid string) (apiErr error)

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

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 (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)
	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 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, 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, onConnect func(), onMessage func(*logmessage.LogMessage)) error
	Close()
}

func NewLoggregatorLogsRepository

func NewLoggregatorLogsRepository(config configuration.Reader, consumer consumer.LoggregatorConsumer, refresher 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 QuotaRepository

type QuotaRepository interface {
	FindAll() (quotas []models.QuotaFields, apiErr error)
	FindByName(name string) (quota models.QuotaFields, apiErr error)

	AssignQuotaToOrg(orgGuid, quotaGuid string) error

	// CRUD ahoy
	Create(quota models.QuotaFields) error
	Update(quota models.QuotaFields) error
	Delete(quotaGuid 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() 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 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)
	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 TokenRefresher

type TokenRefresher interface {
	RefreshAuthToken() (updatedToken string, apiErr error)
}

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