server

Documentation

Index

• Variables
• func EmailVerifyCreator() broker.Any
• func NewHTTPServer(c *conf.Server, svc *service.AuthService, logger log.Logger, ...) *http.Server
• func NewKafkaServer(c *conf.Server, _ log.Logger, svc *service.EmailJobService, ...) *kafka.Server
• func RegisterEmailVerifyHandler(fnc EmaiVerifyHandler) broker.Handler
• type EmaiVerifyHandler

Variables

var ProviderSet = wire.NewSet(NewKafkaServer, NewHTTPServer)

ProviderSet is server providers.

Functions

func EmailVerifyCreator

func EmailVerifyCreator() broker.Any

func NewHTTPServer

func NewHTTPServer(c *conf.Server, svc *service.AuthService, logger log.Logger, tp *tracesdk.TracerProvider) *http.Server

NewHTTPServer new an HTTP server.

func NewKafkaServer

func NewKafkaServer(c *conf.Server, _ log.Logger, svc *service.EmailJobService, tp *tracesdk.TracerProvider) *kafka.Server

func RegisterEmailVerifyHandler

func RegisterEmailVerifyHandler(fnc EmaiVerifyHandler) broker.Handler

Types

type EmaiVerifyHandler

type EmaiVerifyHandler func(ctx context.Context, topic string, headers broker.Headers, msg *v1.SendEmailRequest) error