gateway

type AuthorizePublishFn func(ctx context.Context, identity Identity, req PublishRequestSummary) (bool, error)

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

type GatewayService interface {
	WaitForShutdown()
}

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

type GatewayServiceError interface {
	error
	Code() codes.Code
	ClientMessage() string
}

type IGatewayServiceBuilder interface {
	WithIdentityFn(identityFn IdentityFn) IGatewayServiceBuilder
	WithAuthorizers(authorizers ...AuthorizePublishFn) IGatewayServiceBuilder
	WithBlockchainPublisher(
		blockchainPublisher blockchain.IBlockchainPublisher,
	) IGatewayServiceBuilder
	WithNodeRegistry(nodeRegistry registry.NodeRegistry) IGatewayServiceBuilder
	WithLogger(logger *zap.Logger) IGatewayServiceBuilder
	WithMetricsServer(metricsServer *metrics.Server) IGatewayServiceBuilder
	WithContext(ctx context.Context) IGatewayServiceBuilder
	WithPromRegistry(promRegistry *prometheus.Registry) IGatewayServiceBuilder
	WithClientMetrics(clientMetrics *grpcprom.ClientMetrics) IGatewayServiceBuilder
	WithNonceManager(nonceManager noncemanager.NonceManager) IGatewayServiceBuilder
	Build() (GatewayService, error)
}

type Identity struct {
	Kind     IdentityKind
	Identity string
}

type IdentityFn func(ctx context.Context) (Identity, error)

type IdentityKind string

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

type PublishRequest *payer_api.PublishClientEnvelopesRequest

type PublishRequestSummary struct {
	TotalEnvelopes       int
	OffchainCostEstimate currency.PicoDollar
	OnchainCostEstimate  currency.PicoDollar
	TotalCostEstimate    currency.PicoDollar
}

type RateLimit struct {
	MaxRequests int
	Window      time.Duration
}

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