protocol

type AnnouncePeers struct {
	HandshakeRequirement
	// contains filtered or unexported fields
}

type EncodeableMessage interface {
	msgpack.CustomEncoder
}

type HandshakeDone struct {
	HandshakeRequirement
	// contains filtered or unexported fields
}

type HandshakeOpen struct {
	HandshakeRequirement
	// contains filtered or unexported fields
}

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

type HandshakeRequirer interface {
	RequiresHandshake() bool
	SetRequiresHandshake(value bool)
}

type HashQuery struct {
	HandshakeRequirement
	// contains filtered or unexported fields
}

type IncomingMessage interface {
	HandleMessage(message IncomingMessageData) error
	DecodeMessage(dec *msgpack.Decoder, message IncomingMessageData) error
	HandshakeRequirer
}

type IncomingMessageData struct {
	Original []byte
	Data     []byte
	Ctx      context.Context
	Logger   *zap.Logger
	Peer     net.Peer
	Config   *config.NodeConfig
	VerifyId bool
	Mediator Mediator
}

type IncomingMessageDataSigned struct {
	IncomingMessageData
	NodeId *encoding.NodeId
}

type IncomingMessageReader struct {
	Kind int
	Data []byte
}

type IncomingMessageSigned interface {
	HandleMessage(message IncomingMessageDataSigned) error
	DecodeMessage(dec *msgpack.Decoder, message IncomingMessageDataSigned) error
	HandshakeRequirer
}

type Mediator interface {
	NetworkId() string
	NodeId() *encoding.NodeId
	SelfConnectionUris() []*url.URL
	SignMessageSimple(message []byte) ([]byte, error)
	GetCachedStorageLocations(hash *encoding.Multihash, kinds []types.StorageLocationType) (map[string]storage.StorageLocation, error)
	SortNodesByScore(nodes []*encoding.NodeId) ([]*encoding.NodeId, error)
	ProviderStore() storage.ProviderStore
	AddStorageLocation(hash *encoding.Multihash, nodeId *encoding.NodeId, location storage.StorageLocation, message []byte) error
	HashQueryRoutingTable() structs.Map
	Peers() structs.Map
	RegistrySet(sre SignedRegistryEntry, trusted bool, receivedFrom net.Peer) error
	RegistryGet(pk []byte) (SignedRegistryEntry, error)
	ConnectToNode(connectionUris []*url.URL, retried bool, fromPeer net.Peer) error
	ServicesStarted() bool
	AddPeer(peer net.Peer) error
	SendPublicPeersToPeer(peer net.Peer, peersToSend []net.Peer) error
}

type RegistryEntry interface {
	Sign() SignedRegistryEntry
}

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

type RegistryEntryRequest struct {
	HandshakeRequirement
	// contains filtered or unexported fields
}

type RegistryQuery struct {
	HandshakeRequirement
	// contains filtered or unexported fields
}

type SignedMessage struct {
	HandshakeRequirement
	// contains filtered or unexported fields
}

type SignedRegistryEntry interface {
	PK() []byte
	Revision() uint64
	Data() []byte
	Signature() []byte
	SetPK(pk []byte)
	SetRevision(revision uint64)
	SetData(data []byte)
	SetSignature(signature []byte)
	Verify() bool
}

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

type StorageLocation struct {
	HandshakeRequirement
	// contains filtered or unexported fields
}