mon

Documentation

Index

• type Config
• type Error
• type File
• type Request
  • func (r *Request) Init() (err error)
  • func (r *Request) Validate() (err error)
• type Response
  • func NewResponse() *Response
  • func (r *Response) AddError(object storage.Object, message string)
  • func (r *Response) AddProcessed(route *config.Rule, object storage.Object)
  • func (r *Response) AddUnprocessed(now time.Time, route *config.Rule, file storage.Object)
• type Routes
• type RuleInfo
  • func NewWorkflow(info base.Info) *RuleInfo
• type Service
  • func New(config *Config) Service
  • func NewFromEnv(envKey string) (Service, error)

Types

type Config

type Config struct {
	base.Config
}

Config represents monitoring config

type Error

type Error struct {
	Message string
	URL     string
	Created time.Time
}

Error represents an error

type File

type File struct {
	URL      string
	Age      string
	Modified time.Time
	Size     int
}

File represents workflow file

type Request

type Request struct {
	UnprocessedDuration string

	ProcessedURL     string
	ProcessedRecency string

	ErrorRecency string

	ConfigURL  string
	TriggerURL string
	ErrorURL   string
	// contains filtered or unexported fields
}

Request represents monitoring request

func (*Request) Init

func (r *Request) Init() (err error)

Load initialises request

func (*Request) Validate

func (r *Request) Validate() (err error)

Validate check if request is valid

type Response

type Response struct {
	UnprocessedCount int
	MaxDelayInSec    int `json:",omitempty"`
	ProcessCount     int `json:",omitempty"`
	ProcessedBytes   int `json:",omitempty"`
	ErrorCount       int
	Rules            []*RuleInfo `json:",omitempty"`
	Errors           []*Error    `json:",omitempty"`
	Status           string
	Error            string `json:",omitempty"`
	// contains filtered or unexported fields
}

Response represents monitoring response

func NewResponse

func NewResponse() *Response

NewResponse create a response

func (*Response) AddError

func (r *Response) AddError(object storage.Object, message string)

func (*Response) AddProcessed

func (r *Response) AddProcessed(route *config.Rule, object storage.Object)

func (*Response) AddUnprocessed

func (r *Response) AddUnprocessed(now time.Time, route *config.Rule, file storage.Object)

type Routes

type Routes struct {
	Mirrors config.Ruleset
}

Ruleset represents route config

type RuleInfo

type RuleInfo struct {
	base.Info
	ProcessedCount   int
	MaxProcessedSize int
	MinProcessedSize int
	UnprocessedCount int     `json:",omitempty"`
	DelaySec         int     `json:",omitempty"`
	Unprocessed      []*File `json:",omitempty"`
}

RuleInfo represents workflow info with unprocessed files

func NewWorkflow

func NewWorkflow(info base.Info) *RuleInfo

NewWorkflow create a workflow

type Service

type Service interface {
	//Check checks un process file and mirror errors
	Check(context.Context, *Request) *Response
}

Service represents monitoring service

func New

func New(config *Config) Service

New creates monitoring service

func NewFromEnv

func NewFromEnv(envKey string) (Service, error)

NewFromEnv returns singleton service for env key