api

package
v6.0.0+incompatible Latest Latest
Warning

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

Go to latest
Published: Jan 31, 2014 License: Apache-2.0 Imports: 29 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

func String

func String(val interface{}) string

Types

type AppEventsRepository

type AppEventsRepository interface {
	ListEvents(appGuid string, cb ListEventsCallback) 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 []cf.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 cf.RouteFields)

func (AppRouteResource) ToModel

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

type AppSummaryRepository

type AppSummaryRepository interface {
	GetSummariesInCurrentSpace() (apps []cf.AppSummary, apiResponse net.ApiResponse)
	GetSummary(appGuid string) (summary cf.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
	State           string
	SpaceGuid       string `json:"space_guid"`
	Instances       int
	Memory          int
	Stack           StackResource
	Routes          []AppRouteResource
	EnvironmentJson map[string]string `json:"environment_json"`
}

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 cf.ApplicationFields)

func (ApplicationFromSummary) ToModel

func (resource ApplicationFromSummary) ToModel() (app cf.AppSummary)

type ApplicationRepository

type ApplicationRepository interface {
	Create(params cf.AppParams) (createdApp cf.Application, apiResponse net.ApiResponse)
	Read(name string) (app cf.Application, apiResponse net.ApiResponse)
	Update(appGuid string, params cf.AppParams) (updatedApp cf.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 cf.ApplicationFields)

func (ApplicationResource) ToModel

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

type ApplicationSummaries

type ApplicationSummaries struct {
	Apps []ApplicationFromSummary
}

func (ApplicationSummaries) ToModels

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

type AuthTokenEntity

type AuthTokenEntity struct {
	Label    string
	Provider string
}

type AuthTokenResource

type AuthTokenResource struct {
	Resource
	Entity AuthTokenEntity
}

type AuthenticationRepository

type AuthenticationRepository interface {
	Authenticate(email string, password string) (apiResponse net.ApiResponse)
	RefreshAuthToken() (updatedToken string, apiResponse net.ApiResponse)
}

type BuildpackBitsRepository

type BuildpackBitsRepository interface {
	UploadBuildpack(buildpack cf.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 cf.Buildpack, apiResponse net.ApiResponse)
	ListBuildpacks(stop chan bool) (buildpacksChan chan []cf.Buildpack, statusChan chan net.ApiResponse)
	Create(name string, position *int, enabled *bool, locked *bool) (createdBuildpack cf.Buildpack, apiResponse net.ApiResponse)
	Delete(buildpackGuid string) (apiResponse net.ApiResponse)
	Update(buildpack cf.Buildpack) (updatedBuildpack cf.Buildpack, apiResponse net.ApiResponse)
}

type BuildpackResource

type BuildpackResource struct {
	Resource
	Entity BuildpackEntity
}

type CCUserProvidedServiceInstanceRepository

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

func NewCCUserProvidedServiceInstanceRepository

func NewCCUserProvidedServiceInstanceRepository(config *configuration.Configuration, 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 cf.ServiceInstanceFields) (apiResponse net.ApiResponse)

type CloudControllerAppEventsRepository

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

func NewCloudControllerAppEventsRepository

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

func (CloudControllerAppEventsRepository) ListEvents

func (repo CloudControllerAppEventsRepository) ListEvents(appGuid string, cb ListEventsCallback) (apiResponse net.ApiResponse)

type CloudControllerAppFilesRepository

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

func NewCloudControllerAppFilesRepository

func NewCloudControllerAppFilesRepository(config *configuration.Configuration, 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.Configuration, gateway net.Gateway) (repo CloudControllerAppInstancesRepository)

func (CloudControllerAppInstancesRepository) GetInstances

func (repo CloudControllerAppInstancesRepository) GetInstances(appGuid string) (instances []cf.AppInstanceFields, apiResponse net.ApiResponse)

type CloudControllerAppSummaryRepository

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

func NewCloudControllerAppSummaryRepository

func NewCloudControllerAppSummaryRepository(config *configuration.Configuration, gateway net.Gateway) (repo CloudControllerAppSummaryRepository)

func (CloudControllerAppSummaryRepository) GetSummariesInCurrentSpace

func (repo CloudControllerAppSummaryRepository) GetSummariesInCurrentSpace() (apps []cf.AppSummary, apiResponse net.ApiResponse)

func (CloudControllerAppSummaryRepository) GetSummary

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

type CloudControllerApplicationBitsRepository

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

func NewCloudControllerApplicationBitsRepository

func NewCloudControllerApplicationBitsRepository(config *configuration.Configuration, 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.Configuration, gateway net.Gateway) (repo CloudControllerApplicationRepository)

func (CloudControllerApplicationRepository) Create

func (repo CloudControllerApplicationRepository) Create(params cf.AppParams) (createdApp cf.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 cf.Application, apiResponse net.ApiResponse)

func (CloudControllerApplicationRepository) Update

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

type CloudControllerBuildpackBitsRepository

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

func NewCloudControllerBuildpackBitsRepository

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

func (CloudControllerBuildpackBitsRepository) UploadBuildpack

func (repo CloudControllerBuildpackBitsRepository) UploadBuildpack(buildpack cf.Buildpack, dir string) (apiResponse net.ApiResponse)

type CloudControllerBuildpackRepository

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

func NewCloudControllerBuildpackRepository

func NewCloudControllerBuildpackRepository(config *configuration.Configuration, gateway net.Gateway) (repo CloudControllerBuildpackRepository)

func (CloudControllerBuildpackRepository) Create

func (repo CloudControllerBuildpackRepository) Create(name string, position *int, enabled *bool, locked *bool) (createdBuildpack cf.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 cf.Buildpack, apiResponse net.ApiResponse)

func (CloudControllerBuildpackRepository) ListBuildpacks

func (repo CloudControllerBuildpackRepository) ListBuildpacks(stop chan bool) (buildpacksChan chan []cf.Buildpack, statusChan chan net.ApiResponse)

func (CloudControllerBuildpackRepository) Update

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

type CloudControllerCurlRepository

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

func NewCloudControllerCurlRepository

func NewCloudControllerCurlRepository(config *configuration.Configuration, 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.Configuration, gateway net.Gateway) (repo CloudControllerDomainRepository)

func (CloudControllerDomainRepository) Create

func (repo CloudControllerDomainRepository) Create(domainName string, owningOrgGuid string) (createdDomain cf.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 cf.Domain, apiResponse net.ApiResponse)

func (CloudControllerDomainRepository) FindByNameInCurrentSpace

func (repo CloudControllerDomainRepository) FindByNameInCurrentSpace(name string) (domain cf.Domain, apiResponse net.ApiResponse)

func (CloudControllerDomainRepository) FindByNameInOrg

func (repo CloudControllerDomainRepository) FindByNameInOrg(name string, orgGuid string) (domain cf.Domain, apiResponse net.ApiResponse)

func (CloudControllerDomainRepository) ListDomains

func (CloudControllerDomainRepository) ListDomainsForOrg

func (repo CloudControllerDomainRepository) ListDomainsForOrg(orgGuid string, cb ListDomainsCallback) net.ApiResponse

func (CloudControllerDomainRepository) ListSharedDomains

type CloudControllerOrganizationRepository

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

func NewCloudControllerOrganizationRepository

func NewCloudControllerOrganizationRepository(config *configuration.Configuration, 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 cf.Organization, apiResponse net.ApiResponse)

func (CloudControllerOrganizationRepository) ListOrgs

func (repo CloudControllerOrganizationRepository) ListOrgs(stop chan bool) (orgsChan chan []cf.Organization, statusChan chan 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.Configuration, 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.Configuration, gateway net.Gateway) (repo CloudControllerQuotaRepository)

func (CloudControllerQuotaRepository) FindAll

func (repo CloudControllerQuotaRepository) FindAll() (quotas []cf.QuotaFields, apiResponse net.ApiResponse)

func (CloudControllerQuotaRepository) FindByName

func (repo CloudControllerQuotaRepository) FindByName(name string) (quota cf.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.Configuration, 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 cf.Route, apiResponse net.ApiResponse)

func (CloudControllerRouteRepository) CreateInSpace

func (repo CloudControllerRouteRepository) CreateInSpace(host, domainGuid, spaceGuid string) (createdRoute cf.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 cf.Route, apiResponse net.ApiResponse)

func (CloudControllerRouteRepository) FindByHostAndDomain

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

func (CloudControllerRouteRepository) ListRoutes

func (repo CloudControllerRouteRepository) ListRoutes(stop chan bool) (routesChan chan []cf.Route, statusChan chan 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.Configuration, gateway net.Gateway) (repo CloudControllerServiceAuthTokenRepository)

func (CloudControllerServiceAuthTokenRepository) Create

func (CloudControllerServiceAuthTokenRepository) Delete

func (CloudControllerServiceAuthTokenRepository) FindAll

func (repo CloudControllerServiceAuthTokenRepository) FindAll() (authTokens []cf.ServiceAuthTokenFields, apiResponse net.ApiResponse)

func (CloudControllerServiceAuthTokenRepository) FindByLabelAndProvider

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

func (CloudControllerServiceAuthTokenRepository) Update

type CloudControllerServiceBindingRepository

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

func NewCloudControllerServiceBindingRepository

func NewCloudControllerServiceBindingRepository(config *configuration.Configuration, 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 cf.ServiceInstance, appGuid string) (found bool, apiResponse net.ApiResponse)

type CloudControllerServiceBrokerRepository

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

func NewCloudControllerServiceBrokerRepository

func NewCloudControllerServiceBrokerRepository(config *configuration.Configuration, 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 cf.ServiceBroker, apiResponse net.ApiResponse)

func (CloudControllerServiceBrokerRepository) ListServiceBrokers

func (repo CloudControllerServiceBrokerRepository) ListServiceBrokers(stop chan bool) (serviceBrokersChan chan []cf.ServiceBroker, statusChan chan net.ApiResponse)

func (CloudControllerServiceBrokerRepository) Rename

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

func (CloudControllerServiceBrokerRepository) Update

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

type CloudControllerServiceRepository

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

func NewCloudControllerServiceRepository

func NewCloudControllerServiceRepository(config *configuration.Configuration, 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 cf.ServiceInstance) (apiResponse net.ApiResponse)

func (CloudControllerServiceRepository) FindInstanceByName

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

func (CloudControllerServiceRepository) GetServiceOfferings

func (repo CloudControllerServiceRepository) GetServiceOfferings() (offerings cf.ServiceOfferings, apiResponse net.ApiResponse)

func (CloudControllerServiceRepository) RenameService

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

type CloudControllerServiceSummaryRepository

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

func NewCloudControllerServiceSummaryRepository

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

func (CloudControllerServiceSummaryRepository) GetSummariesInCurrentSpace

func (repo CloudControllerServiceSummaryRepository) GetSummariesInCurrentSpace() (instances []cf.ServiceInstance, apiResponse net.ApiResponse)

type CloudControllerSpaceRepository

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

func NewCloudControllerSpaceRepository

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

func (CloudControllerSpaceRepository) Create

func (repo CloudControllerSpaceRepository) Create(name string, orgGuid string) (space cf.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 cf.Space, apiResponse net.ApiResponse)

func (CloudControllerSpaceRepository) FindByNameInOrg

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

func (CloudControllerSpaceRepository) ListSpaces

func (repo CloudControllerSpaceRepository) ListSpaces(stop chan bool) (spacesChan chan []cf.Space, statusChan chan 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.Configuration, gateway net.Gateway) (repo CloudControllerStackRepository)

func (CloudControllerStackRepository) FindAll

func (repo CloudControllerStackRepository) FindAll() (stacks []cf.Stack, apiResponse net.ApiResponse)

func (CloudControllerStackRepository) FindByName

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

type CloudControllerUserRepository

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

func NewCloudControllerUserRepository

func NewCloudControllerUserRepository(config *configuration.Configuration, 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 cf.UserFields, apiResponse net.ApiResponse)

func (CloudControllerUserRepository) ListUsersInOrgForRole

func (repo CloudControllerUserRepository) ListUsersInOrgForRole(orgGuid string, roleName string, stop chan bool) (usersChan chan []cf.UserFields, statusChan chan net.ApiResponse)

func (CloudControllerUserRepository) ListUsersInSpaceForRole

func (repo CloudControllerUserRepository) ListUsersInSpaceForRole(spaceGuid string, roleName string, stop chan bool) (usersChan chan []cf.UserFields, statusChan chan 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 ListDomainsCallback) net.ApiResponse
	ListSharedDomains(cb ListDomainsCallback) net.ApiResponse
	FindByName(name string) (domain cf.Domain, apiResponse net.ApiResponse)
	FindByNameInCurrentSpace(name string) (domain cf.Domain, apiResponse net.ApiResponse)
	FindByNameInOrg(name string, owningOrgGuid string) (domain cf.Domain, apiResponse net.ApiResponse)
	Create(domainName string, owningOrgGuid string) (createdDomain cf.DomainFields, apiResponse net.ApiResponse)
	CreateSharedDomain(domainName string) (apiResponse net.ApiResponse)
	Delete(domainGuid string) (apiResponse net.ApiResponse)
	DeleteSharedDomain(domainGuid string) (apiResponse net.ApiResponse)
	ListDomains(cb ListDomainsCallback) net.ApiResponse
}

