transport

type BootstrapTransport interface {
	// LeaderElect should perform an initial leader election. It returns
	// true is this node was elected leader, or otherwise a JoinRoundTripper
	// for contacting the elected leader. If one or more nodes believe
	// the cluster to be already bootstrapped, then storage.ErrAlreadyBootstrapped
	// should be returned with an optional JoinRoundTripper to nodes who are
	// already bootstrapped.
	LeaderElect(ctx context.Context) (isLeader bool, rt JoinRoundTripper, err error)
}

type BootstrapTransportFunc func(ctx context.Context) (isLeader bool, rt JoinRoundTripper, err error)

type Dialer interface {
	Dial(ctx context.Context, network, address string) (net.Conn, error)
}

type FeatureResolver = Resolver[v1.Feature]

type FeatureResolverFunc = ResolverFunc[v1.Feature]

type JoinRoundTripper = RoundTripper[v1.JoinRequest, v1.JoinResponse]

type JoinRoundTripperFunc = RoundTripperFunc[v1.JoinRequest, v1.JoinResponse]

type JoinServer = UnaryServer[v1.JoinRequest, v1.JoinResponse]

type JoinServerFunc = UnaryServerFunc[v1.JoinRequest, v1.JoinResponse]

type LeaderDialer interface {
	// DialLeader opens a gRPC connection to the current leader.
	DialLeader(ctx context.Context) (RPCClientConn, error)
}

type LeaderDialerFunc func(ctx context.Context) (RPCClientConn, error)

type LeaveRoundTripper = RoundTripper[v1.LeaveRequest, v1.LeaveResponse]

type LeaveRoundTripperFunc = RoundTripperFunc[v1.LeaveRequest, v1.LeaveResponse]

type NodeDialer interface {
	DialNode(ctx context.Context, id types.NodeID) (RPCClientConn, error)
}

type NodeDialerFunc func(ctx context.Context, id types.NodeID) (RPCClientConn, error)

type NodeIDResolver = Resolver[types.NodeID]

type NodeIDResolverFunc = ResolverFunc[types.NodeID]

type RPCClientConn interface {
	grpc.ClientConnInterface
	io.Closer
}

type RPCTransport interface {
	// Dial opens a gRPC client connection to the remote address. Implementations
	// may choose to ignore the id or address.
	Dial(ctx context.Context, id, address string) (RPCClientConn, error)
}

type RaftTransport interface {
	raft.Transport
	LeaderDialer

	// AddrPort returns the address and port the transport is listening on.
	AddrPort() netip.AddrPort

	// Close closes the transport.
	Close() error
}

type Resolver[T any] interface {
	// Resolve resolves the addresses for the given lookup parameters.
	Resolve(ctx context.Context, lookup T) ([]netip.AddrPort, error)
}

type ResolverFunc[T any] func(ctx context.Context, lookup T) ([]netip.AddrPort, error)

type RoundTripper[REQ, RESP any] interface {
	io.Closer

	RoundTrip(ctx context.Context, req *REQ) (*RESP, error)
}

type RoundTripperFunc[REQ, RESP any] func(ctx context.Context, req *REQ) (*RESP, error)

type UnaryServer[REQ, RESP any] interface {
	// Serve is executed when a unary request is received.
	Serve(ctx context.Context, req *REQ) (*RESP, error)
}

type UnaryServerFunc[REQ, RESP any] func(ctx context.Context, req *REQ) (*RESP, error)

type WebRTCSignalTransport interface {
	// Start starts the transport. This will not return until a remote peer
	// has provided a session description.
	Start(ctx context.Context) error
	// TURNServers returns a list of TURN servers configured for the transport.
	TURNServers() []webrtc.ICEServer
	// SendDescription sends an SDP description to the remote peer.
	SendDescription(ctx context.Context, desc webrtc.SessionDescription) error
	// SendCandidate sends an ICE candidate to the remote peer.
	SendCandidate(ctx context.Context, candidate webrtc.ICECandidateInit) error
	// Candidates returns a channel of ICE candidates received from the remote peer.
	Candidates() <-chan webrtc.ICECandidateInit
	// RemoteDescription returns the SDP description received from the remote peer.
	RemoteDescription() webrtc.SessionDescription
	// Error returns a channel that receives any error encountered during signaling.
	// This channel will be closed when the transport is closed.
	Error() <-chan error
	// Close closes the transport.
	Close() error
}