server

package
v0.0.0-...-efd9455 Latest Latest
Warning

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

 Go to latest Published: Jun 2, 2022 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Cmd2Value 

type Cmd2Value struct {
	Cmd   int
	Value interface{}
}

type MsgPushServiceServer 

type MsgPushServiceServer struct {
	pushpb.UnimplementedMsgPushServiceServer
	SingleConsumerGroup     *xkafka.MConsumerGroup
	SuperGroupConsumerGroup *xkafka.MConsumerGroup
	// contains filtered or unexported fields
}

func NewMsgPushServiceServer 

func NewMsgPushServiceServer(svcCtx *svc.ServiceContext) *MsgPushServiceServer

func (*MsgPushServiceServer) Cleanup 

func (s *MsgPushServiceServer) Cleanup(session sarama.ConsumerGroupSession) error

func (*MsgPushServiceServer) ConsumeClaim 

func (s *MsgPushServiceServer) ConsumeClaim(sess sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (*MsgPushServiceServer) ConsumeSingle 

func (s *MsgPushServiceServer) ConsumeSingle(sess sarama.ConsumerGroupSession, msg *sarama.ConsumerMessage)

func (*MsgPushServiceServer) ConsumeSuperGroup 

func (s *MsgPushServiceServer) ConsumeSuperGroup(sess sarama.ConsumerGroupSession, msg *sarama.ConsumerMessage)

func (*MsgPushServiceServer) PushMsg 

func (s *MsgPushServiceServer) PushMsg(ctx context.Context, in *pushpb.PushMsgReq) (*pushpb.PushMsgResp, error)

func (*MsgPushServiceServer) PushSuperGroupMsg 

func (s *MsgPushServiceServer) PushSuperGroupMsg(ctx context.Context, in *chatpb.PushMsgToSuperGroupDataToMQ) (*pushpb.PushMsgResp, error)

func (*MsgPushServiceServer) Setup 

func (s *MsgPushServiceServer) Setup(session sarama.ConsumerGroupSession) error

func (*MsgPushServiceServer) Subscribe 

func (s *MsgPushServiceServer) Subscribe()

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.