backup

package
v0.0.0-...-bccea44 Latest Latest
Warning

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

Go to latest
Published: Dec 9, 2017 License: MIT Imports: 9 Imported by: 0

Documentation

Overview

backup implement logic of a backup in VR.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AddIncomingPrepare

func AddIncomingPrepare(prepare *vrrpc.PrepareArgs) chan vrrpc.PrepareOk

AddIncomingPrepare adds a vrrpc.PrepareArgs to incomingPrepares queue.

func DummyCommitService

func DummyCommitService()

func Init

func Init(ctx context.Context, vt *time.Timer) error

func ProcessIncomingPrepares

func ProcessIncomingPrepares(ctx context.Context)

func Register

func Register(rcvr interface{}) error

Register registers a RPC receiver.

Types

type BackupReply

type BackupReply int

BackupReply defines the basic RPCs exported by server.

func (*BackupReply) Prepare

func (r *BackupReply) Prepare(prepare *vrrpc.PrepareArgs, resp *vrrpc.PrepareOk) error

Prepare responds to primary with a PrepareOk message if criteria is met

type PrimaryPrepare

type PrimaryPrepare struct {
	PrepareArgs vrrpc.PrepareArgs
	// contains filtered or unexported fields
}

PrimaryPrepare represents the in-memory state of a primary prepare message.

Jump to

Keyboard shortcuts

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