watcher

Documentation

Index

• Variables
• func AccountKey(addr []byte) []byte
• func Commit()
• func DeleteAccount(addr sdk.WasmAddress)
• func Enable() bool
• func GetAccount(addr sdk.WasmAddress) (*types.EthAccount, error)
• func GetParams() types.Params
• func InitDB()
• func NewHeight()
• func NewReadStore(mp map[string][]byte, store sdk.KVStore) sdk.KVStore
• func Save(err error)
• func SetAccount(acc *types.EthAccount) error
• func SetParams(para types.Params)
• func SetWatchDataManager()
• func WrapWriteKVStore(store sdk.KVStore) sdk.KVStore
• type Adapter
  • func (a Adapter) NewStore(ctx sdk.Context, storeKey sdk.StoreKey, pre []byte) sdk.KVStore
• type ParamsManager
  • func (p ParamsManager) GetSendEnabled() bool
  • func (p ParamsManager) SetSendEnabled(enable bool)
• type WatchData
  • func (*WatchData) Descriptor() ([]byte, []int)
  • func (x *WatchData) GetMessages() []*WatchMessage
  • func (d *WatchData) Len() int
  • func (d *WatchData) Less(i, j int) bool
  • func (*WatchData) ProtoMessage()
  • func (x *WatchData) ProtoReflect() protoreflect.Message
  • func (x *WatchData) Reset()
  • func (x *WatchData) String() string
  • func (d *WatchData) Swap(i, j int)
• type WatchDataManager
  • func (w WatchDataManager) ApplyWatchData(v interface{})
  • func (w WatchDataManager) CreateWatchDataGenerator() func() ([]byte, error)
  • func (w WatchDataManager) UnmarshalWatchData(b []byte) (interface{}, error)
• type WatchMessage
  • func (*WatchMessage) Descriptor() ([]byte, []int)
  • func (x *WatchMessage) GetIsDelete() bool
  • func (x *WatchMessage) GetKey() []byte
  • func (x *WatchMessage) GetValue() []byte
  • func (*WatchMessage) ProtoMessage()
  • func (x *WatchMessage) ProtoReflect() protoreflect.Message
  • func (x *WatchMessage) Reset()
  • func (x *WatchMessage) String() string

Variables

var File_watcher_msg_proto protoreflect.FileDescriptor

Functions

func AccountKey

func AccountKey(addr []byte) []byte

func Commit

func Commit()

func DeleteAccount

func DeleteAccount(addr sdk.WasmAddress)

func Enable

func Enable() bool

func GetAccount

func GetAccount(addr sdk.WasmAddress) (*types.EthAccount, error)

func GetParams

func GetParams() types.Params

func InitDB

func InitDB()

func NewHeight

func NewHeight()

func NewReadStore

func NewReadStore(mp map[string][]byte, store sdk.KVStore) sdk.KVStore

func Save

func Save(err error)

func SetAccount

func SetAccount(acc *types.EthAccount) error

func SetParams

func SetParams(para types.Params)

func SetWatchDataManager

func SetWatchDataManager()

func WrapWriteKVStore

func WrapWriteKVStore(store sdk.KVStore) sdk.KVStore

Types

type Adapter

type Adapter struct{}

func (Adapter) NewStore

func (a Adapter) NewStore(ctx sdk.Context, storeKey sdk.StoreKey, pre []byte) sdk.KVStore

type ParamsManager

type ParamsManager struct{}

func (ParamsManager) GetSendEnabled

func (p ParamsManager) GetSendEnabled() bool

func (ParamsManager) SetSendEnabled

func (p ParamsManager) SetSendEnabled(enable bool)

type WatchData

type WatchData struct {
	Messages []*WatchMessage `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchData) Descriptor

func (*WatchData) Descriptor() ([]byte, []int)

Deprecated: Use WatchData.ProtoReflect.Descriptor instead.

func (*WatchData) GetMessages

func (x *WatchData) GetMessages() []*WatchMessage

func (*WatchData) Len

func (d *WatchData) Len() int

func (*WatchData) Less

func (d *WatchData) Less(i, j int) bool

func (*WatchData) ProtoMessage

func (*WatchData) ProtoMessage()

func (*WatchData) ProtoReflect

func (x *WatchData) ProtoReflect() protoreflect.Message

func (*WatchData) Reset

func (x *WatchData) Reset()

func (*WatchData) String

func (x *WatchData) String() string

func (*WatchData) Swap

func (d *WatchData) Swap(i, j int)

type WatchDataManager

type WatchDataManager struct{}

func (WatchDataManager) ApplyWatchData

func (w WatchDataManager) ApplyWatchData(v interface{})

func (WatchDataManager) CreateWatchDataGenerator

func (w WatchDataManager) CreateWatchDataGenerator() func() ([]byte, error)

func (WatchDataManager) UnmarshalWatchData

func (w WatchDataManager) UnmarshalWatchData(b []byte) (interface{}, error)

type WatchMessage

type WatchMessage struct {
	Key      []byte `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value    []byte `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	IsDelete bool   `protobuf:"varint,3,opt,name=isDelete,proto3" json:"isDelete,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchMessage) Descriptor

func (*WatchMessage) Descriptor() ([]byte, []int)

Deprecated: Use WatchMessage.ProtoReflect.Descriptor instead.

func (*WatchMessage) GetIsDelete

func (x *WatchMessage) GetIsDelete() bool

func (*WatchMessage) GetKey

func (x *WatchMessage) GetKey() []byte

func (*WatchMessage) GetValue

func (x *WatchMessage) GetValue() []byte

func (*WatchMessage) ProtoMessage

func (*WatchMessage) ProtoMessage()

func (*WatchMessage) ProtoReflect

func (x *WatchMessage) ProtoReflect() protoreflect.Message

func (*WatchMessage) Reset

func (x *WatchMessage) Reset()

func (*WatchMessage) String

func (x *WatchMessage) String() string