checks

Documentation

Index

• Constants
• Variables
• func AdditionalPreChecks() ...
• func LoggingContextForCheck(checkType string, uuid string, environment string, transactionID string) string
• func ScheduleChecks(p *SchedulerParam, subscribedFeeds map[string][]feeds.Feed, ...)
• func МainPreChecks() ...
• type ContentCheck
  • func NewContentCheck(httpCaller httpcaller.Caller) ContentCheck
• type ContentNeo4jCheck
  • func NewContentNeo4jCheck(httpCaller httpcaller.Caller) ContentNeo4jCheck
• type EndpointSpecificCheck
• type NotificationsCheck
  • func NewNotificationsCheck(httpCaller httpcaller.Caller, subscribedFeeds map[string][]feeds.Feed, ...) NotificationsCheck
• type PublishCheck
  • func NewPublishCheck(pm metrics.PublishMetric, username string, password string, t int, ci int, ...) *PublishCheck
  • func (pc PublishCheck) DoCheck() (checkSuccessful, ignoreCheck bool)
  • func (pc PublishCheck) String() string
• type S3Check
  • func NewS3Check(httpCaller httpcaller.Caller) S3Check
• type SchedulerParam

Constants

const DateLayout = time.RFC3339Nano

Variables

var (
	AbsoluteURLRegex = regexp.MustCompile("(?i)https?://.*")
)

Functions

func AdditionalPreChecks

func AdditionalPreChecks() []func(publishedContent content.Content, tid string, publishDate time.Time, appConfig *config.AppConfig, metricContainer *metrics.History, environments *envs.Environments) (bool, *SchedulerParam)

func LoggingContextForCheck

func LoggingContextForCheck(checkType string, uuid string, environment string, transactionID string) string

func ScheduleChecks

func ScheduleChecks(p *SchedulerParam, subscribedFeeds map[string][]feeds.Feed, endpointSpecificChecks map[string]EndpointSpecificCheck, appConfig *config.AppConfig, metricSink chan metrics.PublishMetric, e2eTestUUIDs []string)

func МainPreChecks

func МainPreChecks() []func(publishedContent content.Content, tid string, publishDate time.Time, appConfig *config.AppConfig, metricContainer *metrics.History, environments *envs.Environments) (bool, *SchedulerParam)

Types

type ContentCheck

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

ContentCheck implements the EndpointSpecificCheck interface to check operation status for the content endpoint.

func NewContentCheck

func NewContentCheck(httpCaller httpcaller.Caller) ContentCheck

type ContentNeo4jCheck

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

ContentNeo4jCheck implements the EndpointSpecificCheck interface to check operation status for the content endpoint.

func NewContentNeo4jCheck

func NewContentNeo4jCheck(httpCaller httpcaller.Caller) ContentNeo4jCheck

type EndpointSpecificCheck

type EndpointSpecificCheck interface {
	// contains filtered or unexported methods
}

EndpointSpecificCheck is the interface which determines the state of the operation we are currently checking.

type NotificationsCheck

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

NotificationsCheck implements the EndpointSpecificCheck interface to build the endpoint URL and to check the operation is present in the notification feed

func NewNotificationsCheck

func NewNotificationsCheck(httpCaller httpcaller.Caller, subscribedFeeds map[string][]feeds.Feed, feedName string) NotificationsCheck

type PublishCheck

type PublishCheck struct {
	Metric metrics.PublishMetric

	Threshold     int
	CheckInterval int
	ResultSink    chan metrics.PublishMetric
	// contains filtered or unexported fields
}

PublishCheck performs an availability check on a piece of content, at a given endpoint, and returns whether the check was successful or not. Holds all the information necessary to check content availability at an endpoint, as well as store and send the results of the check.

func NewPublishCheck

func NewPublishCheck(pm metrics.PublishMetric, username string, password string, t int, ci int, rs chan metrics.PublishMetric, endpointSpecificChecks map[string]EndpointSpecificCheck) *PublishCheck

NewPublishCheck returns a PublishCheck ready to perform a check for pm.UUID, at the pm.Endpoint.

func (PublishCheck) DoCheck

func (pc PublishCheck) DoCheck() (checkSuccessful, ignoreCheck bool)

DoCheck performs an availability check on a piece of content at a certain endpoint, applying endpoint-specific processing. Returns true if the content is available at the endpoint, false otherwise.

func (PublishCheck) String

func (pc PublishCheck) String() string

type S3Check

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

S3Check implements the EndpointSpecificCheck interface to check operation status for the S3 endpoint.

func NewS3Check

func NewS3Check(httpCaller httpcaller.Caller) S3Check

type SchedulerParam

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