proxy

package

Go to main page

Versions in this module

v0

v0.5.4

Jul 4, 2025

Changes in this version

type ReceiverProxyConfig

+ BuilderReadyEndpoint string

v0.5.3

Jul 2, 2025

v0.5.2

Jul 1, 2025

Changes in this version

+ func NewFastHTTPClient(certPEM []byte, maxOpenConnections int) (*fasthttp.Client, error)

+ func SerializeParsedRequestForSharing(req *ParsedRequest, signer *signature.Signer) error

+ type LocalBuilderSender struct

+ func NewLocalBuilderSender(logger *slog.Logger, endpoint string, maxOpenConnections int) (LocalBuilderSender, error)

+ func (s *LocalBuilderSender) SendRequest(req *ParsedRequest) error

type ReceiverProxyConstantConfig

+ LocalBuilderEndpoint string

v0.5.1

Jun 16, 2025

v0.5.0

Jun 12, 2025

v0.4.2

Jun 12, 2025

Changes in this version

+ func OrderflowProxyURLFromIPOrDNSName(ipOrDNSName string) string

type ConfighubBuilder

+ DNSName string

+ Instance ConfighubInstanceData

+ func (b *ConfighubBuilder) SystemAPIAddress() string

+ func (b *ConfighubBuilder) TLSCert() string

+ type ConfighubInstanceData struct

+ TLSCert string

v0.4.1

Jun 10, 2025

v0.4.0

Jun 4, 2025

Changes in this version

+ const DefaultLocalhostMaxIdleConn

+ var HTTP2DefaultMaxConcurrentStreams = uint32(cli.GetEnvInt("HTTP2_MAX_CONCURRENT_STREAMS", 4096))

+ func HTTPClientLocalhost(maxOpenConnections int) *http.Client

v0.3.6

May 21, 2025

Changes in this version

type ReceiverProxyConfig

+ ArchiveWorkerCount int

v0.3.5

Apr 30, 2025

v0.3.4

Apr 29, 2025

Changes in this version

+ var DefaultHTTPCLientWriteBuffer = cli.GetEnvInt("HTTP_CLIENT_WRITE_BUFFER", 64 << 10)

+ var HTTP2DefaultMaxUploadPerConnection = int32(cli.GetEnvInt("HTTP2_MAX_UPLOAD_PER_CONN", 32 << 20))

+ var HTTP2DefaultMaxUploadPerStream = int32(cli.GetEnvInt("HTTP2_MAX_UPLOAD_PER_STREAM", 8 << 20))

type ReceiverProxyConfig

+ CertKeyPath string

+ CertPath string

v0.3.3

Apr 18, 2025

v0.3.2

Apr 16, 2025

v0.3.1

Apr 7, 2025

Changes in this version

+ func EnsureReplacementUUID(args *rpctypes.EthSendBundleArgs) (*rpctypes.EthSendBundleArgs, error)

+ func IsVersionValid(version *string) bool

type ReceiverProxy

+ SystemHandler http.Handler

+ UserHandler http.Handler

+ func (prx *ReceiverProxy) BidSubsidiseBlockSystem(ctx context.Context, bidSubsidiseBlock rpctypes.BidSubsisideBlockArgs) error

+ func (prx *ReceiverProxy) BidSubsidiseBlockUser(ctx context.Context, bidSubsidiseBlock rpctypes.BidSubsisideBlockArgs) error

+ func (prx *ReceiverProxy) EthCancelBundleSystem(ctx context.Context, ethCancelBundle rpctypes.EthCancelBundleArgs) error

+ func (prx *ReceiverProxy) EthCancelBundleUser(ctx context.Context, ethCancelBundle rpctypes.EthCancelBundleArgs) error

+ func (prx *ReceiverProxy) EthSendBundleSystem(ctx context.Context, ethSendBundle rpctypes.EthSendBundleArgs) error

+ func (prx *ReceiverProxy) EthSendBundleUser(ctx context.Context, ethSendBundle rpctypes.EthSendBundleArgs) error

