server

package
v1.7.6 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 24, 2023 License: MIT Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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 added in v1.3.0

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

func NewRocketMqConsumerServer added in v1.3.0

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

func (*RocketMqConsumerServer) Start added in v1.3.0

func (*RocketMqConsumerServer) Stop added in v1.3.0

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL