common

Documentation

Index

• Variables
• type Spec
  • func SpecFromProto(proto *vegapb.EthCallSpec) (Spec, error)
  • func (s Spec) DeepClone() common.DataSourceType
  • func (s Spec) GetFilters() []*common.SpecFilter
  • func (s Spec) IntoProto() (*vegapb.EthCallSpec, error)
  • func (s Spec) IsZero() bool
  • func (s Spec) String() string
  • func (s Spec) ToDefinitionProto() (*vegapb.DataSourceDefinition, error)
• type TimeTrigger
  • func TimeTriggerFromProto(protoTrigger *vegapb.EthTimeTrigger) TimeTrigger
  • func (e TimeTrigger) DeepClone() Trigger
  • func (e TimeTrigger) IntoProto() *vegapb.EthTimeTrigger
  • func (e TimeTrigger) IntoTriggerProto() *vegapb.EthCallTrigger
  • func (e TimeTrigger) String() string
• type Trigger
  • func TriggerFromProto(proto *vegapb.EthCallTrigger) (Trigger, error)

Variables

var (
	ErrCallSpecIsNil      = errors.New("ethereum call spec proto is nil")
	ErrInvalidEthereumAbi = errors.New("is not a valid ethereum abi definition")
	ErrInvalidCallTrigger = errors.New("ethereum call trigger not valid")
	ErrInvalidCallArgs    = errors.New("ethereum call args not valid")
	ErrInvalidFilters     = errors.New("ethereum call filters not valid")
)

Types

type Spec

type Spec struct {
	Address               string
	AbiJson               []byte
	Method                string
	ArgsJson              []string
	Trigger               Trigger
	RequiredConfirmations uint64
	Normalisers           map[string]string
	Filters               common.SpecFilters
	SourceChainID         uint64
}

func SpecFromProto

func SpecFromProto(proto *vegapb.EthCallSpec) (Spec, error)

func (Spec) DeepClone

func (s Spec) DeepClone() common.DataSourceType

Whats the need for this deep clone?

func (Spec) GetFilters

func (s Spec) GetFilters() []*common.SpecFilter

func (Spec) IntoProto

func (s Spec) IntoProto() (*vegapb.EthCallSpec, error)

func (Spec) IsZero

func (s Spec) IsZero() bool

func (Spec) String

func (s Spec) String() string

func (Spec) ToDefinitionProto

func (s Spec) ToDefinitionProto() (*vegapb.DataSourceDefinition, error)

type TimeTrigger

type TimeTrigger struct {
	Initial uint64
	Every   uint64 // 0 = don't repeat
	Until   uint64 // 0 = forever
}

func TimeTriggerFromProto

func TimeTriggerFromProto(protoTrigger *vegapb.EthTimeTrigger) TimeTrigger

func (TimeTrigger) DeepClone

func (e TimeTrigger) DeepClone() Trigger

func (TimeTrigger) IntoProto

func (e TimeTrigger) IntoProto() *vegapb.EthTimeTrigger

func (TimeTrigger) IntoTriggerProto

func (e TimeTrigger) IntoTriggerProto() *vegapb.EthCallTrigger

func (TimeTrigger) String

func (e TimeTrigger) String() string

type Trigger

type Trigger interface {
	IntoTriggerProto() *vegapb.EthCallTrigger
	DeepClone() Trigger
	String() string
}

func TriggerFromProto

func TriggerFromProto(proto *vegapb.EthCallTrigger) (Trigger, error)