repositories

package

Go to main page

Versions in this module

v0

v0.11.0

Jan 23, 2024

v0.10.0

Oct 30, 2023

v0.9.0

Sep 28, 2023

Changes in this version

type CreatePackageMessage

+ Data *PackageData

type DropletRecord

+ Image string

+ Ports []int32

type LifecyclePatch

+ Type *string

type ListAppsMessage

+ LabelSelector string

type ListServiceBindingsMessage

+ LabelSelector string

type ListServiceInstanceMessage

+ GUIDs []string

+ LabelSelector string

+ SpaceGUIDs []string

+ type PackageData struct

+ Image string

+ Password *string

+ Username *string

v0.8.1

Jul 19, 2023

v0.8.0

Jul 17, 2023

Changes in this version

+ const DeploymentResourceType

+ const RunnerInfoResourceType

+ func AlwaysTrue(_ T) bool

+ func Filter(resources []T, predicate ...func(T) bool) []T

+ func SetPredicate(elements []T, mapFn func(S) T) func(S) bool

type AppRecord

+ DeletedAt *time.Time

type AppRepo

+ func (f *AppRepo) GetDeletedAt(ctx context.Context, authInfo authorization.Info, appGUID string) (*time.Time, error)

+ type CreateDeploymentMessage struct

+ AppGUID string

+ DropletGUID string

+ type DeploymentRecord struct

+ CreatedAt time.Time

+ DropletGUID string

+ GUID string

+ Status DeploymentStatus

+ UpdatedAt *time.Time

+ type DeploymentRepo struct

+ func NewDeploymentRepo(userClientFactory authorization.UserK8sClientFactory, ...) *DeploymentRepo

+ func (r *DeploymentRepo) CreateDeployment(ctx context.Context, authInfo authorization.Info, ...) (DeploymentRecord, error)

+ func (r *DeploymentRepo) GetDeployment(ctx context.Context, authInfo authorization.Info, deploymentGUID string) (DeploymentRecord, error)

+ type DeploymentStatus struct

+ Reason DeploymentStatusReason

+ Value DeploymentStatusValue

+ type DeploymentStatusReason string

+ const DeploymentStatusReasonDeployed

+ const DeploymentStatusReasonDeploying

+ type DeploymentStatusValue string

+ const DeploymentStatusValueActive

+ const DeploymentStatusValueFinalized

type DomainRecord

+ DeletedAt *time.Time

type DomainRepo

+ func (r *DomainRepo) GetDeletedAt(ctx context.Context, authInfo authorization.Info, domainGUID string) (*time.Time, error)

+ type LifecycleDataPatch struct

+ Buildpacks *[]string

+ Stack string

+ type LifecyclePatch struct

+ Data *LifecycleDataPatch

type OrgRecord

+ DeletedAt *time.Time

type OrgRepo

+ func (r *OrgRepo) GetDeletedAt(ctx context.Context, authInfo authorization.Info, orgGUID string) (*time.Time, error)

type RoleRecord

+ DeletedAt *time.Time

type RoleRepo

+ func (r *RoleRepo) GetDeletedAt(ctx context.Context, authInfo authorization.Info, roleGUID string) (*time.Time, error)

type RouteRecord

+ DeletedAt *time.Time

type RouteRepo

+ func (r *RouteRepo) GetDeletedAt(ctx context.Context, authInfo authorization.Info, routeGUID string) (*time.Time, error)

+ type RunnerInfoRecord struct

+ Capabilities korifiv1alpha1.RunnerInfoCapabilities

+ Name string

+ Namespace string

+ RunnerName string

+ type RunnerInfoRepository struct

+ func NewRunnerInfoRepository(userClientFactory authorization.UserK8sClientFactory, runnerName string, ...) *RunnerInfoRepository

+ func (r *RunnerInfoRepository) GetRunnerInfo(ctx context.Context, authInfo authorization.Info, runnerName string) (RunnerInfoRecord, error)

+ type Set map[T]struct

+ func NewSet(elements ...T) Set[T]

+ func (s Set[T]) Includes(element T) bool

type SpaceRecord

+ DeletedAt *time.Time

type SpaceRepo

+ func (r *SpaceRepo) GetDeletedAt(ctx context.Context, authInfo authorization.Info, spaceGUID string) (*time.Time, error)

type TaskRecord

+ CreatedAt time.Time

+ UpdatedAt *time.Time

type UpdatePackageSourceMessage

+ RegistrySecretNames []string

v0.7.1

Mar 30, 2023

v0.7.0

Mar 27, 2023

Changes in this version

type AppEnvRecord

+ AppEnv map[string]interface{}

type CreateRoleMessage

+ ServiceAccountNamespace string

+ type DeleteRoleMessage struct

+ GUID string

