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
- type TCPStreamLayer
Constants ¶
This section is empty.
Variables ¶
View Source
var Scan = []interface{}{ RaftLogStoreFactory(), RaftStableStoreFactory(), RaftSnapshotFactory(), RaftServer(), RaftClientPool(), }
View Source
var SnapshotStoreClass = reflect.TypeOf((*raft.SnapshotStore)(nil)).Elem()
View Source
var StableStoreClass = reflect.TypeOf((*raft.StableStore)(nil)).Elem()
Functions ¶
func NewEncryptedSnapshotStore ¶ added in v1.0.3
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 ¶ added in v1.0.3
func StreamDecrypter(sessionKey []byte, source io.ReadCloser) (io.ReadCloser, error)
func StreamEncrypter ¶ added in v1.0.3
func StreamEncrypter(sessionKey []byte, sink raft.SnapshotSink) (raft.SnapshotSink, error)
Types ¶
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.
Click to show internal directories.
Click to hide internal directories.