webhook

package
v0.21.1 Latest Latest
Warning

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

Go to latest
Published: Jul 24, 2022 License: MIT Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type App

type App struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

App of package

func New

func New(config Config, storageApp absto.Storage, prometheusRegisterer prometheus.Registerer, amqpClient *amqp.Client, rendererApp renderer.App, thumbnailApp thumbnail.App) (*App, error)

New creates new App from Config

func (*App) AmqpHandler added in v0.11.0

func (a *App) AmqpHandler(message amqp.Delivery) error

AmqpHandler handle exif message

func (*App) Create

func (a *App) Create(ctx context.Context, pathname string, recursive bool, kind provider.WebhookKind, url string, types []provider.EventType) (string, error)

Create a webhook

func (*App) Delete

func (a *App) Delete(ctx context.Context, id string) error

Delete a webhook

func (*App) EventConsumer

func (a *App) EventConsumer(ctx context.Context, event provider.Event)

EventConsumer handle event pushed to the event bus

func (*App) Exclusive added in v0.11.0

func (a *App) Exclusive(ctx context.Context, name string, duration time.Duration, action func(ctx context.Context) error) error

Exclusive does action on webhook with exclusive lock

func (*App) List

func (a *App) List() (webhooks []provider.Webhook)

List webhooks

func (*App) Start

func (a *App) Start(_ <-chan struct{})

Start worker

type Config

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

Config of package

func Flags

func Flags(fs *flag.FlagSet, prefix string) Config

Flags adds flags for configuring package

Jump to

Keyboard shortcuts

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