Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type EndpointListener ¶
type EndpointListener struct {
// contains filtered or unexported fields
}
func NewEndpointListener ¶
func NewEndpointListener(queue queue.Queuer, projectRepo datastore.ProjectRepository, metaEventRepo datastore.MetaEventRepository) *EndpointListener
func (*EndpointListener) AfterCreate ¶
func (e *EndpointListener) AfterCreate(data interface{}, _ interface{})
func (*EndpointListener) AfterDelete ¶
func (e *EndpointListener) AfterDelete(data interface{}, _ interface{})
func (*EndpointListener) AfterUpdate ¶
func (e *EndpointListener) AfterUpdate(data interface{}, _ interface{})
type EventDeliveryListener ¶
type EventDeliveryListener struct {
// contains filtered or unexported fields
}
func NewEventDeliveryListener ¶
func NewEventDeliveryListener(queue queue.Queuer, projectRepo datastore.ProjectRepository, metaEventRepo datastore.MetaEventRepository) *EventDeliveryListener
func (*EventDeliveryListener) AfterUpdate ¶
func (e *EventDeliveryListener) AfterUpdate(data interface{}, _ interface{})
type MetaEventDelivery ¶
type MetaEventDelivery struct {
UID string `json:"uid"`
ProjectID string `json:"project_id,omitempty"`
EventID string `json:"event_id,omitempty"`
EndpointID string `json:"endpoint_id,omitempty"`
DeviceID string `json:"device_id"`
SubscriptionID string `json:"subscription_id,omitempty"`
Headers httpheader.HTTPHeader `json:"headers"`
URLQueryParams string `json:"url_query_params"`
IdempotencyKey string `json:"idempotency_key"`
Endpoint *datastore.Endpoint `json:"endpoint_metadata,omitempty"`
Event *datastore.Event `json:"event_metadata,omitempty"`
Source *datastore.Source `json:"source_metadata,omitempty"`
Device *datastore.Device `json:"device_metadata,omitempty"`
DeliveryAttempts datastore.DeliveryAttempt `json:"attempt"`
Status datastore.EventDeliveryStatus `json:"status"`
Metadata *datastore.Metadata `json:"metadata"`
CLIMetadata *datastore.CLIMetadata `json:"cli_metadata"`
Description string `json:"description,omitempty"`
CreatedAt time.Time `json:"created_at,omitempty"`
UpdatedAt time.Time `json:"updated_at,omitempty"`
DeletedAt null.Time `json:"deleted_at,omitempty"`
}
type ProjectListener ¶
type ProjectListener struct {
// contains filtered or unexported fields
}
func NewProjectListener ¶
func NewProjectListener(queue queue.Queuer) *ProjectListener
func (*ProjectListener) AfterUpdate ¶
func (e *ProjectListener) AfterUpdate(data interface{}, changelog interface{})
Click to show internal directories.
Click to hide internal directories.