Documentation
¶
Index ¶
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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 ¶ added in v0.15.0
func (m *Module) CreateFileIntentHook(ctx context.Context, req *model.CreateFileRequest) (*model.EventIntent, error)
CreateFileIntentHook handles the create file intent request
func (*Module) DeleteFileIntentHook ¶ added in v0.15.0
DeleteFileIntentHook handles the delete file intent requests
func (*Module) HookDBBatchIntent ¶ added in v0.15.0
func (m *Module) HookDBBatchIntent(ctx context.Context, dbType string, req *model.BatchRequest) (*model.EventIntent, error)
HookDBBatchIntent handles the batch intent requests
func (*Module) HookDBCreateIntent ¶ added in v0.15.0
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 ¶ added in v0.15.0
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 ¶ added in v0.15.0
func (m *Module) HookDBUpdateIntent(ctx context.Context, dbType, col string, req *model.UpdateRequest) (*model.EventIntent, error)
HookDBUpdateIntent handles the update intent requests
func (*Module) IsEnabled ¶ added in v0.12.1
IsEnabled returns whether the eventing module is enabled or not
func (*Module) ProcessTransmittedEvents ¶ added in v0.13.0
func (m *Module) ProcessTransmittedEvents(eventDocs []*model.EventDocument)
ProcessTransmittedEvents processes the event received
func (*Module) QueueEvent ¶ added in v0.12.1
QueueEvent queues a new event
Source Files
Click to show internal directories.
Click to hide internal directories.