poolmgr

Documentation

Index

• Constants
• func IsIPv6(podIP string) bool
• func MakeGenericPoolManager(logger *zap.Logger, fissionClient *crd.FissionClient, ...) (executortype.ExecutorType, error)
• type GenericPool
  • func MakeGenericPool(logger *zap.Logger, fissionClient *crd.FissionClient, ...) (*GenericPool, error)
• type GenericPoolManager
  • func (gpm *GenericPoolManager) AdoptExistingResources()
  • func (gpm *GenericPoolManager) CleanupOldExecutorObjects()
  • func (gpm *GenericPoolManager) DeleteFuncSvcFromCache(fsvc *fscache.FuncSvc)
  • func (gpm *GenericPoolManager) FunctionEventHandlers(kubernetesClient *kubernetes.Clientset, fissionfnNamespace string, ...) k8sCache.ResourceEventHandlerFuncs
  • func (gpm *GenericPoolManager) GetFuncSvc(ctx context.Context, fn *fv1.Function) (*fscache.FuncSvc, error)
  • func (gpm *GenericPoolManager) GetFuncSvcFromCache(fn *fv1.Function) (*fscache.FuncSvc, error)
  • func (gpm *GenericPoolManager) GetFuncSvcFromPoolCache(fn *fv1.Function, requestsPerPod int) (*fscache.FuncSvc, int, error)
  • func (gpm *GenericPoolManager) GetTypeName() fv1.ExecutorType
  • func (gpm *GenericPoolManager) IsValid(fsvc *fscache.FuncSvc) bool
  • func (gpm *GenericPoolManager) NoActiveConnectionEventChecker(kubeClient *kubernetes.Clientset)
  • func (gpm *GenericPoolManager) PackageEventHandlers(kubernetesClient *kubernetes.Clientset, fissionfnNamespace string) k8sCache.ResourceEventHandlerFuncs
  • func (gpm *GenericPoolManager) RefreshFuncPods(logger *zap.Logger, f fv1.Function) error
  • func (gpm *GenericPoolManager) Run(ctx context.Context)
  • func (gpm *GenericPoolManager) TapService(svcHost string) error
  • func (gpm *GenericPoolManager) UnTapService(key string, svcHost string)
  • func (gpm *GenericPoolManager) WebsocketStartEventChecker(kubeClient *kubernetes.Clientset)

Constants

const (
	GET_POOL requestType = iota
	CLEANUP_POOLS
)

Functions

func IsIPv6

func IsIPv6(podIP string) bool

IsIPv6 validates if the podIP follows to IPv6 protocol

func MakeGenericPoolManager

func MakeGenericPoolManager(
	logger *zap.Logger,
	fissionClient *crd.FissionClient,
	kubernetesClient *kubernetes.Clientset,
	metricsClient *metricsclient.Clientset,
	functionNamespace string,
	fetcherConfig *fetcherConfig.Config,
	instanceID string,
	funcInformer *k8sCache.SharedIndexInformer,
	pkgInformer *k8sCache.SharedIndexInformer,
) (executortype.ExecutorType, error)

Types

type GenericPool

type GenericPool struct {
	// contains filtered or unexported fields
}

GenericPool represents a generic environment pool

func MakeGenericPool

func MakeGenericPool(
	logger *zap.Logger,
	fissionClient *crd.FissionClient,
	kubernetesClient *kubernetes.Clientset,
	metricsClient *metricsclient.Clientset,
	env *fv1.Environment,
	initialReplicas int32,
	namespace string,
	functionNamespace string,
	fsCache *fscache.FunctionServiceCache,
	fetcherConfig *fetcherConfig.Config,
	instanceID string,
	enableIstio bool) (*GenericPool, error)

MakeGenericPool returns an instance of GenericPool

type GenericPoolManager

type GenericPoolManager struct {
	// contains filtered or unexported fields
}

func (*GenericPoolManager) AdoptExistingResources

func (gpm *GenericPoolManager) AdoptExistingResources()

func (*GenericPoolManager) CleanupOldExecutorObjects

func (gpm *GenericPoolManager) CleanupOldExecutorObjects()

func (*GenericPoolManager) DeleteFuncSvcFromCache

func (gpm *GenericPoolManager) DeleteFuncSvcFromCache(fsvc *fscache.FuncSvc)

func (*GenericPoolManager) FunctionEventHandlers

func (gpm *GenericPoolManager) FunctionEventHandlers(kubernetesClient *kubernetes.Clientset, fissionfnNamespace string, istioEnabled bool) k8sCache.ResourceEventHandlerFuncs

func (*GenericPoolManager) GetFuncSvc

func (gpm *GenericPoolManager) GetFuncSvc(ctx context.Context, fn *fv1.Function) (*fscache.FuncSvc, error)

func (*GenericPoolManager) GetFuncSvcFromCache

func (gpm *GenericPoolManager) GetFuncSvcFromCache(fn *fv1.Function) (*fscache.FuncSvc, error)

func (*GenericPoolManager) GetFuncSvcFromPoolCache

func (gpm *GenericPoolManager) GetFuncSvcFromPoolCache(fn *fv1.Function, requestsPerPod int) (*fscache.FuncSvc, int, error)

func (*GenericPoolManager) GetTypeName

func (gpm *GenericPoolManager) GetTypeName() fv1.ExecutorType

func (*GenericPoolManager) IsValid

func (gpm *GenericPoolManager) IsValid(fsvc *fscache.FuncSvc) bool

IsValid checks if pod is not deleted and that it has the address passed as the argument. Also checks that all the containers in it are reporting a ready status for the healthCheck.

func (*GenericPoolManager) NoActiveConnectionEventChecker

func (gpm *GenericPoolManager) NoActiveConnectionEventChecker(kubeClient *kubernetes.Clientset)

NoActiveConnectionEventChecker checks if the pod has emitted an inactive event

func (*GenericPoolManager) PackageEventHandlers

func (gpm *GenericPoolManager) PackageEventHandlers(kubernetesClient *kubernetes.Clientset, fissionfnNamespace string) k8sCache.ResourceEventHandlerFuncs

func (*GenericPoolManager) RefreshFuncPods

func (gpm *GenericPoolManager) RefreshFuncPods(logger *zap.Logger, f fv1.Function) error

func (*GenericPoolManager) Run

func (gpm *GenericPoolManager) Run(ctx context.Context)

func (*GenericPoolManager) TapService

func (gpm *GenericPoolManager) TapService(svcHost string) error

func (*GenericPoolManager) UnTapService

func (gpm *GenericPoolManager) UnTapService(key string, svcHost string)

func (*GenericPoolManager) WebsocketStartEventChecker

func (gpm *GenericPoolManager) WebsocketStartEventChecker(kubeClient *kubernetes.Clientset)

WebsocketStartEventChecker checks if the pod has emitted a websocket connection start event