corda

package
v0.0.0-...-22ee8c0 Latest Latest
Warning

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

 Go to latest Published: Aug 1, 2023 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

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")
)

Functions

func RegisterInterfaces 

func RegisterInterfaces(registry codectypes.InterfaceRegistry)

RegisterInterfaces register the module interfaces to protobuf Any.

Types

type Chain 

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

func NewChain 

func NewChain(config ChainConfig) *Chain

func (*Chain) ChainID 

func (c *Chain) ChainID() string

func (*Chain) ClientID 

func (c *Chain) ClientID() string

func (*Chain) Codec 

func (c *Chain) Codec() codec.ProtoCodecMarshaler

func (*Chain) GetAddress 

func (c *Chain) GetAddress() (sdk.AccAddress, error)

func (*Chain) GetLatestHeight 

func (c *Chain) GetLatestHeight() (int64, error)

QueryLatestHeight queries the chain for the latest height and returns it

func (*Chain) Init 

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

func (*Chain) Path 

func (c *Chain) Path() *core.PathEnd

func (*Chain) QueryBalance 

func (c *Chain) QueryBalance(address sdk.AccAddress) (sdk.Coins, error)

QueryBalance returns the amount of coins in the relayer account

func (*Chain) QueryChannel 

func (c *Chain) QueryChannel(height int64) (chanRes *chantypes.QueryChannelResponse, err error)

QueryChannel returns the channel associated with a channelID

func (*Chain) QueryClientConsensusState 

func (c *Chain) QueryClientConsensusState(height int64, dstClientConsHeight ibcexported.Height) (*clienttypes.QueryConsensusStateResponse, error)

QueryClientConsensusState retrevies the latest consensus state for a client in state at a given height

func (*Chain) QueryClientState 

func (c *Chain) QueryClientState(height int64) (*clienttypes.QueryClientStateResponse, error)

height represents the height of src chain

func (*Chain) QueryConnection 

func (c *Chain) QueryConnection(height int64) (*conntypes.QueryConnectionResponse, error)

QueryConnection returns the remote end of a given connection

func (*Chain) QueryDenomTraces 

func (c *Chain) QueryDenomTraces(offset, limit uint64, height int64) (*transfertypes.QueryDenomTracesResponse, error)

QueryDenomTraces returns all the denom traces from a given chain

func (*Chain) QueryPacket 

func (c *Chain) QueryPacket(height int64, sequence uint64) (*chantypes.Packet, error)

QueryPacket returns a packet corresponds to a given sequence

func (*Chain) QueryPacketAcknowledgement 

func (c *Chain) QueryPacketAcknowledgement(height int64, sequence uint64) ([]byte, error)

func (*Chain) QueryPacketAcknowledgementCommitment 

func (c *Chain) QueryPacketAcknowledgementCommitment(height int64, seq uint64) (ackRes *chantypes.QueryPacketAcknowledgementResponse, err error)

QueryPacketAcknowledgementCommitment returns the packet ack proof at a given height

func (*Chain) QueryPacketAcknowledgementCommitments 

func (c *Chain) QueryPacketAcknowledgementCommitments(offset, limit uint64, height int64) (comRes *chantypes.QueryPacketAcknowledgementsResponse, err error)

QueryPacketAcknowledgements returns an array of packet acks

func (*Chain) QueryPacketCommitment 

func (c *Chain) QueryPacketCommitment(height int64, seq uint64) (comRes *chantypes.QueryPacketCommitmentResponse, err error)

QueryPacketCommitment returns the packet commitment proof at a given height

func (*Chain) QueryPacketCommitments 

func (c *Chain) QueryPacketCommitments(offset, limit uint64, height int64) (comRes *chantypes.QueryPacketCommitmentsResponse, err error)

QueryPacketCommitments returns an array of packet commitments

func (*Chain) QueryUnrecievedAcknowledgements 

func (c *Chain) QueryUnrecievedAcknowledgements(height int64, seqs []uint64) ([]uint64, error)

QueryUnrecievedAcknowledgements returns a list of unrelayed packet acks

func (*Chain) QueryUnrecievedPackets 

func (c *Chain) QueryUnrecievedPackets(height int64, seqs []uint64) ([]uint64, error)

QueryUnrecievedPackets returns a list of unrelayed packet commitments

func (*Chain) Send 

func (c *Chain) Send(msgs []sdk.Msg) bool

Send sends msgs to the chain and logging a result of it It returns a boolean value whether the result is success

func (*Chain) SendMsgs 

func (c *Chain) SendMsgs(msgs []sdk.Msg) ([]byte, error)

func (*Chain) SetPath 

func (c *Chain) SetPath(p *core.PathEnd) error

func (*Chain) StartEventListener 

func (c *Chain) StartEventListener(dst core.ChainI, strategy core.StrategyI)

type ChainConfig 

type ChainConfig struct {
	ChainId      string `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	GrpcAddr     string `protobuf:"bytes,2,opt,name=grpc_addr,json=grpcAddr,proto3" json:"grpc_addr,omitempty"`
	PartyName    string `protobuf:"bytes,3,opt,name=party_name,json=partyName,proto3" json:"party_name,omitempty"`
	BankGrpcAddr string `protobuf:"bytes,4,opt,name=bank_grpc_addr,json=bankGrpcAddr,proto3" json:"bank_grpc_addr,omitempty"`
}

func (ChainConfig) Build 

func (c ChainConfig) Build() (core.ChainI, error)

func (*ChainConfig) Descriptor 

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

func (*ChainConfig) Marshal 

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

func (*ChainConfig) MarshalTo 

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

func (*ChainConfig) MarshalToSizedBuffer 

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

func (*ChainConfig) ProtoMessage 

func (*ChainConfig) ProtoMessage()

func (*ChainConfig) Reset 

func (m *ChainConfig) Reset()

func (*ChainConfig) Size 

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

func (*ChainConfig) String 

func (m *ChainConfig) String() string

func (*ChainConfig) Unmarshal 

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

func (*ChainConfig) XXX_DiscardUnknown 

func (m *ChainConfig) XXX_DiscardUnknown()

func (*ChainConfig) XXX_Marshal 

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

func (*ChainConfig) XXX_Merge 

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

func (*ChainConfig) XXX_Size 

func (m *ChainConfig) XXX_Size() int

func (*ChainConfig) XXX_Unmarshal 

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

type Prover 

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

func NewProver 

func NewProver(chain *Chain) *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) 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 ibcexported.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) 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) 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() (header core.HeaderI, provableHeight int64, queryableHeight int64, err error)

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

type ProverConfig 

type ProverConfig struct {
}

func (ProverConfig) Build 

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

func (*ProverConfig) Descriptor 

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

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

Directories

Path Synopsis

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.