+ func (prx *ReceiverProxy) EthSendRawTransactionSystem(ctx context.Context, ethSendRawTransaction rpctypes.EthSendRawTransactionArgs) error

+ func (prx *ReceiverProxy) EthSendRawTransactionUser(ctx context.Context, ethSendRawTransaction rpctypes.EthSendRawTransactionArgs) error

+ func (prx *ReceiverProxy) MevSendBundleSystem(ctx context.Context, mevSendBundle rpctypes.MevSendBundleArgs) error

+ func (prx *ReceiverProxy) MevSendBundleUser(ctx context.Context, mevSendBundle rpctypes.MevSendBundleArgs) error

+ func (prx *ReceiverProxy) SystemJSONRPCHandler(maxRequestBodySizeBytes int64) (*rpcserver.JSONRPCHandler, error)

+ func (prx *ReceiverProxy) UserJSONRPCHandler(maxRequestBodySizeBytes int64) (*rpcserver.JSONRPCHandler, error)

type ReceiverProxyConfig

+ MaxUserRPS int

v0.3.0

Apr 2, 2025

v0.2.11

Apr 1, 2025

v0.2.10

Apr 1, 2025

v0.2.9

Mar 20, 2025

Changes in this version

+ var HTTPDefaultIdleTimeout = 1 * time.Hour

v0.2.8

Mar 14, 2025

v0.2.7

Feb 28, 2025

v0.2.6

Nov 12, 2024

v0.2.5

Nov 12, 2024

v0.2.4

Nov 11, 2024

v0.2.3

Nov 7, 2024

v0.2.2

Nov 5, 2024

Changes in this version

+ var ArchiveRequestTimeout = time.Second * 15

+ var ArchiveRetryMaxTime = time.Second * 120

+ var ArchiveWorkerQueueSize = 10000

+ var ReceiverProxyWorkerQueueSize = 10000

+ var ShareWorkerQueueSize = 10000

+ func HTTPClientWithMaxConnections(maxOpenConnections int) *http.Client

type ReceiverProxyConfig

+ ArchiveConnections int

+ MaxLocalRPS int

v0.2.1

Nov 4, 2024

Changes in this version

type ReceiverProxyConfig

+ ConnectionsPerPeer int

type SenderProxy

+ PeerUpdateForce chan struct{}

type SenderProxyConfig

+ ConnectionsPerPeer int

v0.2.0

Nov 1, 2024

Changes in this version

+ const BidSubsidiseBlockMethod

+ const DefaultMaxRequestBodySizeBytes

+ const EthCancelBundleMethod

+ const EthSendBundleMethod

+ const EthSendRawTransactionMethod

+ const FlashbotsPeerName

+ const MevSendBundleMethod

+ const NewOrderEventsMethod

+ var ArchiveBatchSize = 100

+ var ArchiveBatchSizeFlushTimeout = time.Second * 6

+ var DefaultOrderflowProxyPublicPort = 5544

+ var HTTPDefaultReadTimeout = 60 * time.Second

+ var HTTPDefaultWriteTimeout = 30 * time.Second

+ func GenerateCert(validFor time.Duration, hosts []string) (cert, key []byte, err error)

+ func OrderflowProxyURLFromIP(ip string) string

+ func RPCClientWithCertAndSigner(endpoint string, certPEM []byte, signer *signature.Signer) (rpcclient.RPCClient, error)

+ func ValidateEthCancelBundle(args *rpctypes.EthCancelBundleArgs, publicEndpoint bool) error

+ func ValidateEthSendBundle(args *rpctypes.EthSendBundleArgs, publicEndpoint bool) error

+ func ValidateMevSendBundle(args *rpctypes.MevSendBundleArgs, _ bool) error

+ type ArchiveEvent struct

+ EthCancelBundle *ArchiveEventEthCancelBundle

+ EthSendBundle *ArchiveEventEthSendBundle

