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

fetcher

package

Go to main page

Versions in this module

v1

v1.1.2

Dec 9, 2024

v1.1.1

Nov 24, 2024

v1.1.0

Oct 24, 2024

v1.0.5

Jul 26, 2024

v1.0.4

Jun 3, 2024

v1.0.3

May 31, 2024

v1.0.2

May 30, 2024

v1.0.1

Mar 20, 2024

v1.0.0

Feb 16, 2024

Changes in this version

+ var GetBlockOpts = &rpc.GetBlockOpts

+ var MaxSupportedTransactionVersion = uint64(0)

+ var PrintFreq = uint64(10)

+ func WriteString(b string, e *bin.Encoder) error

+ type BigtableBlockReader struct

+ func NewBigtableReader(bt *bigtable.Client, maxConnectionAttempt uint64, logger *zap.Logger, ...) *BigtableBlockReader

+ func (r *BigtableBlockReader) ProcessRow(row bigtable.Row) (*pbsolv1.Block, *zap.Logger, error)

+ func (r *BigtableBlockReader) Read(ctx context.Context, startBlockNum, stopBlockNum uint64, ...) error

+ type BorshIoError struct

+ Msg string

+ func MustNewBorshIoError(a any) BorshIoError

+ func (b BorshIoError) Encode(encoder *bin.Encoder) error

+ type DuplicateInstructionError struct

+ func MustNewDuplicateInstructionError(e any) *DuplicateInstructionError

+ func (e *DuplicateInstructionError) Encode(encoder *bin.Encoder) error

+ type InstructionCustomError struct

+ CustomErrorCode uint32

+ func MustNewInstructionCustomError(e any) InstructionCustomError

+ func (i InstructionCustomError) Encode(encoder *bin.Encoder) error

+ type InstructionError struct

+ InstructionIndex byte

+ func MustNewInstructionError(e any) *InstructionError

+ func (i *InstructionError) Encode(encoder *bin.Encoder) error

+ type InstructionErrorCode uint32

+ const InstructionError_AccountAlreadyInitialized

+ const InstructionError_AccountBorrowFailed

+ const InstructionError_AccountBorrowOutstanding

+ const InstructionError_AccountDataSizeChanged

+ const InstructionError_AccountDataTooSmall

+ const InstructionError_AccountNotExecutable

+ const InstructionError_AccountNotRentExempt

+ const InstructionError_ArithmeticOverflow

+ const InstructionError_BorshIoError

+ const InstructionError_BuiltinProgramsMustConsumeComputeUnits

+ const InstructionError_CallDepth

+ const InstructionError_ComputationalBudgetExceeded

+ const InstructionError_Custom

+ const InstructionError_DuplicateAccountIndex

+ const InstructionError_DuplicateAccountOutOfSync

+ const InstructionError_ExecutableAccountNotRentExempt

+ const InstructionError_ExecutableDataModified

+ const InstructionError_ExecutableLamportChange

+ const InstructionError_ExecutableModified

+ const InstructionError_ExternalAccountDataModified

+ const InstructionError_ExternalAccountLamportSpend

+ const InstructionError_GenericError

+ const InstructionError_IllegalOwner

+ const InstructionError_Immutable

+ const InstructionError_IncorrectAuthority

+ const InstructionError_IncorrectProgramId

+ const InstructionError_InsufficientFunds

+ const InstructionError_InvalidAccountData

+ const InstructionError_InvalidAccountOwner

+ const InstructionError_InvalidArgument

+ const InstructionError_InvalidError

+ const InstructionError_InvalidInstructionData

+ const InstructionError_InvalidRealloc

+ const InstructionError_InvalidSeeds

+ const InstructionError_MaxAccountsDataAllocationsExceeded

+ const InstructionError_MaxAccountsExceeded

+ const InstructionError_MaxInstructionTraceLengthExceeded

+ const InstructionError_MaxSeedLengthExceeded

+ const InstructionError_MissingAccount

+ const InstructionError_MissingRequiredSignature

