state

Documentation

Index

• func AllBlindWrites(cmds []Command) bool
• func AllReads(cmds []Command) bool
• func AllWrites(cmds []Command) bool
• func Conflict(gamma *Command, delta *Command) bool
• func ConflictBatch(batch1 []Command, batch2 []Command) bool
• func IsRead(command *Command) bool
• type Command
  • func (c *Command) Execute(st *State) Value
  • func (t *Command) Marshal(w io.Writer)
  • func (t *Command) Unmarshal(r io.Reader) error
• type Key
  • func (t *Key) Marshal(w io.Writer)
  • func (t *Key) Unmarshal(r io.Reader) error
• type Operation
• type State
  • func InitState() *State
• type Value
  • func (t *Value) Marshal(w io.Writer)
  • func (t *Value) Unmarshal(r io.Reader) error

Functions

func AllBlindWrites

func AllBlindWrites(cmds []Command) bool

func AllReads

func AllReads(cmds []Command) bool

func AllWrites

func AllWrites(cmds []Command) bool

func Conflict

func Conflict(gamma *Command, delta *Command) bool

func ConflictBatch

func ConflictBatch(batch1 []Command, batch2 []Command) bool

func IsRead

func IsRead(command *Command) bool

Types

type Command

type Command struct {
	Op Operation
	K  Key
	V  Value
}

func (*Command) Execute

func (c *Command) Execute(st *State) Value

func (*Command) Marshal

func (t *Command) Marshal(w io.Writer)

func (*Command) Unmarshal

func (t *Command) Unmarshal(r io.Reader) error

type Key

type Key int64

func (*Key) Marshal

func (t *Key) Marshal(w io.Writer)

func (*Key) Unmarshal

func (t *Key) Unmarshal(r io.Reader) error

type Operation

type Operation uint8

const (
	NONE Operation = iota
	PUT
	GET
	PUT_BLIND // Result not needed immediately
)

type State

type State struct {
	Store map[Key]Value
}

func InitState

func InitState() *State

type Value

type Value int64

const NIL Value = 0

func (*Value) Marshal

func (t *Value) Marshal(w io.Writer)

func (*Value) Unmarshal

func (t *Value) Unmarshal(r io.Reader) error