session

Documentation

Index

• type Session
  • func NewSession(log logr.Logger, host *common.HostPortPB, dialer dial.Dialer, ...) (*Session, error)
  • func (s *Session) Close() error
  • func (s *Session) Connect(host *common.HostPortPB) error
  • func (s *Session) GenerateCallID() int32
  • func (s *Session) Lock()
  • func (s *Session) Read(b []byte) (int, error)
  • func (s *Session) Unlock()
  • func (s *Session) Write(bytes []byte) (int, error)

Types

type Session

type Session struct {
	Host   *common.HostPortPB
	Log    logr.Logger
	Dialer dial.Dialer
	Ping   func(*Session) error
	// contains filtered or unexported fields
}

func NewSession

func NewSession(log logr.Logger, host *common.HostPortPB, dialer dial.Dialer, ping func(*Session) error) (*Session, error)

func (*Session) Close

func (s *Session) Close() error

func (*Session) Connect

func (s *Session) Connect(host *common.HostPortPB) error

func (*Session) GenerateCallID

func (s *Session) GenerateCallID() int32

func (*Session) Lock

func (s *Session) Lock()

func (*Session) Read

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

func (*Session) Unlock

func (s *Session) Unlock()

func (*Session) Write

func (s *Session) Write(bytes []byte) (int, error)