+ Org string

+ Space string

type DropletRepo

+ func (r *DropletRepo) UpdateDroplet(ctx context.Context, authInfo authorization.Info, message UpdateDropletMessage) (DropletRecord, error)

type PatchAppMessage

+ func (m *PatchAppMessage) Apply(app *korifiv1alpha1.CFApp)

+ type PatchServiceInstanceMessage struct

+ Credentials *map[string]string

+ GUID string

+ Name *string

+ SpaceGUID string

+ Tags *[]string

+ func (p PatchServiceInstanceMessage) Apply(cfServiceInstance *korifiv1alpha1.CFServiceInstance)

+ type PatchTaskMetadataMessage struct

+ SpaceGUID string

+ TaskGUID string

type RoleRepo

+ func (r *RoleRepo) DeleteRole(ctx context.Context, authInfo authorization.Info, deleteMsg DeleteRoleMessage) error

+ func (r *RoleRepo) GetRole(ctx context.Context, authInfo authorization.Info, roleGUID string) (RoleRecord, error)

+ func (r *RoleRepo) ListRoles(ctx context.Context, authInfo authorization.Info) ([]RoleRecord, error)

type ServiceBindingRecord

+ Annotations map[string]string

+ Labels map[string]string

type ServiceBindingRepo

+ func (r *ServiceBindingRepo) GetServiceBinding(ctx context.Context, authInfo authorization.Info, guid string) (ServiceBindingRecord, error)

+ func (r *ServiceBindingRepo) UpdateServiceBinding(ctx context.Context, authInfo authorization.Info, ...) (ServiceBindingRecord, error)

type ServiceInstanceRecord

+ Annotations map[string]string

+ Labels map[string]string

type ServiceInstanceRepo

+ func (r *ServiceInstanceRepo) PatchServiceInstance(ctx context.Context, authInfo authorization.Info, ...) (ServiceInstanceRecord, error)

type TaskRecord

+ Annotations map[string]string

+ Labels map[string]string

+ SpaceGUID string

type TaskRepo

+ func (r *TaskRepo) PatchTaskMetadata(ctx context.Context, authInfo authorization.Info, ...) (TaskRecord, error)

+ type UpdateDropletMessage struct

+ GUID string

+ MetadataPatch MetadataPatch

+ type UpdateServiceBindingMessage struct

+ GUID string

+ MetadataPatch MetadataPatch

v0.6.0

Jan 23, 2023

Changes in this version

+ const PodResourceType

+ type MetricsRepo struct

+ func NewMetricsRepo(userClientFactory authorization.UserK8sClientFactory) *MetricsRepo

+ func (r *MetricsRepo) GetMetrics(ctx context.Context, authInfo authorization.Info, namespace string, ...) ([]PodMetrics, error)

+ type PodMetrics struct

+ Metrics metricsv1beta1.PodMetrics

+ Pod corev1.Pod

v0.5.0

Dec 20, 2022

Changes in this version

type BuildRecord

+ ImageRef string

+ type CreateDomainMessage struct

+ Metadata Metadata

+ Name string

type CreatePackageMessage

+ Metadata Metadata

type DomainRepo

+ func (r *DomainRepo) CreateDomain(ctx context.Context, authInfo authorization.Info, message CreateDomainMessage) (DomainRecord, error)

+ func (r *DomainRepo) DeleteDomain(ctx context.Context, authInfo authorization.Info, domainGUID string) error

+ func (r *DomainRepo) UpdateDomain(ctx context.Context, authInfo authorization.Info, message UpdateDomainMessage) (DomainRecord, error)

+ type Metadata struct

+ Annotations map[string]string

+ Labels map[string]string

type MetadataPatch

+ func (p *MetadataPatch) Apply(obj client.Object)

type PackageRecord

+ Annotations map[string]string

+ ImageRef string

+ Labels map[string]string

type PackageRepo

+ func (r *PackageRepo) UpdatePackage(ctx context.Context, authInfo authorization.Info, ...) (PackageRecord, error)

type PatchProcessMessage

+ MetadataPatch *MetadataPatch

+ type PatchRouteMetadataMessage struct

+ RouteGUID string

+ SpaceGUID string

+ type RepositoryCreator interface

+ CreateRepository func(ctx context.Context, name string) error

type RouteRepo

+ func (f *RouteRepo) PatchRouteMetadata(ctx context.Context, authInfo authorization.Info, ...) (RouteRecord, error)

+ type UpdateDomainMessage struct

+ GUID string

+ MetadataPatch MetadataPatch

+ type UpdatePackageMessage struct

+ GUID string

+ MetadataPatch MetadataPatch

v0.4.0

Oct 25, 2022

Changes in this version

type AppRepo

