api

package
v6.0.1+incompatible Latest Latest
Warning

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

Go to latest
Published: Feb 24, 2014 License: Apache-2.0 Imports: 32 Imported by: 0

Documentation

Index

Constants

View Source
const APP_EVENT_TIMESTAMP_FORMAT = "2006-01-02T15:04:05-07:00"
View Source
const LogBufferSize = 1024
View Source
const MAX_INT64 int64 = 1<<63 - 1

Variables

View Source
var KNOWN_METADATA_KEYS = []string{
	"index",
	"reason",
	"exit_description",
	"exit_status",
	"recursive",
	"disk_quota",
	"instances",
	"memory",
	"state",
	"command",
	"environment_json",
}

Functions

This section is empty.

Types

type AppEventsRepository

type AppEventsRepository interface {
	ListEvents(appGuid string, cb func(models.EventFields) bool) net.ApiResponse
}

type AppFileResource

type AppFileResource struct {
	Path string `json:"fn"`
	Sha1 string `json:"sha1"`
	Size int64  `json:"size"`
}

type AppFilesRepository

type AppFilesRepository interface {
	ListFiles(appGuid, path string) (files string, apiResponse net.ApiResponse)
}

type AppInstancesRepository

type AppInstancesRepository interface {
	GetInstances(appGuid string) (instances []models.AppInstanceFields, apiResponse net.ApiResponse)
}

type AppRouteEntity

type AppRouteEntity struct {
	Host   string
	Domain Resource
}

type AppRouteResource

type AppRouteResource struct {
	Resource
	Entity AppRouteEntity
}

func (AppRouteResource) ToFields

func (resource AppRouteResource) ToFields() (route models.RouteFields)

func (AppRouteResource) ToModel

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

type AppSummaryRepository

type AppSummaryRepository interface {
	GetSummariesInCurrentSpace() (apps []models.AppSummary, apiResponse net.ApiResponse)
	GetSummary(appGuid string) (summary models.AppSummary, apiResponse net.ApiResponse)
}

type ApplicationBitsRepository

type ApplicationBitsRepository interface {
	UploadApp(appGuid, dir string, cb func(path string, zipSize, fileCount uint64)) (apiResponse net.ApiResponse)
}

type ApplicationEntity

type ApplicationEntity struct {
	Name               *string             `json:"name,omitempty"`
	Command            *string             `json:"command,omitempty"`
	State              *string             `json:"state,omitempty"`
	SpaceGuid          *string             `json:"space_guid,omitempty"`
	Instances          *int                `json:"instances,omitempty"`
	Memory             *uint64             `json:"memory,omitempty"`
	StackGuid          *string             `json:"stack_guid,omitempty"`
	Stack              *StackResource      `json:"stack,omitempty"`
	Routes             *[]AppRouteResource `json:"routes,omitempty"`
	Buildpack          *string             `json:"buildpack,omitempty"`
	EnvironmentJson    *map[string]string  `json:"environment_json,omitempty"`
	HealthCheckTimeout *int                `json:"health_check_timeout,omitempty"`
}

func NewApplicationEntityFromAppParams

func NewApplicationEntityFromAppParams(app models.AppParams) ApplicationEntity

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.AppSummary)

type ApplicationRepository

type ApplicationRepository interface {
	Create(params models.AppParams) (createdApp models.Application, apiResponse net.ApiResponse)
	Read(name string) (app models.Application, apiResponse net.ApiResponse)
	Update(appGuid string, params models.AppParams) (updatedApp models.Application, apiResponse net.ApiResponse)
	Delete(appGuid string) (apiResponse net.ApiResponse)
}

type ApplicationResource

type ApplicationResource struct {
	Resource
	Entity ApplicationEntity
}

func (ApplicationResource) ToFields

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

func (ApplicationResource) ToModel

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

type ApplicationSummaries

type ApplicationSummaries struct {
	Apps []ApplicationFromSummary
}

func (ApplicationSummaries) ToModels

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

type AuthTokenEntity

type AuthTokenEntity struct {
	Label    string
	Provider string
}

type AuthTokenResource

type AuthTokenResource struct {
	Resource
	Entity AuthTokenEntity
}

type AuthenticationRepository

type AuthenticationRepository interface {
	Authenticate(credentials map[string]string) (apiResponse net.ApiResponse)
	RefreshAuthToken() (updatedToken string, apiResponse net.ApiResponse)
}

type BuildpackBitsRepository

type BuildpackBitsRepository interface {
	UploadBuildpack(buildpack models.Buildpack, dir string) (apiResponse net.ApiResponse)
}

