monitor

Documentation

Index

• Constants
• Variables
• func GetGuardKey(cid mainchain.CidType, simplexReceiver mainchain.Addr) []byte
• func GetPenaltyKey(nonce uint64) []byte
• func GetPullerKey(eLog ethtypes.Log) []byte
• func MonitorTendermintEvent(nodeURI, eventTag string, handleEvent func(event abci.Event))
• func NewMonitor(operator *Operator, db dbm.DB)
• type ChanInfo
• type EventName
• type EventWrapper
  • func NewEvent(name EventName, l types.Log) *EventWrapper
  • func NewEventFromBytes(input []byte) *EventWrapper
  • func (e *EventWrapper) MustMarshal() []byte
  • func (e *EventWrapper) MustUnMarshal(input []byte)
  • func (e *EventWrapper) ParseEvent(ethClient *mainchain.EthClient) interface{}
• type Monitor
• type MonitorContractInfo
  • func NewMonitorContractInfo(address mainchain.Addr, abi string) *MonitorContractInfo
  • func (info *MonitorContractInfo) GetABI() string
  • func (info *MonitorContractInfo) GetAddr() mainchain.Addr
• type Operator
  • func NewOperator(cdc *codec.Codec, cliHome string) (operator *Operator, err error)
  • func (o *Operator) SyncDelegator(candidatorAddr, delegatorAddr mainchain.Addr)
  • func (o *Operator) SyncSubscriptionBalance(consumerAddr mainchain.Addr)
  • func (o *Operator) SyncUpdateSidechainAddr(candidateAddr mainchain.Addr)
  • func (o *Operator) SyncValidator(candidateAddr mainchain.Addr) bool
• type PenaltyEvent
  • func NewPenaltyEvent(nonce uint64) PenaltyEvent
  • func NewPenaltyEventFromBytes(input []byte) PenaltyEvent
  • func (e PenaltyEvent) MustMarshal() []byte
  • func (e *PenaltyEvent) MustUnMarshal(input []byte)

Constants

const (
	ChanInfoState_Null            uint8 = 0
	ChanInfoState_CaughtWithdraw  uint8 = 1
	ChanInfoState_GuardedWithdraw uint8 = 2
	ChanInfoState_CaughtSettle    uint8 = 3
	ChanInfoState_GuardedSettle   uint8 = 4
)

Variables

var (
	PullerKeyPrefix  = []byte{0x01} // Key prefix for puller
	GuardKeyPrefix   = []byte{0x02} // Key prefix for guard
	PenaltyKeyPrefix = []byte{0x03} // Key prefix for penalty
)

var (
	InitiateWithdrawRewardEvent = fmt.Sprintf("%s.%s='%s'", validator.ModuleName, sdk.AttributeKeyAction, validator.ActionInitiateWithdraw)
	SlashEvent                  = fmt.Sprintf("%s.%s='%s'", slash.EventTypeSlash, sdk.AttributeKeyAction, slash.ActionPenalty)
)

Functions

func GetGuardKey

func GetGuardKey(cid mainchain.CidType, simplexReceiver mainchain.Addr) []byte

get guard key from mainchain txHash

func GetPenaltyKey

func GetPenaltyKey(nonce uint64) []byte

get penalty key from nonce

func GetPullerKey

func GetPullerKey(eLog ethtypes.Log) []byte

get puller key from mainchain txHash

func MonitorTendermintEvent

func MonitorTendermintEvent(nodeURI, eventTag string, handleEvent func(event abci.Event))

func NewMonitor

func NewMonitor(operator *Operator, db dbm.DB)

Types

type ChanInfo

type ChanInfo struct {
	Cid             mainchain.CidType
	SimplexReceiver mainchain.Addr
	SeqNum          uint64
	State           uint8
}

type EventName

type EventName string

const (
	UpdateSidechainAddr    EventName = "UpdateSidechainAddr"
	AddSubscriptionBalance EventName = "AddSubscriptionBalance"
	ConfirmParamProposal   EventName = "ConfirmParamProposal"
	UpdateDelegatedStake   EventName = "UpdateDelegatedStake"
	CandidateUnbonded      EventName = "CandidateUnbonded"
	ValidatorChange        EventName = "ValidatorChange"
	UpdateCommissionRate   EventName = "UpdateCommissionRate"
	IntendSettle           EventName = "IntendSettle"
	IntendWithdraw         EventName = "IntendWithdraw"
	IntendWithdrawChannel  EventName = "IntendWithdrawChannel"
)

type EventWrapper

type EventWrapper struct {
	Name EventName `json:"name"`
	Log  types.Log `json:"log"`
}

Wrapper for ethereum Event

func NewEvent

func NewEvent(name EventName, l types.Log) *EventWrapper

func NewEventFromBytes

func NewEventFromBytes(input []byte) *EventWrapper

func (*EventWrapper) MustMarshal

func (e *EventWrapper) MustMarshal() []byte

Marshal event into json bytes

func (*EventWrapper) MustUnMarshal

func (e *EventWrapper) MustUnMarshal(input []byte)

Unmarshal json bytes to event

func (*EventWrapper) ParseEvent

func (e *EventWrapper) ParseEvent(ethClient *mainchain.EthClient) interface{}

type Monitor

type Monitor struct {
	*Operator
	// contains filtered or unexported fields
}

type MonitorContractInfo

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

func NewMonitorContractInfo

func NewMonitorContractInfo(address mainchain.Addr, abi string) *MonitorContractInfo

func (*MonitorContractInfo) GetABI

func (info *MonitorContractInfo) GetABI() string

func (*MonitorContractInfo) GetAddr

func (info *MonitorContractInfo) GetAddr() mainchain.Addr

type Operator

type Operator struct {
	EthClient  *mainchain.EthClient
	Transactor *transactor.Transactor
}

func NewOperator

func NewOperator(cdc *codec.Codec, cliHome string) (operator *Operator, err error)

func (*Operator) SyncDelegator

func (o *Operator) SyncDelegator(candidatorAddr, delegatorAddr mainchain.Addr)

func (*Operator) SyncSubscriptionBalance

func (o *Operator) SyncSubscriptionBalance(consumerAddr mainchain.Addr)

func (*Operator) SyncUpdateSidechainAddr

func (o *Operator) SyncUpdateSidechainAddr(candidateAddr mainchain.Addr)

func (*Operator) SyncValidator

func (o *Operator) SyncValidator(candidateAddr mainchain.Addr) bool

return true if already updated or no need for retry

type PenaltyEvent

type PenaltyEvent struct {
	Nonce      uint64 `json:"nonce"`
	RetryCount uint64 `json:"retry_count"`
}

func NewPenaltyEvent

func NewPenaltyEvent(nonce uint64) PenaltyEvent

func NewPenaltyEventFromBytes

func NewPenaltyEventFromBytes(input []byte) PenaltyEvent

func (PenaltyEvent) MustMarshal

func (e PenaltyEvent) MustMarshal() []byte

Marshal event into json bytes

func (*PenaltyEvent) MustUnMarshal

func (e *PenaltyEvent) MustUnMarshal(input []byte)

Unmarshal json bytes to penalty event