streams

package

Go to main page

Versions in this module

v0

v0.7.1

Feb 5, 2026

v0.7.0

Feb 4, 2026

Changes in this version

type CreateStreamDtoDataset

+ const CreateStreamDtoDatasetBookUpdates

+ const CreateStreamDtoDatasetEvents

+ const CreateStreamDtoDatasetOrders

+ const CreateStreamDtoDatasetTrades

+ const CreateStreamDtoDatasetTwap

+ const CreateStreamDtoDatasetWriterActions

type CreateStreamDtoNetwork

+ const CreateStreamDtoNetworkHypercoreMainnet

+ const CreateStreamDtoNetworkStellarMainnet

+ const CreateStreamDtoNetworkStellarTestnet

type TestFilterFunctionDtoDataset

+ const TestFilterFunctionDtoDatasetBookUpdates

+ const TestFilterFunctionDtoDatasetEvents

+ const TestFilterFunctionDtoDatasetOrders

+ const TestFilterFunctionDtoDatasetTrades

+ const TestFilterFunctionDtoDatasetTwap

+ const TestFilterFunctionDtoDatasetWriterActions

type TestFilterFunctionDtoNetwork

+ const TestFilterFunctionDtoNetworkHypercoreMainnet

+ const TestFilterFunctionDtoNetworkStellarMainnet

+ const TestFilterFunctionDtoNetworkStellarTestnet

v0.6.3

Dec 18, 2025

v0.6.2

Nov 20, 2025

Changes in this version

+ type AzureAttributes struct

+ BlobPrefix string

+ Container string

+ FileCompressionType string

+ FileType AzureAttributesFileType

+ MaxRetry float32

+ RetryIntervalSec float32

+ SasToken *string

+ StorageAccount string

+ type AzureAttributesFileType string

+ const AzureAttributesFileTypeDotJson

+ const AzureAttributesFileTypeDotParquet

type CreateStreamDtoDestination

+ const CreateStreamDtoDestinationAzure

type CreateStreamDtoNetwork

+ const CreateStreamDtoNetworkArcTestnet

+ const CreateStreamDtoNetworkBchMainnet

+ const CreateStreamDtoNetworkBchTestnet

+ const CreateStreamDtoNetworkBitcoinTestnet4

+ const CreateStreamDtoNetworkDogeMainnet

+ const CreateStreamDtoNetworkFlareMainnet

+ const CreateStreamDtoNetworkFlareTestnet

+ const CreateStreamDtoNetworkFraxtalMainnet

+ const CreateStreamDtoNetworkHyperevmMainnet

+ const CreateStreamDtoNetworkKatanaMainnet

+ const CreateStreamDtoNetworkLiskMainnet

+ const CreateStreamDtoNetworkLitecoinMainnet

+ const CreateStreamDtoNetworkLitecoinTestnet

+ const CreateStreamDtoNetworkModeMainnet

+ const CreateStreamDtoNetworkMonadMainnet

+ const CreateStreamDtoNetworkMorphHoodi

+ const CreateStreamDtoNetworkPlasmaMainnet

+ const CreateStreamDtoNetworkRedstoneMainnet

+ const CreateStreamDtoNetworkXlayerMainnet

+ const CreateStreamDtoNetworkXrplevmMainnet

+ const CreateStreamDtoNetworkXrplevmTestnet

+ const CreateStreamDtoNetworkZerogMainnet

type CreateStreamDto_DestinationAttributes

+ func (t *CreateStreamDto_DestinationAttributes) FromAzureAttributes(v AzureAttributes) error

+ func (t *CreateStreamDto_DestinationAttributes) MergeAzureAttributes(v AzureAttributes) error

+ func (t CreateStreamDto_DestinationAttributes) AsAzureAttributes() (AzureAttributes, error)

type QuickfunctionsAttributes

+ MaxRetry float32

type S3AttributesFileType

+ const S3AttributesFileTypeDotJson

+ const S3AttributesFileTypeDotParquet

type TestFilterFunctionDtoNetwork

+ const TestFilterFunctionDtoNetworkArcTestnet

+ const TestFilterFunctionDtoNetworkBchMainnet

+ const TestFilterFunctionDtoNetworkBchTestnet

+ const TestFilterFunctionDtoNetworkBitcoinTestnet4

+ const TestFilterFunctionDtoNetworkDogeMainnet

+ const TestFilterFunctionDtoNetworkFlareMainnet

+ const TestFilterFunctionDtoNetworkFlareTestnet

+ const TestFilterFunctionDtoNetworkFraxtalMainnet

+ const TestFilterFunctionDtoNetworkHyperevmMainnet

+ const TestFilterFunctionDtoNetworkKatanaMainnet

