pyth

package module

Go to main page

Versions in this module

v0

v0.3.7

Apr 7, 2022

Changes in this version

+ const Instruction_UpdPriceNoFailOnError

type InstructionBuilder

+ func (i *InstructionBuilder) UpdPriceNoFailOnError(fundingKey solana.PublicKey, priceKey solana.PublicKey, ...) *Instruction

v0.3.6

Mar 13, 2022

v0.3.5

Mar 10, 2022

v0.3.4

Mar 9, 2022

v0.3.3

Mar 8, 2022

v0.3.2

Mar 8, 2022

Changes in this version

type Client

+ func (c *Client) GetAllPriceAccounts(ctx context.Context, commitment rpc.CommitmentType) ([]PriceAccountEntry, error)

+ func (c *Client) GetAllProductAccounts(ctx context.Context, commitment rpc.CommitmentType) ([]ProductAccountEntry, error)

+ func (c *Client) GetPriceAccountsRecursive(ctx context.Context, commitment rpc.CommitmentType, ...) ([]PriceAccountEntry, error)

+ type MappingAccountEntry struct

+ Pubkey solana.PublicKey

+ Slot uint64

+ type PriceAccountEntry struct

+ Pubkey solana.PublicKey

+ Slot uint64

type ProductAccountEntry

+ Slot uint64

v0.3.1

Mar 6, 2022

Changes in this version

+ type CallbackHandle struct

+ func (c CallbackHandle) Unsubscribe()

type PriceAccountUpdate

+ Price *PriceAccount

+ Pubkey solana.PublicKey

+ type PriceEventHandler struct

+ func NewPriceEventHandler(stream *PriceAccountStream) *PriceEventHandler

+ func (p *PriceEventHandler) Err() error

+ func (p *PriceEventHandler) OnComponentChange(priceKey solana.PublicKey, publisher solana.PublicKey, ...) CallbackHandle

+ func (p *PriceEventHandler) OnPriceChange(priceKey solana.PublicKey, callback func(PriceUpdate)) CallbackHandle

type PriceInfo

+ func (p *PriceInfo) HasChanged(other *PriceInfo) bool

+ func (p *PriceInfo) IsZero() bool

+ func (p *PriceInfo) Value(exponent int32) (price decimal.Decimal, conf decimal.Decimal, ok bool)

+ type PriceUpdate struct

+ Account *PriceAccount

+ CurrentInfo *PriceInfo

+ PreviousInfo *PriceInfo

+ func (p PriceUpdate) Current() (price decimal.Decimal, conf decimal.Decimal, ok bool)

+ func (p PriceUpdate) Previous() (price decimal.Decimal, conf decimal.Decimal, ok bool)

v0.3.0

Mar 6, 2022

Changes in this version

+ const ProductAccountHeaderLen

+ var Devnet = Env

+ var Mainnet = Env

+ var Testnet = Env

type AttrsMap

+ func (a *AttrsMap) MarshalJSON() ([]byte, error)

+ func (a *AttrsMap) UnmarshalJSON(data []byte) (err error)

+ func (a AttrsMap) BinaryLen() (size int)

+ func (a AttrsMap) Sort()

type Client

+ AccountsBatchSize int

+ Env Env

+ func (c *Client) GetAllProductKeys(ctx context.Context) ([]solana.PublicKey, error)

+ func (c *Client) GetAllProducts(ctx context.Context) ([]ProductAccountEntry, error)

+ func (c *Client) GetMappingAccount(ctx context.Context, mappingKey solana.PublicKey) (*MappingAccount, error)

+ type Env struct

+ Mapping solana.PublicKey

+ Program solana.PublicKey

type MappingAccount

+ Pad1 uint32

+ func (m *MappingAccount) ProductKeys() []solana.PublicKey

+ type PriceAccountStream struct

+ func (p *PriceAccountStream) Close()

+ func (p *PriceAccountStream) Err() error

+ func (p *PriceAccountStream) Updates() <-chan PriceAccountUpdate

type ProductAccount

+ func (p *ProductAccount) UnmarshalJSON(buf []byte) error

+ type ProductAccountEntry struct

+ Pubkey solana.PublicKey

+ type ProductAccountHeader struct

+ FirstPrice solana.PublicKey

+ type RawProductAccount struct

+ AttrsData [464]byte

v0.2.0

Mar 5, 2022

Changes in this version

