server

package

Go to main page

Versions in this module

v1

v1.5.0

Oct 9, 2024

Changes in this version

+ const Put

+ func ReadCommitmentMeta(r *http.Request) (commitments.CommitmentMeta, error)

+ func ReadCommitmentVersion(r *http.Request, mode commitments.CommitmentMode) (byte, error)

type Config

+ EdaClientConfig clients.EigenDAClientConfig

+ MemstoreConfig memstore.Config

+ RedisConfig redis.Config

+ VerifierConfig verify.Config

+ type MetaError struct

+ Err error

+ Meta commitments.CommitmentMeta

+ func NewMetaError(err error, meta commitments.CommitmentMeta) MetaError

+ func (me MetaError) Error() string

type Server

+ func (svr *Server) GetStoreStats(bt store.BackendType) (*store.Stats, error)

v1.4.1

Sep 5, 2024

Changes in this version

+ const CacheTargets

+ const DisableTLSFlagName

+ const FallbackTargets

type Config

+ CacheTargets []string

+ FallbackTargets []string

type Server

+ func (svr *Server) GetEigenDAStats() *store.Stats

v1.4.0

Aug 12, 2024

Changes in this version

+ const S3BackupFlagName

+ const S3CredentialTypeFlagName

+ const S3PathFlagName

+ const S3TimeoutFlagName

v1.3.3

Aug 1, 2024

v1.3.3-2

Aug 2, 2024

v1.3.3-1

Aug 1, 2024

v1.3.2

Jul 31, 2024

v1.3.1

Jul 21, 2024

v1.3.0

Jul 19, 2024

Changes in this version

+ const S3AccessKeyIDFlagName

+ const S3AccessKeySecretFlagName

+ const S3BucketFlagName

+ const S3EndpointFlagName

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

type CLIConfig

+ S3Config store.S3Config

type Config

+ S3Config store.S3Config

type Server

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

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

v1.2.0

Jun 27, 2024

Changes in this version

+ const BytesPerSymbol

+ const CachePathFlagName

+ const CommitmentModeKey

+ const CustomQuorumIDsFlagName

+ const DefaultPruneInterval

+ const DisablePointVerificationModeFlagName

+ const DisableTlsFlagName

+ const EigenDADisperserRPCFlagName

+ const EthConfirmationDepthFlagName

+ const EthRPCFlagName

+ const G1PathFlagName

+ const G2TauFlagName

+ const MaxBlobLengthFlagName

+ const MaxCodingRatio

+ const MemstoreExpirationFlagName

+ const MemstoreFlagName

+ const PutBlobEncodingVersionFlagName

+ const ResponseTimeoutFlagName

+ const SignerPrivateKeyHexFlagName

+ const StatusQueryRetryIntervalFlagName

+ const StatusQueryTimeoutFlagName

+ const SvcManagerAddrFlagName

+ var ErrInvalidDomainType = fmt.Errorf("invalid domain type")

+ var MaxAllowedBlobSize = uint64(MaxSRSPoints * BytesPerSymbol / MaxCodingRatio)

+ var MaxSRSPoints = math.Pow(2, 28)

+ func CLIFlags(envPrefix string) []cli.Flag

+ func EncodeCommitment(s []byte, c CommitmentMode) ([]byte, error)

+ func StringToCommitment(key string, c CommitmentMode) ([]byte, error)

+ type CommitmentMode string

+ const OptimismCommitmentMode

+ const SimpleCommitmentMode

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

+ func StringToCommitmentMode(s string) (CommitmentMode, error)

+ type Config struct

+ CacheDir string

+ ClientConfig clients.EigenDAClientConfig

+ EthConfirmationDepth uint64

+ EthRPC string

+ G1Path string

+ G2Path string

+ G2PowerOfTauPath string

+ MaxBlobLength string

+ MemstoreBlobExpiration time.Duration

+ MemstoreEnabled bool

+ PutBlobEncodingVersion codecs.BlobEncodingVersion

+ SvcManagerAddr string

+ func ReadConfig(ctx *cli.Context) Config

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

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

+ func (m Config) Check() error

+ type DomainType uint8

+ const BinaryDomain

+ const PolyDomain

+ const UnknownDomain

+ func StrToDomainType(s string) DomainType

+ func (d DomainType) String() string

+ type EigenDAStore struct

+ func NewEigenDAStore(ctx context.Context, client *clients.EigenDAClient, v *verify.Verifier, ...) (*EigenDAStore, error)

+ func (e EigenDAStore) Get(ctx context.Context, key []byte, domain DomainType) ([]byte, error)

+ func (e EigenDAStore) Put(ctx context.Context, value []byte) (comm []byte, err error)

+ func (e EigenDAStore) Stats() *Stats

+ type EigenDAStoreConfig struct

+ EthConfirmationDepth uint64

+ MaxBlobSizeBytes uint64

+ StatusQueryTimeout time.Duration

+ type MemStore struct

+ func NewMemStore(ctx context.Context, verifier *verify.Verifier, l log.Logger, ...) (*MemStore, error)

+ func (e *MemStore) EventLoop(ctx context.Context)

+ func (e *MemStore) Get(ctx context.Context, commit []byte, domain DomainType) ([]byte, error)

+ func (e *MemStore) Put(ctx context.Context, value []byte) ([]byte, error)

+ func (e *MemStore) Stats() *Stats

+ type Stats struct

+ Entries int

+ Reads int

+ type Store interface

+ Get func(ctx context.Context, key []byte, domain DomainType) ([]byte, error)

+ Put func(ctx context.Context, value []byte) (key []byte, err error)

+ Stats func() *Stats

v1.1.1

Jun 20, 2024

Changes in this version

type Server

+ func (svr *Server) Port() int

+ func (svr *Server) Store() store.Store

v1.0.0

Jun 7, 2024

v0

v0.0.0

Jun 7, 2024

Changes in this version

+ const DomainFilterKey

+ const EnvVarPrefix

+ const GetRoute

+ const ListenAddrFlagName

+ const PortFlagName

+ const PutRoute

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

+ var Flags []cli.Flag

+ var ListenAddrFlag = &cli.StringFlag

+ var PortFlag = &cli.IntFlag

+ func CheckRequired(ctx *cli.Context) error

+ func LoadStore(cfg CLIConfig, ctx context.Context, log log.Logger) (store.Store, error)

+ func ReadDomainFilter(r *http.Request) (common.DomainType, 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 struct

+ EigenDAConfig eigenda.Config

+ MemStoreCfg store.MemStoreConfig

+ MetricsCfg opmetrics.CLIConfig

+ func ReadCLIConfig(ctx *cli.Context) CLIConfig

+ func (c CLIConfig) Check() error

+ type Server struct

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

+ func (svr *Server) Endpoint() string

+ 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) 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)

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