grpc

type Client struct {
	sync.Mutex
	Conf       *ClientConfig
	NewAgent   network.AgentCreateFunc
	CloseAgent network.AgentCloseFunc
	// contains filtered or unexported fields
}

type ClientConfig struct {
	Nodes            []common.NodeInfo `mapstructure:"nodes"`
	ConnNum          int               `mapstructure:"conn_num"`
	ConnectInterval  time.Duration     `mapstructure:"connect_interval"`
	SocketQueueSize  int               `mapstructure:"socket_queue_size"`
	MaxMessageSize   uint32            `mapstructure:"max_message_size"`
	HandshakeTimeout time.Duration     `mapstructure:"handshake_timeout"`
	AutoReconnect    bool              `mapstructure:"auto_reconnect"`
	QueueSize        int               `mapstructure:"queue_size"`
}

type Conn struct {
	sync.Mutex
	// contains filtered or unexported fields
}

type ConnSet map[IRPCStream]struct{}

type IRPCStream interface {
	Send(*ss.Message) error
	Recv() (*ss.Message, error)
	// Context returns the context for this stream.
	Context() context.Context
}

type Server struct {
	ss.UnimplementedRPCServer
	Conf       *ServerConfig
	NewAgent   network.AgentCreateFunc
	CloseAgent network.AgentCloseFunc
	// contains filtered or unexported fields
}

type ServerConfig struct {
	Address         string `mapstructure:"address"`
	MaxConnNum      int    `mapstructure:"max_conn_num"`
	SocketQueueSize int    `mapstructure:"socket_queue_size"`
	MaxMessageSize  uint32 `mapstructure:"max_message_size"`
	QueueSize       int    `mapstructure:"queue_size"`
}