collect

package module

Go to main page

Versions in this module

v0

v0.0.12

Apr 9, 2021

Changes in this version

type Conf

+ Fanout int

+ MaxHitsToSend int

+ RandomFanout int

type IntBFSOptions

+ Fanout int

+ MaxHitsToSend int

+ RandomFanout int

+ type RequestResult struct

v0.0.11

Dec 23, 2020

v0.0.10

Dec 23, 2020

v0.0.9

Dec 10, 2020

Changes in this version

+ const HostWiresProcotolID

+ const IntBFSProtocolID

+ var ErrNilTopicWires = errors.New("ErrNilTopicWires")

+ var ErrTopicJoined = errors.New("ErrTopicJoined")

+ var ErrTopicNotJoined = errors.New("ErrTopicNotJoined")

type Conf

+ Router string

+ type EvalReqReq struct

+ type HostWires struct

+ func NewHostWires(h host.Host) *HostWires

+ func (hw *HostWires) ClosedStream(network.Network, network.Stream)

+ func (hw *HostWires) Connected(n network.Network, c network.Conn)

+ func (hw *HostWires) Disconnected(n network.Network, c network.Conn)

+ func (hw *HostWires) ID() peer.ID

+ func (hw *HostWires) Listen(network.Network, ma.Multiaddr)

+ func (hw *HostWires) ListenClose(network.Network, ma.Multiaddr)

+ func (hw *HostWires) Neighbors() []peer.ID

+ func (hw *HostWires) OpenedStream(network.Network, network.Stream)

+ func (hw *HostWires) SendMsg(to peer.ID, data []byte) error

+ func (hw *HostWires) SetListener(wn WireListener)

+ func (hw *HostWires) SetMsgHandler(h MsgHandler)

type InitOpts

+ Wires TopicWires

+ type IntBFS struct

+ func NewIntBFS(wires Wires, opts *IntBFSOptions) (*IntBFS, error)

+ func (ib *IntBFS) Close() error

+ func (ib *IntBFS) HandlePeerDown(p peer.ID)

+ func (ib *IntBFS) HandlePeerUp(p peer.ID)

+ func (ib *IntBFS) Publish(data []byte, opts ...PubOpt) error

+ type IntBFSCollector struct

+ func NewIntBFSCollector(h host.Host, opts ...InitOpt) (*IntBFSCollector, error)

+ func (ic *IntBFSCollector) Close() error

+ func (ic *IntBFSCollector) Join(topic string, opts ...JoinOpt) (err error)

+ func (ic *IntBFSCollector) Leave(topic string) (err error)

+ func (ic *IntBFSCollector) Publish(topic string, data []byte, opts ...PubOpt) error

+ type IntBFSOptions struct

+ Topic string

+ func MakeDefaultIntBFSOptions() *IntBFSOptions

type JoinOpt

+ func WithProfileFactory(pf ProfileFactory) JoinOpt

+ type Msg struct

+ type MsgHandler func(from peer.ID, data []byte)

+ type Profile interface

+ Insert func(req *Request, resp *Response)

+ Less func(that Profile, req *Request) bool

+ type ProfileFactory func() Profile

+ type PubReq struct

type PubSubCollector

+ func NewCollector(h host.Host, opts ...InitOpt) (PubSubCollector, error)

+ type TopicHub struct

+ func NewTopicHub(tw TopicWires) *TopicHub

+ func (th *TopicHub) Close() error

+ func (th *TopicHub) HandlePeerDown(p peer.ID, topic string)

+ func (th *TopicHub) HandlePeerUp(p peer.ID, topic string)

+ func (th *TopicHub) Join(topic string) error

+ func (th *TopicHub) JoinWithNotifiee(topic string, wn WireListener) error

+ func (th *TopicHub) Leave(topic string) error

+ func (th *TopicHub) Wires(topic string) Wires

+ type TopicMsgHandler = pubsub.TopicMsgHandler

+ type TopicWireListener = pubsub.TopicWireListener

+ type TopicWires interface

+ ID func() peer.ID

+ Join func(topic string) error

+ Leave func(topic string) error

+ Neighbors func(topic string) []peer.ID

+ SendMsg func(topic string, to peer.ID, data []byte) error

+ SetListener func(twn TopicWireListener)

+ SetTopicMsgHandler func(th TopicMsgHandler)

+ Topics func() []string

+ type WireListener interface

+ HandlePeerDown func(p peer.ID)

+ HandlePeerUp func(p peer.ID)

+ type Wires interface

+ ID func() peer.ID

+ Neighbors func() []peer.ID

+ SendMsg func(to peer.ID, data []byte) error

+ SetListener func(wn WireListener)

+ SetMsgHandler func(h MsgHandler)

v0.0.8

Dec 2, 2020

v0.0.8-intbfs

Dec 7, 2020

v0.0.7

Dec 1, 2020

