logstream

type FileConfig struct {
	Path           string
	MaxLineSize    int
	MaxIOReadBytes int64
	// https://docs.docker.com/config/containers/logging/json-file/
	IsDockerJsonLog bool
}

type GLogStream struct {
	Key       string
	Mutex     sync.RWMutex
	Cache     sync.Map
	Listeners []Listener

	Cursor       int64
	PendingBytes int64
	PendingReads int32
	// contains filtered or unexported fields
}

type Listener interface {
	Changed(LogStream, int64)
}

type Log struct {
	Time     int64
	Contents map[string]string
}

type LogGroup struct {
	Tags map[string]string
	Logs []*Log
}

type LogStream interface {
	// GetKey returns the key of LogStream
	GetKey() string
	Start()
	Stop()
	Read(int64) (*ReadResponse, int64, error)
	AddListener(Listener) int64
	RemoveListener(Listener, int64)
	Stat() Stat
	Clean()
	LoadReadState(cursor int64) error
}

type LogStreamState interface {
	SaveState() (interface{}, error)
	LoadState(interface{}) error
}

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

type Mode string

type ReadRequest struct {
	Cursor int64
}

type ReadResponse struct {
	// current read cursor
	Cursor int64
	// io read start time
	IOStartTime time.Time
	// io read end time
	IOEndTime time.Time

	Lines     []string `json:"-"`
	LogGroups []*LogGroup

	// Whether the next data can be read immediately
	HasMore   bool
	HasBroken bool

	Path string
	// The number of bytes read.
	// For some implementations, this value may be inaccurate.
	Bytes int64
	Count int
	// Use a string to describe the scope of this read.
	Range string
	// Count of \u0000 of this read
	ZeroBytes int
	// contains filtered or unexported fields
}

type Reader interface {
	// Returns current cursor
	Cursor() int64
	LoadReadState(int64) error
	// Read
	Read() (*ReadResponse, error)
	// Set listener
	SetListener(Listener)
	Release()
}

type SlsConfig struct {
	Endpoint string
	AK       string
	SK       string
	Project  string
	Logstore string
	Shard    int
}

type SlsSecretProvider func(SlsConfig) (string, string)

type Stat struct {
	LatestCursor int64
	PendingBytes int64
	PendingReads int32
}

type SubLogStream interface {
	transfer.StatefulInput
	Start()
	Stop()
	Read(resp *ReadResponse) error
	CreateResponse(cursor int64) *ReadResponse
}