command

package
v0.0.0-...-3a733ff Latest Latest
Warning

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

Go to latest
Published: May 24, 2022 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewTestingCommand

func NewTestingCommand(key string) *commandpb.Command

NewTestingCommand creates a writing *pb.Command with the provided start and end keys.

Types

type Tracker

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

Tracker tracks in-flight Raft proposals.

func MakeTracker

func MakeTracker(log logger.Logger) Tracker

MakeTracker creates a new proposal Tracker.

func (*Tracker) Finish

func (pr *Tracker) Finish(cp *commandpb.CommandResult)

Finish informs a tracked proposal that it has completed.

func (*Tracker) FinishAll

func (pr *Tracker) FinishAll()

FinishAll informs all tracked proposal that they have completed.

func (*Tracker) Register

func (pr *Tracker) Register(cmd *commandpb.Command, c chan<- *commandpb.CommandResult) bool

Register registers a new proposal with the tracker.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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