Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewMsgServerImpl ¶
NewMsgServerImpl returns a types.MsgServer implementation backed by the supplied Keeper.
Types ¶
type Keeper ¶
type Keeper struct {
// contains filtered or unexported fields
}
Keeper is the orchestration module keeper. It is a thin facade:
- MarketKeeper is used to load leases and mirror health responses.
- Queue is used to enqueue new orchestration messages (the actual state lives in the app-level OrchestrationKeeper).
- tstoreKey is the transient store used for per-block rate-limit counters (cleared automatically at end of block by the SDK).
func NewKeeper ¶
func NewKeeper( cdc codec.BinaryCodec, tstoreKey storetypes.StoreKey, marketKeeper types.MarketKeeper, queue types.OrchestrationQueueKeeper, params types.Params, logger log.Logger, ) Keeper
NewKeeper constructs a new orchestration Keeper.
params are consumed as a snapshot at app-wiring time; the module does not yet persist params on-chain (see §P1.1 of the roadmap). paramsRef is copied via value semantics so callers cannot mutate the keeper after wiring.
type MarketAdapter ¶
MarketAdapter wraps the concrete market IKeeper so it satisfies types.MarketKeeper, converting the orchestration module's independent HealthAttestationMirror into the market keeper's internal HealthAttestationMsg at call time.
func (MarketAdapter) SubmitHealthAttestation ¶
func (a MarketAdapter) SubmitHealthAttestation(ctx sdk.Context, msg *types.HealthAttestationMirror) error
SubmitHealthAttestation mirrors the provided attestation into the market module's health store. The orchestration module uses this ONLY for the transitional fold of MsgHealthAttestation (§P0.1 step 5).
Source Files