type BuildpackEntity

type BuildpackEntity struct {
	Name     string `json:"name"`
	Position *int   `json:"position,omitempty"`
	Enabled  *bool  `json:"enabled,omitempty"`
	Key      string `json:"key,omitempty"`
	Filename string `json:"filename,omitempty"`
	Locked   *bool  `json:"locked,omitempty"`
}

type BuildpackRepository

type BuildpackRepository interface {
	FindByName(name string) (buildpack models.Buildpack, apiResponse net.ApiResponse)
	ListBuildpacks(func(models.Buildpack) bool) net.ApiResponse
	Create(name string, position *int, enabled *bool, locked *bool) (createdBuildpack models.Buildpack, apiResponse net.ApiResponse)
	Delete(buildpackGuid string) (apiResponse net.ApiResponse)
	Update(buildpack models.Buildpack) (updatedBuildpack models.Buildpack, apiResponse net.ApiResponse)
}

type BuildpackResource

type BuildpackResource struct {
	Metadata Metadata
	Entity   BuildpackEntity
}

func (BuildpackResource) ToFields

func (resource BuildpackResource) ToFields() models.Buildpack

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) (apiResponse net.ApiResponse)

func (CCUserProvidedServiceInstanceRepository) Update

func (repo CCUserProvidedServiceInstanceRepository) Update(serviceInstanceFields models.ServiceInstanceFields) (apiResponse net.ApiResponse)

type CloudControllerAppEventsRepository

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

func NewCloudControllerAppEventsRepository

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

func (CloudControllerAppEventsRepository) ListEvents

func (repo CloudControllerAppEventsRepository) ListEvents(appGuid string, cb func(models.EventFields) bool) net.ApiResponse

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, apiResponse net.ApiResponse)

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, apiResponse net.ApiResponse)

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.AppSummary, apiResponse net.ApiResponse)

func (CloudControllerAppSummaryRepository) GetSummary

func (repo CloudControllerAppSummaryRepository) GetSummary(appGuid string) (summary models.AppSummary, apiResponse net.ApiResponse)

type CloudControllerApplicationBitsRepository

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

func NewCloudControllerApplicationBitsRepository

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

func (CloudControllerApplicationBitsRepository) UploadApp

func (repo CloudControllerApplicationBitsRepository) UploadApp(appGuid string, appDir string, cb func(path string, zipSize, fileCount uint64)) (apiResponse net.ApiResponse)

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, apiResponse net.ApiResponse)

func (CloudControllerApplicationRepository) Delete

func (repo CloudControllerApplicationRepository) Delete(appGuid string) (apiResponse net.ApiResponse)

func (CloudControllerApplicationRepository) Read

func (repo CloudControllerApplicationRepository) Read(name string) (app models.Application, apiResponse net.ApiResponse)

func (CloudControllerApplicationRepository) Update

func (repo CloudControllerApplicationRepository) Update(appGuid string, params models.AppParams) (updatedApp models.Application, apiResponse net.ApiResponse)

type CloudControllerBuildpackBitsRepository

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

func NewCloudControllerBuildpackBitsRepository

func NewCloudControllerBuildpackBitsRepository(config configuration.Reader, gateway net.Gateway, zipper cf.Zipper) (repo CloudControllerBuildpackBitsRepository)

func (CloudControllerBuildpackBitsRepository) UploadBuildpack

func (repo CloudControllerBuildpackBitsRepository) UploadBuildpack(buildpack models.Buildpack, buildpackLocation string) (apiResponse net.ApiResponse)

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, apiResponse net.ApiResponse)

func (CloudControllerBuildpackRepository) Delete

func (repo CloudControllerBuildpackRepository) Delete(buildpackGuid string) (apiResponse net.ApiResponse)

func (CloudControllerBuildpackRepository) FindByName

func (repo CloudControllerBuildpackRepository) FindByName(name string) (buildpack models.Buildpack, apiResponse net.ApiResponse)

func (CloudControllerBuildpackRepository) ListBuildpacks

func (CloudControllerBuildpackRepository) Update

func (repo CloudControllerBuildpackRepository) Update(buildpack models.Buildpack) (updatedBuildpack models.Buildpack, apiResponse net.ApiResponse)

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, apiResponse net.ApiResponse)

type CloudControllerDomainRepository

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

func NewCloudControllerDomainRepository

func NewCloudControllerDomainRepository(config configuration.Reader, gateway net.Gateway) (repo CloudControllerDomainRepository)

func (CloudControllerDomainRepository) Create

