producer

type Attempt struct {
	SuccessFlag  bool
	RequestId    string
	ErrorCode    string
	ErrorMessage string
	TimestampMs  int64
}

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

type BatchKey struct {
	Topic       string
	Source      string
	ShardHash   string
	FileName    string
	ContextFlow string
	CallBackFun CallBack
}

type BatchLog struct {
	Key BatchKey
	Log *pb.Log
}

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

type Config struct {
	TotalSizeLnBytes      int64
	MaxSenderCount        int64
	MaxBlockSec           int
	MaxBatchSize          int64
	MaxBatchCount         int
	LingerTime            time.Duration
	Retries               int
	MaxReservedAttempts   int
	BaseRetryBackoffMs    int64
	MaxRetryBackoffMs     int64
	AdjustShardHashFlag   bool
	ShardCount            int
	NoRetryStatusCodeList []int

	common.LoggerConfig
	common.ClientConfig
	Logger *log.Logger
}

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

type Producer interface {
	SendLog(shardHash, topic, source, filename string, log *pb.Log, callBack CallBack) error
	SendLogs(shardHash, topic, source, filename string, logs *pb.LogGroup, callBack CallBack) error
	ResetAccessKeyToken(accessKeyID, accessKeySecret, securityToken string)
	Start()
	Close()
	ForceClose()
}

type Result struct {
	Attempts    []*Attempt
	SuccessFlag bool
}

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

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

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