api

Documentation

Index

• Constants
• Variables
• func RegisterService(server *grpc.Server, service StorageWorker)
• type ForceFinalizeRequest
• type GetLastSyncedRoundRequest
• type GetLastSyncedRoundResponse
• type Status
• type StorageWorker
  • func NewStorageWorkerClient(c *grpc.ClientConn) StorageWorker

Constants

const ModuleName = "worker/storage"

ModuleName is the storage worker module name.

Variables

var ErrRuntimeNotFound = errors.New(ModuleName, 1, "worker/storage: runtime not found")

ErrRuntimeNotFound is the error returned when the called references an unknown runtime.

Functions

func RegisterService

func RegisterService(server *grpc.Server, service StorageWorker)

RegisterService registers a new storage worker service with the given gRPC server.

Types

type ForceFinalizeRequest

type ForceFinalizeRequest struct {
	RuntimeID common.Namespace `json:"runtime_id"`
	Round     uint64           `json:"round"`
}

ForceFinalizeRequest is a ForceFinalize request.

type GetLastSyncedRoundRequest

type GetLastSyncedRoundRequest struct {
	RuntimeID common.Namespace `json:"runtime_id"`
}

GetLastSyncedRoundRequest is a GetLastSyncedRound request.

type GetLastSyncedRoundResponse

type GetLastSyncedRoundResponse struct {
	Round     uint64       `json:"round"`
	IORoot    storage.Root `json:"io_root"`
	StateRoot storage.Root `json:"state_root"`
}

GetLastSyncedRoundResponse is a GetLastSyncedRound response.

type Status

type Status struct {
	// LastFinalizedRound is the last synced and finalized round.
	LastFinalizedRound uint64 `json:"last_finalized_round"`
}

Status is the storage worker status.

type StorageWorker

type StorageWorker interface {
	// GetLastSyncedRound retrieves the last synced round for the storage worker.
	GetLastSyncedRound(ctx context.Context, request *GetLastSyncedRoundRequest) (*GetLastSyncedRoundResponse, error)

	// ForceFinalize forces finalization of a specific round.
	ForceFinalize(ctx context.Context, request *ForceFinalizeRequest) error
}

StorageWorker is the storage worker control API interface.

func NewStorageWorkerClient

func NewStorageWorkerClient(c *grpc.ClientConn) StorageWorker

NewStorageWorkerClient creates a new gRPC transaction scheduler client service.