module

package
v0.0.0-...-965e82c Latest Latest
Warning

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

 Go to latest Published: Oct 11, 2023 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

View Source 
const Quorum string = "xx-quorum"

Variables

View Source 
var (
	ErrInvalidLengthConfig        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowConfig          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupConfig = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	ErrInvalidLengthQbft        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQbft          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQbft = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type ClientState 

type ClientState struct {
	TrustLevelNumerator   uint32 `protobuf:"varint,1,opt,name=trust_level_numerator,json=trustLevelNumerator,proto3" json:"trust_level_numerator,omitempty"`
	TrustLevelDenominator uint32 `` /* 127-byte string literal not displayed */
	TrustingPeriod        uint64 `protobuf:"varint,3,opt,name=trusting_period,json=trustingPeriod,proto3" json:"trusting_period,omitempty"`
	ChainId               int32  `protobuf:"varint,4,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	LatestHeight          int32  `protobuf:"varint,5,opt,name=latest_height,json=latestHeight,proto3" json:"latest_height,omitempty"`
	Frozen                int32  `protobuf:"varint,6,opt,name=frozen,proto3" json:"frozen,omitempty"`
	IbcStoreAddress       []byte `protobuf:"bytes,7,opt,name=ibc_store_address,json=ibcStoreAddress,proto3" json:"ibc_store_address,omitempty"`
}

func (*ClientState) CheckHeaderAndUpdateState 

func (cs *ClientState) CheckHeaderAndUpdateState(sdk.Context, codec.BinaryCodec, sdk.KVStore, exported.Header) (exported.ClientState, exported.ConsensusState, error)

func (*ClientState) CheckMisbehaviourAndUpdateState 

func (cs *ClientState) CheckMisbehaviourAndUpdateState(sdk.Context, codec.BinaryCodec, sdk.KVStore, exported.Misbehaviour) (exported.ClientState, error)

func (*ClientState) CheckSubstituteAndUpdateState 

func (cs *ClientState) CheckSubstituteAndUpdateState(ctx sdk.Context, cdc codec.BinaryCodec, subjectClientStore, substituteClientStore sdk.KVStore, substituteClient exported.ClientState) (exported.ClientState, error)

func (*ClientState) ClientType 

func (cs *ClientState) ClientType() string

func (*ClientState) Descriptor 

func (*ClientState) Descriptor() ([]byte, []int)

func (*ClientState) ExportMetadata 

func (cs *ClientState) ExportMetadata(sdk.KVStore) []exported.GenesisMetadata

func (*ClientState) GetLatestHeight 

func (cs *ClientState) GetLatestHeight() exported.Height

func (*ClientState) Initialize 

func (cs *ClientState) Initialize(sdk.Context, codec.BinaryCodec, sdk.KVStore, exported.ConsensusState) error

func (*ClientState) Marshal 

func (m *ClientState) Marshal() (dAtA []byte, err error)

func (*ClientState) MarshalTo 

func (m *ClientState) MarshalTo(dAtA []byte) (int, error)

func (*ClientState) MarshalToSizedBuffer 

func (m *ClientState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ClientState) ProtoMessage 

func (*ClientState) ProtoMessage()

func (*ClientState) Reset 

func (m *ClientState) Reset()

func (*ClientState) Size 

func (m *ClientState) Size() (n int)

func (*ClientState) Status 

func (cs *ClientState) Status(ctx sdk.Context, clientStore sdk.KVStore, cdc codec.BinaryCodec) exported.Status

func (*ClientState) String 

func (m *ClientState) String() string

func (*ClientState) Unmarshal 

func (m *ClientState) Unmarshal(dAtA []byte) error

func (*ClientState) Validate 

func (cs *ClientState) Validate() error

func (*ClientState) VerifyChannelState 

func (cs *ClientState) VerifyChannelState(
	store sdk.KVStore,
	cdc codec.BinaryCodec,
	height exported.Height,
	prefix exported.Prefix,
	proof []byte,
	portID,
	channelID string,
	channel exported.ChannelI,
) error

func (*ClientState) VerifyClientConsensusState 

func (cs *ClientState) VerifyClientConsensusState(
	store sdk.KVStore,
	cdc codec.BinaryCodec,
	height exported.Height,
	counterpartyClientIdentifier string,
	consensusHeight exported.Height,
	prefix exported.Prefix,
	proof []byte,
	consensusState exported.ConsensusState,
) error

func (*ClientState) VerifyClientState 

func (cs *ClientState) VerifyClientState(
	store sdk.KVStore,
	cdc codec.BinaryCodec,
	height exported.Height,
	prefix exported.Prefix,
	counterpartyClientIdentifier string,
	proof []byte,
	clientState exported.ClientState,
) error

func (*ClientState) VerifyConnectionState 

func (cs *ClientState) VerifyConnectionState(
	store sdk.KVStore,
	cdc codec.BinaryCodec,
	height exported.Height,
	prefix exported.Prefix,
	proof []byte,
	connectionID string,
	connectionEnd exported.ConnectionI,
) error

func (*ClientState) VerifyNextSequenceRecv 

func (cs *ClientState) VerifyNextSequenceRecv(
	ctx sdk.Context,
	store sdk.KVStore,
	cdc codec.BinaryCodec,
	height exported.Height,
	delayTimePeriod uint64,
	delayBlockPeriod uint64,
	prefix exported.Prefix,
	proof []byte,
	portID,
	channelID string,
	nextSequenceRecv uint64,
) error

func (*ClientState) VerifyPacketAcknowledgement 

func (cs *ClientState) VerifyPacketAcknowledgement(
	ctx sdk.Context,
	store sdk.KVStore,
	cdc codec.BinaryCodec,
	height exported.Height,
	delayTimePeriod uint64,
	delayBlockPeriod uint64,
	prefix exported.Prefix,
	proof []byte,
	portID,
	channelID string,
	sequence uint64,
	acknowledgement []byte,
) error

func (*ClientState) VerifyPacketCommitment 

func (cs *ClientState) VerifyPacketCommitment(
	ctx sdk.Context,
	store sdk.KVStore,
	cdc codec.BinaryCodec,
	height exported.Height,
	delayTimePeriod uint64,
	delayBlockPeriod uint64,
	prefix exported.Prefix,
	proof []byte,
	portID,
	channelID string,
	sequence uint64,
	commitmentBytes []byte,
) error

func (*ClientState) VerifyPacketReceiptAbsence 

func (cs *ClientState) VerifyPacketReceiptAbsence(
	ctx sdk.Context,
	store sdk.KVStore,
	cdc codec.BinaryCodec,
	height exported.Height,
	delayTimePeriod uint64,
	delayBlockPeriod uint64,
	prefix exported.Prefix,
	proof []byte,
	portID,
	channelID string,
	sequence uint64,
) error

func (*ClientState) VerifyUpgradeAndUpdateState 

func (cs *ClientState) VerifyUpgradeAndUpdateState(
	ctx sdk.Context,
	cdc codec.BinaryCodec,
	store sdk.KVStore,
	newClient exported.ClientState,
	newConsState exported.ConsensusState,
	proofUpgradeClient,
	proofUpgradeConsState []byte,
) (exported.ClientState, exported.ConsensusState, error)

func (*ClientState) XXX_DiscardUnknown 

func (m *ClientState) XXX_DiscardUnknown()

func (*ClientState) XXX_Marshal 

func (m *ClientState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ClientState) XXX_Merge 

func (m *ClientState) XXX_Merge(src proto.Message)

func (*ClientState) XXX_Size 

func (m *ClientState) XXX_Size() int

func (*ClientState) XXX_Unmarshal 

func (m *ClientState) XXX_Unmarshal(b []byte) error

func (*ClientState) ZeroCustomFields 

func (cs *ClientState) ZeroCustomFields() exported.ClientState

type ConsensusState 

type ConsensusState struct {
	Timestamp    uint64   `protobuf:"varint,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Root         []byte   `protobuf:"bytes,2,opt,name=root,proto3" json:"root,omitempty"`
	ValidatorSet [][]byte `protobuf:"bytes,3,rep,name=validator_set,json=validatorSet,proto3" json:"validator_set,omitempty"`
}

func (*ConsensusState) Descriptor 

func (*ConsensusState) Descriptor() ([]byte, []int)

func (*ConsensusState) GetRoot 

func (m *ConsensusState) GetRoot() []byte

func (*ConsensusState) GetTimestamp 

func (m *ConsensusState) GetTimestamp() uint64

func (*ConsensusState) GetValidatorSet 

func (m *ConsensusState) GetValidatorSet() [][]byte

func (*ConsensusState) Marshal 

func (m *ConsensusState) Marshal() (dAtA []byte, err error)

func (*ConsensusState) MarshalTo 

func (m *ConsensusState) MarshalTo(dAtA []byte) (int, error)

func (*ConsensusState) MarshalToSizedBuffer 

func (m *ConsensusState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ConsensusState) ProtoMessage 

func (*ConsensusState) ProtoMessage()

func (*ConsensusState) Reset 

func (m *ConsensusState) Reset()

func (*ConsensusState) Size 

func (m *ConsensusState) Size() (n int)

func (*ConsensusState) String 

func (m *ConsensusState) String() string

func (*ConsensusState) Unmarshal 

func (m *ConsensusState) Unmarshal(dAtA []byte) error

func (*ConsensusState) XXX_DiscardUnknown 

func (m *ConsensusState) XXX_DiscardUnknown()

func (*ConsensusState) XXX_Marshal 

func (m *ConsensusState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ConsensusState) XXX_Merge 

func (m *ConsensusState) XXX_Merge(src proto.Message)

func (*ConsensusState) XXX_Size 

func (m *ConsensusState) XXX_Size() int

func (*ConsensusState) XXX_Unmarshal 

func (m *ConsensusState) XXX_Unmarshal(b []byte) error
type Header struct {
	TrustedHeight     int32  `protobuf:"varint,1,opt,name=trusted_height,json=trustedHeight,proto3" json:"trusted_height,omitempty"`
	AccountProof      []byte `protobuf:"bytes,2,opt,name=account_proof,json=accountProof,proto3" json:"account_proof,omitempty"`
	GoQuorumHeaderRlp []byte `protobuf:"bytes,3,opt,name=go_quorum_header_rlp,json=goQuorumHeaderRlp,proto3" json:"go_quorum_header_rlp,omitempty"`
}

func (*Header) ClientType 

func (*Header) ClientType() string

func (*Header) Descriptor 

func (*Header) Descriptor() ([]byte, []int)

func (*Header) GetAccountProof 

func (m *Header) GetAccountProof() []byte

func (*Header) GetGoQuorumHeaderRlp 

func (m *Header) GetGoQuorumHeaderRlp() []byte

func (*Header) GetHeight 

func (h *Header) GetHeight() exported.Height

func (*Header) GetTrustedHeight 

func (m *Header) GetTrustedHeight() int32

func (*Header) Marshal 

func (m *Header) Marshal() (dAtA []byte, err error)

func (*Header) MarshalTo 

func (m *Header) MarshalTo(dAtA []byte) (int, error)

func (*Header) MarshalToSizedBuffer 

func (m *Header) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Header) ProtoMessage 

