Documentation
¶
Index ¶
- Constants
- func AskUsersTweets(users []*models.User, node *p2pNet.UserNode, ctx context.Context)
- func BroadcastNewestTweet(usr *models.User)
- func BroadcastTweet(tw *models.Tweets)
- func BroadcastTweetSync(tw *models.Tweets)
- func CenterUserRelease(tw *models.Tweets) error
- func IpfsSync()
- func ReleaseTweet(user *models.User, keyName, content, attachment, forwardId, topicTag string, ...) (*models.Tweets, error)
- func SyncByCid(cid string) *models.TweetJson
- func SyncByUser(usr *models.User, sdb *gorm.DB)
- func SyncUserInfo(usr *models.User, force bool) error
- func SyncUserTweets(ctx context.Context) error
- type TweetInfo
- type TweetInfoSync
- type UserInfo
- func (usrInfo *UserInfo) DoAsk() (err error)
- func (usrInfo *UserInfo) ReceiveHandle(ctx context.Context, node *p2pNet.OnlineNode)
- func (usrInfo *UserInfo) ReceiveHandleAsk(ctx context.Context, node *p2pNet.OnlineNode)
- func (usrInfo *UserInfo) ReceiveHandleUpdate(ctx context.Context, node *p2pNet.OnlineNode)
Constants ¶
View Source
const ( TweetInfoSyncTypeAsk = 1 TweetInfoSyncTypeReply = 2 )
View Source
const ( UserInfoReceiveHandleTypeUpdate = 1 UserInfoReceiveHandleTypeAsk = 2 UserInfoReceiveHandleTypeAskReply = 3 UserInfoReceiveHandleTypeGotoAsk = 4 )
Variables ¶
This section is empty.
Functions ¶
func AskUsersTweets ¶
询问单个用的推文
func BroadcastNewestTweet ¶
func BroadcastTweet ¶
func BroadcastTweetSync ¶
func CenterUserRelease ¶
发布中心用户的文章发布 即 自有用户自己签名后 发布转发
func ReleaseTweet ¶
Types ¶
type TweetInfo ¶
func (*TweetInfo) ReceiveHandle ¶
func (twInfo *TweetInfo) ReceiveHandle(ctx context.Context, node *p2pNet.OnlineNode)
type TweetInfoSync ¶
type TweetInfoSync struct {
UserAddress string
TwNonce uint64
Size int
Type uint8
ReplyTweets []*models.Tweets //对于询问回复的推文信息
//是否还有其他的新推文没有回复 该字段不代表已回复的推文列表是否满足size大小 而是是否还有比已回复的推文更新的内容
//对于size是否完成 通过比较size和len(ReplyTweets)
ReplyTwSurplusNewNum uint64
}
func NewTweetInfoSyncAsk ¶
func NewTweetInfoSyncAsk(userAddress string, twNonce uint64) *TweetInfoSync
func (*TweetInfoSync) ReceiveHandle ¶
func (tis *TweetInfoSync) ReceiveHandle(ctx context.Context, node *p2pNet.OnlineNode)
func (*TweetInfoSync) ReceiveHandleAsk ¶
func (tis *TweetInfoSync) ReceiveHandleAsk(ctx context.Context, node *p2pNet.OnlineNode)
func (*TweetInfoSync) ReceiveHandleReply ¶
func (tis *TweetInfoSync) ReceiveHandleReply(ctx context.Context, node *p2pNet.OnlineNode)
type UserInfo ¶
type UserInfo struct {
Id string
Name string
Desc string
LatestCid string
Avatar string
Nonce uint64
PeerId string
HasPeerId uint8
Sign string
PublicKey string
IpfsHash string
UpdatedSignUnix int64
CreatedAt int64
ReceiveHandleType uint8
IsRemoveNonceBeforeTweets bool
// contains filtered or unexported fields
}
该结构保存用户可广播的资料
func NewUserInfo ¶
func NewUserInfoAsk ¶
func (*UserInfo) ReceiveHandle ¶
func (usrInfo *UserInfo) ReceiveHandle(ctx context.Context, node *p2pNet.OnlineNode)
func (*UserInfo) ReceiveHandleAsk ¶
func (usrInfo *UserInfo) ReceiveHandleAsk(ctx context.Context, node *p2pNet.OnlineNode)
func (*UserInfo) ReceiveHandleUpdate ¶
func (usrInfo *UserInfo) ReceiveHandleUpdate(ctx context.Context, node *p2pNet.OnlineNode)
接收方法
Click to show internal directories.
Click to hide internal directories.