kafkaintegration

type DB interface {
	GetAudio(kafkaID string) (*kafkaapi.DBEntry, error)
	SaveResult(data *kafkaapi.DBResultEntry) error
}

type Filer interface {
	Find(kafkaID string) (*kafkaapi.KafkaTrMap, error)
	SetWorking(krIds *kafkaapi.KafkaTrMap) error
	Delete(kafkaID string) error
}

type KafkaReader interface {
	Get() (*kafkaapi.Msg, error)
	Commit(*kafkaapi.Msg) error
	Close()
}

type KafkaWriter interface {
	Write(msg *kafkaapi.ResponseMsg) error
}

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

type Transcriber interface {
	Upload(audio *kafkaapi.UploadData) (string, error)
	GetStatus(ID string) (*kafkaapi.Status, error)
	GetResult(ID string) (*kafkaapi.Result, error)
	Delete(ID string) error
}