handlers

package
v0.15.1 Latest Latest
Warning

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

 Go to latest Published: Apr 3, 2025 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Overview

nolint:dupl

nolint:dupl

Index

Constants

View Source 
const (
	AppsPath                          = "/v3/apps"
	AppPath                           = "/v3/apps/{guid}"
	AppCurrentDropletRelationshipPath = "/v3/apps/{guid}/relationships/current_droplet"
	AppDropletsPath                   = "/v3/apps/{guid}/droplets"
	AppCurrentDropletPath             = "/v3/apps/{guid}/droplets/current"
	AppProcessesPath                  = "/v3/apps/{guid}/processes"
	AppProcessByTypePath              = "/v3/apps/{guid}/processes/{type}"
	AppProcessStatsByTypePath         = "/v3/apps/{guid}/processes/{type}/stats"
	AppProcessScalePath               = "/v3/apps/{guid}/processes/{processType}/actions/scale"
	AppRoutesPath                     = "/v3/apps/{guid}/routes"
	AppStartPath                      = "/v3/apps/{guid}/actions/start"
	AppStopPath                       = "/v3/apps/{guid}/actions/stop"
	AppRestartPath                    = "/v3/apps/{guid}/actions/restart"
	AppEnvVarsPath                    = "/v3/apps/{guid}/environment_variables"
	AppEnvPath                        = "/v3/apps/{guid}/env"
	AppFeaturePath                    = "/v3/apps/{guid}/features/{name}"
	AppPackagesPath                   = "/v3/apps/{guid}/packages"
	AppSSHEnabledPath                 = "/v3/apps/{guid}/ssh_enabled"
	AppInstanceRestartPath            = "/v3/apps/{guid}/processes/{processType}/instances/{instance}"

	AppStartedState = "STARTED"
	AppStoppedState = "STOPPED"
	AppRevisionKey  = "korifi.cloudfoundry.org/app-rev"
)
View Source 
const (
	BuildPath  = "/v3/builds/{guid}"
	BuildsPath = "/v3/builds"
)
View Source 
const (
	DeploymentsPath = "/v3/deployments"
	DeploymentPath  = "/v3/deployments/{guid}"
)
View Source 
const (
	DomainsPath = "/v3/domains"
	DomainPath  = "/v3/domains/{guid}"
)
View Source 
const (
	JobPath = "/v3/jobs/{guid}"

	AppDeleteJobType                    = "app.delete"
	OrgDeleteJobType                    = "org.delete"
	RouteDeleteJobType                  = "route.delete"
	SpaceDeleteJobType                  = "space.delete"
	DomainDeleteJobType                 = "domain.delete"
	RoleDeleteJobType                   = "role.delete"
	ServiceBrokerCreateJobType          = "service_broker.create"
	ServiceBrokerUpdateJobType          = "service_broker.update"
	ServiceBrokerDeleteJobType          = "service_broker.delete"
	ManagedServiceInstanceDeleteJobType = "managed_service_instance.delete"
	ManagedServiceInstanceCreateJobType = "managed_service_instance.create"
	ManagedServiceBindingCreateJobType  = "managed_service_binding.create"
	ManagedServiceBindingDeleteJobType  = "managed_service_binding.delete"
	JobTimeoutDuration                  = 120.0
)
View Source 
const (
	LogCacheInfoPath = "/api/v1/info"
	LogCacheReadPath = "/api/v1/read/{source-id}"
)
View Source 
const (
	OrgsPath             = "/v3/organizations"
	OrgPath              = "/v3/organizations/{guid}"
	OrgDomainsPath       = "/v3/organizations/{guid}/domains"
	OrgDefaultDomainPath = "/v3/organizations/{guid}/domains/default"
)
View Source 
const (
	PackagePath         = "/v3/packages/{guid}"
	PackagesPath        = "/v3/packages"
	PackageUploadPath   = "/v3/packages/{guid}/upload"
	PackageDropletsPath = "/v3/packages/{guid}/droplets"
)
View Source 
const (
	ProcessPath                = "/v3/processes/{guid}"
	ProcessSidecarsPath        = "/v3/processes/{guid}/sidecars"
	ProcessScalePath           = "/v3/processes/{guid}/actions/scale"
	ProcessStatsPath           = "/v3/processes/{guid}/stats"
	ProcessesPath              = "/v3/processes"
	ProcessInstanceRestartPath = "/v3/processes/{guid}/instances/{instanceID}"
)
View Source 
const (
	RolesPath = "/v3/roles"
	RolePath  = RolesPath + "/{guid}"
)
View Source 
const (
	RoutePath             = "/v3/routes/{guid}"
	RoutesPath            = "/v3/routes"
	RouteDestinationsPath = "/v3/routes/{guid}/destinations"
	RouteDestinationPath  = "/v3/routes/{guid}/destinations/{destination_guid}"
)
View Source 
const (
	ServiceBindingsPath       = "/v3/service_credential_bindings"
	ServiceBindingPath        = "/v3/service_credential_bindings/{guid}"
	ServiceBindingDetailsPath = "/v3/service_credential_bindings/{guid}/details"
	ServiceBindingParamsPath  = "/v3/service_credential_bindings/{guid}/parameters"
)
View Source 
const (
	ServiceBrokersPath = "/v3/service_brokers"
	ServiceBrokerPath  = "/v3/service_brokers/{guid}"
)
View Source 
const (
	ServiceInstancesPath           = "/v3/service_instances"
	ServiceInstancePath            = "/v3/service_instances/{guid}"
	ServiceInstanceCredentialsPath = "/v3/service_instances/{guid}/credentials"
)
View Source 
const (
	ServiceOfferingsPath = "/v3/service_offerings"
	ServiceOfferingPath  = "/v3/service_offerings/{guid}"
)
View Source 
const (
	ServicePlanPath              = "/v3/service_plans/{guid}"
	ServicePlansPath             = "/v3/service_plans"
	ServicePlanVisibilityPath    = "/v3/service_plans/{guid}/visibility"
	ServicePlanVisibilityOrgPath = "/v3/service_plans/{guid}/visibility/{org-guid}"
)
View Source 
const (
	SpacesPath = "/v3/spaces"
	SpacePath  = "/v3/spaces/{guid}"
)
View Source 
const (
	SpaceManifestApplyPath = "/v3/spaces/{spaceGUID}/actions/apply_manifest"
	SpaceManifestDiffPath  = "/v3/spaces/{spaceGUID}/manifest_diff"
)
View Source 
const (
	TasksPath                = "/v3/apps/{appGUID}/tasks"
	TaskRoot                 = "/v3/tasks"
	TaskPath                 = TaskRoot + "/{taskGUID}"
	TaskCancelPath           = TaskRoot + "/{taskGUID}/actions/cancel"
	TaskCancelPathDeprecated = TaskRoot + "/{taskGUID}/cancel"
)
View Source 
const (
	BuildpacksPath = "/v3/buildpacks"
)
View Source 
const (
	DropletPath = "/v3/droplets/{guid}"
)
View Source 
const (
	InfoV3Path = "/v3/info"
)
View Source 
const JobResourceType = "Job"
View Source 
const (
	OAuthTokenPath = "/oauth/token"
)
View Source 
const (
	ResourceMatchesPath = "/v3/resource_matches"
)
View Source 
const (
	RootPath = "/"
)
View Source 
const (
	RootV3Path = "/v3"
)
View Source 
const (
	ServiceRouteBindingsPath = "/v3/service_route_bindings"
)
View Source 
const (
	StacksPath = "/v3/stacks"
)
View Source 
const (
	WhoAmIPath = "/whoami"
)

