Versions in this module Expand all Collapse all v0 v0.4.0 Oct 8, 2023 Changes in this version + const GRPCAddrKey + func SplitFullMethodName(fullMethodName string) ([]string, error) + func ToFullMethodName(addr *rpc.Address) string + func Version() string + func WriteConfig(w io.Writer, cfg *Config) error + type Config struct + CoreMemory string + GRPCMappings []GRPCMapping + GRPCPort int + Group string + LinkClients []LinkClientConfig + LinkServers []LinkServerConfig + ServerCertificates []string + func ExampleConfig() (res *Config) + func LoadConfig(r io.Reader) (*Config, error) + func LoadConfigfromFile(name string) (*Config, error) + type GRPCClient struct + func NewGRPCClient(core *rpc.Core, mountPrefixLen int, target string, insecure bool) *GRPCClient + func (gc *GRPCClient) Close() + func (gc *GRPCClient) Handler() rpc.Handler + type GRPCMapping struct + Methods []string + Mount string + Target string + type GRPCServer struct + func NewGRPCServer(core *rpc.Core, port int) *GRPCServer + func (gs *GRPCServer) Serve() + func (gs *GRPCServer) Stop() + type Link struct + func NewLink(core *rpc.Core, linkt LinkTransport, logString string) (res *Link) + func (lr *Link) ReceiveAndDispatch() (err error) + func (lr *Link) String() string + type LinkClient struct + func NewLinkClient(conn *grpc.ClientConn, core *rpc.Core) (res *LinkClient) + func (lc *LinkClient) Close() + func (lc *LinkClient) Run() + func (lc *LinkClient) String() string + type LinkClientConfig struct + Insecure bool + Target string + type LinkServer struct + func NewLinkServer(listen net.Listener, core *rpc.Core) *LinkServer + func (ls *LinkServer) Link(call pb.LinkService_LinkServer) error + func (ls *LinkServer) Run() + func (ls *LinkServer) Stop() + type LinkServerConfig struct + Port int + type LinkTransport interface + Recv func() (*pb.LinkFrame, error) + Send func(*pb.LinkFrame) error + type Node struct + func NewNode(config *Config) (n *Node, err error) + func (n *Node) AddCloseable(c func()) + func (n *Node) Group() *rpc.Address + func (n *Node) ID() *rpc.Address + func (n *Node) Run() + func (n *Node) Stop()