func (*Header) ProtoMessage()

func (*Header) Reset 

func (m *Header) Reset()

func (*Header) Size 

func (m *Header) Size() (n int)

func (*Header) String 

func (m *Header) String() string

func (*Header) Unmarshal 

func (m *Header) Unmarshal(dAtA []byte) error

func (*Header) ValidateBasic 

func (h *Header) ValidateBasic() error

func (*Header) XXX_DiscardUnknown 

func (m *Header) XXX_DiscardUnknown()

func (*Header) XXX_Marshal 

func (m *Header) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Header) XXX_Merge 

func (m *Header) XXX_Merge(src proto.Message)

func (*Header) XXX_Size 

func (m *Header) XXX_Size() int

func (*Header) XXX_Unmarshal 

func (m *Header) XXX_Unmarshal(b []byte) error

type Module 

type Module struct{}

func (Module) GetCmd 

func (Module) GetCmd(ctx *config.Context) *cobra.Command

GetCmd returns the command

func (Module) Name 

func (Module) Name() string

Name returns the name of the module

func (Module) RegisterInterfaces 

func (Module) RegisterInterfaces(registry codectypes.InterfaceRegistry)

RegisterInterfaces register the module interfaces to protobuf Any.

type Prover 

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

func NewProver 

func NewProver(chain *ethereum.Chain, config ProverConfig) *Prover

