gkafka

type Options struct {
	Brokers                 []string
	Network                 string
	ProcessFileTopic        string
	ProcessedFileTopic      string
	ProcessedFileRepository ProcessedFileRepository
}

type ProcessFileService service

type ProcessedFileRepository interface {
	ProcessedFileResult(ctx context.Context, info *domain.FileInfo) error
}

type Server struct {
	ProcessFile *ProcessFileService
	// contains filtered or unexported fields
}