session

Aug 21, 2023

Changes in this version

+ const ActionGetPubAddr

+ var ErrClosed = errors.New("tuna session is closed")

+ var ErrNilConn = errors.New("conn is nil")

+ var ErrNoPubAddr = errors.New("no public address avalaible")

+ var ErrOnlyDailer = errors.New("this function only for dialer")

+ var ErrRemoteAddrRejected = errors.New("remote address is rejected")

+ var ErrWrongAddr = errors.New("wrong address")

+ var ErrWrongMsgFormat = errors.New("wrong message format")

+ func GetFreePort(port int) (int, error)

type Config

+ MaxUdpDatagramBuffered int

+ ReconnectInterval int

+ ReconnectRetries int

+ TunaMeasurementBytesDownLink int32

+ TunaMinBalance string

+ UDPRecvBufferSize int

+ Verbose bool

type PubAddr

+ func (pa *PubAddr) String() string

type PubAddrs

+ SessionClosed bool

type Request

+ SessionID []byte

type TunaSessionClient

+ func (c *TunaSessionClient) CloseOneConn(sess *ncp.Session, connId string)

+ func (c *TunaSessionClient) DialUDP(remoteAddr string) (*UdpSession, error)

+ func (c *TunaSessionClient) DialUDPWithConfig(remoteAddr string, config *nkn.DialConfig) (*UdpSession, error)

+ func (c *TunaSessionClient) IsSessClosed(sessKey string) bool

+ func (c *TunaSessionClient) ListenUDP() (*UdpSession, error)

+ func (c *TunaSessionClient) OnConnect() chan struct{}

+ func (c *TunaSessionClient) SetTunaNode(node *types.Node)

+ type UdpSession struct

+ func (us *UdpSession) Close() (err error)

+ func (us *UdpSession) CloseTcp(i int)

+ func (us *UdpSession) DialUpSession(listenerNknAddr string, sessionID []byte, config *nkn.DialConfig) (err error)

+ func (us *UdpSession) GetEstablishedUDPConn() (*tuna.EncryptUDPConn, error)

+ func (us *UdpSession) GetUDPConn() *tuna.EncryptUDPConn

+ func (us *UdpSession) IsClosed() bool

+ func (us *UdpSession) LocalAddr() net.Addr

+ func (us *UdpSession) Read(b []byte) (int, error)

+ func (us *UdpSession) ReadFrom(b []byte) (n int, addr net.Addr, err error)

+ func (us *UdpSession) RemoteAddr() net.Addr

+ func (us *UdpSession) SetDeadline(t time.Time) error

+ func (us *UdpSession) SetReadBuffer(size int) error

+ func (us *UdpSession) SetReadDeadline(t time.Time) error

+ func (us *UdpSession) SetWriteBuffer(size int) error

+ func (us *UdpSession) SetWriteDeadline(t time.Time) error

+ func (us *UdpSession) Write(b []byte) (int, error)

+ func (us *UdpSession) WriteTo(b []byte, addr net.Addr) (n int, err error)

Apr 24, 2022

Changes in this version

type Config

+ TunaMinNanoPayFee string

+ TunaNanoPayFeeRatio float64

Feb 24, 2022

Changes in this version

type Config

+ TunaMeasureBandwidth bool

+ TunaMeasureStoragePath string

+ TunaNknFilter *filter.NknFilter

type TunaSessionClient

+ func (c *TunaSessionClient) RotateAll() error

+ func (c *TunaSessionClient) RotateOne(i int) error

+ func (c *TunaSessionClient) SetConfig(conf *Config) error

Oct 17, 2020

Changes in this version

type Config

+ TunaDownloadGeoDB bool

+ TunaGeoDBPath string

Sep 17, 2020

Changes in this version

type PubAddr

+ InPrice string

+ OutPrice string

type TunaSessionClient

+ func (c *TunaSessionClient) GetPubAddrs() *PubAddrs

Aug 6, 2020

Changes in this version

+ type Conn struct

+ ReadLock sync.Mutex

+ WriteLock sync.Mutex

Jul 16, 2020

Changes in this version

+ const DefaultSessionAllowAddr

+ const SessionIDSize

+ func DefaultSessionConfig() *ncp.Config

+ type Config struct

+ NumTunaListeners int

+ SessionConfig *ncp.Config

+ TunaDialTimeout int

+ TunaIPFilter *tuna.IPFilter

+ TunaMaxPrice string

+ TunaNanoPayFee string

+ TunaServiceName string

+ TunaSubscriptionPrefix string

+ func DefaultConfig() *Config

+ func MergedConfig(conf *Config) (*Config, error)

+ type DialConfig struct

+ DialTimeout int32

+ SessionConfig *ncp.Config

+ func DefaultDialConfig(baseSessionConfig *ncp.Config) *DialConfig

+ func MergeDialConfig(baseSessionConfig *ncp.Config, conf *DialConfig) (*DialConfig, error)

+ type PubAddr struct

+ IP string

+ Port uint32

+ type PubAddrs struct

+ Addrs []PubAddr

+ type Request struct

+ Action string

+ type TunaSessionClient struct

+ func NewTunaSessionClient(clientAccount *nkn.Account, m *nkn.MultiClient, wallet *nkn.Wallet, ...) (*TunaSessionClient, error)

+ func (c *TunaSessionClient) Accept() (net.Conn, error)

+ func (c *TunaSessionClient) AcceptSession() (*ncp.Session, error)

+ func (c *TunaSessionClient) Addr() net.Addr

+ func (c *TunaSessionClient) Address() string

+ func (c *TunaSessionClient) Close() error

+ func (c *TunaSessionClient) Dial(remoteAddr string) (net.Conn, error)

+ func (c *TunaSessionClient) DialSession(remoteAddr string) (*ncp.Session, error)

+ func (c *TunaSessionClient) DialWithConfig(remoteAddr string, config *DialConfig) (*ncp.Session, error)

+ func (c *TunaSessionClient) IsClosed() bool

+ func (c *TunaSessionClient) Listen(addrsRe *nkn.StringArray) error