Variables

This section is empty.

Functions

func NotFound added in v0.7.0 

func NotFound(r *http.Request) (*routing.Response, error)

Types

type App added in v0.6.0 

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

func NewApp added in v0.6.0 

func NewApp(
	serverURL url.URL,
	appRepo CFAppRepository,
	dropletRepo CFDropletRepository,
	processRepo CFProcessRepository,
	routeRepo CFRouteRepository,
	domainRepo CFDomainRepository,
	spaceRepo CFSpaceRepository,
	packageRepo CFPackageRepository,
	requestValidator RequestValidator,
	podRepo PodRepository,
	gaugesCollector GaugesCollector,
	instancesStateCollector InstancesStateCollector,
) *App

func (*App) AuthenticatedRoutes added in v0.6.0 

func (h *App) AuthenticatedRoutes() []routing.Route

func (*App) UnauthenticatedRoutes added in v0.6.0 

func (h *App) UnauthenticatedRoutes() []routing.Route

type Build added in v0.6.0 

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

func NewBuild added in v0.6.0 

func NewBuild(
	serverURL url.URL,
	buildRepo CFBuildRepository,
	packageRepo CFPackageRepository,
	appRepo CFAppRepository,
	requestValidator RequestValidator,
) *Build

func (*Build) AuthenticatedRoutes added in v0.6.0 

func (h *Build) AuthenticatedRoutes() []routing.Route

func (*Build) UnauthenticatedRoutes added in v0.6.0 

func (h *Build) UnauthenticatedRoutes() []routing.Route

type Buildpack added in v0.6.0 

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

func NewBuildpack added in v0.6.0 

func NewBuildpack(
	serverURL url.URL,
	buildpackRepo BuildpackRepository,
	requestValidator RequestValidator,
) *Buildpack

func (*Buildpack) AuthenticatedRoutes added in v0.6.0 

func (h *Buildpack) AuthenticatedRoutes() []routing.Route

func (*Buildpack) UnauthenticatedRoutes added in v0.6.0 

func (h *Buildpack) UnauthenticatedRoutes() []routing.Route

type BuildpackRepository 

type BuildpackRepository interface {
	ListBuildpacks(ctx context.Context, authInfo authorization.Info, message repositories.ListBuildpacksMessage) ([]repositories.BuildpackRecord, error)
}

