webhook

May 4, 2024

Changes in this version

+ const DefaultSecretID

+ const EndpointRetryCount

+ const SignatureHeader

+ var ErrConflict = errors.New("webhook already exist")

+ var ErrDisabled = errors.New("webhook is disabled")

+ var ErrInvalidDetail = errors.New("invalid webhook details")

+ var ErrInvalidUUID = errors.New("invalid syntax of uuid")

+ var ErrNotFound = errors.New("webhook doesn't exist")

+ type Config struct

+ EncryptionKey string

+ type Endpoint struct

+ CreatedAt time.Time

+ Description string

+ Headers map[string]string

+ ID string

+ Metadata metadata.Metadata

+ Secrets []Secret

+ State State

+ SubscribedEvents []string

+ URL string

+ UpdatedAt time.Time

+ type EndpointFilter struct

+ State State

+ type EndpointRepository interface

+ Create func(ctx context.Context, endpoint Endpoint) (Endpoint, error)

+ Delete func(ctx context.Context, id string) error

+ List func(ctx context.Context, filter EndpointFilter) ([]Endpoint, error)

+ UpdateByID func(ctx context.Context, endpoint Endpoint) (Endpoint, error)

+ type Event struct

+ Action string

+ CreatedAt time.Time

+ Data metadata.Metadata

+ ID string

+ type Secret struct

+ ID string

+ Value string

+ type Service struct

+ func NewService(eRepo EndpointRepository) *Service

+ func (s Service) CreateEndpoint(ctx context.Context, endpoint Endpoint) (Endpoint, error)

+ func (s Service) DeleteEndpoint(ctx context.Context, id string) error

+ func (s Service) ListEndpoints(ctx context.Context, filter EndpointFilter) ([]Endpoint, error)

+ func (s Service) Publish(ctx context.Context, evt Event) error

+ func (s Service) UpdateEndpoint(ctx context.Context, endpoint Endpoint) (Endpoint, error)

+ type State string

+ const Disabled

+ const Enabled