sets

type ConnGaterSet ¶

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

ConnGaterSet implements the connmgr.ConnectionGater and allow to aggregate multiple instances of this interface.

func NewConnGaterSet() *ConnGaterSet

func (c *ConnGaterSet) Add(connGaters ...connmgr.ConnectionGater)

func (c *ConnGaterSet) InterceptAccept(network network.ConnMultiaddrs) bool

func (c *ConnGaterSet) InterceptAddrDial(id peer.ID, addr multiaddr.Multiaddr) bool

func (c *ConnGaterSet) InterceptPeerDial(id peer.ID) bool

func (c *ConnGaterSet) InterceptSecured(dir network.Direction, id peer.ID, network network.ConnMultiaddrs) bool

func (c *ConnGaterSet) InterceptUpgraded(conn network.Conn) (bool, control.DisconnectReason)

type MessageHandler ¶

type MessageHandler interface {
	// Published is called when new message is published.
	Published(topic string, raw []byte, msg transport.Message)
	// Received is called when new message is received.
	Received(topic string, msg *pubsub.Message, result pubsub.ValidationResult)
	// Broken is called when it is impossible to unmarshall message,
	Broken(topic string, msg *pubsub.Message, err error)
}

MessageHandler can ba implemented by type that supports handling the PubSub system messages.

type MessageHandlerSet ¶

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

MessageHandlerSet stores multiple instances of the MessageHandler interface.

func NewMessageHandlerSet() *MessageHandlerSet

func (n *MessageHandlerSet) Add(messageHandler ...MessageHandler)

func (n *MessageHandlerSet) Broken(topic string, msg *pubsub.Message, err error)

func (n *MessageHandlerSet) Published(topic string, raw []byte, msg transport.Message)

func (n *MessageHandlerSet) Received(topic string, msg *pubsub.Message, result pubsub.ValidationResult)

type NodeConfiguredEvent ¶ added in v0.1.3

type NodeConfiguredEvent struct{}

type NodeEventHandler ¶

type NodeEventHandler interface {
	// Handle is called on a new event.
	Handle(event interface{})
}

NodeEventHandler can ba implemented by type that supports handling the Node system events.

type NodeEventHandlerFunc ¶

type NodeEventHandlerFunc func(event interface{})

NodeEventHandlerFunc is a adapter for the NodeEventHandler interface.

func (f NodeEventHandlerFunc) Handle(event interface{})

type NodeEventHandlerSet ¶

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

NodeEventHandlerSet stores multiple instances of the NodeEventHandler interface.

func NewNodeEventHandlerSet() *NodeEventHandlerSet

func (n *NodeEventHandlerSet) Add(eventHandler ...NodeEventHandler)

func (n *NodeEventHandlerSet) Handle(event interface{})

type NodeHostStartedEvent ¶ added in v0.1.3

type NodeHostStartedEvent struct{}

type NodePubSubStartedEvent ¶ added in v0.1.3

type NodePubSubStartedEvent struct{}

type NodeStartedEvent ¶ added in v0.1.3

type NodeStartedEvent struct{}

type NodeStartingEvent ¶ added in v0.1.3

type NodeStartingEvent struct{}

type NodeStoppedEvent ¶ added in v0.1.3

type NodeStoppedEvent struct{}

type NodeStoppingEvent ¶ added in v0.1.3

type NodeStoppingEvent struct{}

type NodeTopicSubscribedEvent ¶ added in v0.1.3

type NodeTopicSubscribedEvent struct{ Topic string }

type NodeTopicUnsubscribedEvent ¶ added in v0.1.3

type NodeTopicUnsubscribedEvent struct{ Topic string }

type NotifeeSet ¶

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

NotifeeSet implements the network.Notifiee and allow to aggregate multiple instances of this interface.

func NewNotifeeSet() *NotifeeSet

func (n *NotifeeSet) Add(notifees ...network.Notifiee)

func (n *NotifeeSet) ClosedStream(network network.Network, stream network.Stream)

func (n *NotifeeSet) Connected(network network.Network, conn network.Conn)

func (n *NotifeeSet) Disconnected(network network.Network, conn network.Conn)

func (n *NotifeeSet) Listen(network network.Network, maddr multiaddr.Multiaddr)

func (n *NotifeeSet) ListenClose(network network.Network, maddr multiaddr.Multiaddr)

func (n *NotifeeSet) OpenedStream(network network.Network, stream network.Stream)

func (n *NotifeeSet) Remove(notifees ...network.Notifiee)

type PubSubEventHandler ¶

type PubSubEventHandler interface {
	// Handle is called on a new event.
	Handle(topic string, event pubsub.PeerEvent)
}

PubSubEventHandler can ba implemented by type that supports handling the PubSub system events.

type PubSubEventHandlerFunc ¶

type PubSubEventHandlerFunc func(topic string, event pubsub.PeerEvent)

PubSubEventHandlerFunc is a adapter for the PubSubEventHandler interface.

func (f PubSubEventHandlerFunc) Handle(topic string, event pubsub.PeerEvent)

type PubSubEventHandlerSet ¶

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

PubSubEventHandlerSet stores multiple instances of the PubSubEventHandler interface.

func NewPubSubEventHandlerSet() *PubSubEventHandlerSet

func (n *PubSubEventHandlerSet) Add(eventHandler ...PubSubEventHandler)

func (n *PubSubEventHandlerSet) Handle(topic string, event pubsub.PeerEvent)

type Validator ¶

type Validator func(ctx context.Context, topic string, id peer.ID, msg *pubsub.Message) pubsub.ValidationResult

type ValidatorSet ¶

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

ValidatorSet stores multiple instances of validators that implements the pubsub.ValidatorEx functions. Validators are groped by topic.

func NewValidatorSet() *ValidatorSet

func (n *ValidatorSet) Add(validator ...Validator)

func (n *ValidatorSet) Validator(topic string) pubsub.ValidatorEx