Documentation ¶
Index ¶
- type Storage
- func (s *Storage) AgentInfoStore(appName, agentID string, startTime int64, agentInfo []byte) error
- func (s *Storage) AgentStore(agentInfo *network.AgentInfo, islive bool) error
- func (s *Storage) AppMethodStore(appName string, apiInfo *trace.TApiMetaData) error
- func (s *Storage) AppNameStore(name string) error
- func (s *Storage) AppSQLStore(appName string, sqlInfo *trace.TSqlMetaData) error
- func (s *Storage) AppStringStore(appName string, strInfo *trace.TStringMetaData) error
- func (s *Storage) Close() error
- func (s *Storage) GetStaticCql() *gocql.Session
- func (s *Storage) GetTraceCql() *gocql.Session
- func (s *Storage) InsertAPIMapStats(appName string, appType int32, inputTime int64, apiStr string, ...) error
- func (s *Storage) InsertAPIStats(appName string, inputDate int64, urlStr string, url *stats.Url) error
- func (s *Storage) InsertDubboStats(appName string, inputDate int64, dubboApi string, dubbo *stats.Dubbo) error
- func (s *Storage) InsertExceptionStats(appName string, inputTime int64, methodID int32, ...) error
- func (s *Storage) InsertMethodStats(appName string, inputTime int64, apiStr string, methodID int32, ...) error
- func (s *Storage) InsertSQLStats(appName string, inputTime int64, sqlID int32, sqlInfo *stats.SQL) error
- func (s *Storage) InsertTargetMap(appName string, appType int32, inputDate int64, targetType int32, ...) error
- func (s *Storage) InsertUnknowParentMap(targetName string, targetType int32, inputDate int64, ...) error
- func (s *Storage) SpanChunkStore(span *trace.TSpanChunk)
- func (s *Storage) SpanStore(span *trace.TSpan)
- func (s *Storage) Start() error
- func (s *Storage) StoreAPI(span *trace.TSpan) error
- func (s *Storage) UpdateAgentState(appname string, agentid string, islive bool) error
- func (s *Storage) WriteAgentStat(appName, agentID string, agentStat *pinpoint.TAgentStat, infoB []byte) error
- func (s *Storage) WriteAgentStatBatch(appName, agentID string, agentStatBatch *pinpoint.TAgentStatBatch, ...) error
- func (s *Storage) WriteSpan(span *trace.TSpan) error
- func (s *Storage) WriteSpan2(spans []*trace.TSpan) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Storage ¶
type Storage struct {
// contains filtered or unexported fields
}
Storage 存储
func (*Storage) AgentInfoStore ¶
AgentInfoStore ...
func (*Storage) AgentStore ¶
AgentStore agent信息存储
func (*Storage) AppMethodStore ¶
func (s *Storage) AppMethodStore(appName string, apiInfo *trace.TApiMetaData) error
AppMethodStore ...
func (*Storage) AppNameStore ¶
AppNameStore 存储Appname
func (*Storage) AppSQLStore ¶
func (s *Storage) AppSQLStore(appName string, sqlInfo *trace.TSqlMetaData) error
AppSQLStore sql语句存储,sql语句需要base64转码,防止sql注入
func (*Storage) AppStringStore ¶
func (s *Storage) AppStringStore(appName string, strInfo *trace.TStringMetaData) error
AppStringStore ...
func (*Storage) InsertAPIMapStats ¶
func (s *Storage) InsertAPIMapStats(appName string, appType int32, inputTime int64, apiStr string, parentname string, parentInfo *stats.Parent) error
InsertAPIMapStats Api被调用统计信息
func (*Storage) InsertAPIStats ¶
func (s *Storage) InsertAPIStats(appName string, inputDate int64, urlStr string, url *stats.Url) error
InsertAPIStats ...
func (*Storage) InsertDubboStats ¶
func (s *Storage) InsertDubboStats(appName string, inputDate int64, dubboApi string, dubbo *stats.Dubbo) error
InsertDubboStats ...
func (*Storage) InsertExceptionStats ¶
func (s *Storage) InsertExceptionStats(appName string, inputTime int64, methodID int32, exceptions map[int32]*stats.Exception) error
InsertExceptionStats ...
func (*Storage) InsertMethodStats ¶
func (s *Storage) InsertMethodStats(appName string, inputTime int64, apiStr string, methodID int32, methodInfo *stats.Method) error
InsertMethodStats 接口计算数据存储
func (*Storage) InsertSQLStats ¶
func (s *Storage) InsertSQLStats(appName string, inputTime int64, sqlID int32, sqlInfo *stats.SQL) error
InsertSQLStats ...
func (*Storage) InsertTargetMap ¶
func (s *Storage) InsertTargetMap(appName string, appType int32, inputDate int64, targetType int32, targetName string, target *stats.Target) error
InsertTargetMap ...
func (*Storage) InsertUnknowParentMap ¶
func (s *Storage) InsertUnknowParentMap(targetName string, targetType int32, inputDate int64, unknowParent *stats.UnknowParent) error
InsertUnknowParentMap ...
func (*Storage) SpanChunkStore ¶
func (s *Storage) SpanChunkStore(span *trace.TSpanChunk)
SpanChunkStore spanChunk存储
func (*Storage) UpdateAgentState ¶
UpdateAgentState agent在线状态更新
func (*Storage) WriteAgentStat ¶
func (s *Storage) WriteAgentStat(appName, agentID string, agentStat *pinpoint.TAgentStat, infoB []byte) error
WriteAgentStat ...
func (*Storage) WriteAgentStatBatch ¶
func (s *Storage) WriteAgentStatBatch(appName, agentID string, agentStatBatch *pinpoint.TAgentStatBatch, infoB []byte) error
WriteAgentStatBatch ....
Click to show internal directories.
Click to hide internal directories.