+ const TestFilterFunctionDtoNetworkLiskMainnet

+ const TestFilterFunctionDtoNetworkLitecoinMainnet

+ const TestFilterFunctionDtoNetworkLitecoinTestnet

+ const TestFilterFunctionDtoNetworkModeMainnet

+ const TestFilterFunctionDtoNetworkMonadMainnet

+ const TestFilterFunctionDtoNetworkMorphHoodi

+ const TestFilterFunctionDtoNetworkPlasmaMainnet

+ const TestFilterFunctionDtoNetworkRedstoneMainnet

+ const TestFilterFunctionDtoNetworkXlayerMainnet

+ const TestFilterFunctionDtoNetworkXrplevmMainnet

+ const TestFilterFunctionDtoNetworkXrplevmTestnet

+ const TestFilterFunctionDtoNetworkZerogMainnet

type UpdateStreamDtoDestination

+ const UpdateStreamDtoDestinationAzure

type UpdateStreamDto_DestinationAttributes

+ func (t *UpdateStreamDto_DestinationAttributes) FromAzureAttributes(v AzureAttributes) error

+ func (t *UpdateStreamDto_DestinationAttributes) MergeAzureAttributes(v AzureAttributes) error

+ func (t UpdateStreamDto_DestinationAttributes) AsAzureAttributes() (AzureAttributes, error)

v0.6.1

Sep 23, 2025

v0.6.0

Aug 18, 2025

Changes in this version

+ const X_api_keyScopes

+ func NewActivateStreamRequest(server string, id string) (*http.Request, error)

+ func NewCreateRequest(server string, body CreateJSONRequestBody) (*http.Request, error)

+ func NewCreateRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)

+ func NewFindAllRequest(server string, params *FindAllParams) (*http.Request, error)

+ func NewFindOneRequest(server string, id string) (*http.Request, error)

+ func NewGetEnabledStreamsRequest(server string) (*http.Request, error)

+ func NewPauseStreamRequest(server string, id string) (*http.Request, error)

+ func NewRemoveRequest(server string, id string) (*http.Request, error)

+ func NewRemoveStreamsByAccountIdRequest(server string) (*http.Request, error)

+ func NewTestFilterFunctionRequest(server string, body TestFilterFunctionJSONRequestBody) (*http.Request, error)

+ func NewTestFilterFunctionRequestWithBody(server string, contentType string, body io.Reader) (*http.Request, error)

+ func NewUpdateRequest(server string, id string, body UpdateJSONRequestBody) (*http.Request, error)

+ func NewUpdateRequestWithBody(server string, id string, contentType string, body io.Reader) (*http.Request, error)

+ type ActivateStreamResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ func ParseActivateStreamResponse(rsp *http.Response) (*ActivateStreamResponse, error)

+ func (r ActivateStreamResponse) Status() string

+ func (r ActivateStreamResponse) StatusCode() int

+ type Client struct

+ Client HttpRequestDoer

+ RequestEditors []RequestEditorFn

+ Server string

+ func NewClient(server string, opts ...ClientOption) (*Client, error)

+ func (c *Client) ActivateStream(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) Create(ctx context.Context, body CreateJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) CreateWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)