+ MevSendBundle *ArchiveEventMevSendBundle

+ type ArchiveEventEthCancelBundle struct

+ Metadata *ArchiveEventMetadata

+ Params *rpctypes.EthCancelBundleArgs

+ type ArchiveEventEthSendBundle struct

+ Metadata *ArchiveEventMetadata

+ Params *rpctypes.EthSendBundleArgs

+ type ArchiveEventMetadata struct

+ ReceivedAt int64

+ type ArchiveEventMevSendBundle struct

+ Metadata *ArchiveEventMetadata

+ Params *rpctypes.MevSendBundleArgs

+ type ArchiveQueue struct

+ func (aq *ArchiveQueue) Run()

+ type BlockNumberSource struct

+ func NewBlockNumberSource(endpoint string) *BlockNumberSource

+ func (bs *BlockNumberSource) BlockNumber() (uint64, error)

+ func (bs *BlockNumberSource) UpdateCachedBlockNumber() error

+ type BuilderConfigHub struct

+ func NewBuilderConfigHub(log *slog.Logger, endpoint string) *BuilderConfigHub

+ func (b *BuilderConfigHub) Builders() (result []ConfighubBuilder, err error)

+ func (b *BuilderConfigHub) RegisterCredentials(ctx context.Context, info ConfighubOrderflowProxyCredentials) error

+ type ConfighubBuilder struct

+ IP string

+ Name string

+ OrderflowProxy ConfighubOrderflowProxyCredentials

+ type ConfighubOrderflowProxyCredentials struct

+ EcdsaPubkeyAddress common.Address

+ TLSCert string

+ type FlashbotsNewOrderEventsArgs struct

+ OrderEvents []ArchiveEvent

+ type ParsedRequest struct

+ type ReceiverProxy struct

+ CertHandler http.Handler

+ Certificate tls.Certificate

+ ConfigHub *BuilderConfigHub

+ LocalHandler http.Handler

+ OrderflowSigner *signature.Signer

+ PublicCertPEM []byte

+ PublicHandler http.Handler

+ func NewReceiverProxy(config ReceiverProxyConfig) (*ReceiverProxy, error)

+ func (prx *ReceiverProxy) BidSubsidiseBlock(ctx context.Context, bidSubsidiseBlock rpctypes.BidSubsisideBlockArgs, ...) error

+ func (prx *ReceiverProxy) BidSubsidiseBlockLocal(ctx context.Context, bidSubsidiseBlock rpctypes.BidSubsisideBlockArgs) error

+ func (prx *ReceiverProxy) BidSubsidiseBlockPublic(ctx context.Context, bidSubsidiseBlock rpctypes.BidSubsisideBlockArgs) error

+ func (prx *ReceiverProxy) EthCancelBundle(ctx context.Context, ethCancelBundle rpctypes.EthCancelBundleArgs, ...) error

+ func (prx *ReceiverProxy) EthCancelBundleLocal(ctx context.Context, ethCancelBundle rpctypes.EthCancelBundleArgs) error

+ func (prx *ReceiverProxy) EthCancelBundlePublic(ctx context.Context, ethCancelBundle rpctypes.EthCancelBundleArgs) error

+ func (prx *ReceiverProxy) EthSendBundle(ctx context.Context, ethSendBundle rpctypes.EthSendBundleArgs, ...) error

+ func (prx *ReceiverProxy) EthSendBundleLocal(ctx context.Context, ethSendBundle rpctypes.EthSendBundleArgs) error

+ func (prx *ReceiverProxy) EthSendBundlePublic(ctx context.Context, ethSendBundle rpctypes.EthSendBundleArgs) error

+ func (prx *ReceiverProxy) EthSendRawTransaction(ctx context.Context, ethSendRawTransaction rpctypes.EthSendRawTransactionArgs, ...) error

+ func (prx *ReceiverProxy) EthSendRawTransactionLocal(ctx context.Context, ethSendRawTransaction rpctypes.EthSendRawTransactionArgs) error

