server

Documentation

Index

• Constants
• Variables
• func GetNextPage(namespaceList []v1.Namespace, pageSize int32, pageToken string, ...) (string, error)
• func Hydrate(ctx context.Context, mux *runtime.ServeMux, cfg CoreServerConfig) error
• func NewCoreServer(cfg CoreServerConfig) (pb.CoreServer, error)
• type ClientGetterFn
• type CoreServerConfig
  • func NewCoreConfig(log logr.Logger, cfg *rest.Config, cacheContainer cache.Container, ...) CoreServerConfig
• type PageTokenInfo

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

var ErrNamespaceNotFound = errors.New("namespace not found")

Functions

func GetNextPage

func GetNextPage(namespaceList []v1.Namespace, pageSize int32, pageToken string, getRawPage getRawPageData) (string, error)

func Hydrate

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

func NewCoreServer

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

Types

type ClientGetterFn

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

type CoreServerConfig

type CoreServerConfig struct {
	RestCfg *rest.Config

	NSAccess       nsaccess.Checker
	CacheContainer cache.Container
	// contains filtered or unexported fields
}

func NewCoreConfig

func NewCoreConfig(log logr.Logger, cfg *rest.Config, cacheContainer cache.Container, clusterName string) CoreServerConfig

type PageTokenInfo

type PageTokenInfo struct {
	NamespaceIndex int    `json:"namespace_index"`
	Namespace      string `json:"namespace"`
	K8sPageToken   string `json:"k8s_page_token"`
}