broadcast

type Data struct {
	Peer      Peer     `bson:"peer" json:"peer"`
	VN        string   `bson:"vn" json:"vn"`
	Scope     string   `bson:"scope" json:"scope"`
	Data      string   `bson:"data" json:"data"`
	Timestamp int64    `bson:"timestamp" json:"timestamp"`
	Tag       []string `bson:"tag,omitempty" json:"tag,omitempty"`
}

type Listener interface {
	GetCode() string
	Care(ctx context.Context, msg *Message) bool
	Deal(ctx context.Context, msg *Message) *errors.Error
}

type MQ struct {
	Topic string
	// contains filtered or unexported fields
}

type Message struct {
	Peer      Peer     `bson:"peer" json:"peer"`
	Topic     string   `bson:"topic" json:"topic"`
	VN        string   `bson:"vn" json:"vn"`
	Scope     string   `bson:"scope" json:"scope"`
	ID        string   `bson:"id" json:"id"`
	Data      []byte   `bson:"data" json:"data"`
	Timestamp int64    `bson:"timestamp" json:"timestamp"`
	Tag       []string `bson:"tag,omitempty" json:"tag,omitempty"`
}

type Peer struct {
	ID   string     `bson:"id" json:"id"`
	Mode point.Mode `bson:"mode" json:"mode"`
}