ws

package

Go to main page

Versions in this module

v0

v0.0.14

Nov 14, 2024

Changes in this version

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

type AccountSubscription

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

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

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

v0.0.13

Nov 11, 2024

v0.0.12

May 13, 2024

v0.0.11

Nov 20, 2023

v0.0.10

Nov 19, 2023

v0.0.9

May 11, 2023

v0.0.8

Feb 10, 2023

v0.0.7

Feb 10, 2023

Changes in this version

+ var DefaultHandshakeTimeout = 45 * time.Second

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

type Options

+ HandshakeTimeout time.Duration

type SignatureSubscription

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

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

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

v0.0.6

Dec 13, 2022

v0.0.5

Dec 13, 2022

v0.0.4

Dec 13, 2022

v0.0.3

Dec 13, 2022

v0.0.2

Dec 11, 2022

v0.0.1

Dec 11, 2022

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 BankStats struct

+ MaxTransactionsPerEntry uint64

+ NumFailedTransactions uint64

+ NumSuccessfulTransactions uint64

+ NumTransactionEntries uint64

+ 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 struct

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

+ func ConnectWithOptions(ctx context.Context, rpcEndpoint string, opt *Options) (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) BlockSubscribe(filter BlockSubscribeFilter, opts *BlockSubscribeOpts) (*BlockSubscription, 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) SlotsUpdatesSubscribe() (*SlotsUpdatesSubscription, 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 Options struct

+ HttpHeader http.Header

+ type ProgramResult struct

+ Context struct{ ... }

+ Value rpc.KeyedAccount

+ type ProgramSubscription struct

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

+ func (sw *ProgramSubscription) Unsubscribe()

+ type RootResult 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 SlotsUpdatesResult struct

+ Parent uint64

+ Slot uint64

+ Stats *BankStats

+ Timestamp *solana.UnixTimeMilliseconds

+ 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 Subscription struct

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

+ func (s *Subscription) Unsubscribe()

+ type VoteResult struct

+ Hash solana.Hash

+ Slots []uint64

+ Timestamp *solana.UnixTimeSeconds

+ type VoteSubscription struct

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

+ func (sw *VoteSubscription) Unsubscribe()

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