storage

Documentation

Index

• type Storage
  • func NewStorage(logger *zap.Logger) *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

Types

type Storage

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

Storage 存储

func NewStorage

func NewStorage(logger *zap.Logger) *Storage

NewStorage 新建存储

func (*Storage) AgentInfoStore

func (s *Storage) AgentInfoStore(appName, agentID string, startTime int64, agentInfo []byte) error

AgentInfoStore ...

func (*Storage) AgentStore

func (s *Storage) AgentStore(agentInfo *network.AgentInfo, islive bool) error

AgentStore agent信息存储

func (*Storage) AppMethodStore

func (s *Storage) AppMethodStore(appName string, apiInfo *trace.TApiMetaData) error

AppMethodStore ...

func (*Storage) AppNameStore

func (s *Storage) AppNameStore(name string) error

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) Close

func (s *Storage) Close() error

Close ...

func (*Storage) GetStaticCql

func (s *Storage) GetStaticCql() *gocql.Session

GetCql 获取cql

func (*Storage) GetTraceCql

func (s *Storage) GetTraceCql() *gocql.Session

GetCql 获取cql

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) SpanStore

func (s *Storage) SpanStore(span *trace.TSpan)

SpanStore span存储

func (*Storage) Start

func (s *Storage) Start() error

Start ...

func (*Storage) StoreAPI

func (s *Storage) StoreAPI(span *trace.TSpan) error

StoreAPI 存储API信息

func (*Storage) UpdateAgentState

func (s *Storage) UpdateAgentState(appname string, agentid string, islive bool) error

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 ....

func (*Storage) WriteSpan

func (s *Storage) WriteSpan(span *trace.TSpan) error

WriteSpan ...

func (*Storage) WriteSpan2

func (s *Storage) WriteSpan2(spans []*trace.TSpan) error

WriteSpan2 ...