+ const Instruction_AddMapping

+ const Instruction_AddPrice

+ const Instruction_AddProduct

+ const Instruction_AddPublisher

+ const Instruction_AggPrice

+ const Instruction_DelPublisher

+ const Instruction_InitMapping

+ const Instruction_InitPrice

+ const Instruction_InitTest

+ const Instruction_SetMinPub

+ const Instruction_UpdPrice

+ const Instruction_UpdProduct

+ const Instruction_UpdTest

+ const PriceStatusAuction

+ const PriceStatusHalted

+ const PriceStatusTrading

+ const PriceStatusUnknown

+ var MappingKeyDevnet = solana.MustPublicKeyFromBase58("BmA9Z6FjioHJPpjT39QazZyhDRUdZy2ezwx4GiDdE2u2")

+ var MappingKeyMainnet = solana.MustPublicKeyFromBase58("AHtgzX45WTKfkPG53L6WYhGEXwQkN1BVknET3sVsLL8J")

+ var MappingKeyTestnet = solana.MustPublicKeyFromBase58("AFmdnt9ng1uVxqCmqwQJDAYC5cKTkw8gJKSM5PnzuF6z")

+ var ProgramIDDevnet = solana.MustPublicKeyFromBase58("gSbePebfvPy7tRqimPoVecS2UsBvYv46ynrzWocc92s")

+ var ProgramIDMainnet = solana.MustPublicKeyFromBase58("FsJ3A3u2vn5cTVofAjvy6y5kwABJAqYWpe4975bi2epH")

+ var ProgramIDTestnet = solana.MustPublicKeyFromBase58("8tfDNiaEyrV6Q1U4DEXrEigs9DoDtkugzFbybENEbCDz")

+ func InstructionIDToName(id int32) string

+ type AttrsMap struct

+ Pairs [][2]string

+ func NewAttrsMap(fromGo map[string]string) (out AttrsMap, err error)

+ func ReadAttrsMapFromBinary(rd *bytes.Reader) (out AttrsMap, n int, err error)

+ func (a *AttrsMap) UnmarshalBinary(data []byte) (err error)

+ func (a AttrsMap) KVs() map[string]string

+ func (a AttrsMap) MarshalBinary() ([]byte, error)

type Client

+ ProgramKey solana.PublicKey

+ func NewClient(programKey solana.PublicKey, rpcURL string, wsURL string) *Client

+ type CommandAddPrice struct

+ Exponent int32

+ PriceType uint32

+ type CommandAddPublisher struct

+ Publisher solana.PublicKey

+ type CommandDelPublisher struct

+ Publisher solana.PublicKey

+ type CommandHeader struct

+ Cmd int32

+ Version uint32

+ func (h *CommandHeader) Valid() bool

+ type CommandInitPrice struct

+ Exponent int32

+ PriceType uint32

+ type CommandSetMinPub struct

+ MinPub uint8

+ Padding [3]byte

+ type CommandUpdPrice struct

+ Conf uint64

+ Price int64

+ PubSlot uint64

+ Status uint32

+ Unused uint32

+ type CommandUpdProduct struct

+ type CommandUpdTest struct

+ Conf [32]uint64

+ Exponent int32

+ Price [32]int64

+ SlotDiff [32]int8

+ type Instruction struct

+ Header CommandHeader

+ Payload interface{}

+ func DecodeInstruction(programKey solana.PublicKey, accounts []*solana.AccountMeta, data []byte) (*Instruction, error)

+ func (inst *Instruction) Accounts() []*solana.AccountMeta

+ func (inst *Instruction) Data() ([]byte, error)

+ func (inst *Instruction) ProgramID() solana.PublicKey

+ type InstructionBuilder struct

+ func NewInstructionBuilder(programKey solana.PublicKey) *InstructionBuilder

+ func (i *InstructionBuilder) AddMapping(fundingKey solana.PublicKey, tailMappingKey solana.PublicKey, ...) solana.Instruction

+ func (i *InstructionBuilder) AddPrice(fundingKey solana.PublicKey, productKey solana.PublicKey, ...) solana.Instruction

+ func (i *InstructionBuilder) AddProduct(fundingKey solana.PublicKey, mappingKey solana.PublicKey, ...) solana.Instruction

+ func (i *InstructionBuilder) AddPublisher(fundingKey solana.PublicKey, priceKey solana.PublicKey, ...) solana.Instruction