+ func (c *Client) FindAll(ctx context.Context, params *FindAllParams, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) FindOne(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) GetEnabledStreams(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) PauseStream(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) Remove(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) RemoveStreamsByAccountId(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

+ func (c *Client) TestFilterFunction(ctx context.Context, body TestFilterFunctionJSONRequestBody, ...) (*http.Response, error)

+ func (c *Client) TestFilterFunctionWithBody(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)

+ func (c *Client) Update(ctx context.Context, id string, body UpdateJSONRequestBody, ...) (*http.Response, error)

+ func (c *Client) UpdateWithBody(ctx context.Context, id string, contentType string, body io.Reader, ...) (*http.Response, error)

+ type ClientInterface interface

+ ActivateStream func(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*http.Response, error)

+ Create func(ctx context.Context, body CreateJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

+ CreateWithBody func(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)

+ FindAll func(ctx context.Context, params *FindAllParams, reqEditors ...RequestEditorFn) (*http.Response, error)

+ FindOne func(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*http.Response, error)

+ GetEnabledStreams func(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

+ PauseStream func(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*http.Response, error)

+ Remove func(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*http.Response, error)

+ RemoveStreamsByAccountId func(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

+ TestFilterFunction func(ctx context.Context, body TestFilterFunctionJSONRequestBody, ...) (*http.Response, error)

+ TestFilterFunctionWithBody func(ctx context.Context, contentType string, body io.Reader, ...) (*http.Response, error)

+ Update func(ctx context.Context, id string, body UpdateJSONRequestBody, ...) (*http.Response, error)

+ UpdateWithBody func(ctx context.Context, id string, contentType string, body io.Reader, ...) (*http.Response, error)

+ type ClientOption func(*Client) error

+ func WithBaseURL(baseURL string) ClientOption

+ func WithHTTPClient(doer HttpRequestDoer) ClientOption

+ func WithRequestEditorFn(fn RequestEditorFn) ClientOption

+ type ClientWithResponses struct

+ func NewClientWithResponses(server string, opts ...ClientOption) (*ClientWithResponses, error)

+ func (c *ClientWithResponses) ActivateStreamWithResponse(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*ActivateStreamResponse, error)

+ func (c *ClientWithResponses) CreateWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*CreateResponse, error)

+ func (c *ClientWithResponses) CreateWithResponse(ctx context.Context, body CreateJSONRequestBody, reqEditors ...RequestEditorFn) (*CreateResponse, error)

+ func (c *ClientWithResponses) FindAllWithResponse(ctx context.Context, params *FindAllParams, reqEditors ...RequestEditorFn) (*FindAllResponse, error)

+ func (c *ClientWithResponses) FindOneWithResponse(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*FindOneResponse, error)

+ func (c *ClientWithResponses) GetEnabledStreamsWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetEnabledStreamsResponse, error)

+ func (c *ClientWithResponses) PauseStreamWithResponse(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*PauseStreamResponse, error)

+ func (c *ClientWithResponses) RemoveStreamsByAccountIdWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*RemoveStreamsByAccountIdResponse, error)

+ func (c *ClientWithResponses) RemoveWithResponse(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*RemoveResponse, error)

+ func (c *ClientWithResponses) TestFilterFunctionWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, ...) (*TestFilterFunctionResponse, error)

+ func (c *ClientWithResponses) TestFilterFunctionWithResponse(ctx context.Context, body TestFilterFunctionJSONRequestBody, ...) (*TestFilterFunctionResponse, error)

+ func (c *ClientWithResponses) UpdateWithBodyWithResponse(ctx context.Context, id string, contentType string, body io.Reader, ...) (*UpdateResponse, error)

+ func (c *ClientWithResponses) UpdateWithResponse(ctx context.Context, id string, body UpdateJSONRequestBody, ...) (*UpdateResponse, error)

+ type ClientWithResponsesInterface interface

+ ActivateStreamWithResponse func(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*ActivateStreamResponse, error)

+ CreateWithBodyWithResponse func(ctx context.Context, contentType string, body io.Reader, ...) (*CreateResponse, error)

+ CreateWithResponse func(ctx context.Context, body CreateJSONRequestBody, reqEditors ...RequestEditorFn) (*CreateResponse, error)

+ FindAllWithResponse func(ctx context.Context, params *FindAllParams, reqEditors ...RequestEditorFn) (*FindAllResponse, error)

+ FindOneWithResponse func(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*FindOneResponse, error)

+ GetEnabledStreamsWithResponse func(ctx context.Context, reqEditors ...RequestEditorFn) (*GetEnabledStreamsResponse, error)

+ PauseStreamWithResponse func(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*PauseStreamResponse, error)

+ RemoveStreamsByAccountIdWithResponse func(ctx context.Context, reqEditors ...RequestEditorFn) (*RemoveStreamsByAccountIdResponse, error)

+ RemoveWithResponse func(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*RemoveResponse, error)

+ TestFilterFunctionWithBodyWithResponse func(ctx context.Context, contentType string, body io.Reader, ...) (*TestFilterFunctionResponse, error)

+ TestFilterFunctionWithResponse func(ctx context.Context, body TestFilterFunctionJSONRequestBody, ...) (*TestFilterFunctionResponse, error)

+ UpdateWithBodyWithResponse func(ctx context.Context, id string, contentType string, body io.Reader, ...) (*UpdateResponse, error)

+ UpdateWithResponse func(ctx context.Context, id string, body UpdateJSONRequestBody, ...) (*UpdateResponse, error)

+ type CreateJSONRequestBody = CreateStreamDto

+ type CreateResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ func ParseCreateResponse(rsp *http.Response) (*CreateResponse, error)

+ func (r CreateResponse) Status() string

+ func (r CreateResponse) StatusCode() int

+ type CreateStreamDto struct

+ Dataset CreateStreamDtoDataset

+ DatasetBatchSize float32

+ Destination CreateStreamDtoDestination

+ DestinationAttributes CreateStreamDto_DestinationAttributes

+ ElasticBatchEnabled bool

+ EndRange *float32

+ FilterFunction string

+ FixBlockReorgs *float32

+ IncludeStreamMetadata CreateStreamDtoIncludeStreamMetadata