type CFAppRepository 

type CFAppRepository interface {
	GetApp(context.Context, authorization.Info, string) (repositories.AppRecord, error)
	ListApps(context.Context, authorization.Info, repositories.ListAppsMessage) ([]repositories.AppRecord, error)
	PatchAppEnvVars(context.Context, authorization.Info, repositories.PatchAppEnvVarsMessage) (repositories.AppEnvVarsRecord, error)
	CreateApp(context.Context, authorization.Info, repositories.CreateAppMessage) (repositories.AppRecord, error)
	SetCurrentDroplet(context.Context, authorization.Info, repositories.SetCurrentDropletMessage) (repositories.CurrentDropletRecord, error)
	SetAppDesiredState(context.Context, authorization.Info, repositories.SetAppDesiredStateMessage) (repositories.AppRecord, error)
	DeleteApp(context.Context, authorization.Info, repositories.DeleteAppMessage) error
	GetAppEnv(context.Context, authorization.Info, string) (repositories.AppEnvRecord, error)
	PatchApp(context.Context, authorization.Info, repositories.PatchAppMessage) (repositories.AppRecord, error)
}

type CFBuildRepository 

type CFBuildRepository interface {
	GetBuild(context.Context, authorization.Info, string) (repositories.BuildRecord, error)
	GetLatestBuildByAppGUID(context.Context, authorization.Info, string, string) (repositories.BuildRecord, error)
	CreateBuild(context.Context, authorization.Info, repositories.CreateBuildMessage) (repositories.BuildRecord, error)
}

type CFDeploymentRepository added in v0.8.0 

type CFDeploymentRepository interface {
	GetDeployment(context.Context, authorization.Info, string) (repositories.DeploymentRecord, error)
	CreateDeployment(context.Context, authorization.Info, repositories.CreateDeploymentMessage) (repositories.DeploymentRecord, error)
	ListDeployments(context.Context, authorization.Info, repositories.ListDeploymentsMessage) ([]repositories.DeploymentRecord, error)
}

type CFDomainRepository 

type CFDomainRepository interface {
	GetDomain(context.Context, authorization.Info, string) (repositories.DomainRecord, error)
	CreateDomain(context.Context, authorization.Info, repositories.CreateDomainMessage) (repositories.DomainRecord, error)
	UpdateDomain(context.Context, authorization.Info, repositories.UpdateDomainMessage) (repositories.DomainRecord, error)
	ListDomains(context.Context, authorization.Info, repositories.ListDomainsMessage) ([]repositories.DomainRecord, error)
	DeleteDomain(context.Context, authorization.Info, string) error
}

type CFDropletRepository 

type CFDropletRepository interface {
	GetDroplet(context.Context, authorization.Info, string) (repositories.DropletRecord, error)
	ListDroplets(context.Context, authorization.Info, repositories.ListDropletsMessage) ([]repositories.DropletRecord, error)
	UpdateDroplet(context.Context, authorization.Info, repositories.UpdateDropletMessage) (repositories.DropletRecord, error)
}

type CFOrgRepository 

type CFOrgRepository interface {
	CreateOrg(context.Context, authorization.Info, repositories.CreateOrgMessage) (repositories.OrgRecord, error)
	ListOrgs(context.Context, authorization.Info, repositories.ListOrgsMessage) ([]repositories.OrgRecord, error)
	DeleteOrg(context.Context, authorization.Info, repositories.DeleteOrgMessage) error
	GetOrg(context.Context, authorization.Info, string) (repositories.OrgRecord, error)
	PatchOrg(context.Context, authorization.Info, repositories.PatchOrgMessage) (repositories.OrgRecord, error)
	GetDeletedAt(context.Context, authorization.Info, string) (*time.Time, error)
}

type CFPackageRepository 

type CFPackageRepository interface {
	GetPackage(context.Context, authorization.Info, string) (repositories.PackageRecord, error)
	ListPackages(context.Context, authorization.Info, repositories.ListPackagesMessage) ([]repositories.PackageRecord, error)
	CreatePackage(context.Context, authorization.Info, repositories.CreatePackageMessage) (repositories.PackageRecord, error)
	UpdatePackageSource(context.Context, authorization.Info, repositories.UpdatePackageSourceMessage) (repositories.PackageRecord, error)
	UpdatePackage(context.Context, authorization.Info, repositories.UpdatePackageMessage) (repositories.PackageRecord, error)
}

type CFProcessRepository 

type CFProcessRepository interface {
	GetProcess(context.Context, authorization.Info, string) (repositories.ProcessRecord, error)
	ListProcesses(context.Context, authorization.Info, repositories.ListProcessesMessage) ([]repositories.ProcessRecord, error)
	GetAppRevision(ctx context.Context, authInfo authorization.Info, appGUID string) (string, error)
	PatchProcess(context.Context, authorization.Info, repositories.PatchProcessMessage) (repositories.ProcessRecord, error)
	CreateProcess(context.Context, authorization.Info, repositories.CreateProcessMessage) error
	ScaleProcess(ctx context.Context, authInfo authorization.Info, scaleProcessMessage repositories.ScaleProcessMessage) (repositories.ProcessRecord, error)
}

