core

Oct 11, 2022

Changes in this version

type Context

+ func (receiver *Context) HostAvailablerConfig() *HostAvailablerConfig

+ func (receiver *Context) MetricsConfig() *metrics.Config

type ContextParam

+ HostAvailablerConfig *HostAvailablerConfig

+ MetricsConfig *metrics.Config

type HostAvailabler

+ func (receiver *HostAvailabler) GetHost() string

+ type HostAvailablerConfig struct

+ PingInterval time.Duration

+ PingTimeout time.Duration

+ PingUrlFormat string

+ WindowSize int

Apr 14, 2022

Changes in this version

+ func ReportRequestError(metricsPrefix, url string, begin time.Time, code int, message string)

+ func ReportRequestException(metricsPrefix, url string, begin time.Time, err error)

+ func ReportRequestSuccess(metricsPrefix, url string, begin time.Time)

Mar 25, 2022

Changes in this version

+ type HTTPCaller struct

+ func NewHTTPCaller(context *Context) *HTTPCaller

+ func (c *HTTPCaller) DoJSONRequest(url string, request interface{}, response proto.Message, ...) error

+ func (c *HTTPCaller) DoPBRequest(url string, request proto.Message, response proto.Message, ...) error

Mar 24, 2022

Changes in this version

+ const MaxImportItemCount

+ const MaxWriteItemCount

+ const StatusCodeIdempotent

+ const StatusCodeOperationLoss

+ const StatusCodeSuccess

+ const StatusCodeTooManyRequest

+ func AsyncExecute(runnable func())

+ func IsNetError(err error) bool

+ func IsTimeoutError(err error) bool

+ func VolcSign(req *fasthttp.Request, cred Credential) *fasthttp.Request

+ type Context struct

+ func NewContext(param *ContextParam) (*Context, error)

+ func (receiver *Context) AK() string

+ func (receiver *Context) CustomerHeaders() map[string]string

+ func (receiver *Context) HostHeader() string

+ func (receiver *Context) Hosts() []string

+ func (receiver *Context) SK() string

+ func (receiver *Context) Schema() string

+ func (receiver *Context) Tenant() string

+ func (receiver *Context) TenantId() string

+ func (receiver *Context) Token() string

+ func (receiver *Context) UseAirAuth() bool

+ func (receiver *Context) UseVolcAuth() bool

+ type ContextParam struct

+ AK string

+ Headers map[string]string

+ HostHeader string

+ Hosts []string

+ Region Region

+ SK string

+ Schema string

+ Tenant string

+ TenantId string

+ Token string

+ UseAirAuth bool

+ type Credential struct

+ AccessKeyID string

+ Region string

+ SecretAccessKey string

+ Service string

+ SessionToken string

+ type HostAvailabler struct

+ func NewHostAvailabler(urlCenter URLCenter, context *Context) *HostAvailabler

+ func (receiver *HostAvailabler) Shutdown()

+ type HttpCaller struct

+ func NewHttpCaller(context *Context) *HttpCaller

+ func (c *HttpCaller) DoJsonRequest(url string, request interface{}, response proto.Message, ...) error

+ func (c *HttpCaller) DoPbRequest(url string, request proto.Message, response proto.Message, ...) error

+ type Region int

+ const RegionAirCn

+ const RegionAirSg

+ const RegionCn

+ const RegionSaasSg

+ const RegionSg

+ const RegionUnknown

+ const RegionUs

+ type URLCenter interface

+ Refresh func(host string)