newdeploy

Documentation

Index

• Constants
• func MakeNewDeploy(logger *zap.Logger, fissionClient *crd.FissionClient, ...) executortype.ExecutorType
• type NewDeploy
  • func (deploy *NewDeploy) AdoptExistingResources()
  • func (deploy *NewDeploy) CleanupOldExecutorObjects()
  • func (deploy *NewDeploy) DeleteFuncSvcFromCache(fsvc *fscache.FuncSvc)
  • func (deploy *NewDeploy) GetFuncSvc(ctx context.Context, fn *fv1.Function) (*fscache.FuncSvc, error)
  • func (deploy *NewDeploy) GetFuncSvcFromCache(fn *fv1.Function) (*fscache.FuncSvc, error)
  • func (deploy *NewDeploy) GetTypeName() fv1.ExecutorType
  • func (deploy *NewDeploy) IsValid(fsvc *fscache.FuncSvc) bool
  • func (deploy *NewDeploy) RefreshFuncPods(logger *zap.Logger, f fv1.Function) error
  • func (deploy *NewDeploy) Run(ctx context.Context)
  • func (deploy *NewDeploy) TapService(svcHost string) error

Constants

const (
	DeploymentKind    = "Deployment"
	DeploymentVersion = "apps/v1"
)

Functions

func MakeNewDeploy

func MakeNewDeploy(
	logger *zap.Logger,
	fissionClient *crd.FissionClient,
	kubernetesClient *kubernetes.Clientset,
	crdClient rest.Interface,
	namespace string,
	fetcherConfig *fetcherConfig.Config,
	instanceID string,
) executortype.ExecutorType

Types

type NewDeploy

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

func (*NewDeploy) AdoptExistingResources

func (deploy *NewDeploy) AdoptExistingResources()

func (*NewDeploy) CleanupOldExecutorObjects

func (deploy *NewDeploy) CleanupOldExecutorObjects()

func (*NewDeploy) DeleteFuncSvcFromCache

func (deploy *NewDeploy) DeleteFuncSvcFromCache(fsvc *fscache.FuncSvc)

func (*NewDeploy) GetFuncSvc

func (deploy *NewDeploy) GetFuncSvc(ctx context.Context, fn *fv1.Function) (*fscache.FuncSvc, error)

func (*NewDeploy) GetFuncSvcFromCache

func (deploy *NewDeploy) GetFuncSvcFromCache(fn *fv1.Function) (*fscache.FuncSvc, error)

func (*NewDeploy) GetTypeName

func (deploy *NewDeploy) GetTypeName() fv1.ExecutorType

func (*NewDeploy) IsValid

func (deploy *NewDeploy) IsValid(fsvc *fscache.FuncSvc) bool

IsValid does a get on the service address to ensure it's a valid service, then scale deployment to 1 replica if there are no available replicas for function. Return true if no error occurs, return false otherwise.

func (*NewDeploy) RefreshFuncPods

func (deploy *NewDeploy) RefreshFuncPods(logger *zap.Logger, f fv1.Function) error

RefreshFuncPods deleted pods related to the function so that new pods are replenished

func (*NewDeploy) Run

func (deploy *NewDeploy) Run(ctx context.Context)

func (*NewDeploy) TapService

func (deploy *NewDeploy) TapService(svcHost string) error