Versions in this module Expand all Collapse all v0 v0.2.0 Mar 13, 2019 v0.1.0 Jul 23, 2018 Changes in this version + var ErrMissingPeerID = errors.New("missing peer ID") + var ErrMissingProtocolIDs = errors.New("missing protocol IDs") + var OptPeerID = func(peerID peer.ID) StreamOption + var OptProtocolIDs = func(pids ...protocol.ID) StreamOption + func WithAutoClose(service string, method string, h AutoCloseHandler) inet.StreamHandler + type AutoCloseHandler func(context.Context, *monitoring.Span, inet.Stream, Codec) error + type Codec interface + func NewProtobufCodec(stream inet.Stream) Codec + type ProtobufCodec struct + type Provider interface + NewStream func(context.Context, ihost.Host, ...StreamOption) (Stream, error) + func NewStreamProvider() Provider + type Stream interface + Close func() + Codec func() Codec + Conn func() inet.Conn + type StreamOption func(opts *StreamOptions) + type StreamOptions struct + PIDs []protocol.ID + PeerID peer.ID + type StreamProvider struct + func (p *StreamProvider) NewStream(ctx context.Context, host ihost.Host, opts ...StreamOption) (Stream, error)
Go to main page