comm

type BufferedTransport struct{}

type Client interface {
	CallRPCTo(
		target ps.MultiAddr, request ev.Event) (response ev.Event, err error)
	io.Closer
}

type Connection interface {
	Open() error
	io.Closer

	PeerAddr() ps.MultiAddr
	CallRPC(request ev.Event) (response ev.Event, err error)
}

type Decoder interface {
	Decode(e interface{}) error
}

type Encoder interface {
	Encode(e interface{}) error
}

type EventHandler func(ev.Event)

type FileTransport struct{}

type FramedTransport struct{}

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

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

type MemoryConnection struct {
	*MemoryTransport
	// contains filtered or unexported fields
}

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

type MemoryServerTransport struct {
	ConsumeCh  chan *TransportChunk
	ResponseCh chan []byte
	// contains filtered or unexported fields
}

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

type MemoryTransportRegister struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

type RPCAppendEntriesRequest ev.AppendEntriesRequest

type RPCAppendEntriesResponse struct {
	Response *ev.AppendEntriesResponse
}

type RPCAuth struct {
	User     string
	Password string
}

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

type RPCClientAppendRequest ev.ClientAppendRequest

type RPCClientChangeConfigRequest ev.ClientChangeConfigRequest

type RPCClientGetConfigRequest ev.ClientGetConfigRequest

type RPCClientReadOnlyRequest ev.ClientReadOnlyRequest

type RPCClientResponse struct {
	Result RPCResultType
	Data   []byte
	Conf   *ps.Config
	Leader *ps.ServerAddress
	Error  string
}

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

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

type RPCInstallSnapshotRequest ev.InstallSnapshotRequest

type RPCInstallSnapshotResponse struct {
	Response *ev.InstallSnapshotResponse
}

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

type RPCRequestVoteRequest ev.RequestVoteRequest

type RPCRequestVoteResponse struct {
	Response *ev.RequestVoteResponse
}

type RPCResultType int

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

type RequestEventHandler func(ev.RequestEvent)

type Server interface {
	Serve()
	io.Closer
}

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

type SocketConnection struct {
	*SocketTransport
	// contains filtered or unexported fields
}

type SocketNetworkLayer struct {
	*SocketClient
	*SocketServer
}

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

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

type TcpKeepAliveListener struct {
	*net.TCPListener
}

type Transport interface {
	Open() error
	io.Closer

	io.Reader
	io.Writer
}

type TransportChunk struct {
	Data     []byte
	SourceCh chan []byte
}