webhook

Documentation

Index

• type Config
  • func Flags(fs *flag.FlagSet, prefix string) *Config
• type Service
  • func New(config *Config, storageService absto.Storage, ...) *Service
  • func (s *Service) Create(ctx context.Context, pathname string, recursive bool, ...) (string, error)
  • func (s *Service) Delete(ctx context.Context, id string) error
  • func (s *Service) Done() <-chan struct{}
  • func (s *Service) EventConsumer(ctx context.Context, event provider.Event)
  • func (s *Service) Exclusive(ctx context.Context, name string, action func(ctx context.Context) error) error
  • func (s *Service) List() (output []provider.Webhook)
  • func (s *Service) PubSubHandle(webhook provider.Webhook, err error)
  • func (s *Service) Start(ctx context.Context)

Types

type Config

type Config struct {
	HmacSecret    string
	PubsubChannel string
}

func Flags

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

type Service

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

func New

func New(config *Config, storageService absto.Storage, meterProvider metric.MeterProvider, redisClient redis.Client, rendererService *renderer.Service, thumbnailService thumbnail.Service, exclusiveApp exclusive.Service) *Service

func (*Service) Create

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

func (*Service) Delete

func (s *Service) Delete(ctx context.Context, id string) error

func (*Service) Done

func (s *Service) Done() <-chan struct{}

func (*Service) EventConsumer

func (s *Service) EventConsumer(ctx context.Context, event provider.Event)

func (*Service) Exclusive

func (s *Service) Exclusive(ctx context.Context, name string, action func(ctx context.Context) error) error

func (*Service) List

func (s *Service) List() (output []provider.Webhook)

func (*Service) PubSubHandle

func (s *Service) PubSubHandle(webhook provider.Webhook, err error)

func (*Service) Start

func (s *Service) Start(ctx context.Context)