provider

Documentation

Index

• type LSDProvider
  • func NewLSDProvider() *LSDProvider
  • func (p *LSDProvider) QueryLSTRebaseFactor(ctx context.Context, symbol string) (*sdk.Dec, error)
• type Provider
  • func NewProvider(exchange string, config *config.ProviderConfig, stopCh <-chan struct{}) (Provider, error)
• type ProviderManager
  • func NewProviderManager(config *config.Config, stopCh <-chan struct{}) *ProviderManager
  • func (m *ProviderManager) GetPrice(ctx context.Context, denom string) *types.PriceResponse
  • func (m *ProviderManager) GetPrices(ctx context.Context) *types.PricesResponse
• type TelegramProvider
  • func NewTelegramProvider() *TelegramProvider
  • func (p *TelegramProvider) SendError(info string, err error) error
  • func (p *TelegramProvider) SendLog(message string) error
• type TransactionsProvider
  • func NewTransactionsProvider(feederType types.FeederType) TransactionsProvider
  • func (p *TransactionsProvider) SubmitAlliancesTransaction(ctx context.Context, msg []byte) (string, error)

Types

type LSDProvider

type LSDProvider struct {
	internal.BaseGrpc
	// contains filtered or unexported fields
}

func NewLSDProvider

func NewLSDProvider() *LSDProvider

func (*LSDProvider) QueryLSTRebaseFactor

func (p *LSDProvider) QueryLSTRebaseFactor(ctx context.Context, symbol string) (*sdk.Dec, error)

type Provider

type Provider interface {
	GetPrices() map[string]types.PriceByPair
}

Provider represents a source of prices.

For example, a cryptocurrency exchange can be a provider.

func NewProvider

func NewProvider(exchange string, config *config.ProviderConfig, stopCh <-chan struct{}) (Provider, error)

type ProviderManager

type ProviderManager struct {
	// contains filtered or unexported fields
}

func NewProviderManager

func NewProviderManager(config *config.Config, stopCh <-chan struct{}) *ProviderManager

func (*ProviderManager) GetPrice

func (m *ProviderManager) GetPrice(ctx context.Context, denom string) *types.PriceResponse

func (*ProviderManager) GetPrices

func (m *ProviderManager) GetPrices(ctx context.Context) *types.PricesResponse

type TelegramProvider

type TelegramProvider struct {
	// contains filtered or unexported fields
}

func NewTelegramProvider

func NewTelegramProvider() *TelegramProvider

func (*TelegramProvider) SendError

func (p *TelegramProvider) SendError(info string, err error) error

func (*TelegramProvider) SendLog

func (p *TelegramProvider) SendLog(message string) error

type TransactionsProvider

type TransactionsProvider struct {
	internal.BaseGrpc

	ChainId string
	// contains filtered or unexported fields
}

func NewTransactionsProvider

func NewTransactionsProvider(
	feederType types.FeederType,
) TransactionsProvider

func (*TransactionsProvider) SubmitAlliancesTransaction

func (p *TransactionsProvider) SubmitAlliancesTransaction(
	ctx context.Context,
	msg []byte,
) (string, error)