api

package
v6.12.2+incompatible Latest Latest
Warning

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

Go to latest
Published: Jul 15, 2015 License: Apache-2.0 Imports: 58 Imported by: 0

Documentation

Index

Constants

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

Variables

View Source
var BufferTime time.Duration = 5 * time.Second

Functions

This section is empty.

Types

type AppSummaryRepository

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

type ApplicationFromSummary

type ApplicationFromSummary struct {
	Guid               string
	Name               string
	Routes             []RouteSummary
	Services           []ServicePlanSummary
	Diego              bool `json:"diego,omitempty"`
	RunningInstances   int  `json:"running_instances"`
	Memory             int64
	Instances          int
	DiskQuota          int64 `json:"disk_quota"`
	Urls               []string
	EnvironmentVars    map[string]interface{} `json:"environment_json,omitempty"`
	HealthCheckTimeout int                    `json:"health_check_timeout"`
	State              string
	SpaceGuid          string     `json:"space_guid"`
	PackageUpdatedAt   *time.Time `json:"package_updated_at"`
	Buildpack          string
}

func (ApplicationFromSummary) ToFields

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

func (ApplicationFromSummary) ToModel

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

type ApplicationSummaries

type ApplicationSummaries struct {
	Apps []ApplicationFromSummary
}

func (ApplicationSummaries) ToModels

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

type BuildpackBitsRepository

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

func (CCUserProvidedServiceInstanceRepository) Create

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

func (CCUserProvidedServiceInstanceRepository) GetSummaries

func (CCUserProvidedServiceInstanceRepository) Update

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

type CloudControllerAppSummaryRepository

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

func NewCloudControllerAppSummaryRepository

func NewCloudControllerAppSummaryRepository(config core_config.Reader, gateway net.Gateway) (repo CloudControllerAppSummaryRepository)

func (CloudControllerAppSummaryRepository) GetSummariesInCurrentSpace

func (repo CloudControllerAppSummaryRepository) GetSummariesInCurrentSpace() (apps []models.Application, apiErr error)

func (CloudControllerAppSummaryRepository) GetSummary

func (repo CloudControllerAppSummaryRepository) GetSummary(appGuid string) (summary models.Application, apiErr error)

type CloudControllerBuildpackBitsRepository

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

func NewCloudControllerBuildpackBitsRepository

func NewCloudControllerBuildpackBitsRepository(config core_config.Reader, gateway net.Gateway, zipper app_files.Zipper) (repo CloudControllerBuildpackBitsRepository)

func (CloudControllerBuildpackBitsRepository) UploadBuildpack

func (repo CloudControllerBuildpackBitsRepository) UploadBuildpack(buildpack models.Buildpack, buildpackLocation string) (apiErr error)

type CloudControllerBuildpackRepository

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

func NewCloudControllerBuildpackRepository

func NewCloudControllerBuildpackRepository(config core_config.Reader, gateway net.Gateway) (repo CloudControllerBuildpackRepository)

func (CloudControllerBuildpackRepository) 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 core_config.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 core_config.Reader, gateway net.Gateway, strategy strategy.EndpointStrategy) CloudControllerDomainRepository

func (CloudControllerDomainRepository) Create

func (repo CloudControllerDomainRepository) Create(domainName string, owningOrgGuid string) (createdDomain models.DomainFields, err error)

func (CloudControllerDomainRepository) CreateSharedDomain

func (repo CloudControllerDomainRepository) CreateSharedDomain(domainName string) (apiErr error)

func (CloudControllerDomainRepository) Delete

func (repo CloudControllerDomainRepository) Delete(domainGuid string) error

func (CloudControllerDomainRepository) DeleteSharedDomain

func (repo CloudControllerDomainRepository) DeleteSharedDomain(domainGuid string) error

func (CloudControllerDomainRepository) FindByNameInOrg

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

func (CloudControllerDomainRepository) FindPrivateByName

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

func (CloudControllerDomainRepository) FindSharedByName

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

func (CloudControllerDomainRepository) FirstOrDefault

func (repo CloudControllerDomainRepository) FirstOrDefault(orgGuid string, name *string) (domain models.DomainFields, error error)

func (CloudControllerDomainRepository) ListDomainsForOrg

func (repo CloudControllerDomainRepository) ListDomainsForOrg(orgGuid string, cb func(models.DomainFields) bool) error

type CloudControllerRouteRepository

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

func NewCloudControllerRouteRepository

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

func (CloudControllerRouteRepository) Bind

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

func (CloudControllerRouteRepository) CheckIfExists

