kfkempl

Documentation

Index

• Constants
• type DBUser
• type EventMessage
• type EventMessageObjectType
• type SimpleSubscribe
  • func (s *SimpleSubscribe[OTM, OTD, TM, TD, M]) Serve(ctx context.Context)
• type UsersSubscribe
  • func NewUsersSubscribe(ctx context.Context, kfk *kafkaframe.Kafka) *UsersSubscribe

Constants

const SubscribeGroup = "consumer-service"

Types

type DBUser

type DBUser struct {
}

type EventMessage

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

type EventMessageObjectType

type EventMessageObjectType any

type SimpleSubscribe

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)
}

func (*SimpleSubscribe[OTM, OTD, TM, TD, M]) Serve

func (s *SimpleSubscribe[OTM, OTD, TM, TD, M]) Serve(ctx context.Context)

type UsersSubscribe

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

func NewUsersSubscribe

func NewUsersSubscribe(ctx context.Context, kfk *kafkaframe.Kafka) *UsersSubscribe