func (repo CloudControllerDomainRepository) Create(domainName string, owningOrgGuid string) (createdDomain models.DomainFields, apiResponse net.ApiResponse)

func (CloudControllerDomainRepository) CreateSharedDomain

func (repo CloudControllerDomainRepository) CreateSharedDomain(domainName string) (apiResponse net.ApiResponse)

func (CloudControllerDomainRepository) Delete

func (repo CloudControllerDomainRepository) Delete(domainGuid string) (apiResponse net.ApiResponse)

func (CloudControllerDomainRepository) DeleteSharedDomain

func (repo CloudControllerDomainRepository) DeleteSharedDomain(domainGuid string) (apiResponse net.ApiResponse)

func (CloudControllerDomainRepository) FindByName

func (repo CloudControllerDomainRepository) FindByName(name string) (domain models.DomainFields, apiResponse net.ApiResponse)

func (CloudControllerDomainRepository) FindByNameInOrg

func (repo CloudControllerDomainRepository) FindByNameInOrg(name string, orgGuid string) (domain models.DomainFields, apiResponse net.ApiResponse)

func (CloudControllerDomainRepository) ListDomains

func (CloudControllerDomainRepository) ListDomainsForOrg

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

func (CloudControllerDomainRepository) ListSharedDomains

func (repo CloudControllerDomainRepository) ListSharedDomains(cb func(models.DomainFields) bool) net.ApiResponse

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) (apiResponse net.ApiResponse)

func (CloudControllerOrganizationRepository) Delete

func (repo CloudControllerOrganizationRepository) Delete(orgGuid string) (apiResponse net.ApiResponse)

func (CloudControllerOrganizationRepository) FindByName

func (repo CloudControllerOrganizationRepository) FindByName(name string) (org models.Organization, apiResponse net.ApiResponse)

func (CloudControllerOrganizationRepository) ListOrgs

func (repo CloudControllerOrganizationRepository) ListOrgs(cb func(models.Organization) bool) (apiResponse net.ApiResponse)

func (CloudControllerOrganizationRepository) Rename

func (repo CloudControllerOrganizationRepository) Rename(orgGuid string, name string) (apiResponse net.ApiResponse)

type CloudControllerPasswordRepository

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

func NewCloudControllerPasswordRepository

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

func (CloudControllerPasswordRepository) UpdatePassword

func (repo CloudControllerPasswordRepository) UpdatePassword(old string, new string) (apiResponse net.ApiResponse)

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, apiResponse net.ApiResponse)

func (CloudControllerQuotaRepository) FindByName

func (repo CloudControllerQuotaRepository) FindByName(name string) (quota models.QuotaFields, apiResponse net.ApiResponse)

func (CloudControllerQuotaRepository) Update

func (repo CloudControllerQuotaRepository) Update(orgGuid, quotaGuid string) (apiResponse net.ApiResponse)

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) (apiResponse net.ApiResponse)

func (CloudControllerRouteRepository) Create

func (repo CloudControllerRouteRepository) Create(host, domainGuid string) (createdRoute models.Route, apiResponse net.ApiResponse)

func (CloudControllerRouteRepository) CreateInSpace

func (repo CloudControllerRouteRepository) CreateInSpace(host, domainGuid, spaceGuid string) (createdRoute models.Route, apiResponse net.ApiResponse)

func (CloudControllerRouteRepository) Delete

func (repo CloudControllerRouteRepository) Delete(routeGuid string) (apiResponse net.ApiResponse)

func (CloudControllerRouteRepository) FindByHost

func (repo CloudControllerRouteRepository) FindByHost(host string) (route models.Route, apiResponse net.ApiResponse)

func (CloudControllerRouteRepository) FindByHostAndDomain

func (repo CloudControllerRouteRepository) FindByHostAndDomain(host, domainName string) (route models.Route, apiResponse net.ApiResponse)

func (CloudControllerRouteRepository) ListRoutes

func (repo CloudControllerRouteRepository) ListRoutes(cb func(models.Route) bool) (apiResponse net.ApiResponse)

func (CloudControllerRouteRepository) Unbind

func (repo CloudControllerRouteRepository) Unbind(routeGuid, appGuid string) (apiResponse net.ApiResponse)

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, apiResponse net.ApiResponse)

func (CloudControllerServiceAuthTokenRepository) FindByLabelAndProvider

func (repo CloudControllerServiceAuthTokenRepository) FindByLabelAndProvider(label, provider string) (authToken models.ServiceAuthTokenFields, apiResponse net.ApiResponse)

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) (apiResponse net.ApiResponse)

func (CloudControllerServiceBindingRepository) Delete

