zeebe

Documentation

Index

• func GetZeebeJobType(fn *models.Fn) (string, bool)
• func JobHandler(fnID string, loadBalancerHost string) worker.JobHandler
• type FnListener
  • func (fnListener *FnListener) AfterFnCreate(ctx context.Context, fn *models.Fn) error
  • func (fnListener *FnListener) AfterFnDelete(ctx context.Context, fnID string) error
  • func (fnListener *FnListener) AfterFnUpdate(ctx context.Context, fn *models.Fn) error
  • func (fnListener *FnListener) BeforeFnCreate(ctx context.Context, fn *models.Fn) error
  • func (fnListener *FnListener) BeforeFnDelete(ctx context.Context, fnID string) error
  • func (fnListener *FnListener) BeforeFnUpdate(ctx context.Context, fn *models.Fn) error
• type FnWithZeebeJobType
  • func GetFunctionsWithZeebeJobType(apiServerHost string) []*FnWithZeebeJobType
• type JobWorkerRegistry
  • func NewJobWorkerRegistry(loadBalancerAddr string, zeebeGatewayAddr string) JobWorkerRegistry
  • func (jobWorkerRegistry *JobWorkerRegistry) RegisterFunctionAsWorker(fnID string, zeebeJobType string)
  • func (jobWorkerRegistry *JobWorkerRegistry) UnregisterFunctionAsWorker(fnID string)
• type Zeebe
  • func (zeebe *Zeebe) Name() string
  • func (zeebe *Zeebe) Setup(s fnext.ExtServer) error

Functions

func GetZeebeJobType

func GetZeebeJobType(fn *models.Fn) (string, bool)

func JobHandler

func JobHandler(fnID string, loadBalancerHost string) worker.JobHandler

Closure over the function ID and the needed context This is needed as worker.JobHandler of the Zeebe package does not have access to the context such as the function id

Types

type FnListener

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

Function listener for the Zeebe extension implementing the next.FnListener interface Listens to the function create, update and delete events and delegates them to the Zeebe adapter

func (*FnListener) AfterFnCreate

func (fnListener *FnListener) AfterFnCreate(ctx context.Context, fn *models.Fn) error

func (*FnListener) AfterFnDelete

func (fnListener *FnListener) AfterFnDelete(ctx context.Context, fnID string) error

func (*FnListener) AfterFnUpdate

func (fnListener *FnListener) AfterFnUpdate(ctx context.Context, fn *models.Fn) error

func (*FnListener) BeforeFnCreate

func (fnListener *FnListener) BeforeFnCreate(ctx context.Context, fn *models.Fn) error

func (*FnListener) BeforeFnDelete

func (fnListener *FnListener) BeforeFnDelete(ctx context.Context, fnID string) error

func (*FnListener) BeforeFnUpdate

func (fnListener *FnListener) BeforeFnUpdate(ctx context.Context, fn *models.Fn) error

type FnWithZeebeJobType

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

func GetFunctionsWithZeebeJobType

func GetFunctionsWithZeebeJobType(apiServerHost string) []*FnWithZeebeJobType

Gets all functions which are deployed and have a configured Zeebe job type

type JobWorkerRegistry

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

func NewJobWorkerRegistry

func NewJobWorkerRegistry(loadBalancerAddr string, zeebeGatewayAddr string) JobWorkerRegistry

func (*JobWorkerRegistry) RegisterFunctionAsWorker

func (jobWorkerRegistry *JobWorkerRegistry) RegisterFunctionAsWorker(fnID string, zeebeJobType string)

func (*JobWorkerRegistry) UnregisterFunctionAsWorker

func (jobWorkerRegistry *JobWorkerRegistry) UnregisterFunctionAsWorker(fnID string)

type Zeebe

type Zeebe struct {
}

func (*Zeebe) Name

func (zeebe *Zeebe) Name() string

func (*Zeebe) Setup

func (zeebe *Zeebe) Setup(s fnext.ExtServer) error