core

Documentation

Index

• Constants
• 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
  • 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
• type Credential
• type HTTPCaller
  • 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 HostAvailabler
  • func NewHostAvailabler(urlCenter URLCenter, context *Context) *HostAvailabler
  • func (receiver *HostAvailabler) Shutdown()
• type Region
• type URLCenter

Constants

const (
	MaxWriteItemCount = 2000

	MaxImportItemCount = 10000

	// StatusCodeSuccess The request was executed successfully without any exception
	StatusCodeSuccess = 0

	// StatusCodeIdempotent A Request with the same "Request-ID" was already received. This Request was rejected
	StatusCodeIdempotent = 409

	// StatusCodeOperationLoss Operation information is missing due to an unknown exception
	StatusCodeOperationLoss = 410

	// StatusCodeTooManyRequest The server hope slow down request frequency, and this request was rejected
	StatusCodeTooManyRequest = 429
)

Functions

func AsyncExecute

func AsyncExecute(runnable func())

func IsNetError

func IsNetError(err error) bool

func IsTimeoutError

func IsTimeoutError(err error) bool

func VolcSign

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

Types

type Context

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

func NewContext

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

func (*Context) AK

func (receiver *Context) AK() string

func (*Context) CustomerHeaders

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

func (*Context) HostHeader

func (receiver *Context) HostHeader() string

func (*Context) Hosts

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

func (*Context) SK

func (receiver *Context) SK() string

func (*Context) Schema

func (receiver *Context) Schema() string

func (*Context) Tenant

func (receiver *Context) Tenant() string

func (*Context) TenantId

func (receiver *Context) TenantId() string

func (*Context) Token

func (receiver *Context) Token() string

func (*Context) UseAirAuth

func (receiver *Context) UseAirAuth() bool

func (*Context) UseVolcAuth

func (receiver *Context) UseVolcAuth() bool

type ContextParam

type ContextParam struct {
	Tenant     string
	TenantId   string
	Token      string
	AK         string
	SK         string
	Schema     string
	HostHeader string
	Hosts      []string
	Headers    map[string]string
	Region     Region
	UseAirAuth bool
}

type Credential

type Credential struct {
	AccessKeyID     string
	SecretAccessKey string
	Region          string
	Service         string
	SessionToken    string
}

type HTTPCaller

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

func NewHTTPCaller

func NewHTTPCaller(context *Context) *HTTPCaller

func (*HTTPCaller) DoJSONRequest

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

func (*HTTPCaller) DoPBRequest

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

type HostAvailabler

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

func NewHostAvailabler

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

func (*HostAvailabler) Shutdown

func (receiver *HostAvailabler) Shutdown()

type Region

type Region int

const (
	RegionUnknown Region = iota
	RegionCn
	RegionSg
	RegionUs
	RegionAirCn
	RegionAirSg
	RegionSaasSg
)

type URLCenter

type URLCenter interface {
	Refresh(host string)
}