server

Documentation

Index

• Constants
• Variables
• func CLIFlags(envPrefix string) []cli.Flag
• func CheckRequired(ctx *cli.Context) error
• func LoadStoreRouter(cfg CLIConfig, ctx context.Context, log log.Logger) (*store.Router, error)
• func ReadCommitmentMode(r *http.Request) (commitments.CommitmentMode, error)
• func WithLogging(handleFn func(http.ResponseWriter, *http.Request) error, log log.Logger) func(http.ResponseWriter, *http.Request)
• func WithMetrics(handleFn func(http.ResponseWriter, *http.Request) error, m metrics.Metricer) func(http.ResponseWriter, *http.Request) error
• type CLIConfig
  • func ReadCLIConfig(ctx *cli.Context) CLIConfig
  • func (c CLIConfig) Check() error
• type Config
  • func ReadConfig(ctx *cli.Context) Config
  • func (cfg *Config) Check() error
  • func (c *Config) GetMaxBlobLength() (uint64, error)
  • func (c *Config) VerificationCfg() *verify.Config
• type Server
  • func NewServer(host string, port int, router *store.Router, log log.Logger, ...) *Server
  • func (svr *Server) Endpoint() string
  • func (svr *Server) GetMemStats() *store.Stats
  • func (svr *Server) GetS3Stats() *store.Stats
  • func (svr *Server) HandleGet(w http.ResponseWriter, r *http.Request) error
  • func (svr *Server) HandlePut(w http.ResponseWriter, r *http.Request) error
  • func (svr *Server) Health(w http.ResponseWriter, r *http.Request) error
  • func (svr *Server) Port() int
  • func (svr *Server) Start() error
  • func (svr *Server) Stop() error
  • func (svr *Server) WriteBadRequest(w http.ResponseWriter, msg string)
  • func (svr *Server) WriteInternalError(w http.ResponseWriter, err error)
  • func (svr *Server) WriteNotFound(w http.ResponseWriter, msg string)
  • func (svr *Server) WriteResponse(w http.ResponseWriter, data []byte)

Constants

const (
	EigenDADisperserRPCFlagName          = "eigenda-disperser-rpc"
	EthRPCFlagName                       = "eigenda-eth-rpc"
	SvcManagerAddrFlagName               = "eigenda-svc-manager-addr"
	EthConfirmationDepthFlagName         = "eigenda-eth-confirmation-depth"
	StatusQueryRetryIntervalFlagName     = "eigenda-status-query-retry-interval"
	StatusQueryTimeoutFlagName           = "eigenda-status-query-timeout"
	DisableTlsFlagName                   = "eigenda-disable-tls"
	ResponseTimeoutFlagName              = "eigenda-response-timeout"
	CustomQuorumIDsFlagName              = "eigenda-custom-quorum-ids"
	SignerPrivateKeyHexFlagName          = "eigenda-signer-private-key-hex"
	PutBlobEncodingVersionFlagName       = "eigenda-put-blob-encoding-version"
	DisablePointVerificationModeFlagName = "eigenda-disable-point-verification-mode"
	// Kzg flags
	G1PathFlagName             = "eigenda-g1-path"
	G2TauFlagName              = "eigenda-g2-tau-path"
	CachePathFlagName          = "eigenda-cache-path"
	MaxBlobLengthFlagName      = "eigenda-max-blob-length"
	MemstoreFlagName           = "memstore.enabled"
	MemstoreExpirationFlagName = "memstore.expiration"
	// S3 flags
	S3CredentialTypeFlagName  = "s3.credential-type" // #nosec G101
	S3BucketFlagName          = "s3.bucket"          // #nosec G101
	S3PathFlagName            = "s3.path"
	S3EndpointFlagName        = "s3.endpoint"
	S3AccessKeyIDFlagName     = "s3.access-key-id"     // #nosec G101
	S3AccessKeySecretFlagName = "s3.access-key-secret" // #nosec G101
	S3BackupFlagName          = "s3.backup"
	S3TimeoutFlagName         = "s3.timeout"
)

const (
	ListenAddrFlagName = "addr"
	PortFlagName       = "port"
)

const (
	GetRoute = "/get/"
	PutRoute = "/put/"

	DomainFilterKey   = "domain"
	CommitmentModeKey = "commitment_mode"
)

const BytesPerSymbol = 31

const EnvVarPrefix = "EIGENDA_PROXY"

const MaxCodingRatio = 8

