rpc

type Codec = transport.Codec

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

type ErrorReporter interface {
	ReportError(error)
}

type IntroductionInfo struct {
	SendToRecipient ThirdPartyCapID
	SendToProvider  RecipientID
}

type Network interface {
	// Return the identifier for caller on this network.
	LocalID() PeerID

	// Connect to another peer by ID. The supplied Options are used
	// for the connection, with the values for RemotePeerID and Network
	// overridden by the Network.
	Dial(PeerID, *Options) (*Conn, error)

	// Accept the next incoming connection on the network, using the
	// supplied Options for the connection. Generally, callers will
	// want to invoke this in a loop when launching a server.
	Accept(context.Context, *Options) (*Conn, error)

	// Introduce the two connections, in preparation for a third party
	// handoff. Afterwards, a Provide messsage should be sent to
	// provider, and a ThirdPartyCapId should be sent to recipient.
	Introduce(provider, recipient *Conn) (IntroductionInfo, error)

	// Given a ThirdPartyCapID, received from introducedBy, connect
	// to the third party. The caller should then send an Accept
	// message over the returned Connection.
	DialIntroduced(capID ThirdPartyCapID, introducedBy *Conn) (*Conn, ProvisionID, error)

	// Given a RecipientID received in a Provide message via
	// introducedBy, wait for the recipient to connect, and
	// return the connection formed. If there is already an
	// established connection to the relevant Peer, this
	// SHOULD return the existing connection immediately.
	AcceptIntroduced(recipientID RecipientID, introducedBy *Conn) (*Conn, error)
}

type Options struct {
	// BootstrapClient is the capability that will be returned to the
	// remote peer when receiving a Bootstrap message.  NewConn "steals"
	// this reference: it will release the client when the connection is
	// closed.
	BootstrapClient capnp.Client

	// ErrorReporter will be called upon when errors occur while the Conn
	// is receiving messages from the remote vat.
	ErrorReporter ErrorReporter

	// AbortTimeout specifies how long to block on sending an abort message
	// before closing the transport.  If zero, then a reasonably short
	// timeout is used.
	AbortTimeout time.Duration

	// RemotePeerID is the PeerID of the remote side of the connection. Can
	// be left as the zero value for point to point connections. For >= 3
	// party use, this should be filled in by the Network on Accept or Dial.
	// Application code should not set this.
	RemotePeerID PeerID

	// A reference to the Network that this connection is a part of.  Can be
	// left nil for point to point connections. Otherwise, this must be set
	// by Dial or Accept on the Network itself; application code should not
	// set this.
	Network Network
}

type PeerID struct {
	// Network specific value identifying the peer.
	Value any
}

type ProvisionID capnp.Ptr

type RecipientID capnp.Ptr

type ThirdPartyCapID capnp.Ptr

type Transport = transport.Transport