+ func (f *AppRepo) PatchApp(ctx context.Context, authInfo authorization.Info, ...) (AppRecord, error)

+ type PatchAppMessage struct

+ Annotations map[string]string

+ AppGUID string

+ EnvironmentVariables map[string]string

+ Labels map[string]string

+ Lifecycle Lifecycle

+ Name string

+ SpaceGUID string

+ State DesiredState

v0.3.0

Sep 28, 2022

Changes in this version

+ const BuildWorkloadLabelKey

type AppRepo

+ func (f *AppRepo) PatchAppMetadata(ctx context.Context, authInfo authorization.Info, ...) (AppRecord, error)

+ type MetadataPatch struct

+ Annotations map[string]*string

+ Labels map[string]*string

type NamespaceRetriever

+ func NewNamespaceRetriever(client dynamic.Interface) NamespaceRetriever

type OrgRepo

+ func (r *OrgRepo) PatchOrgMetadata(ctx context.Context, authInfo authorization.Info, ...) (OrgRecord, error)

+ type PatchAppMetadataMessage struct

+ AppGUID string

+ SpaceGUID string

+ type PatchOrgMetadataMessage struct

+ GUID string

+ type PatchSpaceMetadataMessage struct

+ GUID string

+ OrgGUID string

type SpaceRepo

+ func (r *SpaceRepo) PatchSpaceMetadata(ctx context.Context, authInfo authorization.Info, ...) (SpaceRecord, error)

v0.2.0

Aug 2, 2022

Changes in this version

+ const ApplicationContainerName

+ const BuildpackResourceType

+ const EnvCFInstanceIndex

+ const ImageLabel

+ const LabelGUID

+ const LabelVersion

+ const TaskResourceType

+ const TaskStateCanceling

+ const TaskStateFailed

+ const TaskStatePending

+ const TaskStateRunning

+ const TaskStateSucceeded

+ const VCAPServicesSecretAvailableCondition

+ var CFTasksGVR = schema.GroupVersionResource

+ type AppEnvRecord struct

+ AppGUID string

+ EnvironmentVariables map[string]string

+ SpaceGUID string

+ SystemEnv map[string]interface{}

type AppRecord

+ IsStaged bool

+ type BuildLogsClient struct

+ func NewBuildLogsClient(k8sClient k8sclient.Interface) *BuildLogsClient

+ func (c *BuildLogsClient) GetImageLogs(ctx context.Context, writer io.Writer, image, namespace string) error

type BuildpackRepository

+ func (r *BuildpackRepository) ListBuildpacks(ctx context.Context, authInfo authorization.Info) ([]BuildpackRecord, error)

+ type ConditionAwaiter interface

+ AwaitCondition func(ctx context.Context, userClient client.WithWatch, object client.Object, ...) (T, error)

+ type CreateTaskMessage struct

+ AppGUID string

+ Command string

+ SpaceGUID string

+ type ListTaskMessage struct

+ AppGUIDs []string

+ SequenceIDs []int64

type LogRecord

+ Header string

+ Tags map[string]string

+ type TaskRecord struct

+ AppGUID string

+ Command string

+ CreationTimestamp time.Time

+ DiskMB int64

+ DropletGUID string

+ FailureReason string

+ GUID string

+ MemoryMB int64

+ Name string

+ SequenceID int64

+ State string

+ type TaskRepo struct

+ func NewTaskRepo(userClientFactory authorization.UserK8sClientFactory, ...) *TaskRepo

+ func (r *TaskRepo) CancelTask(ctx context.Context, authInfo authorization.Info, taskGUID string) (TaskRecord, error)

+ func (r *TaskRepo) CreateTask(ctx context.Context, authInfo authorization.Info, ...) (TaskRecord, error)

+ func (r *TaskRepo) GetTask(ctx context.Context, authInfo authorization.Info, taskGUID string) (TaskRecord, error)

+ func (r *TaskRepo) ListTasks(ctx context.Context, authInfo authorization.Info, msg ListTaskMessage) ([]TaskRecord, error)

v0.1.0

May 24, 2022

Changes in this version

+ const APIVersion

+ const AppEnvResourceType

+ const AppResourceType

+ const BuildResourceType

+ const BuildStateFailed

+ const BuildStateStaged

+ const BuildStateStaging

+ const CFAppGUIDLabel

+ const CFServiceInstanceGUIDLabel

+ const DomainResourceType

+ const DropletResourceType

+ const Kind

+ const LabelServiceBindingProvisionedService

+ const OrgNameLabel

+ const OrgPrefix

+ const OrgResourceType

+ const PackageResourceType

+ const PackageStateAwaitingUpload

+ const PackageStateReady

+ const PodMetricsResourceType

+ const ProcessResourceType

+ const ProcessStatsResourceType

+ const RoleGuidLabel

