storage

type AppendResult struct {
	BaseOffset int64
	LastOffset int64
}

type ByteRange struct {
	Start int64
	End   int64
}

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

type IndexEntry struct {
	Offset   int64
	Position int32
}

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

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

type PartitionLogConfig struct {
	Buffer            WriteBufferConfig
	Segment           SegmentWriterConfig
	ReadAheadSegments int
	CacheEnabled      bool
	Logger            *slog.Logger
}

type RecordBatch struct {
	BaseOffset      int64
	LastOffsetDelta int32
	MessageCount    int32
	Bytes           []byte
}

type RecoveredPartition struct {
	Partition      int32
	SegmentsCopied int
	LastOffset     int64
	Segments       []RecoveredSegment
}

type RecoveredSegment struct {
	Partition   int32
	BaseOffset  int64
	LastOffset  int64
	SizeBytes   int64
	CreatedAt   time.Time
	SourceKey   string
	TargetKey   string
	SourceIndex string
	TargetIndex string
}

type S3Client interface {
	UploadSegment(ctx context.Context, key string, body []byte) error
	UploadIndex(ctx context.Context, key string, body []byte) error
	DeleteSegment(ctx context.Context, key string) error
	DeleteIndex(ctx context.Context, key string) error
	DownloadSegment(ctx context.Context, key string, rng *ByteRange) ([]byte, error)
	DownloadIndex(ctx context.Context, key string) ([]byte, error)
	ListSegments(ctx context.Context, prefix string) ([]S3Object, error)
	EnsureBucket(ctx context.Context) error
}

type S3Config struct {
	Bucket          string
	Region          string
	Endpoint        string
	ForcePathStyle  bool
	AccessKeyID     string
	SecretAccessKey string
	SessionToken    string
	KMSKeyARN       string
	MaxConnections  int
}

type S3Object struct {
	Key  string
	Size int64
}

type SegmentArtifact struct {
	BaseOffset    int64
	LastOffset    int64
	MessageCount  int32
	CreatedAt     time.Time
	SegmentBytes  []byte
	IndexBytes    []byte
	RelativeIndex []*IndexEntry
}

type SegmentWriterConfig struct {
	IndexIntervalMessages int32
}

type TopicRecoveryConfig struct {
	SourceNamespace string
	SourceTopic     string
	TargetNamespace string
	TargetTopic     string
	RestoreTo       time.Time
	Partitions      []int32
}

type TopicRecoveryResult struct {
	SourceNamespace string
	SourceTopic     string
	TargetNamespace string
	TargetTopic     string
	RestoreTo       time.Time
	SegmentsCopied  int
	Partitions      []RecoveredPartition
}

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

type WriteBufferConfig struct {
	MaxBytes      int
	MaxMessages   int
	MaxBatches    int
	FlushInterval time.Duration
}