scheduler

package
v0.2509.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 28, 2025 License: Apache-2.0 Imports: 41 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// AppID is the unique application identifier.
	AppID uint8 = 0x06

	// AppName is the ABCI application name.
	AppName string = "200_scheduler"
)

Variables

View Source 
var (
	// EventType is the ABCI event type for scheduler events.
	EventType = api.EventTypeForApp(AppName)

	// QueryApp is a query for filtering events processed by the
	// scheduler application.
	QueryApp = api.QueryForApp(AppName)
)
View Source 
var (
	RNGContextExecutor   = []byte("EkS-ABCI-Compute")
	RNGContextValidators = []byte("EkS-ABCI-Validators")
	RNGContextEntities   = []byte("EkS-ABCI-Entities")

	RNGContextRoleWorker       = []byte("Worker")
	RNGContextRoleBackupWorker = []byte("Backup-Worker")
)

Functions

This section is empty.

Types

type Application added in v0.2502.0 

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

Application is a scheduler application.

func New 

func New(state api.ApplicationState, md api.MessageDispatcher) *Application

New constructs a new scheduler application.

func (*Application) BeginBlock added in v0.2502.0 

func (app *Application) BeginBlock(ctx *api.Context) error

BeginBlock implements api.Application.

func (*Application) Blessed added in v0.2502.0 

func (app *Application) Blessed() bool

Blessed implements api.Application.

func (*Application) Dependencies added in v0.2502.0 

func (app *Application) Dependencies() []string

Dependencies implements api.Application.

func (*Application) EndBlock added in v0.2502.0 

func (app *Application) EndBlock(ctx *api.Context) (types.ResponseEndBlock, error)

EndBlock implements api.Application.

func (*Application) ExecuteMessage added in v0.2502.0 

func (app *Application) ExecuteMessage(ctx *api.Context, kind, msg any) (any, error)

ExecuteMessage implements api.MessageSubscriber.

func (*Application) ExecuteTx added in v0.2502.0 

func (app *Application) ExecuteTx(*api.Context, *transaction.Transaction) error

ExecuteTx implements api.Application.

func (*Application) ID added in v0.2502.0 

func (app *Application) ID() uint8

ID implements api.Application.

func (*Application) InitChain added in v0.2502.0 

func (app *Application) InitChain(ctx *abciAPI.Context, req types.RequestInitChain, doc *genesis.Document) error

func (*Application) Methods added in v0.2502.0 

func (app *Application) Methods() []transaction.MethodName

Methods implements api.Application.

func (*Application) Name added in v0.2502.0 

func (app *Application) Name() string

Name implements api.Application.

func (*Application) OnCleanup added in v0.2502.0 

func (app *Application) OnCleanup()

OnCleanup implements api.Application.

func (*Application) Subscribe added in v0.2502.0 

func (app *Application) Subscribe()

Subscribe implements api.Application.

type LightQueryFactory added in v0.2504.0 

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

LightQueryFactory is the scheduler light query factory.

func NewLightQueryFactory added in v0.2504.0 

func NewLightQueryFactory(rooter abciAPI.StateRooter, syncer syncer.ReadSyncer) *LightQueryFactory

NewLightQueryFactory returns a new scheduler query factory backed by a trusted state root provider and an untrusted read syncer.

func (*LightQueryFactory) QueryAt added in v0.2504.0 

func (f *LightQueryFactory) QueryAt(ctx context.Context, height int64) (*Query, error)

QueryAt returns a scheduler query for a specific height.

type Query 

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

Query is the scheduler query.

func NewQuery added in v0.2504.0 

func NewQuery(state *schedulerState.ImmutableState) *Query

NewQuery returns a new scheduler query backed by the given state.

func (*Query) AllCommittees 

func (q *Query) AllCommittees(ctx context.Context) ([]*scheduler.Committee, error)

AllCommittees implements scheduler.Query.

func (*Query) ConsensusParameters 

func (q *Query) ConsensusParameters(ctx context.Context) (*scheduler.ConsensusParameters, error)

ConsensusParameters implements scheduler.Query.

func (*Query) Genesis 

func (q *Query) Genesis(ctx context.Context) (*scheduler.Genesis, error)

Genesis implements scheduler.Query.

func (*Query) KindsCommittees 

func (q *Query) KindsCommittees(ctx context.Context, kinds []scheduler.CommitteeKind) ([]*scheduler.Committee, error)

KindsCommittees implements scheduler.Query.

func (*Query) Validators 

func (q *Query) Validators(ctx context.Context) ([]*scheduler.Validator, error)

Validators implements scheduler.Query.

type QueryFactory 

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

QueryFactory is the scheduler query factory.

func NewQueryFactory 

func NewQueryFactory(state abciAPI.ApplicationQueryState) *QueryFactory

NewQueryFactory returns a new scheduler query factory backed by the given application state.

func (*QueryFactory) QueryAt 

func (f *QueryFactory) QueryAt(ctx context.Context, height int64) (*Query, error)

QueryAt returns a scheduler query for a specific height.

Source Files

View all Source files

Directories

Path Synopsis
Package api defines the scheduler application API for other applications.
 Package api defines the scheduler application API for other applications.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.