inmem_transport.go
func (i *InmemTransport) InstallSnapshot(id ServerID, target ServerAddress, args *InstallSnapshotRequest, resp *InstallSnapshotResponse, data io.Reader) error {
	rpcResp, err := i.makeRPC(target, args, data, 10*i.timeout)
	if err != nil {
		return err
	}

	// Copy the result back
	out := rpcResp.Response.(*InstallSnapshotResponse)
	*resp = *out
	return nil
}
func (i *InmemTransport) InstallSnapshot(id ServerID, target ServerAddress, args *InstallSnapshotRequest, resp *InstallSnapshotResponse, data io.Reader) error {
	rpcResp, err := i.makeRPC(target, args, data, 10*i.timeout)
	if err != nil {
		return err
	}

	// Copy the result back
	out := rpcResp.Response.(*InstallSnapshotResponse)
	*resp = *out
	return nil
}
func ( i * InmemTransport ) InstallSnapshot ( id ServerID , target ServerAddress , args * InstallSnapshotRequest , resp * InstallSnapshotResponse , data io . Reader ) error { rpcResp , err := i . makeRPC ( target , args , data , 10 * i . timeout ) if err != nil { return err } // Copy the result back out := rpcResp . Response . ( * InstallSnapshotResponse ) * resp = * out return nil }
// InstallSnapshot implements the Transport interface.
InstallSnapshot implements the Transport interface .