+ func (i *InstructionBuilder) AggPrice(fundingKey solana.PublicKey, priceKey solana.PublicKey) solana.Instruction

+ func (i *InstructionBuilder) DelPublisher(fundingKey solana.PublicKey, priceKey solana.PublicKey, ...) solana.Instruction

+ func (i *InstructionBuilder) InitMapping(fundingKey solana.PublicKey, mappingKey solana.PublicKey) *Instruction

+ func (i *InstructionBuilder) InitPrice(fundingKey solana.PublicKey, priceKey solana.PublicKey, ...) solana.Instruction

+ func (i *InstructionBuilder) InitTest(fundingKey solana.PublicKey, testKey solana.PublicKey) solana.Instruction

+ func (i *InstructionBuilder) SetMinPub(fundingKey solana.PublicKey, priceKey solana.PublicKey, ...) solana.Instruction

+ func (i *InstructionBuilder) UpdPrice(fundingKey solana.PublicKey, priceKey solana.PublicKey, ...) solana.Instruction

+ func (i *InstructionBuilder) UpdProduct(fundingKey solana.PublicKey, productKey solana.PublicKey, ...) solana.Instruction

+ func (i *InstructionBuilder) UpdTest(fundingKey solana.PublicKey, testKey solana.PublicKey, payload CommandUpdTest) solana.Instruction

type ProductAccount

+ AttrsData [464]byte

+ func (p *ProductAccount) GetAttrsMap() (AttrsMap, error)

v0.1.1

Mar 4, 2022

Changes in this version

type Client

+ RPC *rpc.Client

+ func (c *Client) GetPriceAccount(ctx context.Context, productKey solana.PublicKey) (*PriceAccount, error)

+ func (c *Client) GetProductAccount(ctx context.Context, productKey solana.PublicKey) (*ProductAccount, error)

+ type ProductAccount struct

+ Attrs [464]byte

+ FirstPrice solana.PublicKey

+ func (p *ProductAccount) GetAttrs() (map[string]string, error)

+ func (p *ProductAccount) UnmarshalBinary(buf []byte) error

v0.1.0

Feb 27, 2022

Changes in this version

+ const AccountTypeMapping

+ const AccountTypePrice

+ const AccountTypeProduct

+ const AccountTypeUnknown

+ const Magic

+ const V2

+ func PeekAccount(data []byte) uint32

+ type AccountHeader struct

+ AccountType uint32

+ Magic uint32

+ Size uint32

+ Version uint32

+ func (h AccountHeader) Valid() bool

+ type Client struct

+ Log *zap.Logger

+ WebSocketURL string

+ func (c *Client) StreamPriceAccounts(ctx context.Context, updates chan<- PriceAccountUpdate) error

+ type Ema struct

+ Denom int64

+ Numer int64

+ Val int64

+ type MappingAccount struct

+ Next solana.PublicKey

+ Num uint32

+ Products [640]solana.PublicKey

+ Unused uint32

+ func (m *MappingAccount) UnmarshalBinary(buf []byte) error

+ type Opts struct

+ ProgramKey solana.PublicKey

+ type PriceAccount struct

+ Agg PriceInfo

+ Components [32]PriceComp

+ Drv1 int64

+ Drv2 int64

+ Drv3 int64

+ Exponent int32

+ LastSlot uint64

+ Next solana.PublicKey

+ Num uint32

+ NumQt uint32

+ PrevConf uint64

+ PrevPrice int64

+ PrevSlot uint64

+ PriceType uint32

+ Product solana.PublicKey

+ Twac Ema

+ Twap Ema

+ ValidSlot uint64

+ func (p *PriceAccount) GetComponent(publisher *solana.PublicKey) *PriceComp

+ func (p *PriceAccount) UnmarshalBinary(buf []byte) error

+ type PriceAccountUpdate struct

+ Slot uint64

+ type PriceComp struct

+ Agg PriceInfo

+ Latest PriceInfo

+ Publisher solana.PublicKey

+ type PriceInfo struct

+ Conf uint64

+ CorpAct uint32

+ Price int64

+ PubSlot uint64

+ Status uint32

+ type Product struct

+ Attrs [464]byte

+ FirstPrice solana.PublicKey

+ func (p *Product) GetAttrs() (map[string]string, error)

+ func (p *Product) UnmarshalBinary(buf []byte) error

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL