streaming_transmit

package
v0.0.0-...-4db8000 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 29, 2020 License: MIT Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var DefaultClientSeqDelta uint32 = 2
View Source 
var DefaultClientSeqOffset uint32 = 1
View Source 
var DefaultDialTimeout = 3 * time.Second
View Source 
var DefaultHandshakeTimeout = 3 * time.Second
View Source 
var DefaultMaxClientConns = 4
View Source 
var DefaultMaxConnWaitTimeout = 3 * time.Second
View Source 
var DefaultMaxServerConns = 1024
View Source 
var DefaultNumDialAttempts = 1
View Source 
var DefaultReadBufferSize = 4096
View Source 
var DefaultReadTimeout = 3 * time.Second
View Source 
var DefaultSeqDelta uint32 = 2
View Source 
var DefaultSeqOffset uint32 = 1
View Source 
var DefaultServerSeqDelta uint32 = 2
View Source 
var DefaultServerSeqOffset uint32 = 2
View Source 
var DefaultTickerDuration = 1 * time.Second
View Source 
var DefaultWriteBufferSize = 4096
View Source 
var DefaultWriteTimeout = 3 * time.Second

Functions

func IsEOF 

func IsEOF(err error) bool

func JsonStringPoolMetrics 

func JsonStringPoolMetrics() string

func Read 

func Read(dst []byte, r io.Reader) ([]byte, error)

func ReadSized 

func ReadSized(dst []byte, r io.Reader, max int) ([]byte, error)

func ReleasePoolMetrics 

func ReleasePoolMetrics()

func StartPoolMetrics 

func StartPoolMetrics()

func Write 

func Write(w io.Writer, buf []byte) error

func WriteSized 

func WriteSized(w io.Writer, buf []byte) error

Types

type BufferedConn 

type BufferedConn interface {
	net.Conn
	Flush() error
}

type Client 

type Client struct {
	Addr string

	Handler   Handler
	ConnState ConnStateHandler

	Handshaker       Handshaker
	HandshakeTimeout time.Duration

	MaxConns        int
	NumDialAttempts int

	ReadBufferSize  int
	WriteBufferSize int

	DialTimeout  time.Duration
	ReadTimeout  time.Duration
	WriteTimeout time.Duration

	SeqOffset uint32
	SeqDelta  uint32
	// contains filtered or unexported fields
}

func (*Client) Get 

func (c *Client) Get() (*Conn, error)

func (*Client) NumOfPendingWrites 

func (c *Client) NumOfPendingWrites() int

func (*Client) Request 

func (c *Client) Request(dst, buf []byte) ([]byte, error)

func (*Client) Send 

func (c *Client) Send(buf []byte) error

func (*Client) SendNoWait 

func (c *Client) SendNoWait(buf []byte) error

func (*Client) Shutdown 

func (c *Client) Shutdown()

type Conn 

type Conn struct {
	Handler Handler

	ReadBufferSize  int
	WriteBufferSize int

	ReadTimeout  time.Duration
	WriteTimeout time.Duration

	SeqOffset uint32
	SeqDelta  uint32
	// contains filtered or unexported fields
}

func (*Conn) Handle 

func (c *Conn) Handle(done chan struct{}, conn BufferedConn) error

func (*Conn) NumOfPendingWrites 

func (c *Conn) NumOfPendingWrites() int

func (*Conn) Request 

func (c *Conn) Request(dst []byte, payload []byte) ([]byte, error)

func (*Conn) Send 

func (c *Conn) Send(payload []byte) error

func (*Conn) SendNoWait 

func (c *Conn) SendNoWait(payload []byte) error

type ConnState 

type ConnState int
const (
	StateNew ConnState = iota
	StateClosed
)

type ConnStateHandler 

type ConnStateHandler interface {
	HandleConnState(conn *Conn, state ConnState)
}

type ConnStateHandlerFunc 

type ConnStateHandlerFunc func(conn *Conn, state ConnState)
var DefaultConnStateHandler ConnStateHandlerFunc = func(conn *Conn, state ConnState) {}

func (ConnStateHandlerFunc) HandleConnState 

func (fn ConnStateHandlerFunc) HandleConnState(conn *Conn, state ConnState)

type Context 

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

func (*Context) Body 

func (c *Context) Body() []byte

func (*Context) Conn 

func (c *Context) Conn() *Conn