func (*Prover) CreateMsgCreateClient 

func (pr *Prover) CreateMsgCreateClient(clientID string, dstHeader core.HeaderI, signer sdk.AccAddress) (*clienttypes.MsgCreateClient, error)

CreateMsgCreateClient creates a CreateClientMsg to this chain

func (*Prover) GetChainID 

func (pr *Prover) GetChainID() string

GetChainID returns the chain ID

func (*Prover) GetLatestLightHeight 

func (pr *Prover) GetLatestLightHeight() (int64, error)

GetLatestLightHeight returns the latest height on the light client

func (*Prover) Init 

func (pr *Prover) Init(homePath string, timeout time.Duration, codec codec.ProtoCodecMarshaler, debug bool) error

Init initializes the chain

func (*Prover) QueryChannelWithProof 

func (pr *Prover) QueryChannelWithProof(height int64) (chanRes *chantypes.QueryChannelResponse, err error)

QueryChannelWithProof returns the Channel and its proof

func (*Prover) QueryClientConsensusStateWithProof 

func (pr *Prover) QueryClientConsensusStateWithProof(height int64, dstClientConsHeight exported.Height) (*clienttypes.QueryConsensusStateResponse, error)

QueryClientConsensusState returns the ClientConsensusState and its proof

func (*Prover) QueryClientStateWithProof 

