Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

tcpless

package module

Go to main page

Versions in this module

v0

v0.1.2

Jun 21, 2023

v0.1.1

Feb 15, 2023

v0.1.0

Feb 15, 2023

Changes in this version

+ const ClientModeAsker

+ const ClientModeResponder

+ const DefaultSharedBufferSize

+ const MinimumSharedBufferSize

+ func ConcurrentClient(n int, bufferSize int, client ClientConstructor, config *Config, ...) (*concurrentClient, error)

+ func CreateBuffer(height, weight int) *buffer

+ func NewConnection(conn net.Conn, buf *bytes.Buffer, index uint16) *connection

+ type Client struct

+ func CreateClient(config *Config, sig ISignature, logger gocli.Logger) Client

+ func (c *Client) Ask(route string, v any) porterr.IError

+ func (c *Client) AskBytes(route string, b []byte) porterr.IError

+ func (c *Client) Ctx() context.Context

+ func (c *Client) Dial() (net.Conn, porterr.IError)

+ func (c *Client) Logger() gocli.Logger

+ func (c *Client) Parse(v any) porterr.IError

+ func (c *Client) Read() (ISignature, porterr.IError)

+ func (c *Client) SetStream(stream Streamer)

+ func (c *Client) Signature() ISignature

+ func (c *Client) Stream() Streamer

+ func (c *Client) WithContext(ctx context.Context)

+ type ClientConstructor func(config *Config, logger gocli.Logger) IClient

+ type Config struct

+ Address *net.TCPAddr

+ Limits ConnectionLimit

+ Mode uint8

+ TLS TLSConfig

+ type ConnectionLimit struct

+ MaxConnections uint16

+ MaxIdle time.Duration

+ RedialTimeout time.Duration

+ SharedBufferSize int32

+ type DataEncryptor interface

+ Decode func(v any) error

+ Encode func(v any) error

+ RegisterType func(v any)

+ func NewEmptyDataEncryptor(buf *bytes.Buffer) DataEncryptor

+ func NewGobDataEncryptor(buf *bytes.Buffer) DataEncryptor

+ func NewJSONDataEncryptor(buf *bytes.Buffer) DataEncryptor

+ type DataEncryptorConstructor func(buf *bytes.Buffer) DataEncryptor

+ type Decoder interface

+ Decode func(v any) error

+ func NewEmptyDecoder(r io.Reader) Decoder

+ type EmptyDataEncryptor struct

+ func (d *EmptyDataEncryptor) Decode(v any) error

+ func (d *EmptyDataEncryptor) Encode(v any) error

+ func (d *EmptyDataEncryptor) RegisterType(v any)

+ type EmptyDecoder struct

+ func (e *EmptyDecoder) Decode(v any) error

+ type EmptyEncoder struct

+ func (e *EmptyEncoder) Encode(v any) error

+ type Encoder interface

+ Encode func(v any) error

+ func NewEmptyEncoder(w io.Writer) Encoder

+ type GobClient struct

+ func (g *GobClient) Dial() (net.Conn, porterr.IError)

+ type GobDataEncryptor struct

+ func (d *GobDataEncryptor) Decode(v any) error

+ func (d *GobDataEncryptor) Encode(v any) error

+ func (d *GobDataEncryptor) RegisterType(v any)

+ type Handler func(client IClient)

+ func (h Handler) Reg(route string, handler Handler) Handler

+ func (h Handler) Route(route string) Route

+ func (h Handler) UnReg(route string) Handler

+ type IClient interface

+ Ask func(route string, v any) porterr.IError

+ AskBytes func(route string, b []byte) porterr.IError

+ Ctx func() context.Context

+ Dial func() (net.Conn, porterr.IError)

+ Logger func() gocli.Logger

+ Parse func(v any) porterr.IError

+ Read func() (ISignature, porterr.IError)

+ SetStream func(stream Streamer)

+ Signature func() ISignature

+ Stream func() Streamer

+ WithContext func(ctx context.Context)

+ func NewGobClient(config *Config, logger gocli.Logger) IClient

+ type ISignature interface

+ Data func() []byte

+ Decode func(r io.Reader, buf *bytes.Buffer) error

+ Encode func(buf *bytes.Buffer) []byte

+ Encryptor func() DataEncryptor

+ InitEncryptor func(buf *bytes.Buffer)

+ Len func() uint64

+ Read func(p []byte) (n int, err error)

+ Reset func()

+ Route func() string

+ Write func(p []byte) (n int, err error)

+ type JsonDataEncryptor struct

+ func (d *JsonDataEncryptor) Decode(v any) error

+ func (d *JsonDataEncryptor) Encode(v any) error

+ func (d *JsonDataEncryptor) RegisterType(v any)

+ type PermanentBuffer struct

+ func NewPermanentBuffer(data []byte) *PermanentBuffer

+ func (b *PermanentBuffer) Bytes() []byte

+ func (b *PermanentBuffer) Cap() int

+ func (b *PermanentBuffer) Next(n int) []byte

+ func (b *PermanentBuffer) Read(p []byte) (n int, err error)

+ func (b *PermanentBuffer) Reset()

+ func (b *PermanentBuffer) Seek(offset int64, whence int) (int64, error)

+ func (b *PermanentBuffer) Write(data []byte) (n int, err error)

+ type Route string

+ func (r Route) Handle(route string, handler Handler)

+ func (r Route) Hook(handler Handler) Route

+ func (r Route) Sub(route string) Route

+ type Server struct

+ func NewServer(config *Config, handler Handler, client ClientConstructor, logger gocli.Logger) *Server

+ func (s *Server) Start() error

+ func (s *Server) Stop()

+ type Signature struct

+ func CreateSignature(route []byte, data []byte, initEncryptor DataEncryptorConstructor) Signature

+ func (h *Signature) Data() []byte

+ func (h *Signature) Decode(r io.Reader, buf *bytes.Buffer) error

+ func (h *Signature) Encode(buf *bytes.Buffer) []byte

+ func (h *Signature) Encryptor() DataEncryptor

+ func (h *Signature) InitEncryptor(buf *bytes.Buffer)

+ func (h *Signature) Len() uint64

+ func (h *Signature) Read(p []byte) (n int, err error)

+ func (h *Signature) Reset()

+ func (h *Signature) Route() string

+ func (h *Signature) Write(p []byte) (n int, err error)

+ type Streamer interface

+ Buffer func() *bytes.Buffer

+ Connection func() net.Conn

+ Exit func() <-chan struct{}

+ Index func() uint16

+ Release func() error

+ type TLSConfig struct

+ CaPath string

+ CertPath string

+ Enabled bool

+ KeyPath string

+ func (c *TLSConfig) LoadTLSConfig() (*tls.Config, error)