+ KeepDistanceFromTip *float32

+ Name string

+ Network CreateStreamDtoNetwork

+ NotificationEmail *string

+ Region CreateStreamDtoRegion

+ StartRange *float32

+ Status CreateStreamDtoStatus

+ type CreateStreamDtoDataset string

+ const CreateStreamDtoDatasetBlock

+ const CreateStreamDtoDatasetBlockWithReceipts

+ const CreateStreamDtoDatasetBlockWithReceiptsDebugTrace

+ const CreateStreamDtoDatasetBlockWithReceiptsTraceBlock

+ const CreateStreamDtoDatasetDebugTraces

+ const CreateStreamDtoDatasetLedger

+ const CreateStreamDtoDatasetLogs

+ const CreateStreamDtoDatasetProgramsWithLogs

+ const CreateStreamDtoDatasetReceipts

+ const CreateStreamDtoDatasetTraceBlocks

+ const CreateStreamDtoDatasetTransactions

+ type CreateStreamDtoDestination string

+ const CreateStreamDtoDestinationFunction

+ const CreateStreamDtoDestinationPostgres

+ const CreateStreamDtoDestinationS3

+ const CreateStreamDtoDestinationWebhook

+ type CreateStreamDtoIncludeStreamMetadata string

+ const CreateStreamDtoIncludeStreamMetadataBody

+ const CreateStreamDtoIncludeStreamMetadataHeader

+ const CreateStreamDtoIncludeStreamMetadataNone

+ type CreateStreamDtoNetwork string

+ const CreateStreamDtoNetworkAbstractMainnet

+ const CreateStreamDtoNetworkAbstractTestnet

+ const CreateStreamDtoNetworkArbitrumMainnet

+ const CreateStreamDtoNetworkArbitrumSepolia

+ const CreateStreamDtoNetworkAvalancheFuji

+ const CreateStreamDtoNetworkAvalancheMainnet

+ const CreateStreamDtoNetworkB3Mainnet

+ const CreateStreamDtoNetworkB3Sepolia

+ const CreateStreamDtoNetworkBaseMainnet

+ const CreateStreamDtoNetworkBaseSepolia

+ const CreateStreamDtoNetworkBeraBepolia

+ const CreateStreamDtoNetworkBeraMainnet

+ const CreateStreamDtoNetworkBitcoinMainnet

+ const CreateStreamDtoNetworkBlastMainnet

+ const CreateStreamDtoNetworkBlastSepolia

+ const CreateStreamDtoNetworkBnbchainMainnet

+ const CreateStreamDtoNetworkBnbchainTestnet

+ const CreateStreamDtoNetworkCeloMainnet

+ const CreateStreamDtoNetworkCyberMainnet

+ const CreateStreamDtoNetworkCyberSepolia

+ const CreateStreamDtoNetworkEthereumHolesky

+ const CreateStreamDtoNetworkEthereumHoodi

+ const CreateStreamDtoNetworkEthereumMainnet

+ const CreateStreamDtoNetworkEthereumSepolia

+ const CreateStreamDtoNetworkFantomMainnet

+ const CreateStreamDtoNetworkFlowMainnet

+ const CreateStreamDtoNetworkFlowTestnet

+ const CreateStreamDtoNetworkGnosisMainnet

+ const CreateStreamDtoNetworkGravityAlpham

+ const CreateStreamDtoNetworkHederaMainnet

+ const CreateStreamDtoNetworkHederaTestnet

+ const CreateStreamDtoNetworkHemiMainnet

+ const CreateStreamDtoNetworkHemiTestnet

+ const CreateStreamDtoNetworkHyperliquidMainnet

+ const CreateStreamDtoNetworkImxMainnet

+ const CreateStreamDtoNetworkImxTestnet

+ const CreateStreamDtoNetworkInjectiveMainnet

+ const CreateStreamDtoNetworkInjectiveTestnet

+ const CreateStreamDtoNetworkInkMainnet

+ const CreateStreamDtoNetworkInkSepolia

+ const CreateStreamDtoNetworkJocMainnet

+ const CreateStreamDtoNetworkKaiaMainnet

+ const CreateStreamDtoNetworkKaiaTestnet

+ const CreateStreamDtoNetworkLensMainnet

+ const CreateStreamDtoNetworkLensTestnet

+ const CreateStreamDtoNetworkLineaMainnet

+ const CreateStreamDtoNetworkMantleMainnet

+ const CreateStreamDtoNetworkMantleSepolia

+ const CreateStreamDtoNetworkMonadTestnet

+ const CreateStreamDtoNetworkMorphHolesky

+ const CreateStreamDtoNetworkMorphMainnet

+ const CreateStreamDtoNetworkNovaMainnet