func (repo CloudControllerServiceBindingRepository) Delete(instance models.ServiceInstance, appGuid string) (found bool, apiResponse net.ApiResponse)

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) (apiResponse net.ApiResponse)

func (CloudControllerServiceBrokerRepository) Delete

func (repo CloudControllerServiceBrokerRepository) Delete(guid string) (apiResponse net.ApiResponse)

func (CloudControllerServiceBrokerRepository) FindByName

func (repo CloudControllerServiceBrokerRepository) FindByName(name string) (serviceBroker models.ServiceBroker, apiResponse net.ApiResponse)

func (CloudControllerServiceBrokerRepository) ListServiceBrokers

func (repo CloudControllerServiceBrokerRepository) ListServiceBrokers(callback func(models.ServiceBroker) bool) net.ApiResponse

func (CloudControllerServiceBrokerRepository) Rename

func (repo CloudControllerServiceBrokerRepository) Rename(guid, name string) (apiResponse net.ApiResponse)

func (CloudControllerServiceBrokerRepository) Update

func (repo CloudControllerServiceBrokerRepository) Update(serviceBroker models.ServiceBroker) (apiResponse net.ApiResponse)

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) (identicalAlreadyExists bool, apiResponse net.ApiResponse)

func (CloudControllerServiceRepository) DeleteService

func (repo CloudControllerServiceRepository) DeleteService(instance models.ServiceInstance) (apiResponse net.ApiResponse)

func (CloudControllerServiceRepository) FindInstanceByName

func (repo CloudControllerServiceRepository) FindInstanceByName(name string) (instance models.ServiceInstance, apiResponse net.ApiResponse)

func (CloudControllerServiceRepository) FindServiceOfferingByLabelAndProvider

func (repo CloudControllerServiceRepository) FindServiceOfferingByLabelAndProvider(label, provider string) (offering models.ServiceOffering, apiResponse net.ApiResponse)

func (CloudControllerServiceRepository) FindServicePlanByDescription

func (repo CloudControllerServiceRepository) FindServicePlanByDescription(planDescription ServicePlanDescription) (planGuid string, apiResponse net.ApiResponse)

func (CloudControllerServiceRepository) GetAllServiceOfferings

func (repo CloudControllerServiceRepository) GetAllServiceOfferings() (offerings models.ServiceOfferings, apiResponse net.ApiResponse)

func (CloudControllerServiceRepository) GetServiceInstanceCountForServicePlan

func (repo CloudControllerServiceRepository) GetServiceInstanceCountForServicePlan(v1PlanGuid string) (count int, apiResponse net.ApiResponse)

func (CloudControllerServiceRepository) GetServiceOfferingsForSpace

func (repo CloudControllerServiceRepository) GetServiceOfferingsForSpace(spaceGuid string) (offerings models.ServiceOfferings, apiResponse net.ApiResponse)

func (CloudControllerServiceRepository) MigrateServicePlanFromV1ToV2

func (repo CloudControllerServiceRepository) MigrateServicePlanFromV1ToV2(v1PlanGuid, v2PlanGuid string) (changedCount int, apiResponse net.ApiResponse)

func (CloudControllerServiceRepository) PurgeServiceOffering

func (repo CloudControllerServiceRepository) PurgeServiceOffering(offering models.ServiceOffering) net.ApiResponse

func (CloudControllerServiceRepository) RenameService

func (repo CloudControllerServiceRepository) RenameService(instance models.ServiceInstance, newName string) (apiResponse net.ApiResponse)

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, apiResponse net.ApiResponse)

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, apiResponse net.ApiResponse)

func (CloudControllerSpaceRepository) Delete

func (repo CloudControllerSpaceRepository) Delete(spaceGuid string) (apiResponse net.ApiResponse)

func (CloudControllerSpaceRepository) FindByName

func (repo CloudControllerSpaceRepository) FindByName(name string) (space models.Space, apiResponse net.ApiResponse)

func (CloudControllerSpaceRepository) FindByNameInOrg

func (repo CloudControllerSpaceRepository) FindByNameInOrg(name, orgGuid string) (space models.Space, apiResponse net.ApiResponse)

func (CloudControllerSpaceRepository) ListSpaces

func (repo CloudControllerSpaceRepository) ListSpaces(callback func(models.Space) bool) net.ApiResponse

func (CloudControllerSpaceRepository) Rename

func (repo CloudControllerSpaceRepository) Rename(spaceGuid, newName string) (apiResponse net.ApiResponse)

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, apiResponse net.ApiResponse)

func (CloudControllerStackRepository) FindByName

