message

package

v0.4.13 Latest Latest Go to latest Published: Aug 15, 2024 License: MIT Imports: 12 Imported by: 0

Details

This section is empty.

View Source

var ProviderSet = wire.NewSet(
	NewMessageService,
	NewMessageConsumer,
)

ProviderSet is service providers.

This section is empty.

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

func NewMessageConsumer(ms *MessageService) *MessageConsumer

func (s *MessageConsumer) Cleanup(sarama.ConsumerGroupSession) error

func (s *MessageConsumer) ConsumeClaim(session sarama.ConsumerGroupSession, claim sarama.ConsumerGroupClaim) error

func (s *MessageConsumer) Setup(sarama.ConsumerGroupSession) error

type MessageService struct {
	messageApi.UnimplementedMessageServer
	// contains filtered or unexported fields
}

func NewMessageService(dc *conf.DatabaseServerConfig, lc *conf.MessageConfig, rc *conf.RedisConfig) *MessageService

func (ms *MessageService) GetMessage(ctx context.Context, req *messageApi.GetMessageReq) (*messageApi.MessageRecord, error)

func (ms *MessageService) GetMessageList(ctx context.Context, req *messageApi.GetMessageListReq) (*messageApi.GetMessageListResp, error)

func (ms *MessageService) GetUnreadNum(ctx context.Context, req *messageApi.GetUnreadNumReq) (*messageApi.GetUnreadNumResp, error)

func (ms *MessageService) MarkAllRead(ctx context.Context, req *messageApi.MarkAllReadReq) (*messageApi.Empty, error)

func (ms *MessageService) SendMessage(ctx context.Context, req *messageApi.SendMessageReq) (*messageApi.Empty, error)

Path	Synopsis
model