oracles

Oct 31, 2022

Changes in this version

+ var ErrMissingSigners = errors.New("signers are required")

type Engine

+ func (e *Engine) ListensToSigners(data OracleData) bool

type OracleData

+ Signers []*types.Signer

type OracleSpec

+ func (s *OracleSpec) MatchSigners(data OracleData) bool

Sep 12, 2022

Changes in this version

type Engine

+ func (e *Engine) HasMatch(data OracleData) (bool, error)

Aug 16, 2022

Changes in this version

+ const BuiltinOraclePrefix

+ const BuiltinOracleTimestamp

+ var ErrAtLeastOneFilterIsRequired = errors.New("at least one filter is required")

+ var ErrInvalidPropertyKey = errors.New("property key is reserved")

+ var ErrInvalidTimestamp = errors.New("invalid timestamp")

+ var ErrMissingPropertyKey = errors.New("a property key is required")

+ var ErrMissingPropertyName = errors.New("a property name is required")

+ var ErrMissingPubKeys = errors.New("public keys are required")

+ type Broker interface

+ Send func(event events.Event)

+ SendBatch func(events []events.Event)

+ type Builtin struct

+ func NewBuiltinOracle(engine *Engine, ts TimeService) *Builtin

+ func (b *Builtin) OnTick(ctx context.Context, _ time.Time)

+ type Config struct

+ Level encoding.LogLevel

+ func NewDefaultConfig() Config

+ type Engine struct

+ func NewEngine(log *logging.Logger, conf Config, ts TimeService, broker Broker) *Engine

+ func (e *Engine) BroadcastData(ctx context.Context, data OracleData) error

+ func (e *Engine) ListensToPubKeys(data OracleData) bool

+ func (e *Engine) Subscribe(ctx context.Context, spec OracleSpec, cb OnMatchedOracleData) (SubscriptionID, Unsubscriber)

+ func (e *Engine) Unsubscribe(ctx context.Context, id SubscriptionID)

+ type OnMatchedOracleData func(ctx context.Context, data OracleData) error

+ type OracleData struct

+ Data map[string]string

+ PubKeys []string

+ func (d OracleData) Debug() []zap.Field

+ func (d OracleData) FromInternalOracle() bool

+ func (d OracleData) GetBoolean(propertyName string) (bool, error)

+ func (d OracleData) GetDecimal(propertyName string) (num.Decimal, error)

+ func (d OracleData) GetInteger(propertyName string) (*num.Int, error)

+ func (d OracleData) GetString(propertyName string) (string, error)

+ func (d OracleData) GetTimestamp(propertyName string) (int64, error)

+ func (d OracleData) GetUint(name string) (*num.Uint, error)

+ type OracleSpec struct

+ OriginalSpec *types.OracleSpec

+ func NewOracleSpec(originalSpec types.OracleSpec) (*OracleSpec, error)

+ func (s *OracleSpec) MatchData(data OracleData) (bool, error)

+ func (s *OracleSpec) MatchPubKeys(data OracleData) bool

+ func (s OracleSpec) EnsureBoundableProperty(property string, propType oraclespb.PropertyKey_Type) error

+ type OracleSpecID string

+ type OracleSpecPredicate func(spec OracleSpec) (bool, error)

+ type OracleSubscriptionPredicate func(spec OracleSpec) bool

+ type SubscriptionID uint64

+ type TimeService interface

+ GetTimeNow func() time.Time

+ type Unsubscriber func(context.Context, SubscriptionID)