+ const RoleResourceType

+ const RoutePrefix

+ const RouteResourceType

+ const RunningState

+ const ServiceBindingResourceType

+ const ServiceBindingTypeApp

+ const ServiceInstanceResourceType

+ const SourceImageResourceType

+ const SpaceNameLabel

+ const SpacePrefix

+ const SpaceResourceType

+ const StagingConditionType

+ const StartedState

+ const StatusConditionReady

+ const StoppedState

+ const SucceededConditionType

+ const TimestampFormat

+ var CFAppsGVR = schema.GroupVersionResource

+ var CFBuildsGVR = schema.GroupVersionResource

+ var CFDomainsGVR = schema.GroupVersionResource

+ var CFDropletsGVR = schema.GroupVersionResource

+ var CFPackagesGVR = schema.GroupVersionResource

+ var CFProcessesGVR = schema.GroupVersionResource

+ var CFRoutesGVR = schema.GroupVersionResource

+ var CFServiceBindingsGVR = schema.GroupVersionResource

+ var CFServiceInstancesGVR = schema.GroupVersionResource

+ var CFSpacesGVR = schema.GroupVersionResource

+ var ResourceMap = map[string]schema.GroupVersionResource

+ func GenerateEnvSecretName(appGUID string) string

+ func GenerateProcessGUID() string

+ type AddDestinationsToRouteMessage struct

+ ExistingDestinations []DestinationRecord

+ NewDestinations []DestinationMessage

+ RouteGUID string

+ SpaceGUID string

+ type AppEnvVarsRecord struct

+ AppGUID string

+ EnvironmentVariables map[string]string

+ Name string

+ SpaceGUID string

+ type AppRecord struct

+ Annotations map[string]string

+ CreatedAt string

+ DropletGUID string

+ EtcdUID types.UID

+ GUID string

+ Labels map[string]string

+ Lifecycle Lifecycle

+ Name string

+ Revision string

+ SpaceGUID string

+ State DesiredState

+ UpdatedAt string

+ type AppRepo struct

+ func NewAppRepo(namespaceRetriever NamespaceRetriever, ...) *AppRepo

+ func (f *AppRepo) CreateApp(ctx context.Context, authInfo authorization.Info, ...) (AppRecord, error)

+ func (f *AppRepo) CreateOrPatchAppEnvVars(ctx context.Context, authInfo authorization.Info, ...) (AppEnvVarsRecord, error)

+ func (f *AppRepo) DeleteApp(ctx context.Context, authInfo authorization.Info, message DeleteAppMessage) error

+ func (f *AppRepo) GetApp(ctx context.Context, authInfo authorization.Info, appGUID string) (AppRecord, error)

+ func (f *AppRepo) GetAppByNameAndSpace(ctx context.Context, authInfo authorization.Info, appName string, ...) (AppRecord, error)

+ func (f *AppRepo) GetAppEnv(ctx context.Context, authInfo authorization.Info, appGUID string) (map[string]string, error)

+ func (f *AppRepo) ListApps(ctx context.Context, authInfo authorization.Info, message ListAppsMessage) ([]AppRecord, error)

+ func (f *AppRepo) PatchAppEnvVars(ctx context.Context, authInfo authorization.Info, ...) (AppEnvVarsRecord, error)

+ func (f *AppRepo) SetAppDesiredState(ctx context.Context, authInfo authorization.Info, ...) (AppRecord, error)

+ func (f *AppRepo) SetCurrentDroplet(ctx context.Context, authInfo authorization.Info, ...) (CurrentDropletRecord, error)

+ type AuthorizedInChecker interface

+ AuthorizedIn func(ctx context.Context, identity authorization.Identity, namespace string) (bool, error)

+ type BuildRecord struct

+ Annotations map[string]string

+ AppGUID string

+ CreatedAt string

+ DropletGUID string

+ GUID string

+ Labels map[string]string

+ Lifecycle Lifecycle

+ PackageGUID string

+ StagingDiskMB int

+ StagingErrorMsg string

+ StagingMemoryMB int

+ State string

+ UpdatedAt string

+ type BuildRepo struct

+ func NewBuildRepo(namespaceRetriever NamespaceRetriever, ...) *BuildRepo

+ func (b *BuildRepo) CreateBuild(ctx context.Context, authInfo authorization.Info, message CreateBuildMessage) (BuildRecord, error)

+ func (b *BuildRepo) GetBuild(ctx context.Context, authInfo authorization.Info, buildGUID string) (BuildRecord, error)

+ func (b *BuildRepo) GetBuildLogs(ctx context.Context, authInfo authorization.Info, spaceGUID string, ...) ([]LogRecord, error)

+ func (b *BuildRepo) GetLatestBuildByAppGUID(ctx context.Context, authInfo authorization.Info, spaceGUID string, ...) (BuildRecord, error)

+ type BuildpackRecord struct

+ CreatedAt string

+ Name string

+ Position int

+ Stack string

+ UpdatedAt string

+ Version string

+ type BuildpackRepository struct

+ func NewBuildpackRepository(userClientFactory authorization.UserK8sClientFactory) *BuildpackRepository

+ func (r *BuildpackRepository) GetBuildpacksForBuilder(ctx context.Context, authInfo authorization.Info, builderName string) ([]BuildpackRecord, error)

+ type CreateAppMessage struct

+ Annotations map[string]string

+ EnvironmentVariables map[string]string

+ Labels map[string]string

+ Lifecycle Lifecycle

+ Name string

+ SpaceGUID string

+ State DesiredState

+ type CreateBuildMessage struct

+ Annotations map[string]string

+ AppGUID string

+ Labels map[string]string

+ Lifecycle Lifecycle

+ OwnerRef metav1.OwnerReference

+ PackageGUID string

+ SpaceGUID string

+ StagingDiskMB int

+ StagingMemoryMB int

+ type CreateOrPatchAppEnvVarsMessage struct

+ AppEtcdUID types.UID

+ AppGUID string

+ EnvironmentVariables map[string]string

+ SpaceGUID string

+ type CreateOrgMessage struct

+ Annotations map[string]string

+ Labels map[string]string

+ Name string

+ Suspended bool

+ type CreatePackageMessage struct

+ AppGUID string

+ OwnerRef metav1.OwnerReference

+ SpaceGUID string

+ Type string

+ type CreateProcessMessage struct

+ AppGUID string

+ Command string

+ DesiredInstances int

+ DiskQuotaMB int64

+ HealthCheck HealthCheck

+ MemoryMB int64

+ SpaceGUID string

+ Type string

+ type CreateRoleMessage struct

+ GUID string

+ Kind string

+ Org string

+ Space string

+ Type string

+ User string

+ type CreateRouteMessage struct

+ Annotations map[string]string

+ DomainGUID string

+ DomainName string

+ DomainNamespace string

+ Host string

+ Labels map[string]string

+ Path string

+ SpaceGUID string

+ type CreateServiceBindingMessage struct

+ AppGUID string

+ Name *string

+ ServiceInstanceGUID string

+ SpaceGUID string

+ type CreateServiceInstanceMessage struct

+ Annotations map[string]string

+ Credentials map[string]string

+ Labels map[string]string

+ Name string

+ SpaceGUID string

+ Tags []string

+ Type string

+ type CreateSpaceMessage struct

+ ImageRegistryCredentials string

+ Name string

+ OrganizationGUID string

+ type CurrentDropletRecord struct

+ AppGUID string

+ DropletGUID string

+ type DeleteAppMessage struct

+ AppGUID string

+ SpaceGUID string

+ type DeleteOrgMessage struct

+ GUID string

+ type DeleteRouteMessage struct

+ GUID string

+ SpaceGUID string

+ type DeleteServiceBindingMessage struct

+ GUID string

+ type DeleteServiceInstanceMessage struct

+ GUID string

+ SpaceGUID string

+ type DeleteSpaceMessage struct

+ GUID string

+ OrganizationGUID string

+ type DesiredState string

+ type DestinationMessage struct

+ AppGUID string

+ Port int

+ ProcessType string

+ Protocol string

+ type DestinationRecord struct

+ AppGUID string

+ GUID string

+ Port int

+ ProcessType string

+ Protocol string

+ type DomainRecord struct

+ Annotations map[string]string

+ CreatedAt string

+ GUID string

+ Labels map[string]string

+ Name string

+ Namespace string

+ UpdatedAt string

+ type DomainRepo struct

+ func NewDomainRepo(userClientFactory authorization.UserK8sClientFactory, ...) *DomainRepo

+ func (r *DomainRepo) GetDomain(ctx context.Context, authInfo authorization.Info, domainGUID string) (DomainRecord, error)

+ func (r *DomainRepo) GetDomainByName(ctx context.Context, authInfo authorization.Info, domainName string) (DomainRecord, error)

+ func (r *DomainRepo) ListDomains(ctx context.Context, authInfo authorization.Info, message ListDomainsMessage) ([]DomainRecord, error)

+ type DropletRecord struct

+ Annotations map[string]string

+ AppGUID string

+ CreatedAt string

+ DropletErrorMsg string

+ GUID string

+ Labels map[string]string

+ Lifecycle Lifecycle

+ PackageGUID string

+ ProcessTypes map[string]string

+ Stack string

+ State string

+ UpdatedAt string

+ type DropletRepo struct

+ func NewDropletRepo(userClientFactory authorization.UserK8sClientFactory, ...) *DropletRepo

+ func (r *DropletRepo) GetDroplet(ctx context.Context, authInfo authorization.Info, dropletGUID string) (DropletRecord, error)

+ func (r *DropletRepo) ListDroplets(ctx context.Context, authInfo authorization.Info, message ListDropletsMessage) ([]DropletRecord, error)

+ type HealthCheck struct

+ Data HealthCheckData

+ Type string

+ type HealthCheckData struct

+ HTTPEndpoint string

+ InvocationTimeoutSeconds int64

+ TimeoutSeconds int64

+ type ImageBuilder interface

+ Build func(ctx context.Context, srcReader io.Reader) (registryv1.Image, error)

+ type ImagePusher interface

+ Push func(ctx context.Context, imageRef string, image registryv1.Image, ...) (string, error)

+ type ImageRepository struct

+ func NewImageRepository(privilegedK8sClient k8sclient.Interface, ...) *ImageRepository

+ func (r *ImageRepository) UploadSourceImage(ctx context.Context, authInfo authorization.Info, imageRef string, ...) (string, error)

+ type Lifecycle struct

+ Data LifecycleData

+ Type string

+ type LifecycleData struct

+ Buildpacks []string

+ Stack string

+ type ListAppsMessage struct

+ Guids []string

+ Names []string

+ SpaceGuids []string

+ type ListBuildpacksMessage struct

+ OrderBy []string

+ type ListDomainsMessage struct

+ Names []string

+ type ListDropletsMessage struct

+ PackageGUIDs []string

+ type ListOrgsMessage struct

+ GUIDs []string

+ Names []string

+ type ListPackagesMessage struct

+ AppGUIDs []string

+ DescendingOrder bool

+ SortBy string

+ States []string

+ type ListPodStatsMessage struct

+ AppGUID string

+ AppRevision string

+ Instances int

+ Namespace string

+ ProcessGUID string

+ ProcessType string

+ type ListProcessesMessage struct

+ AppGUIDs []string

+ SpaceGUID string

+ type ListRoutesMessage struct

+ AppGUIDs []string

+ DomainGUIDs []string

+ Hosts []string

+ Paths []string

+ SpaceGUIDs []string

+ type ListServiceBindingsMessage struct

+ AppGUIDs []string

+ ServiceInstanceGUIDs []string

+ type ListServiceInstanceMessage struct

+ DescendingOrder bool

+ Names []string

+ OrderBy string

+ SpaceGuids []string

+ type ListSpacesMessage struct

+ GUIDs []string

+ Names []string

+ OrganizationGUIDs []string

+ type LogRecord struct

+ Message string

+ Timestamp int64

+ type MetricsFetcherFn func(ctx context.Context, namespace, name string) (*metricsv1beta1.PodMetrics, error)

+ func CreateMetricsFetcher(k8sClientConfig *rest.Config) (MetricsFetcherFn, error)

+ type NamespaceGetter interface

+ GetNamespaceForServiceInstance func(ctx context.Context, guid string) (string, error)

+ type NamespaceRetriever struct

+ func NewNamespaceRetriver(client dynamic.Interface) NamespaceRetriever

+ func (nr NamespaceRetriever) NamespaceFor(ctx context.Context, resourceGUID, resourceType string) (string, error)

+ type OrgRecord struct

+ Annotations map[string]string

+ CreatedAt time.Time

+ GUID string

+ Labels map[string]string

+ Name string

+ Suspended bool

+ UpdatedAt time.Time

+ type OrgRepo struct

+ func NewOrgRepo(rootNamespace string, privilegedClient client.WithWatch, ...) *OrgRepo

+ func (r *OrgRepo) CreateOrg(ctx context.Context, info authorization.Info, message CreateOrgMessage) (OrgRecord, error)

+ func (r *OrgRepo) DeleteOrg(ctx context.Context, info authorization.Info, message DeleteOrgMessage) error

+ func (r *OrgRepo) GetOrg(ctx context.Context, info authorization.Info, orgGUID string) (OrgRecord, error)

+ func (r *OrgRepo) ListOrgs(ctx context.Context, info authorization.Info, filter ListOrgsMessage) ([]OrgRecord, error)

+ type PackageRecord struct

+ AppGUID string

+ CreatedAt string

+ GUID string

+ SpaceGUID string

+ State string

+ Type string

+ UID types.UID

+ UpdatedAt string

+ type PackageRepo struct

+ func NewPackageRepo(userClientFactory authorization.UserK8sClientFactory, ...) *PackageRepo

+ func (r *PackageRepo) CreatePackage(ctx context.Context, authInfo authorization.Info, message CreatePackageMessage) (PackageRecord, error)

+ func (r *PackageRepo) GetPackage(ctx context.Context, authInfo authorization.Info, guid string) (PackageRecord, error)