type CFRoleRepository 

type CFRoleRepository interface {
	CreateRole(context.Context, authorization.Info, repositories.CreateRoleMessage) (repositories.RoleRecord, error)
	ListRoles(context.Context, authorization.Info, repositories.ListRolesMessage) ([]repositories.RoleRecord, error)
	GetRole(context.Context, authorization.Info, string) (repositories.RoleRecord, error)
	DeleteRole(context.Context, authorization.Info, repositories.DeleteRoleMessage) error
}

type CFRouteRepository 

type CFRouteRepository interface {
	GetRoute(context.Context, authorization.Info, string) (repositories.RouteRecord, error)
	ListRoutes(context.Context, authorization.Info, repositories.ListRoutesMessage) ([]repositories.RouteRecord, error)
	ListRoutesForApp(context.Context, authorization.Info, string, string) ([]repositories.RouteRecord, error)
	CreateRoute(context.Context, authorization.Info, repositories.CreateRouteMessage) (repositories.RouteRecord, error)
	DeleteRoute(context.Context, authorization.Info, repositories.DeleteRouteMessage) error
	AddDestinationsToRoute(ctx context.Context, c authorization.Info, message repositories.AddDestinationsMessage) (repositories.RouteRecord, error)
	RemoveDestinationFromRoute(ctx context.Context, authInfo authorization.Info, message repositories.RemoveDestinationMessage) (repositories.RouteRecord, error)
	PatchRouteMetadata(context.Context, authorization.Info, repositories.PatchRouteMetadataMessage) (repositories.RouteRecord, error)
}

type CFServiceBindingRepository 

type CFServiceBindingRepository interface {
	CreateServiceBinding(context.Context, authorization.Info, repositories.CreateServiceBindingMessage) (repositories.ServiceBindingRecord, error)
	DeleteServiceBinding(context.Context, authorization.Info, string) error
	ListServiceBindings(context.Context, authorization.Info, repositories.ListServiceBindingsMessage) ([]repositories.ServiceBindingRecord, error)
	GetServiceBinding(context.Context, authorization.Info, string) (repositories.ServiceBindingRecord, error)
	UpdateServiceBinding(context.Context, authorization.Info, repositories.UpdateServiceBindingMessage) (repositories.ServiceBindingRecord, error)
	GetServiceBindingDetails(context.Context, authorization.Info, string) (repositories.ServiceBindingDetailsRecord, error)
	GetServiceBindingParameters(context.Context, authorization.Info, string) (map[string]any, error)
}

type CFServiceBrokerRepository added in v0.13.0 

type CFServiceBrokerRepository interface {
	CreateServiceBroker(context.Context, authorization.Info, repositories.CreateServiceBrokerMessage) (repositories.ServiceBrokerRecord, error)
	ListServiceBrokers(context.Context, authorization.Info, repositories.ListServiceBrokerMessage) ([]repositories.ServiceBrokerRecord, error)
	GetServiceBroker(context.Context, authorization.Info, string) (repositories.ServiceBrokerRecord, error)
	DeleteServiceBroker(context.Context, authorization.Info, string) error
	UpdateServiceBroker(context.Context, authorization.Info, repositories.UpdateServiceBrokerMessage) (repositories.ServiceBrokerRecord, error)
}

type CFServiceInstanceRepository 

type CFServiceInstanceRepository interface {
	CreateUserProvidedServiceInstance(context.Context, authorization.Info, repositories.CreateUPSIMessage) (repositories.ServiceInstanceRecord, error)
	CreateManagedServiceInstance(context.Context, authorization.Info, repositories.CreateManagedSIMessage) (repositories.ServiceInstanceRecord, error)
	PatchServiceInstance(context.Context, authorization.Info, repositories.PatchServiceInstanceMessage) (repositories.ServiceInstanceRecord, error)
	ListServiceInstances(context.Context, authorization.Info, repositories.ListServiceInstanceMessage) ([]repositories.ServiceInstanceRecord, error)
	GetServiceInstance(context.Context, authorization.Info, string) (repositories.ServiceInstanceRecord, error)
	GetServiceInstanceCredentials(context.Context, authorization.Info, string) (map[string]any, error)
	DeleteServiceInstance(context.Context, authorization.Info, repositories.DeleteServiceInstanceMessage) (repositories.ServiceInstanceRecord, error)
}

type CFServiceOfferingRepository added in v0.13.0 

type CFServiceOfferingRepository interface {
	GetServiceOffering(context.Context, authorization.Info, string) (repositories.ServiceOfferingRecord, error)
	ListOfferings(context.Context, authorization.Info, repositories.ListServiceOfferingMessage) ([]repositories.ServiceOfferingRecord, error)
	DeleteOffering(context.Context, authorization.Info, repositories.DeleteServiceOfferingMessage) error
}

