server

Documentation

Index

• func NewServiceHandler(store store.Store, peerManager p2p.P2PRPC, proposerAddress []byte, ...) (http.Handler, error)
• func RegisterCustomHTTPEndpoints(mux *http.ServeMux, s store.Store, pm p2p.P2PRPC, cfg config.Config, ...)
• func SetDAVisualizationServer(server *DAVisualizationServer)
• type BestKnownHeightProvider
• type ConfigServer
  • func NewConfigServer(config config.Config, proposerAddress []byte, logger zerolog.Logger) *ConfigServer
  • func (cs *ConfigServer) GetNamespace(ctx context.Context, req *connect.Request[emptypb.Empty]) (*connect.Response[pb.GetNamespaceResponse], error)
  • func (cs *ConfigServer) GetSignerInfo(ctx context.Context, req *connect.Request[emptypb.Empty]) (*connect.Response[pb.GetSignerInfoResponse], error)
• type DASubmissionInfo
• type DAVisualizationServer
  • func GetDAVisualizationServer() *DAVisualizationServer
  • func NewDAVisualizationServer(da coreda.DA, logger zerolog.Logger, isAggregator bool) *DAVisualizationServer
  • func (s *DAVisualizationServer) RecordSubmission(result *coreda.ResultSubmit, gasPrice float64, numBlobs uint64)
• type HealthServer
  • func NewHealthServer() *HealthServer
  • func (h *HealthServer) Livez(ctx context.Context, req *connect.Request[emptypb.Empty]) (*connect.Response[pb.GetHealthResponse], error)
• type P2PServer
  • func NewP2PServer(peerManager p2p.P2PRPC) *P2PServer
  • func (p *P2PServer) GetNetInfo(ctx context.Context, req *connect.Request[emptypb.Empty]) (*connect.Response[pb.GetNetInfoResponse], error)
  • func (p *P2PServer) GetPeerInfo(ctx context.Context, req *connect.Request[emptypb.Empty]) (*connect.Response[pb.GetPeerInfoResponse], error)
• type StoreServer
  • func NewStoreServer(store store.Store, logger zerolog.Logger) *StoreServer
  • func (s *StoreServer) GetBlock(ctx context.Context, req *connect.Request[pb.GetBlockRequest]) (*connect.Response[pb.GetBlockResponse], error)
  • func (s *StoreServer) GetGenesisDaHeight(ctx context.Context, _ *connect.Request[emptypb.Empty]) (*connect.Response[pb.GetGenesisDaHeightResponse], error)
  • func (s *StoreServer) GetMetadata(ctx context.Context, req *connect.Request[pb.GetMetadataRequest]) (*connect.Response[pb.GetMetadataResponse], error)
  • func (s *StoreServer) GetState(ctx context.Context, req *connect.Request[emptypb.Empty]) (*connect.Response[pb.GetStateResponse], error)

Functions

func NewServiceHandler

func NewServiceHandler(store store.Store, peerManager p2p.P2PRPC, proposerAddress []byte, logger zerolog.Logger, config config.Config, bestKnown BestKnownHeightProvider) (http.Handler, error)

NewServiceHandler creates a new HTTP handler for Store, P2P and Health services

func RegisterCustomHTTPEndpoints

func RegisterCustomHTTPEndpoints(mux *http.ServeMux, s store.Store, pm p2p.P2PRPC, cfg config.Config, bestKnownHeightProvider BestKnownHeightProvider)

RegisterCustomHTTPEndpoints is the designated place to add new, non-gRPC, plain HTTP handlers. Additional custom HTTP endpoints can be registered on the mux here.

func SetDAVisualizationServer

func SetDAVisualizationServer(server *DAVisualizationServer)

SetDAVisualizationServer sets the global DA visualization server instance

Types

type BestKnownHeightProvider

type BestKnownHeightProvider func() uint64

BestKnownHeightProvider should return the best-known network height observed by the node (e.g. min(headerSyncHeight, dataSyncHeight) for full nodes, or header height for light nodes).

type ConfigServer

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

func NewConfigServer

func NewConfigServer(config config.Config, proposerAddress []byte, logger zerolog.Logger) *ConfigServer

func (*ConfigServer) GetNamespace

