types

type Client interface {
	BroadcastTxSync(msg *TxMsg) error
	BroadcastTxAsync(msg *TxMsg) error
	BroadcastTxCommit(msg *TxMsg) error
	Commit() error
	Has(msg *ViewMsg) (bool, error)
	Query(msg *ViewMsg) ([]byte, error)
	GetObject(msg *ViewMsg, obj interface{}) (err error)
	GetMany(msg *ViewMsg, handler KVHandler) (err error)
	GetKeys(msg *ViewMsg) ([]string, error)
	UnmarshalObject(bz []byte, ptr interface{}) error
	MarshalObject(ptr interface{}) ([]byte, error)
	UnmarshalJson(bz []byte, ptr interface{}) error
	MarshalJson(ptr interface{}) ([]byte, error)
	CurrentBlockNumber() (block int64)
}

type Codec = amino.Codec

type EmptyModuleConfig struct {
}

type Event interface {
	Path() EventPath
}

type EventBus struct {
	sync.Mutex
	// contains filtered or unexported fields
}

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

type EventHandler func(event Event)

type EventPath string

type EventRouter struct {
	sync.Mutex
	Path EventPath
	// contains filtered or unexported fields
}

type EventScope string

type KVHandler func(key []byte, value []byte) bool

type KeyValue struct {
	Key   []byte
	Value []byte
}

type ModuleConfig interface {
	GetTemplate() string
}

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

type SpaceRegistry interface {
	RegisterSpace(name string)
	RegisterSpaceIfNotExist(name string)
}

type Store interface {
	GetPath() string
	Get(key []byte) ([]byte, error)
	Has(key []byte) (bool, error)
	Set(key []byte, value []byte) error
	SetSync(key []byte, value []byte) error
	Delete(key []byte) error
	DeleteSync(key []byte) error
	Iterator(start, end []byte) (dbm.Iterator, error)
	GetMany(start, end []byte) (kvArrayBytes []byte, err error)
}

type TxMsg struct {
	Type   TxType
	Space  string
	Path   string
	Key    []byte
	Data   []byte
	TxHash int64
}

type TxType uint8

type ViewMsg struct {
	Type  ViewType
	Space string
	Path  string
	Start []byte
	End   []byte
}

type ViewType uint8