transport

Documentation

Index

• type ContainerResolver
• type MessageHandler
• type Option
  • func WithErrorHandler(value func(*bhraftpb.RaftMessage, error)) Option
  • func WithMaxBodyBytes(value int) Option
  • func WithSendBatch(value int64) Option
  • func WithTimeout(read, write time.Duration) Option
  • func WithWorkerCount(raft, snap uint64) Option
• type Transport
  • func NewDefaultTransport(storeID uint64, addr string, snapMgr snapshot.SnapshotManager, ...) Transport

Types

type ContainerResolver

type ContainerResolver func(id uint64) (metadata.Container, error)

ContainerResolver container resolver func

type MessageHandler

type MessageHandler func(msg interface{})

MessageHandler message handler

type Option

type Option func(*options)

Option transport option

func WithErrorHandler

func WithErrorHandler(value func(*bhraftpb.RaftMessage, error)) Option

WithErrorHandler set error handler

func WithMaxBodyBytes

func WithMaxBodyBytes(value int) Option

WithMaxBodyBytes set max body bytes for decode message

func WithSendBatch

func WithSendBatch(value int64) Option

WithSendBatch set batch size for sending messages

func WithTimeout

func WithTimeout(read, write time.Duration) Option

WithTimeout set read and write timeout for rpc

func WithWorkerCount

func WithWorkerCount(raft, snap uint64) Option

WithWorkerCount set worker count for send raft messages

type Transport

type Transport interface {
	// Start start the transport, receiving and sending messages
	Start()
	// Stop stop the transport
	Stop()
	// Send send the raft message to other node
	Send(*bhraftpb.RaftMessage)
	// SendingSnapshotCount returns the count of sending snapshots
	SendingSnapshotCount() uint64
}

Transport raft transport

func NewDefaultTransport

func NewDefaultTransport(
	storeID uint64,
	addr string,
	snapMgr snapshot.SnapshotManager,
	handler MessageHandler,
	resolver ContainerResolver,
	opts ...Option) Transport

NewDefaultTransport create default transport