poolmgr

Documentation

Index

• Constants
• func IsIPv6(podIP string) bool
• func MakeGenericPoolManager(logger *zap.Logger, fissionClient *crd.FissionClient, ...) executortype.ExecutorType
• 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) GetFuncSvc(ctx context.Context, fn *fv1.Function) (*fscache.FuncSvc, error)
  • func (gpm *GenericPoolManager) GetFuncSvcFromCache(fn *fv1.Function) (*fscache.FuncSvc, error)
  • func (gpm *GenericPoolManager) GetTypeName() fv1.ExecutorType
  • func (gpm *GenericPoolManager) IsValid(fsvc *fscache.FuncSvc) bool
  • 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

Constants

const (
	GET_POOL requestType = iota
	CLEANUP_POOLS
)

Functions

func IsIPv6

func IsIPv6(podIP string) bool

func MakeGenericPoolManager

func MakeGenericPoolManager(
	logger *zap.Logger,
	fissionClient *crd.FissionClient,
	kubernetesClient *kubernetes.Clientset,
	functionNamespace string,
	fetcherConfig *fetcherConfig.Config,
	instanceId string) executortype.ExecutorType

Types

type GenericPool

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

func MakeGenericPool

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

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