watcher

package
v0.0.0-...-69704c5 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 27, 2023 License: Apache-2.0 Imports: 22 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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.AccAddress)

func Enable

func Enable() bool

func GetAccount

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

func GetParams

func GetParams() types.Params

func InitDB

func InitDB()

func NewHeight

func NewHeight()

func NewReadStore

func NewReadStore(pre []byte) 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(gasMeter sdk.GasMeter, _ sdk.KVStore, 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 deprecated

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 deprecated

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL