natsproxy

Documentation

Index

• Constants
• Variables
• type Conn
  • func (c *Conn) Close() error
  • func (c *Conn) LocalAddr() net.Addr
  • func (c *Conn) Read(b []byte) (int, error)
  • func (c *Conn) RemoteAddr() net.Addr
  • func (c *Conn) SetDeadline(t time.Time) error
  • func (c *Conn) SetReadDeadline(t time.Time) error
  • func (c *Conn) SetWriteDeadline(t time.Time) error
  • func (c *Conn) Start() error
  • func (c *Conn) Write(b []byte) (int, error)

Constants

const (
	HeaderFin = "Hz-Connection-Fin"
)

Variables

var (
	StatusOK    []byte = []uint8{0}
	StatusError []byte = []uint8{1}
)

Types

type Conn

type Conn struct {
	Conn    *nats.Conn
	Subject string
	// contains filtered or unexported fields
}

func (*Conn) Close

func (c *Conn) Close() error

Close implements net.Conn.

func (*Conn) LocalAddr

func (c *Conn) LocalAddr() net.Addr

LocalAddr implements net.Conn.

func (*Conn) Read

func (c *Conn) Read(b []byte) (int, error)

Read implements net.Conn.

func (*Conn) RemoteAddr

func (c *Conn) RemoteAddr() net.Addr

RemoteAddr implements net.Conn.

func (*Conn) SetDeadline

func (c *Conn) SetDeadline(t time.Time) error

SetDeadline implements net.Conn.

func (*Conn) SetReadDeadline

func (c *Conn) SetReadDeadline(t time.Time) error

SetReadDeadline implements net.Conn.

func (*Conn) SetWriteDeadline

func (c *Conn) SetWriteDeadline(t time.Time) error

SetWriteDeadline implements net.Conn.

func (*Conn) Start

func (c *Conn) Start() error

func (*Conn) Write

func (c *Conn) Write(b []byte) (int, error)

Write implements net.Conn.