kafka

Documentation

Index

• Constants
• func NewIdentityMessageProcessor(log logging.Logger, cfg *config.Config, v *validator.Validate, ...) *identityMessageProcessor

Constants

const (
	PoolSize = 30
)

Functions

func NewIdentityMessageProcessor

func NewIdentityMessageProcessor(
	log logging.Logger,
	cfg *config.Config,
	v *validator.Validate,
	us *services.UserService,
	gs *services.GroupService,
	ms *services.MembershipService,
	as *services.AuthService,
	metrics *metrics.CommandServiceMetrics,
) *identityMessageProcessor