streams

package
v0.6.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 18, 2025 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Overview

Package streams provides primitives to interact with the openapi HTTP API.

Code generated by github.com/oapi-codegen/oapi-codegen/v2 version v2.4.1 DO NOT EDIT.

Index

Constants

View Source 
const (
	X_api_keyScopes = "x_api_key.Scopes"
)

Variables

This section is empty.

Functions

func NewActivateStreamRequest 

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

NewActivateStreamRequest generates requests for ActivateStream

func NewCreateRequest 

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

NewCreateRequest calls the generic Create builder with application/json body

func NewCreateRequestWithBody 

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

NewCreateRequestWithBody generates requests for Create with any type of body

func NewFindAllRequest 

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

NewFindAllRequest generates requests for FindAll

func NewFindOneRequest 

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

NewFindOneRequest generates requests for FindOne

func NewGetEnabledStreamsRequest 

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

NewGetEnabledStreamsRequest generates requests for GetEnabledStreams

func NewPauseStreamRequest 

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

NewPauseStreamRequest generates requests for PauseStream

func NewRemoveRequest 

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

NewRemoveRequest generates requests for Remove

func NewRemoveStreamsByAccountIdRequest 

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

NewRemoveStreamsByAccountIdRequest generates requests for RemoveStreamsByAccountId

func NewTestFilterFunctionRequest 

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

NewTestFilterFunctionRequest calls the generic TestFilterFunction builder with application/json body

func NewTestFilterFunctionRequestWithBody 

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

NewTestFilterFunctionRequestWithBody generates requests for TestFilterFunction with any type of body

func NewUpdateRequest 

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

NewUpdateRequest calls the generic Update builder with application/json body

func NewUpdateRequestWithBody 

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

NewUpdateRequestWithBody generates requests for Update with any type of body

Types

type ActivateStreamResponse 

type ActivateStreamResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

func ParseActivateStreamResponse 

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

ParseActivateStreamResponse parses an HTTP response from a ActivateStreamWithResponse call

func (ActivateStreamResponse) Status 

func (r ActivateStreamResponse) Status() string

Status returns HTTPResponse.Status

func (ActivateStreamResponse) StatusCode 