func (repo CloudControllerStackRepository) FindByName(name string) (stack models.Stack, apiResponse net.ApiResponse)

type CloudControllerUserRepository

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

func NewCloudControllerUserRepository

func NewCloudControllerUserRepository(config configuration.Reader, uaaGateway net.Gateway, ccGateway net.Gateway, endpointRepo EndpointRepository) (repo CloudControllerUserRepository)

func (CloudControllerUserRepository) Create

func (repo CloudControllerUserRepository) Create(username, password string) (apiResponse net.ApiResponse)

func (CloudControllerUserRepository) Delete

func (repo CloudControllerUserRepository) Delete(userGuid string) (apiResponse net.ApiResponse)

func (CloudControllerUserRepository) FindByUsername

func (repo CloudControllerUserRepository) FindByUsername(username string) (user models.UserFields, apiResponse net.ApiResponse)

func (CloudControllerUserRepository) ListUsersInOrgForRole

func (repo CloudControllerUserRepository) ListUsersInOrgForRole(orgGuid string, roleName string) (users []models.UserFields, apiResponse net.ApiResponse)

func (CloudControllerUserRepository) ListUsersInSpaceForRole

func (repo CloudControllerUserRepository) ListUsersInSpaceForRole(spaceGuid string, roleName string) (users []models.UserFields, apiResponse net.ApiResponse)

func (CloudControllerUserRepository) SetOrgRole

func (repo CloudControllerUserRepository) SetOrgRole(userGuid string, orgGuid string, role string) (apiResponse net.ApiResponse)

func (CloudControllerUserRepository) SetSpaceRole

func (repo CloudControllerUserRepository) SetSpaceRole(userGuid, spaceGuid, orgGuid, role string) (apiResponse net.ApiResponse)

func (CloudControllerUserRepository) UnsetOrgRole

func (repo CloudControllerUserRepository) UnsetOrgRole(userGuid, orgGuid, role string) (apiResponse net.ApiResponse)

func (CloudControllerUserRepository) UnsetSpaceRole

func (repo CloudControllerUserRepository) UnsetSpaceRole(userGuid, spaceGuid, role string) (apiResponse net.ApiResponse)

type CurlRepository

type CurlRepository interface {
	Request(method, path, header, body string) (resHeaders, resBody string, apiResponse net.ApiResponse)
}

type DomainEntity

type DomainEntity struct {
	Name                   string
	OwningOrganizationGuid string `json:"owning_organization_guid"`
}

type DomainRepository

type DomainRepository interface {
	ListDomainsForOrg(orgGuid string, cb func(models.DomainFields) bool) net.ApiResponse
	ListSharedDomains(cb func(models.DomainFields) bool) net.ApiResponse
	FindByName(name string) (domain models.DomainFields, apiResponse net.ApiResponse)
	FindByNameInOrg(name string, owningOrgGuid string) (domain models.DomainFields, apiResponse net.ApiResponse)
	Create(domainName string, owningOrgGuid string) (createdDomain models.DomainFields, apiResponse net.ApiResponse)
	CreateSharedDomain(domainName string) (apiResponse net.ApiResponse)
	Delete(domainGuid string) (apiResponse net.ApiResponse)
	DeleteSharedDomain(domainGuid string) (apiResponse net.ApiResponse)
	ListDomains(cb func(models.DomainFields) bool) net.ApiResponse
}

type DomainResource

type DomainResource struct {
	Resource
	Entity DomainEntity
}

func (DomainResource) ToFields

func (resource DomainResource) ToFields() models.DomainFields

type DomainSummary

type DomainSummary struct {
	Guid                   string
	Name                   string
	OwningOrganizationGuid string
}

type EndpointRepository

type EndpointRepository interface {
	UpdateEndpoint(endpoint string) (finalEndpoint string, apiResponse net.ApiResponse)
	GetLoggregatorEndpoint() (endpoint string, apiResponse net.ApiResponse)
	GetUAAEndpoint() (endpoint string, apiResponse net.ApiResponse)
	GetCloudControllerEndpoint() (endpoint string, apiResponse net.ApiResponse)
}

type Entity

type Entity struct {
	Name string
}

type EventResourceNewV2

type EventResourceNewV2 struct {
	Resource
	Entity struct {
		Timestamp time.Time
		Type      string
		Metadata  map[string]interface{}
	}
}

func (EventResourceNewV2) ToFields

func (resource EventResourceNewV2) ToFields() models.EventFields

type EventResourceOldV2

