fscache

Documentation

Index

• Constants
• func IsNameExistError(err error) bool
• func IsNotFoundError(err error) bool
• type FuncSvc
• type FunctionServiceCache
  • func MakeFunctionServiceCache(logger *zap.Logger) *FunctionServiceCache
  • func (fsc *FunctionServiceCache) Add(fsvc FuncSvc) (*FuncSvc, error)
  • func (fsc *FunctionServiceCache) AddFunc(fsvc FuncSvc)
  • func (fsc *FunctionServiceCache) DeleteEntry(fsvc *FuncSvc)
  • func (fsc *FunctionServiceCache) DeleteFunctionSvc(fsvc *FuncSvc)
  • func (fsc *FunctionServiceCache) DeleteOld(fsvc *FuncSvc, minAge time.Duration) (bool, error)
  • func (fsc *FunctionServiceCache) DeleteOldPoolCache(fsvc *FuncSvc, minAge time.Duration) (bool, error)
  • func (fsc *FunctionServiceCache) GetByFunction(m *metav1.ObjectMeta) (*FuncSvc, error)
  • func (fsc *FunctionServiceCache) GetByFunctionUID(uid types.UID) (*FuncSvc, error)
  • func (fsc *FunctionServiceCache) GetFuncSvc(m *metav1.ObjectMeta) (*FuncSvc, error)
  • func (fsc *FunctionServiceCache) GetTotalAvailable(m *metav1.ObjectMeta) int
  • func (fsc *FunctionServiceCache) IncreaseColdStarts(funcname, funcuid string)
  • func (fsc *FunctionServiceCache) ListOld(age time.Duration) ([]*FuncSvc, error)
  • func (fsc *FunctionServiceCache) ListOldForPool(age time.Duration) ([]*FuncSvc, error)
  • func (fsc *FunctionServiceCache) Log()
  • func (fsc *FunctionServiceCache) MarkAvailable(fn *fv1.Function, svcHost string)
  • func (fsc *FunctionServiceCache) TouchByAddress(address string) error

Constants

const (
	TOUCH fscRequestType = iota
	LISTOLD
	LOG
	LISTOLDPOOL
)

Functions

func IsNameExistError

func IsNameExistError(err error) bool

func IsNotFoundError

func IsNotFoundError(err error) bool

Types

type FuncSvc

type FuncSvc struct {
	Name              string                  // Name of object
	Function          *metav1.ObjectMeta      // function this pod/service is for
	Environment       *fv1.Environment        // function's environment
	Address           string                  // Host:Port or IP:Port that the function's service can be reached at.
	KubernetesObjects []apiv1.ObjectReference // Kubernetes Objects (within the function namespace)
	Executor          fv1.ExecutorType

	Ctime time.Time
	Atime time.Time
}

type FunctionServiceCache

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

func MakeFunctionServiceCache

func MakeFunctionServiceCache(logger *zap.Logger) *FunctionServiceCache

func (*FunctionServiceCache) Add

func (fsc *FunctionServiceCache) Add(fsvc FuncSvc) (*FuncSvc, error)

func (*FunctionServiceCache) AddFunc

func (fsc *FunctionServiceCache) AddFunc(fsvc FuncSvc)

func (*FunctionServiceCache) DeleteEntry

func (fsc *FunctionServiceCache) DeleteEntry(fsvc *FuncSvc)

func (*FunctionServiceCache) DeleteFunctionSvc

func (fsc *FunctionServiceCache) DeleteFunctionSvc(fsvc *FuncSvc)

func (*FunctionServiceCache) DeleteOld

func (fsc *FunctionServiceCache) DeleteOld(fsvc *FuncSvc, minAge time.Duration) (bool, error)

func (*FunctionServiceCache) DeleteOldPoolCache

func (fsc *FunctionServiceCache) DeleteOldPoolCache(fsvc *FuncSvc, minAge time.Duration) (bool, error)

func (*FunctionServiceCache) GetByFunction

func (fsc *FunctionServiceCache) GetByFunction(m *metav1.ObjectMeta) (*FuncSvc, error)

func (*FunctionServiceCache) GetByFunctionUID

func (fsc *FunctionServiceCache) GetByFunctionUID(uid types.UID) (*FuncSvc, error)

func (*FunctionServiceCache) GetFuncSvc

func (fsc *FunctionServiceCache) GetFuncSvc(m *metav1.ObjectMeta) (*FuncSvc, error)

func (*FunctionServiceCache) GetTotalAvailable

func (fsc *FunctionServiceCache) GetTotalAvailable(m *metav1.ObjectMeta) int

func (*FunctionServiceCache) IncreaseColdStarts

func (fsc *FunctionServiceCache) IncreaseColdStarts(funcname, funcuid string)

func (*FunctionServiceCache) ListOld

func (fsc *FunctionServiceCache) ListOld(age time.Duration) ([]*FuncSvc, error)

func (*FunctionServiceCache) ListOldForPool

func (fsc *FunctionServiceCache) ListOldForPool(age time.Duration) ([]*FuncSvc, error)

func (*FunctionServiceCache) Log

func (fsc *FunctionServiceCache) Log()

func (*FunctionServiceCache) MarkAvailable

func (fsc *FunctionServiceCache) MarkAvailable(fn *fv1.Function, svcHost string)

func (*FunctionServiceCache) TouchByAddress

func (fsc *FunctionServiceCache) TouchByAddress(address string) error