app

Documentation

Index

• Variables
• func AppConfig() depinject.Config
• type AlloraApp
  • func NewAlloraApp(logger log.Logger, db dbm.DB, traceStore io.Writer, loadLatest bool, ...) (*AlloraApp, error)
  • func (app *AlloraApp) ExportAppStateAndValidators(forZeroHeight bool, jailAllowedAddrs []string, modulesToExport []string) (servertypes.ExportedApp, error)
  • func (app *AlloraApp) GetKey(storeKey string) *storetypes.KVStoreKey
  • func (app *AlloraApp) LegacyAmino() *codec.LegacyAmino
  • func (app *AlloraApp) RegisterAPIRoutes(apiSvr *api.Server, apiConfig config.APIConfig)
  • func (app *AlloraApp) SimulationManager() *module.SimulationManager
• type BlocklessRequest
• type Config
• type EnvVar
• type InferenceItem
• type LatestInferences
• type TopicsHandler
  • func NewTopicsHandler(emissionsKeeper emissionskeeper.Keeper) *TopicsHandler
  • func (th *TopicsHandler) PrepareProposalHandler() sdk.PrepareProposalHandler
• type WeightInferencePayload

Variables

var AppConfigYAML []byte

var DefaultNodeHome string

DefaultNodeHome default home directories for the application daemon

Functions

func AppConfig

func AppConfig() depinject.Config

AppConfig returns the default app config.

Types

type AlloraApp

type AlloraApp struct {
	*runtime.App

	// keepers
	AccountKeeper         authkeeper.AccountKeeper
	BankKeeper            bankkeeper.Keeper
	StakingKeeper         *stakingkeeper.Keeper
	DistrKeeper           distrkeeper.Keeper
	ConsensusParamsKeeper consensuskeeper.Keeper
	MintKeeper            mintkeeper.Keeper
	EmissionsKeeper       emissionsKeeper.Keeper
	// contains filtered or unexported fields
}

AlloraApp extends an ABCI application, but with most of its parameters exported. They are exported for convenience in creating helper functions, as object capabilities aren't needed for testing.

func NewAlloraApp

func NewAlloraApp(
	logger log.Logger,
	db dbm.DB,
	traceStore io.Writer,
	loadLatest bool,
	appOpts servertypes.AppOptions,
	baseAppOptions ...func(*baseapp.BaseApp),
) (*AlloraApp, error)

NewAlloraApp returns a reference to an initialized AlloraApp.

func (*AlloraApp) ExportAppStateAndValidators

func (app *AlloraApp) ExportAppStateAndValidators(
	forZeroHeight bool,
	jailAllowedAddrs []string,
	modulesToExport []string,
) (servertypes.ExportedApp, error)

ExportAppStateAndValidators exports the state of the application for a genesis file.

func (*AlloraApp) GetKey

func (app *AlloraApp) GetKey(storeKey string) *storetypes.KVStoreKey

GetKey returns the KVStoreKey for the provided store key.

func (*AlloraApp) LegacyAmino

func (app *AlloraApp) LegacyAmino() *codec.LegacyAmino

LegacyAmino returns AlloraApp's amino codec.

func (*AlloraApp) RegisterAPIRoutes

func (app *AlloraApp) RegisterAPIRoutes(apiSvr *api.Server, apiConfig config.APIConfig)

RegisterAPIRoutes registers all application module routes with the provided API server.

func (*AlloraApp) SimulationManager

func (app *AlloraApp) SimulationManager() *module.SimulationManager

SimulationManager implements the SimulationApp interface

type BlocklessRequest

type BlocklessRequest struct {
	FunctionID string `json:"function_id"`
	Method     string `json:"method"`
	TopicID    string `json:"topic,omitempty"`
	Config     Config `json:"config"`
}

type Config

type Config struct {
	Environment []EnvVar `json:"env_vars,omitempty"`
	Stdin       *string  `json:"stdin,omitempty"`
	NodeCount   int      `json:"number_of_nodes,omitempty"`
	Timeout     int      `json:"timeout,omitempty"`
}

type EnvVar

type EnvVar struct {
	Name  string `json:"name,omitempty"`
	Value string `json:"value,omitempty"`
}

type InferenceItem

type InferenceItem struct {
	Worker    string `json:"worker"`
	Inference string `json:"inference"`
}

type LatestInferences

type LatestInferences struct {
	Timestamp  string          `json:"timestamp"`
	Inferences []InferenceItem `json:"inferences"`
}

type TopicsHandler

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

func NewTopicsHandler

func NewTopicsHandler(emissionsKeeper emissionskeeper.Keeper) *TopicsHandler

func (*TopicsHandler) PrepareProposalHandler

func (th *TopicsHandler) PrepareProposalHandler() sdk.PrepareProposalHandler

type WeightInferencePayload

type WeightInferencePayload struct {
	Inferences    []LatestInferences `json:"inferences"`
	LatestWeights map[string]string  `json:"latest_weights"`
}