backup

Documentation

Overview

backup implement logic of a backup in VR.

Index

• func AddIncomingPrepare(prepare *vrrpc.PrepareArgs) chan vrrpc.PrepareOk
• func DummyCommitService()
• func Init(ctx context.Context, vt *time.Timer) error
• func ProcessIncomingPrepares(ctx context.Context)
• func Register(rcvr interface{}) error
• type BackupReply
  • func (r *BackupReply) Prepare(prepare *vrrpc.PrepareArgs, resp *vrrpc.PrepareOk) error
• type PrimaryPrepare

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.