Versions in this module Expand all Collapse all v0 v0.1.2 May 31, 2019 v0.1.1 May 31, 2019 v0.1.0 May 14, 2019 Changes in this version + type Cycle struct + Cycle int + ID uuid.UUID + RanAt time.Time + Took string + func (c Cycle) String() string + type CycleData struct + Cycle *Cycle + Extension string + MonitoredData chan *MonitoredData + Path string + type CycleService struct + func (c CycleService) DeleteAllBeforeTime(timeToDelete time.Time) error + func (c CycleService) GetAll() (chan Cycle, error) + func (c CycleService) GetAllBeforeTime(timeToDelete time.Time) (chan Cycle, error) + func (c CycleService) Save(cycle Cycle) error + func (c CycleService) Update(cycle Cycle) error + type DB struct + CycleService CycleService + EngineInnoDBService EngineInnoDBService + FileOnDiskService FileOnDiskService + MysqlProcessListService MysqlProcessListService + SlaveStatusService SlaveStatusService + ThreadsService ThreadsService + TopService TopService + UnixProcessListService UnixProcessListService + func GetDB(file string) *DB + type EngineINNODBStatus struct + CycleID uuid.UUID + ID int + Name string + Status string + Type string + type EngineInnoDBService struct + func (e EngineInnoDBService) GetAllByCycle(cycleID uuid.UUID) (chan EngineINNODBStatus, error) + func (e EngineInnoDBService) Save(status *EngineINNODBStatus) error + type FileOnDiskService struct + func (f FileOnDiskService) GetAllPathByCycleID(cycleID uuid.UUID) (chan string, error) + func (f FileOnDiskService) Save(cycleID uuid.UUID, path string) error + type MonitoredData struct + EngineINNODBStatus *EngineINNODBStatus + MysqlProcessList *MysqlProcessList + SlaveStatus *SlaveStatus + Thread *Thread + Top *Top + UnixProcessList *UnixProcessList + type MysqlProcessList struct + Command string + CycleID uuid.UUID + DB sql.NullString + Host string + ID uint64 + Info sql.NullString + ItemID int + RowsExamined uint64 + RowsSent uint64 + State sql.NullString + Time int64 + User string + func (m *MysqlProcessList) MarshalJSON() ([]byte, error) + type MysqlProcessListService struct + func (m MysqlProcessListService) GetAllByCycle(cycleID uuid.UUID) (chan MysqlProcessList, error) + func (m MysqlProcessListService) Save(list *MysqlProcessList) error + type SlaveStatus struct + AutoPosition int + ChannelName sql.NullString + ConnectRetry string + CycleID uuid.UUID + ExecMasterLogPos int + ExecutedGtidSet sql.NullString + ID int + LastErrno int + LastError sql.NullString + LastIoErrno int + LastIoError sql.NullString + LastIoErrorTimestamp sql.NullString + LastSqlErrno int + LastSqlError sql.NullString + LastSqlErrorTimestamp sql.NullString + MasterBind sql.NullString + MasterHost string + MasterInfoFile string + MasterLogFile string + MasterPort string + MasterRetryCount int + MasterServerId int + MasterSslAllowed string + MasterSslCaFile sql.NullString + MasterSslCaPath sql.NullString + MasterSslCert sql.NullString + MasterSslCipher sql.NullString + MasterSslCrl sql.NullString + MasterSslCrlpath sql.NullString + MasterSslKey sql.NullString + MasterSslVerifyServerCert string + MasterTlsVersion sql.NullString + MasterUser string + MasterUuid uuid.UUID + ReadMasterLogPos int + RelayLogFile string + RelayLogPos int + RelayLogSpace int + RelayMasterLogFile string + ReplicateDoTable sql.NullString + ReplicateDodb sql.NullString + ReplicateIgnoreServerIds interface{} + ReplicateIgnoreTable sql.NullString + ReplicateIgnoredb sql.NullString + ReplicateRewritedb sql.NullString + ReplicateWildDoTable sql.NullString + ReplicateWildIgnoreTable sql.NullString + RetrievedGtidSet sql.NullString + SecondsBehindMaster int + SkipCounter int + SlaveIoRunning string + SlaveIoState string + SlaveIoStatus string + SlaveSqlRunning string + SlaveSqlRunningState string + SlaveStatus string + SqlDelay int + SqlRemainingDelay sql.NullInt64 + UntilCondition string + UntilLogFile string + UntilLogPos int + func (s *SlaveStatus) MarshalJSON() ([]byte, error) + type SlaveStatusService struct + func (s SlaveStatusService) GetAllByCycle(cycleID uuid.UUID) (chan SlaveStatus, error) + func (s SlaveStatusService) Save(status *SlaveStatus) error + type Thread struct + ConnectionType sql.NullString + CycleID uuid.UUID + History string + ID int + Instrumented string + Name string + ParentThreadID sql.NullInt64 + ProcessListCommand sql.NullString + ProcessListDB sql.NullString + ProcessListHost sql.NullString + ProcessListID sql.NullInt64 + ProcessListInfo sql.NullString + ProcessListState sql.NullString + ProcessListTime sql.NullInt64 + ProcessListUser sql.NullString + Role sql.NullString + ThreadID int64 + ThreadOsID sql.NullInt64 + Type string + func (t *Thread) MarshalJSON() ([]byte, error) + type ThreadsService struct + func (t ThreadsService) GetAllByCycle(cycleID uuid.UUID) (chan Thread, error) + func (t ThreadsService) Save(thread *Thread) error + type Top struct + CycleID uuid.UUID + ID int + Text string + type TopService struct + func (t TopService) GetAllByCycle(cycleID uuid.UUID) (chan Top, error) + func (t TopService) Save(top *Top) error + type UnixProcessList struct + CycleID uuid.UUID + ID int + Text string + type UnixProcessListService struct + func (u UnixProcessListService) GetAllByCycle(cycleID uuid.UUID) (chan UnixProcessList, error) + func (u UnixProcessListService) Save(list *UnixProcessList) error