keeper

package
v1.10.1 Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	ErrConsensusQueueNotImplemented   = whoops.Errorf("consensus queue not implemented for queueTypeName %s")
	ErrUnableToFindPubKeyForValidator = whoops.Errorf("unable to find public key for validator: %s")
	ErrSignatureVerificationFailed    = whoops.Errorf("signature verification failed (msgId: %d, valAddr: %s, pubKey: %s)")
	ErrInvalidLimitValue              = whoops.Errorf("invalid N value: %d")
)

Variables

This section is empty.

Functions

func NewMsgServerImpl 

func NewMsgServerImpl(keeper Keeper) types.MsgServer

NewMsgServerImpl returns an implementation of the MsgServer interface for the provided Keeper.

func NewRegistry 

func NewRegistry() *registry

Types

type Keeper 

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

func NewKeeper 

func NewKeeper(
	cdc codec.BinaryCodec,
	storeKey,
	memKey storetypes.StoreKey,
	ps paramtypes.Subspace,
	valsetKeeper types.ValsetKeeper,
	reg *registry,
) *Keeper

func (Keeper) AddMessageEvidence 

func (k Keeper) AddMessageEvidence(
	ctx sdk.Context,
	valAddr sdk.ValAddress,
	msg *types.MsgAddEvidence,
) error

func (Keeper) AddMessageSignature 

func (k Keeper) AddMessageSignature(
	ctx sdk.Context,
	valAddr sdk.ValAddress,
	msgs []*types.ConsensusMessageSignature,
) error

AddMessageSignature adds signatures to the messages.

func (Keeper) CheckAndProcessAttestedMessages 

func (k Keeper) CheckAndProcessAttestedMessages(ctx sdk.Context) error

CheckAndProcessAttestedMessages is supposed to be used within the EndBlocker. It will get messages for the attestators that have reached a consensus and process them.

func (Keeper) DeleteJob added in v0.6.0 

func (k Keeper) DeleteJob(ctx sdk.Context, queueTypeName string, id uint64) (err error)

func (Keeper) DeleteOldMessages added in v1.5.0 

func (k Keeper) DeleteOldMessages(ctx sdk.Context, blocksAgo int64) error

func (Keeper) GetAllQueueNames 

func (k Keeper) GetAllQueueNames(goCtx context.Context, req *types.QueryGetAllQueueNamesRequest) (*types.QueryGetAllQueueNamesResponse, error)

func (Keeper) GetMessagesForAttesting added in v1.4.0 

func (k Keeper) GetMessagesForAttesting(ctx sdk.Context, queueTypeName string, valAddress sdk.ValAddress) (msgs []types.QueuedSignedMessageI, err error)

GetMessagesForAttesting returns messages for a single validator to attest.

func (Keeper) GetMessagesForRelaying added in v1.4.0 

func (k Keeper) GetMessagesForRelaying(ctx sdk.Context, queueTypeName string, valAddress sdk.ValAddress) (msgs []types.QueuedSignedMessageI, err error)

GetMessagesForRelaying returns messages for a single validator to relay.

func (Keeper) GetMessagesForSigning 

func (k Keeper) GetMessagesForSigning(ctx sdk.Context, queueTypeName string, valAddress sdk.ValAddress) (msgs []types.QueuedSignedMessageI, err error)

GetMessagesForSigning returns messages for a single validator that needs to be signed.

func (Keeper) GetMessagesFromQueue 

func (k Keeper) GetMessagesFromQueue(ctx sdk.Context, queueTypeName string, n int) (msgs []types.QueuedSignedMessageI, err error)

GetMessagesFromQueue gets N messages from the queue.

func (Keeper) GetMessagesThatHaveReachedConsensus 

func (k Keeper) GetMessagesThatHaveReachedConsensus(ctx sdk.Context, queueTypeName string) ([]types.QueuedSignedMessageI, error)

GetMessagesThatHaveReachedConsensus returns messages from a given queueTypeName that have reached consensus based on the latest snapshot available.

func (Keeper) GetParams 

func (k Keeper) GetParams(ctx sdk.Context) types.Params

GetParams get all parameters as types.Params

func (Keeper) Logger 

func (k Keeper) Logger(ctx sdk.Context) log.Logger

func (Keeper) MessagesInQueue 

func (k Keeper) MessagesInQueue(goCtx context.Context, req *types.QueryMessagesInQueueRequest) (*types.QueryMessagesInQueueResponse, error)

func (Keeper) Params 

func (k Keeper) Params(c context.Context, req *types.QueryParamsRequest) (*types.QueryParamsResponse, error)

func (Keeper) PutMessageInQueue added in v0.6.0 

func (k Keeper) PutMessageInQueue(ctx sdk.Context, queueTypeName string, msg consensus.ConsensusMsg, opts *consensus.PutOptions) (uint64, error)

func (Keeper) QueuedMessagesForAttesting added in v1.4.0 

func (k Keeper) QueuedMessagesForAttesting(goCtx context.Context, req *types.QueryQueuedMessagesForAttestingRequest) (*types.QueryQueuedMessagesForAttestingResponse, error)

func (Keeper) QueuedMessagesForRelaying added in v1.4.0 

func (k Keeper) QueuedMessagesForRelaying(goCtx context.Context, req *types.QueryQueuedMessagesForRelayingRequest) (*types.QueryQueuedMessagesForRelayingResponse, error)

func (Keeper) QueuedMessagesForSigning 

func (k Keeper) QueuedMessagesForSigning(goCtx context.Context, req *types.QueryQueuedMessagesForSigningRequest) (*types.QueryQueuedMessagesForSigningResponse, error)

func (Keeper) RemoveConsensusQueue 

func (k Keeper) RemoveConsensusQueue(ctx sdk.Context, queueTypeName string) error

func (Keeper) SetMessageErrorData added in v1.3.0 

func (k Keeper) SetMessageErrorData(
	ctx sdk.Context,
	valAddr sdk.ValAddress,
	msg *types.MsgSetErrorData,
) error

func (Keeper) SetMessagePublicAccessData 

func (k Keeper) SetMessagePublicAccessData(
	ctx sdk.Context,
	valAddr sdk.ValAddress,
	msg *types.MsgSetPublicAccessData,
) error

func (Keeper) SetParams 

func (k Keeper) SetParams(ctx sdk.Context, params types.Params)

SetParams set the params

func (Keeper) Store 

func (k Keeper) Store(ctx sdk.Context) sdk.KVStore

Source Files

View all Source files

Directories

Path Synopsis
mocks

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.