eventing

Documentation

Index

• type Module
  • func New(auth *auth.Module, crud *crud.Module, functions *functions.Module, ...) *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) IsEnabled() bool
  • func (m *Module) ProcessTransmittedEvents(eventDocs []*model.EventDocument)
  • func (m *Module) QueueEvent(ctx context.Context, req *model.QueueEventRequest) 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(auth *auth.Module, crud *crud.Module, functions *functions.Module, adminMan *admin.Manager, syncMan *syncman.Manager) *Module

New creates a new instance of the eventing module

func (*Module) AddInternalRules

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

AddInternalRules adds triggers which are used for space cloud internally

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) IsEnabled

func (m *Module) IsEnabled() bool

IsEnabled returns whether the eventing module is enabled or not

func (*Module) ProcessTransmittedEvents

func (m *Module) ProcessTransmittedEvents(eventDocs []*model.EventDocument)

ProcessTransmittedEvents processes the event received

func (*Module) QueueEvent

func (m *Module) QueueEvent(ctx context.Context, req *model.QueueEventRequest) error

QueueEvent queues a new event

func (*Module) SetConfig

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

SetConfig sets the module config