poolmgr

Documentation

Index

• Constants
• func IsIPv6(podIP string) bool
• type GenericPool
  • func MakeGenericPool(fissionClient *crd.FissionClient, kubernetesClient *kubernetes.Clientset, ...) (*GenericPool, error)
  • func (gp *GenericPool) GetFuncSvc(m *metav1.ObjectMeta) (*fscache.FuncSvc, error)
• type GenericPoolManager
  • func MakeGenericPoolManager(fissionClient *crd.FissionClient, kubernetesClient *kubernetes.Clientset, ...) *GenericPoolManager
  • func (gpm *GenericPoolManager) CleanupPools(envs []crd.Environment)
  • func (gpm *GenericPoolManager) GetPool(env *crd.Environment) (*GenericPool, error)

Constants

const (
	GET_POOL requestType = iota
	CLEANUP_POOLS
)

const POD_PHASE_RUNNING string = "Running"

Functions

func IsIPv6

func IsIPv6(podIP string) bool

Types

type GenericPool

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

func MakeGenericPool

func MakeGenericPool(
	fissionClient *crd.FissionClient,
	kubernetesClient *kubernetes.Clientset,
	env *crd.Environment,
	initialReplicas int32,
	namespace string,
	fsCache *fscache.FunctionServiceCache,
	instanceId string) (*GenericPool, error)

func (*GenericPool) GetFuncSvc

func (gp *GenericPool) GetFuncSvc(m *metav1.ObjectMeta) (*fscache.FuncSvc, error)

type GenericPoolManager

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

func MakeGenericPoolManager

func MakeGenericPoolManager(
	fissionClient *crd.FissionClient,
	kubernetesClient *kubernetes.Clientset,
	fissionNamespace string,
	functionNamespace string,
	fsCache *fscache.FunctionServiceCache,
	instanceId string) *GenericPoolManager

func (*GenericPoolManager) CleanupPools

func (gpm *GenericPoolManager) CleanupPools(envs []crd.Environment)

func (*GenericPoolManager) GetPool

func (gpm *GenericPoolManager) GetPool(env *crd.Environment) (*GenericPool, error)