tcp

Documentation

Index

• Constants
• Variables
• func GetErrorCode(err error) (code int)
• func GetErrorMessage(code int) (err error)
• type AckMessage
  • func (am *AckMessage) Decode(p []byte) (n int, err error)
  • func (spm *AckMessage) Encode(p []byte) (n int, err error)
• type ErrorHandler
• type ErrorMessage
  • func (em *ErrorMessage) Decode(p []byte) (n int, err error)
  • func (em *ErrorMessage) Encode(p []byte) (n int, err error)
• type HeartbeatMessage
  • func (hm *HeartbeatMessage) Decode(p []byte) (n int, err error)
  • func (hm *HeartbeatMessage) Encode(p []byte) (n int, err error)
• type Message
  • func (m *Message) Decode(p []byte) (n int, err error)
  • func (m *Message) Encode(p []byte) (n int, err error)
• type MessageReader
  • func NewMessageReader(r io.Reader, bufferSize int, flag recio.IOMode) (mr *MessageReader)
  • func (mr *MessageReader) Fill() (err error)
  • func (mr *MessageReader) ReadMessage(m *Message) (n int, err error)
• type MessageWriter
  • func NewMessageWriter(w io.Writer, bufferSize int, flag recio.IOMode) (mw *MessageWriter)
  • func (mw *MessageWriter) Flush() (err error)
  • func (mw *MessageWriter) WriteMessage(m *Message) (n int, err error)
• type RecordMessage
  • func (rm *RecordMessage) Decode(p []byte) (n int, err error)
  • func (rm *RecordMessage) Encode(p []byte) (n int, err error)
• type TCPPeer
  • func NewTCPPeer(conn *net.TCPConn, writeBufferSize int, readBufferSize int, localTimeout int, ...) (tp *TCPPeer)
  • func (tp *TCPPeer) Close() (err error)
  • func (tp *TCPPeer) Fill() (err error)
  • func (tp *TCPPeer) Flush() (err error)
  • func (tp *TCPPeer) HandleError(h ErrorHandler)
  • func (tp *TCPPeer) ReadMessage(m *Message) (n int, err error)
  • func (tp *TCPPeer) WriteMessage(m *Message) (n int, err error)
• type TCPReader
  • func NewTCPReader(conn *net.TCPConn, writeBufferSize int, readBufferSize int, localTimeout int, ...) (tr *TCPReader)
  • func (tr *TCPReader) Close() (err error)
  • func (tr *TCPReader) Fill() (err error)
  • func (tr *TCPReader) Flush() (err error)
  • func (tr *TCPReader) HandleError(h ErrorHandler)
  • func (tr *TCPReader) Read(r *log.Record) (n int, err error)
  • func (tr *TCPReader) WriteAck(progress *log.SyncProgress) (n int, err error)
  • func (tr *TCPReader) WriteError(er error) (n int, err error)
• type TCPWriter
  • func NewTCPWriter(conn *net.TCPConn, writeBufferSize int, readBufferSize int, localTimeout int, ...) (tw *TCPWriter)
  • func (tw *TCPWriter) Close() (err error)
  • func (tw *TCPWriter) Flush() (err error)
  • func (tw *TCPWriter) HandleError(h ErrorHandler)
  • func (tw *TCPWriter) HandleSync(h log.SyncHandler)
  • func (tw *TCPWriter) Write(r *log.Record) (n int, err error)
  • func (tw *TCPWriter) WriteError(er error) (n int, err error)

Constants

const (
	TypeRecordMessage = iota + 1
	TypeAckMessage
	TypeHeartbeatMessage
	TypeErrorMessage
)

Variables

var (
	ErrUnkownMessageType     = errors.New("tcp: unknown message type")
	ErrUnexpectedMessageType = errors.New("tcp: unexpected message type")
)

var (
	ErrClosed = errors.New("peer: closed")
)

var (
	ErrUnknownError = errors.New("tcp: unknown error")
)

Functions

func GetErrorCode

func GetErrorCode(err error) (code int)

func GetErrorMessage

func GetErrorMessage(code int) (err error)

Types

type AckMessage

type AckMessage struct {
	Position int64
	Count    int64
}

func (*AckMessage) Decode

func (am *AckMessage) Decode(p []byte) (n int, err error)

func (*AckMessage) Encode

func (spm *AckMessage) Encode(p []byte) (n int, err error)

type ErrorHandler

type ErrorHandler func(err error)

type ErrorMessage

type ErrorMessage struct {
	Code int
}