+ func (prx *ReceiverProxy) EthSendRawTransactionPublic(ctx context.Context, ethSendRawTransaction rpctypes.EthSendRawTransactionArgs) error

+ func (prx *ReceiverProxy) FlushArchiveQueue()

+ func (prx *ReceiverProxy) HandleParsedRequest(ctx context.Context, parsedRequest ParsedRequest) error

+ func (prx *ReceiverProxy) LocalJSONRPCHandler(maxRequestBodySizeBytes int64) (*rpcserver.JSONRPCHandler, error)

+ func (prx *ReceiverProxy) MevSendBundle(ctx context.Context, mevSendBundle rpctypes.MevSendBundleArgs, ...) error

+ func (prx *ReceiverProxy) MevSendBundleLocal(ctx context.Context, mevSendBundle rpctypes.MevSendBundleArgs) error

+ func (prx *ReceiverProxy) MevSendBundlePublic(ctx context.Context, mevSendBundle rpctypes.MevSendBundleArgs) error

+ func (prx *ReceiverProxy) PublicJSONRPCHandler(maxRequestBodySizeBytes int64) (*rpcserver.JSONRPCHandler, error)

+ func (prx *ReceiverProxy) RegisterSecrets(ctx context.Context) error

+ func (prx *ReceiverProxy) RequestNewPeers() error

+ func (prx *ReceiverProxy) Stop()

+ func (prx *ReceiverProxy) TLSConfig() *tls.Config

+ func (prx *ReceiverProxy) ValidateSigner(ctx context.Context, req *ParsedRequest, publicEndpoint bool) error

+ type ReceiverProxyConfig struct

+ ArchiveEndpoint string

+ BuilderConfigHubEndpoint string

+ CertHosts []string

+ CertValidDuration time.Duration

+ EthRPC string

+ LocalBuilderEndpoint string

+ MaxRequestBodySizeBytes int64

+ type ReceiverProxyConstantConfig struct

+ FlashbotsSignerAddress common.Address

+ Log *slog.Logger

+ Name string

+ type ReceiverProxyServers struct

+ func StartReceiverServers(proxy *ReceiverProxy, ...) (*ReceiverProxyServers, error)

+ func (s *ReceiverProxyServers) Stop()

+ type SenderProxy struct

+ ConfigHub *BuilderConfigHub

+ Handler http.Handler

+ func NewSenderProxy(config SenderProxyConfig) (*SenderProxy, error)

+ func (prx *SenderProxy) BidSubsidiseBlock(ctx context.Context, bidSubsidiseBlock rpctypes.BidSubsisideBlockArgs) error

+ func (prx *SenderProxy) EthCancelBundle(ctx context.Context, ethCancelBundle rpctypes.EthCancelBundleArgs) error

+ func (prx *SenderProxy) EthSendBundle(ctx context.Context, ethSendBundle rpctypes.EthSendBundleArgs) error

+ func (prx *SenderProxy) EthSendRawTransaction(ctx context.Context, ethSendRawTransaction rpctypes.EthSendRawTransactionArgs) error

+ func (prx *SenderProxy) HandleParsedRequest(ctx context.Context, parsedRequest ParsedRequest) error

+ func (prx *SenderProxy) MevSendBundle(ctx context.Context, mevSendBundle rpctypes.MevSendBundleArgs) error

+ func (prx *SenderProxy) Stop()

+ type SenderProxyConfig struct

+ BuilderConfigHubEndpoint string

+ MaxRequestBodySizeBytes int64

+ type SenderProxyConstantConfig struct

+ Log *slog.Logger

+ OrderflowSigner *signature.Signer

+ type SenderProxyServers struct

+ func StartSenderServers(proxy *SenderProxy, listenAddress string) (*SenderProxyServers, error)

+ func (s *SenderProxyServers) Stop()

+ type ShareQueue struct

+ func (sq *ShareQueue) Run()

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