resources

Apr 9, 2020

Changes in this version

type HealthCheck

+ StatusFunc RequestStatusFn

+ type RequestStatusFn func(ctx context.Context, url string) (int, error)

Mar 4, 2020

Changes in this version

+ const APIKeyHeaderField

+ const ClientAdrKey

+ const HeartbeatMsg

type HealthCheck

+ func (h *HealthCheck) RegisterHandlers(r *mux.Router)

+ type KeyErr struct

+ KeySuffix string

+ Msg string

+ Status int

+ func NewKeyErr(msg string, status int, key string) *KeyErr

+ func (e *KeyErr) Error() string

+ type KeyValidator struct

+ APIGatewayURL string

+ func NewKeyValidator(url string, client *http.Client, log *logger.UPPLogger) *KeyValidator

+ func (v *KeyValidator) Validate(ctx context.Context, key string) error

+ type SubHandler struct

+ func NewSubHandler(dispatcher dispatch.Registrar, validator keyValidator, ...) *SubHandler

+ func (h *SubHandler) HandleSubscription(w http.ResponseWriter, r *http.Request)

+ func (h *SubHandler) RegisterHandlers(r *mux.Router)

Oct 29, 2019

Changes in this version

+ func History(history dispatch.History) func(w http.ResponseWriter, r *http.Request)

+ func Push(reg dispatch.Registrar, apiGatewayKeyValidationURL string, ...) func(w http.ResponseWriter, r *http.Request)

+ func Stats(dispatcher dispatch.Dispatcher) func(w http.ResponseWriter, r *http.Request)

+ type HealthCheck struct

+ ApiGatewayGTGAddress string

+ Consumer KafkaConsumer

+ HttpClient HealthCheckHttpClient

+ func NewHealthCheck(kafkaConsumer KafkaConsumer, apiGatewayGTGAddress string, ...) *HealthCheck

+ func (h *HealthCheck) GTG() gtg.Status

+ func (h *HealthCheck) Health() func(w http.ResponseWriter, r *http.Request)

+ type HealthCheckHttpClient interface

+ GetStatusCode func(url string) (int, error)

+ type HttpClient struct

+ func (hc *HttpClient) GetStatusCode(url string) (int, error)

+ type KafkaConsumer interface

+ ConnectivityCheck func() error