service

Documentation

Index

• Constants
• func New(ctx context.Context, envs *env.Map, stdLogger *stdLog.Logger) (webhooks.Service, error)
• type Service
  • func (s *Service) Flush(_ context.Context, payload *webhooks.FlushPayload) (res string, err error)
  • func (s *Service) HealthCheck(_ context.Context) (res string, err error)
  • func (s *Service) Import(ctx context.Context, payload *webhooks.ImportPayload, bodyStream io.ReadCloser) (res *webhooks.ImportResult, err error)
  • func (s *Service) IndexRoot(_ context.Context) (res *webhooks.Index, err error)
  • func (s *Service) Register(_ context.Context, payload *webhooks.RegisterPayload) (res *webhooks.RegistrationResult, err error)
  • func (s *Service) StartCron()
  • func (s *Service) Update(_ context.Context, payload *webhooks.UpdatePayload) (res *webhooks.UpdateResult, err error)

Constants

const (
	WebhookCheckInterval = 15 * time.Second
	HeadersCtxKey        = ctxKey("headers")
)

Functions

func New

func New(ctx context.Context, envs *env.Map, stdLogger *stdLog.Logger) (webhooks.Service, error)

Types

type Service

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

func (*Service) Flush

func (s *Service) Flush(_ context.Context, payload *webhooks.FlushPayload) (res string, err error)

func (*Service) HealthCheck

func (s *Service) HealthCheck(_ context.Context) (res string, err error)

func (*Service) Import

func (s *Service) Import(ctx context.Context, payload *webhooks.ImportPayload, bodyStream io.ReadCloser) (res *webhooks.ImportResult, err error)

func (*Service) IndexRoot

func (s *Service) IndexRoot(_ context.Context) (res *webhooks.Index, err error)

func (*Service) Register

func (s *Service) Register(_ context.Context, payload *webhooks.RegisterPayload) (res *webhooks.RegistrationResult, err error)

func (*Service) StartCron

func (s *Service) StartCron()

func (*Service) Update

func (s *Service) Update(_ context.Context, payload *webhooks.UpdatePayload) (res *webhooks.UpdateResult, err error)