type CFServicePlanRepository added in v0.13.0 

type CFServicePlanRepository interface {
	GetPlan(context.Context, authorization.Info, string) (repositories.ServicePlanRecord, error)
	ListPlans(context.Context, authorization.Info, repositories.ListServicePlanMessage) ([]repositories.ServicePlanRecord, error)
	ApplyPlanVisibility(context.Context, authorization.Info, repositories.ApplyServicePlanVisibilityMessage) (repositories.ServicePlanRecord, error)
	UpdatePlanVisibility(context.Context, authorization.Info, repositories.UpdateServicePlanVisibilityMessage) (repositories.ServicePlanRecord, error)
	DeletePlanVisibility(context.Context, authorization.Info, repositories.DeleteServicePlanVisibilityMessage) error
	DeletePlan(context.Context, authorization.Info, string) error
}

type CFSpaceRepository 

type CFSpaceRepository interface {
	CreateSpace(context.Context, authorization.Info, repositories.CreateSpaceMessage) (repositories.SpaceRecord, error)
	ListSpaces(context.Context, authorization.Info, repositories.ListSpacesMessage) ([]repositories.SpaceRecord, error)
	GetSpace(context.Context, authorization.Info, string) (repositories.SpaceRecord, error)
	DeleteSpace(context.Context, authorization.Info, repositories.DeleteSpaceMessage) error
	PatchSpaceMetadata(context.Context, authorization.Info, repositories.PatchSpaceMetadataMessage) (repositories.SpaceRecord, error)
	GetDeletedAt(context.Context, authorization.Info, string) (*time.Time, error)
}

type CFTaskRepository 

type CFTaskRepository interface {
	CreateTask(context.Context, authorization.Info, repositories.CreateTaskMessage) (repositories.TaskRecord, error)
	GetTask(context.Context, authorization.Info, string) (repositories.TaskRecord, error)
	ListTasks(context.Context, authorization.Info, repositories.ListTaskMessage) ([]repositories.TaskRecord, error)
	CancelTask(context.Context, authorization.Info, string) (repositories.TaskRecord, error)
	PatchTaskMetadata(ctx context.Context, info authorization.Info, message repositories.PatchTaskMetadataMessage) (repositories.TaskRecord, error)
}

type DeletionRepository added in v0.8.0 

type DeletionRepository interface {
	GetDeletedAt(context.Context, authorization.Info, string) (*time.Time, error)
}

type Deployment added in v0.8.0 

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

func NewDeployment added in v0.8.0 

func NewDeployment(
	serverURL url.URL,
	requestValidator RequestValidator,
	deploymentRepo CFDeploymentRepository,
	runnerInfoRepo RunnerInfoRepository,
	runnerName string,
) *Deployment

func (*Deployment) AuthenticatedRoutes added in v0.8.0 

func (h *Deployment) AuthenticatedRoutes() []routing.Route

func (*Deployment) UnauthenticatedRoutes added in v0.8.0 

func (h *Deployment) UnauthenticatedRoutes() []routing.Route

type Domain added in v0.6.0 

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

func NewDomain added in v0.6.0 

func NewDomain(
	serverURL url.URL,
	requestValidator RequestValidator,
	domainRepo CFDomainRepository,
) *Domain

func (*Domain) AuthenticatedRoutes added in v0.6.0 

func (h *Domain) AuthenticatedRoutes() []routing.Route

func (*Domain) UnauthenticatedRoutes added in v0.6.0 

func (h *Domain) UnauthenticatedRoutes() []routing.Route

type Droplet added in v0.6.0 

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

func NewDroplet added in v0.6.0 

func NewDroplet(
	serverURL url.URL,
	dropletRepo CFDropletRepository,
	requestValidator RequestValidator,
) *Droplet

func (*Droplet) AuthenticatedRoutes added in v0.6.0 

func (h *Droplet) AuthenticatedRoutes() []routing.Route

func (*Droplet) UnauthenticatedRoutes added in v0.6.0 

func (h *Droplet) UnauthenticatedRoutes() []routing.Route

type GaugesCollector added in v0.15.0 

type GaugesCollector interface {
	CollectProcessGauges(ctx context.Context, appGUID, processGUID string) ([]stats.ProcessGauges, error)
}

type IdentityProvider 

type IdentityProvider interface {
	GetIdentity(context.Context, authorization.Info) (authorization.Identity, error)
}

type ImageRepository 

type ImageRepository interface {
	UploadSourceImage(ctx context.Context, authInfo authorization.Info, imageRef string, srcReader io.Reader, spaceGUID string, tags ...string) (imageRefWithDigest string, err error)
}

type InfoV3 added in v0.12.0 

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

func NewInfoV3 added in v0.12.0 

func NewInfoV3(baseURL url.URL, infoConfig config.InfoConfig) *InfoV3

func (*InfoV3) AuthenticatedRoutes added in v0.12.0 

func (h *InfoV3) AuthenticatedRoutes() []routing.Route

func (*InfoV3) UnauthenticatedRoutes added in v0.12.0 