type EventResourceOldV2 struct {
	Resource
	Entity struct {
		Timestamp       time.Time
		ExitDescription string `json:"exit_description"`
		ExitStatus      int    `json:"exit_status"`
		InstanceIndex   int    `json:"instance_index"`
	}
}

FIXME: needs semantic versioning

func (EventResourceOldV2) ToFields

func (resource EventResourceOldV2) ToFields() models.EventFields

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 Item

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

type LoggregatorLogsRepository

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

func NewLoggregatorLogsRepository

func NewLoggregatorLogsRepository(config configuration.Reader, endpointRepo EndpointRepository) (repo LoggregatorLogsRepository)

func (LoggregatorLogsRepository) RecentLogsFor

func (repo LoggregatorLogsRepository) RecentLogsFor(appGuid string, onConnect func(), logChan chan *logmessage.Message) (err error)

func (LoggregatorLogsRepository) TailLogsFor

func (repo LoggregatorLogsRepository) TailLogsFor(appGuid string, onConnect func(), logChan chan *logmessage.Message, stopLoggingChan chan bool, printTimeBuffer time.Duration) error

type LogsRepository

type LogsRepository interface {
	RecentLogsFor(appGuid string, onConnect func(), logChan chan *logmessage.Message) (err error)
	TailLogsFor(appGuid string, onConnect func(), logChan chan *logmessage.Message, stopLoggingChan chan bool, printInterval time.Duration) (err error)
}

type Metadata

type Metadata struct {
	Guid string
	Url  string
}

type OrganizationEntity

type OrganizationEntity struct {
	Name            string
	QuotaDefinition QuotaResource `json:"quota_definition"`
	Spaces          []SpaceResource
	Domains         []DomainResource
}

type OrganizationRepository

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

type OrganizationResource

type OrganizationResource struct {
	Resource
	Entity OrganizationEntity
}

func (OrganizationResource) ToFields

func (resource OrganizationResource) ToFields() (fields models.OrganizationFields)

func (OrganizationResource) ToModel

func (resource OrganizationResource) ToModel() (org models.Organization)

type PaginatedApplicationResources

type PaginatedApplicationResources struct {
	Resources []ApplicationResource
}

type PaginatedAuthTokenResources

type PaginatedAuthTokenResources struct {
	Resources []AuthTokenResource
}

type PaginatedQuotaResources

type PaginatedQuotaResources struct {
	Resources []QuotaResource
}

type PaginatedServiceInstanceResources

type PaginatedServiceInstanceResources struct {
	TotalResults int `json:"total_results"`
	Resources    []ServiceInstanceResource
}

type PaginatedServiceOfferingResources

type PaginatedServiceOfferingResources struct {
	Resources []ServiceOfferingResource
}

type PaginatedStackResources

type PaginatedStackResources struct {
	Resources []StackResource
}

type PasswordRepository

type PasswordRepository interface {
	UpdatePassword(old string, new string) net.ApiResponse
}

type QuotaEntity

type QuotaEntity struct {
	Name        string
	MemoryLimit uint64 `json:"memory_limit"`
}

type QuotaRepository

type QuotaRepository interface {
	FindAll() (quotas []models.QuotaFields, apiResponse net.ApiResponse)
	FindByName(name string) (quota models.QuotaFields, apiResponse net.ApiResponse)
	Update(orgGuid, quotaGuid string) (apiResponse net.ApiResponse)
}

type QuotaResource

type QuotaResource struct {
	Resource
	Entity QuotaEntity
}

func (QuotaResource) ToFields

func (resource QuotaResource) ToFields() (quota models.QuotaFields)

type RemoteEndpointRepository

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

func NewEndpointRepository

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

func (RemoteEndpointRepository) GetCloudControllerEndpoint

func (repo RemoteEndpointRepository) GetCloudControllerEndpoint() (endpoint string, apiResponse net.ApiResponse)

func (RemoteEndpointRepository) GetLoggregatorEndpoint

func (repo RemoteEndpointRepository) GetLoggregatorEndpoint() (endpoint string, apiResponse net.ApiResponse)

func (RemoteEndpointRepository) GetUAAEndpoint

func (repo RemoteEndpointRepository) GetUAAEndpoint() (endpoint string, apiResponse net.ApiResponse)

func (RemoteEndpointRepository) UpdateEndpoint

func (repo RemoteEndpointRepository) UpdateEndpoint(endpoint string) (finalEndpoint string, apiResponse net.ApiResponse)

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 Resource

type Resource struct {
	Metadata Metadata
	Entity   Entity
}

type RouteEntity

type RouteEntity struct {
	Host   string
	Domain DomainResource
	Space  SpaceResource
	Apps   []ApplicationResource
}

