tcp

package
v0.1.4 Latest Latest
Warning

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

 Go to latest Published: Mar 31, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TypeRecordMessage = iota + 1
	TypeAckMessage
	TypeHeartbeatMessage
	TypeErrorMessage
)

Variables

View Source 
var (
	ErrUnkownMessageType     = errors.New("tcp: unknown message type")
	ErrUnexpectedMessageType = errors.New("tcp: unexpected message type")
)
View Source 
var (
	ErrClosed = errors.New("peer: closed")
)
View Source 
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)

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.