kfkempl

type DBUser struct {
}

type EventMessage[T EventMessageObjectType] interface {
	*T
	proto.Message
	GetEvent() *kafkaemployees.Event
	Len() int
}

type EventMessageObjectType any

type SimpleSubscribe[OTM, OTD EventMessageObjectType, TM EventMessage[OTM], TD EventMessage[OTD], M any] struct {
	Kfk *kafkaframe.Kafka
	CntModify,
	CntDelete,
	CntErrors prometheus.Counter
	DurSec          prometheus.Histogram
	TopicModify     string
	TopicDelete     string
	ProcessModify   func(t TM) ([]M, error)
	GetIdsForDelete func(t TD) ([]string, error)
}

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