keeper

package
v1.7.0 Latest Latest
Warning

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

 Go to latest Published: Aug 25, 2022 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Keeper 

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

func NewKeeper 

func NewKeeper(cdc codec.BinaryMarshaler, key store.StoreKey, ck types.ClientKeeper) Keeper

func (Keeper) ClientConnections 

func (q Keeper) ClientConnections(c context.Context, req *types.QueryClientConnectionsRequest) (*types.QueryClientConnectionsResponse, error)

ClientConnections implements the Query/ClientConnections gRPC method

func (Keeper) ConnOpenAck 

func (k Keeper) ConnOpenAck(
	ctx sdk.Context,
	connectionID string,
	clientState exported.ClientState,
	version *types.Version,
	counterpartyConnectionID string,
	proofTry []byte,
	proofClient []byte,
	proofConsensus []byte,
	proofHeight exported.Height,
	consensusHeight exported.Height,
) error

ConnOpenAck relays acceptance of a connection open attempt from chain B back to chain A (this code is executed on chain A).

NOTE: Identifiers are checked on msg validation.

func (Keeper) ConnOpenConfirm 

func (k Keeper) ConnOpenConfirm(
	ctx sdk.Context,
	connectionID string,
	proofAck []byte,
	proofHeight exported.Height,
) error

ConnOpenConfirm confirms opening of a connection on chain A to chain B, after which the connection is open on both chains (this code is executed on chain B).

NOTE: Identifiers are checked on msg validation.

func (Keeper) ConnOpenInit 

func (k Keeper) ConnOpenInit(
	ctx sdk.Context,
	clientID string,
	counterparty types.Counterparty,
	version *types.Version,
	delayPeriod uint64,
) (string, error)

ConnOpenInit initialises a connection attempt on chain A. The generated connection identifier is returned.

NOTE: Msg validation verifies the supplied identifiers and ensures that the counterparty connection identifier is empty.

func (Keeper) ConnOpenTry 

func (k Keeper) ConnOpenTry(
	ctx sdk.Context,
	previousConnectionID string,
	counterparty types.Counterparty,
	delayPeriod uint64,
	clientID string,
	clientState exported.ClientState,
	counterpartyVersions []exported.Version,
	proofInit []byte,
	proofClient []byte,
	proofConsensus []byte,
	proofHeight exported.Height,
	consensusHeight exported.Height,
) (string, error)

ConnOpenTry relays notice of a connection attempt on chain A to chain B (this code is executed on chain B).

NOTE:

  • Here chain A acts as the counterparty
  • Identifiers are checked on msg validation

func (Keeper) Connection 

func (q Keeper) Connection(c context.Context, req *types.QueryConnectionRequest) (*types.QueryConnectionResponse, error)

Connection implements the Query/Connection gRPC method

func (Keeper) ConnectionClientState 

func (q Keeper) ConnectionClientState(c context.Context, req *types.QueryConnectionClientStateRequest) (*types.QueryConnectionClientStateResponse, error)

ConnectionClientState implements the Query/ConnectionClientState gRPC method

func (Keeper) ConnectionConsensusState 

func (q Keeper) ConnectionConsensusState(c context.Context, req *types.QueryConnectionConsensusStateRequest) (*types.QueryConnectionConsensusStateResponse, error)

ConnectionConsensusState implements the Query/ConnectionConsensusState gRPC method

func (Keeper) Connections 

func (q Keeper) Connections(c context.Context, req *types.QueryConnectionsRequest) (*types.QueryConnectionsResponse, error)

Connections implements the Query/Connections gRPC method

func (Keeper) ConnectionsRest 

func (q Keeper) ConnectionsRest(ctx sdk.Context, r abci.RequestQuery) ([]byte, error)

Connections implements the Query/Connections gRPC method

func (Keeper) GenerateConnectionIdentifier 

func (k Keeper) GenerateConnectionIdentifier(ctx sdk.Context) string

func (Keeper) GetClientConnectionPaths 

func (k Keeper) GetClientConnectionPaths(ctx sdk.Context, clientID string) ([]string, bool)

GetClientConnectionPaths returns all the connection paths stored under a particular client

func (Keeper) GetCommitmentPrefix 

func (k Keeper) GetCommitmentPrefix() exported.Prefix

func (Keeper) GetConnection 

