Documentation
¶
Index ¶
- func NewClient(client appsenderpb.AppSenderClient) p2p.Sender
- type Client
- func (c *Client) SendError(ctx context.Context, nodeID ids.NodeID, requestID uint32, errorCode int32, ...) error
- func (c *Client) SendGossip(ctx context.Context, config p2p.SendConfig, msg []byte) error
- func (c *Client) SendRequest(ctx context.Context, nodeIDs set.Set[ids.NodeID], requestID uint32, ...) error
- func (c *Client) SendResponse(ctx context.Context, nodeID ids.NodeID, requestID uint32, response []byte) error
- type Server
- func (s *Server) SendCrossChainError(ctx context.Context, req *appsenderpb.SendCrossChainErrorMsg) (*emptypb.Empty, error)
- func (s *Server) SendCrossChainRequest(ctx context.Context, req *appsenderpb.SendCrossChainRequestMsg) (*emptypb.Empty, error)
- func (s *Server) SendCrossChainResponse(ctx context.Context, req *appsenderpb.SendCrossChainResponseMsg) (*emptypb.Empty, error)
- func (s *Server) SendError(ctx context.Context, req *appsenderpb.SendErrorMsg) (*emptypb.Empty, error)
- func (s *Server) SendGossip(ctx context.Context, req *appsenderpb.SendGossipMsg) (*emptypb.Empty, error)
- func (s *Server) SendRequest(ctx context.Context, req *appsenderpb.SendRequestMsg) (*emptypb.Empty, error)
- func (s *Server) SendResponse(ctx context.Context, req *appsenderpb.SendResponseMsg) (*emptypb.Empty, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewClient ¶
func NewClient(client appsenderpb.AppSenderClient) p2p.Sender
NewClient returns a p2p.Sender backed by gRPC
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
Client implements p2p.Sender over gRPC
func (*Client) SendGossip ¶ added in v1.16.56
func (*Client) SendRequest ¶ added in v1.16.56
type Server ¶
type Server struct {
appsenderpb.UnsafeAppSenderServer
// contains filtered or unexported fields
}
func (*Server) SendCrossChainError ¶ added in v1.22.87
func (s *Server) SendCrossChainError(ctx context.Context, req *appsenderpb.SendCrossChainErrorMsg) (*emptypb.Empty, error)
SendCrossChainError implements AppSenderServer
func (*Server) SendCrossChainRequest ¶ added in v1.22.87
func (s *Server) SendCrossChainRequest(ctx context.Context, req *appsenderpb.SendCrossChainRequestMsg) (*emptypb.Empty, error)
SendCrossChainRequest implements AppSenderServer
func (*Server) SendCrossChainResponse ¶ added in v1.22.87
func (s *Server) SendCrossChainResponse(ctx context.Context, req *appsenderpb.SendCrossChainResponseMsg) (*emptypb.Empty, error)
SendCrossChainResponse implements AppSenderServer
func (*Server) SendError ¶ added in v1.22.87
func (s *Server) SendError(ctx context.Context, req *appsenderpb.SendErrorMsg) (*emptypb.Empty, error)
func (*Server) SendGossip ¶ added in v1.22.87
func (s *Server) SendGossip(ctx context.Context, req *appsenderpb.SendGossipMsg) (*emptypb.Empty, error)
func (*Server) SendRequest ¶ added in v1.22.87
func (s *Server) SendRequest(ctx context.Context, req *appsenderpb.SendRequestMsg) (*emptypb.Empty, error)
func (*Server) SendResponse ¶ added in v1.22.87
func (s *Server) SendResponse(ctx context.Context, req *appsenderpb.SendResponseMsg) (*emptypb.Empty, error)
Click to show internal directories.
Click to hide internal directories.