session

Documentation

Index

• type Client
  • func NewClient(ctx context.Context, logger logger.Logger, dialOut util.DialOutFunc, ...) *Client
  • func (c *Client) Close() error
  • func (c *Client) CreateStream(ctx context.Context) (net.Conn, error)
• type Session
  • func NewClientSession(conn net.Conn, _padding *atomic.TypedValue[*padding.PaddingFactory], ...) *Session
  • func NewServerSession(conn net.Conn, onNewStream func(stream *Stream), ...) *Session
  • func (s *Session) Close() error
  • func (s *Session) IsClosed() bool
  • func (s *Session) OpenStream() (*Stream, error)
  • func (s *Session) Run()
• type Stream
  • func (s *Stream) Close() error
  • func (s *Stream) LocalAddr() net.Addr
  • func (s *Stream) Read(b []byte) (n int, err error)
  • func (s *Stream) RemoteAddr() net.Addr
  • func (s *Stream) SetDeadline(t time.Time) error
  • func (s *Stream) SetReadDeadline(t time.Time) error
  • func (s *Stream) SetWriteDeadline(t time.Time) error
  • func (s *Stream) Write(b []byte) (n int, err error)

Types

type Client

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

func NewClient

func NewClient(ctx context.Context, logger logger.Logger, dialOut util.DialOutFunc,
	_padding *atomic.TypedValue[*padding.PaddingFactory], idleSessionCheckInterval, idleSessionTimeout time.Duration, minIdleSession int,
) *Client

func (*Client) Close

func (c *Client) Close() error

func (*Client) CreateStream

func (c *Client) CreateStream(ctx context.Context) (net.Conn, error)

type Session

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

func NewClientSession

func NewClientSession(conn net.Conn, _padding *atomic.TypedValue[*padding.PaddingFactory], logger logger.Logger) *Session

func NewServerSession

func NewServerSession(conn net.Conn, onNewStream func(stream *Stream), _padding *atomic.TypedValue[*padding.PaddingFactory], logger logger.Logger) *Session

func (*Session) Close

func (s *Session) Close() error

Close is used to close the session and all streams.

func (*Session) IsClosed

func (s *Session) IsClosed() bool

IsClosed does a safe check to see if we have shutdown

func (*Session) OpenStream

func (s *Session) OpenStream() (*Stream, error)

OpenStream is used to create a new stream for CLIENT

func (*Session) Run

func (s *Session) Run()

type Stream

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

Stream implements net.Conn

func (*Stream) Close

func (s *Stream) Close() error

Close implements net.Conn

func (*Stream) LocalAddr

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

LocalAddr satisfies net.Conn interface

func (*Stream) Read

func (s *Stream) Read(b []byte) (n int, err error)

Read implements net.Conn

func (*Stream) RemoteAddr

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

RemoteAddr satisfies net.Conn interface

func (*Stream) SetDeadline

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

func (*Stream) SetReadDeadline

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

func (*Stream) SetWriteDeadline

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

func (*Stream) Write

func (s *Stream) Write(b []byte) (n int, err error)

Write implements net.Conn