envconfig

Documentation

Index

• Constants
• func CreateProductLogstore(region, project, logstore, product, lang string) error
• func GetAnnotationByError(projectInfo map[string]string, customError *CustomError) map[string]string
• func GetAnnotationByObject(config *AliyunLogConfigSpec, project, logstore, product, configName string, ...) map[string]string
• func PKCS5UnPadding(origData []byte) []byte
• func UpdateTokenFunction() (accessKeyID, accessKeySecret, securityToken string, expireTime time.Time, ...)
• type AKInfo
• type AliyunLogConfigDetail
  • func (alcs *AliyunLogConfigDetail) InitFromDockerInfo(dockerInfo *helper.DockerInfoDetail, config string, configKeys []string, ...) error
• type AliyunLogConfigSpec
  • func (alcs *AliyunLogConfigSpec) Key() string
• type CustomError
  • func CustomErrorFromPopError(popError error) *CustomError
  • func CustomErrorFromSlsSDKError(slsSDKError error) *CustomError
  • func CustomErrorNew(code string, requestID string, msg string) *CustomError
  • func (e *CustomError) CustomError() string
• type Manager
• type SDKError
• type SecurityTokenResult

Constants

const (
	AddOnTokenConfigPathEnv     = "ALIYUN_LOG_ADDON_TOKEN_PATH" //nolint:gosec
	DefaultAddOnTokenConfigPath = "/var/addon/token-config"     //nolint:gosec
)

const (
	QueryMode    string = "query"
	StandardMode string = "standard"
)

Functions

func CreateProductLogstore

func CreateProductLogstore(region, project, logstore, product, lang string) error

CreateProductLogstore create product logstore

"cn-hangzhou"
"test-hangzhou-project"
"audit-logstore"
"k8s-audit"
"cn"

func GetAnnotationByError

func GetAnnotationByError(projectInfo map[string]string, customError *CustomError) map[string]string

func GetAnnotationByObject

func GetAnnotationByObject(config *AliyunLogConfigSpec, project, logstore, product, configName string, rawConfig bool) map[string]string

func PKCS5UnPadding

func PKCS5UnPadding(origData []byte) []byte

func UpdateTokenFunction

func UpdateTokenFunction() (accessKeyID, accessKeySecret, securityToken string, expireTime time.Time, err error)

Types

type AKInfo

type AKInfo struct {
	AccessKeyID     string `json:"access.key.id"`
	AccessKeySecret string `json:"access.key.secret"`
	SecurityToken   string `json:"security.token"`
	Expiration      string `json:"expiration"`
	Keyring         string `json:"keyring"`
}

AKInfo ...

type AliyunLogConfigDetail

type AliyunLogConfigDetail struct {
	ConfigName    string                 `json:"configName"`
	InputType     string                 `json:"inputType"`
	LogtailConfig map[string]interface{} `json:"inputDetail"`
}

AliyunLogConfigDetail logtail config detail

func (*AliyunLogConfigDetail) InitFromDockerInfo

func (alcs *AliyunLogConfigDetail) InitFromDockerInfo(dockerInfo *helper.DockerInfoDetail,
	config string,
	configKeys []string,
	configValues []string) error

InitFromDockerInfo init AliyunLogConfigDetail from docker info with specific config name

type AliyunLogConfigSpec

type AliyunLogConfigSpec struct {
	Project       string                `json:"project"`
	Logstore      string                `json:"logstore"`
	ShardCount    *int32                `json:"shardCount"`
	LifeCycle     *int32                `json:"lifeCycle"`
	MachineGroups []string              `json:"machineGroups"`
	LogtailConfig AliyunLogConfigDetail `json:"logtailConfig"`
	ContainerName string                `json:"containerName"`
	HashCode      []byte                `json:"hashCode"`
	ErrorCount    int                   `json:"errorCount"`
	NextTryTime   int64                 `json:"nextTryTime"`
	SimpleConfig  bool                  `json:"simpleConfig"`
	LastFetchTime int64                 `json:"lastFetchTime"`
	ProductCode   string                `json:"productCode"`
	ProductLang   string                `json:"productLang"`
	LogstoreMode  string                `json:"logstoreMode"`
}

AliyunLogConfigSpec logtail config struct for wrapper

func (*AliyunLogConfigSpec) Key

func (alcs *AliyunLogConfigSpec) Key() string

Key return the unique key

type CustomError

type CustomError struct {
	Code      string
	RequestID string
	Message   string
	RawError  error
}

func CustomErrorFromPopError

func CustomErrorFromPopError(popError error) *CustomError

func CustomErrorFromSlsSDKError

func CustomErrorFromSlsSDKError(slsSDKError error) *CustomError

func CustomErrorNew

func CustomErrorNew(code string, requestID string, msg string) *CustomError

func (*CustomError) CustomError

func (e *CustomError) CustomError() string

type Manager

type Manager struct {
	AllConfigMap map[string]*AliyunLogConfigSpec
	// contains filtered or unexported fields
}

type SDKError

type SDKError struct {
	HTTPCode     int    `json:"httpCode"`
	ErrorCode    string `json:"errorCode"`
	ErrorMessage string `json:"errorMessage"`
	RequestID    string `json:"requestID"`
}

type SecurityTokenResult

type SecurityTokenResult struct {
	AccessKeyID     string
	AccessKeySecret string
	Expiration      string
	SecurityToken   string
	Code            string
	LastUpdated     string
}