Method NewMessage

store/server.go:210–219

NewMessage save message to leveldb,

(_ context.Context, req *meta.StoreNewMessageRequest)

// NewMessage save message to leveldb,
func (s *Store) NewMessage(_ context.Context, req *meta.StoreNewMessageRequest) (*meta.StoreNewMessageResponse, error) {
	log.Debugf("Store NewMessage, msg:%v", req.Msg)
	// 直接发送，如果失败会自动插入到重试队列中
	if err := s.message.send(meta.PushMessage{Msg: req.Msg}); err != nil {
		return &meta.StoreNewMessageResponse{Header: &meta.ResponseHeader{Code: -1, Msg: err.Error()}}, nil
	}
	log.Debugf("Store messate success")

	return &meta.StoreNewMessageResponse{}, nil
}

// UploadFile 上传文件接口，一次一个文件.
func (s *Store) UploadFile(_ context.Context, req *meta.StoreUploadFileRequest) (*meta.StoreUploadFileResponse, error) {