Documentation
¶
Index ¶
- type Module
- func (m *Module) CloseConfig() error
- func (m *Module) CreateFileIntentHook(ctx context.Context, req *model.CreateFileRequest) (*model.EventIntent, error)
- func (m *Module) DeleteFileIntentHook(ctx context.Context, path string, meta map[string]interface{}) (*model.EventIntent, error)
- func (m *Module) HookStage(ctx context.Context, intent *model.EventIntent, err error)
- func (m *Module) IsEnabled() bool
- func (m *Module) MakeInvocationHTTPRequest(ctx context.Context, client model.HTTPEventingInterface, ...) error
- func (m *Module) ProcessEventResponseMessage(ctx context.Context, batchID string, payload interface{})
- func (m *Module) ProcessTransmittedEvents(eventDocs []*model.EventDocument)
- func (m *Module) QueueAdminEvent(ctx context.Context, reqs []*model.QueueEventRequest) error
- func (m *Module) QueueEvent(ctx context.Context, project, token string, req *model.QueueEventRequest) (interface{}, error)
- func (m *Module) SetConfig(projectID string, eventing *config.EventingConfig) error
- func (m *Module) SetInternalTriggersFromDbRules(dbRules config.DatabaseRules)
- func (m *Module) SetRealtimeTriggers(eventingRules []*config.EventingTrigger)
- func (m *Module) SetSchemaConfig(evSchemas config.EventingSchemas) error
- func (m *Module) SetSecurityRuleConfig(rules map[string]*config.Rule) error
- func (m *Module) SetTriggerConfig(triggers config.EventingTriggers) 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(clusterID, projectID, nodeID string, auth model.AuthEventingInterface, crud model.CrudEventingInterface, syncMan *syncman.Manager, file model.FilestoreEventingInterface, hook model.MetricEventingHook) (*Module, error)
New creates a new instance of the eventing module
func (*Module) CloseConfig ¶
CloseConfig closes the module config
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, meta map[string]interface{}) (*model.EventIntent, error)
DeleteFileIntentHook handles the delete file intent requests
func (*Module) MakeInvocationHTTPRequest ¶
func (m *Module) MakeInvocationHTTPRequest(ctx context.Context, client model.HTTPEventingInterface, method, url, eventID, token, scToken string, payload, vPtr interface{}) error
MakeInvocationHTTPRequest fires an http request and returns a response
func (*Module) ProcessEventResponseMessage ¶
func (m *Module) ProcessEventResponseMessage(ctx context.Context, batchID string, payload interface{})
ProcessEventResponseMessage sends response to client via channel
func (*Module) ProcessTransmittedEvents ¶
func (m *Module) ProcessTransmittedEvents(eventDocs []*model.EventDocument)
ProcessTransmittedEvents processes the event received
func (*Module) QueueAdminEvent ¶
QueueAdminEvent queues a new event created by the admin. This does no validation and hence must be used cautiously. For most use cases, consider using QueueEvent instead.
func (*Module) QueueEvent ¶
func (m *Module) QueueEvent(ctx context.Context, project, token string, req *model.QueueEventRequest) (interface{}, error)
QueueEvent queues a new event
func (*Module) SetConfig ¶
func (m *Module) SetConfig(projectID string, eventing *config.EventingConfig) error
SetConfig sets the module config
func (*Module) SetInternalTriggersFromDbRules ¶
func (m *Module) SetInternalTriggersFromDbRules(dbRules config.DatabaseRules)
SetInternalTriggersFromDbRules set internal triggers from db rules
func (*Module) SetRealtimeTriggers ¶
func (m *Module) SetRealtimeTriggers(eventingRules []*config.EventingTrigger)
SetRealtimeTriggers adds triggers which are used for space cloud internally
func (*Module) SetSchemaConfig ¶
func (m *Module) SetSchemaConfig(evSchemas config.EventingSchemas) error
SetSchemaConfig sets schema config of eventing module
func (*Module) SetSecurityRuleConfig ¶
SetSecurityRuleConfig set security rule config of eventing module
func (*Module) SetTriggerConfig ¶
func (m *Module) SetTriggerConfig(triggers config.EventingTriggers) error
SetTriggerConfig sets eventing trigger config of eventing module
Source Files