func (*ErrorMessage) Decode

func (em *ErrorMessage) Decode(p []byte) (n int, err error)

func (*ErrorMessage) Encode

func (em *ErrorMessage) Encode(p []byte) (n int, err error)

type HeartbeatMessage

type HeartbeatMessage struct {
}

func (*HeartbeatMessage) Decode

func (hm *HeartbeatMessage) Decode(p []byte) (n int, err error)

func (*HeartbeatMessage) Encode

func (hm *HeartbeatMessage) Encode(p []byte) (n int, err error)

type Message

type Message struct {
	Type    int
	Payload recio.EncodeDecoder
	// contains filtered or unexported fields
}

func (*Message) Decode

func (m *Message) Decode(p []byte) (n int, err error)

func (*Message) Encode

func (m *Message) Encode(p []byte) (n int, err error)

type MessageReader

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

func NewMessageReader

func NewMessageReader(r io.Reader, bufferSize int, flag recio.IOMode) (mr *MessageReader)

func (*MessageReader) Fill

func (mr *MessageReader) Fill() (err error)

func (*MessageReader) ReadMessage

func (mr *MessageReader) ReadMessage(m *Message) (n int, err error)

type MessageWriter

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

func NewMessageWriter

func NewMessageWriter(w io.Writer, bufferSize int, flag recio.IOMode) (mw *MessageWriter)

func (*MessageWriter) Flush

func (mw *MessageWriter) Flush() (err error)

func (*MessageWriter) WriteMessage

func (mw *MessageWriter) WriteMessage(m *Message) (n int, err error)

type RecordMessage

type RecordMessage struct {
	Record log.Record
}

func (*RecordMessage) Decode

func (rm *RecordMessage) Decode(p []byte) (n int, err error)

func (*RecordMessage) Encode

func (rm *RecordMessage) Encode(p []byte) (n int, err error)

type TCPPeer

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

func NewTCPPeer

func NewTCPPeer(conn *net.TCPConn, writeBufferSize int, readBufferSize int, localTimeout int, remoteTimeout int, ioMode recio.IOMode) (tp *TCPPeer)

func (*TCPPeer) Close

func (tp *TCPPeer) Close() (err error)

func (*TCPPeer) Fill

func (tp *TCPPeer) Fill() (err error)

func (*TCPPeer) Flush

func (tp *TCPPeer) Flush() (err error)

func (*TCPPeer) HandleError

func (tp *TCPPeer) HandleError(h ErrorHandler)

func (*TCPPeer) ReadMessage

func (tp *TCPPeer) ReadMessage(m *Message) (n int, err error)

func (*TCPPeer) WriteMessage

func (tp *TCPPeer) WriteMessage(m *Message) (n int, err error)

type TCPReader

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

func NewTCPReader

func NewTCPReader(conn *net.TCPConn, writeBufferSize int, readBufferSize int, localTimeout int, remoteTimeout int, ioMode recio.IOMode) (tr *TCPReader)

func (*TCPReader) Close

func (tr *TCPReader) Close() (err error)

func (*TCPReader) Fill

func (tr *TCPReader) Fill() (err error)

func (*TCPReader) Flush

func (tr *TCPReader) Flush() (err error)

func (*TCPReader) HandleError

func (tr *TCPReader) HandleError(h ErrorHandler)

func (*TCPReader) Read

func (tr *TCPReader) Read(r *log.Record) (n int, err error)

func (*TCPReader) WriteAck

func (tr *TCPReader) WriteAck(progress *log.SyncProgress) (n int, err error)

func (*TCPReader) WriteError

func (tr *TCPReader) WriteError(er error) (n int, err error)

type TCPWriter

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

func NewTCPWriter

func NewTCPWriter(conn *net.TCPConn, writeBufferSize int, readBufferSize int, localTimeout int, remoteTimeout int, ioMode recio.IOMode) (tw *TCPWriter)

func (*TCPWriter) Close

func (tw *TCPWriter) Close() (err error)

func (*TCPWriter) Flush

func (tw *TCPWriter) Flush() (err error)

func (*TCPWriter) HandleError

func (tw *TCPWriter) HandleError(h ErrorHandler)

func (*TCPWriter) HandleSync

func (tw *TCPWriter) HandleSync(h log.SyncHandler)

func (*TCPWriter) Write

func (tw *TCPWriter) Write(r *log.Record) (n int, err error)

func (*TCPWriter) WriteError

func (tw *TCPWriter) WriteError(er error) (n int, err error)