data

package
v0.1.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 31, 2019 License: BSD-3-Clause Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Cycle 

type Cycle struct {
	Cycle int       `db:"cycle"json:"cycle"`
	ID    uuid.UUID `db:"id" json:"id"`
	RanAt time.Time `db:"ran_at" json:"ran_at"`
	Took  string    `db:"took" json:"took"`
}

func (Cycle) String 

func (c Cycle) String() string

type CycleData 

type CycleData struct {
	Cycle         *Cycle
	MonitoredData chan *MonitoredData
	Extension     string
	Path          string
}

type CycleService 

type CycleService struct {
	// contains filtered or unexported fields
}

func (CycleService) DeleteAllBeforeTime 

func (c CycleService) DeleteAllBeforeTime(timeToDelete time.Time) error

func (CycleService) GetAll 

func (c CycleService) GetAll() (chan Cycle, error)

func (CycleService) GetAllBeforeTime 

func (c CycleService) GetAllBeforeTime(timeToDelete time.Time) (chan Cycle, error)

func (CycleService) Save 

func (c CycleService) Save(cycle Cycle) error

func (CycleService) Update 

func (c CycleService) Update(cycle Cycle) error

type DB 

type DB struct {
	*sqlx.DB

	SlaveStatusService      SlaveStatusService
	MysqlProcessListService MysqlProcessListService
	EngineInnoDBService     EngineInnoDBService
	CycleService            CycleService
	ThreadsService          ThreadsService
	UnixProcessListService  UnixProcessListService
	TopService              TopService
	FileOnDiskService       FileOnDiskService
	// contains filtered or unexported fields
}

func GetDB 

func GetDB(file string) *DB

type EngineINNODBStatus 

type EngineINNODBStatus struct {
	ID      int       `db:"id" json:"-"`
	CycleID uuid.UUID `db:"cycle_id"json:"-"`

	Name   string `db:"name" json:"name"`
	Type   string `db:"type" json:"type"`
	Status string `db:"status" json:"status"`
}

type EngineInnoDBService 

type EngineInnoDBService struct {
	// contains filtered or unexported fields
}

func (EngineInnoDBService) GetAllByCycle 

func (e EngineInnoDBService) GetAllByCycle(cycleID uuid.UUID) (chan EngineINNODBStatus, error)

func (EngineInnoDBService) Save 

func (e EngineInnoDBService) Save(status *EngineINNODBStatus) error

type FileOnDiskService 

type FileOnDiskService struct {
	// contains filtered or unexported fields
}

func (FileOnDiskService) GetAllPathByCycleID 

func (f FileOnDiskService) GetAllPathByCycleID(cycleID uuid.UUID) (chan string, error)

func (FileOnDiskService) Save 

func (f FileOnDiskService) Save(cycleID uuid.UUID, path string) error

type MonitoredData 

type MonitoredData struct {
	SlaveStatus        *SlaveStatus
	MysqlProcessList   *MysqlProcessList
	EngineINNODBStatus *EngineINNODBStatus
	Thread             *Thread
	UnixProcessList    *UnixProcessList
	Top                *Top
}

type MysqlProcessList 

type MysqlProcessList struct {
	ItemID  int       `json:"-"db:"itemId"`
	CycleID uuid.UUID `db:"cycle_id"json:"-"`

	ID           uint64         `json:"id" db:"id"`
	User         string         `json:"user" db:"user"`
	Host         string         `json:"host" db:"host"`
	DB           sql.NullString `json:"db" db:"db"swaggertype:"primitive,string"`
	Command      string         `json:"command" db:"command"`
	Time         int64          `json:"time" db:"time"`
	State        sql.NullString `json:"state" db:"state"swaggertype:"primitive,string"`
	Info         sql.NullString `json:"info" db:"info"swaggertype:"primitive,string"`
	RowsSent     uint64         `json:"rows_sent" db:"rows_sent"`
	RowsExamined uint64         `json:"rows_examined" db:"rows_examined"`
}

