hooks

package

v1.1.0 Latest Latest Go to latest Published: Apr 6, 2026 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/patent-dev/bulk-file-loader

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func AllEvents() []string
func IsValidEvent(event string) bool
func ParseEvents(eventsJSON string) []string
type Alert
type Delivery
type Error
type Event
- func NewEvent(eventType, source string) *Event
type File
type Manager
- func New(db *database.DB) *Manager
type Product

Constants ¶

View Source

const (
	EventFileAvailable     = "file.available"
	EventDownloadStarted   = "download.started"
	EventDownloadCompleted = "download.completed"
	EventDownloadFailed    = "download.failed"
	EventDownloadCancelled = "download.cancelled"
	EventChecksumMismatch  = "checksum.mismatch"
	EventSyncCompleted     = "sync.completed"
	EventSyncFailed        = "sync.failed"
)

Variables ¶

This section is empty.

Functions ¶

func AllEvents ¶

func AllEvents() []string

func IsValidEvent ¶

func IsValidEvent(event string) bool

func ParseEvents ¶

func ParseEvents(eventsJSON string) []string

Types ¶

type Alert ¶

type Alert struct {
	Type     string `json:"type"`
	Message  string `json:"message"`
	Severity string `json:"severity"` // "info", "warning", "error"
}

type Delivery ¶

type Delivery struct {
	ID   string `json:"id"`
	Name string `json:"name"`
}

type Error ¶

type Error struct {
	Code    string `json:"code"`
	Message string `json:"message"`
}

type Event ¶

type Event struct {
	Type      string    `json:"event"`
	Timestamp time.Time `json:"timestamp"`
	Source    string    `json:"source"`
	Product   *Product  `json:"product,omitempty"`
	Delivery  *Delivery `json:"delivery,omitempty"`
	File      *File     `json:"file,omitempty"`
	Alerts    []Alert   `json:"alerts,omitempty"`
	Error     *Error    `json:"error,omitempty"`
}

func NewEvent ¶

func NewEvent(eventType, source string) *Event

func (*Event) WithAlert ¶

func (e *Event) WithAlert(alertType, message, severity string) *Event

func (*Event) WithDelivery ¶

func (e *Event) WithDelivery(id, name string) *Event

func (*Event) WithError ¶

func (e *Event) WithError(code, message string) *Event

func (*Event) WithFile ¶

func (e *Event) WithFile(id, name string, size int64, checksum, path string) *Event

func (*Event) WithProduct ¶

func (e *Event) WithProduct(id, name string) *Event

type File ¶

type File struct {
	ID       string `json:"id"`
	Name     string `json:"name"`
	Size     int64  `json:"size"`
	Checksum string `json:"checksum,omitempty"`
	Path     string `json:"path,omitempty"`
}

type Manager ¶

type Manager struct {
	// contains filtered or unexported fields
}

func New ¶

func New(db *database.DB) *Manager

func (*Manager) CreateWebhook ¶

func (m *Manager) CreateWebhook(name, url string, events []string) (*database.Webhook, error)

func (*Manager) DeleteWebhook ¶

func (m *Manager) DeleteWebhook(id uint) error

func (*Manager) Emit ¶

func (m *Manager) Emit(ctx context.Context, event *Event)

func (*Manager) GetWebhook ¶

func (m *Manager) GetWebhook(id uint) (*database.Webhook, error)

func (*Manager) ListWebhooks ¶

func (m *Manager) ListWebhooks() ([]database.Webhook, error)

func (*Manager) SetDisabled ¶ added in v0.2.0

func (m *Manager) SetDisabled(disabled bool)

func (*Manager) UpdateWebhook ¶

func (m *Manager) UpdateWebhook(id uint, name, url string, events []string, enabled bool) error

type Product ¶

type Product struct {
	ID   string `json:"id"`
	Name string `json:"name"`
}

Source Files ¶

View all Source files

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