func (repo CloudControllerRouteRepository) CheckIfExists(host string, domain models.DomainFields) (found bool, apiErr error)

func (CloudControllerRouteRepository) Create

func (repo CloudControllerRouteRepository) Create(host string, domain models.DomainFields) (createdRoute models.Route, apiErr error)

func (CloudControllerRouteRepository) CreateInSpace

func (repo CloudControllerRouteRepository) CreateInSpace(host, domainGuid, spaceGuid string) (createdRoute models.Route, apiErr error)

func (CloudControllerRouteRepository) Delete

func (repo CloudControllerRouteRepository) Delete(routeGuid string) (apiErr error)

func (CloudControllerRouteRepository) FindByHostAndDomain

func (repo CloudControllerRouteRepository) FindByHostAndDomain(host string, domain models.DomainFields) (route models.Route, apiErr error)

func (CloudControllerRouteRepository) ListAllRoutes

func (repo CloudControllerRouteRepository) ListAllRoutes(cb func(models.Route) bool) (apiErr error)

func (CloudControllerRouteRepository) ListRoutes

func (repo CloudControllerRouteRepository) ListRoutes(cb func(models.Route) bool) (apiErr error)

func (CloudControllerRouteRepository) Unbind

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

type CloudControllerServiceAuthTokenRepository

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

func NewCloudControllerServiceAuthTokenRepository

func NewCloudControllerServiceAuthTokenRepository(config core_config.Reader, gateway net.Gateway) (repo CloudControllerServiceAuthTokenRepository)

func (CloudControllerServiceAuthTokenRepository) Create

func (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 core_config.Reader, gateway net.Gateway) (repo CloudControllerServiceBindingRepository)

func (CloudControllerServiceBindingRepository) Create

func (repo CloudControllerServiceBindingRepository) Create(instanceGuid, appGuid string, paramsMap map[string]interface{}) (apiErr error)

func (CloudControllerServiceBindingRepository) Delete

func (repo CloudControllerServiceBindingRepository) Delete(instance models.ServiceInstance, appGuid string) (found bool, apiErr error)

type CloudControllerServiceBrokerRepository

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

func NewCloudControllerServiceBrokerRepository

func NewCloudControllerServiceBrokerRepository(config core_config.Reader, gateway net.Gateway) (repo CloudControllerServiceBrokerRepository)

func (CloudControllerServiceBrokerRepository) Create

func (repo CloudControllerServiceBrokerRepository) Create(name, url, username, password string) (apiErr error)

func (CloudControllerServiceBrokerRepository) Delete

func (repo CloudControllerServiceBrokerRepository) Delete(guid string) (apiErr error)

func (CloudControllerServiceBrokerRepository) FindByGuid

func (repo CloudControllerServiceBrokerRepository) FindByGuid(guid string) (serviceBroker models.ServiceBroker, apiErr error)

func (CloudControllerServiceBrokerRepository) FindByName

func (repo CloudControllerServiceBrokerRepository) FindByName(name string) (serviceBroker models.ServiceBroker, apiErr error)

func (CloudControllerServiceBrokerRepository) ListServiceBrokers

func (repo CloudControllerServiceBrokerRepository) ListServiceBrokers(callback func(models.ServiceBroker) bool) error

func (CloudControllerServiceBrokerRepository) Rename

func (repo CloudControllerServiceBrokerRepository) Rename(guid, name string) (apiErr error)

func (CloudControllerServiceBrokerRepository) Update

func (repo CloudControllerServiceBrokerRepository) Update(serviceBroker models.ServiceBroker) (apiErr error)

type CloudControllerServiceKeyRepository

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

func NewCloudControllerServiceKeyRepository

func NewCloudControllerServiceKeyRepository(config core_config.Reader, gateway net.Gateway) (repo CloudControllerServiceKeyRepository)

func (CloudControllerServiceKeyRepository) CreateServiceKey

func (c CloudControllerServiceKeyRepository) CreateServiceKey(instanceGuid string, keyName string, params map[string]interface{}) error

func (CloudControllerServiceKeyRepository) DeleteServiceKey

func (c CloudControllerServiceKeyRepository) DeleteServiceKey(serviceKeyGuid string) error

func (CloudControllerServiceKeyRepository) GetServiceKey

func (c CloudControllerServiceKeyRepository) GetServiceKey(instanceGuid string, keyName string) (models.ServiceKey, error)

func (CloudControllerServiceKeyRepository) ListServiceKeys

func (c CloudControllerServiceKeyRepository) ListServiceKeys(instanceGuid string) ([]models.ServiceKey, error)

type CloudControllerServicePlanRepository

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

func NewCloudControllerServicePlanRepository

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

func (CloudControllerServicePlanRepository) ListPlansFromManyServices

func (repo CloudControllerServicePlanRepository) ListPlansFromManyServices(serviceGuids []string) ([]models.ServicePlanFields, error)

func (CloudControllerServicePlanRepository) Search

func (repo CloudControllerServicePlanRepository) Search(queryParams map[string]string) (plans []models.ServicePlanFields, err error)

func (CloudControllerServicePlanRepository) Update

func (repo CloudControllerServicePlanRepository) Update(servicePlan models.ServicePlanFields, serviceGuid string, public bool) error

type CloudControllerServicePlanVisibilityRepository

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

func NewCloudControllerServicePlanVisibilityRepository

func NewCloudControllerServicePlanVisibilityRepository(config core_config.Reader, gateway net.Gateway) CloudControllerServicePlanVisibilityRepository

func (CloudControllerServicePlanVisibilityRepository) Create

func (repo CloudControllerServicePlanVisibilityRepository) Create(serviceGuid, orgGuid string) error

func (CloudControllerServicePlanVisibilityRepository) Delete

func (repo CloudControllerServicePlanVisibilityRepository) Delete(servicePlanGuid string) error

func (CloudControllerServicePlanVisibilityRepository) List

func (CloudControllerServicePlanVisibilityRepository) Search

type CloudControllerServiceRepository

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

func NewCloudControllerServiceRepository

func NewCloudControllerServiceRepository(config core_config.Reader, gateway net.Gateway) (repo CloudControllerServiceRepository)

func (CloudControllerServiceRepository) CreateServiceInstance

func (repo CloudControllerServiceRepository) CreateServiceInstance(name, planGuid string, params map[string]interface{}, tags []string) (err error)

func (CloudControllerServiceRepository) DeleteService

func (repo CloudControllerServiceRepository) DeleteService(instance models.ServiceInstance) (apiErr error)

func (CloudControllerServiceRepository) FindInstanceByName

func (repo CloudControllerServiceRepository) FindInstanceByName(name string) (instance models.ServiceInstance, apiErr error)

func (CloudControllerServiceRepository) FindServiceOfferingByLabelAndProvider

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

func (CloudControllerServiceRepository) FindServiceOfferingsByLabel

func (repo CloudControllerServiceRepository) FindServiceOfferingsByLabel(label string) (models.ServiceOfferings, error)

func (CloudControllerServiceRepository) FindServiceOfferingsForSpaceByLabel

func (repo CloudControllerServiceRepository) FindServiceOfferingsForSpaceByLabel(spaceGuid, name string) (offerings models.ServiceOfferings, err error)

func (CloudControllerServiceRepository) FindServicePlanByDescription

func (repo CloudControllerServiceRepository) FindServicePlanByDescription(planDescription resources.ServicePlanDescription) (string, error)

func (CloudControllerServiceRepository) GetAllServiceOfferings

func (repo CloudControllerServiceRepository) GetAllServiceOfferings() (models.ServiceOfferings, error)

func (CloudControllerServiceRepository) GetServiceInstanceCountForServicePlan

func (repo CloudControllerServiceRepository) GetServiceInstanceCountForServicePlan(v1PlanGuid string) (count int, apiErr error)

func (CloudControllerServiceRepository) GetServiceOfferingByGuid

func (repo CloudControllerServiceRepository) GetServiceOfferingByGuid(serviceGuid string) (models.ServiceOffering, error)

func (CloudControllerServiceRepository) GetServiceOfferingsForSpace

func (repo CloudControllerServiceRepository) GetServiceOfferingsForSpace(spaceGuid string) (models.ServiceOfferings, error)

func (CloudControllerServiceRepository) ListServicesFromBroker

func (repo CloudControllerServiceRepository) ListServicesFromBroker(brokerGuid string) (offerings []models.ServiceOffering, err error)

func (CloudControllerServiceRepository) ListServicesFromManyBrokers

func (repo CloudControllerServiceRepository) ListServicesFromManyBrokers(brokerGuids []string) ([]models.ServiceOffering, error)

func (CloudControllerServiceRepository) MigrateServicePlanFromV1ToV2

func (repo CloudControllerServiceRepository) MigrateServicePlanFromV1ToV2(v1PlanGuid, v2PlanGuid string) (changedCount int, apiErr error)

func (CloudControllerServiceRepository) PurgeServiceOffering

func (repo CloudControllerServiceRepository) PurgeServiceOffering(offering models.ServiceOffering) error

func (CloudControllerServiceRepository) RenameService

func (repo CloudControllerServiceRepository) RenameService(instance models.ServiceInstance, newName string) (apiErr error)

func (CloudControllerServiceRepository) UpdateServiceInstance

func (repo CloudControllerServiceRepository) UpdateServiceInstance(instanceGuid, planGuid string, params map[string]interface{}, tags []string) (err error)

type CloudControllerServiceSummaryRepository

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

func NewCloudControllerServiceSummaryRepository

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

func (CloudControllerServiceSummaryRepository) GetSummariesInCurrentSpace

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

type CloudControllerUserRepository

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

func NewCloudControllerUserRepository

func NewCloudControllerUserRepository(config core_config.Reader, uaaGateway net.Gateway, ccGateway net.Gateway) (repo CloudControllerUserRepository)

func (CloudControllerUserRepository) Create

func (repo CloudControllerUserRepository) Create(username, password string) (err error)

func (CloudControllerUserRepository) Delete

func (repo CloudControllerUserRepository) Delete(userGuid string) (apiErr error)

func (CloudControllerUserRepository) FindByUsername

func (repo CloudControllerUserRepository) FindByUsername(username string) (models.UserFields, error)

func (CloudControllerUserRepository) ListUsersInOrgForRole

func (repo CloudControllerUserRepository) ListUsersInOrgForRole(orgGuid string, roleName string) (users []models.UserFields, apiErr error)

func (CloudControllerUserRepository) ListUsersInOrgForRoleWithNoUAA

func (repo CloudControllerUserRepository) ListUsersInOrgForRoleWithNoUAA(orgGuid string, roleName string) (users []models.UserFields, apiErr error)

func (CloudControllerUserRepository) ListUsersInSpaceForRole

func (repo CloudControllerUserRepository) ListUsersInSpaceForRole(spaceGuid string, roleName string) (users []models.UserFields, apiErr error)

func (CloudControllerUserRepository) ListUsersInSpaceForRoleWithNoUAA

func (repo CloudControllerUserRepository) ListUsersInSpaceForRoleWithNoUAA(spaceGuid string, roleName string) (users []models.UserFields, apiErr error)

func (CloudControllerUserRepository) SetOrgRole

func (repo CloudControllerUserRepository) SetOrgRole(userGuid string, orgGuid string, role string) (apiErr error)

func (CloudControllerUserRepository) SetSpaceRole

func (repo CloudControllerUserRepository) SetSpaceRole(userGuid, spaceGuid, orgGuid, role string) (apiErr error)

func (CloudControllerUserRepository) UnsetOrgRole

func (repo CloudControllerUserRepository) UnsetOrgRole(userGuid, orgGuid, role string) (apiErr error)

func (CloudControllerUserRepository) UnsetSpaceRole

func (repo CloudControllerUserRepository) UnsetSpaceRole(userGuid, spaceGuid, role string) (apiErr error)

type CurlRepository

type 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
	FindSharedByName(name string) (domain models.DomainFields, apiErr error)
	FindPrivateByName(name string) (domain models.DomainFields, apiErr error)
	FindByNameInOrg(name string, owningOrgGuid string) (domain models.DomainFields, apiErr error)
	Create(domainName string, owningOrgGuid string) (createdDomain models.DomainFields, apiErr error)
	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)
}

func NewEndpointRepository

func NewEndpointRepository(config core_config.ReadWriter, gateway net.Gateway) EndpointRepository

type LastOperationSummary

type LastOperationSummary struct {
	Type        string `json:"type"`
	State       string `json:"state"`
	Description string `json:"description"`
}

type LoggregatorLogsRepository

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

func (*LoggregatorLogsRepository) Close

func (repo *LoggregatorLogsRepository) Close()

func (*LoggregatorLogsRepository) RecentLogsFor

func (repo *LoggregatorLogsRepository) RecentLogsFor(appGuid string) ([]*logmessage.LogMessage, error)

func (*LoggregatorLogsRepository) TailLogsFor

func (repo *LoggregatorLogsRepository) TailLogsFor(appGuid string, onConnect func(), onMessage func(*logmessage.LogMessage)) error

type Loggregator_SortedMessageQueue

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

func NewLoggregator_SortedMessageQueue

func NewLoggregator_SortedMessageQueue(printTimeBuffer time.Duration, clock func() time.Time) *Loggregator_SortedMessageQueue

func (*Loggregator_SortedMessageQueue) Len

func (*Loggregator_SortedMessageQueue) Less

func (pq *Loggregator_SortedMessageQueue) Less(i, j int) bool

implement sort interface so we can sort messages as we receive them in PushMessage

func (*Loggregator_SortedMessageQueue) NextTimestamp

func (pq *Loggregator_SortedMessageQueue) NextTimestamp() int64

func (*Loggregator_SortedMessageQueue) PopMessage

func (*Loggregator_SortedMessageQueue) PushMessage

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

func (*Loggregator_SortedMessageQueue) Swap

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

type LogsNoaaRepository

type LogsNoaaRepository interface {
	GetContainerMetrics(string, []models.AppInstanceFields) ([]models.AppInstanceFields, error)
	RecentLogsFor(appGuid string) ([]*events.LogMessage, error)
	TailNoaaLogsFor(appGuid string, onConnect func(), onMessage func(*events.LogMessage)) error
	Close()
}

type NoaaConsumer

type NoaaConsumer interface {
	GetContainerMetrics(string, string) ([]*events.ContainerMetric, error)
	RecentLogs(string, string) ([]*events.LogMessage, error)
	TailingLogs(string, string, chan<- *events.LogMessage, chan<- error)
	SetOnConnectCallback(func())
	Close() error
}

func NewNoaaConsumer

func NewNoaaConsumer(consumer *noaa.Consumer) NoaaConsumer

type OldLogsRepository

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

type RemoteEndpointRepository

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

func (RemoteEndpointRepository) UpdateEndpoint

func (repo RemoteEndpointRepository) UpdateEndpoint(endpoint string) (finalEndpoint string, apiErr error)

type RepositoryLocator

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

func NewRepositoryLocator

func NewRepositoryLocator(config core_config.ReadWriter, gatewaysByName map[string]net.Gateway) (loc RepositoryLocator)

func (RepositoryLocator) GetAppEventsRepository

func (locator RepositoryLocator) GetAppEventsRepository() app_events.AppEventsRepository

func (RepositoryLocator) GetAppFilesRepository

func (locator RepositoryLocator) GetAppFilesRepository() api_app_files.AppFilesRepository

func (RepositoryLocator) GetAppInstancesRepository

func (locator RepositoryLocator) GetAppInstancesRepository() app_instances.AppInstancesRepository

func (RepositoryLocator) GetAppSummaryRepository

func (locator RepositoryLocator) GetAppSummaryRepository() AppSummaryRepository

func (RepositoryLocator) GetApplicationBitsRepository

func (locator RepositoryLocator) GetApplicationBitsRepository() application_bits.ApplicationBitsRepository

func (RepositoryLocator) GetApplicationRepository

func (locator RepositoryLocator) GetApplicationRepository() applications.ApplicationRepository

func (RepositoryLocator) GetAuthenticationRepository

func (locator RepositoryLocator) GetAuthenticationRepository() authentication.AuthenticationRepository

func (RepositoryLocator) GetBuildpackBitsRepository

func (locator RepositoryLocator) GetBuildpackBitsRepository() BuildpackBitsRepository

func (RepositoryLocator) GetBuildpackRepository

func (locator RepositoryLocator) GetBuildpackRepository() BuildpackRepository

func (RepositoryLocator) GetCopyApplicationSourceRepository

func (locator RepositoryLocator) GetCopyApplicationSourceRepository() copy_application_source.CopyApplicationSourceRepository

func (RepositoryLocator) GetCurlRepository

func (locator RepositoryLocator) GetCurlRepository() CurlRepository

func (RepositoryLocator) GetDomainRepository

func (locator RepositoryLocator) GetDomainRepository() DomainRepository

func (RepositoryLocator) GetEndpointRepository

func (locator RepositoryLocator) GetEndpointRepository() EndpointRepository

func (RepositoryLocator) GetEnvironmentVariableGroupsRepository

func (locator RepositoryLocator) GetEnvironmentVariableGroupsRepository() environment_variable_groups.EnvironmentVariableGroupsRepository

func (RepositoryLocator) GetFeatureFlagRepository

func (locator RepositoryLocator) GetFeatureFlagRepository() feature_flags.FeatureFlagRepository

func (RepositoryLocator) GetLogsNoaaRepository

func (locator RepositoryLocator) GetLogsNoaaRepository() LogsNoaaRepository

func (RepositoryLocator) GetOldLogsRepository

func (locator RepositoryLocator) GetOldLogsRepository() OldLogsRepository

func (RepositoryLocator) GetOrganizationRepository

