domain

Dec 30, 2024

Changes in this version

type QueryProcessor

+ ProcessLatestAvailableNetworkInferencesOutlierResistant func(ctx context.Context, topicID uint64) error

+ ProcessLatestNetworkInferencesOutlierResistant func(ctx context.Context, topicID uint64) error

type QueryService

+ GetLatestAvailableNetworkInferencesOutlierResistant func(ctx context.Context, topicID uint64) (*QueryResult, error)

+ GetLatestNetworkInferencesOutlierResistant func(ctx context.Context, topicID uint64) (*QueryResult, error)

Dec 18, 2024

Changes in this version

type ProcessedBlockRepositoryInterface

+ MarkBlockAsFailed func(ctx context.Context, height int64) error

+ MarkBlockEventAsFailed func(ctx context.Context, height int64) error

Dec 12, 2024

Changes in this version

type QueryProcessor

+ ProcessReputerStakes func(ctx context.Context, topicID uint64) error

type QueryService

+ GetActiveReputers func(ctx context.Context, topicID uint64) (emissionTypes.GetActiveReputersForTopicResponse, int64, error)

+ GetReputerStake func(ctx context.Context, reputerAddr string, topicID uint64) (math.Int, error)

+ type ReputerStake struct

+ Address string

+ Stake math.Int

Dec 10, 2024

Changes in this version

+ type OHLCData struct

+ Close string

+ Date string

+ ExchangeCode string

+ High string

+ Low string

+ Open string

+ Ticker string

+ TradesDone int

+ Volume string

+ VolumeNotional string

+ type OHLCResponse struct

+ Data struct{ ... }

+ RequestID string

+ Status bool

type QueryProcessor

+ ProcessGroundTruthData func(ctx context.Context, topicID uint64) error

type QueryService

+ GetOHLCData func(ctx context.Context, ticker string, fromDate string) (OHLCResponse, error)

Nov 27, 2024

Changes in this version

type AlloraClientInterface

+ Query func(ctx context.Context, path string, data bytes.HexBytes) (*ctypes.ResultABCIQuery, error)

+ type QueryProcessor interface

+ GetMaxTopicID func(ctx context.Context) (uint64, error)

+ ProcessEmissionInfo func(ctx context.Context) error

+ ProcessInflation func(ctx context.Context) error

+ ProcessNaiveInfererNetworkRegret func(ctx context.Context, topicID uint64) error

+ ProcessNetworkInferences func(ctx context.Context, topicID uint64) error

+ type QueryProducer interface

+ Execute func(ctx context.Context) error

+ type QueryResult struct

+ Data json.RawMessage

+ Height int64

+ type QueryResultRepositoryInterface interface

+ SaveQueryResult func(ctx context.Context, key string, queryType string, metadata json.RawMessage, ...) error

+ type QueryService interface

+ GetEmissionInfo func(ctx context.Context) (*QueryResult, error)

+ GetInflation func(ctx context.Context) (*QueryResult, error)

+ GetLatestNetworkInferences func(ctx context.Context, topicID uint64) (*QueryResult, error)

+ GetNaiveInfererNetworkRegret func(ctx context.Context, topicID uint64) (*QueryResult, error)

+ GetNextTopicID func(ctx context.Context) (uint64, error)

Oct 9, 2024

Changes in this version

type CodecInterface

+ IsTypedEvent func(event *abcitypes.Event) bool

+ ParseUntypedEvent func(event *abcitypes.Event) (json.RawMessage, error)

Oct 7, 2024

Changes in this version

+ const MessageTypeEvent

+ const MessageTypeTransaction

+ const StatusCompleted

+ const StatusFailed

+ const StatusPending

+ type AlloraClientInterface interface

+ GetBlockByHeight func(ctx context.Context, height int64) (*ctypes.ResultBlock, error)

+ GetBlockResults func(ctx context.Context, height int64) (*ctypes.ResultBlockResults, error)

+ GetHeader func(ctx context.Context, height int64) (*ctypes.ResultHeader, error)

+ GetLatestBlockHeight func(ctx context.Context) (int64, error)

+ type BlockMetadata struct

+ ChainID string

+ Hash string

+ Height int64

+ Time time.Time

+ type CodecInterface interface

+ MarshalProtoJSON func(event proto.Message) (json.RawMessage, error)

+ ParseEvent func(event *abcitypes.Event) (proto.Message, error)

+ ParseTx func(txBytes []byte) (*tx.Tx, error)

+ ParseTxMessage func(message *codectypes.Any) (proto.Message, error)

+ ParseTxMessages func(txMessages []*codectypes.Any) ([]proto.Message, error)

+ type EventsProducer interface

+ Execute func(ctx context.Context) error

+ type FilterInterface interface

+ ShouldProcess func(typeValue *T) bool

+ type Message struct

+ ID string

+ Name string

+ Payload Payload

+ Timestamp time.Time

+ Type string

+ func NewMessage(msgType, name string, payload Payload) (Message, error)

+ type Metadata struct

+ BlockMetadata BlockMetadata

+ TransactionMetadata TransactionMetadata

+ func NewMetadata(blockHeight int64, chainID string, blockHash string, time time.Time, ...) Metadata

+ type Payload struct

+ Data json.RawMessage

+ Metadata Metadata

+ func NewPayload(metadata Metadata, data json.RawMessage) Payload

+ type ProcessedBlock struct

+ Height int64

+ ID int64

+ ProcessedAt time.Time

+ Status string

+ type ProcessedBlockEvent struct

+ Height int64

+ ID int64

+ ProcessedAt time.Time

+ Status string

+ type ProcessedBlockRepositoryInterface interface

+ GetLastProcessedBlock func(ctx context.Context) (ProcessedBlock, error)

+ GetLastProcessedBlockEvent func(ctx context.Context) (ProcessedBlockEvent, error)

+ SaveProcessedBlock func(ctx context.Context, block ProcessedBlock) error

+ SaveProcessedBlockEvent func(ctx context.Context, blockEvent ProcessedBlockEvent) error

+ type ProcessorService interface

+ ProcessBlock func(ctx context.Context, block *ctypes.ResultBlock) error

+ ProcessBlockResults func(ctx context.Context, blockResults *ctypes.ResultBlockResults, ...) error

+ type StreamingClient interface

+ Close func() error

+ Flush func(ctx context.Context) error

+ PublishAsync func(ctx context.Context, msgType string, message []byte, blockHeight int64) error

+ type TopicRouter interface

+ GetTopic func(msgType string) (string, error)

+ type TransactionMetadata struct

+ TxHash string

+ TxIndex int

+ Type string

+ type TransactionsProducer interface

+ Execute func(ctx context.Context) error