server

package

v1.0.0-beta.1 Latest Latest Go to latest Published: Jul 8, 2025 License: Apache-2.0 Imports: 19 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/rollkit/rollkit

Links

Open Source Insights

Documentation ¶

Index ¶

func NewServiceHandler(store store.Store, peerManager p2p.P2PRPC, logger logging.EventLogger) (http.Handler, error)
func RegisterCustomHTTPEndpoints(mux *http.ServeMux)
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 logging.EventLogger) *StoreServer

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewServiceHandler ¶

func NewServiceHandler(store store.Store, peerManager p2p.P2PRPC, logger logging.EventLogger) (http.Handler, error)

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

func RegisterCustomHTTPEndpoints ¶

func RegisterCustomHTTPEndpoints(mux *http.ServeMux)

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

Types ¶

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 logging.EventLogger) *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) 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

Source Files ¶

View all Source files

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