repo

type KafkaRepo interface {
	SendMessage(ctx context.Context, topic string, key []byte, value interface{}) error
	AddConsumer(topic, groupID string, handler func(ctx context.Context, key, value []byte) error) error
	StartConsumer(ctx context.Context, topic string) error
	StartAllConsumers(ctx context.Context)
	Close() error

	// Control methods
	EnableProducer()
	DisableProducer()
	IsProducerEnabled() bool
	EnableConsumer()
	DisableConsumer()
	IsConsumerEnabled() bool
	GetStatus() map[string]interface{}
}

type NatsRepo interface {
	Publish(subject string, data []byte) error
	Subscribe(subject string, handler func(msg []byte)) (unsubscribe func() error, err error)
}

type RedisRepo interface {
	SetValue(context.Context, entity.RedisValue) error
	GetValue(context.Context, string) (entity.RedisValue, error)
}

type TranslationRepo interface {
	Store(context.Context, models.TranslationModel) error
	GetHistory(context.Context) ([]entity.Translation, error)
}

type TranslationWebAPI interface {
	Translate(entity.Translation) (entity.Translation, error)
}

type UserRepo interface {
	Create(context.Context, models.UserModel) (entity.User, error)
	GetByID(context.Context, int64) (entity.User, error)
	GetByEmail(context.Context, string) (entity.User, error)
	Update(context.Context, models.UserModel) error
	Delete(context.Context, int64) error
	List(context.Context) ([]entity.User, error)
	// Database access methods
	GetBuilder() squirrel.StatementBuilderType
	GetPool() *pgxpool.Pool
}