lock

Documentation

Index

• Constants
• func RegisterCodec(cdc *codec.Codec)
• func RegisterOPCodec(cdc *codec.Codec)
• type LockOP
• type OP
• type OPManager
  • func GetOPManager(tp cross.StateConstraintType) (OPManager, error)
• type ReadOP
  • func (r ReadOP) Equal(cop cross.OP) bool
  • func (r ReadOP) Key() []byte
  • func (r ReadOP) String() string
  • func (r ReadOP) Type() uint8
  • func (r ReadOP) Value() []byte
• type Store
  • func NewStore(kvs sdk.KVStore, tp cross.StateConstraintType) Store
  • func (s Store) Commit(id []byte) error
  • func (s Store) CommitImmediately() error
  • func (s Store) Delete(key []byte)
  • func (s Store) Discard(id []byte) error
  • func (s Store) Get(key []byte) []byte
  • func (s Store) Has(key []byte) bool
  • func (s Store) OPs() cross.OPs
  • func (s Store) Precommit(id []byte) error
  • func (s Store) Set(key, value []byte)
• type WriteOP
  • func (w WriteOP) ApplyTo(kvs sdk.KVStore)
  • func (w WriteOP) Equal(cop cross.OP) bool
  • func (w WriteOP) Key() []byte
  • func (w WriteOP) String() string
  • func (w WriteOP) Type() uint8
  • func (w WriteOP) Value() []byte

Constants

const (
	// This order equals a priority of operation
	OP_TYPE_READ uint8 = iota + 1
	OP_TYPE_WRITE
)

const (
	MainStorePrefix uint8 = iota
	TxStorePrefix
	LockStorePrefix
)

Functions

func RegisterCodec

func RegisterCodec(cdc *codec.Codec)

func RegisterOPCodec

func RegisterOPCodec(cdc *codec.Codec)

Types

type LockOP

type LockOP interface {
	cross.OP

	Key() []byte
	ApplyTo(sdk.KVStore)
}

type OP

type OP interface {
	cross.OP

	Key() []byte
	Type() uint8
}

type OPManager

type OPManager interface {
	AddRead(key, value []byte)
	AddWrite(key, value []byte)
	GetUpdatedValue(key []byte) ([]byte, bool)
	OPs() cross.OPs
	LockOPs() []LockOP
}

func GetOPManager

func GetOPManager(tp cross.StateConstraintType) (OPManager, error)

type ReadOP

type ReadOP struct {
	K []byte
	V []byte
}

func (ReadOP) Equal

func (r ReadOP) Equal(cop cross.OP) bool

func (ReadOP) Key

func (r ReadOP) Key() []byte

func (ReadOP) String

func (r ReadOP) String() string

func (ReadOP) Type

func (r ReadOP) Type() uint8

func (ReadOP) Value

func (r ReadOP) Value() []byte

type Store

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

func NewStore

func NewStore(kvs sdk.KVStore, tp cross.StateConstraintType) Store

func (Store) Commit

func (s Store) Commit(id []byte) error

func (Store) CommitImmediately

func (s Store) CommitImmediately() error

func (Store) Delete

func (s Store) Delete(key []byte)

func (Store) Discard

func (s Store) Discard(id []byte) error

func (Store) Get

func (s Store) Get(key []byte) []byte

func (Store) Has

func (s Store) Has(key []byte) bool

func (Store) OPs

func (s Store) OPs() cross.OPs

func (Store) Precommit

func (s Store) Precommit(id []byte) error

func (Store) Set

func (s Store) Set(key, value []byte)

type WriteOP

type WriteOP struct {
	K []byte
	V []byte
}

func (WriteOP) ApplyTo

func (w WriteOP) ApplyTo(kvs sdk.KVStore)

func (WriteOP) Equal

func (w WriteOP) Equal(cop cross.OP) bool

func (WriteOP) Key

func (w WriteOP) Key() []byte

func (WriteOP) String

func (w WriteOP) String() string

func (WriteOP) Type

func (w WriteOP) Type() uint8

func (WriteOP) Value

func (w WriteOP) Value() []byte