+ func (r *PackageRepo) ListPackages(ctx context.Context, authInfo authorization.Info, message ListPackagesMessage) ([]PackageRecord, error)

+ func (r *PackageRepo) UpdatePackageSource(ctx context.Context, authInfo authorization.Info, ...) (PackageRecord, error)

+ type PatchAppEnvVarsMessage struct

+ AppGUID string

+ EnvironmentVariables map[string]*string

+ SpaceGUID string

+ type PatchProcessMessage struct

+ Command *string

+ DesiredInstances *int

+ DiskQuotaMB *int64

+ HealthCheckHTTPEndpoint *string

+ HealthCheckInvocationTimeoutSeconds *int64

+ HealthCheckTimeoutSeconds *int64

+ HealthCheckType *string

+ MemoryMB *int64

+ ProcessGUID string

+ SpaceGUID string

+ type PodRepo struct

+ func NewPodRepo(userClientFactory authorization.UserK8sClientFactory, ...) *PodRepo

+ func (r *PodRepo) GetRuntimeLogsForApp(ctx context.Context, logger logr.Logger, authInfo authorization.Info, ...) ([]LogRecord, error)

+ func (r *PodRepo) ListPodStats(ctx context.Context, authInfo authorization.Info, message ListPodStatsMessage) ([]PodStatsRecord, error)

+ func (r *PodRepo) ListPods(ctx context.Context, authInfo authorization.Info, listOpts client.ListOptions) ([]corev1.Pod, error)

+ type PodStatsRecord struct

+ Index int

+ State string

+ Type string

+ Usage Usage

+ type ProcessRecord struct

+ Annotations map[string]string

+ AppGUID string

+ Command string

+ CreatedAt string

+ DesiredInstances int

+ DiskQuotaMB int64

+ GUID string

+ HealthCheck HealthCheck

+ Labels map[string]string

+ MemoryMB int64

+ Ports []int32

+ SpaceGUID string

+ Type string

+ UpdatedAt string

+ type ProcessRepo struct

+ func NewProcessRepo(namespaceRetriever NamespaceRetriever, ...) *ProcessRepo

+ func (r *ProcessRepo) CreateProcess(ctx context.Context, authInfo authorization.Info, message CreateProcessMessage) error

+ func (r *ProcessRepo) GetProcess(ctx context.Context, authInfo authorization.Info, processGUID string) (ProcessRecord, error)

+ func (r *ProcessRepo) GetProcessByAppTypeAndSpace(ctx context.Context, authInfo authorization.Info, ...) (ProcessRecord, error)

+ func (r *ProcessRepo) ListProcesses(ctx context.Context, authInfo authorization.Info, message ListProcessesMessage) ([]ProcessRecord, error)

+ func (r *ProcessRepo) PatchProcess(ctx context.Context, authInfo authorization.Info, message PatchProcessMessage) (ProcessRecord, error)

+ func (r *ProcessRepo) ScaleProcess(ctx context.Context, authInfo authorization.Info, ...) (ProcessRecord, error)

+ type ProcessScaleValues struct

+ DiskMB *int64

+ Instances *int

+ MemoryMB *int64

+ type RemoveDestinationFromRouteMessage struct

+ DestinationGuid string

+ ExistingDestinations []DestinationRecord

+ RouteGUID string

+ SpaceGUID string

+ type RoleRecord struct

+ CreatedAt time.Time

+ GUID string

+ Kind string

+ Org string

+ Space string

+ Type string

+ UpdatedAt time.Time

+ User string

+ type RoleRepo struct

+ func NewRoleRepo(userClientFactory authorization.UserK8sClientFactory, spaceRepo *SpaceRepo, ...) *RoleRepo

+ func (r *RoleRepo) CreateRole(ctx context.Context, authInfo authorization.Info, role CreateRoleMessage) (RoleRecord, error)

+ type RouteRecord struct

+ Annotations map[string]string

+ CreatedAt string

+ Destinations []DestinationRecord

+ Domain DomainRecord

+ GUID string

+ Host string

+ Labels map[string]string

+ Path string

+ Protocol string

+ SpaceGUID string

+ UpdatedAt string

+ func (r RouteRecord) UpdateDomainRef(d DomainRecord) RouteRecord

+ type RouteRepo struct

+ func NewRouteRepo(namespaceRetriever NamespaceRetriever, ...) *RouteRepo

+ func (f *RouteRepo) AddDestinationsToRoute(ctx context.Context, authInfo authorization.Info, ...) (RouteRecord, error)

+ func (f *RouteRepo) CreateRoute(ctx context.Context, authInfo authorization.Info, message CreateRouteMessage) (RouteRecord, error)

+ func (f *RouteRepo) DeleteRoute(ctx context.Context, authInfo authorization.Info, message DeleteRouteMessage) error

+ func (f *RouteRepo) GetOrCreateRoute(ctx context.Context, authInfo authorization.Info, message CreateRouteMessage) (RouteRecord, error)

+ func (f *RouteRepo) GetRoute(ctx context.Context, authInfo authorization.Info, routeGUID string) (RouteRecord, error)

+ func (f *RouteRepo) ListRoutes(ctx context.Context, authInfo authorization.Info, message ListRoutesMessage) ([]RouteRecord, error)

+ func (f *RouteRepo) ListRoutesForApp(ctx context.Context, authInfo authorization.Info, appGUID string, ...) ([]RouteRecord, error)

+ func (f *RouteRepo) RemoveDestinationFromRoute(ctx context.Context, authInfo authorization.Info, ...) (RouteRecord, error)

+ type RuntimeLogsMessage struct

+ AppGUID string

+ AppRevision string

+ Limit int64

+ SpaceGUID string

+ type ScaleProcessMessage struct

+ GUID string

+ SpaceGUID string

+ type ServiceBindingLastOperation struct

+ CreatedAt string

+ Description *string

+ State string

+ Type string

+ UpdatedAt string

+ type ServiceBindingRecord struct

+ AppGUID string

+ CreatedAt string

+ GUID string

+ LastOperation ServiceBindingLastOperation

+ Name *string

+ ServiceInstanceGUID string

+ SpaceGUID string

+ Type string

+ UpdatedAt string

+ type ServiceBindingRepo struct

+ func NewServiceBindingRepo(namespaceRetriever NamespaceRetriever, ...) *ServiceBindingRepo

+ func (r *ServiceBindingRepo) CreateServiceBinding(ctx context.Context, authInfo authorization.Info, ...) (ServiceBindingRecord, error)

+ func (r *ServiceBindingRepo) DeleteServiceBinding(ctx context.Context, authInfo authorization.Info, guid string) error

+ func (r *ServiceBindingRepo) ListServiceBindings(ctx context.Context, authInfo authorization.Info, ...) ([]ServiceBindingRecord, error)

+ func (r *ServiceBindingRepo) ServiceBindingExists(ctx context.Context, authInfo authorization.Info, ...) (bool, error)

+ type ServiceInstanceRecord struct

+ CreatedAt string

+ GUID string

+ Name string

+ SecretName string

+ SpaceGUID string

+ Tags []string

+ Type string

+ UpdatedAt string

+ type ServiceInstanceRepo struct

+ func NewServiceInstanceRepo(namespaceRetriever NamespaceRetriever, ...) *ServiceInstanceRepo

+ func (r *ServiceInstanceRepo) CreateServiceInstance(ctx context.Context, authInfo authorization.Info, ...) (ServiceInstanceRecord, error)

+ func (r *ServiceInstanceRepo) DeleteServiceInstance(ctx context.Context, authInfo authorization.Info, ...) error

+ func (r *ServiceInstanceRepo) GetServiceInstance(ctx context.Context, authInfo authorization.Info, guid string) (ServiceInstanceRecord, error)

+ func (r *ServiceInstanceRepo) ListServiceInstances(ctx context.Context, authInfo authorization.Info, ...) ([]ServiceInstanceRecord, error)

+ type SetAppDesiredStateMessage struct

+ AppGUID string

+ DesiredState string

+ SpaceGUID string

+ type SetCurrentDropletMessage struct

+ AppGUID string

+ DropletGUID string

+ SpaceGUID string

+ type SpaceRecord struct

+ Annotations map[string]string

+ CreatedAt time.Time

+ GUID string

+ Labels map[string]string

+ Name string

+ OrganizationGUID string

+ UpdatedAt time.Time

+ type SpaceRepo struct

+ func NewSpaceRepo(namespaceRetriever NamespaceRetriever, orgRepo *OrgRepo, ...) *SpaceRepo

+ func (r *SpaceRepo) CreateSpace(ctx context.Context, info authorization.Info, message CreateSpaceMessage) (SpaceRecord, error)

+ func (r *SpaceRepo) DeleteSpace(ctx context.Context, info authorization.Info, message DeleteSpaceMessage) error

+ func (r *SpaceRepo) GetSpace(ctx context.Context, info authorization.Info, spaceGUID string) (SpaceRecord, error)

+ func (r *SpaceRepo) ListSpaces(ctx context.Context, info authorization.Info, message ListSpacesMessage) ([]SpaceRecord, error)

+ type UpdatePackageSourceMessage struct

+ GUID string

+ ImageRef string

+ RegistrySecretName string

+ SpaceGUID string

+ type Usage struct

+ CPU *float64

+ Disk *int64

+ Mem *int64

+ Time *string

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