raft_server

package
v0.0.0-...-d7efa00 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 24, 2021 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	TcpServerHalt = false
)

Functions

This section is empty.

Types

type Manager

type Manager struct {
	Server *TCPServer
	Store  raft_fsm.StoreHandle
}

func New

func New() *Manager

type TCPServer

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

func (*TCPServer) Join

func (svr *TCPServer) Join(reqBody []byte) []byte

func (*TCPServer) Leave

func (svr *TCPServer) Leave(reqBody []byte) []byte

func (*TCPServer) Payload

func (svr *TCPServer) Payload(reqBody []byte) []byte

func (*TCPServer) SendJoin

func (svr *TCPServer) SendJoin(sendToBody []byte) []byte

func (*TCPServer) SendLeave

func (svr *TCPServer) SendLeave(sendToBody []byte) []byte

func (*TCPServer) SendPayload

func (svr *TCPServer) SendPayload(sendToBody []byte) []byte

func (*TCPServer) Start

func (svr *TCPServer) Start(connection_string string)

func (*TCPServer) Stats

func (svr *TCPServer) Stats() []byte

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL