Documentation ¶
Overview ¶
nolint
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrNotConnected = errors.New("peer is not connected")
ErrNotConnected is returned when peer is not connected.
Functions ¶
This section is empty.
Types ¶
type Host ¶ added in v1.0.0
type Host interface { SetStreamHandler(protocol.ID, network.StreamHandler) NewStream(context.Context, peer.ID, ...protocol.ID) (network.Stream, error) Network() network.Network }
Host is a subset of libp2p Host interface that needs to be implemented to be usable with server.
type Opt ¶ added in v1.0.0
type Opt func(s *Server)
Opt is a type to configure a server.
func WithContext ¶ added in v1.0.0
WithContext configures parent context for contexts that are passed to the handler.
func WithTimeout ¶ added in v1.0.0
WithTimeout configures stream timeout.
type Response ¶ added in v1.0.0
Response is a server response.
func (*Response) DecodeScale ¶ added in v1.0.0
func (*Response) EncodeScale ¶ added in v1.0.0
type Server ¶ added in v1.0.0
type Server struct {
// contains filtered or unexported fields
}
Server for the Handler.
func (*Server) Request ¶ added in v1.0.0
func (s *Server) Request(ctx context.Context, pid peer.ID, req []byte, resp func([]byte), failure func(error)) error
Request sends a binary request to the peer. Request is executed in the background, one of the callbacks is guaranteed to be called on success/error.
Click to show internal directories.
Click to hide internal directories.