server

Documentation

Index

• Constants
• Variables
• func Hydrate(ctx context.Context, mux *runtime.ServeMux, cfg CoreServerConfig) error
• func NewCoreServer(cfg CoreServerConfig, setters ...CoreOption) (pb.CoreServer, error)
• type ClientGetterFn
• type CoreOption
  • func WithClientGetter(clientGetter kube.ClientGetter) CoreOption
• type CoreOptions
• type CoreServerConfig
  • func NewCoreConfig(log logr.Logger, cfg *rest.Config, clusterName string, ...) CoreServerConfig

Constants

const (
	FluxNamespacePartOf = "flux"
)

Variables

var (
	KustomizeNameKey      = fmt.Sprintf("%s/name", kustomizev1.GroupVersion.Group)
	KustomizeNamespaceKey = fmt.Sprintf("%s/namespace", kustomizev1.GroupVersion.Group)
	HelmNameKey           = fmt.Sprintf("%s/name", helmv2.GroupVersion.Group)
	HelmNamespaceKey      = fmt.Sprintf("%s/namespace", helmv2.GroupVersion.Group)

	// ErrFluxNamespaceNotFound no flux namespace found
	ErrFluxNamespaceNotFound = errors.New("could not find flux namespace in cluster")
	// ErrListingDeployments no deployments found
	ErrListingDeployments = errors.New("could not list deployments in namespace")
)

var (
	Version   = "v0.0.0"
	GitCommit = ""
	Branch    = ""
	Buildtime = ""
)

Variables that we'll set @ build time

Functions

func Hydrate

func Hydrate(ctx context.Context, mux *runtime.ServeMux, cfg CoreServerConfig) error

func NewCoreServer

func NewCoreServer(cfg CoreServerConfig, setters ...CoreOption) (pb.CoreServer, error)

Types

type ClientGetterFn

type ClientGetterFn func(ctx context.Context) clustersmngr.Client

type CoreOption

type CoreOption func(*CoreOptions)

CoreOption defines the signature of a function that can be used to set an option for an CoreServer.

func WithClientGetter

func WithClientGetter(clientGetter kube.ClientGetter) CoreOption

WithClientGetter allows for setting a ClientGetter.

type CoreOptions

type CoreOptions struct {
	ClientGetter kube.ClientGetter
}

CoreOptions includes all the options that can be set for an CoreServer.

type CoreServerConfig

type CoreServerConfig struct {
	RestCfg *rest.Config

	NSAccess       nsaccess.Checker
	ClientsFactory clustersmngr.ClientsFactory
	// contains filtered or unexported fields
}

func NewCoreConfig

func NewCoreConfig(log logr.Logger, cfg *rest.Config, clusterName string, clusterClientFactory clustersmngr.ClientsFactory) CoreServerConfig