+ const CreateStreamDtoNetworkOmniMainnet

+ const CreateStreamDtoNetworkOmniOmega

+ const CreateStreamDtoNetworkOptimismMainnet

+ const CreateStreamDtoNetworkOptimismSepolia

+ const CreateStreamDtoNetworkPeaqMainnet

+ const CreateStreamDtoNetworkPlasmaTestnet

+ const CreateStreamDtoNetworkPolygonAmoy

+ const CreateStreamDtoNetworkPolygonMainnet

+ const CreateStreamDtoNetworkRaceMainnet

+ const CreateStreamDtoNetworkRaceTestnet

+ const CreateStreamDtoNetworkSaharaTestnet

+ const CreateStreamDtoNetworkScrollMainnet

+ const CreateStreamDtoNetworkScrollTestnet

+ const CreateStreamDtoNetworkSeiMainnet

+ const CreateStreamDtoNetworkSeiTestnet

+ const CreateStreamDtoNetworkSolanaDevnet

+ const CreateStreamDtoNetworkSolanaMainnet

+ const CreateStreamDtoNetworkSolanaTestnet

+ const CreateStreamDtoNetworkSoneiumMainnet

+ const CreateStreamDtoNetworkSonicMainnet

+ const CreateStreamDtoNetworkSophonMainnet

+ const CreateStreamDtoNetworkSophonTestnet

+ const CreateStreamDtoNetworkStoryAeneid

+ const CreateStreamDtoNetworkStoryMainnet

+ const CreateStreamDtoNetworkTronMainnet

+ const CreateStreamDtoNetworkUnichainMainnet

+ const CreateStreamDtoNetworkUnichainSepolia

+ const CreateStreamDtoNetworkVanaMainnet

+ const CreateStreamDtoNetworkVanaMoksha

+ const CreateStreamDtoNetworkWorldchainMainnet

+ const CreateStreamDtoNetworkWorldchainSepolia

+ const CreateStreamDtoNetworkXaiMainnet

+ const CreateStreamDtoNetworkXaiSepolia

+ const CreateStreamDtoNetworkXrpMainnet

+ const CreateStreamDtoNetworkXrpTestnet

+ const CreateStreamDtoNetworkZerogGalileo

+ const CreateStreamDtoNetworkZkevmCardona

+ const CreateStreamDtoNetworkZkevmMainnet

+ const CreateStreamDtoNetworkZksyncMainnet

+ const CreateStreamDtoNetworkZksyncSepolia

+ const CreateStreamDtoNetworkZoraMainnet

+ type CreateStreamDtoRegion string

+ const AsiaEast

+ const EuropeCentral

+ const UsaEast

+ type CreateStreamDtoStatus string

+ const CreateStreamDtoStatusActive

+ const CreateStreamDtoStatusCompleted

+ const CreateStreamDtoStatusPaused

+ const CreateStreamDtoStatusTerminated

+ type CreateStreamDto_DestinationAttributes struct

+ func (t *CreateStreamDto_DestinationAttributes) FromPostgresAttributes(v PostgresAttributes) error

+ func (t *CreateStreamDto_DestinationAttributes) FromQuickfunctionsAttributes(v QuickfunctionsAttributes) error

+ func (t *CreateStreamDto_DestinationAttributes) FromS3Attributes(v S3Attributes) error

+ func (t *CreateStreamDto_DestinationAttributes) FromWebhookAttributes(v WebhookAttributes) error

+ func (t *CreateStreamDto_DestinationAttributes) MergePostgresAttributes(v PostgresAttributes) error

+ func (t *CreateStreamDto_DestinationAttributes) MergeQuickfunctionsAttributes(v QuickfunctionsAttributes) error

+ func (t *CreateStreamDto_DestinationAttributes) MergeS3Attributes(v S3Attributes) error

+ func (t *CreateStreamDto_DestinationAttributes) MergeWebhookAttributes(v WebhookAttributes) error

+ func (t *CreateStreamDto_DestinationAttributes) UnmarshalJSON(b []byte) error

+ func (t CreateStreamDto_DestinationAttributes) AsPostgresAttributes() (PostgresAttributes, error)

+ func (t CreateStreamDto_DestinationAttributes) AsQuickfunctionsAttributes() (QuickfunctionsAttributes, error)

+ func (t CreateStreamDto_DestinationAttributes) AsS3Attributes() (S3Attributes, error)

+ func (t CreateStreamDto_DestinationAttributes) AsWebhookAttributes() (WebhookAttributes, error)

+ func (t CreateStreamDto_DestinationAttributes) MarshalJSON() ([]byte, error)

+ type FindAllParams struct

+ Limit float32

+ Offset float32

