Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

ws

package

Go to main page

Versions in this module

v1

v1.13.2

Jan 1, 2025

Changes in this version

+ type TransactionAccountsFilter_Triton struct

+ Exclude []string

+ Include []string

+ Required []string

+ type TransactionResult_Triton struct

+ Value TransactionResult

+ type TransactionSubscribeFilter_Triton struct

+ Accounts TransactionAccountsFilter_Triton

+ Failed bool

+ Signature string

+ Vote bool

v1.13.1

Jan 1, 2025

Changes in this version

type Client

+ func (cl *Client) TransactionSubscribe(filter TransactionSubscribeFilter, options *TransactionSubscribeOptions) (*TransactionSubscription, error)

+ type TransactionResult struct

+ Signature string

+ Slot uint64

+ Transaction rpc.GetParsedTransactionResult

+ type TransactionSubscribeFilter struct

+ AccountExclude []string

+ AccountInclude []string

+ AccountRequired []string

+ Failed bool

+ Signature string

+ Vote bool

+ type TransactionSubscribeOptions struct

+ Commitment rpc.CommitmentType

+ Encoding solana.EncodingType

+ MaxSupportedTransactionVersion int

+ ShowRewards bool

+ TransactionDetails string

+ type TransactionSubscription struct

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

+ func (sw *TransactionSubscription) Recv(ctx context.Context) (*TransactionResult, error)

+ func (sw *TransactionSubscription) Response() <-chan *TransactionResult

+ func (sw *TransactionSubscription) Unsubscribe()

v1.13.0

Dec 5, 2024

Changes in this version

+ var DefaultHandshakeTimeout = 45 * time.Second

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

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

+ type AccountResult struct

+ Context struct{ ... }

+ Value struct{ ... }

+ type AccountSubscription struct

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

+ func (sw *AccountSubscription) Recv(ctx context.Context) (*AccountResult, error)

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

+ 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

+ MaxSupportedTransactionVersion *uint64

+ Rewards *bool

+ TransactionDetails rpc.TransactionDetailsType

+ type BlockSubscription struct

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

+ func (sw *BlockSubscription) Recv(ctx context.Context) (*BlockResult, error)

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

+ 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) ParsedBlockSubscribe(filter BlockSubscribeFilter, opts *BlockSubscribeOpts) (*ParsedBlockSubscription, 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) Err() <-chan error

+ func (sw *LogSubscription) Recv(ctx context.Context) (*LogResult, error)

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

+ func (sw *LogSubscription) Unsubscribe()

+ type LogsSubscribeFilterType string

+ const LogsSubscribeFilterAll

+ const LogsSubscribeFilterAllWithVotes

+ type Options struct

+ HandshakeTimeout time.Duration

+ HttpHeader http.Header

+ 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()

+ type ProgramResult struct

+ Context struct{ ... }

+ Value rpc.KeyedAccount

+ type ProgramSubscription struct

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

+ func (sw *ProgramSubscription) Recv(ctx context.Context) (*ProgramResult, error)

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

+ func (sw *ProgramSubscription) Unsubscribe()

+ type RootResult uint64

+ type RootSubscription struct

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

+ func (sw *RootSubscription) Recv(ctx context.Context) (*RootResult, error)

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

+ func (sw *RootSubscription) Unsubscribe()

+ type SignatureResult struct

+ Context struct{ ... }

+ Value struct{ ... }

+ type SignatureSubscription struct

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

+ func (sw *SignatureSubscription) Recv(ctx context.Context) (*SignatureResult, error)

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

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

+ func (sw *SignatureSubscription) Unsubscribe()

+ type SlotResult struct

+ Parent uint64

+ Root uint64

+ Slot uint64

+ type SlotSubscription struct

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

+ func (sw *SlotSubscription) Recv(ctx context.Context) (*SlotResult, error)

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

+ func (sw *SlotSubscription) Unsubscribe()

+ type SlotsUpdatesResult struct

+ Parent uint64

+ Slot uint64

+ Stats *BankStats

+ Timestamp *solana.UnixTimeMilliseconds

+ Type SlotsUpdatesType

+ type SlotsUpdatesSubscription struct

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

+ func (sw *SlotsUpdatesSubscription) Recv(ctx context.Context) (*SlotsUpdatesResult, error)

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

+ 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(ctx context.Context) (interface{}, error)

+ func (s *Subscription) Unsubscribe()

+ type VoteResult struct

+ Hash solana.Hash

+ Slots []uint64

+ Timestamp *solana.UnixTimeSeconds

+ type VoteSubscription struct

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

+ func (sw *VoteSubscription) Recv(ctx context.Context) (*VoteResult, error)

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

+ func (sw *VoteSubscription) Unsubscribe()