eventing

Documentation

Index

• type Module
  • func New(crud *crud.Module, functions *functions.Module, syncMan *syncman.SyncManager) *Module
  • func (m *Module) AddInternalRules(eventingRules []config.EventingRule)
  • func (m *Module) HandleBatchIntent(ctx context.Context, dbType string, req *model.BatchRequest) (*model.EventIntent, error)
  • func (m *Module) HandleCreateIntent(ctx context.Context, dbType, col string, req *model.CreateRequest) (*model.EventIntent, error)
  • func (m *Module) HandleDeleteIntent(ctx context.Context, dbType, col string, req *model.DeleteRequest) (*model.EventIntent, error)
  • func (m *Module) HandleStage(ctx context.Context, intent *model.EventIntent, err error)
  • func (m *Module) HandleUpdateIntent(ctx context.Context, dbType, col string, req *model.UpdateRequest) (*model.EventIntent, error)
  • func (m *Module) SetConfig(project string, eventing *config.Eventing) error

Types

type Module

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

Module is responsible for managing the eventing system

func New

func New(crud *crud.Module, functions *functions.Module, syncMan *syncman.SyncManager) *Module

New creates a new instance of the eventing module

func (*Module) AddInternalRules

func (m *Module) AddInternalRules(eventingRules []config.EventingRule)

func (*Module) HandleBatchIntent

func (m *Module) HandleBatchIntent(ctx context.Context, dbType string, req *model.BatchRequest) (*model.EventIntent, error)

HandleBatchIntent handles the batch intent requests

func (*Module) HandleCreateIntent

func (m *Module) HandleCreateIntent(ctx context.Context, dbType, col string, req *model.CreateRequest) (*model.EventIntent, error)

HandleCreateIntent handles the create intent request

func (*Module) HandleDeleteIntent

func (m *Module) HandleDeleteIntent(ctx context.Context, dbType, col string, req *model.DeleteRequest) (*model.EventIntent, error)

HandleDeleteIntent handles the delete intent requests

func (*Module) HandleStage

func (m *Module) HandleStage(ctx context.Context, intent *model.EventIntent, err error)

HandleStage stages the event so that it can be processed

func (*Module) HandleUpdateIntent

func (m *Module) HandleUpdateIntent(ctx context.Context, dbType, col string, req *model.UpdateRequest) (*model.EventIntent, error)

HandleUpdateIntent handles the update intent requests

func (*Module) SetConfig

func (m *Module) SetConfig(project string, eventing *config.Eventing) error

SetConfig sets the module config