webhook

Mar 15, 2021

Changes in this version

+ func ProvideMetrics() fx.Option

Apr 11, 2019

Changes in this version

+ const DEFAULT_EXPIRATION_DURATION

+ const DEFAULT_UNDERTAKER_INTERVAL

+ const ListSize

+ const NotificationUnmarshallFailed

+ func Metrics() []xmetrics.Metric

+ type Factory struct

+ Start *StartConfig

+ Tick func(time.Duration) <-chan time.Time

+ UndertakerInterval time.Duration

+ func NewFactory(v *viper.Viper) (f *Factory, err error)

+ func (f *Factory) NewRegistryAndHandler(registry xmetrics.Registry) (Registry, http.Handler)

+ func (f *Factory) Prune(items []W) (list []W)

+ func (f *Factory) SetExternalUpdate(fn func([]W))

+ func (f *Factory) SetList(ul UpdatableList)

+ type List interface

+ Get func(int) *W

+ Len func() int

+ type Registry struct

+ Changes chan []W

+ func NewRegistry(mon *monitor) Registry

+ func (r *Registry) GetRegistry(rw http.ResponseWriter, req *http.Request)

+ func (r *Registry) UpdateRegistry(rw http.ResponseWriter, req *http.Request)

+ type Result struct

+ Error error

+ Hooks []W

+ type StartConfig struct

+ ApiPath string

+ AuthHeader string

+ Duration time.Duration

+ Sat struct{ ... }

+ func NewStartFactory(v *viper.Viper) (sc *StartConfig)

+ func (sc *StartConfig) GetCurrentSystemsHooks(rc chan Result)

+ type UpdatableList interface

+ Filter func(func([]W) []W)

+ Update func([]W)

+ func NewList(initial []W) UpdatableList

+ type W struct

+ Address string

+ Config struct{ ... }

+ Duration time.Duration

+ Events []string

+ FailureURL string

+ Matcher struct{ ... }

+ Until time.Time

+ func NewW(jsonString []byte, ip string) (w *W, err error)

+ func (w *W) ID() string

+ type WebhookMetrics struct

+ ListSize metrics.Gauge

+ NotificationUnmarshallFailed metrics.Counter

+ func ApplyMetricsData(registry xmetrics.Registry) (m WebhookMetrics)