funcinsts

Documentation

Index

• Constants
• type Operator
  • func NewOperator(cfg *rest.Config, rclient refunc.Interface, ...) (*Operator, error)
  • func (r *Operator) GetFuncInstance(trigger *rfv1beta3.Trigger) (*rfv1beta3.Funcinst, error)
  • func (r *Operator) Run(stopC <-chan struct{})
  • func (r *Operator) Tap(key string)
  • func (r *Operator) TriggerForEndpoint(endpoint string) (*rfv1beta3.Trigger, error)

Constants

const (
	// Type name for rpc trigger
	Type = "eventgateway"
)

Types

type Operator

type Operator struct {
	*operators.BaseOperator

	// configured
	TappingInterval time.Duration

	// shared by concrete funcinst
	FuncinstLister rflistersv1.FuncinstLister
	// contains filtered or unexported fields
}

Operator creates http based rpc trigger automatically for every funcs

func NewOperator

func NewOperator(
	cfg *rest.Config,
	rclient refunc.Interface,
	rfInformers informers.SharedInformerFactory,
	handler transport.OperatorHandler,
	creds credsyncer.Provider,
) (*Operator, error)

NewOperator creates a new rpc trigger operator

func (*Operator) GetFuncInstance

func (r *Operator) GetFuncInstance(trigger *rfv1beta3.Trigger) (*rfv1beta3.Funcinst, error)

GetFuncInstance returns or creates a refunc instance from trigger

func (*Operator) Run

func (r *Operator) Run(stopC <-chan struct{})

Run will not return until stopC is closed.

func (*Operator) Tap

func (r *Operator) Tap(key string)

Tap funcinst keeps it live

func (*Operator) TriggerForEndpoint

func (r *Operator) TriggerForEndpoint(endpoint string) (*rfv1beta3.Trigger, error)

TriggerForEndpoint returns trigger specified by endpoint