ws

Nov 14, 2024

Changes in this version

+ var ErrSubscriptionClosed = errors.New("subscription closed")

type Client

+ func (cl *Client) ParsedBlockSubscribe(filter BlockSubscribeFilter, opts *BlockSubscribeOpts) (*ParsedBlockSubscription, error)

type Options

+ ShortID bool

+ type ParsedBlockResult struct

+ Context struct{ ... }

+ Value struct{ ... }

+ type ParsedBlockSubscription struct

+ func (sw *ParsedBlockSubscription) Err() <-chan error

+ func (sw *ParsedBlockSubscription) Recv(ctx context.Context) (*ParsedBlockResult, error)

+ func (sw *ParsedBlockSubscription) Response() <-chan *ParsedBlockResult

+ func (sw *ParsedBlockSubscription) Unsubscribe()

Apr 1, 2024

Changes in this version

type AccountSubscription

+ func (sw *AccountSubscription) Err() <-chan error

+ func (sw *AccountSubscription) Response() <-chan *AccountResult

type BlockSubscribeOpts

+ MaxSupportedTransactionVersion *uint64

type BlockSubscription

+ func (sw *BlockSubscription) Err() <-chan error

+ func (sw *BlockSubscription) Response() <-chan *BlockResult

type LogSubscription

+ func (sw *LogSubscription) Err() <-chan error

+ func (sw *LogSubscription) Response() <-chan *LogResult

type ProgramSubscription

+ func (sw *ProgramSubscription) Err() <-chan error

+ func (sw *ProgramSubscription) Response() <-chan *ProgramResult

type RootSubscription

+ func (sw *RootSubscription) Err() <-chan error

+ func (sw *RootSubscription) Response() <-chan *RootResult

type SlotSubscription

+ func (sw *SlotSubscription) Err() <-chan error

+ func (sw *SlotSubscription) Response() <-chan *SlotResult

type SlotsUpdatesSubscription

+ func (sw *SlotsUpdatesSubscription) Err() <-chan error

+ func (sw *SlotsUpdatesSubscription) Response() <-chan *SlotsUpdatesResult

type VoteSubscription

+ func (sw *VoteSubscription) Err() <-chan error

+ func (sw *VoteSubscription) Response() <-chan *VoteResult

Jun 26, 2023

Changes in this version

+ var DefaultHandshakeTimeout = 45 * time.Second

type Options

+ HandshakeTimeout time.Duration

Oct 26, 2022

Changes in this version

+ var ErrTimeout = fmt.Errorf("timeout waiting for confirmation")

type SignatureSubscription

+ func (sw *SignatureSubscription) Err() <-chan error

+ func (sw *SignatureSubscription) RecvWithTimeout(timeout time.Duration) (*SignatureResult, error)

+ func (sw *SignatureSubscription) Response() <-chan *SignatureResult

Jul 28, 2022

Changes in this version

+ type BankStats struct

+ MaxTransactionsPerEntry uint64

+ NumFailedTransactions uint64

+ NumSuccessfulTransactions uint64

+ NumTransactionEntries uint64

type Client

+ func ConnectWithOptions(ctx context.Context, rpcEndpoint string, opt *Options) (c *Client, err error)

+ type Options struct

+ HttpHeader http.Header

type SlotsUpdatesResult

+ Stats *BankStats

Feb 16, 2022

Changes in this version

+ type BlockResult struct

+ Context struct{ ... }

+ Value struct{ ... }

+ type BlockSubscribeFilter interface

+ func NewBlockSubscribeFilterAll() BlockSubscribeFilter

+ type BlockSubscribeFilterAll string

+ type BlockSubscribeFilterMentionsAccountOrProgram struct

+ Pubkey solana.PublicKey

+ func NewBlockSubscribeFilterMentionsAccountOrProgram(pubkey solana.PublicKey) *BlockSubscribeFilterMentionsAccountOrProgram

+ type BlockSubscribeOpts struct

+ Commitment rpc.CommitmentType

+ Encoding solana.EncodingType

+ Rewards *bool

+ TransactionDetails rpc.TransactionDetailsType

+ type BlockSubscription struct

+ func (sw *BlockSubscription) Recv() (*BlockResult, error)

+ func (sw *BlockSubscription) Unsubscribe()

type Client

+ func (cl *Client) BlockSubscribe(filter BlockSubscribeFilter, opts *BlockSubscribeOpts) (*BlockSubscription, error)

Jul 20, 2021

Changes in this version

type Client

+ func Connect(ctx context.Context, rpcEndpoint string) (c *Client, err error)

