Documentation
¶
Index ¶
Constants ¶
View Source
const (
TOUCH fscRequestType = iota
LISTOLD
LOG
DELETE_BY_POD
)
View Source
const (
GET_POOL requestType = iota
CLEANUP_POOLS
)
View Source
const POD_PHASE_RUNNING string = "Running"
View Source
const POOLMGR_INSTANCEID_LABEL string = "poolmgrInstanceId"
Variables ¶
This section is empty.
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)
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.