type DomainResource

type DomainResource struct {
	Resource
	Entity DomainEntity
}

func (DomainResource) ToFields

func (resource DomainResource) ToFields() (fields cf.DomainFields)

func (DomainResource) ToModel

func (resource DomainResource) ToModel() (domain cf.Domain)

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 EventEntity

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

type EventEntityNewV2

type EventEntityNewV2 struct {
	Timestamp time.Time
	Type      string
	Metadata  map[string]interface{}
}

type EventResource

type EventResource struct {
	Resource
	Entity EventEntity
}

func (EventResource) ToFields

func (resource EventResource) ToFields() (event cf.EventFields)

type EventResourceNewV2

type EventResourceNewV2 struct {
	Resource
	Entity EventEntityNewV2
}

func (EventResourceNewV2) ToFields

func (resource EventResourceNewV2) ToFields() (event cf.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 ListDomainsCallback

type ListDomainsCallback func(domains []cf.Domain) (fetchNext bool)

type ListEventsCallback

type ListEventsCallback func(events []cf.EventFields) (fetchNext bool)

type LoggregatorLogsRepository

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

func NewLoggregatorLogsRepository

func NewLoggregatorLogsRepository(config *configuration.Configuration, 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(stop chan bool) (orgsChan chan []cf.Organization, statusChan chan net.ApiResponse)
	FindByName(name string) (org cf.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 cf.OrganizationFields)

func (OrganizationResource) ToModel

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

type PaginatedApplicationResources

type PaginatedApplicationResources struct {
	Resources []ApplicationResource
}

type PaginatedAuthTokenResources

type PaginatedAuthTokenResources struct {
	Resources []AuthTokenResource
}

type PaginatedBuildpackResources

type PaginatedBuildpackResources struct {
	Resources []BuildpackResource
	NextUrl   string `json:"next_url"`
}

type PaginatedDomainResources

type PaginatedDomainResources struct {
	NextUrl   string `json:"next_url"`
	Resources []DomainResource
}

type PaginatedEventResourcesNewV2

type PaginatedEventResourcesNewV2 struct {
	Resources []EventResourceNewV2
	NextURL   string `json:"next_url"`
}

func (PaginatedEventResourcesNewV2) NextUrl

func (res PaginatedEventResourcesNewV2) NextUrl() string

func (PaginatedEventResourcesNewV2) ToEventFields

func (res PaginatedEventResourcesNewV2) ToEventFields() (events []cf.EventFields)

type PaginatedEventResourcesOldV2

type PaginatedEventResourcesOldV2 struct {
	Resources []EventResource
	NextURL   string `json:"next_url"`
}

func (PaginatedEventResourcesOldV2) NextUrl

func (res PaginatedEventResourcesOldV2) NextUrl() string

func (PaginatedEventResourcesOldV2) ToEventFields

func (res PaginatedEventResourcesOldV2) ToEventFields() (events []cf.EventFields)

type PaginatedEventsResources

type PaginatedEventsResources interface {
	ToEventFields() []cf.EventFields
	NextUrl() string
}

type PaginatedOrganizationResources

type PaginatedOrganizationResources struct {
	Resources []OrganizationResource
	NextUrl   string `json:"next_url"`
}

type PaginatedQuotaResources

type PaginatedQuotaResources struct {
	Resources []QuotaResource
}

type PaginatedResources

type PaginatedResources struct {
	Resources []Resource
}

type PaginatedRouteResources

type PaginatedRouteResources struct {
	Resources []RouteResource `json:"resources"`
	NextUrl   string          `json:"next_url"`
}

type PaginatedServiceBrokerResources

type PaginatedServiceBrokerResources struct {
	ServiceBrokers []ServiceBrokerResource `json:"resources"`
	NextUrl        string                  `json:"next_url"`
}

type PaginatedServiceInstanceResources

type PaginatedServiceInstanceResources struct {
	Resources []ServiceInstanceResource
}

type PaginatedServiceOfferingResources

type PaginatedServiceOfferingResources struct {
	Resources []ServiceOfferingResource
}

type PaginatedSpaceResources

type PaginatedSpaceResources struct {
	Resources []SpaceResource
	NextUrl   string `json:"next_url"`
}

type PaginatedStackResources

type PaginatedStackResources struct {
	Resources []StackResource
}

type PaginatedUserResources

type PaginatedUserResources struct {
	NextUrl   string `json:"next_url"`
	Resources []UserResource
}

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 []cf.QuotaFields, apiResponse net.ApiResponse)
	FindByName(name string) (quota cf.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 cf.QuotaFields)

type RemoteEndpointRepository

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

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.Configuration, configRepo configuration.ConfigurationRepository, 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(stop chan bool) (routesChan chan []cf.Route, statusChan chan net.ApiResponse)
	FindByHost(host string) (route cf.Route, apiResponse net.ApiResponse)
	FindByHostAndDomain(host, domain string) (route cf.Route, apiResponse net.ApiResponse)
	Create(host, domainGuid string) (createdRoute cf.Route, apiResponse net.ApiResponse)
	CreateInSpace(host, domainGuid, spaceGuid string) (createdRoute cf.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 cf.RouteFields)

func (RouteResource) ToModel

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

type RouteSummary

type RouteSummary struct {
	Guid   string
	Host   string
	Domain DomainSummary
}

func (RouteSummary) ToModel

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

type ServiceAuthTokenRepository

type ServiceAuthTokenRepository interface {
	FindAll() (authTokens []cf.ServiceAuthTokenFields, apiResponse net.ApiResponse)
	FindByLabelAndProvider(label, provider string) (authToken cf.ServiceAuthTokenFields, apiResponse net.ApiResponse)
	Create(authToken cf.ServiceAuthTokenFields) (apiResponse net.ApiResponse)
	Update(authToken cf.ServiceAuthTokenFields) (apiResponse net.ApiResponse)
	Delete(authToken cf.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 cf.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 cf.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(stop chan bool) (serviceBrokersChan chan []cf.ServiceBroker, statusChan chan net.ApiResponse)
	FindByName(name string) (serviceBroker cf.ServiceBroker, apiResponse net.ApiResponse)
	Create(name, url, username, password string) (apiResponse net.ApiResponse)
	Update(serviceBroker cf.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 cf.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 cf.ServiceInstanceFields)

func (ServiceInstanceResource) ToModel

func (resource ServiceInstanceResource) ToModel() (instance cf.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 []cf.ServiceInstance)

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 cf.ServiceOfferingFields)

func (ServiceOfferingResource) ToModel

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

type ServiceOfferingSummary

type ServiceOfferingSummary struct {
	Label    string
	Provider string
	Version  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 cf.ServicePlanFields)

type ServicePlanSummary

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

type ServiceRepository

type ServiceRepository interface {
	GetServiceOfferings() (offerings cf.ServiceOfferings, apiResponse net.ApiResponse)
	FindInstanceByName(name string) (instance cf.ServiceInstance, apiResponse net.ApiResponse)
	CreateServiceInstance(name, planGuid string) (identicalAlreadyExists bool, apiResponse net.ApiResponse)
	RenameService(instance cf.ServiceInstance, newName string) (apiResponse net.ApiResponse)
	DeleteService(instance cf.ServiceInstance) (apiResponse net.ApiResponse)
}

type ServiceSummaryRepository

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

type SortedMessageQueue

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

func NewSortedMessageQueue

func NewSortedMessageQueue(printTimeBuffer time.Duration) *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(stop chan bool) (spacesChan chan []cf.Space, statusChan chan net.ApiResponse)
	FindByName(name string) (space cf.Space, apiResponse net.ApiResponse)
	FindByNameInOrg(name, orgGuid string) (space cf.Space, apiResponse net.ApiResponse)
	Create(name string, orgGuid string) (space cf.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 cf.SpaceFields)

func (SpaceResource) ToModel

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

type StackEntity

type StackEntity struct {
	Name        string
	Description string
}

type StackRepository

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

type StackResource

type StackResource struct {
	Resource
	Entity StackEntity
}

func (StackResource) ToFields

func (resource StackResource) ToFields() (fields cf.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, configRepo configuration.ConfigurationRepository) (uaa UAAAuthenticationRepository)

func (UAAAuthenticationRepository) Authenticate

func (uaa UAAAuthenticationRepository) Authenticate(email string, password string) (apiResponse net.ApiResponse)

func (UAAAuthenticationRepository) RefreshAuthToken

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

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

type UserRepository

type UserRepository interface {
	FindByUsername(username string) (user cf.UserFields, apiResponse net.ApiResponse)
	ListUsersInOrgForRole(orgGuid string, role string, stop chan bool) (usersChan chan []cf.UserFields, statusChan chan net.ApiResponse)
	ListUsersInSpaceForRole(spaceGuid string, role string, stop chan bool) (usersChan chan []cf.UserFields, statusChan chan 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
}

Jump to

Keyboard shortcuts

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