func (r ActivateStreamResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type AzureAttributes added in v0.6.2 

type AzureAttributes struct {
	BlobPrefix          string                  `json:"blob_prefix"`
	Container           string                  `json:"container"`
	FileCompressionType string                  `json:"file_compression_type"`
	FileType            AzureAttributesFileType `json:"file_type"`
	MaxRetry            float32                 `json:"max_retry"`
	RetryIntervalSec    float32                 `json:"retry_interval_sec"`
	SasToken            *string                 `json:"sas_token,omitempty"`
	StorageAccount      string                  `json:"storage_account"`
}

AzureAttributes defines model for AzureAttributes.

type AzureAttributesFileType added in v0.6.2 

type AzureAttributesFileType string

AzureAttributesFileType defines model for AzureAttributes.FileType. 

const (
	AzureAttributesFileTypeDotJson    AzureAttributesFileType = ".json"
	AzureAttributesFileTypeDotParquet AzureAttributesFileType = ".parquet"
)

Defines values for AzureAttributesFileType.

type Client 

type Client struct {
	// The endpoint of the server conforming to this interface, with scheme,
	// https://api.deepmap.com for example. This can contain a path relative
	// to the server, such as https://api.deepmap.com/dev-test, and all the
	// paths in the swagger spec will be appended to the server.
	Server string

	// Doer for performing requests, typically a *http.Client with any
	// customized settings, such as certificate chains.
	Client HttpRequestDoer

	// A list of callbacks for modifying requests which are generated before sending over
	// the network.
	RequestEditors []RequestEditorFn
}

Client which conforms to the OpenAPI3 specification for this service.

func NewClient 

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

Creates a new Client, with reasonable defaults

func (*Client) ActivateStream 

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

func (*Client) Create 

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

func (*Client) CreateWithBody 

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

func (*Client) FindAll 

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

func (*Client) FindOne 

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

func (*Client) GetEnabledStreams 

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

func (*Client) PauseStream 

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

func (*Client) Remove 

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

func (*Client) RemoveStreamsByAccountId 

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

func (*Client) TestFilterFunction 

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

func (*Client) TestFilterFunctionWithBody 

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

func (*Client) Update 

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

func (*Client) UpdateWithBody 

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

type ClientInterface 

type ClientInterface interface {
	// RemoveStreamsByAccountId request
	RemoveStreamsByAccountId(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

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

	// CreateWithBody request with any body
	CreateWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

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

	// GetEnabledStreams request
	GetEnabledStreams(ctx context.Context, reqEditors ...RequestEditorFn) (*http.Response, error)

	// TestFilterFunctionWithBody request with any body
	TestFilterFunctionWithBody(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

	TestFilterFunction(ctx context.Context, body TestFilterFunctionJSONRequestBody, reqEditors ...RequestEditorFn) (*http.Response, error)

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

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

	// UpdateWithBody request with any body
	UpdateWithBody(ctx context.Context, id string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*http.Response, error)

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

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

	// PauseStream request
	PauseStream(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*http.Response, error)
}

The interface specification for the client above.

type ClientOption 

type ClientOption func(*Client) error

ClientOption allows setting custom parameters during construction

func WithBaseURL 

func WithBaseURL(baseURL string) ClientOption

WithBaseURL overrides the baseURL.

func WithHTTPClient 

func WithHTTPClient(doer HttpRequestDoer) ClientOption

WithHTTPClient allows overriding the default Doer, which is automatically created using http.Client. This is useful for tests.

func WithRequestEditorFn 

func WithRequestEditorFn(fn RequestEditorFn) ClientOption

WithRequestEditorFn allows setting up a callback function, which will be called right before sending the request. This can be used to mutate the request.

type ClientWithResponses 

type ClientWithResponses struct {
	ClientInterface
}

ClientWithResponses builds on ClientInterface to offer response payloads

func NewClientWithResponses 

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

NewClientWithResponses creates a new ClientWithResponses, which wraps Client with return type handling

func (*ClientWithResponses) ActivateStreamWithResponse 

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

ActivateStreamWithResponse request returning *ActivateStreamResponse

func (*ClientWithResponses) CreateWithBodyWithResponse 

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

CreateWithBodyWithResponse request with arbitrary body returning *CreateResponse

func (*ClientWithResponses) CreateWithResponse 

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

func (*ClientWithResponses) FindAllWithResponse 

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

FindAllWithResponse request returning *FindAllResponse

func (*ClientWithResponses) FindOneWithResponse 

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

FindOneWithResponse request returning *FindOneResponse

func (*ClientWithResponses) GetEnabledStreamsWithResponse 

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

GetEnabledStreamsWithResponse request returning *GetEnabledStreamsResponse

func (*ClientWithResponses) PauseStreamWithResponse 

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

PauseStreamWithResponse request returning *PauseStreamResponse

func (*ClientWithResponses) RemoveStreamsByAccountIdWithResponse 

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

RemoveStreamsByAccountIdWithResponse request returning *RemoveStreamsByAccountIdResponse

func (*ClientWithResponses) RemoveWithResponse 

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

RemoveWithResponse request returning *RemoveResponse

func (*ClientWithResponses) TestFilterFunctionWithBodyWithResponse 

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

TestFilterFunctionWithBodyWithResponse request with arbitrary body returning *TestFilterFunctionResponse

func (*ClientWithResponses) TestFilterFunctionWithResponse 

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

func (*ClientWithResponses) UpdateWithBodyWithResponse 

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

UpdateWithBodyWithResponse request with arbitrary body returning *UpdateResponse

func (*ClientWithResponses) UpdateWithResponse 

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

type ClientWithResponsesInterface 

type ClientWithResponsesInterface interface {
	// RemoveStreamsByAccountIdWithResponse request
	RemoveStreamsByAccountIdWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*RemoveStreamsByAccountIdResponse, error)

	// FindAllWithResponse request
	FindAllWithResponse(ctx context.Context, params *FindAllParams, reqEditors ...RequestEditorFn) (*FindAllResponse, error)

	// CreateWithBodyWithResponse request with any body
	CreateWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*CreateResponse, error)

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

	// GetEnabledStreamsWithResponse request
	GetEnabledStreamsWithResponse(ctx context.Context, reqEditors ...RequestEditorFn) (*GetEnabledStreamsResponse, error)

	// TestFilterFunctionWithBodyWithResponse request with any body
	TestFilterFunctionWithBodyWithResponse(ctx context.Context, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*TestFilterFunctionResponse, error)

	TestFilterFunctionWithResponse(ctx context.Context, body TestFilterFunctionJSONRequestBody, reqEditors ...RequestEditorFn) (*TestFilterFunctionResponse, error)

	// RemoveWithResponse request
	RemoveWithResponse(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*RemoveResponse, error)

	// FindOneWithResponse request
	FindOneWithResponse(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*FindOneResponse, error)

	// UpdateWithBodyWithResponse request with any body
	UpdateWithBodyWithResponse(ctx context.Context, id string, contentType string, body io.Reader, reqEditors ...RequestEditorFn) (*UpdateResponse, error)

	UpdateWithResponse(ctx context.Context, id string, body UpdateJSONRequestBody, reqEditors ...RequestEditorFn) (*UpdateResponse, error)

	// ActivateStreamWithResponse request
	ActivateStreamWithResponse(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*ActivateStreamResponse, error)

	// PauseStreamWithResponse request
	PauseStreamWithResponse(ctx context.Context, id string, reqEditors ...RequestEditorFn) (*PauseStreamResponse, error)
}

ClientWithResponsesInterface is the interface specification for the client with responses above.

type CreateJSONRequestBody 

type CreateJSONRequestBody = CreateStreamDto

CreateJSONRequestBody defines body for Create for application/json ContentType.

type CreateResponse 

type CreateResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

func ParseCreateResponse 

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

ParseCreateResponse parses an HTTP response from a CreateWithResponse call

func (CreateResponse) Status 

func (r CreateResponse) Status() string

Status returns HTTPResponse.Status

func (CreateResponse) StatusCode 

func (r CreateResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type CreateStreamDto 

type CreateStreamDto struct {
	Dataset               CreateStreamDtoDataset                `json:"dataset"`
	DatasetBatchSize      float32                               `json:"dataset_batch_size"`
	Destination           CreateStreamDtoDestination            `json:"destination"`
	DestinationAttributes CreateStreamDto_DestinationAttributes `json:"destination_attributes"`
	ElasticBatchEnabled   bool                                  `json:"elastic_batch_enabled"`

	// EndRange Stream until block number
	EndRange *int `json:"end_range,omitempty"`

	// FilterFunction JS/ECMAScript compliant filter encoded in base64
	FilterFunction string `json:"filter_function"`

	// FixBlockReorgs Fix block reorgs by streaming correct blocks: 1. Ignore reorgs: 0
	FixBlockReorgs        *float32                             `json:"fix_block_reorgs,omitempty"`
	IncludeStreamMetadata CreateStreamDtoIncludeStreamMetadata `json:"include_stream_metadata"`

	// KeepDistanceFromTip Stay away from tip by N blocks
	KeepDistanceFromTip *float32               `json:"keep_distance_from_tip,omitempty"`
	Name                string                 `json:"name"`
	Network             CreateStreamDtoNetwork `json:"network"`

	// NotificationEmail Notify when stream is terminated
	NotificationEmail *string               `json:"notification_email,omitempty"`
	Region            CreateStreamDtoRegion `json:"region"`

	// StartRange Stream start at block number. If not provided, the stream will start at the latest block.
	StartRange *int                  `json:"start_range,omitempty"`
	Status     CreateStreamDtoStatus `json:"status"`
}

CreateStreamDto defines model for CreateStreamDto.

type CreateStreamDtoDataset 

type CreateStreamDtoDataset string

CreateStreamDtoDataset defines model for CreateStreamDto.Dataset. 

const (
	CreateStreamDtoDatasetBlock                       CreateStreamDtoDataset = "block"
	CreateStreamDtoDatasetBlockWithReceipts           CreateStreamDtoDataset = "block_with_receipts"
	CreateStreamDtoDatasetBlockWithReceiptsDebugTrace CreateStreamDtoDataset = "block_with_receipts_debug_trace"
	CreateStreamDtoDatasetBlockWithReceiptsTraceBlock CreateStreamDtoDataset = "block_with_receipts_trace_block"
	CreateStreamDtoDatasetDebugTraces                 CreateStreamDtoDataset = "debug_traces"
	CreateStreamDtoDatasetLedger                      CreateStreamDtoDataset = "ledger"
	CreateStreamDtoDatasetLogs                        CreateStreamDtoDataset = "logs"
	CreateStreamDtoDatasetProgramsWithLogs            CreateStreamDtoDataset = "programs_with_logs"
	CreateStreamDtoDatasetReceipts                    CreateStreamDtoDataset = "receipts"
	CreateStreamDtoDatasetTraceBlocks                 CreateStreamDtoDataset = "trace_blocks"
	CreateStreamDtoDatasetTransactions                CreateStreamDtoDataset = "transactions"
)

Defines values for CreateStreamDtoDataset.

type CreateStreamDtoDestination 

type CreateStreamDtoDestination string

CreateStreamDtoDestination defines model for CreateStreamDto.Destination. 

const (
	CreateStreamDtoDestinationAzure    CreateStreamDtoDestination = "azure"
	CreateStreamDtoDestinationFunction CreateStreamDtoDestination = "function"
	CreateStreamDtoDestinationPostgres CreateStreamDtoDestination = "postgres"
	CreateStreamDtoDestinationS3       CreateStreamDtoDestination = "s3"
	CreateStreamDtoDestinationWebhook  CreateStreamDtoDestination = "webhook"
)

Defines values for CreateStreamDtoDestination.

type CreateStreamDtoIncludeStreamMetadata 

type CreateStreamDtoIncludeStreamMetadata string

CreateStreamDtoIncludeStreamMetadata defines model for CreateStreamDto.IncludeStreamMetadata. 

const (
	CreateStreamDtoIncludeStreamMetadataBody   CreateStreamDtoIncludeStreamMetadata = "body"
	CreateStreamDtoIncludeStreamMetadataHeader CreateStreamDtoIncludeStreamMetadata = "header"
	CreateStreamDtoIncludeStreamMetadataNone   CreateStreamDtoIncludeStreamMetadata = "none"
)

Defines values for CreateStreamDtoIncludeStreamMetadata.

type CreateStreamDtoNetwork 

type CreateStreamDtoNetwork string

CreateStreamDtoNetwork defines model for CreateStreamDto.Network. 

const (
	CreateStreamDtoNetworkAbstractMainnet   CreateStreamDtoNetwork = "abstract-mainnet"
	CreateStreamDtoNetworkAbstractTestnet   CreateStreamDtoNetwork = "abstract-testnet"
	CreateStreamDtoNetworkArbitrumMainnet   CreateStreamDtoNetwork = "arbitrum-mainnet"
	CreateStreamDtoNetworkArbitrumSepolia   CreateStreamDtoNetwork = "arbitrum-sepolia"
	CreateStreamDtoNetworkArcTestnet        CreateStreamDtoNetwork = "arc-testnet"
	CreateStreamDtoNetworkAvalancheFuji     CreateStreamDtoNetwork = "avalanche-fuji"
	CreateStreamDtoNetworkAvalancheMainnet  CreateStreamDtoNetwork = "avalanche-mainnet"
	CreateStreamDtoNetworkB3Mainnet         CreateStreamDtoNetwork = "b3-mainnet"
	CreateStreamDtoNetworkB3Sepolia         CreateStreamDtoNetwork = "b3-sepolia"
	CreateStreamDtoNetworkBaseMainnet       CreateStreamDtoNetwork = "base-mainnet"
	CreateStreamDtoNetworkBaseSepolia       CreateStreamDtoNetwork = "base-sepolia"
	CreateStreamDtoNetworkBchMainnet        CreateStreamDtoNetwork = "bch-mainnet"
	CreateStreamDtoNetworkBchTestnet        CreateStreamDtoNetwork = "bch-testnet"
	CreateStreamDtoNetworkBeraBepolia       CreateStreamDtoNetwork = "bera-bepolia"
	CreateStreamDtoNetworkBeraMainnet       CreateStreamDtoNetwork = "bera-mainnet"
	CreateStreamDtoNetworkBitcoinMainnet    CreateStreamDtoNetwork = "bitcoin-mainnet"
	CreateStreamDtoNetworkBitcoinTestnet4   CreateStreamDtoNetwork = "bitcoin-testnet4"
	CreateStreamDtoNetworkBlastMainnet      CreateStreamDtoNetwork = "blast-mainnet"
	CreateStreamDtoNetworkBlastSepolia      CreateStreamDtoNetwork = "blast-sepolia"
	CreateStreamDtoNetworkBnbchainMainnet   CreateStreamDtoNetwork = "bnbchain-mainnet"
	CreateStreamDtoNetworkBnbchainTestnet   CreateStreamDtoNetwork = "bnbchain-testnet"
	CreateStreamDtoNetworkCeloMainnet       CreateStreamDtoNetwork = "celo-mainnet"
	CreateStreamDtoNetworkCyberMainnet      CreateStreamDtoNetwork = "cyber-mainnet"
	CreateStreamDtoNetworkCyberSepolia      CreateStreamDtoNetwork = "cyber-sepolia"
	CreateStreamDtoNetworkDogeMainnet       CreateStreamDtoNetwork = "doge-mainnet"
	CreateStreamDtoNetworkEthereumHoodi     CreateStreamDtoNetwork = "ethereum-hoodi"
	CreateStreamDtoNetworkEthereumMainnet   CreateStreamDtoNetwork = "ethereum-mainnet"
	CreateStreamDtoNetworkEthereumSepolia   CreateStreamDtoNetwork = "ethereum-sepolia"
	CreateStreamDtoNetworkFantomMainnet     CreateStreamDtoNetwork = "fantom-mainnet"
	CreateStreamDtoNetworkFlareMainnet      CreateStreamDtoNetwork = "flare-mainnet"
	CreateStreamDtoNetworkFlareTestnet      CreateStreamDtoNetwork = "flare-testnet"
	CreateStreamDtoNetworkFlowMainnet       CreateStreamDtoNetwork = "flow-mainnet"
	CreateStreamDtoNetworkFlowTestnet       CreateStreamDtoNetwork = "flow-testnet"
	CreateStreamDtoNetworkFraxtalMainnet    CreateStreamDtoNetwork = "fraxtal-mainnet"
	CreateStreamDtoNetworkGnosisMainnet     CreateStreamDtoNetwork = "gnosis-mainnet"
	CreateStreamDtoNetworkGravityAlpham     CreateStreamDtoNetwork = "gravity-alpham"
	CreateStreamDtoNetworkHemiMainnet       CreateStreamDtoNetwork = "hemi-mainnet"
	CreateStreamDtoNetworkHemiTestnet       CreateStreamDtoNetwork = "hemi-testnet"
	CreateStreamDtoNetworkHyperevmMainnet   CreateStreamDtoNetwork = "hyperevm-mainnet"
	CreateStreamDtoNetworkImxMainnet        CreateStreamDtoNetwork = "imx-mainnet"
	CreateStreamDtoNetworkImxTestnet        CreateStreamDtoNetwork = "imx-testnet"
	CreateStreamDtoNetworkInjectiveMainnet  CreateStreamDtoNetwork = "injective-mainnet"
	CreateStreamDtoNetworkInjectiveTestnet  CreateStreamDtoNetwork = "injective-testnet"
	CreateStreamDtoNetworkInkMainnet        CreateStreamDtoNetwork = "ink-mainnet"
	CreateStreamDtoNetworkInkSepolia        CreateStreamDtoNetwork = "ink-sepolia"
	CreateStreamDtoNetworkJocMainnet        CreateStreamDtoNetwork = "joc-mainnet"
	CreateStreamDtoNetworkKaiaMainnet       CreateStreamDtoNetwork = "kaia-mainnet"
	CreateStreamDtoNetworkKaiaTestnet       CreateStreamDtoNetwork = "kaia-testnet"
	CreateStreamDtoNetworkKatanaMainnet     CreateStreamDtoNetwork = "katana-mainnet"
	CreateStreamDtoNetworkLensMainnet       CreateStreamDtoNetwork = "lens-mainnet"
	CreateStreamDtoNetworkLensTestnet       CreateStreamDtoNetwork = "lens-testnet"
	CreateStreamDtoNetworkLineaMainnet      CreateStreamDtoNetwork = "linea-mainnet"
	CreateStreamDtoNetworkLiskMainnet       CreateStreamDtoNetwork = "lisk-mainnet"
	CreateStreamDtoNetworkLitecoinMainnet   CreateStreamDtoNetwork = "litecoin-mainnet"
	CreateStreamDtoNetworkLitecoinTestnet   CreateStreamDtoNetwork = "litecoin-testnet"
	CreateStreamDtoNetworkMantleMainnet     CreateStreamDtoNetwork = "mantle-mainnet"
	CreateStreamDtoNetworkMantleSepolia     CreateStreamDtoNetwork = "mantle-sepolia"
	CreateStreamDtoNetworkModeMainnet       CreateStreamDtoNetwork = "mode-mainnet"
	CreateStreamDtoNetworkMonadMainnet      CreateStreamDtoNetwork = "monad-mainnet"
	CreateStreamDtoNetworkMonadTestnet      CreateStreamDtoNetwork = "monad-testnet"
	CreateStreamDtoNetworkMorphHoodi        CreateStreamDtoNetwork = "morph-hoodi"
	CreateStreamDtoNetworkMorphMainnet      CreateStreamDtoNetwork = "morph-mainnet"
	CreateStreamDtoNetworkNovaMainnet       CreateStreamDtoNetwork = "nova-mainnet"
	CreateStreamDtoNetworkOmniMainnet       CreateStreamDtoNetwork = "omni-mainnet"
	CreateStreamDtoNetworkOmniOmega         CreateStreamDtoNetwork = "omni-omega"
	CreateStreamDtoNetworkOptimismMainnet   CreateStreamDtoNetwork = "optimism-mainnet"
	CreateStreamDtoNetworkOptimismSepolia   CreateStreamDtoNetwork = "optimism-sepolia"
	CreateStreamDtoNetworkPeaqMainnet       CreateStreamDtoNetwork = "peaq-mainnet"
	CreateStreamDtoNetworkPlasmaMainnet     CreateStreamDtoNetwork = "plasma-mainnet"
	CreateStreamDtoNetworkPlasmaTestnet     CreateStreamDtoNetwork = "plasma-testnet"
	CreateStreamDtoNetworkPolygonAmoy       CreateStreamDtoNetwork = "polygon-amoy"
	CreateStreamDtoNetworkPolygonMainnet    CreateStreamDtoNetwork = "polygon-mainnet"
	CreateStreamDtoNetworkRedstoneMainnet   CreateStreamDtoNetwork = "redstone-mainnet"
	CreateStreamDtoNetworkSaharaTestnet     CreateStreamDtoNetwork = "sahara-testnet"
	CreateStreamDtoNetworkScrollMainnet     CreateStreamDtoNetwork = "scroll-mainnet"
	CreateStreamDtoNetworkScrollTestnet     CreateStreamDtoNetwork = "scroll-testnet"
	CreateStreamDtoNetworkSeiMainnet        CreateStreamDtoNetwork = "sei-mainnet"
	CreateStreamDtoNetworkSeiTestnet        CreateStreamDtoNetwork = "sei-testnet"
	CreateStreamDtoNetworkSolanaDevnet      CreateStreamDtoNetwork = "solana-devnet"
	CreateStreamDtoNetworkSolanaMainnet     CreateStreamDtoNetwork = "solana-mainnet"
	CreateStreamDtoNetworkSolanaTestnet     CreateStreamDtoNetwork = "solana-testnet"
	CreateStreamDtoNetworkSoneiumMainnet    CreateStreamDtoNetwork = "soneium-mainnet"
	CreateStreamDtoNetworkSonicMainnet      CreateStreamDtoNetwork = "sonic-mainnet"
	CreateStreamDtoNetworkSophonMainnet     CreateStreamDtoNetwork = "sophon-mainnet"
	CreateStreamDtoNetworkSophonTestnet     CreateStreamDtoNetwork = "sophon-testnet"
	CreateStreamDtoNetworkStoryAeneid       CreateStreamDtoNetwork = "story-aeneid"
	CreateStreamDtoNetworkStoryMainnet      CreateStreamDtoNetwork = "story-mainnet"
	CreateStreamDtoNetworkTronMainnet       CreateStreamDtoNetwork = "tron-mainnet"
	CreateStreamDtoNetworkUnichainMainnet   CreateStreamDtoNetwork = "unichain-mainnet"
	CreateStreamDtoNetworkUnichainSepolia   CreateStreamDtoNetwork = "unichain-sepolia"
	CreateStreamDtoNetworkVanaMainnet       CreateStreamDtoNetwork = "vana-mainnet"
	CreateStreamDtoNetworkVanaMoksha        CreateStreamDtoNetwork = "vana-moksha"
	CreateStreamDtoNetworkWorldchainMainnet CreateStreamDtoNetwork = "worldchain-mainnet"
	CreateStreamDtoNetworkWorldchainSepolia CreateStreamDtoNetwork = "worldchain-sepolia"
	CreateStreamDtoNetworkXaiMainnet        CreateStreamDtoNetwork = "xai-mainnet"
	CreateStreamDtoNetworkXaiSepolia        CreateStreamDtoNetwork = "xai-sepolia"
	CreateStreamDtoNetworkXlayerMainnet     CreateStreamDtoNetwork = "xlayer-mainnet"
	CreateStreamDtoNetworkXrpMainnet        CreateStreamDtoNetwork = "xrp-mainnet"
	CreateStreamDtoNetworkXrpTestnet        CreateStreamDtoNetwork = "xrp-testnet"
	CreateStreamDtoNetworkXrplevmMainnet    CreateStreamDtoNetwork = "xrplevm-mainnet"
	CreateStreamDtoNetworkXrplevmTestnet    CreateStreamDtoNetwork = "xrplevm-testnet"
	CreateStreamDtoNetworkZerogGalileo      CreateStreamDtoNetwork = "zerog-galileo"
	CreateStreamDtoNetworkZerogMainnet      CreateStreamDtoNetwork = "zerog-mainnet"
	CreateStreamDtoNetworkZkevmCardona      CreateStreamDtoNetwork = "zkevm-cardona"
	CreateStreamDtoNetworkZkevmMainnet      CreateStreamDtoNetwork = "zkevm-mainnet"
	CreateStreamDtoNetworkZksyncMainnet     CreateStreamDtoNetwork = "zksync-mainnet"
	CreateStreamDtoNetworkZksyncSepolia     CreateStreamDtoNetwork = "zksync-sepolia"
	CreateStreamDtoNetworkZoraMainnet       CreateStreamDtoNetwork = "zora-mainnet"
)

Defines values for CreateStreamDtoNetwork.

type CreateStreamDtoRegion 

type CreateStreamDtoRegion string

CreateStreamDtoRegion defines model for CreateStreamDto.Region. 

const (
	AsiaEast      CreateStreamDtoRegion = "asia_east"
	EuropeCentral CreateStreamDtoRegion = "europe_central"
	UsaEast       CreateStreamDtoRegion = "usa_east"
)

Defines values for CreateStreamDtoRegion.

type CreateStreamDtoStatus 

type CreateStreamDtoStatus string

CreateStreamDtoStatus defines model for CreateStreamDto.Status. 

const (
	CreateStreamDtoStatusActive CreateStreamDtoStatus = "active"
	CreateStreamDtoStatusPaused CreateStreamDtoStatus = "paused"
)

Defines values for CreateStreamDtoStatus.

type CreateStreamDto_DestinationAttributes 

type CreateStreamDto_DestinationAttributes struct {
	// contains filtered or unexported fields
}

CreateStreamDto_DestinationAttributes defines model for CreateStreamDto.DestinationAttributes.

func (CreateStreamDto_DestinationAttributes) AsAzureAttributes added in v0.6.2 

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

AsAzureAttributes returns the union data inside the CreateStreamDto_DestinationAttributes as a AzureAttributes

func (CreateStreamDto_DestinationAttributes) AsPostgresAttributes 

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

AsPostgresAttributes returns the union data inside the CreateStreamDto_DestinationAttributes as a PostgresAttributes

func (CreateStreamDto_DestinationAttributes) AsQuickfunctionsAttributes 

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

AsQuickfunctionsAttributes returns the union data inside the CreateStreamDto_DestinationAttributes as a QuickfunctionsAttributes

func (CreateStreamDto_DestinationAttributes) AsS3Attributes 

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

AsS3Attributes returns the union data inside the CreateStreamDto_DestinationAttributes as a S3Attributes

func (CreateStreamDto_DestinationAttributes) AsWebhookAttributes 

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

AsWebhookAttributes returns the union data inside the CreateStreamDto_DestinationAttributes as a WebhookAttributes

func (*CreateStreamDto_DestinationAttributes) FromAzureAttributes added in v0.6.2 

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

FromAzureAttributes overwrites any union data inside the CreateStreamDto_DestinationAttributes as the provided AzureAttributes

func (*CreateStreamDto_DestinationAttributes) FromPostgresAttributes 

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

FromPostgresAttributes overwrites any union data inside the CreateStreamDto_DestinationAttributes as the provided PostgresAttributes

func (*CreateStreamDto_DestinationAttributes) FromQuickfunctionsAttributes 

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

FromQuickfunctionsAttributes overwrites any union data inside the CreateStreamDto_DestinationAttributes as the provided QuickfunctionsAttributes

func (*CreateStreamDto_DestinationAttributes) FromS3Attributes 

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

FromS3Attributes overwrites any union data inside the CreateStreamDto_DestinationAttributes as the provided S3Attributes

func (*CreateStreamDto_DestinationAttributes) FromWebhookAttributes 

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

FromWebhookAttributes overwrites any union data inside the CreateStreamDto_DestinationAttributes as the provided WebhookAttributes

func (CreateStreamDto_DestinationAttributes) MarshalJSON 

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

func (*CreateStreamDto_DestinationAttributes) MergeAzureAttributes added in v0.6.2 

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

MergeAzureAttributes performs a merge with any union data inside the CreateStreamDto_DestinationAttributes, using the provided AzureAttributes

func (*CreateStreamDto_DestinationAttributes) MergePostgresAttributes 

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

MergePostgresAttributes performs a merge with any union data inside the CreateStreamDto_DestinationAttributes, using the provided PostgresAttributes

func (*CreateStreamDto_DestinationAttributes) MergeQuickfunctionsAttributes 

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

MergeQuickfunctionsAttributes performs a merge with any union data inside the CreateStreamDto_DestinationAttributes, using the provided QuickfunctionsAttributes

func (*CreateStreamDto_DestinationAttributes) MergeS3Attributes 

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

MergeS3Attributes performs a merge with any union data inside the CreateStreamDto_DestinationAttributes, using the provided S3Attributes

func (*CreateStreamDto_DestinationAttributes) MergeWebhookAttributes 

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

MergeWebhookAttributes performs a merge with any union data inside the CreateStreamDto_DestinationAttributes, using the provided WebhookAttributes

func (*CreateStreamDto_DestinationAttributes) UnmarshalJSON 

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

type FindAllParams 

type FindAllParams struct {
	Limit  float32 `form:"limit" json:"limit"`
	Offset float32 `form:"offset" json:"offset"`
}

FindAllParams defines parameters for FindAll.

type FindAllResponse 

type FindAllResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

func ParseFindAllResponse 

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

ParseFindAllResponse parses an HTTP response from a FindAllWithResponse call

func (FindAllResponse) Status 

func (r FindAllResponse) Status() string

Status returns HTTPResponse.Status

func (FindAllResponse) StatusCode 

func (r FindAllResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type FindOneResponse 

type FindOneResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

func ParseFindOneResponse 

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

ParseFindOneResponse parses an HTTP response from a FindOneWithResponse call

func (FindOneResponse) Status 

func (r FindOneResponse) Status() string

Status returns HTTPResponse.Status

func (FindOneResponse) StatusCode 

func (r FindOneResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type GetEnabledStreamsResponse 

type GetEnabledStreamsResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

func ParseGetEnabledStreamsResponse 

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

ParseGetEnabledStreamsResponse parses an HTTP response from a GetEnabledStreamsWithResponse call

func (GetEnabledStreamsResponse) Status 

func (r GetEnabledStreamsResponse) Status() string

Status returns HTTPResponse.Status

func (GetEnabledStreamsResponse) StatusCode 

func (r GetEnabledStreamsResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type HttpRequestDoer 

type HttpRequestDoer interface {
	Do(req *http.Request) (*http.Response, error)
}

Doer performs HTTP requests.

The standard http.Client implements this interface.

type PauseStreamResponse 

type PauseStreamResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

func ParsePauseStreamResponse 

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

ParsePauseStreamResponse parses an HTTP response from a PauseStreamWithResponse call

func (PauseStreamResponse) Status 

func (r PauseStreamResponse) Status() string

Status returns HTTPResponse.Status

func (PauseStreamResponse) StatusCode 

func (r PauseStreamResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type PostgresAttributes 

type PostgresAttributes struct {
	AccessKey        string                    `json:"access_key"`
	Database         string                    `json:"database"`
	Host             string                    `json:"host"`
	MaxRetry         float32                   `json:"max_retry"`
	Password         string                    `json:"password"`
	Port             float32                   `json:"port"`
	RetryIntervalSec float32                   `json:"retry_interval_sec"`
	Sslmode          PostgresAttributesSslmode `json:"sslmode"`
	TableName        string                    `json:"table_name"`
	Username         string                    `json:"username"`
}

PostgresAttributes defines model for PostgresAttributes.

type PostgresAttributesSslmode 

type PostgresAttributesSslmode string

PostgresAttributesSslmode defines model for PostgresAttributes.Sslmode. 

const (
	Disable PostgresAttributesSslmode = "disable"
	Require PostgresAttributesSslmode = "require"
)

Defines values for PostgresAttributesSslmode.

type QuickfunctionsAttributes 

type QuickfunctionsAttributes struct {
	Headers          map[string]interface{} `json:"headers"`
	MaxRetry         float32                `json:"max_retry"`
	Name             string                 `json:"name"`
	Namespace        string                 `json:"namespace"`
	PostTimeoutSec   float32                `json:"post_timeout_sec"`
	RetryIntervalSec float32                `json:"retry_interval_sec"`
	SecurityToken    string                 `json:"security_token"`
}

QuickfunctionsAttributes defines model for QuickfunctionsAttributes.

type RemoveResponse 

type RemoveResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

func ParseRemoveResponse 

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

ParseRemoveResponse parses an HTTP response from a RemoveWithResponse call

func (RemoveResponse) Status 

func (r RemoveResponse) Status() string

Status returns HTTPResponse.Status

func (RemoveResponse) StatusCode 

func (r RemoveResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type RemoveStreamsByAccountIdResponse 

type RemoveStreamsByAccountIdResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

func ParseRemoveStreamsByAccountIdResponse 

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

ParseRemoveStreamsByAccountIdResponse parses an HTTP response from a RemoveStreamsByAccountIdWithResponse call

func (RemoveStreamsByAccountIdResponse) Status 

func (r RemoveStreamsByAccountIdResponse) Status() string

Status returns HTTPResponse.Status

func (RemoveStreamsByAccountIdResponse) StatusCode 

func (r RemoveStreamsByAccountIdResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type RequestEditorFn 

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

RequestEditorFn is the function signature for the RequestEditor callback function

type S3Attributes 

type S3Attributes struct {
	AccessKey        string               `json:"access_key"`
	Bucket           string               `json:"bucket"`
	Endpoint         string               `json:"endpoint"`
	FileCompression  string               `json:"file_compression"`
	FileType         S3AttributesFileType `json:"file_type"`
	MaxRetry         float32              `json:"max_retry"`
	ObjectPrefix     string               `json:"object_prefix"`
	RetryIntervalSec float32              `json:"retry_interval_sec"`
	SecretKey        string               `json:"secret_key"`
	UseSsl           bool                 `json:"use_ssl"`
}

S3Attributes defines model for S3Attributes.

type S3AttributesFileType 

type S3AttributesFileType string

S3AttributesFileType defines model for S3Attributes.FileType. 

const (
	S3AttributesFileTypeDotJson    S3AttributesFileType = ".json"
	S3AttributesFileTypeDotParquet S3AttributesFileType = ".parquet"
)

Defines values for S3AttributesFileType.

type TestFilterFunctionDto 

type TestFilterFunctionDto struct {
	Block   string                       `json:"block"`
	Dataset TestFilterFunctionDtoDataset `json:"dataset"`

	// FilterFunction JS/ECMAScript compliant filter encoded in base64
	FilterFunction string                       `json:"filter_function"`
	Network        TestFilterFunctionDtoNetwork `json:"network"`
}

TestFilterFunctionDto defines model for TestFilterFunctionDto.

type TestFilterFunctionDtoDataset 

type TestFilterFunctionDtoDataset string

TestFilterFunctionDtoDataset defines model for TestFilterFunctionDto.Dataset. 

const (
	TestFilterFunctionDtoDatasetBlock                       TestFilterFunctionDtoDataset = "block"
	TestFilterFunctionDtoDatasetBlockWithReceipts           TestFilterFunctionDtoDataset = "block_with_receipts"
	TestFilterFunctionDtoDatasetBlockWithReceiptsDebugTrace TestFilterFunctionDtoDataset = "block_with_receipts_debug_trace"
	TestFilterFunctionDtoDatasetBlockWithReceiptsTraceBlock TestFilterFunctionDtoDataset = "block_with_receipts_trace_block"
	TestFilterFunctionDtoDatasetDebugTraces                 TestFilterFunctionDtoDataset = "debug_traces"
	TestFilterFunctionDtoDatasetLedger                      TestFilterFunctionDtoDataset = "ledger"
	TestFilterFunctionDtoDatasetLogs                        TestFilterFunctionDtoDataset = "logs"
	TestFilterFunctionDtoDatasetProgramsWithLogs            TestFilterFunctionDtoDataset = "programs_with_logs"
	TestFilterFunctionDtoDatasetReceipts                    TestFilterFunctionDtoDataset = "receipts"
	TestFilterFunctionDtoDatasetTraceBlocks                 TestFilterFunctionDtoDataset = "trace_blocks"
	TestFilterFunctionDtoDatasetTransactions                TestFilterFunctionDtoDataset = "transactions"
)

Defines values for TestFilterFunctionDtoDataset.

type TestFilterFunctionDtoNetwork 

type TestFilterFunctionDtoNetwork string

TestFilterFunctionDtoNetwork defines model for TestFilterFunctionDto.Network. 

const (
	TestFilterFunctionDtoNetworkAbstractMainnet   TestFilterFunctionDtoNetwork = "abstract-mainnet"
	TestFilterFunctionDtoNetworkAbstractTestnet   TestFilterFunctionDtoNetwork = "abstract-testnet"
	TestFilterFunctionDtoNetworkArbitrumMainnet   TestFilterFunctionDtoNetwork = "arbitrum-mainnet"
	TestFilterFunctionDtoNetworkArbitrumSepolia   TestFilterFunctionDtoNetwork = "arbitrum-sepolia"
	TestFilterFunctionDtoNetworkArcTestnet        TestFilterFunctionDtoNetwork = "arc-testnet"
	TestFilterFunctionDtoNetworkAvalancheFuji     TestFilterFunctionDtoNetwork = "avalanche-fuji"
	TestFilterFunctionDtoNetworkAvalancheMainnet  TestFilterFunctionDtoNetwork = "avalanche-mainnet"
	TestFilterFunctionDtoNetworkB3Mainnet         TestFilterFunctionDtoNetwork = "b3-mainnet"
	TestFilterFunctionDtoNetworkB3Sepolia         TestFilterFunctionDtoNetwork = "b3-sepolia"
	TestFilterFunctionDtoNetworkBaseMainnet       TestFilterFunctionDtoNetwork = "base-mainnet"
	TestFilterFunctionDtoNetworkBaseSepolia       TestFilterFunctionDtoNetwork = "base-sepolia"
	TestFilterFunctionDtoNetworkBchMainnet        TestFilterFunctionDtoNetwork = "bch-mainnet"
	TestFilterFunctionDtoNetworkBchTestnet        TestFilterFunctionDtoNetwork = "bch-testnet"
	TestFilterFunctionDtoNetworkBeraBepolia       TestFilterFunctionDtoNetwork = "bera-bepolia"
	TestFilterFunctionDtoNetworkBeraMainnet       TestFilterFunctionDtoNetwork = "bera-mainnet"
	TestFilterFunctionDtoNetworkBitcoinMainnet    TestFilterFunctionDtoNetwork = "bitcoin-mainnet"
	TestFilterFunctionDtoNetworkBitcoinTestnet4   TestFilterFunctionDtoNetwork = "bitcoin-testnet4"
	TestFilterFunctionDtoNetworkBlastMainnet      TestFilterFunctionDtoNetwork = "blast-mainnet"
	TestFilterFunctionDtoNetworkBlastSepolia      TestFilterFunctionDtoNetwork = "blast-sepolia"
	TestFilterFunctionDtoNetworkBnbchainMainnet   TestFilterFunctionDtoNetwork = "bnbchain-mainnet"
	TestFilterFunctionDtoNetworkBnbchainTestnet   TestFilterFunctionDtoNetwork = "bnbchain-testnet"
	TestFilterFunctionDtoNetworkCeloMainnet       TestFilterFunctionDtoNetwork = "celo-mainnet"
	TestFilterFunctionDtoNetworkCyberMainnet      TestFilterFunctionDtoNetwork = "cyber-mainnet"
	TestFilterFunctionDtoNetworkCyberSepolia      TestFilterFunctionDtoNetwork = "cyber-sepolia"
	TestFilterFunctionDtoNetworkDogeMainnet       TestFilterFunctionDtoNetwork = "doge-mainnet"
	TestFilterFunctionDtoNetworkEthereumHoodi     TestFilterFunctionDtoNetwork = "ethereum-hoodi"
	TestFilterFunctionDtoNetworkEthereumMainnet   TestFilterFunctionDtoNetwork = "ethereum-mainnet"
	TestFilterFunctionDtoNetworkEthereumSepolia   TestFilterFunctionDtoNetwork = "ethereum-sepolia"
	TestFilterFunctionDtoNetworkFantomMainnet     TestFilterFunctionDtoNetwork = "fantom-mainnet"
	TestFilterFunctionDtoNetworkFlareMainnet      TestFilterFunctionDtoNetwork = "flare-mainnet"
	TestFilterFunctionDtoNetworkFlareTestnet      TestFilterFunctionDtoNetwork = "flare-testnet"
	TestFilterFunctionDtoNetworkFlowMainnet       TestFilterFunctionDtoNetwork = "flow-mainnet"
	TestFilterFunctionDtoNetworkFlowTestnet       TestFilterFunctionDtoNetwork = "flow-testnet"
	TestFilterFunctionDtoNetworkFraxtalMainnet    TestFilterFunctionDtoNetwork = "fraxtal-mainnet"
	TestFilterFunctionDtoNetworkGnosisMainnet     TestFilterFunctionDtoNetwork = "gnosis-mainnet"
	TestFilterFunctionDtoNetworkGravityAlpham     TestFilterFunctionDtoNetwork = "gravity-alpham"
	TestFilterFunctionDtoNetworkHemiMainnet       TestFilterFunctionDtoNetwork = "hemi-mainnet"
	TestFilterFunctionDtoNetworkHemiTestnet       TestFilterFunctionDtoNetwork = "hemi-testnet"
	TestFilterFunctionDtoNetworkHyperevmMainnet   TestFilterFunctionDtoNetwork = "hyperevm-mainnet"
	TestFilterFunctionDtoNetworkImxMainnet        TestFilterFunctionDtoNetwork = "imx-mainnet"
	TestFilterFunctionDtoNetworkImxTestnet        TestFilterFunctionDtoNetwork = "imx-testnet"
	TestFilterFunctionDtoNetworkInjectiveMainnet  TestFilterFunctionDtoNetwork = "injective-mainnet"
	TestFilterFunctionDtoNetworkInjectiveTestnet  TestFilterFunctionDtoNetwork = "injective-testnet"
	TestFilterFunctionDtoNetworkInkMainnet        TestFilterFunctionDtoNetwork = "ink-mainnet"
	TestFilterFunctionDtoNetworkInkSepolia        TestFilterFunctionDtoNetwork = "ink-sepolia"
	TestFilterFunctionDtoNetworkJocMainnet        TestFilterFunctionDtoNetwork = "joc-mainnet"
	TestFilterFunctionDtoNetworkKaiaMainnet       TestFilterFunctionDtoNetwork = "kaia-mainnet"
	TestFilterFunctionDtoNetworkKaiaTestnet       TestFilterFunctionDtoNetwork = "kaia-testnet"
	TestFilterFunctionDtoNetworkKatanaMainnet     TestFilterFunctionDtoNetwork = "katana-mainnet"
	TestFilterFunctionDtoNetworkLensMainnet       TestFilterFunctionDtoNetwork = "lens-mainnet"
	TestFilterFunctionDtoNetworkLensTestnet       TestFilterFunctionDtoNetwork = "lens-testnet"
	TestFilterFunctionDtoNetworkLineaMainnet      TestFilterFunctionDtoNetwork = "linea-mainnet"
	TestFilterFunctionDtoNetworkLiskMainnet       TestFilterFunctionDtoNetwork = "lisk-mainnet"
	TestFilterFunctionDtoNetworkLitecoinMainnet   TestFilterFunctionDtoNetwork = "litecoin-mainnet"
	TestFilterFunctionDtoNetworkLitecoinTestnet   TestFilterFunctionDtoNetwork = "litecoin-testnet"
	TestFilterFunctionDtoNetworkMantleMainnet     TestFilterFunctionDtoNetwork = "mantle-mainnet"
	TestFilterFunctionDtoNetworkMantleSepolia     TestFilterFunctionDtoNetwork = "mantle-sepolia"
	TestFilterFunctionDtoNetworkModeMainnet       TestFilterFunctionDtoNetwork = "mode-mainnet"
	TestFilterFunctionDtoNetworkMonadMainnet      TestFilterFunctionDtoNetwork = "monad-mainnet"
	TestFilterFunctionDtoNetworkMonadTestnet      TestFilterFunctionDtoNetwork = "monad-testnet"
	TestFilterFunctionDtoNetworkMorphHoodi        TestFilterFunctionDtoNetwork = "morph-hoodi"
	TestFilterFunctionDtoNetworkMorphMainnet      TestFilterFunctionDtoNetwork = "morph-mainnet"
	TestFilterFunctionDtoNetworkNovaMainnet       TestFilterFunctionDtoNetwork = "nova-mainnet"
	TestFilterFunctionDtoNetworkOmniMainnet       TestFilterFunctionDtoNetwork = "omni-mainnet"
	TestFilterFunctionDtoNetworkOmniOmega         TestFilterFunctionDtoNetwork = "omni-omega"
	TestFilterFunctionDtoNetworkOptimismMainnet   TestFilterFunctionDtoNetwork = "optimism-mainnet"
	TestFilterFunctionDtoNetworkOptimismSepolia   TestFilterFunctionDtoNetwork = "optimism-sepolia"
	TestFilterFunctionDtoNetworkPeaqMainnet       TestFilterFunctionDtoNetwork = "peaq-mainnet"
	TestFilterFunctionDtoNetworkPlasmaMainnet     TestFilterFunctionDtoNetwork = "plasma-mainnet"
	TestFilterFunctionDtoNetworkPlasmaTestnet     TestFilterFunctionDtoNetwork = "plasma-testnet"
	TestFilterFunctionDtoNetworkPolygonAmoy       TestFilterFunctionDtoNetwork = "polygon-amoy"
	TestFilterFunctionDtoNetworkPolygonMainnet    TestFilterFunctionDtoNetwork = "polygon-mainnet"
	TestFilterFunctionDtoNetworkRedstoneMainnet   TestFilterFunctionDtoNetwork = "redstone-mainnet"
	TestFilterFunctionDtoNetworkSaharaTestnet     TestFilterFunctionDtoNetwork = "sahara-testnet"
	TestFilterFunctionDtoNetworkScrollMainnet     TestFilterFunctionDtoNetwork = "scroll-mainnet"
	TestFilterFunctionDtoNetworkScrollTestnet     TestFilterFunctionDtoNetwork = "scroll-testnet"
	TestFilterFunctionDtoNetworkSeiMainnet        TestFilterFunctionDtoNetwork = "sei-mainnet"
	TestFilterFunctionDtoNetworkSeiTestnet        TestFilterFunctionDtoNetwork = "sei-testnet"
	TestFilterFunctionDtoNetworkSolanaDevnet      TestFilterFunctionDtoNetwork = "solana-devnet"
	TestFilterFunctionDtoNetworkSolanaMainnet     TestFilterFunctionDtoNetwork = "solana-mainnet"
	TestFilterFunctionDtoNetworkSolanaTestnet     TestFilterFunctionDtoNetwork = "solana-testnet"
	TestFilterFunctionDtoNetworkSoneiumMainnet    TestFilterFunctionDtoNetwork = "soneium-mainnet"
	TestFilterFunctionDtoNetworkSonicMainnet      TestFilterFunctionDtoNetwork = "sonic-mainnet"
	TestFilterFunctionDtoNetworkSophonMainnet     TestFilterFunctionDtoNetwork = "sophon-mainnet"
	TestFilterFunctionDtoNetworkSophonTestnet     TestFilterFunctionDtoNetwork = "sophon-testnet"
	TestFilterFunctionDtoNetworkStoryAeneid       TestFilterFunctionDtoNetwork = "story-aeneid"
	TestFilterFunctionDtoNetworkStoryMainnet      TestFilterFunctionDtoNetwork = "story-mainnet"
	TestFilterFunctionDtoNetworkTronMainnet       TestFilterFunctionDtoNetwork = "tron-mainnet"
	TestFilterFunctionDtoNetworkUnichainMainnet   TestFilterFunctionDtoNetwork = "unichain-mainnet"
	TestFilterFunctionDtoNetworkUnichainSepolia   TestFilterFunctionDtoNetwork = "unichain-sepolia"
	TestFilterFunctionDtoNetworkVanaMainnet       TestFilterFunctionDtoNetwork = "vana-mainnet"
	TestFilterFunctionDtoNetworkVanaMoksha        TestFilterFunctionDtoNetwork = "vana-moksha"
	TestFilterFunctionDtoNetworkWorldchainMainnet TestFilterFunctionDtoNetwork = "worldchain-mainnet"
	TestFilterFunctionDtoNetworkWorldchainSepolia TestFilterFunctionDtoNetwork = "worldchain-sepolia"
	TestFilterFunctionDtoNetworkXaiMainnet        TestFilterFunctionDtoNetwork = "xai-mainnet"
	TestFilterFunctionDtoNetworkXaiSepolia        TestFilterFunctionDtoNetwork = "xai-sepolia"
	TestFilterFunctionDtoNetworkXlayerMainnet     TestFilterFunctionDtoNetwork = "xlayer-mainnet"
	TestFilterFunctionDtoNetworkXrpMainnet        TestFilterFunctionDtoNetwork = "xrp-mainnet"
	TestFilterFunctionDtoNetworkXrpTestnet        TestFilterFunctionDtoNetwork = "xrp-testnet"
	TestFilterFunctionDtoNetworkXrplevmMainnet    TestFilterFunctionDtoNetwork = "xrplevm-mainnet"
	TestFilterFunctionDtoNetworkXrplevmTestnet    TestFilterFunctionDtoNetwork = "xrplevm-testnet"
	TestFilterFunctionDtoNetworkZerogGalileo      TestFilterFunctionDtoNetwork = "zerog-galileo"
	TestFilterFunctionDtoNetworkZerogMainnet      TestFilterFunctionDtoNetwork = "zerog-mainnet"
	TestFilterFunctionDtoNetworkZkevmCardona      TestFilterFunctionDtoNetwork = "zkevm-cardona"
	TestFilterFunctionDtoNetworkZkevmMainnet      TestFilterFunctionDtoNetwork = "zkevm-mainnet"
	TestFilterFunctionDtoNetworkZksyncMainnet     TestFilterFunctionDtoNetwork = "zksync-mainnet"
	TestFilterFunctionDtoNetworkZksyncSepolia     TestFilterFunctionDtoNetwork = "zksync-sepolia"
	TestFilterFunctionDtoNetworkZoraMainnet       TestFilterFunctionDtoNetwork = "zora-mainnet"
)

Defines values for TestFilterFunctionDtoNetwork.

type TestFilterFunctionJSONRequestBody 

type TestFilterFunctionJSONRequestBody = TestFilterFunctionDto

TestFilterFunctionJSONRequestBody defines body for TestFilterFunction for application/json ContentType.

type TestFilterFunctionResponse 

type TestFilterFunctionResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

func ParseTestFilterFunctionResponse 

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

ParseTestFilterFunctionResponse parses an HTTP response from a TestFilterFunctionWithResponse call

func (TestFilterFunctionResponse) Status 

func (r TestFilterFunctionResponse) Status() string

Status returns HTTPResponse.Status

func (TestFilterFunctionResponse) StatusCode 

func (r TestFilterFunctionResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type UpdateJSONRequestBody 

type UpdateJSONRequestBody = UpdateStreamDto

UpdateJSONRequestBody defines body for Update for application/json ContentType.

type UpdateResponse 

type UpdateResponse struct {
	Body         []byte
	HTTPResponse *http.Response
}

func ParseUpdateResponse 

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

ParseUpdateResponse parses an HTTP response from a UpdateWithResponse call

func (UpdateResponse) Status 

func (r UpdateResponse) Status() string

Status returns HTTPResponse.Status

func (UpdateResponse) StatusCode 

func (r UpdateResponse) StatusCode() int

StatusCode returns HTTPResponse.StatusCode

type UpdateStreamDto 

type UpdateStreamDto struct {
	DatasetBatchSize      *float32                               `json:"dataset_batch_size,omitempty"`
	Destination           *UpdateStreamDtoDestination            `json:"destination,omitempty"`
	DestinationAttributes *UpdateStreamDto_DestinationAttributes `json:"destination_attributes,omitempty"`
	ElasticBatchEnabled   *bool                                  `json:"elastic_batch_enabled,omitempty"`

	// EndRange Stream until block number
	EndRange *int `json:"end_range,omitempty"`

	// FilterFunction JS/ECMAScript compliant filter encoded in base64
	FilterFunction *string `json:"filter_function,omitempty"`

	// FixBlockReorgs Fix block reorgs by streaming correct blocks: 1. Ignore reorgs: 0
	FixBlockReorgs        *float32                              `json:"fix_block_reorgs,omitempty"`
	IncludeStreamMetadata *UpdateStreamDtoIncludeStreamMetadata `json:"include_stream_metadata,omitempty"`

	// KeepDistanceFromTip Stay away from tip by N blocks
	KeepDistanceFromTip *float32 `json:"keep_distance_from_tip,omitempty"`
	Name                *string  `json:"name,omitempty"`

	// NotificationEmail Notify when stream is terminated
	NotificationEmail *string `json:"notification_email,omitempty"`

	// StartRange Stream start at block number. If not provided, the stream will start at the latest block.
	StartRange *int                   `json:"start_range,omitempty"`
	Status     *UpdateStreamDtoStatus `json:"status,omitempty"`
}

UpdateStreamDto defines model for UpdateStreamDto.

type UpdateStreamDtoDestination 

type UpdateStreamDtoDestination string

UpdateStreamDtoDestination defines model for UpdateStreamDto.Destination. 

const (
	UpdateStreamDtoDestinationAzure    UpdateStreamDtoDestination = "azure"
	UpdateStreamDtoDestinationFunction UpdateStreamDtoDestination = "function"
	UpdateStreamDtoDestinationPostgres UpdateStreamDtoDestination = "postgres"
	UpdateStreamDtoDestinationS3       UpdateStreamDtoDestination = "s3"
	UpdateStreamDtoDestinationWebhook  UpdateStreamDtoDestination = "webhook"
)

Defines values for UpdateStreamDtoDestination.

type UpdateStreamDtoIncludeStreamMetadata 

type UpdateStreamDtoIncludeStreamMetadata string

UpdateStreamDtoIncludeStreamMetadata defines model for UpdateStreamDto.IncludeStreamMetadata. 

const (
	UpdateStreamDtoIncludeStreamMetadataBody   UpdateStreamDtoIncludeStreamMetadata = "body"
	UpdateStreamDtoIncludeStreamMetadataHeader UpdateStreamDtoIncludeStreamMetadata = "header"
	UpdateStreamDtoIncludeStreamMetadataNone   UpdateStreamDtoIncludeStreamMetadata = "none"
)

Defines values for UpdateStreamDtoIncludeStreamMetadata.

type UpdateStreamDtoStatus 

type UpdateStreamDtoStatus string

UpdateStreamDtoStatus defines model for UpdateStreamDto.Status. 

const (
	UpdateStreamDtoStatusActive UpdateStreamDtoStatus = "active"
	UpdateStreamDtoStatusPaused UpdateStreamDtoStatus = "paused"
)

Defines values for UpdateStreamDtoStatus.

type UpdateStreamDto_DestinationAttributes 

type UpdateStreamDto_DestinationAttributes struct {
	// contains filtered or unexported fields
}

UpdateStreamDto_DestinationAttributes defines model for UpdateStreamDto.DestinationAttributes.

func (UpdateStreamDto_DestinationAttributes) AsAzureAttributes added in v0.6.2 

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

AsAzureAttributes returns the union data inside the UpdateStreamDto_DestinationAttributes as a AzureAttributes

func (UpdateStreamDto_DestinationAttributes) AsPostgresAttributes 

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

AsPostgresAttributes returns the union data inside the UpdateStreamDto_DestinationAttributes as a PostgresAttributes

func (UpdateStreamDto_DestinationAttributes) AsQuickfunctionsAttributes 

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

AsQuickfunctionsAttributes returns the union data inside the UpdateStreamDto_DestinationAttributes as a QuickfunctionsAttributes

func (UpdateStreamDto_DestinationAttributes) AsS3Attributes 

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

AsS3Attributes returns the union data inside the UpdateStreamDto_DestinationAttributes as a S3Attributes

func (UpdateStreamDto_DestinationAttributes) AsWebhookAttributes 

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

AsWebhookAttributes returns the union data inside the UpdateStreamDto_DestinationAttributes as a WebhookAttributes

func (*UpdateStreamDto_DestinationAttributes) FromAzureAttributes added in v0.6.2 

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

FromAzureAttributes overwrites any union data inside the UpdateStreamDto_DestinationAttributes as the provided AzureAttributes

func (*UpdateStreamDto_DestinationAttributes) FromPostgresAttributes 

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

FromPostgresAttributes overwrites any union data inside the UpdateStreamDto_DestinationAttributes as the provided PostgresAttributes

func (*UpdateStreamDto_DestinationAttributes) FromQuickfunctionsAttributes 

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

FromQuickfunctionsAttributes overwrites any union data inside the UpdateStreamDto_DestinationAttributes as the provided QuickfunctionsAttributes

func (*UpdateStreamDto_DestinationAttributes) FromS3Attributes 

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

FromS3Attributes overwrites any union data inside the UpdateStreamDto_DestinationAttributes as the provided S3Attributes

func (*UpdateStreamDto_DestinationAttributes) FromWebhookAttributes 

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

FromWebhookAttributes overwrites any union data inside the UpdateStreamDto_DestinationAttributes as the provided WebhookAttributes

func (UpdateStreamDto_DestinationAttributes) MarshalJSON 

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

func (*UpdateStreamDto_DestinationAttributes) MergeAzureAttributes added in v0.6.2 

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

MergeAzureAttributes performs a merge with any union data inside the UpdateStreamDto_DestinationAttributes, using the provided AzureAttributes

func (*UpdateStreamDto_DestinationAttributes) MergePostgresAttributes 

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

MergePostgresAttributes performs a merge with any union data inside the UpdateStreamDto_DestinationAttributes, using the provided PostgresAttributes

func (*UpdateStreamDto_DestinationAttributes) MergeQuickfunctionsAttributes 

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

MergeQuickfunctionsAttributes performs a merge with any union data inside the UpdateStreamDto_DestinationAttributes, using the provided QuickfunctionsAttributes

func (*UpdateStreamDto_DestinationAttributes) MergeS3Attributes 

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

MergeS3Attributes performs a merge with any union data inside the UpdateStreamDto_DestinationAttributes, using the provided S3Attributes

func (*UpdateStreamDto_DestinationAttributes) MergeWebhookAttributes 

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

MergeWebhookAttributes performs a merge with any union data inside the UpdateStreamDto_DestinationAttributes, using the provided WebhookAttributes

func (*UpdateStreamDto_DestinationAttributes) UnmarshalJSON 

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

type WebhookAttributes 

type WebhookAttributes struct {
	Compression      string                 `json:"compression"`
	Headers          map[string]interface{} `json:"headers"`
	MaxRetry         float32                `json:"max_retry"`
	PostTimeoutSec   float32                `json:"post_timeout_sec"`
	RetryIntervalSec float32                `json:"retry_interval_sec"`
	SecurityToken    string                 `json:"security_token"`
	Url              string                 `json:"url"`
}

WebhookAttributes defines model for WebhookAttributes.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.