func (*MysqlProcessList) MarshalJSON 

func (m *MysqlProcessList) MarshalJSON() ([]byte, error)

type MysqlProcessListService 

type MysqlProcessListService struct {
	// contains filtered or unexported fields
}

func (MysqlProcessListService) GetAllByCycle 

func (m MysqlProcessListService) GetAllByCycle(cycleID uuid.UUID) (chan MysqlProcessList, error)

func (MysqlProcessListService) Save 

func (m MysqlProcessListService) Save(list *MysqlProcessList) error

type SlaveStatus 

type SlaveStatus struct {
	ID      int       `json:"-"db:"id"`
	CycleID uuid.UUID `db:"cycle_id"json:"-"`

	MasterLogFile             string         `json:"master_log_file" db:"Master_Log_File"`
	MasterHost                string         `json:"master_host" db:"Master_Host"`
	MasterUser                string         `json:"master_user" db:"Master_User"`
	MasterPort                string         `json:"master_port" db:"Master_Port"`
	ConnectRetry              string         `json:"connect_retry" db:"Connect_Retry"`
	ReadMasterLogPos          int            `json:"read_master_log_pos" db:"Read_Master_Log_Pos"`
	RelayLogFile              string         `json:"relay_log_file" db:"Relay_Log_File"`
	RelayLogPos               int            `json:"relay_log_pos" db:"Relay_Log_Pos"`
	RelayMasterLogFile        string         `json:"relay_master_log_file" db:"Relay_Master_Log_File"`
	SlaveIoRunning            string         `json:"slave_io_running" db:"Slave_IO_Running"`
	SlaveIoState              string         `json:"slave_io_state" db:"Slave_IO_State"`
	SlaveIoStatus             string         `json:"slave_io_status" db:"Slave_IO_Status"`
	SlaveSqlRunning           string         `json:"slave_sql_running" db:"Slave_SQL_Running"`
	ReplicateDodb             sql.NullString `json:"replicate_do_db" db:"Replicate_Do_DB"swaggertype:"primitive,string"`
	ReplicateIgnoredb         sql.NullString `json:"replicate_ignore_db" db:"Replicate_Ignore_DB"swaggertype:"primitive,string"`
	ReplicateDoTable          sql.NullString `json:"replicate_do_table" db:"Replicate_Do_Table"swaggertype:"primitive,string"`
	ReplicateIgnoreTable      sql.NullString `json:"replicate_ignore_table" db:"Replicate_Ignore_Table"swaggertype:"primitive,string"`
	ReplicateWildDoTable      sql.NullString `json:"replicate_wild_do_table" db:"Replicate_Wild_Do_Table"swaggertype:"primitive,string"`
	ReplicateWildIgnoreTable  sql.NullString `json:"replicate_wild_ignore_table" db:"Replicate_Wild_Ignore_Table"swaggertype:"primitive,string"`
	LastErrno                 int            `json:"last_errno" db:"Last_Errno"`
	LastError                 sql.NullString `json:"last_error" db:"Last_Error"swaggertype:"primitive,string"`
	SkipCounter               int            `json:"skip_counter" db:"Skip_Counter"`
	ExecMasterLogPos          int            `json:"exec_master_log_pos" db:"Exec_Master_Log_Pos"`
	RelayLogSpace             int            `json:"relay_log_space" db:"Relay_Log_Space"`
	UntilCondition            string         `json:"until_condition" db:"Until_Condition"`
	UntilLogFile              string         `json:"until_log_file" db:"Until_Log_File"`
	UntilLogPos               int            `json:"until_log_pos" db:"Until_Log_Pos"`
	MasterSslAllowed          string         `json:"master_ssl_allowed" db:"Master_SSL_Allowed"`
	MasterSslCaFile           sql.NullString `json:"master_ssl_ca_file" db:"Master_SSL_CA_File"swaggertype:"primitive,string"`
	MasterSslCaPath           sql.NullString `json:"master_ssl_ca_path" db:"Master_SSL_CA_Path"swaggertype:"primitive,string"`
	MasterSslCert             sql.NullString `json:"master_ssl_cert" db:"Master_SSL_Cert"swaggertype:"primitive,string"`
	MasterSslCipher           sql.NullString `json:"master_ssl_cipher" db:"Master_SSL_Cipher"swaggertype:"primitive,string"`
	MasterSslKey              sql.NullString `json:"master_ssl_key" db:"Master_SSL_Key"swaggertype:"primitive,string"`
	SecondsBehindMaster       int            `json:"seconds_behind_master" db:"Seconds_Behind_Master"`
	MasterSslVerifyServerCert string         `json:"master_ssl_verify_server_cert" db:"Master_SSL_Verify_Server_Cert"`
	LastIoErrno               int            `json:"last_io_errno" db:"Last_IO_Errno"`
	LastIoError               sql.NullString `json:"last_io_error" db:"Last_IO_Error"swaggertype:"primitive,string"`
	LastSqlErrno              int            `json:"last_sql_errno" db:"Last_SQL_Errno"`
	LastSqlError              sql.NullString `json:"last_sql_error" db:"Last_SQL_Error"swaggertype:"primitive,string"`
	ReplicateIgnoreServerIds  interface{}    `json:"replicate_ignore_server_ids" db:"Replicate_Ignore_Server_Ids"`
	MasterServerId            int            `json:"master_server_id" db:"Master_Server_Id"`
	MasterUuid                uuid.UUID      `json:"master_uuid" db:"Master_UUID"`
	MasterInfoFile            string         `json:"master_info_file" db:"Master_Info_File"`
	SqlDelay                  int            `json:"sql_delay" db:"SQL_Delay"`
	SqlRemainingDelay         sql.NullInt64  `json:"sql_remaining_delay" db:"SQL_Remaining_Delay"`
	SlaveSqlRunningState      string         `json:"slave_sql_running_state" db:"Slave_SQL_Running_State"`
	SlaveStatus               string         `json:"slave_status" db:"Slave_Status"`
	MasterRetryCount          int            `json:"master_retry_count" db:"Master_Retry_Count"`
	MasterBind                sql.NullString `json:"master_bind" db:"Master_Bind"swaggertype:"primitive,string"`
	LastIoErrorTimestamp      sql.NullString `json:"last_io_error_timestamp" db:"Last_IO_Error_Timestamp"swaggertype:"primitive,string"`
	LastSqlErrorTimestamp     sql.NullString `json:"last_sql_error_timestamp" db:"Last_SQL_Error_Timestamp"swaggertype:"primitive,string"`
	MasterSslCrl              sql.NullString `json:"master_ssl_crl" db:"Master_SSL_Crl"swaggertype:"primitive,string"`
	MasterSslCrlpath          sql.NullString `json:"master_ssl_crlpath" db:"Master_SSL_Crlpath"swaggertype:"primitive,string"`
	RetrievedGtidSet          sql.NullString `json:"retrieved_gtid_set" db:"Retrieved_Gtid_Set"swaggertype:"primitive,string"`
	ExecutedGtidSet           sql.NullString `json:"executed_gtid_set" db:"Executed_Gtid_Set"swaggertype:"primitive,string"`
	AutoPosition              int            `json:"auto_position" db:"Auto_Position"`
	ReplicateRewritedb        sql.NullString `json:"replicate_rewrite_db" db:"Replicate_Rewrite_DB"swaggertype:"primitive,string"`
	ChannelName               sql.NullString `json:"channel_name" db:"Channel_Name"swaggertype:"primitive,string"`
	MasterTlsVersion          sql.NullString `json:"master_tls_version" db:"Master_TLS_Version"swaggertype:"primitive,string"`
}

func (*SlaveStatus) MarshalJSON 

func (s *SlaveStatus) MarshalJSON() ([]byte, error)

type SlaveStatusService 

type SlaveStatusService struct {
	// contains filtered or unexported fields
}

func (SlaveStatusService) GetAllByCycle 

func (s SlaveStatusService) GetAllByCycle(cycleID uuid.UUID) (chan SlaveStatus, error)

func (SlaveStatusService) Save 

func (s SlaveStatusService) Save(status *SlaveStatus) error

type Thread 

type Thread struct {
	ID      int       `db:"id"json:"-"`
	CycleID uuid.UUID `db:"cycle_id"json:"-"`

	ThreadID           int64          `json:"thread_id" db:"thread_id"`
	Name               string         `json:"name" db:"name"`
	Type               string         `json:"type" db:"type"`
	ProcessListID      sql.NullInt64  `json:"process_list_id" db:"processlist_id"swaggertype:"primitive,integer"`
	ProcessListUser    sql.NullString `json:"process_list_user" db:"processlist_user"swaggertype:"primitive,string"`
	ProcessListHost    sql.NullString `json:"process_list_host" db:"processlist_host"swaggertype:"primitive,string"`
	ProcessListDB      sql.NullString `json:"process_list_db" db:"processlist_db"swaggertype:"primitive,string"`
	ProcessListCommand sql.NullString `json:"process_list_command" db:"processlist_command"swaggertype:"primitive,string"`
	ProcessListTime    sql.NullInt64  `json:"process_list_time" db:"processlist_time"swaggertype:"primitive,string"`
	ProcessListState   sql.NullString `json:"process_list_state" db:"processlist_state"swaggertype:"primitive,string"`
	ProcessListInfo    sql.NullString `json:"process_list_info" db:"processlist_info"swaggertype:"primitive,string"`
	ParentThreadID     sql.NullInt64  `json:"parent_thread_id" db:"parent_thread_id"swaggertype:"primitive,integer"`
	Role               sql.NullString `json:"role" db:"role"swaggertype:"primitive,string"`
	Instrumented       string         `json:"instrumented" db:"instrumented"`
	History            string         `json:"history" db:"history"`
	ConnectionType     sql.NullString `json:"connection_type" db:"connection_type"swaggertype:"primitive,integer"`
	ThreadOsID         sql.NullInt64  `json:"thread_os_id" db:"thread_os_id"swaggertype:"primitive,integer"`
}