Variables

var (
	ListenAddrFlag = &cli.StringFlag{
		Name:    ListenAddrFlagName,
		Usage:   "server listening address",
		Value:   "127.0.0.1",
		EnvVars: prefixEnvVars("ADDR"),
	}
	PortFlag = &cli.IntFlag{
		Name:    PortFlagName,
		Usage:   "server listening port",
		Value:   3100,
		EnvVars: prefixEnvVars("PORT"),
	}
)

var (
	ErrNotFound = errors.New("not found")
)

var Flags []cli.Flag

Flags contains the list of configuration options available to the binary.

var MaxAllowedBlobSize = uint64(MaxSRSPoints * BytesPerSymbol / MaxCodingRatio)

var MaxSRSPoints = math.Pow(2, 28)

Functions

func CLIFlags

func CLIFlags(envPrefix string) []cli.Flag

func CheckRequired

func CheckRequired(ctx *cli.Context) error

func LoadStoreRouter

func LoadStoreRouter(cfg CLIConfig, ctx context.Context, log log.Logger) (*store.Router, error)

func ReadCommitmentMode

func ReadCommitmentMode(r *http.Request) (commitments.CommitmentMode, error)

func WithLogging

func WithLogging(handleFn func(http.ResponseWriter, *http.Request) error, log log.Logger) func(http.ResponseWriter, *http.Request)

WithLogging is a middleware that logs the request method and URL.

func WithMetrics

func WithMetrics(handleFn func(http.ResponseWriter, *http.Request) error, m metrics.Metricer) func(http.ResponseWriter, *http.Request) error

WithMetrics is a middleware that records metrics for the route path.

Types

type CLIConfig

type CLIConfig struct {
	S3Config      store.S3Config
	EigenDAConfig Config
	MetricsCfg    opmetrics.CLIConfig
}

func ReadCLIConfig

func ReadCLIConfig(ctx *cli.Context) CLIConfig

func (CLIConfig) Check

func (c CLIConfig) Check() error

type Config

type Config struct {
	S3Config store.S3Config

	ClientConfig clients.EigenDAClientConfig

	// The blob encoding version to use when writing blobs from the high level interface.
	PutBlobEncodingVersion codecs.BlobEncodingVersion

	// ETH vars
	EthRPC               string
	SvcManagerAddr       string
	EthConfirmationDepth int64

	// KZG vars
	CacheDir string
	G1Path   string
	G2Path   string

	MaxBlobLength string

	G2PowerOfTauPath string

	// Memstore Config params
	MemstoreEnabled        bool
	MemstoreBlobExpiration time.Duration
	// contains filtered or unexported fields
}

func ReadConfig

func ReadConfig(ctx *cli.Context) Config

NewConfig parses the Config from the provided flags or environment variables.

func (*Config) Check

func (cfg *Config) Check() error

Check ... verifies that configuration values are adequately set

func (*Config) GetMaxBlobLength

func (c *Config) GetMaxBlobLength() (uint64, error)

func (*Config) VerificationCfg

func (c *Config) VerificationCfg() *verify.Config

type Server

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

func NewServer

func NewServer(host string, port int, router *store.Router, log log.Logger, m metrics.Metricer) *Server

func (*Server) Endpoint

func (svr *Server) Endpoint() string

func (*Server) GetMemStats

func (svr *Server) GetMemStats() *store.Stats

func (*Server) GetS3Stats

func (svr *Server) GetS3Stats() *store.Stats

func (*Server) HandleGet

func (svr *Server) HandleGet(w http.ResponseWriter, r *http.Request) error

func (*Server) HandlePut

func (svr *Server) HandlePut(w http.ResponseWriter, r *http.Request) error

func (*Server) Health

func (svr *Server) Health(w http.ResponseWriter, r *http.Request) error

func (*Server) Port

func (svr *Server) Port() int

func (*Server) Start

func (svr *Server) Start() error

func (*Server) Stop

func (svr *Server) Stop() error

func (*Server) WriteBadRequest

func (svr *Server) WriteBadRequest(w http.ResponseWriter, msg string)

func (*Server) WriteInternalError

func (svr *Server) WriteInternalError(w http.ResponseWriter, err error)

func (*Server) WriteNotFound

func (svr *Server) WriteNotFound(w http.ResponseWriter, msg string)

func (*Server) WriteResponse

func (svr *Server) WriteResponse(w http.ResponseWriter, data []byte)