message

Documentation

Index

• Variables
• func NewConsumerGroup(cli sarama.Client) sarama.ConsumerGroup
• func NewMessageGrpcServer(config *conf.GrpcServerConfig, message *message.MessageService) *utils.GrpcGatewayServer
• type MessageMQServer
  • func NewMessageMQServerServer(cli sarama.Client, c *message.MessageConsumer) *MessageMQServer
  • func (l *MessageMQServer) Start(ctx context.Context) error
  • func (l *MessageMQServer) Stop(ctx context.Context) error

Variables

var ProviderSet = wire.NewSet(
	NewMessageGrpcServer,
	utils.ForceNewKafkaClient,
	NewConsumerGroup,
	NewMessageMQServerServer,
)

Functions

func NewConsumerGroup

func NewConsumerGroup(
	cli sarama.Client,
) sarama.ConsumerGroup

func NewMessageGrpcServer

func NewMessageGrpcServer(
	config *conf.GrpcServerConfig,
	message *message.MessageService,
) *utils.GrpcGatewayServer

Types

type MessageMQServer

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

func NewMessageMQServerServer

func NewMessageMQServerServer(
	cli sarama.Client,
	c *message.MessageConsumer,
) *MessageMQServer

func (*MessageMQServer) Start

func (l *MessageMQServer) Start(ctx context.Context) error

func (*MessageMQServer) Stop

func (l *MessageMQServer) Stop(ctx context.Context) error