func (*Thread) MarshalJSON 

func (t *Thread) MarshalJSON() ([]byte, error)

type ThreadsService 

type ThreadsService struct {
	// contains filtered or unexported fields
}

func (ThreadsService) GetAllByCycle 

func (t ThreadsService) GetAllByCycle(cycleID uuid.UUID) (chan Thread, error)

func (ThreadsService) Save 

func (t ThreadsService) Save(thread *Thread) error

type Top 

type Top struct {
	ID      int       `db:"id"json:"-"`
	CycleID uuid.UUID `db:"cycle_id"json:"-"`

	Text string `db:"text"json:"text"`
}

type TopService 

type TopService struct {
	// contains filtered or unexported fields
}

func (TopService) GetAllByCycle 

func (t TopService) GetAllByCycle(cycleID uuid.UUID) (chan Top, error)

func (TopService) Save 

func (t TopService) Save(top *Top) error

type UnixProcessList 

type UnixProcessList struct {
	ID      int       `db:"id"json:"-"`
	CycleID uuid.UUID `db:"cycle_id"json:"-"`

	Text string `db:"text"json:"text"`
}

type UnixProcessListService 

type UnixProcessListService struct {
	// contains filtered or unexported fields
}

func (UnixProcessListService) GetAllByCycle 

func (u UnixProcessListService) GetAllByCycle(cycleID uuid.UUID) (chan UnixProcessList, error)

func (UnixProcessListService) Save 

func (u UnixProcessListService) Save(list *UnixProcessList) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.