core

Documentation

Overview

Package core 包含SDKClient

Index

• Constants
• type Otel
  • func NewOtel(namespace string, appKey string) *Otel
  • func (o *Otel) WithSpan(ctx context.Context, req *http.Request, resp model.Response, payload []byte, ...) error
• type RateLimiter
• type SDKClient
  • func NewSDKClient(appKey string, secret string) *SDKClient
  • func (c *SDKClient) Copy() *SDKClient
  • func (c *SDKClient) Get(ctx context.Context, gw string, req model.GetRequest, resp model.Response) error
  • func (c *SDKClient) SetDebug(debug bool)
  • func (c *SDKClient) SetHttpClient(client *http.Client)
  • func (c *SDKClient) SetRateLimiter(limiter RateLimiter)
  • func (c *SDKClient) WithSpan(ctx context.Context, req *http.Request, resp model.Response, payload []byte, ...) error
  • func (c *SDKClient) WithTracer(namespace string)

Constants

const (
	// BASE_URL 默认APIgateway
	BASE_URL = "https://openapi.meituan.com/api/"
)

Types

type Otel

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

func NewOtel

func NewOtel(namespace string, appKey string) *Otel

func (*Otel) WithSpan

func (o *Otel) WithSpan(ctx context.Context, req *http.Request, resp model.Response, payload []byte, fn func(*http.Request, model.Response) (*http.Response, error)) error

type RateLimiter

type RateLimiter interface {
	Take() time.Duration
}

type SDKClient

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

SDKClient sdk client

func NewSDKClient

func NewSDKClient(appKey string, secret string) *SDKClient

NewSDKClient 创建SDKClient

func (*SDKClient) Copy

func (c *SDKClient) Copy() *SDKClient

Copy 复制SDKClient

func (*SDKClient) Get

func (c *SDKClient) Get(ctx context.Context, gw string, req model.GetRequest, resp model.Response) error

Get get api

func (*SDKClient) SetDebug

func (c *SDKClient) SetDebug(debug bool)

SetDebug 设置debug模式

func (*SDKClient) SetHttpClient

func (c *SDKClient) SetHttpClient(client *http.Client)

SetHttpClient 设置http.Client

func (*SDKClient) SetRateLimiter

func (c *SDKClient) SetRateLimiter(limiter RateLimiter)

SetRateLimiter 设置限流

func (*SDKClient) WithSpan

func (c *SDKClient) WithSpan(ctx context.Context, req *http.Request, resp model.Response, payload []byte, fn func(*http.Request, model.Response) (*http.Response, error)) error

func (*SDKClient) WithTracer

func (c *SDKClient) WithTracer(namespace string)