server

Documentation

Index

• Variables
• func MqRecovery(...) ...
• func NewGRPCServer(c *conf.Server, messageService *service.MessageService, logger log.Logger) *grpc.Server
• func NewHTTPServer(c *conf.Server, messageService *service.MessageService, logger log.Logger) *http.Server
• type RocketMqConsumerServer
  • func NewRocketMqConsumerServer(conf *conf.Server, messageService *service.MessageService, logger log.Logger) *RocketMqConsumerServer
  • func (s *RocketMqConsumerServer) Start(_ context.Context) error
  • func (s *RocketMqConsumerServer) Stop(_ context.Context) error

Variables

var ProviderSet = wire.NewSet(NewHTTPServer, NewGRPCServer, NewRocketMqConsumerServer)

ProviderSet is user providers.

Functions

func MqRecovery

func MqRecovery(fn func(ctx context.Context,
	msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error)) func(ctx context.Context,
	msgs ...*primitive.MessageExt) (consumer.ConsumeResult, error)

func NewGRPCServer

func NewGRPCServer(c *conf.Server, messageService *service.MessageService, logger log.Logger) *grpc.Server

func NewHTTPServer

func NewHTTPServer(c *conf.Server, messageService *service.MessageService, logger log.Logger) *http.Server

NewHTTPServer new a HTTP user.

Types

type RocketMqConsumerServer

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

func NewRocketMqConsumerServer

func NewRocketMqConsumerServer(conf *conf.Server, messageService *service.MessageService, logger log.Logger) *RocketMqConsumerServer

func (*RocketMqConsumerServer) Start

func (s *RocketMqConsumerServer) Start(_ context.Context) error

func (*RocketMqConsumerServer) Stop

func (s *RocketMqConsumerServer) Stop(_ context.Context) error