func (locator RepositoryLocator) GetOrganizationRepository() organizations.OrganizationRepository

func (RepositoryLocator) GetPasswordRepository

func (locator RepositoryLocator) GetPasswordRepository() password.PasswordRepository

func (RepositoryLocator) GetQuotaRepository

func (locator RepositoryLocator) GetQuotaRepository() quotas.QuotaRepository

func (RepositoryLocator) GetRouteRepository

func (locator RepositoryLocator) GetRouteRepository() RouteRepository

func (RepositoryLocator) GetRunningSecurityGroupsRepository

func (locator RepositoryLocator) GetRunningSecurityGroupsRepository() running.RunningSecurityGroupsRepo

func (RepositoryLocator) GetSecurityGroupRepository

func (locator RepositoryLocator) GetSecurityGroupRepository() security_groups.SecurityGroupRepo

func (RepositoryLocator) GetSecurityGroupSpaceBinder

func (locator RepositoryLocator) GetSecurityGroupSpaceBinder() securitygroupspaces.SecurityGroupSpaceBinder

func (RepositoryLocator) GetServiceAuthTokenRepository

func (locator RepositoryLocator) GetServiceAuthTokenRepository() ServiceAuthTokenRepository

func (RepositoryLocator) GetServiceBindingRepository

func (locator RepositoryLocator) GetServiceBindingRepository() ServiceBindingRepository

func (RepositoryLocator) GetServiceBrokerRepository

func (locator RepositoryLocator) GetServiceBrokerRepository() ServiceBrokerRepository

func (RepositoryLocator) GetServiceKeyRepository

func (locator RepositoryLocator) GetServiceKeyRepository() ServiceKeyRepository

func (RepositoryLocator) GetServicePlanRepository

func (locator RepositoryLocator) GetServicePlanRepository() ServicePlanRepository

func (RepositoryLocator) GetServicePlanVisibilityRepository

func (locator RepositoryLocator) GetServicePlanVisibilityRepository() ServicePlanVisibilityRepository

func (RepositoryLocator) GetServiceRepository

func (locator RepositoryLocator) GetServiceRepository() ServiceRepository

func (RepositoryLocator) GetServiceSummaryRepository

func (locator RepositoryLocator) GetServiceSummaryRepository() ServiceSummaryRepository

func (RepositoryLocator) GetSpaceQuotaRepository

func (locator RepositoryLocator) GetSpaceQuotaRepository() space_quotas.SpaceQuotaRepository

func (RepositoryLocator) GetSpaceRepository

func (locator RepositoryLocator) GetSpaceRepository() spaces.SpaceRepository

func (RepositoryLocator) GetStackRepository

func (locator RepositoryLocator) GetStackRepository() stacks.StackRepository

func (RepositoryLocator) GetStagingSecurityGroupsRepository

func (locator RepositoryLocator) GetStagingSecurityGroupsRepository() staging.StagingSecurityGroupsRepo

func (RepositoryLocator) GetUserProvidedServiceInstanceRepository

func (locator RepositoryLocator) GetUserProvidedServiceInstanceRepository() UserProvidedServiceInstanceRepository

func (RepositoryLocator) GetUserRepository

func (locator RepositoryLocator) GetUserRepository() UserRepository

func (RepositoryLocator) SetAppEventsRepository

func (locator RepositoryLocator) SetAppEventsRepository(repo app_events.AppEventsRepository) RepositoryLocator

func (RepositoryLocator) SetAppFileRepository

func (locator RepositoryLocator) SetAppFileRepository(repo api_app_files.AppFilesRepository) RepositoryLocator

func (RepositoryLocator) SetAppInstancesRepository

func (locator RepositoryLocator) SetAppInstancesRepository(repo app_instances.AppInstancesRepository) RepositoryLocator

func (RepositoryLocator) SetAppSummaryRepository

func (locator RepositoryLocator) SetAppSummaryRepository(repo AppSummaryRepository) RepositoryLocator

func (RepositoryLocator) SetApplicationRepository

func (locator RepositoryLocator) SetApplicationRepository(repo applications.ApplicationRepository) RepositoryLocator

func (RepositoryLocator) SetAuthenticationRepository

func (locator RepositoryLocator) SetAuthenticationRepository(repo authentication.AuthenticationRepository) RepositoryLocator

func (RepositoryLocator) SetEndpointRepository

func (locator RepositoryLocator) SetEndpointRepository(e EndpointRepository) RepositoryLocator

func (RepositoryLocator) SetLogsNoaaRepository

