mirror of
https://source.quilibrium.com/quilibrium/ceremonyclient.git
synced 2025-11-04 10:37:27 +00:00
39 lines
1.1 KiB
Go
39 lines
1.1 KiB
Go
package p2p
|
|
|
|
import (
|
|
"context"
|
|
|
|
"github.com/multiformats/go-multiaddr"
|
|
"google.golang.org/grpc"
|
|
"source.quilibrium.com/quilibrium/monorepo/go-libp2p-blossomsub/pb"
|
|
"source.quilibrium.com/quilibrium/monorepo/node/protobufs"
|
|
)
|
|
|
|
type PubSub interface {
|
|
PublishToBitmask(bitmask []byte, data []byte) error
|
|
Publish(address []byte, data []byte) error
|
|
Subscribe(bitmask []byte, handler func(message *pb.Message) error) error
|
|
Unsubscribe(bitmask []byte, raw bool)
|
|
GetPeerID() []byte
|
|
GetBitmaskPeers() map[string][]string
|
|
GetPeerstoreCount() int
|
|
GetNetworkPeersCount() int
|
|
GetRandomPeer(bitmask []byte) ([]byte, error)
|
|
GetMultiaddrOfPeerStream(
|
|
ctx context.Context,
|
|
peerId []byte,
|
|
) <-chan multiaddr.Multiaddr
|
|
GetMultiaddrOfPeer(peerId []byte) string
|
|
StartDirectChannelListener(
|
|
key []byte,
|
|
purpose string,
|
|
server *grpc.Server,
|
|
) error
|
|
GetDirectChannel(peerId []byte, purpose string) (*grpc.ClientConn, error)
|
|
GetNetworkInfo() *protobufs.NetworkInfoResponse
|
|
SignMessage(msg []byte) ([]byte, error)
|
|
GetPublicKey() []byte
|
|
GetPeerScore(peerId []byte) int64
|
|
SetPeerScore(peerId []byte, score int64)
|
|
}
|