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 WithSocketAddr(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) SocketAddr() 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"
	SocketAddrParam    = "socket"
)

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 WithSocketAddr

func WithSocketAddr(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 {
	*dtlWithSocket.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) SocketAddr

func (p *Publisher) SocketAddr() 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
}