resources

Documentation

Index

• func ReadNotifications(mapper mapping.NotificationsMapper, nextLink mapping.NextLinkGenerator, ...) func(w http.ResponseWriter, r *http.Request)
• func UpdateLogLevel(log *logger.UPPLogger) func(w http.ResponseWriter, r *http.Request)
• func WriteNotification(dumpRequests bool, mapper mapping.NotificationsMapper, ...) func(w http.ResponseWriter, r *http.Request)
• type Filters
  • func Filter(next func(w http.ResponseWriter, r *http.Request), log *logger.UPPLogger) Filters
  • func (f Filters) Build() func(w http.ResponseWriter, r *http.Request)
  • func (f Filters) FilterCarouselPublishes(finder notificationFinder) Filters
  • func (f Filters) FilterSyntheticTransactions() Filters
  • func (f Filters) Gunzip() Filters
• type HealthService
  • func NewHealthService(db databaseHealthChecker, appSystemCode string, appName string, ...) *HealthService
  • func (service *HealthService) GTG() gtg.Status
  • func (service *HealthService) HealthChecksHandler() func(w http.ResponseWriter, r *http.Request)

Functions

func ReadNotifications

func ReadNotifications(mapper mapping.NotificationsMapper, nextLink mapping.NextLinkGenerator, reader notificationReader, maxSinceInterval int, log *logger.UPPLogger) func(w http.ResponseWriter, r *http.Request)

ReadNotifications reads notifications from the backing db

func UpdateLogLevel

func UpdateLogLevel(log *logger.UPPLogger) func(w http.ResponseWriter, r *http.Request)

UpdateLogLevel changes the logrus log level dynamically.

func WriteNotification

func WriteNotification(dumpRequests bool, mapper mapping.NotificationsMapper, writer notificationWriter, log *logger.UPPLogger) func(w http.ResponseWriter, r *http.Request)

WriteNotification will write a new notification for the provided list.

Types

type Filters

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

Filters contains the composed chain

func Filter

func Filter(next func(w http.ResponseWriter, r *http.Request), log *logger.UPPLogger) Filters

Filter creates a new composable filter.

func (Filters) Build

func (f Filters) Build() func(w http.ResponseWriter, r *http.Request)

Build returns the final chained handler

func (Filters) FilterCarouselPublishes

func (f Filters) FilterCarouselPublishes(finder notificationFinder) Filters

FilterCarouselPublishes checks whether this is a carousel publish and processes it accordingly

func (Filters) FilterSyntheticTransactions

func (f Filters) FilterSyntheticTransactions() Filters

FilterSyntheticTransactions will filter out incoming requests if they have a synthetic prefix.

func (Filters) Gunzip

func (f Filters) Gunzip() Filters

Gunzip pre-processes the request body if it's gzipped.

type HealthService

type HealthService struct {
	fthealth.TimedHealthCheck
}

func NewHealthService

func NewHealthService(db databaseHealthChecker, appSystemCode string, appName string, appDescription string) *HealthService

func (*HealthService) GTG

func (service *HealthService) GTG() gtg.Status

GTG lightly tests the service and returns an FT standard GTG response

func (*HealthService) HealthChecksHandler

func (service *HealthService) HealthChecksHandler() func(w http.ResponseWriter, r *http.Request)

HealthChecksHandler HealthChecks returns a handler for the standard FT health checks