eventing

Documentation

Index

• type Module
  • func New(auth *auth.Module, crud *crud.Module, schema *schema.Schema, ...) *Module
  • func (m *Module) AddInternalRules(eventingRules []config.EventingRule)
  • func (m *Module) CreateFileIntentHook(ctx context.Context, req *model.CreateFileRequest) (*model.EventIntent, error)
  • func (m *Module) DeleteFileIntentHook(ctx context.Context, path string) (*model.EventIntent, error)
  • func (m *Module) HookDBBatchIntent(ctx context.Context, dbType string, req *model.BatchRequest) (*model.EventIntent, error)
  • func (m *Module) HookDBCreateIntent(ctx context.Context, dbAlias, col string, req *model.CreateRequest) (*model.EventIntent, error)
  • func (m *Module) HookDBDeleteIntent(ctx context.Context, dbType, col string, req *model.DeleteRequest) (*model.EventIntent, error)
  • func (m *Module) HookDBUpdateIntent(ctx context.Context, dbType, col string, req *model.UpdateRequest) (*model.EventIntent, error)
  • func (m *Module) HookStage(ctx context.Context, intent *model.EventIntent, err 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, schema *schema.Schema, functions *functions.Module, adminMan *admin.Manager, syncMan *syncman.Manager, file *filestore.Module) *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) CreateFileIntentHook

func (m *Module) CreateFileIntentHook(ctx context.Context, req *model.CreateFileRequest) (*model.EventIntent, error)

CreateFileIntentHook handles the create file intent request

func (*Module) DeleteFileIntentHook

func (m *Module) DeleteFileIntentHook(ctx context.Context, path string) (*model.EventIntent, error)

DeleteFileIntentHook handles the delete file intent requests

func (*Module) HookDBBatchIntent

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

HookDBBatchIntent handles the batch intent requests

func (*Module) HookDBCreateIntent

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

HookDBCreateIntent handles the create intent request

func (*Module) HookDBDeleteIntent

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

HookDBDeleteIntent handles the delete intent requests

func (*Module) HookDBUpdateIntent

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

HookDBUpdateIntent handles the update intent requests

func (*Module) HookStage

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

HookStage stages the event so that it can be processed

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