helper

Documentation

Index

• Constants
• Variables
• type InfluxDBHelper
  • func NewInfluxDBHelper(conf *InfluxDBHelperConfig) (*InfluxDBHelper, error)
  • func (i *InfluxDBHelper) HandleReport() ultron.ReportHandleFunc
  • func (i *InfluxDBHelper) HandleResult() ultron.ResultHandleFunc
• type InfluxDBHelperConfig
  • func NewInfluxDBHelperConfig() *InfluxDBHelperConfig
• type JSONRPCError
  • func (err *JSONRPCError) Error() string
• type JSONRPCNotification
• type JSONRPCRequest
  • func NewJSONRPCRequest(method string, obj interface{}, args ...interface{}) *JSONRPCRequest
  • func (req *JSONRPCRequest) ToFastHTTPRequest(url string, r *fasthttp.Request) error
  • func (req *JSONRPCRequest) ToHTTPRequest(url string) (*http.Request, error)
• type JSONRPCResponse
  • func (res *JSONRPCResponse) GetError() error
  • func (res *JSONRPCResponse) HasError() bool

Constants

const (
	// DefaultInfluxDBURL influxdb address
	DefaultInfluxDBURL = "127.0.0.1:8089"
	// DefaultInfluxDBName influxdb database name
	DefaultInfluxDBName = "ultron"
	// DefaultMeasurementSucc the measurement to store successful request
	DefaultMeasurementSucc = "success"
	// DefaultMeasurementFail the measurement to store failed request
	DefaultMeasurementFail = "failures"
	// DefaultMeasurementAggregation the measurement to store report
	DefaultMeasurementAggregation = "report"
)

Variables

var (
	AutoIncreaseJSONRPCID = false
)

Types

type InfluxDBHelper

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

InfluxDBHelper .

func NewInfluxDBHelper

func NewInfluxDBHelper(conf *InfluxDBHelperConfig) (*InfluxDBHelper, error)

NewInfluxDBHelper 实例化NewInfluxDBHelper对象

func (*InfluxDBHelper) HandleReport

func (i *InfluxDBHelper) HandleReport() ultron.ReportHandleFunc

HandleReport 处理聚合报告

func (*InfluxDBHelper) HandleResult

func (i *InfluxDBHelper) HandleResult() ultron.ResultHandleFunc

HandleResult 处理单次请求结果

type InfluxDBHelperConfig

type InfluxDBHelperConfig struct {
	URL                    string
	UDP                    bool
	User                   string
	Password               string
	Database               string
	MeasurementSucc        string
	MeasurementFail        string
	MeasurementAggregation string
}

InfluxDBHelperConfig InfluxDBHelper配置

func NewInfluxDBHelperConfig

func NewInfluxDBHelperConfig() *InfluxDBHelperConfig

NewInfluxDBHelperConfig 实例化InfluxDBHelpConfig默认配置

type JSONRPCError

type JSONRPCError struct {
	Code    int                 `json:"code"`
	Message string              `json:"message"`
	Data    jsoniter.RawMessage `json:"data,omitempty"`
}

func (*JSONRPCError) Error

func (err *JSONRPCError) Error() string

type JSONRPCNotification

type JSONRPCNotification struct {
	Version string      `json:"jsonrpc"`
	Method  string      `json:"method"`
	Params  interface{} `json:"params"`
}

type JSONRPCRequest

type JSONRPCRequest struct {
	ID      int64       `json:"id"`
	Version string      `json:"jsonrpc"`
	Method  string      `json:"method"`
	Params  interface{} `json:"params"`
}

func NewJSONRPCRequest

func NewJSONRPCRequest(method string, obj interface{}, args ...interface{}) *JSONRPCRequest

func (*JSONRPCRequest) ToFastHTTPRequest

func (req *JSONRPCRequest) ToFastHTTPRequest(url string, r *fasthttp.Request) error

func (*JSONRPCRequest) ToHTTPRequest

func (req *JSONRPCRequest) ToHTTPRequest(url string) (*http.Request, error)

type JSONRPCResponse

type JSONRPCResponse struct {
	ID     int                 `json:"id,omitempty"`
	Result jsoniter.RawMessage `json:"result,omitempty"`
	Error  *JSONRPCError       `json:"error,omitempty"`
}

func (*JSONRPCResponse) GetError

func (res *JSONRPCResponse) GetError() error

func (*JSONRPCResponse) HasError

func (res *JSONRPCResponse) HasError() bool