handlers

package
v0.11.0 Latest Latest
Warning

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

Go to latest
Published: Jan 23, 2024 License: Apache-2.0 Imports: 24 Imported by: 0

Documentation

Index

Constants

View Source
const (
	AppsPath                          = "/v3/apps"
	AppPath                           = "/v3/apps/{guid}"
	AppCurrentDropletRelationshipPath = "/v3/apps/{guid}/relationships/current_droplet"
	AppCurrentDropletPath             = "/v3/apps/{guid}/droplets/current"
	AppProcessesPath                  = "/v3/apps/{guid}/processes"
	AppProcessByTypePath              = "/v3/apps/{guid}/processes/{type}"
	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"
	AppPackagesPath                   = "/v3/apps/{guid}/packages"
	AppSSHEnabledPath                 = "/v3/apps/{guid}/ssh_enabled"

	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"

	JobTimeoutDuration = 120.0
)
View Source
const (
	LogCacheInfoPath = "/api/v1/info"
	LogCacheReadPath = "/api/v1/read/{guid}"
)
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"
)
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}"
)
View Source
const (
	ServiceInstancesPath = "/v3/service_instances"
	ServiceInstancePath  = "/v3/service_instances/{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 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 (
	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,
) *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 AppLogsReader

type AppLogsReader interface {
	Read(ctx context.Context, logger logr.Logger, authInfo authorization.Info, appGUID string, read payloads.LogRead) ([]repositories.LogRecord, error)
}

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) ([]repositories.BuildpackRecord, 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 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 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, repositories map[string]DeletionRepository, 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(
	appRepo CFAppRepository,
	buildRepository CFBuildRepository,
	appLogsReader AppLogsReader,
	requestValidator RequestValidator,
) *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 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 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,
	processStatsFetcher ProcessStats,
	requestValidator RequestValidator,
) *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)
}

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) *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 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,
) *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 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 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

Directories

Path Synopsis
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