func (pr *Prover) QueryClientStateWithProof(height int64) (*clienttypes.QueryClientStateResponse, error)

QueryClientStateWithProof returns the ClientState and its proof

func (*Prover) QueryConnectionWithProof 

func (pr *Prover) QueryConnectionWithProof(height int64) (*conntypes.QueryConnectionResponse, error)

QueryConnectionWithProof returns the Connection and its proof

func (*Prover) QueryHeader 

func (pr *Prover) QueryHeader(height int64) (core.HeaderI, error)

QueryHeader returns the header corresponding to the height

func (*Prover) QueryLatestHeader 

func (pr *Prover) QueryLatestHeader() (out core.HeaderI, err error)

QueryLatestHeader returns the latest header from the chain

func (*Prover) QueryPacketAcknowledgementCommitmentWithProof 

func (pr *Prover) QueryPacketAcknowledgementCommitmentWithProof(height int64, seq uint64) (ackRes *chantypes.QueryPacketAcknowledgementResponse, err error)

QueryPacketAcknowledgementCommitmentWithProof returns the packet acknowledgement commitment and its proof

func (*Prover) QueryPacketCommitmentWithProof 

func (pr *Prover) QueryPacketCommitmentWithProof(height int64, seq uint64) (comRes *chantypes.QueryPacketCommitmentResponse, err error)

QueryPacketCommitmentWithProof returns the packet commitment and its proof

func (*Prover) SetRelayInfo 

func (pr *Prover) SetRelayInfo(path *core.PathEnd, counterparty *core.ProvableChain, counterpartyPath *core.PathEnd) error

SetRelayInfo sets source's path and counterparty's info to the chain

func (*Prover) SetupForRelay 

func (pr *Prover) SetupForRelay(ctx context.Context) error

SetupForRelay performs chain-specific setup before starting the relay

func (*Prover) SetupHeader 

func (pr *Prover) SetupHeader(dst core.LightClientIBCQueryierI, baseSrcHeader core.HeaderI) (core.HeaderI, error)

SetupHeader creates a new header based on a given header

func (*Prover) UpdateLightWithHeader 

func (pr *Prover) UpdateLightWithHeader() (core.HeaderI, int64, int64, error)

UpdateLightWithHeader updates a header on the light client and returns the header and height corresponding to the chain

type ProverConfig 

type ProverConfig struct {
	TrustLevelNumerator   uint32 `protobuf:"varint,1,opt,name=trust_level_numerator,json=trustLevelNumerator,proto3" json:"trust_level_numerator,omitempty"`
	TrustLevelDenominator uint32 `` /* 127-byte string literal not displayed */
	TrustingPeriod        uint64 `protobuf:"varint,3,opt,name=trusting_period,json=trustingPeriod,proto3" json:"trusting_period,omitempty"`
}

func (ProverConfig) Build 

func (c ProverConfig) Build(chain core.ChainI) (core.ProverI, error)

func (*ProverConfig) Descriptor 

func (*ProverConfig) Descriptor() ([]byte, []int)

func (*ProverConfig) GetTrustLevelDenominator 

func (m *ProverConfig) GetTrustLevelDenominator() uint32

func (*ProverConfig) GetTrustLevelNumerator 

func (m *ProverConfig) GetTrustLevelNumerator() uint32

func (*ProverConfig) GetTrustingPeriod 

func (m *ProverConfig) GetTrustingPeriod() uint64

func (*ProverConfig) Marshal 

func (m *ProverConfig) Marshal() (dAtA []byte, err error)

func (*ProverConfig) MarshalTo 

func (m *ProverConfig) MarshalTo(dAtA []byte) (int, error)

func (*ProverConfig) MarshalToSizedBuffer 

func (m *ProverConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ProverConfig) ProtoMessage 

func (*ProverConfig) ProtoMessage()

func (*ProverConfig) Reset 

func (m *ProverConfig) Reset()

func (*ProverConfig) Size 

func (m *ProverConfig) Size() (n int)

func (*ProverConfig) String 

func (m *ProverConfig) String() string

func (*ProverConfig) Unmarshal 

func (m *ProverConfig) Unmarshal(dAtA []byte) error

func (*ProverConfig) XXX_DiscardUnknown 

func (m *ProverConfig) XXX_DiscardUnknown()

func (*ProverConfig) XXX_Marshal 

func (m *ProverConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ProverConfig) XXX_Merge 

func (m *ProverConfig) XXX_Merge(src proto.Message)

func (*ProverConfig) XXX_Size 

func (m *ProverConfig) XXX_Size() int

func (*ProverConfig) XXX_Unmarshal 

func (m *ProverConfig) XXX_Unmarshal(b []byte) error

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.