Documentation ¶
Index ¶
- func ConvertFromClickhouseStatRequest(data *StatRequest) (*apiPb.GetAgentInformationResponse_Statistic, error)
- func ConvertFromClickhouseStatRequests(data []*StatRequest) []*apiPb.GetAgentInformationResponse_Statistic
- func ConvertFromSnapshots(snapshots []*Snapshot) []*apiPb.SchedulerSnapshot
- type CPUInfo
- type Clickhouse
- func (c *Clickhouse) GetActiveIncidentByRuleId(ruleId string) (*apiPb.Incident, error)
- func (c *Clickhouse) GetCPUInfo(agentID string, pagination *apiPb.Pagination, filter *apiPb.TimeFilter) ([]*apiPb.GetAgentInformationResponse_Statistic, int32, error)
- func (c *Clickhouse) GetDiskInfo(agentID string, pagination *apiPb.Pagination, filter *apiPb.TimeFilter) ([]*apiPb.GetAgentInformationResponse_Statistic, int32, error)
- func (c *Clickhouse) GetIncidentById(id string) (*apiPb.Incident, error)
- func (c *Clickhouse) GetIncidents(request *apiPb.GetIncidentsListRequest) ([]*apiPb.Incident, int64, error)
- func (c *Clickhouse) GetMemoryInfo(agentID string, pagination *apiPb.Pagination, filter *apiPb.TimeFilter) ([]*apiPb.GetAgentInformationResponse_Statistic, int32, error)
- func (c *Clickhouse) GetNetInfo(agentID string, pagination *apiPb.Pagination, filter *apiPb.TimeFilter) ([]*apiPb.GetAgentInformationResponse_Statistic, int32, error)
- func (c *Clickhouse) GetSnapshots(request *apiPb.GetSchedulerInformationRequest) ([]*apiPb.SchedulerSnapshot, int32, error)
- func (c *Clickhouse) GetSnapshotsUptime(request *apiPb.GetSchedulerUptimeRequest) (*apiPb.GetSchedulerUptimeResponse, error)
- func (c *Clickhouse) GetStatRequest(agentID string, pagination *apiPb.Pagination, filter *apiPb.TimeFilter) ([]*apiPb.GetAgentInformationResponse_Statistic, int32, error)
- func (c *Clickhouse) GetTransactionByID(request *apiPb.GetTransactionByIdRequest) (*apiPb.TransactionInfo, []*apiPb.TransactionInfo, error)
- func (c *Clickhouse) GetTransactionChildren(transactionId, cyclicalLoopCheck string) ([]*TransactionInfo, error)
- func (c *Clickhouse) GetTransactionGroup(request *apiPb.GetTransactionGroupRequest) (map[string]*apiPb.TransactionGroup, error)
- func (c *Clickhouse) GetTransactionInfo(request *apiPb.GetTransactionsRequest) ([]*apiPb.TransactionInfo, int64, error)
- func (c *Clickhouse) InsertIncident(data *apiPb.Incident) error
- func (c *Clickhouse) InsertSnapshot(data *apiPb.SchedulerResponse) error
- func (c *Clickhouse) InsertStatRequest(data *apiPb.Metric) error
- func (c *Clickhouse) InsertTransactionInfo(data *apiPb.TransactionInfo) error
- func (c *Clickhouse) Migrate() error
- func (c *Clickhouse) UpdateIncidentStatus(id string, status apiPb.IncidentStatus) (*apiPb.Incident, error)
- type DiskInfo
- type GroupResult
- type Incident
- type IncidentHistory
- type MemoryInfo
- type MemoryMem
- type MemorySwap
- type Model
- type NetInfo
- type Snapshot
- type StatRequest
- type TransactionInfo
- type UptimeResult
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func ConvertFromClickhouseStatRequest ¶
func ConvertFromClickhouseStatRequest(data *StatRequest) (*apiPb.GetAgentInformationResponse_Statistic, error)
func ConvertFromClickhouseStatRequests ¶
func ConvertFromClickhouseStatRequests(data []*StatRequest) []*apiPb.GetAgentInformationResponse_Statistic
func ConvertFromSnapshots ¶
func ConvertFromSnapshots(snapshots []*Snapshot) []*apiPb.SchedulerSnapshot
Types ¶
type Clickhouse ¶
func (*Clickhouse) GetActiveIncidentByRuleId ¶
func (c *Clickhouse) GetActiveIncidentByRuleId(ruleId string) (*apiPb.Incident, error)
func (*Clickhouse) GetCPUInfo ¶
func (c *Clickhouse) GetCPUInfo(agentID string, pagination *apiPb.Pagination, filter *apiPb.TimeFilter) ([]*apiPb.GetAgentInformationResponse_Statistic, int32, error)
func (*Clickhouse) GetDiskInfo ¶
func (c *Clickhouse) GetDiskInfo(agentID string, pagination *apiPb.Pagination, filter *apiPb.TimeFilter) ([]*apiPb.GetAgentInformationResponse_Statistic, int32, error)
func (*Clickhouse) GetIncidentById ¶
func (c *Clickhouse) GetIncidentById(id string) (*apiPb.Incident, error)
func (*Clickhouse) GetIncidents ¶
func (c *Clickhouse) GetIncidents(request *apiPb.GetIncidentsListRequest) ([]*apiPb.Incident, int64, error)
func (*Clickhouse) GetMemoryInfo ¶
func (c *Clickhouse) GetMemoryInfo(agentID string, pagination *apiPb.Pagination, filter *apiPb.TimeFilter) ([]*apiPb.GetAgentInformationResponse_Statistic, int32, error)
func (*Clickhouse) GetNetInfo ¶
func (c *Clickhouse) GetNetInfo(agentID string, pagination *apiPb.Pagination, filter *apiPb.TimeFilter) ([]*apiPb.GetAgentInformationResponse_Statistic, int32, error)
func (*Clickhouse) GetSnapshots ¶
func (c *Clickhouse) GetSnapshots(request *apiPb.GetSchedulerInformationRequest) ([]*apiPb.SchedulerSnapshot, int32, error)
func (*Clickhouse) GetSnapshotsUptime ¶
func (c *Clickhouse) GetSnapshotsUptime(request *apiPb.GetSchedulerUptimeRequest) (*apiPb.GetSchedulerUptimeResponse, error)
func (*Clickhouse) GetStatRequest ¶
func (c *Clickhouse) GetStatRequest(agentID string, pagination *apiPb.Pagination, filter *apiPb.TimeFilter) ([]*apiPb.GetAgentInformationResponse_Statistic, int32, error)
func (*Clickhouse) GetTransactionByID ¶
func (c *Clickhouse) GetTransactionByID(request *apiPb.GetTransactionByIdRequest) (*apiPb.TransactionInfo, []*apiPb.TransactionInfo, error)
func (*Clickhouse) GetTransactionChildren ¶
func (c *Clickhouse) GetTransactionChildren(transactionId, cyclicalLoopCheck string) ([]*TransactionInfo, error)
func (*Clickhouse) GetTransactionGroup ¶
func (c *Clickhouse) GetTransactionGroup(request *apiPb.GetTransactionGroupRequest) (map[string]*apiPb.TransactionGroup, error)
todo order
func (*Clickhouse) GetTransactionInfo ¶
func (c *Clickhouse) GetTransactionInfo(request *apiPb.GetTransactionsRequest) ([]*apiPb.TransactionInfo, int64, error)
func (*Clickhouse) InsertIncident ¶
func (c *Clickhouse) InsertIncident(data *apiPb.Incident) error
func (*Clickhouse) InsertSnapshot ¶
func (c *Clickhouse) InsertSnapshot(data *apiPb.SchedulerResponse) error
func (*Clickhouse) InsertStatRequest ¶
func (c *Clickhouse) InsertStatRequest(data *apiPb.Metric) error
func (*Clickhouse) InsertTransactionInfo ¶
func (c *Clickhouse) InsertTransactionInfo(data *apiPb.TransactionInfo) error
func (*Clickhouse) Migrate ¶
func (c *Clickhouse) Migrate() error
func (*Clickhouse) UpdateIncidentStatus ¶
func (c *Clickhouse) UpdateIncidentStatus(id string, status apiPb.IncidentStatus) (*apiPb.Incident, error)
type GroupResult ¶
type IncidentHistory ¶
type MemoryInfo ¶
type MemoryInfo struct { Model Model StatRequestID string Mem *MemoryMem Swap *MemorySwap }
type MemorySwap ¶
type Snapshot ¶
type Snapshot struct { Model Model SchedulerID string Code int32 Type int32 Error string MetaStartTime int64 MetaEndTime int64 MetaValue []byte }
func ConvertToSnapshot ¶
func ConvertToSnapshot(request *apiPb.SchedulerResponse) (*Snapshot, error)
type StatRequest ¶
type StatRequest struct { Model Model AgentID string AgentName string CPUInfo []*CPUInfo MemoryInfo *MemoryInfo DiskInfo []*DiskInfo NetInfo []*NetInfo Time time.Time }
func ConvertToClickhouseStatRequest ¶
func ConvertToClickhouseStatRequest(request *apiPb.Metric) (*StatRequest, error)
type TransactionInfo ¶
type UptimeResult ¶
Click to show internal directories.
Click to hide internal directories.