+ type FindAllResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ func ParseFindAllResponse(rsp *http.Response) (*FindAllResponse, error)

+ func (r FindAllResponse) Status() string

+ func (r FindAllResponse) StatusCode() int

+ type FindOneResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ func ParseFindOneResponse(rsp *http.Response) (*FindOneResponse, error)

+ func (r FindOneResponse) Status() string

+ func (r FindOneResponse) StatusCode() int

+ type GetEnabledStreamsResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ func ParseGetEnabledStreamsResponse(rsp *http.Response) (*GetEnabledStreamsResponse, error)

+ func (r GetEnabledStreamsResponse) Status() string

+ func (r GetEnabledStreamsResponse) StatusCode() int

+ type HttpRequestDoer interface

+ Do func(req *http.Request) (*http.Response, error)

+ type PauseStreamResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ func ParsePauseStreamResponse(rsp *http.Response) (*PauseStreamResponse, error)

+ func (r PauseStreamResponse) Status() string

+ func (r PauseStreamResponse) StatusCode() int

+ type PostgresAttributes struct

+ AccessKey string

+ Database string

+ Host string

+ MaxRetry float32

+ Password string

+ Port float32

+ RetryIntervalSec float32

+ Sslmode PostgresAttributesSslmode

+ TableName string

+ Username string

+ type PostgresAttributesSslmode string

+ const Disable

+ const Require

+ type QuickfunctionsAttributes struct

+ Headers map[string]interface{}

+ MaxEntry float32

+ Name string

+ Namespace string

+ PostTimeoutSec float32

+ RetryIntervalSec float32

+ SecurityToken string

+ type RemoveResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ func ParseRemoveResponse(rsp *http.Response) (*RemoveResponse, error)

+ func (r RemoveResponse) Status() string

+ func (r RemoveResponse) StatusCode() int

+ type RemoveStreamsByAccountIdResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ func ParseRemoveStreamsByAccountIdResponse(rsp *http.Response) (*RemoveStreamsByAccountIdResponse, error)

+ func (r RemoveStreamsByAccountIdResponse) Status() string

+ func (r RemoveStreamsByAccountIdResponse) StatusCode() int

+ type RequestEditorFn func(ctx context.Context, req *http.Request) error

+ type S3Attributes struct

+ AccessKey string

+ Bucket string

+ Endpoint string

+ FileCompression string

+ FileType S3AttributesFileType

+ MaxRetry float32

+ ObjectPrefix string

+ RetryIntervalSec float32

+ SecretKey string

+ UseSsl bool

+ type S3AttributesFileType string

+ const DotJson

+ const DotParquet

+ type TestFilterFunctionDto struct

+ Block string

+ Dataset TestFilterFunctionDtoDataset

+ FilterFunction string

+ Network TestFilterFunctionDtoNetwork

+ type TestFilterFunctionDtoDataset string

+ const TestFilterFunctionDtoDatasetBlock

+ const TestFilterFunctionDtoDatasetBlockWithReceipts

+ const TestFilterFunctionDtoDatasetBlockWithReceiptsDebugTrace

+ const TestFilterFunctionDtoDatasetBlockWithReceiptsTraceBlock

+ const TestFilterFunctionDtoDatasetDebugTraces

+ const TestFilterFunctionDtoDatasetLedger

+ const TestFilterFunctionDtoDatasetLogs

+ const TestFilterFunctionDtoDatasetProgramsWithLogs

+ const TestFilterFunctionDtoDatasetReceipts

+ const TestFilterFunctionDtoDatasetTraceBlocks

+ const TestFilterFunctionDtoDatasetTransactions

+ type TestFilterFunctionDtoNetwork string

+ const TestFilterFunctionDtoNetworkAbstractMainnet

+ const TestFilterFunctionDtoNetworkAbstractTestnet

+ const TestFilterFunctionDtoNetworkArbitrumMainnet

+ const TestFilterFunctionDtoNetworkArbitrumSepolia

+ const TestFilterFunctionDtoNetworkAvalancheFuji

+ const TestFilterFunctionDtoNetworkAvalancheMainnet

+ const TestFilterFunctionDtoNetworkB3Mainnet

+ const TestFilterFunctionDtoNetworkB3Sepolia

+ const TestFilterFunctionDtoNetworkBaseMainnet

+ const TestFilterFunctionDtoNetworkBaseSepolia

+ const TestFilterFunctionDtoNetworkBeraBepolia

+ const TestFilterFunctionDtoNetworkBeraMainnet

+ const TestFilterFunctionDtoNetworkBitcoinMainnet

+ const TestFilterFunctionDtoNetworkBlastMainnet

+ const TestFilterFunctionDtoNetworkBlastSepolia

