client

Documentation

Overview

* * Generated by go-doudou v2.0.4. * Don't edit!

* * Generated by go-doudou v2.0.4. * You can edit it as your need.

* * Generated by go-doudou v2.0.4. * Don't edit!

Index

• type IPromClient
• type PromClient
  • func NewPromClient(opts ...restclient.RestClientOption) *PromClient
  • func (receiver *PromClient) GetLabel_Label_nameValues(ctx context.Context, _headers map[string]string, start *string, end *string, ...) (_resp *resty.Response, data []string, status string, err error)
  • func (receiver *PromClient) GetQuery(ctx context.Context, _headers map[string]string, query string, time *string, ...) (_resp *resty.Response, data dto.QueryData, status string, err error)
  • func (receiver *PromClient) GetQuery_range(ctx context.Context, _headers map[string]string, query string, start *string, ...) (_resp *resty.Response, data dto.QueryData, status string, err error)
  • func (receiver *PromClient) Query(ctx context.Context, _headers map[string]string, query string, time *string, ...) (_resp *resty.Response, data dto.QueryData, status string, err error)
  • func (receiver *PromClient) Query_range(ctx context.Context, _headers map[string]string, query string, start *string, ...) (_resp *resty.Response, data dto.QueryData, status string, err error)
  • func (receiver *PromClient) SetClient(client *resty.Client)
  • func (receiver *PromClient) SetProvider(provider registry.IServiceProvider)
  • func (receiver *PromClient) SetRootPath(rootPath string)
• type PromClientProxy
  • func NewPromClientProxy(client *PromClient, opts ...ProxyOption) *PromClientProxy
  • func (receiver *PromClientProxy) GetLabel_Label_nameValues(ctx context.Context, _headers map[string]string, start *string, end *string, ...) (_resp *resty.Response, data []string, status string, err error)
  • func (receiver *PromClientProxy) GetQuery(ctx context.Context, _headers map[string]string, query string, time *string, ...) (_resp *resty.Response, data dto.QueryData, status string, err error)
  • func (receiver *PromClientProxy) GetQuery_range(ctx context.Context, _headers map[string]string, query string, start *string, ...) (_resp *resty.Response, data dto.QueryData, status string, err error)
  • func (receiver *PromClientProxy) Query(ctx context.Context, _headers map[string]string, query string, time *string, ...) (_resp *resty.Response, data dto.QueryData, status string, err error)
  • func (receiver *PromClientProxy) Query_range(ctx context.Context, _headers map[string]string, query string, start *string, ...) (_resp *resty.Response, data dto.QueryData, status string, err error)
• type ProxyOption
  • func WithLogger(logger zerolog.Logger) ProxyOption
  • func WithRunner(runner goresilience.Runner) ProxyOption

Types

type IPromClient

type IPromClient interface {
	Query(ctx context.Context, _headers map[string]string, query string, time *string, timeout *string) (_resp *resty.Response, data dto.QueryData, status string, err error)
	GetQuery(ctx context.Context, _headers map[string]string, query string, time *string, timeout *string) (_resp *resty.Response, data dto.QueryData, status string, err error)
	Query_range(ctx context.Context, _headers map[string]string, query string, start *string, end *string, step *string, timeout *string) (_resp *resty.Response, data dto.QueryData, status string, err error)
	GetQuery_range(ctx context.Context, _headers map[string]string, query string, start *string, end *string, step *string, timeout *string) (_resp *resty.Response, data dto.QueryData, status string, err error)
	GetLabel_Label_nameValues(ctx context.Context, _headers map[string]string, start *string, end *string, match *[]string, label_name string) (_resp *resty.Response, data []string, status string, err error)
}

type PromClient

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

func NewPromClient

func NewPromClient(opts ...restclient.RestClientOption) *PromClient

func (*PromClient) GetLabel_Label_nameValues

func (receiver *PromClient) GetLabel_Label_nameValues(ctx context.Context, _headers map[string]string, start *string, end *string, match *[]string, label_name string) (_resp *resty.Response, data []string, status string, err error)

func (*PromClient) GetQuery

func (receiver *PromClient) GetQuery(ctx context.Context, _headers map[string]string, query string, time *string, timeout *string) (_resp *resty.Response, data dto.QueryData, status string, err error)

func (*PromClient) GetQuery_range

func (receiver *PromClient) GetQuery_range(ctx context.Context, _headers map[string]string, query string, start *string, end *string, step *string, timeout *string) (_resp *resty.Response, data dto.QueryData, status string, err error)

func (*PromClient) Query

func (receiver *PromClient) Query(ctx context.Context, _headers map[string]string, query string, time *string, timeout *string) (_resp *resty.Response, data dto.QueryData, status string, err error)

func (*PromClient) Query_range

func (receiver *PromClient) Query_range(ctx context.Context, _headers map[string]string, query string, start *string, end *string, step *string, timeout *string) (_resp *resty.Response, data dto.QueryData, status string, err error)

func (*PromClient) SetClient

func (receiver *PromClient) SetClient(client *resty.Client)

func (*PromClient) SetProvider

func (receiver *PromClient) SetProvider(provider registry.IServiceProvider)

func (*PromClient) SetRootPath

func (receiver *PromClient) SetRootPath(rootPath string)

type PromClientProxy

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

func NewPromClientProxy

func NewPromClientProxy(client *PromClient, opts ...ProxyOption) *PromClientProxy

func (*PromClientProxy) GetLabel_Label_nameValues

func (receiver *PromClientProxy) GetLabel_Label_nameValues(ctx context.Context, _headers map[string]string, start *string, end *string, match *[]string, label_name string) (_resp *resty.Response, data []string, status string, err error)

func (*PromClientProxy) GetQuery

func (receiver *PromClientProxy) GetQuery(ctx context.Context, _headers map[string]string, query string, time *string, timeout *string) (_resp *resty.Response, data dto.QueryData, status string, err error)

func (*PromClientProxy) GetQuery_range

func (receiver *PromClientProxy) GetQuery_range(ctx context.Context, _headers map[string]string, query string, start *string, end *string, step *string, timeout *string) (_resp *resty.Response, data dto.QueryData, status string, err error)

func (*PromClientProxy) Query

func (receiver *PromClientProxy) Query(ctx context.Context, _headers map[string]string, query string, time *string, timeout *string) (_resp *resty.Response, data dto.QueryData, status string, err error)

func (*PromClientProxy) Query_range

func (receiver *PromClientProxy) Query_range(ctx context.Context, _headers map[string]string, query string, start *string, end *string, step *string, timeout *string) (_resp *resty.Response, data dto.QueryData, status string, err error)

type ProxyOption

type ProxyOption func(*PromClientProxy)

func WithLogger

func WithLogger(logger zerolog.Logger) ProxyOption

func WithRunner

func WithRunner(runner goresilience.Runner) ProxyOption