func (h *InfoV3) UnauthenticatedRoutes() []routing.Route

type InstancesStateCollector added in v0.15.0 

type InstancesStateCollector interface {
	CollectProcessInstancesStates(ctx context.Context, processGUID string) ([]stats.ProcessInstanceState, error)
}

type Job added in v0.6.0 

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

func NewJob added in v0.6.0 

func NewJob(
	serverURL url.URL,
	deletionRepositories map[string]DeletionRepository,
	stateRepositories map[string]StateRepository,
	pollingInterval time.Duration,
) *Job

func (*Job) AuthenticatedRoutes added in v0.6.0 

func (h *Job) AuthenticatedRoutes() []routing.Route

func (*Job) UnauthenticatedRoutes added in v0.6.0 

func (h *Job) UnauthenticatedRoutes() []routing.Route

type LogCache added in v0.6.0 

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

LogCache implements the minimal set of log-cache API endpoints/features necessary to support the "cf push" workfloh.handlerWrapper.

func NewLogCache added in v0.6.0 

func NewLogCache(
	requestValidator RequestValidator,
	appRepo CFAppRepository,
	buildRepository CFBuildRepository,
	logRepo LogRepository,
	processStats ProcessStats,
) *LogCache

func (*LogCache) AuthenticatedRoutes added in v0.6.0 

func (h *LogCache) AuthenticatedRoutes() []routing.Route

func (*LogCache) UnauthenticatedRoutes added in v0.6.0 

func (h *LogCache) UnauthenticatedRoutes() []routing.Route

type LogRepository added in v0.13.0 

type LogRepository interface {
	GetAppLogs(context.Context, authorization.Info, repositories.GetLogsMessage) ([]repositories.LogRecord, error)
}

type ManifestApplier 

type ManifestApplier interface {
	Apply(ctx context.Context, authInfo authorization.Info, spaceGUID string, manifest payloads.Manifest) error
}

type OAuth added in v0.6.0 

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

func NewOAuth added in v0.6.0 

func NewOAuth(apiBaseURL url.URL) *OAuth

func (*OAuth) AuthenticatedRoutes added in v0.6.0 

func (h *OAuth) AuthenticatedRoutes() []routing.Route

func (*OAuth) UnauthenticatedRoutes added in v0.6.0 

func (h *OAuth) UnauthenticatedRoutes() []routing.Route

type Org added in v0.6.0 

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

func NewOrg added in v0.6.0 

func NewOrg(apiBaseURL url.URL, orgRepo CFOrgRepository, domainRepo CFDomainRepository, requestValidator RequestValidator, userCertificateExpirationWarningDuration time.Duration, defaultDomainName string) *Org

func (*Org) AuthenticatedRoutes added in v0.6.0 

func (h *Org) AuthenticatedRoutes() []routing.Route

func (*Org) UnauthenticatedRoutes added in v0.6.0 

func (h *Org) UnauthenticatedRoutes() []routing.Route

type Package added in v0.6.0 

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

func NewPackage added in v0.6.0 

func NewPackage(
	serverURL url.URL,
	packageRepo CFPackageRepository,
	appRepo CFAppRepository,
	dropletRepo CFDropletRepository,
	imageRepo ImageRepository,
	requestValidator RequestValidator,
	registrySecretNames []string,
) *Package

func (*Package) AuthenticatedRoutes added in v0.6.0 

func (h *Package) AuthenticatedRoutes() []routing.Route

func (*Package) UnauthenticatedRoutes added in v0.6.0 

func (h *Package) UnauthenticatedRoutes() []routing.Route

type PodRepository added in v0.13.0 

type PodRepository interface {
	DeletePod(context.Context, authorization.Info, string, repositories.ProcessRecord, string) error
}

type Process added in v0.6.0 

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

func NewProcess added in v0.6.0 

func NewProcess(
	serverURL url.URL,
	processRepo CFProcessRepository,
	requestValidator RequestValidator,
	podRepo PodRepository,
	gaugesCollector GaugesCollector,
	instancesStateCollector InstancesStateCollector,
) *Process

func (*Process) AuthenticatedRoutes added in v0.6.0 

func (h *Process) AuthenticatedRoutes() []routing.Route

func (*Process) UnauthenticatedRoutes added in v0.6.0 

func (h *Process) UnauthenticatedRoutes() []routing.Route

type ProcessStats added in v0.6.0 

type ProcessStats interface {
	FetchStats(context.Context, authorization.Info, string) ([]actions.PodStatsRecord, error)
	FetchAppProcessesStats(context.Context, authorization.Info, string) ([]actions.PodStatsRecord, error)
}

type RequestValidator added in v0.8.0 

type RequestValidator interface {
	DecodeAndValidateJSONPayload(r *http.Request, object any) error
	DecodeAndValidateURLValues(r *http.Request, payloadObject validation.KeyedPayload) error
	DecodeAndValidateYAMLPayload(r *http.Request, object any) error
}

type ResourceMatches added in v0.6.0 

