Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

monitor

package

Go to main page

Versions in this module

v2

v2.2.0

Nov 14, 2022

v2.1.0

Oct 22, 2022

Changes in this version

type TaskInfo

+ CreatedAt time.Time

+ func (task *TaskInfo) IsInited() bool

v2.0.0

Jul 20, 2022

Changes in this version

+ type ApplicationInfo struct

+ Host string

+ Hostname string

+ InitedAt time.Time

+ Name string

+ Servers map[string]time.Time

+ Tasks map[string][]string

+ func (app *ApplicationInfo) Merge(info *ApplicationInfo)

+ type ClusterInfoReader interface

+ ApplicationInfo func() (*ApplicationInfo, error)

+ ListOfNodes func() (map[string][]string, int, error)

+ TaskInfo func(name string) (*TaskInfo, error)

+ TaskInfoByID func(id string) (*TaskInfo, error)

+ type EventType interface

+ CreatedAt func() time.Time

+ Err func() error

+ ID func() uuid.UUID

+ Name func() string

+ func NewErrorEvent(err error) EventType

+ func WrapEventWithName(name string, event EventType) EventType

+ type MetricReader interface

+ ApplicationInfo func() *ApplicationInfo

+ FailoverTaskInfo func(name string) (*TaskInfo, error)

+ ReceiveCount func() (uint64, error)

+ TaskInfo func(name string) (*TaskInfo, error)

+ type MetricUpdater interface

+ DeregisterApplication func() error

+ ExecuteFailoverTask func(event EventType, execTime time.Duration) error

+ ExecuteTask func(event EventType, execTime time.Duration) error

+ ReceiveEvent func(event EventType) error

+ RegisterApplication func(appInfo *ApplicationInfo) error

+ type Storage interface

+ type TaskInfo struct

+ AvgExecTime time.Duration

+ ErrorCount uint64

+ MaxExecTime time.Duration

+ MinExecTime time.Duration

+ SkipCount uint64

+ SuccessCount uint64

+ TaskNames []string

+ TotalCount uint64

+ UpdatedAt time.Time

+ func (task *TaskInfo) Add(info *TaskInfo)

+ func (task *TaskInfo) AddTaskName(name string)

+ func (task *TaskInfo) Inc(err error, execTime time.Duration)

Other modules containing this package

github.com/demdxx/asyncp