monitor

Documentation

Index

• Constants
• type Authentication
• type Endpoint
  • func NewEndpoint(url, accessKey, secret string) Endpoint
  • func NewEndpointFromURL(url string) Endpoint
• type IMonitor
• type Monitor
  • func NewMonitor(viper *viper.Viper) *Monitor
  • func (m *Monitor) IsTargetedSlashEvent(event abci.Event) bool
  • func (m *Monitor) Scan()
  • func (m *Monitor) Stop()
• type RetryConfig
  • func NewRetryConfig(timeout time.Duration, attempts int) RetryConfig

Constants

const (
	ServiceSlashingEventType = "service_slash"
)

Types

type Authentication

type Authentication struct {
	AccessKey string
	Secret    string
}

type Endpoint

type Endpoint struct {
	URL  string
	Auth Authentication
}

func NewEndpoint

func NewEndpoint(url, accessKey, secret string) Endpoint

func NewEndpointFromURL

func NewEndpointFromURL(url string) Endpoint

type IMonitor

type IMonitor interface {
	Start()
	Stop()
}

type Monitor

type Monitor struct {
	Client            servicesdk.ServiceClient
	RPCEndpoint       Endpoint
	GRPCEndpoint      Endpoint
	Interval          time.Duration
	Threshold         int64
	ProviderAddresses map[string]bool

	Stopped bool
	// contains filtered or unexported fields
}

func NewMonitor

func NewMonitor(viper *viper.Viper) *Monitor

func (*Monitor) IsTargetedSlashEvent

func (m *Monitor) IsTargetedSlashEvent(event abci.Event) bool

func (*Monitor) Scan

func (m *Monitor) Scan()

func (*Monitor) Stop

func (m *Monitor) Stop()

type RetryConfig

type RetryConfig struct {
	Timeout  time.Duration
	Attempts int
}

func NewRetryConfig

func NewRetryConfig(timeout time.Duration, attempts int) RetryConfig