type ResourceMatches struct{}

func NewResourceMatches added in v0.6.0 

func NewResourceMatches() *ResourceMatches

func (*ResourceMatches) AuthenticatedRoutes added in v0.6.0 

func (h *ResourceMatches) AuthenticatedRoutes() []routing.Route

func (*ResourceMatches) UnauthenticatedRoutes added in v0.6.0 

func (h *ResourceMatches) UnauthenticatedRoutes() []routing.Route

type Role added in v0.6.0 

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

func NewRole added in v0.6.0 

func NewRole(apiBaseURL url.URL, roleRepo CFRoleRepository, requestValidator RequestValidator) *Role

func (*Role) AuthenticatedRoutes added in v0.6.0 

func (h *Role) AuthenticatedRoutes() []routing.Route

func (*Role) UnauthenticatedRoutes added in v0.6.0 

func (h *Role) UnauthenticatedRoutes() []routing.Route

type Root added in v0.6.0 

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

func NewRoot added in v0.6.0 

func NewRoot(baseURL url.URL, uaaConfig config.UAA, logCacheURL url.URL) *Root

func (*Root) AuthenticatedRoutes added in v0.6.0 

func (h *Root) AuthenticatedRoutes() []routing.Route

func (*Root) UnauthenticatedRoutes added in v0.6.0 

func (h *Root) UnauthenticatedRoutes() []routing.Route

type RootV3 added in v0.6.0 

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

func NewRootV3 added in v0.6.0 

func NewRootV3(baseURL url.URL) *RootV3

func (*RootV3) AuthenticatedRoutes added in v0.6.0 

func (h *RootV3) AuthenticatedRoutes() []routing.Route

func (*RootV3) UnauthenticatedRoutes added in v0.6.0 

func (h *RootV3) UnauthenticatedRoutes() []routing.Route

type Route added in v0.6.0 

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

func NewRoute added in v0.6.0 

func NewRoute(
	serverURL url.URL,
	routeRepo CFRouteRepository,
	domainRepo CFDomainRepository,
	appRepo CFAppRepository,
	spaceRepo CFSpaceRepository,
	requestValidator RequestValidator,
) *Route

func (*Route) AuthenticatedRoutes added in v0.6.0 

func (h *Route) AuthenticatedRoutes() []routing.Route

func (*Route) UnauthenticatedRoutes added in v0.6.0 

func (h *Route) UnauthenticatedRoutes() []routing.Route

type RunnerInfoRepository added in v0.8.0 

type RunnerInfoRepository interface {
	GetRunnerInfo(context.Context, authorization.Info, string) (repositories.RunnerInfoRecord, error)
}

type ServiceBinding added in v0.6.0 

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

func NewServiceBinding added in v0.6.0 

func NewServiceBinding(serverURL url.URL, serviceBindingRepo CFServiceBindingRepository, appRepo CFAppRepository, serviceInstanceRepo CFServiceInstanceRepository, requestValidator RequestValidator) *ServiceBinding

func (*ServiceBinding) AuthenticatedRoutes added in v0.6.0 

func (h *ServiceBinding) AuthenticatedRoutes() []routing.Route

func (*ServiceBinding) UnauthenticatedRoutes added in v0.6.0 

func (h *ServiceBinding) UnauthenticatedRoutes() []routing.Route

type ServiceBroker added in v0.13.0 

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

func NewServiceBroker added in v0.13.0 

func NewServiceBroker(
	serverURL url.URL,
	serviceBrokerRepo CFServiceBrokerRepository,
	requestValidator RequestValidator,
) *ServiceBroker

func (*ServiceBroker) AuthenticatedRoutes added in v0.13.0 

func (h *ServiceBroker) AuthenticatedRoutes() []routing.Route

func (*ServiceBroker) UnauthenticatedRoutes added in v0.13.0 

func (h *ServiceBroker) UnauthenticatedRoutes() []routing.Route

type ServiceInstance added in v0.6.0 

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

func NewServiceInstance added in v0.6.0 

func NewServiceInstance(
	serverURL url.URL,
	serviceInstanceRepo CFServiceInstanceRepository,
	spaceRepo CFSpaceRepository,
	requestValidator RequestValidator,
	relationshipRepo include.ResourceRelationshipRepository,
) *ServiceInstance

func (*ServiceInstance) AuthenticatedRoutes added in v0.6.0 

func (h *ServiceInstance) AuthenticatedRoutes() []routing.Route

func (*ServiceInstance) UnauthenticatedRoutes added in v0.6.0 

func (h *ServiceInstance) UnauthenticatedRoutes() []routing.Route

type ServiceOffering added in v0.13.0 

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

func NewServiceOffering added in v0.13.0 

func NewServiceOffering(
	serverURL url.URL,
	requestValidator RequestValidator,
	serviceOfferingRepo CFServiceOfferingRepository,
	serviceBrokerRepo CFServiceBrokerRepository,
	relationshipRepo include.ResourceRelationshipRepository,
) *ServiceOffering

