poolmgr

Documentation

Index

• Constants
• func MakeFunctionServiceCache() *functionServiceCache
• func StartPoolmgr(fissionNamespace string, functionNamespace string, port int) error
• type GenericPool
  • func MakeGenericPool(kubernetesClient *kubernetes.Clientset, env *tpr.Environment, ...) (*GenericPool, error)
  • func (gp *GenericPool) CleanupFunctionService(podName string) error
  • func (gp *GenericPool) GetFuncSvc(m *api.ObjectMeta) (*funcSvc, error)
• type GenericPoolManager
  • func MakeGenericPoolManager(fissionClient *tpr.FissionClient, kubernetesClient *kubernetes.Clientset, ...) *GenericPoolManager
  • func (gpm *GenericPoolManager) CleanupPools(envs []tpr.Environment)
  • func (gpm *GenericPoolManager) GetPool(env *tpr.Environment) (*GenericPool, error)
• type Poolmgr
  • func MakePoolmgr(gpm *GenericPoolManager, fissionClient *tpr.FissionClient, fissionNs string, ...) *Poolmgr
  • func (poolMgr *Poolmgr) Serve(port int)

Constants

const (
	TOUCH fscRequestType = iota
	LISTOLD
	LOG
	DELETE_BY_POD
)

const (
	GET_POOL requestType = iota
	CLEANUP_POOLS
)

const POD_PHASE_RUNNING string = "Running"

const POOLMGR_INSTANCEID_LABEL string = "poolmgrInstanceId"

Functions

func MakeFunctionServiceCache

func MakeFunctionServiceCache() *functionServiceCache

func StartPoolmgr

func StartPoolmgr(fissionNamespace string, functionNamespace string, port int) error

Start the poolmgr service.

Types

type GenericPool

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

func MakeGenericPool

func MakeGenericPool(
	kubernetesClient *kubernetes.Clientset,
	env *tpr.Environment,
	initialReplicas int32,
	namespace string,
	fsCache *functionServiceCache,
	instanceId string) (*GenericPool, error)

func (*GenericPool) CleanupFunctionService

func (gp *GenericPool) CleanupFunctionService(podName string) error

func (*GenericPool) GetFuncSvc

func (gp *GenericPool) GetFuncSvc(m *api.ObjectMeta) (*funcSvc, error)

type GenericPoolManager

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

func MakeGenericPoolManager

func MakeGenericPoolManager(
	fissionClient *tpr.FissionClient,
	kubernetesClient *kubernetes.Clientset,
	fissionNamespace string,
	functionNamespace string,
	fsCache *functionServiceCache,
	instanceId string) *GenericPoolManager

func (*GenericPoolManager) CleanupPools

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

func (*GenericPoolManager) GetPool

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

type Poolmgr

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

func MakePoolmgr

func MakePoolmgr(gpm *GenericPoolManager, fissionClient *tpr.FissionClient, fissionNs string, fsCache *functionServiceCache) *Poolmgr

func (*Poolmgr) Serve

func (poolMgr *Poolmgr) Serve(port int)