state

Documentation

Index

• func Conflict(gamma *Command, delta *Command) bool
• func ConflictBatch(batch1 []Command, batch2 []Command) bool
• func IsRead(command *Command) bool
• func KeyComparator(a, b interface{}) int
• type Command
  • func NOOP() []Command
  • func (c *Command) Execute(st *State) Value
  • func (t *Command) Marshal(w io.Writer)
  • func (t *Command) String() string
  • func (t *Command) Unmarshal(r io.Reader) error
• type Key
  • func (t *Key) Marshal(w io.Writer)
  • func (t *Key) String() string
  • func (t *Key) Unmarshal(r io.Reader) error
• type Operation
  • func (t *Operation) Marshal(w io.Writer)
  • func (t *Operation) Unmarshal(r io.Reader) error
• type State
  • func InitState() *State
• type Value
  • func NIL() Value
  • func (t *Value) Marshal(w io.Writer)
  • func (t *Value) String() string
  • func (t *Value) Unmarshal(r io.Reader) error

Functions

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

func KeyComparator

func KeyComparator(a, b interface{}) int

Types

type Command

type Command struct {
	Op Operation
	K  Key
	V  Value
}

func NOOP

func NOOP() []Command

func (*Command) Execute

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

func (*Command) Marshal

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

func (*Command) String

func (t *Command) String() string

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) String

func (t *Key) String() string

func (*Key) Unmarshal

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

type Operation

type Operation uint8

const (
	NONE Operation = iota
	PUT
	GET
	SCAN
)

func (*Operation) Marshal

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

func (*Operation) Unmarshal

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

type State

type State struct {
	Store *treemap.Map
	// contains filtered or unexported fields
}

func InitState

func InitState() *State

type Value

type Value []byte

func NIL

func NIL() Value

func (*Value) Marshal

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

func (*Value) String

func (t *Value) String() string

func (*Value) Unmarshal

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