producer

type Attempt struct {
	Success           bool
	HttpCode          int32
	RequestId         string
	ErrorCode         string
	ErrorMessage      string
	TimeStampMs       int64
	LastAttemptCostMs int64
}

type BadResponseError struct {
	RespBody   string
	RespHeader map[string][]string
	HTTPCode   int
}

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

type CallBack interface {
	Success(result *Result)
	Fail(result *Result)
}

type Client struct {
	Endpoint        string // IP or hostname of SLS endpoint
	AccessKeyID     string
	AccessKeySecret string
	RequestTimeOut  time.Duration
	RetryTimeOut    time.Duration
	HTTPClient      *http.Client
	Region          string
	ProjectId       string
	// contains filtered or unexported fields
}

type ClientInterface interface {
	PutLogs(project, logStore string, lg *LogGroup) (err error)
}

type ConditionOperation func() (bool, error)

type Config struct {
	TotalSizeLnBytes    int64
	MaxIoWorkers        int64
	MaxBlockSec         int
	MaxBatchSize        int64
	MaxBatchCount       int
	LingerMs            int64
	Retries             int
	MaxReservedAttempts int
	BaseRetryBackoffMs  int64
	MaxRetryBackoffMs   int64
	Buckets             int
	Endpoint            string
	AccessKeyID         string
	AccessKeySecret     string
	ProjectId           string
	RegionId            string
	NoRetryCodeList     []int
	HTTPClient          *http.Client
}

type CustomLog struct {
	LogTimeNs int64  `json:"log_time_ns"`
	Log       string `json:"log"`
}

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

type Error struct {
	HTTPCode  int32  `json:"httpCode"`
	Code      string `json:"errorCode"`
	Message   string `json:"errorMessage"`
	RequestID string `json:"requestID"`
}

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

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

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

type Log struct {
	Time      *uint32       `json:"time,omitempty"`
	Contents  []*LogContent `json:"contents,omitempty"`
	Labels    string        `json:"labels"`
	ProjectId string        `json:"tenant_project_id,omitempty"`
}

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

type LogContent struct {
	LogTimeNs int64  `json:"log_time_ns"`
	Log       string `json:"log"`
}

type LogGroup struct {
	Logs     []*Log    `json:"log_items,omitempty"`
	Category *string   `json:"Category,omitempty"`
	LogTags  []*LogTag `json:"LogTags,omitempty"`
}

type LogItem struct {
	Contents        []LogContent `json:"contents"`
	Labels          string       `json:"labels"`
	TenantProjectId string       `json:"tenant_project_id"`
}

type LogItems struct {
	LogItems []LogItem `json:"log_items"`
}

type LogProject struct {
	Region          string // region id
	Endpoint        string // IP or hostname
	AccessKeyID     string
	AccessKeySecret string

	ProjectId string
	// contains filtered or unexported fields
}

type LogStore struct {
	GroupId  string
	StreamId string
	// contains filtered or unexported fields
}

type LogTag struct {
	Key   *string `json:"Key,omitempty"`
	Value *string `json:"Value,omitempty"`
}

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

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

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

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