listener

package
v1.1.8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 15, 2023 License: MPL-2.0 Imports: 10 Imported by: 1

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{})

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL