infra

Nov 27, 2024

Changes in this version

+ func NewPgQueryResult(db DBPool) (domain.QueryResultRepositoryInterface, error)

type AlloraClient

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

+ type QueryResultRepositoryInfra struct

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

type RPCClient

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

Oct 23, 2024

Changes in this version

+ func CreateTables(ctx context.Context, db DBPool) error

+ func DropTables(ctx context.Context, db DBPool) error

Oct 7, 2024

Changes in this version

+ var ErrUnknownMessageType = errors.New("unknown message type")

+ func NewAlloraClient(rpcURL string, timeout time.Duration) (domain.AlloraClientInterface, error)

+ func NewFranzClient(seeds []string, user, password string) (*kgo.Client, error)

+ func NewKafkaClient(client KafkaClient, router domain.TopicRouter) (domain.StreamingClient, error)

+ func NewPgProcessedBlock(db DBPool) (domain.ProcessedBlockRepositoryInterface, error)

+ type AlloraClient struct

+ func (a *AlloraClient) GetBlockByHeight(ctx context.Context, height int64) (*coretypes.ResultBlock, error)

+ func (a *AlloraClient) GetBlockResults(ctx context.Context, height int64) (*coretypes.ResultBlockResults, error)

+ func (a *AlloraClient) GetHeader(ctx context.Context, height int64) (*coretypes.ResultHeader, error)

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

+ type DBPool interface

+ Exec func(ctx context.Context, sql string, arguments ...interface{}) (pgconn.CommandTag, error)

+ QueryRow func(ctx context.Context, sql string, args ...interface{}) RowInterface

+ type KafkaClient interface

+ Close func()

+ Flush func(ctx context.Context) error

+ Produce func(ctx context.Context, r *kgo.Record, promise func(*kgo.Record, error))

+ type RPCClient interface

+ Block func(ctx context.Context, height *int64) (*coretypes.ResultBlock, error)

+ BlockResults func(ctx context.Context, height *int64) (*coretypes.ResultBlockResults, error)

+ Header func(ctx context.Context, height *int64) (*coretypes.ResultHeader, error)

+ Status func(ctx context.Context) (*coretypes.ResultStatus, error)

+ type RowInterface = pgx.Row

+ type TopicRouterImpl struct

+ func NewTopicRouter(mapping map[string]string) *TopicRouterImpl

+ func (tr *TopicRouterImpl) GetTopic(msgType string) (string, error)