frontend

Documentation

Index

• func NewFrontend(ctx context.Context, auditLog *logrus.Entry, baseLog *logrus.Entry, ...) (*frontend, error)
• type ProvidersValidator
• type QuotaValidator
• type Runnable
• type SkuValidator
• type StreamResponder

Functions

func NewFrontend

func NewFrontend(ctx context.Context,
	auditLog *logrus.Entry,
	baseLog *logrus.Entry,
	_env env.Interface,
	dbAsyncOperations database.AsyncOperations,
	dbClusterManagerConfiguration database.ClusterManagerConfigurations,
	dbOpenShiftClusters database.OpenShiftClusters,
	dbSubscriptions database.Subscriptions,
	dbOpenShiftVersions database.OpenShiftVersions,
	apis map[string]*api.Version,
	m metrics.Emitter,
	clusterm metrics.Emitter,
	aead encryption.AEAD,
	hiveClusterManager hive.ClusterManager,
	kubeActionsFactory kubeActionsFactory,
	azureActionsFactory azureActionsFactory,
	enricher clusterdata.BestEffortEnricher,
) (*frontend, error)

NewFrontend returns a new runnable frontend

Types

type ProvidersValidator

type ProvidersValidator interface {
	ValidateProviders(ctx context.Context, azEnv *azureclient.AROEnvironment, environment env.Interface, subscriptionID, tenantID string) error
}

type QuotaValidator

type QuotaValidator interface {
	ValidateQuota(ctx context.Context, azEnv *azureclient.AROEnvironment, environment env.Interface, subscriptionID, tenantID string, oc *api.OpenShiftCluster) error
}

type Runnable

type Runnable interface {
	Run(context.Context, <-chan struct{}, chan<- struct{})
}

Runnable represents a runnable object

type SkuValidator

type SkuValidator interface {
	ValidateVMSku(ctx context.Context, azEnv *azureclient.AROEnvironment, environment env.Interface, subscriptionID, tenantID string, oc *api.OpenShiftCluster) error
}

type StreamResponder

type StreamResponder interface {
	ReplyStream(log *logrus.Entry, w http.ResponseWriter, header http.Header, reader io.Reader, err error)
	AdminReplyStream(log *logrus.Entry, w http.ResponseWriter, header http.Header, reader io.Reader, err error)
}