transport

Documentation

Index

• type Manager
  • func New(localAddress raft.ServerAddress, dialOptions []grpc.DialOption, ...) *Manager
  • func (m *Manager) Close() error
  • func (m *Manager) Service() *service
  • func (m *Manager) Transport() raft.Transport
• type Option
  • func WithHeartbeatTimeout(d time.Duration) Option

Types

type Manager

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

func New

func New(localAddress raft.ServerAddress, dialOptions []grpc.DialOption, options ...Option) *Manager

func (*Manager) Close

func (m *Manager) Close() error

func (*Manager) Service

func (m *Manager) Service() *service

func (*Manager) Transport

func (m *Manager) Transport() raft.Transport

type Option

type Option func(m *Manager)

func WithHeartbeatTimeout

func WithHeartbeatTimeout(d time.Duration) Option

WithHeartbeatTimeout configures the transport to not wait for than d for heartbeat to be executes by remote peer.