rpcprovider

type BucketType string

type IVerificationsStatus interface {
	GetVerificationsStatus() (status []*pairingtypes.Verification)
}

type MethodConfig struct {
	MaxConcurrent int64         // Max concurrent executions
	QueueSize     int           // Max queued requests
	Timeout       time.Duration // Max time in queue
}

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

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

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

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

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

type ProviderRelaySender interface {
	SendNodeMsg(ctx context.Context, ch chan interface{}, chainMessage chainlib.ChainMessageForSend, extensions []string) (relayReply *chainlib.RelayReplyWrapper, subscriptionID string, relayReplyServer *rpcclient.ClientSubscription, proxyUrl common.NodeUrl, chainId string, err error)
}

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

type ProviderStateTrackerInf interface {
	RegisterForVersionUpdates(ctx context.Context, version *protocoltypes.Version, versionValidator updaters.VersionValidationInf)
	RegisterForSpecUpdates(ctx context.Context, specUpdatable updaters.SpecUpdatable, endpoint lavasession.RPCEndpoint) error
	RegisterForSpecVerifications(ctx context.Context, specVerifier updaters.SpecVerifier, chainId string) error
	RegisterForEpochUpdates(ctx context.Context, epochUpdatable updaters.EpochUpdatable)
	RegisterForDowntimeParamsUpdates(ctx context.Context, downtimeParamsUpdatable updaters.DowntimeParamsUpdatable) error
	TxRelayPayment(ctx context.Context, relayRequests []*pairingtypes.RelaySession, description string, latestBlocks []*pairingtypes.LatestBlockReport) error
	LatestBlock() int64
	GetMaxCuForUser(ctx context.Context, consumerAddress, chainID string, epocu uint64) (maxCu uint64, err error)
	VerifyPairing(ctx context.Context, consumerAddress, providerAddress string, epoch uint64, chainID string) (valid bool, total int64, projectId string, err error)
	GetEpochSize(ctx context.Context) (uint64, error)
	EarliestBlockInMemory(ctx context.Context) (uint64, error)
	RegisterPaymentUpdatableForPayments(ctx context.Context, paymentUpdatable updaters.PaymentUpdatable)
	GetRecommendedEpochNumToCollectPayment(ctx context.Context) (uint64, error)
	GetEpochSizeMultipliedByRecommendedEpochNumToCollectPayment(ctx context.Context) (uint64, error)
	GetProtocolVersion(ctx context.Context) (*updaters.ProtocolVersionResponse, error)
	GetVirtualEpoch(epoch uint64) uint64
	GetAverageBlockTime() time.Duration
}

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

type RPCProviderServer struct {
	StaticProvider bool
	// contains filtered or unexported fields
}

type RelayReceiver interface {
	Relay(ctx context.Context, request *pairingtypes.RelayRequest) (*pairingtypes.RelayReply, error)
	RelaySubscribe(request *pairingtypes.RelayRequest, srv pairingtypes.Relayer_RelaySubscribeServer) error
	Probe(ctx context.Context, probeReq *pairingtypes.ProbeRequest) (*pairingtypes.ProbeReply, error)
}

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

type ResourceLimiterMetrics struct {
	TotalRejected  uint64
	TotalQueued    uint64
	TotalTimeout   uint64
	HeavyInFlight  uint64
	NormalInFlight uint64
	// contains filtered or unexported fields
}

type RewardServerInf interface {
	SendNewProof(ctx context.Context, proof *pairingtypes.RelaySession, epoch uint64, consumerAddr, apiInterface string) (existingCU uint64, updatedWithProof bool)
	SubscribeStarted(consumer string, epoch uint64, subscribeID string)
	SubscribeEnded(consumer string, epoch uint64, subscribeID string)
}

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

type StateTrackerInf interface {
	LatestBlock() int64
	GetMaxCuForUser(ctx context.Context, consumerAddress, chainID string, epocu uint64) (maxCu uint64, err error)
	VerifyPairing(ctx context.Context, consumerAddress, providerAddress string, epoch uint64, chainID string) (valid bool, total int64, projectId string, err error)
	GetVirtualEpoch(epoch uint64) uint64
}

type TestModeConfig struct {
	TestMode     bool                    `json:"test_mode"`
	Responses    map[string]TestResponse `json:"responses"`
	ResponseFile string                  `json:"response_file"`
}

type TestModeContextKey struct{}

type TestResponse struct {
	SuccessReply           string  `json:"success_reply"`
	ErrorReply             string  `json:"error_reply"`
	RateLimitReply         string  `json:"rate_limit_reply"`
	UnsupportedMethodReply string  `json:"unsupported_method_reply"`
	SuccessProbability     float64 `json:"success_probability"`
	ErrorProbability       float64 `json:"error_probability"`
	RateLimitProbability   float64 `json:"rate_limit_probability"`
	UnsupportedProbability float64 `json:"unsupported_probability"`
}