types

Documentation

Index

• Variables
• type BlockInfo
• type Coin
  • func NewCoin(denom string, amount uint64) *Coin
  • func (c *Coin) Calculate() string
  • func (c *Coin) String() string
• type ContractConfigMap
  • func (c ContractConfigMap) Validate() error
• type EventMap
• type Message
  • func (m *Message) MessageKey() *MessageKey
• type MessageCache
  • func NewMessageCache() *MessageCache
  • func (m *MessageCache) Add(r *RouteMessage)
  • func (m *MessageCache) Get(key *MessageKey) (*RouteMessage, bool)
  • func (m *MessageCache) Len() int
  • func (m *MessageCache) Remove(key *MessageKey)
• type MessageKey
  • func NewMessageKey(sn uint64, src string, dst string, eventType string) *MessageKey
• type MessageKeyWithMessageHeight
  • func NewMessagekeyWithMessageHeight(key *MessageKey, height uint64) *MessageKeyWithMessageHeight
• type Receipt
• type ResponseCode
• type RouteMessage
  • func NewRouteMessage(m *Message) *RouteMessage
  • func (r *RouteMessage) AddNextTry()
  • func (r *RouteMessage) GetMessage() *Message
  • func (r *RouteMessage) GetRetry() uint8
  • func (r *RouteMessage) IncrementRetry()
  • func (r *RouteMessage) IsElasped(duration time.Duration) bool
  • func (r *RouteMessage) IsProcessing() bool
  • func (r *RouteMessage) IsStale() bool
  • func (r *RouteMessage) ToggleProcessing()
  • func (r *RouteMessage) ToggleStale()
• type TransactionObject
  • func NewTransactionObject(messageKey *MessageKeyWithMessageHeight, txHash string, height uint64) *TransactionObject
• type TxResponse
• type TxResponseFunc

Variables

var (
	MaxTxRetry         uint8 = 10
	StaleMarkCount           = MaxTxRetry * 3
	SpecialRetryCount  uint8 = 2
	XcallContract            = "xcall"
	ConnectionContract       = "connection"
	SupportedContracts       = []string{XcallContract, ConnectionContract}
	RetryInterval            = 5 * time.Second
)

Types

type BlockInfo

type BlockInfo struct {
	Height   uint64
	Messages []*Message
}

type Coin

type Coin struct {
	Denom  string
	Amount uint64
}

func NewCoin

func NewCoin(denom string, amount uint64) *Coin

func (*Coin) Calculate

func (c *Coin) Calculate() string

func (*Coin) String

func (c *Coin) String() string

type ContractConfigMap

type ContractConfigMap map[string]string

func (ContractConfigMap) Validate

func (c ContractConfigMap) Validate() error

type EventMap

type EventMap struct {
	Address      string
	ContractName string
	SigType      map[string]string
}

type Message

type Message struct {
	Dst           string `json:"dst"`
	Src           string `json:"src"`
	Sn            uint64 `json:"sn"`
	Data          []byte `json:"data"`
	MessageHeight uint64 `json:"messageHeight"`
	EventType     string `json:"eventType"`
	ReqID         uint64 `json:"reqID,omitempty"`
}

func (*Message) MessageKey

func (m *Message) MessageKey() *MessageKey

type MessageCache

type MessageCache struct {
	Messages map[MessageKey]*RouteMessage
	*sync.RWMutex
}

func NewMessageCache

func NewMessageCache() *MessageCache

func (*MessageCache) Add

func (m *MessageCache) Add(r *RouteMessage)

func (*MessageCache) Get

func (m *MessageCache) Get(key *MessageKey) (*RouteMessage, bool)

Get returns the message from the cache

func (*MessageCache) Len

func (m *MessageCache) Len() int

func (*MessageCache) Remove

func (m *MessageCache) Remove(key *MessageKey)

type MessageKey

type MessageKey struct {
	Sn        uint64
	Src       string
	Dst       string
	EventType string
}

func NewMessageKey

func NewMessageKey(sn uint64, src string, dst string, eventType string) *MessageKey

type MessageKeyWithMessageHeight

type MessageKeyWithMessageHeight struct {
	*MessageKey
	Height uint64
}

func NewMessagekeyWithMessageHeight

func NewMessagekeyWithMessageHeight(key *MessageKey, height uint64) *MessageKeyWithMessageHeight

type Receipt

type Receipt struct {
	TxHash string
	Height uint64
	Status bool
}

type ResponseCode

type ResponseCode uint8

const (
	Failed  ResponseCode = 0
	Success ResponseCode = 1
)

type RouteMessage

type RouteMessage struct {
	*Message
	Retry       uint8
	Processing  bool
	MarkedStale bool
	LastTry     time.Time
}

func NewRouteMessage

func NewRouteMessage(m *Message) *RouteMessage

func (*RouteMessage) AddNextTry

func (r *RouteMessage) AddNextTry()

ResetLastTry resets the last try time to the current time plus the retry interval

func (*RouteMessage) GetMessage

func (r *RouteMessage) GetMessage() *Message

func (*RouteMessage) GetRetry

func (r *RouteMessage) GetRetry() uint8

func (*RouteMessage) IncrementRetry

func (r *RouteMessage) IncrementRetry()

func (*RouteMessage) IsElasped

func (r *RouteMessage) IsElasped(duration time.Duration) bool

IsElasped checks if the last try is elasped by the duration

func (*RouteMessage) IsProcessing

func (r *RouteMessage) IsProcessing() bool

func (*RouteMessage) IsStale

func (r *RouteMessage) IsStale() bool

stale means message which is expired

func (*RouteMessage) ToggleProcessing

func (r *RouteMessage) ToggleProcessing()

func (*RouteMessage) ToggleStale

func (r *RouteMessage) ToggleStale()

type TransactionObject

type TransactionObject struct {
	*MessageKeyWithMessageHeight
	TxHash   string
	TxHeight uint64
}

func NewTransactionObject

func NewTransactionObject(messageKey *MessageKeyWithMessageHeight, txHash string, height uint64) *TransactionObject

type TxResponse

type TxResponse struct {
	Height    int64
	TxHash    string
	Codespace string
	Code      ResponseCode
	Data      string
}

type TxResponseFunc

type TxResponseFunc func(key *MessageKey, response *TxResponse, err error)