gossiper

package

v0.0.0-...-2b12960 Latest Latest Go to latest Published: Sep 25, 2020 License: Apache-2.0 Imports: 15 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Never-M/MyGossip

Links

Open Source Insights

Documentation ¶

Index ¶

Constants
func NewPair(key, val string) pair
func NewPeer(name, ip string) *peer
func NewPeerFromGossiper(g *Gossiper) *peer
func Newdb(path string) (int, *mydb, error)
func Newlogger() *logger
func TearDown(name string)
type Gossiper
- func NewGossiper(name, ip string) *Gossiper
type PeerPair
- func ReadPeersFromFile(name string) []PeerPair

Constants ¶

View Source

const (
	PUT    = "PUT"
	DELETE = "DELETE"
)

View Source

const FIXED_DIFF = 400

View Source

const HEARTBEAT_PATH = "heartbeat"

View Source

const HEARTBEAT_PORT = ":8002"

View Source

const HEARTBEAT_TIMEOUT = 1000

View Source

const SYNC_PORT = 8001

Variables ¶

This section is empty.

Functions ¶

func NewPair ¶

func NewPair(key, val string) pair

func NewPeer ¶

func NewPeer(name, ip string) *peer

func NewPeerFromGossiper ¶

func NewPeerFromGossiper(g *Gossiper) *peer

func Newdb ¶

func Newdb(path string) (int, *mydb, error)

func Newlogger ¶

func Newlogger() *logger

func TearDown ¶

func TearDown(name string)

TearDown Delete the trace of testcase

Types ¶

type Gossiper ¶

type Gossiper struct {
	SyncServer genSync.GenSync
	// contains filtered or unexported fields
}

func NewGossiper ¶

func NewGossiper(name, ip string) *Gossiper

func (*Gossiper) AddPeer ¶

func (g *Gossiper) AddPeer(p *peer) int

func (*Gossiper) CheckSyncClient ¶

func (g *Gossiper) CheckSyncClient()

func (*Gossiper) Delete ¶

func (g *Gossiper) Delete(key string)

func (*Gossiper) Get ¶

func (g *Gossiper) Get(key string) string

func (*Gossiper) GetDB ¶

func (g *Gossiper) GetDB() *mydb

func (*Gossiper) GetHeartBeatTimer ¶

func (g *Gossiper) GetHeartBeatTimer() *time.Timer

func (*Gossiper) GetIP ¶

func (g *Gossiper) GetIP() string

func (*Gossiper) GetLogger ¶

func (g *Gossiper) GetLogger() *logger

func (*Gossiper) GetName ¶

func (g *Gossiper) GetName() string

func (*Gossiper) GetPeers ¶

func (g *Gossiper) GetPeers() map[string]*peer

func (*Gossiper) GetTerminateChan ¶

func (g *Gossiper) GetTerminateChan() chan int

func (*Gossiper) HeartBeatHandler ¶

func (g *Gossiper) HeartBeatHandler(w http.ResponseWriter, r *http.Request)

func (*Gossiper) HeartBeatReceiver ¶

func (g *Gossiper) HeartBeatReceiver()

func (*Gossiper) PopLeft ¶

func (g *Gossiper) PopLeft() logEntry

func (*Gossiper) PrintPeerNames ¶

func (g *Gossiper) PrintPeerNames()

func (*Gossiper) Push ¶

func (g *Gossiper) Push(l logEntry)

func (*Gossiper) Put ¶

func (g *Gossiper) Put(key, value string)

func (*Gossiper) ReadLogsFromFile ¶

func (g *Gossiper) ReadLogsFromFile()

func (*Gossiper) RemovePeer ¶

func (g *Gossiper) RemovePeer(name string) int

func (*Gossiper) SendHeartBeat ¶

func (g *Gossiper) SendHeartBeat(p *peer) (int, error)

func (*Gossiper) SendHeartBeats ¶

func (g *Gossiper) SendHeartBeats() (int, error)

func (*Gossiper) Start ¶

func (g *Gossiper) Start()

func (*Gossiper) Stop ¶

func (g *Gossiper) Stop()

func (*Gossiper) SyncClientStart ¶

func (g *Gossiper) SyncClientStart(logEntryNum int)

func (*Gossiper) SyncServerStart ¶

func (g *Gossiper) SyncServerStart()

func (*Gossiper) WriteLogToFile ¶

func (g *Gossiper) WriteLogToFile()

func (*Gossiper) WritePeersToFile ¶

func (g *Gossiper) WritePeersToFile()

type PeerPair ¶

type PeerPair struct {
	Name string
	IP   string
}

func ReadPeersFromFile ¶

func ReadPeersFromFile(name string) []PeerPair

Source Files ¶

View all Source files

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