transport

package

v0.9.0 Latest Latest Go to latest Published: Sep 7, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Details

This section is empty.

View Source

var ErrNotReachable = errors.New("raft node unreachable")

View Source

var ErrPeerClosed = errors.New("peer closed")

func NewServer(dmx Demultiplexer) raftpb.RaftServerServer

type Demultiplexer interface {
	Receive(ctx context.Context, msg *raftpb.Message, endpoint string) error
}

type Host interface {
	Sender
	Demultiplexer

	Stop()
	Register(node uint64, r Receiver)
}

func NewHost(resolver Resolver, callback string) Host

type Multiplexer interface {
	Send(ctx context.Context, msg *raftpb.Message, cb SendCallback)
}

type Receiver interface {
	Receive(ctx context.Context, msg *raftpb.Message, from uint64, endpoint string)
}

type Resolver interface {
	Resolve(node uint64) string
}

type SendCallback func(error)

type Sender interface {
	Send(ctx context.Context, msg *raftpb.Message, to uint64, endpoint string, cb SendCallback)
}

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

func NewSimpleResolver() *SimpleResolver

func (r *SimpleResolver) Register(node uint64, endpoint string)

func (r *SimpleResolver) Resolve(node uint64) string

func (r *SimpleResolver) Unregister(node uint64)