ancla

Jan 10, 2023

Changes in this version

+ const ChrysomPollsTotalCounterHelp

+ const ChrysomPollsTotalCounterName

+ const WebhookListSizeGaugeHelp

+ const WebhookListSizeGaugeName

type Measures

+ ChrysomPollsTotalCounterName *prometheus.CounterVec

+ WebhookListSizeGaugeName prometheus.Gauge

type MeasuresIn

+ Factory *touchstone.Factory

+ type MeasuresOut struct

+ M *Measures

Aug 24, 2022

Changes in this version

+ func NewService(cfg Config, getLogger func(ctx context.Context) log.Logger) (*service, error)

type Config

+ BasicClientConfig chrysom.BasicClientConfig

+ type ListenerConfig struct

+ Config chrysom.ListenerClientConfig

+ Logger log.Logger

+ Measures Measures

Apr 28, 2022

Changes in this version

+ type CustomDuration time.Duration

+ func (cd *CustomDuration) UnmarshalJSON(b []byte) (err error)

+ func (cd CustomDuration) MarshalJSON() ([]byte, error)

+ func (cd CustomDuration) String() string

+ type InvalidDurationError struct

+ Value string

+ func (ide *InvalidDurationError) Error() string

+ type WebhookRegistration struct

+ Address string

+ Config DeliveryConfig

+ Duration CustomDuration

+ Events []string

+ FailureURL string

+ Matcher MetadataMatcherConfig

+ Until time.Time

+ func (w WebhookRegistration) ToWebhook() Webhook

Apr 26, 2022

Changes in this version

+ const ChrysomPollsTotalCounter

+ func ProvideMetrics() fx.Option

type Config

+ Measures Measures

+ type Measures struct

+ ChrysomPollsTotalCounter *prometheus.CounterVec

+ WebhookListSizeGauge metrics.Gauge

+ func NewMeasures(p xmetrics.Registry) *Measures

+ type MeasuresIn struct

+ ChrysomPollsTotalCounter *prometheus.CounterVec

+ WebhookListSizeGauge metrics.Gauge

Mar 25, 2022

Changes in this version

+ func InternalWebhookToItem(now func() time.Time, iw InternalWebhook) (model.Item, error)

type InternalWebhook

+ func ItemToInternalWebhook(i model.Item) (InternalWebhook, error)

+ func ItemsToInternalWebhooks(items []model.Item) ([]InternalWebhook, error)

type Webhook

+ func InternalWebhooksToWebhooks(iws []InternalWebhook) []Webhook

Nov 29, 2021

Changes in this version

+ type GetLoggerFunc func(context.Context) log.Logger

type HandlerConfig

+ GetLogger GetLoggerFunc

type ValidatorFunc

+ func AlwaysValid() ValidatorFunc

Nov 24, 2021

Changes in this version

+ type ArgusConfig struct

+ Listen chrysom.ListenerClientConfig

type Config

+ Validation ValidatorConfig

Oct 5, 2021

Changes in this version

type Config

+ DisablePartnerIDs bool

+ WebhookValidationConfig ValidatorConfig

Sep 28, 2021

Changes in this version

type HandlerConfig

+ DisablePartnerIDs bool

Sep 28, 2021

Changes in this version

+ var DefaultBasicPartnerIDsHeader = "X-Xmidt-Partner-Ids"

+ type InternalWebhook struct

+ PartnerIDs []string

+ Webhook Webhook

type Service

+ GetAll func(ctx context.Context) ([]InternalWebhook, error)

Sep 15, 2021

Changes in this version

type ValidURLFunc

+ func GoodURLScheme(httpsOnly bool) ValidURLFunc

Sep 14, 2021

Changes in this version

+ var SpecialUseHosts = []string

+ var SpecialUseIPs = []string

type HandlerConfig

+ V Validator

+ type TTLVConfig struct

+ Jitter time.Duration

+ Max time.Duration

+ Now func() time.Time

+ type URLVConfig struct

+ AllowIP bool

+ AllowLoopback bool

+ AllowSpecialUseHosts bool

+ AllowSpecialUseIPs bool

+ HTTPSOnly bool

+ InvalidHosts []string

+ InvalidSubnets []string

type ValidURLFunc

+ func InvalidSubnets(i []string) (ValidURLFunc, error)

+ type ValidatorConfig struct

+ TTL TTLVConfig

+ URL URLVConfig

type ValidatorFunc

+ func CheckDeviceID() ValidatorFunc

+ func CheckDuration(maxTTL time.Duration) (ValidatorFunc, error)

+ func CheckEvents() ValidatorFunc

+ func CheckUntil(jitter time.Duration, maxTTL time.Duration, now func() time.Time) (ValidatorFunc, error)

+ func CheckUntilOrDurationExist() ValidatorFunc

type Validators

+ func BuildValidators(config ValidatorConfig) (Validators, error)

Aug 31, 2021

Changes in this version

+ type ValidURLFunc func(*url.URL) error

+ func HTTPSOnlyEndpoints() ValidURLFunc

+ func RejectAllIPs() ValidURLFunc

+ func RejectHosts(invalidHosts []string) ValidURLFunc

+ func RejectLoopback() ValidURLFunc

+ type Validator interface

+ Validate func(w Webhook) error

+ type ValidatorFunc func(Webhook) error

+ func GoodAlternativeURLs(vs []ValidURLFunc) ValidatorFunc

+ func GoodConfigURL(vs []ValidURLFunc) ValidatorFunc

+ func GoodFailureURL(vs []ValidURLFunc) ValidatorFunc

+ func (vf ValidatorFunc) Validate(w Webhook) error

+ type Validators []Validator

+ func (vs Validators) Validate(w Webhook) error

May 27, 2021

Changes in this version

type Config

+ JWTParserType jwtAcquireParserType

Mar 6, 2021

Changes in this version

+ const URLLabel

+ const WebhookLegacyDecodeCount

type Config

+ Logger log.Logger

+ MetricsProvider provider.Provider

+ type DeliveryConfig struct

+ AlternativeURLs []string

+ ContentType string

+ Secret string

+ URL string

+ type HandlerConfig struct

+ MetricsProvider provider.Provider

+ type MetadataMatcherConfig struct

+ DeviceID []string

Feb 17, 2021

Changes in this version

+ const ClientIDHeader

+ const FailureOutcome

+ const OutcomeLabel

+ const PollCounter

+ const SuccessOutcome

+ const WebhookListSizeGauge

+ func Metrics() []xmetrics.Metric

+ func NewAddWebhookHandler(s Service) http.Handler

+ func NewGetAllWebhooksHandler(s Service) http.Handler

+ type Config struct

+ Argus chrysom.ClientConfig

+ WatchUpdateInterval time.Duration

+ type PushReader interface

+ type Pusher interface

+ Push func(item model.Item, owner string) (string, error)

+ Remove func(id string, owner string) (model.Item, error)

+ type Reader interface

+ GetItems func(owner string) ([]model.Item, error)

+ type Service interface

+ Add func(owner string, w *Webhook) error

+ AllWebhooks func(owner string) ([]Webhook, error)

+ func Initialize(cfg *Config, watches ...Watch) (Service, func(), error)

+ type Watch interface

+ Update func([]Webhook)

+ type WatchFunc func([]Webhook)

+ func (f WatchFunc) Update(update []Webhook)

+ type Webhook struct

+ Address string

+ Config struct{ ... }

+ Duration time.Duration

+ Events []string

+ FailureURL string

+ Matcher struct{ ... }

+ Until time.Time