compression

type CompressedPointer struct {
	OriginalTokens   int    `json:"original_tokens"`
	CompressedTokens int    `json:"compressed_tokens"`
	Strategy         string `json:"strategy"`
	CreatedAt        int64  `json:"created_at"`
	Size             int    `json:"size"`
}

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

type CompressionResult struct {
	Data             []byte
	OriginalTokens   int
	CompressedTokens int
	Strategy         CompressionStrategy
	Outcome          Outcome
	DurationMs       int64
}

type CompressionStats struct {
	OriginalBytes    int
	CompressedBytes  int
	OriginalTokens   int
	CompressedTokens int
	Strategy         string
}

type CompressionStrategy string

type Config struct {
	Strategy             CompressionStrategy `yaml:"strategy"`
	CacheEnabled         bool                `yaml:"cacheEnabled"`
	TokenThreshold       int                 `yaml:"tokenThreshold"`
	MaxContentBytes      int                 `yaml:"maxContentBytes"`
	TokenEncoding        string              `yaml:"tokenEncoding"`
	Timeout              time.Duration       `yaml:"timeout"`
	ContentCacheMaxBytes int64               `yaml:"contentCacheMaxBytes"` // cache only
	ContentCacheTTL      time.Duration       `yaml:"contentCacheTTL"`      // cache only
}

type ContentMeta struct {
	Integration string // Source type: types.SourceGmail, types.SourceGitHub, etc.
	QueryPath   string
	ResultID    string
	Filename    string
	MimeHint    string
}

type ContextCompressor interface {
	Name() CompressionStrategy
	Compress(ctx context.Context, content []byte, meta ContentMeta) (*CompressionResult, error)
}

type Outcome string

type RedisClient interface {
	Get(ctx context.Context, key string) *redis.StringCmd
	Set(ctx context.Context, key string, value interface{}, expiration time.Duration) *redis.StatusCmd
	IncrBy(ctx context.Context, key string, value int64) *redis.IntCmd
	Expire(ctx context.Context, key string, expiration time.Duration) *redis.BoolCmd
	SAdd(ctx context.Context, key string, members ...interface{}) *redis.IntCmd
	Del(ctx context.Context, keys ...string) *redis.IntCmd
	Pipeline() redis.Pipeliner
}

type ScanClient interface {
	Scan(ctx context.Context, pattern string) ([]string, error)
}

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

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