+ const InstructionError_ModifiedProgramId

+ const InstructionError_NotEnoughAccountKeys

+ const InstructionError_PrivilegeEscalation

+ const InstructionError_ProgramEnvironmentSetupFailure

+ const InstructionError_ProgramFailedToCompile

+ const InstructionError_ProgramFailedToComplete

+ const InstructionError_ReadonlyDataModified

+ const InstructionError_ReadonlyLamportChange

+ const InstructionError_ReentrancyNotAllowed

+ const InstructionError_RentEpochModified

+ const InstructionError_UnbalancedInstruction

+ const InstructionError_UninitializedAccount

+ const InstructionError_UnsupportedProgramId

+ const InstructionError_UnsupportedSysvar

+ type InsufficientFundsForRentError struct

+ AccountIndex byte

+ func MustNewInsufficientFundsForRentError(e any) *InsufficientFundsForRentError

+ func (e *InsufficientFundsForRentError) Encode(encoder *bin.Encoder) error

+ type ProgramExecutionTemporarilyRestrictedError struct

+ AccountIndex byte

+ func MustNewProgramExecutionTemporarilyRestrictedError(e any) *ProgramExecutionTemporarilyRestrictedError

+ func (e *ProgramExecutionTemporarilyRestrictedError) Encode(encoder *bin.Encoder) error

+ type RPCFetcher struct

+ func NewRPC(rpcClient *rpc.Client, fetchInterval time.Duration, ...) *RPCFetcher

+ func (f *RPCFetcher) Fetch(ctx context.Context, requestedSlot uint64) (out *pbbstream.Block, skip bool, err error)

+ func (f *RPCFetcher) IsBlockAvailable(requestedSlot uint64) bool

+ type RowType string

+ const RowTypeBin

+ const RowTypeProto

+ type TransactionError struct

+ func MustNewTransactionError(e any) *TransactionError

+ func (e *TransactionError) Encode(encoder *bin.Encoder) error

+ type TrxErrCode int32

+ const TrxErr_AccountBorrowOutstanding

+ const TrxErr_AccountInUse

+ const TrxErr_AccountLoadedTwice

+ const TrxErr_AccountNotFound

+ const TrxErr_AddressLookupTableNotFound

+ const TrxErr_AlreadyProcessed

+ const TrxErr_BlockhashNotFound

+ const TrxErr_CallChainTooDeep

+ const TrxErr_ClusterMaintenance

+ const TrxErr_DuplicateInstruction

+ const TrxErr_InstructionError

+ const TrxErr_InsufficientFundsForFee

+ const TrxErr_InsufficientFundsForRent

+ const TrxErr_InvalidAccountForFee

+ const TrxErr_InvalidAccountIndex

+ const TrxErr_InvalidAddressLookupTableData

+ const TrxErr_InvalidAddressLookupTableIndex

+ const TrxErr_InvalidAddressLookupTableOwner

+ const TrxErr_InvalidLoadedAccountsDataSizeLimit

+ const TrxErr_InvalidProgramForExecution

+ const TrxErr_InvalidRentPayingAccount

+ const TrxErr_InvalidWritableAccount

+ const TrxErr_MaxLoadedAccountsDataSizeExceeded

+ const TrxErr_MissingSignatureForFee

+ const TrxErr_ProgramAccountNotFound

+ const TrxErr_ProgramExecutionTemporarilyRestricted

+ const TrxErr_ResanitizationNeeded

+ const TrxErr_SanitizeFailure

+ const TrxErr_SignatureFailure

+ const TrxErr_TooManyAccountLocks

+ const TrxErr_UnbalancedTransaction

+ const TrxErr_UnsupportedVersion

+ const TrxErr_WouldExceedAccountDataBlockLimit

+ const TrxErr_WouldExceedAccountDataTotalLimit

+ const TrxErr_WouldExceedMaxAccountCostLimit

+ const TrxErr_WouldExceedMaxBlockCostLimit

+ const TrxErr_WouldExceedMaxVoteCostLimit