middleware

Jul 6, 2023

Changes in this version

+ func UnicastMaxMsgSizeByCode(payload []byte) (int, error)

Apr 5, 2023

Changes in this version

type Middleware

+ func (m *Middleware) OnDisallowListNotification(notification *p2p.DisallowListUpdateNotification)

+ type ReadSubscriptionCallBackFunction func(msg *message.Message, peerID peer.ID)

Dec 16, 2022

Changes in this version

+ var ErrUnicastMsgWithoutSub = errors.New(...)

type MiddlewareOption

+ func WithPeerManagerFilters(peerManagerFilters []p2p.PeerFilter) MiddlewareOption

+ func WithUnicastRateLimiters(rateLimiters *ratelimit.RateLimiters) MiddlewareOption

Oct 13, 2022

Changes in this version

+ const DefaultMaxUnicastMsgSize

+ const DefaultUnicastTimeout

+ const LargeMsgMaxUnicastMsgSize

+ const LargeMsgUnicastTimeout

+ func DefaultValidators(log zerolog.Logger, flowID flow.Identifier) []network.MessageValidator

+ type Middleware struct

+ func NewMiddleware(log zerolog.Logger, libP2PNode *p2pnode.Node, flowID flow.Identifier, ...) *Middleware

+ func (m *Middleware) GetIPPort() (string, string, error)

+ func (m *Middleware) IsConnected(nodeID flow.Identifier) (bool, error)

+ func (m *Middleware) Me() flow.Identifier

+ func (m *Middleware) NewBlobService(channel channels.Channel, ds datastore.Batching, ...) network.BlobService

+ func (m *Middleware) NewPingService(pingProtocol protocol.ID, provider network.PingInfoProvider) network.PingService

+ func (m *Middleware) Publish(msg *message.Message, channel channels.Channel) error

+ func (m *Middleware) SendDirect(msg *message.Message, targetID flow.Identifier) (err error)

+ func (m *Middleware) SetOverlay(ov network.Overlay)

+ func (m *Middleware) Subscribe(channel channels.Channel) error

+ func (m *Middleware) Unsubscribe(channel channels.Channel) error

+ func (m *Middleware) UpdateNodeAddresses()

+ type MiddlewareOption func(*Middleware)

+ func WithMessageValidators(validators ...network.MessageValidator) MiddlewareOption

+ func WithPreferredUnicastProtocols(unicasts []unicast.ProtocolName) MiddlewareOption