tcp

Documentation

Index

• type PresentWriteProgress
• type Session
  • func NewSession(c net.Conn) *Session
  • func (s *Session) Ack() error
  • func (s *Session) Close()
  • func (s *Session) Fetch(msg *message.Message, data interface{}) (*message.Message, error)
  • func (s *Session) Read(p []byte) (n int, err error)
  • func (s *Session) ReadFile(filepath string, md5 string, size int64) (written int64, err error)
  • func (s *Session) ReadJson(size int, v interface{}) error
  • func (s *Session) ReadMessage() (*message.Message, error)
  • func (s *Session) Send(msg *message.Message, data interface{}) error
  • func (s *Session) SendFile(file_path string, ...) error
  • func (s *Session) SendMessage(msg *message.Message, payload io.Reader, payload_size int64) error
  • func (s *Session) String() string
  • func (s *Session) Write(p []byte) (n int, err error)

Types

type PresentWriteProgress

type PresentWriteProgress func(n int)

type Session

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

func NewSession

func NewSession(c net.Conn) *Session

func (*Session) Ack

func (s *Session) Ack() error

func (*Session) Close

func (s *Session) Close()

func (*Session) Fetch

func (s *Session) Fetch(msg *message.Message, data interface{}) (*message.Message, error)

func (*Session) Read

func (s *Session) Read(p []byte) (n int, err error)

func (*Session) ReadFile

func (s *Session) ReadFile(filepath string, md5 string, size int64) (written int64, err error)

func (*Session) ReadJson

func (s *Session) ReadJson(size int, v interface{}) error

func (*Session) ReadMessage

func (s *Session) ReadMessage() (*message.Message, error)

func (*Session) Send

func (s *Session) Send(msg *message.Message, data interface{}) error

func (*Session) SendFile

func (s *Session) SendFile(file_path string, pre_send func(filename string, md5 string, size int64) (offset int64, send bool)) error

func (*Session) SendMessage

func (s *Session) SendMessage(msg *message.Message, payload io.Reader, payload_size int64) error

func (*Session) String

func (s *Session) String() string

func (*Session) Write

func (s *Session) Write(p []byte) (n int, err error)