streams

package
v0.6.0 Latest Latest
Warning

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

 Go to latest Published: Aug 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/deepmap/oapi-codegen version v1.16.3 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 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 *float32 `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 *float32              `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 (
	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"
	CreateStreamDtoNetworkAvalancheFuji      CreateStreamDtoNetwork = "avalanche-fuji"
	CreateStreamDtoNetworkAvalancheMainnet   CreateStreamDtoNetwork = "avalanche-mainnet"
	CreateStreamDtoNetworkB3Mainnet          CreateStreamDtoNetwork = "b3-mainnet"
	CreateStreamDtoNetworkB3Sepolia          CreateStreamDtoNetwork = "b3-sepolia"
	CreateStreamDtoNetworkBaseMainnet        CreateStreamDtoNetwork = "base-mainnet"
	CreateStreamDtoNetworkBaseSepolia        CreateStreamDtoNetwork = "base-sepolia"
	CreateStreamDtoNetworkBeraBepolia        CreateStreamDtoNetwork = "bera-bepolia"
	CreateStreamDtoNetworkBeraMainnet        CreateStreamDtoNetwork = "bera-mainnet"
	CreateStreamDtoNetworkBitcoinMainnet     CreateStreamDtoNetwork = "bitcoin-mainnet"
	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"
	CreateStreamDtoNetworkEthereumHolesky    CreateStreamDtoNetwork = "ethereum-holesky"
	CreateStreamDtoNetworkEthereumHoodi      CreateStreamDtoNetwork = "ethereum-hoodi"
	CreateStreamDtoNetworkEthereumMainnet    CreateStreamDtoNetwork = "ethereum-mainnet"
	CreateStreamDtoNetworkEthereumSepolia    CreateStreamDtoNetwork = "ethereum-sepolia"
	CreateStreamDtoNetworkFantomMainnet      CreateStreamDtoNetwork = "fantom-mainnet"
	CreateStreamDtoNetworkFlowMainnet        CreateStreamDtoNetwork = "flow-mainnet"
	CreateStreamDtoNetworkFlowTestnet        CreateStreamDtoNetwork = "flow-testnet"
	CreateStreamDtoNetworkGnosisMainnet      CreateStreamDtoNetwork = "gnosis-mainnet"
	CreateStreamDtoNetworkGravityAlpham      CreateStreamDtoNetwork = "gravity-alpham"
	CreateStreamDtoNetworkHederaMainnet      CreateStreamDtoNetwork = "hedera-mainnet"
	CreateStreamDtoNetworkHederaTestnet      CreateStreamDtoNetwork = "hedera-testnet"
	CreateStreamDtoNetworkHemiMainnet        CreateStreamDtoNetwork = "hemi-mainnet"
	CreateStreamDtoNetworkHemiTestnet        CreateStreamDtoNetwork = "hemi-testnet"
	CreateStreamDtoNetworkHyperliquidMainnet CreateStreamDtoNetwork = "hyperliquid-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"
	CreateStreamDtoNetworkLensMainnet        CreateStreamDtoNetwork = "lens-mainnet"
	CreateStreamDtoNetworkLensTestnet        CreateStreamDtoNetwork = "lens-testnet"
	CreateStreamDtoNetworkLineaMainnet       CreateStreamDtoNetwork = "linea-mainnet"
	CreateStreamDtoNetworkMantleMainnet      CreateStreamDtoNetwork = "mantle-mainnet"
	CreateStreamDtoNetworkMantleSepolia      CreateStreamDtoNetwork = "mantle-sepolia"
	CreateStreamDtoNetworkMonadTestnet       CreateStreamDtoNetwork = "monad-testnet"
	CreateStreamDtoNetworkMorphHolesky       CreateStreamDtoNetwork = "morph-holesky"
	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"
	CreateStreamDtoNetworkPlasmaTestnet      CreateStreamDtoNetwork = "plasma-testnet"
	CreateStreamDtoNetworkPolygonAmoy        CreateStreamDtoNetwork = "polygon-amoy"
	CreateStreamDtoNetworkPolygonMainnet     CreateStreamDtoNetwork = "polygon-mainnet"
	CreateStreamDtoNetworkRaceMainnet        CreateStreamDtoNetwork = "race-mainnet"
	CreateStreamDtoNetworkRaceTestnet        CreateStreamDtoNetwork = "race-testnet"
	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"
	CreateStreamDtoNetworkXrpMainnet         CreateStreamDtoNetwork = "xrp-mainnet"
	CreateStreamDtoNetworkXrpTestnet         CreateStreamDtoNetwork = "xrp-testnet"
	CreateStreamDtoNetworkZerogGalileo       CreateStreamDtoNetwork = "zerog-galileo"
	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"
	CreateStreamDtoStatusCompleted  CreateStreamDtoStatus = "completed"
	CreateStreamDtoStatusPaused     CreateStreamDtoStatus = "paused"
	CreateStreamDtoStatusTerminated CreateStreamDtoStatus = "terminated"
)

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) 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) 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) 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"`
	MaxEntry         float32                `json:"max_entry"`
	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 (
	DotJson    S3AttributesFileType = ".json"
	DotParquet 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"
	TestFilterFunctionDtoNetworkAvalancheFuji      TestFilterFunctionDtoNetwork = "avalanche-fuji"
	TestFilterFunctionDtoNetworkAvalancheMainnet   TestFilterFunctionDtoNetwork = "avalanche-mainnet"
	TestFilterFunctionDtoNetworkB3Mainnet          TestFilterFunctionDtoNetwork = "b3-mainnet"
	TestFilterFunctionDtoNetworkB3Sepolia          TestFilterFunctionDtoNetwork = "b3-sepolia"
	TestFilterFunctionDtoNetworkBaseMainnet        TestFilterFunctionDtoNetwork = "base-mainnet"
	TestFilterFunctionDtoNetworkBaseSepolia        TestFilterFunctionDtoNetwork = "base-sepolia"
	TestFilterFunctionDtoNetworkBeraBepolia        TestFilterFunctionDtoNetwork = "bera-bepolia"
	TestFilterFunctionDtoNetworkBeraMainnet        TestFilterFunctionDtoNetwork = "bera-mainnet"
	TestFilterFunctionDtoNetworkBitcoinMainnet     TestFilterFunctionDtoNetwork = "bitcoin-mainnet"
	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"
	TestFilterFunctionDtoNetworkEthereumHolesky    TestFilterFunctionDtoNetwork = "ethereum-holesky"
	TestFilterFunctionDtoNetworkEthereumHoodi      TestFilterFunctionDtoNetwork = "ethereum-hoodi"
	TestFilterFunctionDtoNetworkEthereumMainnet    TestFilterFunctionDtoNetwork = "ethereum-mainnet"
	TestFilterFunctionDtoNetworkEthereumSepolia    TestFilterFunctionDtoNetwork = "ethereum-sepolia"
	TestFilterFunctionDtoNetworkFantomMainnet      TestFilterFunctionDtoNetwork = "fantom-mainnet"
	TestFilterFunctionDtoNetworkFlowMainnet        TestFilterFunctionDtoNetwork = "flow-mainnet"
	TestFilterFunctionDtoNetworkFlowTestnet        TestFilterFunctionDtoNetwork = "flow-testnet"
	TestFilterFunctionDtoNetworkGnosisMainnet      TestFilterFunctionDtoNetwork = "gnosis-mainnet"
	TestFilterFunctionDtoNetworkGravityAlpham      TestFilterFunctionDtoNetwork = "gravity-alpham"
	TestFilterFunctionDtoNetworkHederaMainnet      TestFilterFunctionDtoNetwork = "hedera-mainnet"
	TestFilterFunctionDtoNetworkHederaTestnet      TestFilterFunctionDtoNetwork = "hedera-testnet"
	TestFilterFunctionDtoNetworkHemiMainnet        TestFilterFunctionDtoNetwork = "hemi-mainnet"
	TestFilterFunctionDtoNetworkHemiTestnet        TestFilterFunctionDtoNetwork = "hemi-testnet"
	TestFilterFunctionDtoNetworkHyperliquidMainnet TestFilterFunctionDtoNetwork = "hyperliquid-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"
	TestFilterFunctionDtoNetworkLensMainnet        TestFilterFunctionDtoNetwork = "lens-mainnet"
	TestFilterFunctionDtoNetworkLensTestnet        TestFilterFunctionDtoNetwork = "lens-testnet"
	TestFilterFunctionDtoNetworkLineaMainnet       TestFilterFunctionDtoNetwork = "linea-mainnet"
	TestFilterFunctionDtoNetworkMantleMainnet      TestFilterFunctionDtoNetwork = "mantle-mainnet"
	TestFilterFunctionDtoNetworkMantleSepolia      TestFilterFunctionDtoNetwork = "mantle-sepolia"
	TestFilterFunctionDtoNetworkMonadTestnet       TestFilterFunctionDtoNetwork = "monad-testnet"
	TestFilterFunctionDtoNetworkMorphHolesky       TestFilterFunctionDtoNetwork = "morph-holesky"
	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"
	TestFilterFunctionDtoNetworkPlasmaTestnet      TestFilterFunctionDtoNetwork = "plasma-testnet"
	TestFilterFunctionDtoNetworkPolygonAmoy        TestFilterFunctionDtoNetwork = "polygon-amoy"
	TestFilterFunctionDtoNetworkPolygonMainnet     TestFilterFunctionDtoNetwork = "polygon-mainnet"
	TestFilterFunctionDtoNetworkRaceMainnet        TestFilterFunctionDtoNetwork = "race-mainnet"
	TestFilterFunctionDtoNetworkRaceTestnet        TestFilterFunctionDtoNetwork = "race-testnet"
	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"
	TestFilterFunctionDtoNetworkXrpMainnet         TestFilterFunctionDtoNetwork = "xrp-mainnet"
	TestFilterFunctionDtoNetworkXrpTestnet         TestFilterFunctionDtoNetwork = "xrp-testnet"
	TestFilterFunctionDtoNetworkZerogGalileo       TestFilterFunctionDtoNetwork = "zerog-galileo"
	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 *float32 `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 *float32               `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 (
	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"
	UpdateStreamDtoStatusCompleted  UpdateStreamDtoStatus = "completed"
	UpdateStreamDtoStatusPaused     UpdateStreamDtoStatus = "paused"
	UpdateStreamDtoStatusTerminated UpdateStreamDtoStatus = "terminated"
)

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) 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) 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) 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.