core

Documentation

Overview

Package core 包含SDKClient

Index

• Constants
• type Otel
  • func NewOtel(namespace string, appKey string) *Otel
  • func (o *Otel) WithSpan(ctx context.Context, methodName string, req *http.Request, resp model.Response, ...) error
• type SDKClient
  • func NewSDKClient(clientID string, secret string) *SDKClient
  • func (c *SDKClient) ClientID() string
  • func (c *SDKClient) Do(ctx context.Context, req model.Request, resp model.Response, ...) error
  • func (c *SDKClient) SetDataType(t model.RequestDataType)
  • func (c *SDKClient) SetDebug(debug bool)
  • func (c *SDKClient) SetGateway(gw string)
  • func (c *SDKClient) SetHttpClient(client *http.Client)
  • func (c *SDKClient) SetUploadGateway(gw string)
  • func (c *SDKClient) Upload(ctx context.Context, req model.UploadRequest, resp model.Response, ...) error
  • func (c *SDKClient) WSSUrl() string
  • func (c *SDKClient) WithSpan(ctx context.Context, methodName string, req *http.Request, resp model.Response, ...) error
  • func (c *SDKClient) WithTracer(namespace string)

Constants

const (
	// GATEWAY 默认APIgateway
	GATEWAY = "https://gw-api.pinduoduo.com/api/router"
	// UPLOAD GATEWAY
	UPLOAD_GATEWAY = "https://gw-upload.pinduoduo.com/api/upload"
	// WSSEndPoint wws endpoint
	WSSEndPoint = "wss://message-api.pinduoduo.com/message"
)

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, methodName string, req *http.Request, resp model.Response, payload []byte, fn func(*http.Request, model.Response) (*http.Response, error)) error

type SDKClient

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

SDKClient sdk client

func NewSDKClient

func NewSDKClient(clientID string, secret string) *SDKClient

NewSDKClient 创建SDKClient

func (*SDKClient) ClientID

func (c *SDKClient) ClientID() string

ClientID returns client client_id

func (*SDKClient) Do

func (c *SDKClient) Do(ctx context.Context, req model.Request, resp model.Response, accessToken string) error

func (*SDKClient) SetDataType

func (c *SDKClient) SetDataType(t model.RequestDataType)

SetDataType 设置返回数据格式

func (*SDKClient) SetDebug

func (c *SDKClient) SetDebug(debug bool)

SetDebug 设置debug模式

func (*SDKClient) SetGateway

func (c *SDKClient) SetGateway(gw string)

SetGateway 设置gateway

func (*SDKClient) SetHttpClient

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

SetHttpClient 设置http.Client

func (*SDKClient) SetUploadGateway

func (c *SDKClient) SetUploadGateway(gw string)

func (*SDKClient) Upload

func (c *SDKClient) Upload(ctx context.Context, req model.UploadRequest, resp model.Response, accessToken string) error

func (*SDKClient) WSSUrl

func (c *SDKClient) WSSUrl() string

func (*SDKClient) WithSpan

func (c *SDKClient) WithSpan(ctx context.Context, methodName string, 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)