func (*ServiceOffering) AuthenticatedRoutes added in v0.13.0 

func (h *ServiceOffering) AuthenticatedRoutes() []routing.Route

func (*ServiceOffering) UnauthenticatedRoutes added in v0.13.0 

func (h *ServiceOffering) UnauthenticatedRoutes() []routing.Route

type ServicePlan added in v0.13.0 

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

func NewServicePlan added in v0.13.0 

func NewServicePlan(
	serverURL url.URL,
	requestValidator RequestValidator,
	servicePlanRepo CFServicePlanRepository,
	relationshipRepo include.ResourceRelationshipRepository,
) *ServicePlan

func (*ServicePlan) AuthenticatedRoutes added in v0.13.0 

func (h *ServicePlan) AuthenticatedRoutes() []routing.Route

func (*ServicePlan) UnauthenticatedRoutes added in v0.13.0 

func (h *ServicePlan) UnauthenticatedRoutes() []routing.Route

type ServiceRouteBinding added in v0.6.0 

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

func NewServiceRouteBinding added in v0.6.0 

func NewServiceRouteBinding(
	serverURL url.URL,
) *ServiceRouteBinding

func (*ServiceRouteBinding) AuthenticatedRoutes added in v0.6.0 

func (h *ServiceRouteBinding) AuthenticatedRoutes() []routing.Route

func (*ServiceRouteBinding) UnauthenticatedRoutes added in v0.6.0 

func (h *ServiceRouteBinding) UnauthenticatedRoutes() []routing.Route

type Space added in v0.6.0 

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

func NewSpace added in v0.6.0 

func NewSpace(apiBaseURL url.URL, spaceRepo CFSpaceRepository, requestValidator RequestValidator) *Space

func (*Space) AuthenticatedRoutes added in v0.6.0 

func (h *Space) AuthenticatedRoutes() []routing.Route

func (*Space) UnauthenticatedRoutes added in v0.6.0 

func (h *Space) UnauthenticatedRoutes() []routing.Route

type SpaceManifest added in v0.6.0 

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

func NewSpaceManifest added in v0.6.0 

func NewSpaceManifest(
	serverURL url.URL,
	manifestApplier ManifestApplier,
	spaceRepo CFSpaceRepository,
	requestValidator RequestValidator,
) *SpaceManifest

func (*SpaceManifest) AuthenticatedRoutes added in v0.6.0 

func (h *SpaceManifest) AuthenticatedRoutes() []routing.Route

func (*SpaceManifest) UnauthenticatedRoutes added in v0.6.0 

func (h *SpaceManifest) UnauthenticatedRoutes() []routing.Route

type Stack added in v0.14.0 

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

func NewStack added in v0.14.0 

func NewStack(
	serverURL url.URL,
	stackRepo StackRepository,
) *Stack

func (*Stack) AuthenticatedRoutes added in v0.14.0 

func (h *Stack) AuthenticatedRoutes() []routing.Route

func (*Stack) UnauthenticatedRoutes added in v0.14.0 

func (h *Stack) UnauthenticatedRoutes() []routing.Route

type StackRepository added in v0.14.0 

type StackRepository interface {
	ListStacks(ctx context.Context, authInfo authorization.Info) ([]repositories.StackRecord, error)
}

type StateRepository added in v0.13.0 

type StateRepository interface {
	GetState(context.Context, authorization.Info, string) (repositories.ResourceState, error)
}

type Task added in v0.6.0 

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

func NewTask added in v0.6.0 

func NewTask(
	serverURL url.URL,
	appRepo CFAppRepository,
	taskRepo CFTaskRepository,
	requestValidator RequestValidator,
) *Task

func (*Task) AuthenticatedRoutes added in v0.6.0 

func (h *Task) AuthenticatedRoutes() []routing.Route

func (*Task) UnauthenticatedRoutes added in v0.6.0 

func (h *Task) UnauthenticatedRoutes() []routing.Route

type User added in v0.7.0 

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

func NewUser added in v0.7.0 

func NewUser(apiBaseURL url.URL) User

func (User) AuthenticatedRoutes added in v0.7.0 

func (h User) AuthenticatedRoutes() []routing.Route

func (User) UnauthenticatedRoutes added in v0.7.0 

func (h User) UnauthenticatedRoutes() []routing.Route

type WhoAmI added in v0.6.0 

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

func NewWhoAmI 

func NewWhoAmI(identityProvider IdentityProvider, apiBaseURL url.URL) *WhoAmI

func (*WhoAmI) AuthenticatedRoutes added in v0.6.0 

func (h *WhoAmI) AuthenticatedRoutes() []routing.Route

func (*WhoAmI) UnauthenticatedRoutes added in v0.6.0 

func (h *WhoAmI) UnauthenticatedRoutes() []routing.Route

Source Files

View all Source files

Directories

Path Synopsis
Code generated by counterfeiter.
 Code generated by counterfeiter.
fake
Code generated by counterfeiter.
 Code generated by counterfeiter.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.