transport

Aug 16, 2021

Changes in this version

+ var DefaultClientTimeout = 10 * time.Second

+ var DefaultDecoder = codec.PlainDecoder

+ var DefaultDialTimeout = policy.ConstantTimeout(time.Second)

+ var DefaultEncoder = codec.PlainEncoder

+ var DefaultExpiryTimeout = time.Minute

+ var DefaultHost = "localhost"

+ var DefaultPort = uint16(3333)

+ var DefaultServerTimeout = 10 * time.Second

type Options

+ ClientTimeout time.Duration

+ Decoder codec.Decoder

+ DialTimeout policy.Timeout

+ Encoder codec.Encoder

+ ExpiryDuration time.Duration

+ Host string

+ OncePoolOptions handshake.OncePoolOptions

+ Port uint16

+ ServerTimeout time.Duration

+ func (opts Options) WithClientTimeout(timeout time.Duration) Options

+ func (opts Options) WithExpiry(minimumDuration time.Duration) Options

+ func (opts Options) WithHost(host string) Options

+ func (opts Options) WithOncePoolOptions(oncePoolOpts handshake.OncePoolOptions) Options

+ func (opts Options) WithPort(port uint16) Options

+ func (opts Options) WithServerTimeout(timeout time.Duration) Options

type Transport

+ func (t *Transport) Host() string

+ func (t *Transport) IsConnected(remote id.Signatory) bool

+ func (t *Transport) IsLinked(remote id.Signatory) bool

+ func (t *Transport) Link(remote id.Signatory)

+ func (t *Transport) Port() uint16

+ func (t *Transport) Receive(ctx context.Context, receiver func(id.Signatory, wire.Packet) error)

+ func (t *Transport) Self() id.Signatory

+ func (t *Transport) Table() dht.Table

+ func (t *Transport) Unlink(remote id.Signatory)

May 15, 2020

Changes in this version

+ type Options struct

+ Logger logrus.FieldLogger

+ TCPClientOpts tcp.ClientOptions

+ TCPServerOpts tcp.ServerOptions

+ func DefaultOptions() Options

+ func (opts Options) WithLogger(logger logrus.FieldLogger) Options

+ func (opts Options) WithTCPClientOptions(clientOpts tcp.ClientOptions) Options

+ func (opts Options) WithTCPServerOptions(serverOpts tcp.ServerOptions) Options

+ type TCPOptions struct

+ type Transport struct

+ func New(opts Options, handshaker handshake.Handshaker) *Transport

+ func (trans *Transport) DidReceivePing(version uint8, data []byte, from id.Signatory) (wire.Message, error)

+ func (trans *Transport) DidReceivePingAck(version uint8, data []byte, from id.Signatory) error

+ func (trans *Transport) DidReceivePull(version uint8, data []byte, from id.Signatory) (wire.Message, error)

+ func (trans *Transport) DidReceivePullAck(version uint8, data []byte, from id.Signatory) error

+ func (trans *Transport) DidReceivePush(version uint8, data []byte, from id.Signatory) (wire.Message, error)

+ func (trans *Transport) DidReceivePushAck(version uint8, data []byte, from id.Signatory) error

+ func (trans *Transport) Run(ctx context.Context)

+ func (trans *Transport) Send(ctx context.Context, addr wire.Address, msg wire.Message) error

+ func (trans *Transport) SetPingListener(listener wire.PingListener)

+ func (trans *Transport) SetPullListener(listener wire.PullListener)

+ func (trans *Transport) SetPushListener(listener wire.PushListener)

+ type WSOptions struct