+ func (cl *Client) SlotsUpdatesSubscribe() (*SlotsUpdatesSubscription, error)

+ type SlotsUpdatesResult struct

+ Parent uint64

+ Slot uint64

+ Timestamp *rpc.UnixTimeSeconds

+ Type SlotsUpdatesType

+ type SlotsUpdatesSubscription struct

+ func (sw *SlotsUpdatesSubscription) Recv() (*SlotsUpdatesResult, error)

+ func (sw *SlotsUpdatesSubscription) Unsubscribe()

+ type SlotsUpdatesType string

+ const SlotsUpdatesCompleted

+ const SlotsUpdatesCreatedBank

+ const SlotsUpdatesDead

+ const SlotsUpdatesFirstShredReceived

+ const SlotsUpdatesFrozen

+ const SlotsUpdatesOptimisticConfirmation

+ const SlotsUpdatesRoot

type VoteResult

+ Timestamp *rpc.UnixTimeSeconds

Jul 12, 2021

Changes in this version

+ type AccountResult struct

+ Context struct{ ... }

+ Value struct{ ... }

+ type AccountSubscription struct

+ func (sw *AccountSubscription) Recv() (*AccountResult, error)

+ func (sw *AccountSubscription) Unsubscribe()

+ type Client struct

+ func Dial(ctx context.Context, rpcURL string) (c *Client, err error)

+ func (c *Client) Close()

+ func (cl *Client) AccountSubscribe(account solana.PublicKey, commitment rpc.CommitmentType) (*AccountSubscription, error)

+ func (cl *Client) AccountSubscribeWithOpts(account solana.PublicKey, commitment rpc.CommitmentType, ...) (*AccountSubscription, error)

+ func (cl *Client) LogsSubscribe(filter LogsSubscribeFilterType, commitment rpc.CommitmentType) (*LogSubscription, error)

+ func (cl *Client) LogsSubscribeMentions(mentions solana.PublicKey, commitment rpc.CommitmentType) (*LogSubscription, error)

+ func (cl *Client) ProgramSubscribe(programID solana.PublicKey, commitment rpc.CommitmentType) (*ProgramSubscription, error)

+ func (cl *Client) ProgramSubscribeWithOpts(programID solana.PublicKey, commitment rpc.CommitmentType, ...) (*ProgramSubscription, error)

+ func (cl *Client) RootSubscribe() (*RootSubscription, error)

+ func (cl *Client) SignatureSubscribe(signature solana.Signature, commitment rpc.CommitmentType) (*SignatureSubscription, error)

+ func (cl *Client) SlotSubscribe() (*SlotSubscription, error)

+ func (cl *Client) VoteSubscribe() (*VoteSubscription, error)

+ type LogResult struct

+ Context struct{ ... }

+ Value struct{ ... }

+ type LogSubscription struct

+ func (sw *LogSubscription) Recv() (*LogResult, error)

+ func (sw *LogSubscription) Unsubscribe()

+ type LogsSubscribeFilterType string

+ const LogsSubscribeFilterAll

+ const LogsSubscribeFilterAllWithVotes

+ type ProgramResult struct

+ Context struct{ ... }

+ Value rpc.KeyedAccount

+ type ProgramSubscription struct

+ func (sw *ProgramSubscription) Recv() (*ProgramResult, error)

+ func (sw *ProgramSubscription) Unsubscribe()

+ type RootResult bin.Uint64

+ type RootSubscription struct

+ func (sw *RootSubscription) Recv() (*RootResult, error)

+ func (sw *RootSubscription) Unsubscribe()

+ type SignatureResult struct

+ Context struct{ ... }

+ Value struct{ ... }

+ type SignatureSubscription struct

+ func (sw *SignatureSubscription) Recv() (*SignatureResult, error)

+ func (sw *SignatureSubscription) Unsubscribe()

+ type SlotResult struct

+ Parent uint64

+ Root uint64

+ Slot uint64

+ type SlotSubscription struct

+ func (sw *SlotSubscription) Recv() (*SlotResult, error)

+ func (sw *SlotSubscription) Unsubscribe()

+ type Subscription struct

+ func (s *Subscription) Recv() (interface{}, error)

+ func (s *Subscription) Unsubscribe()

+ type VoteResult struct

+ Hash solana.Hash

+ Slots []bin.Uint64

+ type VoteSubscription struct

+ func (sw *VoteSubscription) Recv() (*VoteResult, error)

+ func (sw *VoteSubscription) Unsubscribe()