resources

Documentation

Index

• Constants
• Variables
• func NewBoolResult(val bool, err error) *boolResult
• func NewIntResult(val int64, err error) *intResult
• func NewInterfaceResult(val interface{}, err error) *interfaceResult
• func NewStatusResult(err error) *statusResult
• func NewStringResult(val string, err error) *stringResult
• func NewStringResultBytes(value []byte, err error) *stringResult
• func ToBytes(v int64) []byte
• func ToInt(b []byte) int64
• type BoolResult
• type ICache
• type IVectors
• type IntResult
• type InterfaceResult
• type Metrics
• type StatusResult
• type StringResult
• type TX
• type Vector
• type VectorsLocalBuild
  • func NewVectorsLocalBuild() *VectorsLocalBuild
  • func (v *VectorsLocalBuild) BuildVector(name string, uni, step time.Duration) (Vector, error)

Constants

const CacheSkill = "github.com/eolinker/apinto/resources.resources.ICache"

const VectorsSkill = "github.com/eolinker/apinto/resources.resources.IVectors"

通过滑动窗口实现的平滑计数器

Variables

var (
	LocalCache func() ICache
)

var (
	LocalVector func() IVectors
)

Functions

func NewBoolResult

func NewBoolResult(val bool, err error) *boolResult

func NewIntResult

func NewIntResult(val int64, err error) *intResult

func NewInterfaceResult

func NewInterfaceResult(val interface{}, err error) *interfaceResult

func NewStatusResult

func NewStatusResult(err error) *statusResult

func NewStringResult

func NewStringResult(val string, err error) *stringResult

func NewStringResultBytes

func NewStringResultBytes(value []byte, err error) *stringResult

func ToBytes

func ToBytes(v int64) []byte

func ToInt

func ToInt(b []byte) int64

Types

type BoolResult

type BoolResult interface {
	Result() (bool, error)
}

type ICache

type ICache interface {
	Set(ctx context.Context, key string, value []byte, expiration time.Duration) StatusResult
	SetNX(ctx context.Context, key string, value []byte, expiration time.Duration) BoolResult
	DecrBy(ctx context.Context, key string, decrement int64, expiration time.Duration) IntResult
	IncrBy(ctx context.Context, key string, decrement int64, expiration time.Duration) IntResult
	Get(ctx context.Context, key string) StringResult
	GetDel(ctx context.Context, key string) StringResult
	Del(ctx context.Context, keys ...string) IntResult
	Run(ctx context.Context, script interface{}, keys []string, args ...interface{}) InterfaceResult
	Tx() TX
}

type IVectors

type IVectors interface {
	BuildVector(name string, uni, step time.Duration) (Vector, error)
}

type IntResult

type IntResult interface {
	Result() (int64, error)
}

type InterfaceResult

type InterfaceResult interface {
	Result() (interface{}, error)
}

type Metrics

type Metrics interface {
	Send(labels map[string]string, fields map[string]interface{})
}

type StatusResult

type StatusResult interface {
	Result() error
}

type StringResult

type StringResult interface {
	Result() (string, error)
	Bytes() ([]byte, error)
}

type TX

type TX interface {
	ICache
	Exec(ctx context.Context) error
}

type Vector

type Vector interface {
	Add(key string, delta int64)
	CompareAndAdd(key string, threshold, delta int64) bool
	Get(key string) int64
}

type VectorsLocalBuild

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

func NewVectorsLocalBuild

func NewVectorsLocalBuild() *VectorsLocalBuild

func (*VectorsLocalBuild) BuildVector

func (v *VectorsLocalBuild) BuildVector(name string, uni, step time.Duration) (Vector, error)