utils

Documentation

Index

• Constants
• func CredentialsWithAccessKey(accessKeyId, accessKeySecret string) auth.Credential
• func CredentialsWithEcsRamRole(roleName string) auth.Credential
• func CredentialsWithRamRoleArnOrSts(accessKeyId, accessKeySecret, roleSessionName, roleArn, policy string) auth.Credential
• func CredentialsWithToken(tokenId, token string) auth.Credential
• func DecryptAes256Cbc(data, secret, iv, salt []byte) (string, error)
• func EncryptAes256Cbc(data, secret, iv, salt []byte) ([]byte, error)
• func FileDelete(filePath, fileName string) error
• func FileExists(filePath, fileName string) bool
• func GetEndpoint(regionId string) string
• func GetVpcEndpoint(regionId string) string
• func JudgeNeedBackoff(err error) bool
• func JudgeNeedRecoveryException(err error) bool
• func ParseBool(obj interface{}) (bool, error)
• func ParseString(obj interface{}) (string, error)
• func Ping(host string) float64
• func ReadJsonObject(filePath, fileName string, out interface{}) error
• func WriteJsonObject(filePath, fileName string, in interface{}) error

Constants

const (
	IterationCount   = 1000
	KeyLength        = 32
	Aes256CbcModeKey = "001"
)

const (
	// KMS限流返回错误码
	RejectedThrottling = "Rejected.Throttling"

	// KMS服务不可用返回错误码
	ServiceUnavailableTemporary = "ServiceUnavailableTemporary"

	// KMS服务内部错误返回错误码
	InternalFailure = "InternalFailure"
)

const (
	// 凭据当前stage
	StageAcsCurrent = "ACSCurrent"

	// 随机IV字节长度
	IvLength = 16

	// 随机密钥字节长度
	RandomKeyLength = 32

	// 默认最大重试次数
	DefaultRetryMaxAttempts = 5

	// 默认重试间隔时间
	DefaultRetryInitialIntervalMills = 2000

	// 默认最大等待时间
	DefaultCapacity = 10000

	// 环境变量cache_client_region_id key
	EnvCacheClientRegionIdKey = "cache_client_region_id"

	// 环境变量credentials_type key
	EnvCredentialsTypeKey = "credentials_type"

	// 环境变量credentials_access_key_id key
	EnvCredentialsAccessKeyIdKey = "credentials_access_key_id"

	// 环境变量credentials_access_secret key
	EnvCredentialsAccessSecretKey = "credentials_access_secret"

	// 环境变量credentials_access_token_id key
	EnvCredentialsAccessTokenIdKey = "credentials_access_token_id"

	// 环境变量credentials_access_token key
	EnvCredentialsAccessTokenKey = "credentials_access_token"

	// 环境变量credentials_role_session_name key
	EnvCredentialsRoleSessionNameKey = "credentials_role_session_name"

	// 环境变量credentials_role_arn key
	EnvCredentialsRoleArnKey = "credentials_role_arn"

	// 环境变量credentials_policy key
	EnvCredentialsPolicyKey = "credentials_policy"

	// 环境变量credentials_role_name key
	EnvCredentialsRoleNameKey = "credentials_role_name"

	// 欠费errorCode
	ErrorCodeForbiddenInDebtOverDue = "Forbidden.InDebtOverdue"

	// 欠费errorCode
	ErrorCodeForbiddenInDebt = "Forbidden.InDebt"

	// 模块名称
	ModeName = "CacheClient"

	// 凭据文本数据类型
	TextDataType = "text"

	// 凭据二进制数据类型
	BinaryDataType = "binary"

	// 项目版本
	ProjectVersion = "1.0"

	// the user agent of secrets manager golang
	UserAgentOfSecretsManagerGolang = "aliyun-secretsmanager-client-go"

	// 环境变量region中endPoint key
	EnvRegionEndpointNameKey = "endpoint"

	// 环境变量region中regionId key
	EnvRegionRegionIdNameKey = "regionId"

	// 环境变量region中regionId key
	EnvRegionVpcNameKey = "vpc"

	// KMS服务Socket连接超时错误码
	SdkReadTimeout = "SDK.ReadTimeout"

	// KMS服务无法连接错误码
	SdkServerUnreachable = "SDK.ServerUnreachable"
)

Functions

func CredentialsWithAccessKey

func CredentialsWithAccessKey(accessKeyId, accessKeySecret string) auth.Credential

func CredentialsWithEcsRamRole

func CredentialsWithEcsRamRole(roleName string) auth.Credential

func CredentialsWithRamRoleArnOrSts

func CredentialsWithRamRoleArnOrSts(accessKeyId, accessKeySecret, roleSessionName, roleArn, policy string) auth.Credential

func CredentialsWithToken

func CredentialsWithToken(tokenId, token string) auth.Credential

func DecryptAes256Cbc

func DecryptAes256Cbc(data, secret, iv, salt []byte) (string, error)

DecryptAes256Cbc 解密data， 使用aes256-cbc算法，填充方式为pkcs5, aes密钥通过pbkdf2-hmac-sha256算法派生

func EncryptAes256Cbc

func EncryptAes256Cbc(data, secret, iv, salt []byte) ([]byte, error)

EncryptAes256Cbc 加密data，使用aes256-cbc算法，填充方式为pkcs5, aes密钥通过pbkdf2-hmac-sha256算法派生

func FileDelete

func FileDelete(filePath, fileName string) error

func FileExists

func FileExists(filePath, fileName string) bool

func GetEndpoint

func GetEndpoint(regionId string) string

func GetVpcEndpoint

func GetVpcEndpoint(regionId string) string

func JudgeNeedBackoff

func JudgeNeedBackoff(err error) bool

根据Client异常判断是否进行规避重试

func JudgeNeedRecoveryException

func JudgeNeedRecoveryException(err error) bool

根据Client异常判断是否进行容灾重试

func ParseBool

func ParseBool(obj interface{}) (bool, error)

func ParseString

func ParseString(obj interface{}) (string, error)

func Ping

func Ping(host string) float64

func ReadJsonObject

func ReadJsonObject(filePath, fileName string, out interface{}) error

func WriteJsonObject

func WriteJsonObject(filePath, fileName string, in interface{}) error