Changes in this version

+ func DefaultMsgIDFn(pmsg *pubsub.PbMessage) string

+ type AsyncPubSub struct

+ func NewAsyncPubSub(h host.Host, opts ...TopicOpt) (apsub *AsyncPubSub, err error)

+ func (ap *AsyncPubSub) Close() error

+ func (ap *AsyncPubSub) LoadTopicItem(topic string, key interface{}) (value interface{}, err error)

+ func (ap *AsyncPubSub) Publish(ctx context.Context, topic string, data []byte) (err error)

+ func (ap *AsyncPubSub) SetTopicItem(topic string, key interface{}, value interface{}) error

+ func (ap *AsyncPubSub) Subscribe(topic string, handle TopicHandle) (err error)

+ func (ap *AsyncPubSub) Topics() (out []string)

+ func (ap *AsyncPubSub) Unsubscribe(topic string) (err error)

+ type BasicPubSubCollector struct

+ func NewBasicPubSubCollector(h host.Host, options ...InitOpt) (bpsc *BasicPubSubCollector, err error)

+ func (bpsc *BasicPubSubCollector) Close() (err error)

+ func (bpsc *BasicPubSubCollector) Join(topic string, opts ...JoinOpt) (err error)

+ func (bpsc *BasicPubSubCollector) Leave(topic string) (err error)

+ func (bpsc *BasicPubSubCollector) Publish(topic string, payload []byte, opts ...PubOpt) (err error)

+ type Conf struct

+ ProtocolPrefix string

+ RequestCacheSize int

+ ResponseCacheSize int

+ func MakeDefaultConf() Conf

+ type FinalRespHandler func(context.Context, *Response)

+ type InitOpt func(*InitOpts) error

+ func WithConf(conf Conf) InitOpt

+ func WithLogger(l Logger) InitOpt

+ func WithRequestIDGenerator(ridFn ReqIDFn) InitOpt

+ type InitOpts struct

+ Conf Conf

+ Logger Logger

+ MsgIDFn pubsub.MsgIDFn

+ ReqIDFn ReqIDFn

+ func NewInitOpts(opts []InitOpt) (out *InitOpts, err error)

+ type Intermediate = pb.Intermediate

+ type JoinOpt func(*JoinOpts) error

+ func WithRequestHandler(rqhandle RequestHandler) JoinOpt

+ func WithResponseHandler(handler ResponseHandler) JoinOpt

+ type JoinOpts struct

+ func NewJoinOptions(opts []JoinOpt) (out *JoinOpts, err error)

+ type Logger interface

+ Logf func(level, format string, args ...interface{})

+ func MakeDefaultLogger() Logger

+ type Message = pubsub.Message

+ type PeerSet struct

+ func NewPeerSet() *PeerSet

+ func (ps *PeerSet) Add(p peer.ID)

+ func (ps *PeerSet) Del(p peer.ID)

+ func (ps *PeerSet) Equal(another *PeerSet) bool

+ func (ps *PeerSet) Slice() []peer.ID

+ func (ps *PeerSet) String() string

+ type PubOpt func(*PubOpts) error

+ func WithFinalRespHandler(handler FinalRespHandler) PubOpt

+ func WithRequestContext(ctx context.Context) PubOpt

+ type PubOpts struct

+ FinalRespHandle FinalRespHandler

+ RequestContext context.Context

+ func NewPublishOptions(opts []PubOpt) (out *PubOpts, err error)

+ type PubSubCollector interface

+ Join func(topic string, opts ...JoinOpt) error

+ Leave func(topic string) error

+ Publish func(topic string, data []byte, opts ...PubOpt) error

+ type PubSubFactory func(h host.Host) (*pubsub.PubSub, error)

+ type RelayPubSubCollector struct

+ func NewRelayPubSubCollector(h host.Host, options ...InitOpt) (r *RelayPubSubCollector, err error)

+ func (r *RelayPubSubCollector) Close() (err error)

+ func (r *RelayPubSubCollector) Join(topic string, options ...JoinOpt) (err error)

+ func (r *RelayPubSubCollector) Leave(topic string) (err error)

+ func (r *RelayPubSubCollector) Publish(topic string, data []byte, opts ...PubOpt) (err error)

+ type ReqIDFn func(*Request) RequestID

+ type Request = pb.Request

+ type RequestHandler func(ctx context.Context, req *Request) *Intermediate

+ type RequestID = pb.RequestID

+ func DefaultReqIDFn(rq *Request) RequestID

+ type Response = pb.Response

+ type ResponseHandler func(context.Context, *Response) *Intermediate

+ type TopicHandle func(topic string, msg *Message)

+ type TopicOpt func(*AsyncPubSub) error

+ func WithCustomPubSubFactory(psubFact PubSubFactory) TopicOpt

+ func WithSelfNotif(enable bool) TopicOpt

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL