kafkafs

type KafkaClient interface {
	// list all topics
	GetTopics() ([]string, error)

	// list the partitions for a topic
	GetPartitions(topic string) ([]int32, error)

	// get the earliest and next offsets available for a topic /
	// partition.  Note that the "next" offset is for the next
	// message, that is, the one that currently doesn't exist yet
	// (e.g., 0 if the partition is empty)
	GetBoundingOffsets(topic string, partition int32) (int64, int64, error)

	// get the bytes for a given message
	GetMessage(topic string, partition int32, offset int64) ([]byte, error)
}

type KafkaRoFs struct {
	pathfs.FileSystem

	KafkaClient KafkaClient
	// contains filtered or unexported fields
}