dataconn

Documentation

Index

• Constants
• Variables
• type Client
  • func NewClient(conn net.Conn, engineToReplicaTimeout time.Duration) *Client
  • func (c *Client) Close()
  • func (c *Client) Ping() error
  • func (c *Client) ReadAt(buf []byte, offset int64) (int, error)
  • func (c *Client) SetError(err error)
  • func (c *Client) TargetID() string
  • func (c *Client) UnmapAt(length uint32, offset int64) (int, error)
  • func (c *Client) WriteAt(buf []byte, offset int64) (int, error)
• type Message
• type Server
  • func NewServer(conn net.Conn, data types.DataProcessor) *Server
  • func (s *Server) Handle() error
  • func (s *Server) Stop()
• type Wire
  • func NewWire(conn net.Conn) *Wire
  • func (w *Wire) Close() error
  • func (w *Wire) Read() (*Message, error)
  • func (w *Wire) Write(msg *Message) error

Constants

const (
	TypeRead = iota
	TypeWrite
	TypeResponse
	TypeError
	TypeEOF
	TypeClose
	TypePing
	TypeUnmap
)

const (
	MagicVersion = uint16(0x1b01) // LongHorn01
)

Variables

var (
	//ErrRWTimeout r/w operation timeout
	ErrRWTimeout = errors.New("r/w timeout")
)

Types

type Client

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

Client replica client

func NewClient

func NewClient(conn net.Conn, engineToReplicaTimeout time.Duration) *Client

NewClient replica client

func (*Client) Close

func (c *Client) Close()

Close replica client

func (*Client) Ping

func (c *Client) Ping() error

Ping replica client

func (*Client) ReadAt

func (c *Client) ReadAt(buf []byte, offset int64) (int, error)

ReadAt replica client

func (*Client) SetError

func (c *Client) SetError(err error)

SetError replica client transport error

func (*Client) TargetID

func (c *Client) TargetID() string

TargetID operation target ID

func (*Client) UnmapAt

func (c *Client) UnmapAt(length uint32, offset int64) (int, error)

UnmapAt replica client

func (*Client) WriteAt

func (c *Client) WriteAt(buf []byte, offset int64) (int, error)

WriteAt replica client

type Message

type Message struct {
	Complete chan struct{}

	MagicVersion uint16
	Seq          uint32
	Type         uint32
	Offset       int64
	Size         uint32
	Data         []byte

	ID journal.OpID //Seq and ID can apparently be collapsed into one (ID)
	// contains filtered or unexported fields
}

type Server

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

func NewServer

func NewServer(conn net.Conn, data types.DataProcessor) *Server

func (*Server) Handle

func (s *Server) Handle() error

func (*Server) Stop

func (s *Server) Stop()

type Wire

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

func NewWire

func NewWire(conn net.Conn) *Wire

func (*Wire) Close

func (w *Wire) Close() error

func (*Wire) Read

func (w *Wire) Read() (*Message, error)

func (*Wire) Write

func (w *Wire) Write(msg *Message) error