func (cs *ConfigServer) GetNamespace(
	ctx context.Context,
	req *connect.Request[emptypb.Empty],
) (*connect.Response[pb.GetNamespaceResponse], error)

func (*ConfigServer) GetSignerInfo

func (cs *ConfigServer) GetSignerInfo(
	ctx context.Context,
	req *connect.Request[emptypb.Empty],
) (*connect.Response[pb.GetSignerInfoResponse], error)

type DASubmissionInfo

type DASubmissionInfo struct {
	ID         string    `json:"id"`
	Height     uint64    `json:"height"`
	BlobSize   uint64    `json:"blob_size"`
	Timestamp  time.Time `json:"timestamp"`
	GasPrice   float64   `json:"gas_price"`
	StatusCode string    `json:"status_code"`
	Message    string    `json:"message,omitempty"`
	NumBlobs   uint64    `json:"num_blobs"`
	BlobIDs    []string  `json:"blob_ids,omitempty"`
}

DASubmissionInfo represents information about a DA submission

type DAVisualizationServer

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

DAVisualizationServer provides DA layer visualization endpoints

func GetDAVisualizationServer

func GetDAVisualizationServer() *DAVisualizationServer

GetDAVisualizationServer returns the global DA visualization server instance

func NewDAVisualizationServer

func NewDAVisualizationServer(da coreda.DA, logger zerolog.Logger, isAggregator bool) *DAVisualizationServer

NewDAVisualizationServer creates a new DA visualization server

func (*DAVisualizationServer) RecordSubmission

func (s *DAVisualizationServer) RecordSubmission(result *coreda.ResultSubmit, gasPrice float64, numBlobs uint64)

RecordSubmission records a DA submission for visualization Only keeps the last 100 submissions in memory for the dashboard display

type HealthServer

type HealthServer struct{}

HealthServer implements the HealthService defined in the proto file

func NewHealthServer

func NewHealthServer() *HealthServer

NewHealthServer creates a new HealthServer instance

func (*HealthServer) Livez

func (h *HealthServer) Livez(
	ctx context.Context,
	req *connect.Request[emptypb.Empty],
) (*connect.Response[pb.GetHealthResponse], error)

Livez implements the HealthService.Livez RPC

type P2PServer

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

P2PServer implements the P2PService defined in the proto file

func NewP2PServer

func NewP2PServer(peerManager p2p.P2PRPC) *P2PServer

NewP2PServer creates a new P2PServer instance

func (*P2PServer) GetNetInfo

func (p *P2PServer) GetNetInfo(
	ctx context.Context,
	req *connect.Request[emptypb.Empty],
) (*connect.Response[pb.GetNetInfoResponse], error)

GetNetInfo implements the GetNetInfo RPC method

func (*P2PServer) GetPeerInfo

func (p *P2PServer) GetPeerInfo(
	ctx context.Context,
	req *connect.Request[emptypb.Empty],
) (*connect.Response[pb.GetPeerInfoResponse], error)

GetPeerInfo implements the GetPeerInfo RPC method

type StoreServer

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

StoreServer implements the StoreService defined in the proto file

func NewStoreServer

func NewStoreServer(store store.Store, logger zerolog.Logger) *StoreServer

NewStoreServer creates a new StoreServer instance

func (*StoreServer) GetBlock

func (s *StoreServer) GetBlock(
	ctx context.Context,
	req *connect.Request[pb.GetBlockRequest],
) (*connect.Response[pb.GetBlockResponse], error)

GetBlock implements the GetBlock RPC method

func (*StoreServer) GetGenesisDaHeight

func (s *StoreServer) GetGenesisDaHeight(
	ctx context.Context,
	_ *connect.Request[emptypb.Empty],
) (*connect.Response[pb.GetGenesisDaHeightResponse], error)

GetGenesisDaHeight implements the GetGenesisDaHeight RPC method

func (*StoreServer) GetMetadata

func (s *StoreServer) GetMetadata(
	ctx context.Context,
	req *connect.Request[pb.GetMetadataRequest],
) (*connect.Response[pb.GetMetadataResponse], error)

GetMetadata implements the GetMetadata RPC method

func (*StoreServer) GetState

func (s *StoreServer) GetState(
	ctx context.Context,
	req *connect.Request[emptypb.Empty],
) (*connect.Response[pb.GetStateResponse], error)

GetState implements the GetState RPC method