func (*Context) Reply 

func (c *Context) Reply(buf []byte) error

type ContextPool 

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

type Handler 

type Handler interface {
	HandleMessage(ctx *Context) error
}

type HandlerFunc 

type HandlerFunc func(ctx *Context) error
var DefaultHandler HandlerFunc = func(ctx *Context) error { return nil }

func (HandlerFunc) HandleMessage 

func (fn HandlerFunc) HandleMessage(ctx *Context) error

type Handshaker 

type Handshaker interface {
	Handshake(conn net.Conn) (BufferedConn, error)
}

type HandshakerFunc 

type HandshakerFunc func(conn net.Conn) (BufferedConn, error)
var DefaultClientHandshaker HandshakerFunc = func(conn net.Conn) (BufferedConn, error) {
	var session Session
	err := session.DoClient(conn)
	if err != nil {
		return nil, err
	}

	return NewSessionConn(session.Suite(), conn), nil
}
var DefaultServerHandshaker HandshakerFunc = func(conn net.Conn) (BufferedConn, error) {
	var session Session
	err := session.DoServer(conn)
	if err != nil {
		return nil, err
	}
	return NewSessionConn(session.Suite(), conn), nil
}

func (HandshakerFunc) Handshake 

func (fn HandshakerFunc) Handshake(conn net.Conn) (BufferedConn, error)

type PendingRequestPool 

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

type PendingWritePool 

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

type PoolMetrics 

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

na + nr equal the total number of acquires na + nr - np equal the number of still running.

type Server 

type Server struct {
	Handler   Handler
	ConnState ConnStateHandler

	Handshaker       Handshaker
	HandshakeTimeout time.Duration

	MaxConns           int
	MaxConnWaitTimeout time.Duration

	ReadBufferSize  int
	WriteBufferSize int

	ReadTimeout  time.Duration
	WriteTimeout time.Duration

	SeqOffset uint32
	SeqDelta  uint32
	// contains filtered or unexported fields
}

func (*Server) Serve 

func (s *Server) Serve(ln net.Listener) error

func (*Server) Shutdown 

func (s *Server) Shutdown()

type Session 

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

Session is not safe for concurrent use.

func (*Session) DoClient 

func (s *Session) DoClient(conn net.Conn) error

func (*Session) DoServer 

func (s *Session) DoServer(conn net.Conn) error

func (*Session) Establish 

func (s *Session) Establish(ourPriv []byte) error

func (*Session) GenerateEphemeralKeys 

func (s *Session) GenerateEphemeralKeys() ([]byte, []byte, error)

func (*Session) Read 

func (s *Session) Read(conn net.Conn) error

func (*Session) SharedKey 

func (s *Session) SharedKey() []byte

func (*Session) Suite 

func (s *Session) Suite() cipher.AEAD

func (*Session) Write 

func (s *Session) Write(conn net.Conn, ourPub []byte) error

type SessionConn 

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

SessionConn is not safe for concurrent use. It decrypts on reads and encrypts on writes via a provided cipher.AEAD suite for a given conn that implements net.Conn. It assumes all packets sent/received are to be prefixed with a 32-bit unsigned integer that designates the length of each individual packet.

The same cipher.AEAD suite must not be used for multiple SessionConn instances. Doing so will cause for plaintext data to be leaked.

func NewSessionConn 

func NewSessionConn(suite cipher.AEAD, conn net.Conn) *SessionConn

func (*SessionConn) Close 

func (s *SessionConn) Close() error

func (*SessionConn) Flush 

func (s *SessionConn) Flush() error

func (*SessionConn) LocalAddr 

func (s *SessionConn) LocalAddr() net.Addr

func (*SessionConn) Read 

func (s *SessionConn) Read(b []byte) (int, error)

func (*SessionConn) RemoteAddr 

func (s *SessionConn) RemoteAddr() net.Addr

func (*SessionConn) SetDeadline 

func (s *SessionConn) SetDeadline(t time.Time) error

func (*SessionConn) SetReadDeadline 

func (s *SessionConn) SetReadDeadline(t time.Time) error

func (*SessionConn) SetWriteDeadline 

func (s *SessionConn) SetWriteDeadline(t time.Time) error

func (*SessionConn) Write 

func (s *SessionConn) Write(b []byte) (int, error)

type TimerPool 

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.