store

Documentation

Index

• Variables
• type ProfileStorage
  • func NewProfileStorage(db *genji.DB) (*ProfileStorage, error)
  • func (s *ProfileStorage) AddProfile(pt meta.ProfileTarget, t time.Time, profileData []byte, profileErr error) error
  • func (s *ProfileStorage) Close()
  • func (s *ProfileStorage) GetTargetInfoFromCache(pt meta.ProfileTarget) *meta.TargetInfo
  • func (s *ProfileStorage) QueryGroupProfiles(param *meta.BasicQueryParam) ([]meta.ProfileList, error)
  • func (s *ProfileStorage) QueryProfileData(param *meta.BasicQueryParam, ...) error
  • func (s *ProfileStorage) QueryTargetProfileData(pt meta.ProfileTarget, ptInfo *meta.TargetInfo, param *meta.BasicQueryParam, ...) error
  • func (s *ProfileStorage) QueryTargetProfiles(pt meta.ProfileTarget, ptInfo *meta.TargetInfo, param *meta.BasicQueryParam) (meta.ProfileList, error)
  • func (s *ProfileStorage) UpdateProfileTargetInfo(pt meta.ProfileTarget, ts int64) (bool, error)
• type QueryLimiter
  • func (l *QueryLimiter) Add(n int)
  • func (l *QueryLimiter) IsFull() bool

Variables

var ErrStoreIsClosed = errors.New("storage is closed")

Types

type ProfileStorage

type ProfileStorage struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewProfileStorage

func NewProfileStorage(db *genji.DB) (*ProfileStorage, error)

func (*ProfileStorage) AddProfile

func (s *ProfileStorage) AddProfile(pt meta.ProfileTarget, t time.Time, profileData []byte, profileErr error) error

func (*ProfileStorage) Close

func (s *ProfileStorage) Close()

func (*ProfileStorage) GetTargetInfoFromCache

func (s *ProfileStorage) GetTargetInfoFromCache(pt meta.ProfileTarget) *meta.TargetInfo

func (*ProfileStorage) QueryGroupProfiles

func (s *ProfileStorage) QueryGroupProfiles(param *meta.BasicQueryParam) ([]meta.ProfileList, error)

func (*ProfileStorage) QueryProfileData

func (s *ProfileStorage) QueryProfileData(param *meta.BasicQueryParam, handleFn func(meta.ProfileTarget, int64, []byte) error) error

func (*ProfileStorage) QueryTargetProfileData

func (s *ProfileStorage) QueryTargetProfileData(pt meta.ProfileTarget, ptInfo *meta.TargetInfo, param *meta.BasicQueryParam, handleFn func(meta.ProfileTarget, int64, []byte) error) error

func (*ProfileStorage) QueryTargetProfiles

func (s *ProfileStorage) QueryTargetProfiles(pt meta.ProfileTarget, ptInfo *meta.TargetInfo, param *meta.BasicQueryParam) (meta.ProfileList, error)

func (*ProfileStorage) UpdateProfileTargetInfo

func (s *ProfileStorage) UpdateProfileTargetInfo(pt meta.ProfileTarget, ts int64) (bool, error)

type QueryLimiter

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

func (*QueryLimiter) Add

func (l *QueryLimiter) Add(n int)

func (*QueryLimiter) IsFull

func (l *QueryLimiter) IsFull() bool