cosmos-sdk: github.com/cosmos/cosmos-sdk/x/ibc/03-connection/keeper Index | Files

package keeper

import "github.com/cosmos/cosmos-sdk/x/ibc/03-connection/keeper"

Index

Package Files

grpc_query.go handshake.go keeper.go verify.go

type Keeper Uses

type Keeper struct {
    // implements gRPC QueryServer interface
    types.QueryServer
    // contains filtered or unexported fields
}

Keeper defines the IBC connection keeper

func NewKeeper Uses

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

NewKeeper creates a new IBC connection Keeper instance

func (Keeper) ClientConnections Uses

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

ClientConnections implements the Query/ClientConnections gRPC method

func (Keeper) ConnOpenAck Uses

func (k Keeper) ConnOpenAck(
    ctx sdk.Context,
    connectionID string,
    encodedVersion string,
    proofTry []byte,
    proofConsensus []byte,
    proofHeight uint64,
    consensusHeight uint64,
) 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 Uses

func (k Keeper) ConnOpenConfirm(
    ctx sdk.Context,
    connectionID string,
    proofAck []byte,
    proofHeight uint64,
) 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 Uses

func (k Keeper) ConnOpenInit(
    ctx sdk.Context,
    connectionID,
    clientID string,
    counterparty types.Counterparty,
) error

ConnOpenInit initialises a connection attempt on chain A.

NOTE: Identifiers are checked on msg validation.

func (Keeper) ConnOpenTry Uses

func (k Keeper) ConnOpenTry(
    ctx sdk.Context,
    connectionID string,
    counterparty types.Counterparty,
    clientID string,
    counterpartyVersions []string,
    proofInit []byte,
    proofConsensus []byte,
    proofHeight uint64,
    consensusHeight uint64,
) 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 Uses

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

Connection implements the Query/Connection gRPC method

func (Keeper) ConnectionClientState Uses

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

ConnectionClientState implements the Query/ConnectionClientState gRPC method

func (Keeper) ConnectionConsensusState Uses

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

ConnectionConsensusState implements the Query/ConnectionConsensusState gRPC method

func (Keeper) Connections Uses

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

Connections implements the Query/Connections gRPC method

func (Keeper) GetAllClientConnectionPaths Uses

func (k Keeper) GetAllClientConnectionPaths(ctx sdk.Context) []types.ConnectionPaths

GetAllClientConnectionPaths returns all stored clients connection id paths. It will ignore the clients that haven't initialized a connection handshake since no paths are stored.

func (Keeper) GetAllConnections Uses

func (k Keeper) GetAllConnections(ctx sdk.Context) (connections []types.IdentifiedConnection)

GetAllConnections returns all stored ConnectionEnd objects.

func (Keeper) GetClientConnectionPaths Uses

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 Uses

func (k Keeper) GetCommitmentPrefix() commitmentexported.Prefix

GetCommitmentPrefix returns the IBC connection store prefix as a commitment Prefix

func (Keeper) GetConnection Uses

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

GetConnection returns a connection with a particular identifier

func (Keeper) GetTimestampAtHeight Uses

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

GetTimestampAtHeight returns the timestamp in nanoseconds of the consensus state at the given height.

func (Keeper) IterateConnections Uses

func (k Keeper) IterateConnections(ctx sdk.Context, cb func(types.IdentifiedConnection) bool)

IterateConnections provides an iterator over all ConnectionEnd objects. For each ConnectionEnd, cb will be called. If the cb returns true, the iterator will close and stop.

func (Keeper) Logger Uses

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

Logger returns a module-specific logger.

func (Keeper) SetClientConnectionPaths Uses

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

SetClientConnectionPaths sets the connections paths for client

func (Keeper) SetConnection Uses

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

SetConnection sets a connection to the store

func (Keeper) VerifyChannelState Uses

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

VerifyChannelState verifies a proof of the channel state of the specified channel end, under the specified port, stored on the target machine.

func (Keeper) VerifyClientConsensusState Uses

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

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

func (Keeper) VerifyConnectionState Uses

func (k Keeper) VerifyConnectionState(
    ctx sdk.Context,
    connection exported.ConnectionI,
    height uint64,
    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 Uses

func (k Keeper) VerifyNextSequenceRecv(
    ctx sdk.Context,
    connection exported.ConnectionI,
    height uint64,
    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 Uses

func (k Keeper) VerifyPacketAcknowledgement(
    ctx sdk.Context,
    connection exported.ConnectionI,
    height uint64,
    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) VerifyPacketAcknowledgementAbsence Uses

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

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

func (Keeper) VerifyPacketCommitment Uses

func (k Keeper) VerifyPacketCommitment(
    ctx sdk.Context,
    connection exported.ConnectionI,
    height uint64,
    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.

Package keeper imports 19 packages (graph) and is imported by 2 packages. Updated 2020-08-13. Refresh now. Tools for package owners.