osmosis

Documentation

Index

• Variables
• func ContextWithHeight(ctx context.Context, height int64) context.Context
• func ExtractUniquePoolIds(ev ctypes.ResultEvent) []uint64
• func WithBlocksToIndex(blocks uint64) options.Option
• func WithGRPCAPI(url string) options.Option
• func WithMempoolPeriod(d time.Duration) options.Option
• func WithMetrics(url string) options.Option
• func WithPoolIds(ids []uint64) options.Option
• func WithPriceSubject(url string) options.Option
• func WithRPCAPI(url string) options.Option
• func WithTendermintAPI(url string) options.Option
• type IBCDenomTrace
  • func (c IBCDenomTrace) Add(denom string)
• type Publisher
  • func New(db repository.Repository, opts ...options.Option) (*Publisher, error)
  • func (p *Publisher) BlocksToIndex() uint64
  • func (p *Publisher) Close() error
  • func (p *Publisher) DiagnosticsObtainLiquidity(poolId uint64, minHeight, maxHeight int64) []sdktypes.Coins
  • func (p *Publisher) DiagnosticsObtainVolume(poolId uint64, minHeight, maxHeight int64) []sdktypes.Coins
  • func (p *Publisher) GRPCApi() string
  • func (p *Publisher) MakeSentinel(timeout time.Duration) func() error
  • func (p *Publisher) MempoolPeriod() time.Duration
  • func (p *Publisher) MetricsURL() string
  • func (p *Publisher) NewNonce() string
  • func (p *Publisher) PoolIds() []uint64
  • func (p *Publisher) PriceSubject() string
  • func (p *Publisher) RPCApi() string
  • func (p *Publisher) Start() context.Context
  • func (p *Publisher) SubscribeAll() error
  • func (p *Publisher) TendermintApi() string
• type TxProtoGetter

Variables

var (
	TendermintAPIParam = "tm"
	RPCAPIParam        = "rpc"
	GRPCAPIParam       = "grpc"
	MempoolPeriodParam = "mmp"
	PoolIdsParam       = "pids"
	BlocksToIndexParam = "bti"
	PriceSubjectParam  = "prices"
	MetricsParam       = "metrics"
)

Functions

func ContextWithHeight

func ContextWithHeight(ctx context.Context, height int64) context.Context

Will add Height to gRPC call context. This will instruct the full node to return the state at that height. NOTE: It will ignore height values <= 0

func ExtractUniquePoolIds

func ExtractUniquePoolIds(ev ctypes.ResultEvent) []uint64

func WithBlocksToIndex

func WithBlocksToIndex(blocks uint64) options.Option

func WithGRPCAPI

func WithGRPCAPI(url string) options.Option

func WithMempoolPeriod

func WithMempoolPeriod(d time.Duration) options.Option

func WithMetrics

func WithMetrics(url string) options.Option

func WithPoolIds

func WithPoolIds(ids []uint64) options.Option

func WithPriceSubject

func WithPriceSubject(url string) options.Option

func WithRPCAPI

func WithRPCAPI(url string) options.Option

func WithTendermintAPI

func WithTendermintAPI(url string) options.Option

Types

type IBCDenomTrace

type IBCDenomTrace map[string]ibctypes.DenomTrace

func (IBCDenomTrace) Add

func (c IBCDenomTrace) Add(denom string)

type Publisher

type Publisher struct {
	*service.Service
	// contains filtered or unexported fields
}

func New

func New(db repository.Repository, opts ...options.Option) (*Publisher, error)

func (*Publisher) BlocksToIndex

func (p *Publisher) BlocksToIndex() uint64

func (*Publisher) Close

func (p *Publisher) Close() error

func (*Publisher) DiagnosticsObtainLiquidity

func (p *Publisher) DiagnosticsObtainLiquidity(poolId uint64, minHeight, maxHeight int64) []sdktypes.Coins

DiagnosticsObtainLiquidity sequentially retrieves pool Liquidity from minHeight till maxHeight. It will panic on error.

func (*Publisher) DiagnosticsObtainVolume

func (p *Publisher) DiagnosticsObtainVolume(poolId uint64, minHeight, maxHeight int64) []sdktypes.Coins

DiagnosticsObtainVolume sequentially retrieves pool volume from minHeight till maxHeight. It will panic on error.

func (*Publisher) GRPCApi

func (p *Publisher) GRPCApi() string

func (*Publisher) MakeSentinel

func (p *Publisher) MakeSentinel(timeout time.Duration) func() error

func (*Publisher) MempoolPeriod

func (p *Publisher) MempoolPeriod() time.Duration

func (*Publisher) MetricsURL

func (p *Publisher) MetricsURL() string

func (*Publisher) NewNonce

func (p *Publisher) NewNonce() string

func (*Publisher) PoolIds

func (p *Publisher) PoolIds() []uint64

func (*Publisher) PriceSubject

func (p *Publisher) PriceSubject() string

func (*Publisher) RPCApi

func (p *Publisher) RPCApi() string

func (*Publisher) Start

func (p *Publisher) Start() context.Context

func (*Publisher) SubscribeAll

func (p *Publisher) SubscribeAll() error

func (*Publisher) TendermintApi

func (p *Publisher) TendermintApi() string

type TxProtoGetter

type TxProtoGetter interface {
	GetProtoTx() *tx.Tx
}