func (locator RepositoryLocator) SetLogsNoaaRepository(repo LogsNoaaRepository) RepositoryLocator

func (RepositoryLocator) SetOldLogsRepository

func (locator RepositoryLocator) SetOldLogsRepository(repo OldLogsRepository) RepositoryLocator

func (RepositoryLocator) SetOrganizationRepository

func (locator RepositoryLocator) SetOrganizationRepository(repo organizations.OrganizationRepository) RepositoryLocator

func (RepositoryLocator) SetPasswordRepository

func (locator RepositoryLocator) SetPasswordRepository(repo password.PasswordRepository) RepositoryLocator

func (RepositoryLocator) SetRouteRepository

func (locator RepositoryLocator) SetRouteRepository(repo RouteRepository) RepositoryLocator

func (RepositoryLocator) SetServiceRepository

func (locator RepositoryLocator) SetServiceRepository(repo ServiceRepository) RepositoryLocator

func (RepositoryLocator) SetServiceSummaryRepository

func (locator RepositoryLocator) SetServiceSummaryRepository(repo ServiceSummaryRepository) RepositoryLocator

func (RepositoryLocator) SetSpaceQuotaRepository

func (locator RepositoryLocator) SetSpaceQuotaRepository(repo space_quotas.SpaceQuotaRepository) RepositoryLocator

func (RepositoryLocator) SetSpaceRepository

func (locator RepositoryLocator) SetSpaceRepository(repo spaces.SpaceRepository) RepositoryLocator

func (RepositoryLocator) SetStackRepository

func (locator RepositoryLocator) SetStackRepository(repo stacks.StackRepository) RepositoryLocator

func (RepositoryLocator) SetUserRepository

func (locator RepositoryLocator) SetUserRepository(repo UserRepository) RepositoryLocator

type RouteRepository

type RouteRepository interface {
	ListRoutes(cb func(models.Route) bool) (apiErr error)
	ListAllRoutes(cb func(models.Route) bool) (apiErr error)
	FindByHostAndDomain(host string, domain models.DomainFields) (route models.Route, apiErr error)
	Create(host string, domain models.DomainFields) (createdRoute models.Route, apiErr error)
	CheckIfExists(host string, domain models.DomainFields) (found bool, apiErr error)
	CreateInSpace(host, domainGuid, spaceGuid string) (createdRoute models.Route, apiErr error)
	Bind(routeGuid, appGuid string) (apiErr error)
	Unbind(routeGuid, appGuid string) (apiErr error)
	Delete(routeGuid string) (apiErr error)
}

type RouteSummary

type RouteSummary struct {
	Guid   string
	Host   string
	Domain DomainSummary
}

func (RouteSummary) ToModel

func (resource RouteSummary) ToModel() (route models.RouteSummary)

type ServiceAuthTokenRepository

type ServiceAuthTokenRepository interface {
	FindAll() (authTokens []models.ServiceAuthTokenFields, apiErr error)
	FindByLabelAndProvider(label, provider string) (authToken models.ServiceAuthTokenFields, apiErr error)
	Create(authToken models.ServiceAuthTokenFields) (apiErr error)
	Update(authToken models.ServiceAuthTokenFields) (apiErr error)
	Delete(authToken models.ServiceAuthTokenFields) (apiErr error)
}

type ServiceBindingRepository

type ServiceBindingRepository interface {
	Create(instanceGuid, appGuid string, paramsMap map[string]interface{}) (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
	LastOperation LastOperationSummary `json:"last_operation"`
	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 ServiceKeyRepository

type ServiceKeyRepository interface {
	CreateServiceKey(serviceKeyGuid string, keyName string, params map[string]interface{}) error
	ListServiceKeys(serviceKeyGuid string) ([]models.ServiceKey, error)
	GetServiceKey(serviceKeyGuid string, keyName string) (models.ServiceKey, error)
	DeleteServiceKey(serviceKeyGuid string) error
}

type ServiceOfferingSummary

type 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
	ListPlansFromManyServices(serviceGuids []string) ([]models.ServicePlanFields, error)
}

type ServicePlanSummary

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

func (ServicePlanSummary) ToModel

func (resource ServicePlanSummary) ToModel() (route models.ServicePlanSummary)

type 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)
	FindServiceOfferingsByLabel(name string) (offering models.ServiceOfferings, apiErr error)
	FindServiceOfferingByLabelAndProvider(name, provider string) (offering models.ServiceOffering, apiErr error)

	FindServiceOfferingsForSpaceByLabel(spaceGuid, name string) (offering models.ServiceOfferings, apiErr error)

	GetAllServiceOfferings() (offerings models.ServiceOfferings, apiErr error)
	GetServiceOfferingsForSpace(spaceGuid string) (offerings models.ServiceOfferings, apiErr error)
	FindInstanceByName(name string) (instance models.ServiceInstance, apiErr error)
	CreateServiceInstance(name, planGuid string, params map[string]interface{}, tags []string) (apiErr error)
	UpdateServiceInstance(instanceGuid, planGuid string, params map[string]interface{}, tags []string) (apiErr error)
	RenameService(instance models.ServiceInstance, newName string) (apiErr error)
	DeleteService(instance models.ServiceInstance) (apiErr error)
	FindServicePlanByDescription(planDescription resources.ServicePlanDescription) (planGuid string, apiErr error)
	ListServicesFromBroker(brokerGuid string) (services []models.ServiceOffering, err error)
	ListServicesFromManyBrokers(brokerGuids []string) (services []models.ServiceOffering, err error)
	GetServiceInstanceCountForServicePlan(v1PlanGuid string) (count int, apiErr error)
	MigrateServicePlanFromV1ToV2(v1PlanGuid, v2PlanGuid string) (changedCount int, apiErr error)
}

