resources

Documentation

Index

• Constants
• func History(history dispatch.History, log *logger.UPPLogger) func(w http.ResponseWriter, r *http.Request)
• func Stats(provider clientsProvider, log *logger.UPPLogger) func(w http.ResponseWriter, r *http.Request)
• type HealthCheck
  • 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 KafkaConsumer
• type KeyErr
  • func NewKeyErr(msg string, status int, key string) *KeyErr
  • func (e *KeyErr) Error() string
• type KeyValidator
  • func NewKeyValidator(url string, client *http.Client, log *logger.UPPLogger) *KeyValidator
  • func (v *KeyValidator) Validate(ctx context.Context, key string) error
• type RequestStatusFn
• type SubHandler
  • func NewSubHandler(n notifier, validator keyValidator, shutdown onShutdown, ...) *SubHandler
  • func (h *SubHandler) HandleSubscription(w http.ResponseWriter, r *http.Request)

Constants

const (
	HeartbeatMsg = "[]"

	ClientAdrKey = "X-Forwarded-For"
)

const APIKeyHeaderField = "X-Api-Key"

Functions

func History

func History(history dispatch.History, log *logger.UPPLogger) func(w http.ResponseWriter, r *http.Request)

History returns history data

func Stats

func Stats(provider clientsProvider, log *logger.UPPLogger) func(w http.ResponseWriter, r *http.Request)

Stats returns subscriber stats

Types

type HealthCheck

type HealthCheck struct {
	StatusFunc RequestStatusFn
	// contains filtered or unexported fields
}

func NewHealthCheck

func NewHealthCheck(kafkaConsumer KafkaConsumer, apiGatewayGTGAddress string, statusFunc RequestStatusFn) *HealthCheck

func (*HealthCheck) GTG

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

func (*HealthCheck) Health

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

type KafkaConsumer

type KafkaConsumer interface {
	ConnectivityCheck() error
}

type KeyErr

type KeyErr struct {
	Msg       string
	Status    int
	KeySuffix string
}

func NewKeyErr

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

func (*KeyErr) Error

func (e *KeyErr) Error() string

type KeyValidator

type KeyValidator struct {
	APIGatewayURL string
	// contains filtered or unexported fields
}

func NewKeyValidator

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

func (*KeyValidator) Validate

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

type RequestStatusFn

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

type SubHandler

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

SubHandler manages subscription requests

func NewSubHandler

func NewSubHandler(n notifier,
	validator keyValidator,
	shutdown onShutdown,
	heartbeatPeriod time.Duration,
	log *logger.UPPLogger) *SubHandler

func (*SubHandler) HandleSubscription

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