type RouteRepository

type RouteRepository interface {
	ListRoutes(cb func(models.Route) bool) (apiResponse net.ApiResponse)
	FindByHost(host string) (route models.Route, apiResponse net.ApiResponse)
	FindByHostAndDomain(host, domain string) (route models.Route, apiResponse net.ApiResponse)
	Create(host, domainGuid string) (createdRoute models.Route, apiResponse net.ApiResponse)
	CreateInSpace(host, domainGuid, spaceGuid string) (createdRoute models.Route, apiResponse net.ApiResponse)
	Bind(routeGuid, appGuid string) (apiResponse net.ApiResponse)
	Unbind(routeGuid, appGuid string) (apiResponse net.ApiResponse)
	Delete(routeGuid string) (apiResponse net.ApiResponse)
}

type RouteResource

type RouteResource struct {
	Resource
	Entity RouteEntity
}

func (RouteResource) ToFields

func (resource RouteResource) ToFields() (fields models.RouteFields)

func (RouteResource) ToModel

func (resource RouteResource) ToModel() (route models.Route)

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, apiResponse net.ApiResponse)
	FindByLabelAndProvider(label, provider string) (authToken models.ServiceAuthTokenFields, apiResponse net.ApiResponse)
	Create(authToken models.ServiceAuthTokenFields) (apiResponse net.ApiResponse)
	Update(authToken models.ServiceAuthTokenFields) (apiResponse net.ApiResponse)
	Delete(authToken models.ServiceAuthTokenFields) (apiResponse net.ApiResponse)
}

type ServiceBindingEntity

type ServiceBindingEntity struct {
	AppGuid string `json:"app_guid"`
}

type ServiceBindingRepository

type ServiceBindingRepository interface {
	Create(instanceGuid, appGuid string) (apiResponse net.ApiResponse)
	Delete(instance models.ServiceInstance, appGuid string) (found bool, apiResponse net.ApiResponse)
}

type ServiceBindingResource

type ServiceBindingResource struct {
	Metadata Metadata
	Entity   ServiceBindingEntity
}

func (ServiceBindingResource) ToFields

func (resource ServiceBindingResource) ToFields() (fields models.ServiceBindingFields)

type ServiceBrokerEntity

type ServiceBrokerEntity struct {
	Guid     string
	Name     string
	Password string `json:"auth_password"`
	Username string `json:"auth_username"`
	Url      string `json:"broker_url"`
}

type ServiceBrokerRepository

type ServiceBrokerRepository interface {
	ListServiceBrokers(callback func(models.ServiceBroker) bool) net.ApiResponse
	FindByName(name string) (serviceBroker models.ServiceBroker, apiResponse net.ApiResponse)
	Create(name, url, username, password string) (apiResponse net.ApiResponse)
	Update(serviceBroker models.ServiceBroker) (apiResponse net.ApiResponse)
	Rename(guid, name string) (apiResponse net.ApiResponse)
	Delete(guid string) (apiResponse net.ApiResponse)
}

type ServiceBrokerResource

type ServiceBrokerResource struct {
	Resource
	Entity ServiceBrokerEntity
}

func (ServiceBrokerResource) ToFields

func (resource ServiceBrokerResource) ToFields() (fields models.ServiceBroker)

type ServiceInstanceEntity

type ServiceInstanceEntity struct {
	Name            string
	ServiceBindings []ServiceBindingResource `json:"service_bindings"`
	ServicePlan     ServicePlanResource      `json:"service_plan"`
}

type ServiceInstanceResource

type ServiceInstanceResource struct {
	Metadata Metadata
	Entity   ServiceInstanceEntity
}

func (ServiceInstanceResource) ToFields

func (resource ServiceInstanceResource) ToFields() (fields models.ServiceInstanceFields)

func (ServiceInstanceResource) ToModel

func (resource ServiceInstanceResource) ToModel() (instance models.ServiceInstance)

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 ServiceMigrateV1ToV2Response

type ServiceMigrateV1ToV2Response struct {
	ChangedCount int `json:"changed_count"`
}

type ServiceOfferingEntity

type ServiceOfferingEntity struct {
	Label            string
	Version          string
	Description      string
	DocumentationUrl string `json:"documentation_url"`
	Provider         string
	ServicePlans     []ServicePlanResource `json:"service_plans"`
}

type ServiceOfferingResource

type ServiceOfferingResource struct {
	Metadata Metadata
	Entity   ServiceOfferingEntity
}

func (ServiceOfferingResource) ToFields

func (resource ServiceOfferingResource) ToFields() (fields models.ServiceOfferingFields)

