detector

Documentation

Index

• Constants
• type Detector
  • func (dtc *Detector) AddRecord(record RecordDetail, serviceGroup string)
  • func (dtc *Detector) ClearIncidentReport() error
  • func (dtc *Detector) GetIncidentCountAll() (map[string]map[string]int, int)
  • func (dtc *Detector) GetIncidentCountByService(ServiceGroup string) map[string]int
  • func (dtc *Detector) GetIncidentReportByService(ServiceGroup string) map[string][]RecordDetail
  • func (dtc *Detector) GetIncidentReportByServiceAndType(ServiceGroup string, recordType string) []RecordDetail
  • func (dtc *Detector) RecordLog(ctx context.Context, in *logger.LogRequest) (*emptypb.Empty, error)
  • func (dtc *Detector) StartService(port int)
• type RecordDetail
• type ServiceRecorder

Constants

const (
	RECORDTYPE_LOSTCONNECTION = "lost_connection"
	RECORDTYPE_CRITICAL       = "critical"
	RECORDTYPE_DEBUG          = "debug"
	RECORDTYPE_OTHER          = "other"
	RECORDTYPE_SUSPECT_CRASH  = "suspect_crash"
)

Types

type Detector

type Detector struct {
	Lck      sync.RWMutex
	Services map[string]ServiceRecorder

	logger.UnimplementedLoggerServer
}

func (*Detector) AddRecord

func (dtc *Detector) AddRecord(record RecordDetail, serviceGroup string)

func (*Detector) ClearIncidentReport

func (dtc *Detector) ClearIncidentReport() error

func (*Detector) GetIncidentCountAll

func (dtc *Detector) GetIncidentCountAll() (map[string]map[string]int, int)

func (*Detector) GetIncidentCountByService

func (dtc *Detector) GetIncidentCountByService(ServiceGroup string) map[string]int

func (*Detector) GetIncidentReportByService

func (dtc *Detector) GetIncidentReportByService(ServiceGroup string) map[string][]RecordDetail

func (*Detector) GetIncidentReportByServiceAndType

func (dtc *Detector) GetIncidentReportByServiceAndType(ServiceGroup string, recordType string) []RecordDetail

func (*Detector) RecordLog

func (dtc *Detector) RecordLog(ctx context.Context, in *logger.LogRequest) (*emptypb.Empty, error)

func (*Detector) StartService

func (dtc *Detector) StartService(port int)

type RecordDetail

type RecordDetail struct {
	ServiceID string
	Type      string
	Reason    string
	Time      int64
}

type ServiceRecorder

type ServiceRecorder struct {
	Records map[string][]RecordDetail // map[RECORD_TYPE][]RecordDetail
}