election

Documentation

Index

• type TcpProxy
  • func NewTcpProxy(port int, to func() string) *TcpProxy
  • func (t *TcpProxy) Close() error
  • func (t *TcpProxy) Forward() error
  • func (t *TcpProxy) Reset() error
• type TimeoutConn
  • func (i TimeoutConn) Read(buf []byte) (int, error)
  • func (i TimeoutConn) Write(buf []byte) (int, error)
• type Watcher
  • func New(client *metadata.Client, port int, command []string) *Watcher
  • func NewSrcDstWatcher(client *metadata.Client, srcPort, dstPort int) *Watcher
  • func (w *Watcher) Forwarder() error
  • func (w *Watcher) GetSelfServiceLeader() (metadata.Container, bool, error)
  • func (w *Watcher) IsLeader() bool
  • func (w *Watcher) Watch() error

Types

type TcpProxy

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

func NewTcpProxy

func NewTcpProxy(port int, to func() string) *TcpProxy

func (*TcpProxy) Close

func (t *TcpProxy) Close() error

func (*TcpProxy) Forward

func (t *TcpProxy) Forward() error

func (*TcpProxy) Reset

func (t *TcpProxy) Reset() error

type TimeoutConn

type TimeoutConn struct {
	Conn    net.Conn
	Timeout time.Duration
}

func (TimeoutConn) Read

func (i TimeoutConn) Read(buf []byte) (int, error)

func (TimeoutConn) Write

func (i TimeoutConn) Write(buf []byte) (int, error)

type Watcher

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

func New

func New(client *metadata.Client, port int, command []string) *Watcher

func NewSrcDstWatcher

func NewSrcDstWatcher(client *metadata.Client, srcPort, dstPort int) *Watcher

func (*Watcher) Forwarder

func (w *Watcher) Forwarder() error

func (*Watcher) GetSelfServiceLeader

func (w *Watcher) GetSelfServiceLeader() (metadata.Container, bool, error)

func (*Watcher) IsLeader

func (w *Watcher) IsLeader() bool

func (*Watcher) Watch

func (w *Watcher) Watch() error