func (ServiceOfferingResource) ToModel

func (resource ServiceOfferingResource) ToModel() (offering models.ServiceOffering)

type ServiceOfferingSummary

type ServiceOfferingSummary struct {
	Label    string
	Provider string
	Version  string
}

type ServicePlanDescription

type ServicePlanDescription struct {
	ServiceName     string
	ServicePlanName string
	ServiceProvider string
}

func (ServicePlanDescription) String

func (planDesc ServicePlanDescription) String() string

type ServicePlanEntity

type ServicePlanEntity struct {
	Name            string
	ServiceOffering ServiceOfferingResource `json:"service"`
}

type ServicePlanResource

type ServicePlanResource struct {
	Metadata Metadata
	Entity   ServicePlanEntity
}

func (ServicePlanResource) ToFields

func (resource ServicePlanResource) ToFields() (fields models.ServicePlanFields)

type ServicePlanSummary

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

type ServiceRepository

type ServiceRepository interface {
	PurgeServiceOffering(offering models.ServiceOffering) net.ApiResponse
	FindServiceOfferingByLabelAndProvider(name, provider string) (offering models.ServiceOffering, apiResponse net.ApiResponse)
	GetAllServiceOfferings() (offerings models.ServiceOfferings, apiResponse net.ApiResponse)
	GetServiceOfferingsForSpace(spaceGuid string) (offerings models.ServiceOfferings, apiResponse net.ApiResponse)
	FindInstanceByName(name string) (instance models.ServiceInstance, apiResponse net.ApiResponse)
	CreateServiceInstance(name, planGuid string) (identicalAlreadyExists bool, apiResponse net.ApiResponse)
	RenameService(instance models.ServiceInstance, newName string) (apiResponse net.ApiResponse)
	DeleteService(instance models.ServiceInstance) (apiResponse net.ApiResponse)
	FindServicePlanByDescription(planDescription ServicePlanDescription) (planGuid string, apiResponse net.ApiResponse)
	GetServiceInstanceCountForServicePlan(v1PlanGuid string) (count int, apiResponse net.ApiResponse)
	MigrateServicePlanFromV1ToV2(v1PlanGuid, v2PlanGuid string) (changedCount int, apiResponse net.ApiResponse)
}

type ServiceSummaryRepository

type ServiceSummaryRepository interface {
	GetSummariesInCurrentSpace() (instances []models.ServiceInstance, apiResponse net.ApiResponse)
}

type SortedMessageQueue

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

func NewSortedMessageQueue

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

func (*SortedMessageQueue) NextTimestamp

func (pq *SortedMessageQueue) NextTimestamp() int64

func (*SortedMessageQueue) PopMessage

func (pq *SortedMessageQueue) PopMessage() *logmessage.Message

func (*SortedMessageQueue) PushMessage

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

type SpaceEntity

type SpaceEntity struct {
	Name             string
	Organization     OrganizationResource
	Applications     []ApplicationResource `json:"apps"`
	Domains          []DomainResource
	ServiceInstances []ServiceInstanceResource `json:"service_instances"`
}

type SpaceRepository

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

type SpaceResource

type SpaceResource struct {
	Metadata Metadata
	Entity   SpaceEntity
}

func (SpaceResource) ToFields

func (resource SpaceResource) ToFields() (fields models.SpaceFields)

func (SpaceResource) ToModel

func (resource SpaceResource) ToModel() (space models.Space)

type StackEntity

type StackEntity struct {
	Name        string
	Description string
}

type StackRepository

type StackRepository interface {
	FindByName(name string) (stack models.Stack, apiResponse net.ApiResponse)
	FindAll() (stacks []models.Stack, apiResponse net.ApiResponse)
}

type StackResource

type StackResource struct {
	Resource
	Entity StackEntity
}

func (StackResource) ToFields

func (resource StackResource) ToFields() (fields models.Stack)

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) (apiResponse net.ApiResponse)

func (UAAAuthenticationRepository) RefreshAuthToken

func (uaa UAAAuthenticationRepository) RefreshAuthToken() (updatedToken string, apiResponse net.ApiResponse)

type UAAUserResources

type UAAUserResources struct {
	Resources []struct {
		Id       string
		Username string
	}
}

type UserEntity

type UserEntity struct {
	Entity
	Admin bool
}

type UserProvidedServiceInstanceRepository

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

type UserRepository

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

type UserResource

type UserResource struct {
	Resource
	Entity UserEntity
}

func (UserResource) ToFields

func (resource UserResource) ToFields() models.UserFields

Jump to

Keyboard shortcuts

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