transportwrapper

package
v0.0.0-...-90a1d44 Latest Latest
Warning

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

Go to latest
Published: Aug 15, 2019 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type TransportWrapper

type TransportWrapper interface {
	NormalTransport() net.Listener
	ForwardToRaft(net.Conn, error)
	ForwardToRpc(net.Conn, error)
	RaftTransport() transport.Transport
	RpcTransport() transport.Transport
	Port() int
	Addr() net.Addr
	Close()
	SetNodeID(id raft.ServerID)
}

func NewTransportWrapper

func NewTransportWrapper(addr string) (TransportWrapper, error)

func NewTransportWrapperEx

func NewTransportWrapperEx(listener transport.Transport) TransportWrapper

func NewTransportWrapperFromListener

func NewTransportWrapperFromListener(listener net.Listener) TransportWrapper

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL