tcp

type MessageType int

type OnConnectionFunc func(address, host string, port int)

type OnMessageFunc func(fromAddrss string, msgType int, msgBytes *[]byte)

type OnUdpMessage func(nodeID, ip string, port int)

type State int

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

type TCPOptions struct {

	// Enable UDP discovery
	UdpDiscovery bool
	// Reusing UDP server socket
	UdpReuseAddr bool

	// UDP port
	UdpPort int
	// UDP bind address (if null, bind on all interfaces)
	UdpBindAddress string
	// UDP sending period (seconds)
	UdpPeriod time.Duration

	UdpMaxDiscovery int

	// Multicast address.
	UdpMulticast string
	// Multicast TTL setting
	UdpMulticastTTL int

	// Send broadcast (Boolean, String, Array<String>)
	UdpBroadcast      []string
	UdpBroadcastAddrs []string
	// TCP server port. 0 means random port
	Port int
	// Static remote nodes address list (when UDP discovery is not available)
	Urls []string
	// Use hostname as preffered connection address
	UseHostname bool

	// Gossip sending period in seconds
	GossipPeriod int
	// Maximum enabled outgoing connections. If reach, close the old connections
	MaxConnections int
	// Maximum TCP packet size
	MaxPacketSize int

	Prefix      string
	NodeId      string
	Namespace   string
	Logger      *log.Entry
	Serializer  serializer.Serializer
	ValidateMsg transit.ValidateMsgFunc
}

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

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

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

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

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

type UdpServerOptions struct {
	Port           int
	Multicast      string
	MulticastTTL   int
	BindAddress    string
	BroadcastAddrs []string
	DiscoverPeriod time.Duration
	MaxDiscovery   int
	Discovery      bool
	Namespace      string
	NodeID         string
}