transport

Documentation

Index

• func NewKCPTransport(bindAddr string, advertise net.Addr, maxPool int, timeout time.Duration, ...) (*raft.NetworkTransport, error)
• type KCPStreamLayer
  • func (ksl *KCPStreamLayer) Accept() (net.Conn, error)
  • func (ksl *KCPStreamLayer) Addr() net.Addr
  • func (ksl *KCPStreamLayer) Close() error
  • func (ksl *KCPStreamLayer) Dial(address raft.ServerAddress, timeout time.Duration) (net.Conn, error)

Functions

func NewKCPTransport

func NewKCPTransport(
	bindAddr string,
	advertise net.Addr,
	maxPool int,
	timeout time.Duration,
	logOutput io.Writer,
) (*raft.NetworkTransport, error)

Types

type KCPStreamLayer

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

func (*KCPStreamLayer) Accept

func (ksl *KCPStreamLayer) Accept() (net.Conn, error)

func (*KCPStreamLayer) Addr

func (ksl *KCPStreamLayer) Addr() net.Addr

func (*KCPStreamLayer) Close

func (ksl *KCPStreamLayer) Close() error

func (*KCPStreamLayer) Dial

func (ksl *KCPStreamLayer) Dial(address raft.ServerAddress, timeout time.Duration) (net.Conn, error)