osmosis

package
v0.3.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 26, 2024 License: MIT Imports: 46 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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 added in v0.3.1 

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 added in v0.3.1 

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
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.