func (k Keeper) GetConnection(ctx sdk.Context, connectionID string) (types.ConnectionEnd, bool)

func (Keeper) GetConnects added in v1.5.25 

func (k Keeper) GetConnects(ctx sdk.Context, cb func(end types.ConnectionEnd) (stop bool))

func (Keeper) GetNextConnectionSequence 

func (k Keeper) GetNextConnectionSequence(ctx sdk.Context) uint64

GetNextConnectionSequence gets the next connection sequence from the store.

func (Keeper) GetTimestampAtHeight 

func (k Keeper) GetTimestampAtHeight(ctx sdk.Context, connection types.ConnectionEnd, height exported.Height) (uint64, error)

func (Keeper) Logger 

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

func (Keeper) SetClientConnectionPaths 

func (k Keeper) SetClientConnectionPaths(ctx sdk.Context, clientID string, paths []string)

SetClientConnectionPaths sets the connections paths for client

func (Keeper) SetConnection 

func (k Keeper) SetConnection(ctx sdk.Context, connectionID string, connection types.ConnectionEnd)

func (Keeper) SetNextConnectionSequence 

func (k Keeper) SetNextConnectionSequence(ctx sdk.Context, sequence uint64)

SetNextConnectionSequence sets the next connection sequence to the store.

func (Keeper) VerifyChannelState 

func (k Keeper) VerifyChannelState(ctx sdk.Context,
	connection exported.ConnectionI,
	height exported.Height,
	proof []byte,
	portID, channelID string,
	channel exported.ChannelI) error

func (Keeper) VerifyClientConsensusState 

func (k Keeper) VerifyClientConsensusState(
	ctx sdk.Context,
	connection exported.ConnectionI,
	height exported.Height,
	consensusHeight exported.Height,
	proof []byte,
	consensusState exported.ConsensusState,
) error

VerifyClientConsensusState verifies a proof of the consensus state of the specified client stored on the target machine.

func (Keeper) VerifyClientState 

func (k Keeper) VerifyClientState(
	ctx sdk.Context,
	connection exported.ConnectionI,
	height exported.Height,
	proof []byte,
	clientState exported.ClientState,
) error

VerifyClientState verifies a proof of a client state of the running machine stored on the target machine

func (Keeper) VerifyConnectionState 

func (k Keeper) VerifyConnectionState(
	ctx sdk.Context,
	connection exported.ConnectionI,
	height exported.Height,
	proof []byte,
	connectionID string,
	connectionEnd exported.ConnectionI,
) error

VerifyConnectionState verifies a proof of the connection state of the specified connection end stored on the target machine.

func (Keeper) VerifyNextSequenceRecv 

func (k Keeper) VerifyNextSequenceRecv(
	ctx sdk.Context,
	connection exported.ConnectionI,
	height exported.Height,
	proof []byte,
	portID,
	channelID string,
	nextSequenceRecv uint64,
) error

VerifyNextSequenceRecv verifies a proof of the next sequence number to be received of the specified channel at the specified port.

func (Keeper) VerifyPacketAcknowledgement 

func (k Keeper) VerifyPacketAcknowledgement(
	ctx sdk.Context,
	connection exported.ConnectionI,
	height exported.Height,
	proof []byte,
	portID,
	channelID string,
	sequence uint64,
	acknowledgement []byte,
) error

VerifyPacketAcknowledgement verifies a proof of an incoming packet acknowledgement at the specified port, specified channel, and specified sequence.

func (Keeper) VerifyPacketCommitment 

func (k Keeper) VerifyPacketCommitment(
	ctx sdk.Context,
	connection exported.ConnectionI,
	height exported.Height,
	proof []byte,
	portID,
	channelID string,
	sequence uint64,
	commitmentBytes []byte,
) error

VerifyPacketCommitment verifies a proof of an outgoing packet commitment at the specified port, specified channel, and specified sequence.

func (Keeper) VerifyPacketReceiptAbsence 

func (k Keeper) VerifyPacketReceiptAbsence(
	ctx sdk.Context,
	connection exported.ConnectionI,
	height exported.Height,
	proof []byte,
	portID,
	channelID string,
	sequence uint64,
) error

VerifyPacketReceiptAbsence verifies a proof of the absence of an incoming packet receipt at the specified port, specified channel, and specified sequence.

Source Files

View all Source files

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.