+ const TestFilterFunctionDtoNetworkBnbchainMainnet

+ const TestFilterFunctionDtoNetworkBnbchainTestnet

+ const TestFilterFunctionDtoNetworkCeloMainnet

+ const TestFilterFunctionDtoNetworkCyberMainnet

+ const TestFilterFunctionDtoNetworkCyberSepolia

+ const TestFilterFunctionDtoNetworkEthereumHolesky

+ const TestFilterFunctionDtoNetworkEthereumHoodi

+ const TestFilterFunctionDtoNetworkEthereumMainnet

+ const TestFilterFunctionDtoNetworkEthereumSepolia

+ const TestFilterFunctionDtoNetworkFantomMainnet

+ const TestFilterFunctionDtoNetworkFlowMainnet

+ const TestFilterFunctionDtoNetworkFlowTestnet

+ const TestFilterFunctionDtoNetworkGnosisMainnet

+ const TestFilterFunctionDtoNetworkGravityAlpham

+ const TestFilterFunctionDtoNetworkHederaMainnet

+ const TestFilterFunctionDtoNetworkHederaTestnet

+ const TestFilterFunctionDtoNetworkHemiMainnet

+ const TestFilterFunctionDtoNetworkHemiTestnet

+ const TestFilterFunctionDtoNetworkHyperliquidMainnet

+ const TestFilterFunctionDtoNetworkImxMainnet

+ const TestFilterFunctionDtoNetworkImxTestnet

+ const TestFilterFunctionDtoNetworkInjectiveMainnet

+ const TestFilterFunctionDtoNetworkInjectiveTestnet

+ const TestFilterFunctionDtoNetworkInkMainnet

+ const TestFilterFunctionDtoNetworkInkSepolia

+ const TestFilterFunctionDtoNetworkJocMainnet

+ const TestFilterFunctionDtoNetworkKaiaMainnet

+ const TestFilterFunctionDtoNetworkKaiaTestnet

+ const TestFilterFunctionDtoNetworkLensMainnet

+ const TestFilterFunctionDtoNetworkLensTestnet

+ const TestFilterFunctionDtoNetworkLineaMainnet

+ const TestFilterFunctionDtoNetworkMantleMainnet

+ const TestFilterFunctionDtoNetworkMantleSepolia

+ const TestFilterFunctionDtoNetworkMonadTestnet

+ const TestFilterFunctionDtoNetworkMorphHolesky

+ const TestFilterFunctionDtoNetworkMorphMainnet

+ const TestFilterFunctionDtoNetworkNovaMainnet

+ const TestFilterFunctionDtoNetworkOmniMainnet

+ const TestFilterFunctionDtoNetworkOmniOmega

+ const TestFilterFunctionDtoNetworkOptimismMainnet

+ const TestFilterFunctionDtoNetworkOptimismSepolia

+ const TestFilterFunctionDtoNetworkPeaqMainnet

+ const TestFilterFunctionDtoNetworkPlasmaTestnet

+ const TestFilterFunctionDtoNetworkPolygonAmoy

+ const TestFilterFunctionDtoNetworkPolygonMainnet

+ const TestFilterFunctionDtoNetworkRaceMainnet

+ const TestFilterFunctionDtoNetworkRaceTestnet

+ const TestFilterFunctionDtoNetworkSaharaTestnet

+ const TestFilterFunctionDtoNetworkScrollMainnet

+ const TestFilterFunctionDtoNetworkScrollTestnet

+ const TestFilterFunctionDtoNetworkSeiMainnet

+ const TestFilterFunctionDtoNetworkSeiTestnet

+ const TestFilterFunctionDtoNetworkSolanaDevnet

+ const TestFilterFunctionDtoNetworkSolanaMainnet

+ const TestFilterFunctionDtoNetworkSolanaTestnet

+ const TestFilterFunctionDtoNetworkSoneiumMainnet

+ const TestFilterFunctionDtoNetworkSonicMainnet

+ const TestFilterFunctionDtoNetworkSophonMainnet

+ const TestFilterFunctionDtoNetworkSophonTestnet

+ const TestFilterFunctionDtoNetworkStoryAeneid

+ const TestFilterFunctionDtoNetworkStoryMainnet

+ const TestFilterFunctionDtoNetworkTronMainnet

+ const TestFilterFunctionDtoNetworkUnichainMainnet

+ const TestFilterFunctionDtoNetworkUnichainSepolia

+ const TestFilterFunctionDtoNetworkVanaMainnet

+ const TestFilterFunctionDtoNetworkVanaMoksha

+ const TestFilterFunctionDtoNetworkWorldchainMainnet

+ const TestFilterFunctionDtoNetworkWorldchainSepolia

+ const TestFilterFunctionDtoNetworkXaiMainnet

