xtransport

Mar 25, 2022

Changes in this version

+ func Write(w io.Writer, v interface{}) (n int, err error)

+ func WriteBytes(w io.Writer, data []byte) (n int, err error)

+ func WriteString(w io.Writer, data string) (n int, err error)

Mar 13, 2022

Changes in this version

+ type Client interface

type Transport

+ Dial func(addr string, opts ...DialOption) (Client[T], error)

Mar 13, 2022

Changes in this version

+ type DialOption func(*DialOptions)

+ func WithStream() DialOption

+ func WithTimeout(d time.Duration) DialOption

+ type DialOptions struct

+ Context context.Context

+ Stream bool

+ Timeout time.Duration

+ type ListenOption func(*ListenOptions)

+ type ListenOptions struct

+ Context context.Context

+ type Listener interface

+ Accept func(func(Socket[T])) error

+ Addr func() string

+ Close func() error

type Option

+ func Addrs(addrs ...string) Option

+ func TLSConfig(t *tls.Config) Option

type Options

+ Addrs []string

+ TLSConfig *tls.Config

+ type Packet interface

+ Write func(io.Writer) error

type Socket

+ ConnectionState func() *tls.ConnectionState

Mar 12, 2022

Changes in this version

+ type Context struct

+ func (c *Context) Get(key string) (value interface{}, exists bool)

+ func (c *Context) GetBool(key string) (b bool)

+ func (c *Context) GetDuration(key string) (d time.Duration)

+ func (c *Context) GetFloat64(key string) (f64 float64)

+ func (c *Context) GetInt(key string) (i int)

+ func (c *Context) GetInt64(key string) (i64 int64)

+ func (c *Context) GetString(key string) (s string)

+ func (c *Context) GetStringMap(key string) (sm map[string]interface{})

+ func (c *Context) GetStringMapString(key string) (sms map[string]string)

+ func (c *Context) GetStringMapStringSlice(key string) (smss map[string][]string)

+ func (c *Context) GetStringSlice(key string) (ss []string)

+ func (c *Context) GetTime(key string) (t time.Time)

+ func (c *Context) GetUint(key string) (ui uint)

+ func (c *Context) GetUint64(key string) (ui64 uint64)

+ func (c *Context) MustGet(key string) interface{}

+ func (c *Context) Session() *Context

+ func (c *Context) Set(key string, value interface{})

Mar 12, 2022

Changes in this version

+ func NewSession() *session

Mar 12, 2022

Changes in this version

+ type Writer interface

+ Write func(io.Writer) error

Mar 10, 2022

Changes in this version

+ type Option func(*Options)

+ func Port(i uint16) Option

+ func Secure(b bool) Option

+ func Timeout(t time.Duration) Option

+ func TlsConfig(tls *tls.Config) Option

+ type Options struct

+ Context context.Context

+ Port uint16

+ Secure bool

+ Timeout time.Duration

+ TlsConfig *tls.Config

+ type Socket interface

+ Close func() error

+ ConnectState func() *tls.ConnectionState

+ Local func() string

+ Recv func() (packets.ControlPacket, error)

+ Remote func() string

+ Send func(packets.ControlPacket) error

+ Session func() *session

+ SetTimeOut func(time.Duration)

+ type Transport interface

+ Accept func(fn func(sock Socket)) error

+ Listen func() error

+ Options func() Options

+ String func() string

+ func NewTcpTransport(opts ...Option) Transport