monitor_entry

Documentation

Index

• Constants
• Variables
• type IClient
• type IOutput
• type IPoint
  • func ReadProxy(ctx http_context.IHttpContext) []IPoint
  • func ReadRequest(ctx http_context.IHttpContext) []IPoint
• type Point
  • func NewPoint(table string, tags map[string]string, fields map[string]interface{}, ...) *Point
  • func (p *Point) Fields() map[string]interface{}
  • func (p *Point) Table() string
  • func (p *Point) Tags() map[string]string
  • func (p *Point) Time() time.Time
• type ProxyReadFunc
• type RequestReadFunc

Constants

const Skill = "github.com/eolinker/apinto/monitor-entry.monitor-entry.IOutput"

Variables

var (
	LabelApi      = "api"
	LabelApp      = "app"
	LabelUpstream = "upstream"
	LabelHandler  = "handler"
)

Types

type IClient

type IClient interface {
	ID() string
	Write(point IPoint) error
	Close()
}

type IOutput

type IOutput interface {
	Output(point ...IPoint)
}

type IPoint

type IPoint interface {
	Table() string
	Tags() map[string]string
	Fields() map[string]interface{}
	Time() time.Time
}

func ReadProxy

func ReadProxy(ctx http_context.IHttpContext) []IPoint

func ReadRequest

func ReadRequest(ctx http_context.IHttpContext) []IPoint

type Point

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

func NewPoint

func NewPoint(table string, tags map[string]string, fields map[string]interface{}, pointTime time.Time) *Point

func (*Point) Fields

func (p *Point) Fields() map[string]interface{}

func (*Point) Table

func (p *Point) Table() string

func (*Point) Tags

func (p *Point) Tags() map[string]string

func (*Point) Time

func (p *Point) Time() time.Time

type ProxyReadFunc

type ProxyReadFunc func(request http_context.IProxy) (interface{}, bool)

type RequestReadFunc

type RequestReadFunc func(ctx http_context.IHttpContext) (interface{}, bool)