+ const TestFilterFunctionDtoNetworkXaiSepolia

+ const TestFilterFunctionDtoNetworkXrpMainnet

+ const TestFilterFunctionDtoNetworkXrpTestnet

+ const TestFilterFunctionDtoNetworkZerogGalileo

+ const TestFilterFunctionDtoNetworkZkevmCardona

+ const TestFilterFunctionDtoNetworkZkevmMainnet

+ const TestFilterFunctionDtoNetworkZksyncMainnet

+ const TestFilterFunctionDtoNetworkZksyncSepolia

+ const TestFilterFunctionDtoNetworkZoraMainnet

+ type TestFilterFunctionJSONRequestBody = TestFilterFunctionDto

+ type TestFilterFunctionResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ func ParseTestFilterFunctionResponse(rsp *http.Response) (*TestFilterFunctionResponse, error)

+ func (r TestFilterFunctionResponse) Status() string

+ func (r TestFilterFunctionResponse) StatusCode() int

+ type UpdateJSONRequestBody = UpdateStreamDto

+ type UpdateResponse struct

+ Body []byte

+ HTTPResponse *http.Response

+ func ParseUpdateResponse(rsp *http.Response) (*UpdateResponse, error)

+ func (r UpdateResponse) Status() string

+ func (r UpdateResponse) StatusCode() int

+ type UpdateStreamDto struct

+ DatasetBatchSize *float32

+ Destination *UpdateStreamDtoDestination

+ DestinationAttributes *UpdateStreamDto_DestinationAttributes

+ ElasticBatchEnabled *bool

+ EndRange *float32

+ FilterFunction *string

+ FixBlockReorgs *float32

+ IncludeStreamMetadata *UpdateStreamDtoIncludeStreamMetadata

+ KeepDistanceFromTip *float32

+ Name *string

+ NotificationEmail *string

+ StartRange *float32

+ Status *UpdateStreamDtoStatus

+ type UpdateStreamDtoDestination string

+ const UpdateStreamDtoDestinationFunction

+ const UpdateStreamDtoDestinationPostgres

+ const UpdateStreamDtoDestinationS3

+ const UpdateStreamDtoDestinationWebhook

+ type UpdateStreamDtoIncludeStreamMetadata string

+ const UpdateStreamDtoIncludeStreamMetadataBody

+ const UpdateStreamDtoIncludeStreamMetadataHeader

+ const UpdateStreamDtoIncludeStreamMetadataNone

+ type UpdateStreamDtoStatus string

+ const UpdateStreamDtoStatusActive

+ const UpdateStreamDtoStatusCompleted

+ const UpdateStreamDtoStatusPaused

+ const UpdateStreamDtoStatusTerminated

+ type UpdateStreamDto_DestinationAttributes struct

+ func (t *UpdateStreamDto_DestinationAttributes) FromPostgresAttributes(v PostgresAttributes) error

+ func (t *UpdateStreamDto_DestinationAttributes) FromQuickfunctionsAttributes(v QuickfunctionsAttributes) error

+ func (t *UpdateStreamDto_DestinationAttributes) FromS3Attributes(v S3Attributes) error

+ func (t *UpdateStreamDto_DestinationAttributes) FromWebhookAttributes(v WebhookAttributes) error

+ func (t *UpdateStreamDto_DestinationAttributes) MergePostgresAttributes(v PostgresAttributes) error

+ func (t *UpdateStreamDto_DestinationAttributes) MergeQuickfunctionsAttributes(v QuickfunctionsAttributes) error

+ func (t *UpdateStreamDto_DestinationAttributes) MergeS3Attributes(v S3Attributes) error

+ func (t *UpdateStreamDto_DestinationAttributes) MergeWebhookAttributes(v WebhookAttributes) error

+ func (t *UpdateStreamDto_DestinationAttributes) UnmarshalJSON(b []byte) error

+ func (t UpdateStreamDto_DestinationAttributes) AsPostgresAttributes() (PostgresAttributes, error)

+ func (t UpdateStreamDto_DestinationAttributes) AsQuickfunctionsAttributes() (QuickfunctionsAttributes, error)

+ func (t UpdateStreamDto_DestinationAttributes) AsS3Attributes() (S3Attributes, error)

+ func (t UpdateStreamDto_DestinationAttributes) AsWebhookAttributes() (WebhookAttributes, error)

+ func (t UpdateStreamDto_DestinationAttributes) MarshalJSON() ([]byte, error)

+ type WebhookAttributes struct

+ Compression string

+ Headers map[string]interface{}

+ MaxRetry float32

+ PostTimeoutSec float32

+ RetryIntervalSec float32

+ SecurityToken string

+ Url string

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