type ServiceSummaryRepository

type ServiceSummaryRepository interface {
	GetSummariesInCurrentSpace() (instances []models.ServiceInstance, apiErr error)
}

type SortedMessageQueue

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

func NewSortedMessageQueue

func NewSortedMessageQueue(printTimeBuffer time.Duration, clock func() time.Time) *SortedMessageQueue

func (*SortedMessageQueue) Len

func (pq *SortedMessageQueue) Len() int

func (*SortedMessageQueue) Less

func (pq *SortedMessageQueue) Less(i, j int) bool

implement sort interface so we can sort messages as we receive them in PushMessage

func (*SortedMessageQueue) NextTimestamp

func (pq *SortedMessageQueue) NextTimestamp() int64

func (*SortedMessageQueue) PopMessage

func (pq *SortedMessageQueue) PopMessage() *events.LogMessage

func (*SortedMessageQueue) PushMessage

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

func (*SortedMessageQueue) Swap

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

type UserProvidedServiceInstanceRepository

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

type UserRepository

type UserRepository interface {
	FindByUsername(username string) (user models.UserFields, apiErr error)
	ListUsersInOrgForRole(orgGuid string, role string) ([]models.UserFields, error)
	ListUsersInOrgForRoleWithNoUAA(orgGuid string, role string) ([]models.UserFields, error)
	ListUsersInSpaceForRole(spaceGuid string, role string) ([]models.UserFields, error)
	ListUsersInSpaceForRoleWithNoUAA(spaceGuid string, role string) ([]models.UserFields, error)
	Create(username, password string) (apiErr error)
	Delete(userGuid string) (apiErr error)
	SetOrgRole(userGuid, orgGuid, role string) (apiErr error)
	UnsetOrgRole(userGuid, orgGuid, role string) (apiErr error)
	SetSpaceRole(userGuid, spaceGuid, orgGuid, role string) (apiErr error)
	UnsetSpaceRole(userGuid, spaceGuid, role string) (apiErr error)
}

Directories

Path Synopsis
fakes
This file was generated by counterfeiter
This file was generated by counterfeiter
fakes
This file was generated by counterfeiter
This file was generated by counterfeiter
fakes
This file was generated by counterfeiter
This file was generated by counterfeiter
fakes
This file was generated by counterfeiter
This file was generated by counterfeiter
fakes
This file was generated by counterfeiter
This file was generated by counterfeiter
fakes
This file was generated by counterfeiter
This file was generated by counterfeiter
This file was generated by counterfeiter
This file was generated by counterfeiter
fakes
This file was generated by counterfeiter
This file was generated by counterfeiter
fakes
This file was generated by counterfeiter
This file was generated by counterfeiter
fakes
This file was generated by counterfeiter
This file was generated by counterfeiter
defaults/running/fakes
This file was generated by counterfeiter
This file was generated by counterfeiter
defaults/staging/fakes
This file was generated by counterfeiter
This file was generated by counterfeiter
fakes
This file was generated by counterfeiter
This file was generated by counterfeiter
spaces/fakes
This file was generated by counterfeiter
This file was generated by counterfeiter
fakes
This file was generated by counterfeiter
This file was generated by counterfeiter
fakes
This file was generated by counterfeiter
This file was generated by counterfeiter

Jump to

Keyboard shortcuts

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