service

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

type KafkaMsg struct {
	Id string `json:"uuid"`
}

type QProcessor interface {
	ProcessMsg(m kafka.FTMessage)
}

type Reader interface {
	Get(uuid string, path string) (bool, io.ReadCloser, *string, error)
	Count() (int64, error)
	Ids() (io.PipeReader, error)
	GetAll(path string) (io.PipeReader, error)
}

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

type S3QProcessor struct {
	Writer
	// contains filtered or unexported fields
}

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

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

type Status int

type Writer interface {
	Write(uuid string, path string, b *[]byte, contentType string, transactionID string, ignoreHash bool) (Status, error)
	Delete(uuid string, path string, transactionID string) error
}

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