admin

Documentation

Index

• type API
  • func NewAPI(service internal.ConsensusService, healthChecker *observability.HealthChecker, ...) *API
  • func (a *API) HandleAddNode(ctx forge.Context) error
  • func (a *API) HandleApplyCommand(ctx forge.Context) error
  • func (a *API) HandleDetailedHealth(ctx forge.Context) error
  • func (a *API) HandleGetLeader(ctx forge.Context) error
  • func (a *API) HandleHealth(ctx forge.Context) error
  • func (a *API) HandleListNodes(ctx forge.Context) error
  • func (a *API) HandleMetrics(ctx forge.Context) error
  • func (a *API) HandleReadQuery(ctx forge.Context) error
  • func (a *API) HandleRemoveNode(ctx forge.Context) error
  • func (a *API) HandleSnapshot(ctx forge.Context) error
  • func (a *API) HandleStatus(ctx forge.Context) error
  • func (a *API) HandleStepDown(ctx forge.Context) error
  • func (a *API) HandleTransferLeadership(ctx forge.Context) error
  • func (a *API) RegisterRoutes(router forge.Router, prefix string)

Types

type API

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

API provides admin endpoints for consensus management

func NewAPI

func NewAPI(
	service internal.ConsensusService,
	healthChecker *observability.HealthChecker,
	metricsCollector *observability.MetricsCollector,
	logger forge.Logger,
) *API

NewAPI creates a new admin API

func (*API) HandleAddNode

func (a *API) HandleAddNode(ctx forge.Context) error

HandleAddNode handles add node requests

func (*API) HandleApplyCommand

func (a *API) HandleApplyCommand(ctx forge.Context) error

HandleApplyCommand handles apply command requests (for testing)

func (*API) HandleDetailedHealth

func (a *API) HandleDetailedHealth(ctx forge.Context) error

HandleDetailedHealth handles detailed health check requests

func (*API) HandleGetLeader

func (a *API) HandleGetLeader(ctx forge.Context) error

HandleGetLeader handles get leader requests

func (*API) HandleHealth

func (a *API) HandleHealth(ctx forge.Context) error

HandleHealth handles health check requests

func (*API) HandleListNodes

func (a *API) HandleListNodes(ctx forge.Context) error

HandleListNodes handles list nodes requests

func (*API) HandleMetrics

func (a *API) HandleMetrics(ctx forge.Context) error

HandleMetrics handles metrics requests

func (*API) HandleReadQuery

func (a *API) HandleReadQuery(ctx forge.Context) error

HandleReadQuery handles read query requests

func (*API) HandleRemoveNode

func (a *API) HandleRemoveNode(ctx forge.Context) error

HandleRemoveNode handles remove node requests

func (*API) HandleSnapshot

func (a *API) HandleSnapshot(ctx forge.Context) error

HandleSnapshot handles snapshot requests

func (*API) HandleStatus

func (a *API) HandleStatus(ctx forge.Context) error

HandleStatus handles status requests

func (*API) HandleStepDown

func (a *API) HandleStepDown(ctx forge.Context) error

HandleStepDown handles step down requests

func (*API) HandleTransferLeadership

func (a *API) HandleTransferLeadership(ctx forge.Context) error

HandleTransferLeadership handles leadership transfer requests

func (*API) RegisterRoutes

func (a *API) RegisterRoutes(router forge.Router, prefix string)

RegisterRoutes registers all admin API routes