Package mocks is a generated GoMock package.

New builds a new Spec from a common.Spec (currently uses one level below - common.ExternalDataSourceSpec) in a form that suits the processing of the filters.

NewDefaultConfig creates an instance of the package specific configuration, given a pointer to a logger instance to be used for logging within the package.

NewEngine creates a new Engine.

Config represent the configuration of the oracle engine.

Engine is responsible for broadcasting the Data to products and risk models interested in it.

Broker interface.

The verifier and filterer need to know about new spec immediately, waiting on the event will lead to spec not found issues go:generate go run github.com/golang/mock/mockgen -destination mocks/spec_activations_listener.go -package mocks code.vegaprotocol.io/vega/core/datasource/spec SpecActivationsListener.

TimeService interface.

OnMatchedData describes the callback function used when an data dource data matches the spec.

SpecPredicate describes the predicate used to filter the subscribers.

SubscriptionID is a unique identifier referencing the subscription of an OnMatchedData to a Spec.

SubscriptionPredicate describes the predicate used to check if any of the currently existing subscriptions expects the public keys inside the incoming Spec object.

Unsubscriber is a closure that is created at subscription step in order to provide the ability to unsubscribe at any conveninent moment.