poolmgr

Documentation

Index

• Constants
• func MakeFunctionServiceCache() *functionServiceCache
• func StartPoolmgr(controllerUrl string, namespace string, port int) error
• type API
  • func MakeAPI(gpm *GenericPoolManager, controller *controllerclient.Client, ...) *API
  • func (api *API) Serve(port int)
• type GenericPool
  • func MakeGenericPool(controllerUrl string, kubernetesClient *kubernetes.Clientset, ...) (*GenericPool, error)
  • func (gp *GenericPool) CleanupFunctionService(podName string) error
  • func (gp *GenericPool) GetFuncSvc(m *fission.Metadata) (*funcSvc, error)
• type GenericPoolManager
  • func MakeGenericPoolManager(controllerUrl string, kubernetesClient *kubernetes.Clientset, namespace string, ...) *GenericPoolManager
  • func (gpm *GenericPoolManager) CleanupPools(envs []fission.Environment)
  • func (gpm *GenericPoolManager) GetPool(env *fission.Environment) (*GenericPool, error)

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(controllerUrl string, namespace string, port int) error

Types

type API

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

func MakeAPI

func MakeAPI(gpm *GenericPoolManager, controller *controllerclient.Client, fsCache *functionServiceCache) *API

func (*API) Serve

func (api *API) Serve(port int)

type GenericPool

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

func MakeGenericPool

func MakeGenericPool(
	controllerUrl string,
	kubernetesClient *kubernetes.Clientset,
	env *fission.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 *fission.Metadata) (*funcSvc, error)

type GenericPoolManager

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

func MakeGenericPoolManager

func MakeGenericPoolManager(
	controllerUrl string,
	kubernetesClient *kubernetes.Clientset,
	namespace string,
	fsCache *functionServiceCache,
	instanceId string) *GenericPoolManager

func (*GenericPoolManager) CleanupPools

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

func (*GenericPoolManager) GetPool

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