Documentation
¶
Index ¶
- Constants
- Variables
- func NewFunctionsHandler(cfg FunctionsHandlerConfig, donConfig *config.DONConfig, don handlers.DON, ...) handlers.Handler
- func NewFunctionsHandlerFromConfig(handlerConfig json.RawMessage, donConfig *config.DONConfig, don handlers.DON, ...) (handlers.Handler, error)
- type CombinedResponse
- type FunctionsHandlerConfig
- type PendingRequest
- type ResponseBase
- type SecretsListResponse
- type SecretsListRow
- type SecretsSetRequest
- type SecretsSetResponse
Constants ¶
View Source
const ( MethodSecretsSet = "secrets_set" MethodSecretsList = "secrets_list" MethodHeartbeat = "heartbeat" )
Variables ¶
Functions ¶
func NewFunctionsHandler ¶
func NewFunctionsHandler( cfg FunctionsHandlerConfig, donConfig *config.DONConfig, don handlers.DON, pendingRequestsCache hc.RequestCache[PendingRequest], allowlist fallow.OnchainAllowlist, subscriptions fsub.OnchainSubscriptions, minimumBalance *assets.Link, userRateLimiter *hc.RateLimiter, nodeRateLimiter *hc.RateLimiter, allowedHeartbeatInitiators map[string]struct{}, lggr logger.Logger) handlers.Handler
Types ¶
type CombinedResponse ¶ added in v2.8.0
type CombinedResponse struct {
ResponseBase
NodeResponses []*api.Message `json:"node_responses"`
}
Gateway -> User response, which combines responses from several nodes
type FunctionsHandlerConfig ¶
type FunctionsHandlerConfig struct {
ChainID string `json:"chainId"`
// Not specifying OnchainAllowlist config disables allowlist checks
OnchainAllowlist *fallow.OnchainAllowlistConfig `json:"onchainAllowlist"`
// Not specifying OnchainSubscriptions config disables minimum balance checks
OnchainSubscriptions *fsub.OnchainSubscriptionsConfig `json:"onchainSubscriptions"`
MinimumSubscriptionBalance *assets.Link `json:"minimumSubscriptionBalance"`
// Not specifying RateLimiter config disables rate limiting
UserRateLimiter *hc.RateLimiterConfig `json:"userRateLimiter"`
NodeRateLimiter *hc.RateLimiterConfig `json:"nodeRateLimiter"`
MaxPendingRequests uint32 `json:"maxPendingRequests"`
RequestTimeoutMillis int64 `json:"requestTimeoutMillis"`
AllowedHeartbeatInitiators []string `json:"allowedHeartbeatInitiators"`
}
type PendingRequest ¶ added in v2.8.0
type PendingRequest struct {
// contains filtered or unexported fields
}
type ResponseBase ¶ added in v2.8.0
type SecretsListResponse ¶ added in v2.4.0
type SecretsListResponse struct {
ResponseBase
Rows []SecretsListRow `json:"rows,omitempty"`
}
type SecretsListRow ¶ added in v2.4.0
type SecretsSetRequest ¶ added in v2.4.0
type SecretsSetResponse ¶ added in v2.4.0
type SecretsSetResponse struct {
ResponseBase
}
Click to show internal directories.
Click to hide internal directories.