raftmod

README

raftmod

Raft Service Module

Documentation

Index

• Variables
• func LocalIP() (net.IP, error)
• func NewEncryptedSnapshotStore(store raft.SnapshotStore, token string) (raft.SnapshotStore, error)
• func RaftClientPool() raftapi.RaftClientPool
• func RaftLogStoreFactory() glue.FactoryBean
• func RaftServer() raftapi.RaftServer
• func RaftSnapshotFactory() glue.FactoryBean
• func RaftStableStoreFactory() glue.FactoryBean
• func StreamDecrypter(sessionKey []byte, source io.ReadCloser) (io.ReadCloser, error)
• func StreamEncrypter(sessionKey []byte, sink raft.SnapshotSink) (raft.SnapshotSink, error)
• type EmptyAddr
  • func (t EmptyAddr) Network() string
  • func (t EmptyAddr) String() string
• type TCPStreamLayer
  • func (t *TCPStreamLayer) Accept() (c net.Conn, err error)
  • func (t *TCPStreamLayer) Addr() net.Addr
  • func (t *TCPStreamLayer) Close() (err error)
  • func (t *TCPStreamLayer) Dial(address raft.ServerAddress, timeout time.Duration) (net.Conn, error)

Variables

var LogStoreClass = reflect.TypeOf((*raft.LogStore)(nil)).Elem()

var Scan = []interface{}{
	RaftLogStoreFactory(),
	RaftStableStoreFactory(),
	RaftSnapshotFactory(),
	RaftServer(),
	RaftClientPool(),
}

var SnapshotStoreClass = reflect.TypeOf((*raft.SnapshotStore)(nil)).Elem()

var StableStoreClass = reflect.TypeOf((*raft.StableStore)(nil)).Elem()

Functions

func LocalIP

func LocalIP() (net.IP, error)

LocalIP get the host machine local IP address

func NewEncryptedSnapshotStore

func NewEncryptedSnapshotStore(store raft.SnapshotStore, token string) (raft.SnapshotStore, error)

func RaftClientPool

func RaftClientPool() raftapi.RaftClientPool

func RaftLogStoreFactory

func RaftLogStoreFactory() glue.FactoryBean

func RaftServer

func RaftServer() raftapi.RaftServer

func RaftSnapshotFactory

func RaftSnapshotFactory() glue.FactoryBean

func RaftStableStoreFactory

func RaftStableStoreFactory() glue.FactoryBean

func StreamDecrypter

func StreamDecrypter(sessionKey []byte, source io.ReadCloser) (io.ReadCloser, error)

func StreamEncrypter

func StreamEncrypter(sessionKey []byte, sink raft.SnapshotSink) (raft.SnapshotSink, error)

Types

type EmptyAddr

type EmptyAddr struct {
}

func (EmptyAddr) Network

func (t EmptyAddr) Network() string

func (EmptyAddr) String

func (t EmptyAddr) String() string

type TCPStreamLayer

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

TCPStreamLayer implements StreamLayer interface for plain TCP.

func (*TCPStreamLayer) Accept

func (t *TCPStreamLayer) Accept() (c net.Conn, err error)

Accept implements the net.Listener interface.

func (*TCPStreamLayer) Addr

func (t *TCPStreamLayer) Addr() net.Addr

Addr implements the net.Listener interface.

func (*TCPStreamLayer) Close

func (t *TCPStreamLayer) Close() (err error)

Close implements the net.Listener interface.

func (*TCPStreamLayer) Dial

func (t *TCPStreamLayer) Dial(address raft.ServerAddress, timeout time.Duration) (net.Conn, error)

Dial implements the StreamLayer interface.