Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterCommitPluginCodecServer(s grpc.ServiceRegistrar, srv CommitPluginCodecServer)
- func RegisterMsgHasherServer(s grpc.ServiceRegistrar, srv MsgHasherServer)
- type BigInt
- type CommitPluginCodecClient
- type CommitPluginCodecServer
- type CommitPluginReport
- func (*CommitPluginReport) Descriptor() ([]byte, []int)deprecated
- func (x *CommitPluginReport) GetMerkleRoots() []*MerkleRootChain
- func (x *CommitPluginReport) GetPriceUpdates() *PriceUpdates
- func (*CommitPluginReport) ProtoMessage()
- func (x *CommitPluginReport) ProtoReflect() protoreflect.Message
- func (x *CommitPluginReport) Reset()
- func (x *CommitPluginReport) String() string
- type DecodeCommitPluginReportInput
- func (*DecodeCommitPluginReportInput) Descriptor() ([]byte, []int)deprecated
- func (x *DecodeCommitPluginReportInput) GetEncodedReport() []byte
- func (*DecodeCommitPluginReportInput) ProtoMessage()
- func (x *DecodeCommitPluginReportInput) ProtoReflect() protoreflect.Message
- func (x *DecodeCommitPluginReportInput) Reset()
- func (x *DecodeCommitPluginReportInput) String() string
- type DecodeCommitPluginReportOutput
- func (*DecodeCommitPluginReportOutput) Descriptor() ([]byte, []int)deprecated
- func (x *DecodeCommitPluginReportOutput) GetReport() *CommitPluginReport
- func (*DecodeCommitPluginReportOutput) ProtoMessage()
- func (x *DecodeCommitPluginReportOutput) ProtoReflect() protoreflect.Message
- func (x *DecodeCommitPluginReportOutput) Reset()
- func (x *DecodeCommitPluginReportOutput) String() string
- type EncodeCommitPluginReportInput
- func (*EncodeCommitPluginReportInput) Descriptor() ([]byte, []int)deprecated
- func (x *EncodeCommitPluginReportInput) GetReport() *CommitPluginReport
- func (*EncodeCommitPluginReportInput) ProtoMessage()
- func (x *EncodeCommitPluginReportInput) ProtoReflect() protoreflect.Message
- func (x *EncodeCommitPluginReportInput) Reset()
- func (x *EncodeCommitPluginReportInput) String() string
- type EncodeCommitPluginReportOutput
- func (*EncodeCommitPluginReportOutput) Descriptor() ([]byte, []int)deprecated
- func (x *EncodeCommitPluginReportOutput) GetEncodedReport() []byte
- func (*EncodeCommitPluginReportOutput) ProtoMessage()
- func (x *EncodeCommitPluginReportOutput) ProtoReflect() protoreflect.Message
- func (x *EncodeCommitPluginReportOutput) Reset()
- func (x *EncodeCommitPluginReportOutput) String() string
- type GasPriceChain
- func (*GasPriceChain) Descriptor() ([]byte, []int)deprecated
- func (x *GasPriceChain) GetChainSelector() uint64
- func (x *GasPriceChain) GetPrice() *BigInt
- func (*GasPriceChain) ProtoMessage()
- func (x *GasPriceChain) ProtoReflect() protoreflect.Message
- func (x *GasPriceChain) Reset()
- func (x *GasPriceChain) String() string
- type HashMsgInput
- type HashMsgOutput
- type MerkleRootChain
- func (*MerkleRootChain) Descriptor() ([]byte, []int)deprecated
- func (x *MerkleRootChain) GetChainSelector() uint64
- func (x *MerkleRootChain) GetMerkleRoot() []byte
- func (x *MerkleRootChain) GetSeqNumRange() *SeqNumRange
- func (*MerkleRootChain) ProtoMessage()
- func (x *MerkleRootChain) ProtoReflect() protoreflect.Message
- func (x *MerkleRootChain) Reset()
- func (x *MerkleRootChain) String() string
- type Message
- func (*Message) Descriptor() ([]byte, []int)deprecated
- func (x *Message) GetData() [][]byte
- func (x *Message) GetExtraArgs() [][]byte
- func (x *Message) GetFeeToken() [][]byte
- func (x *Message) GetFeeTokenAmount() *BigInt
- func (x *Message) GetHeader() *RampMessageHeader
- func (x *Message) GetReceiver() [][]byte
- func (x *Message) GetSender() [][]byte
- func (x *Message) GetTokenAmounts() []*RampTokenAmount
- func (*Message) ProtoMessage()
- func (x *Message) ProtoReflect() protoreflect.Message
- func (x *Message) Reset()
- func (x *Message) String() string
- type MsgHasherClient
- type MsgHasherServer
- type PriceUpdates
- func (*PriceUpdates) Descriptor() ([]byte, []int)deprecated
- func (x *PriceUpdates) GetGasPriceUpdates() []*GasPriceChain
- func (x *PriceUpdates) GetTokenPriceUpdates() []*TokenAmount
- func (*PriceUpdates) ProtoMessage()
- func (x *PriceUpdates) ProtoReflect() protoreflect.Message
- func (x *PriceUpdates) Reset()
- func (x *PriceUpdates) String() string
- type RampMessageHeader
- func (*RampMessageHeader) Descriptor() ([]byte, []int)deprecated
- func (x *RampMessageHeader) GetDestChainSelector() uint64
- func (x *RampMessageHeader) GetMessageHash() [][]byte
- func (x *RampMessageHeader) GetMessageId() [][]byte
- func (x *RampMessageHeader) GetNonce() uint64
- func (x *RampMessageHeader) GetOnRamp() [][]byte
- func (x *RampMessageHeader) GetSequenceNumber() uint64
- func (x *RampMessageHeader) GetSourceChainSelector() uint64
- func (*RampMessageHeader) ProtoMessage()
- func (x *RampMessageHeader) ProtoReflect() protoreflect.Message
- func (x *RampMessageHeader) Reset()
- func (x *RampMessageHeader) String() string
- type RampTokenAmount
- func (*RampTokenAmount) Descriptor() ([]byte, []int)deprecated
- func (x *RampTokenAmount) GetAmount() *BigInt
- func (x *RampTokenAmount) GetDestTokenAddress() [][]byte
- func (x *RampTokenAmount) GetExtraData() [][]byte
- func (x *RampTokenAmount) GetSourcePoolAddress() [][]byte
- func (*RampTokenAmount) ProtoMessage()
- func (x *RampTokenAmount) ProtoReflect() protoreflect.Message
- func (x *RampTokenAmount) Reset()
- func (x *RampTokenAmount) String() string
- type SeqNumRange
- type TokenAmount
- func (*TokenAmount) Descriptor() ([]byte, []int)deprecated
- func (x *TokenAmount) GetAmount() *BigInt
- func (x *TokenAmount) GetToken() string
- func (*TokenAmount) ProtoMessage()
- func (x *TokenAmount) ProtoReflect() protoreflect.Message
- func (x *TokenAmount) Reset()
- func (x *TokenAmount) String() string
- type UnimplementedCommitPluginCodecServer
- type UnimplementedMsgHasherServer
- type UnsafeCommitPluginCodecServer
- type UnsafeMsgHasherServer
Constants ¶
const ( CommitPluginCodec_Encode_FullMethodName = "/loop.internal.pb.ccipocr3.CommitPluginCodec/Encode" CommitPluginCodec_Decode_FullMethodName = "/loop.internal.pb.ccipocr3.CommitPluginCodec/Decode" )
const (
MsgHasher_HashMsg_FullMethodName = "/loop.internal.pb.ccipocr3.MsgHasher/HashMsg"
)
Variables ¶
var CommitPluginCodec_ServiceDesc = grpc.ServiceDesc{ ServiceName: "loop.internal.pb.ccipocr3.CommitPluginCodec", HandlerType: (*CommitPluginCodecServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Encode", Handler: _CommitPluginCodec_Encode_Handler, }, { MethodName: "Decode", Handler: _CommitPluginCodec_Decode_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "reportcodec.proto", }
CommitPluginCodec_ServiceDesc is the grpc.ServiceDesc for CommitPluginCodec service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_models_proto protoreflect.FileDescriptor
var File_msghasher_proto protoreflect.FileDescriptor
var File_reportcodec_proto protoreflect.FileDescriptor
var MsgHasher_ServiceDesc = grpc.ServiceDesc{ ServiceName: "loop.internal.pb.ccipocr3.MsgHasher", HandlerType: (*MsgHasherServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "HashMsg", Handler: _MsgHasher_HashMsg_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "msghasher.proto", }
MsgHasher_ServiceDesc is the grpc.ServiceDesc for MsgHasher service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterCommitPluginCodecServer ¶
func RegisterCommitPluginCodecServer(s grpc.ServiceRegistrar, srv CommitPluginCodecServer)
func RegisterMsgHasherServer ¶
func RegisterMsgHasherServer(s grpc.ServiceRegistrar, srv MsgHasherServer)
Types ¶
type BigInt ¶
type BigInt struct { Value []byte `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
BigInt represents a [big.Int].
func (*BigInt) Descriptor
deprecated
func (*BigInt) ProtoMessage ¶
func (*BigInt) ProtoMessage()
func (*BigInt) ProtoReflect ¶
func (x *BigInt) ProtoReflect() protoreflect.Message
type CommitPluginCodecClient ¶
type CommitPluginCodecClient interface { Encode(ctx context.Context, in *EncodeCommitPluginReportInput, opts ...grpc.CallOption) (*EncodeCommitPluginReportOutput, error) Decode(ctx context.Context, in *DecodeCommitPluginReportInput, opts ...grpc.CallOption) (*EncodeCommitPluginReportOutput, error) }
CommitPluginCodecClient is the client API for CommitPluginCodec service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewCommitPluginCodecClient ¶
func NewCommitPluginCodecClient(cc grpc.ClientConnInterface) CommitPluginCodecClient
type CommitPluginCodecServer ¶
type CommitPluginCodecServer interface { Encode(context.Context, *EncodeCommitPluginReportInput) (*EncodeCommitPluginReportOutput, error) Decode(context.Context, *DecodeCommitPluginReportInput) (*EncodeCommitPluginReportOutput, error) // contains filtered or unexported methods }
CommitPluginCodecServer is the server API for CommitPluginCodec service. All implementations must embed UnimplementedCommitPluginCodecServer for forward compatibility
type CommitPluginReport ¶
type CommitPluginReport struct { PriceUpdates *PriceUpdates `protobuf:"bytes,1,opt,name=price_updates,json=priceUpdates,proto3" json:"price_updates,omitempty"` MerkleRoots []*MerkleRootChain `protobuf:"bytes,2,rep,name=merkle_roots,json=merkleRoots,proto3" json:"merkle_roots,omitempty"` // contains filtered or unexported fields }
CommitPluginReport is a gRPC adapter to github.com/goplugin/plugin-common/pkg/types/ccipocr3.CommitPluginReport.
func (*CommitPluginReport) Descriptor
deprecated
func (*CommitPluginReport) Descriptor() ([]byte, []int)
Deprecated: Use CommitPluginReport.ProtoReflect.Descriptor instead.
func (*CommitPluginReport) GetMerkleRoots ¶
func (x *CommitPluginReport) GetMerkleRoots() []*MerkleRootChain
func (*CommitPluginReport) GetPriceUpdates ¶
func (x *CommitPluginReport) GetPriceUpdates() *PriceUpdates
func (*CommitPluginReport) ProtoMessage ¶
func (*CommitPluginReport) ProtoMessage()
func (*CommitPluginReport) ProtoReflect ¶
func (x *CommitPluginReport) ProtoReflect() protoreflect.Message
func (*CommitPluginReport) Reset ¶
func (x *CommitPluginReport) Reset()
func (*CommitPluginReport) String ¶
func (x *CommitPluginReport) String() string
type DecodeCommitPluginReportInput ¶
type DecodeCommitPluginReportInput struct { EncodedReport []byte `protobuf:"bytes,1,opt,name=encoded_report,json=encodedReport,proto3" json:"encoded_report,omitempty"` // contains filtered or unexported fields }
func (*DecodeCommitPluginReportInput) Descriptor
deprecated
func (*DecodeCommitPluginReportInput) Descriptor() ([]byte, []int)
Deprecated: Use DecodeCommitPluginReportInput.ProtoReflect.Descriptor instead.
func (*DecodeCommitPluginReportInput) GetEncodedReport ¶
func (x *DecodeCommitPluginReportInput) GetEncodedReport() []byte
func (*DecodeCommitPluginReportInput) ProtoMessage ¶
func (*DecodeCommitPluginReportInput) ProtoMessage()
func (*DecodeCommitPluginReportInput) ProtoReflect ¶
func (x *DecodeCommitPluginReportInput) ProtoReflect() protoreflect.Message
func (*DecodeCommitPluginReportInput) Reset ¶
func (x *DecodeCommitPluginReportInput) Reset()
func (*DecodeCommitPluginReportInput) String ¶
func (x *DecodeCommitPluginReportInput) String() string
type DecodeCommitPluginReportOutput ¶
type DecodeCommitPluginReportOutput struct { Report *CommitPluginReport `protobuf:"bytes,1,opt,name=report,proto3" json:"report,omitempty"` // contains filtered or unexported fields }
func (*DecodeCommitPluginReportOutput) Descriptor
deprecated
func (*DecodeCommitPluginReportOutput) Descriptor() ([]byte, []int)
Deprecated: Use DecodeCommitPluginReportOutput.ProtoReflect.Descriptor instead.
func (*DecodeCommitPluginReportOutput) GetReport ¶
func (x *DecodeCommitPluginReportOutput) GetReport() *CommitPluginReport
func (*DecodeCommitPluginReportOutput) ProtoMessage ¶
func (*DecodeCommitPluginReportOutput) ProtoMessage()
func (*DecodeCommitPluginReportOutput) ProtoReflect ¶
func (x *DecodeCommitPluginReportOutput) ProtoReflect() protoreflect.Message
func (*DecodeCommitPluginReportOutput) Reset ¶
func (x *DecodeCommitPluginReportOutput) Reset()
func (*DecodeCommitPluginReportOutput) String ¶
func (x *DecodeCommitPluginReportOutput) String() string
type EncodeCommitPluginReportInput ¶
type EncodeCommitPluginReportInput struct { Report *CommitPluginReport `protobuf:"bytes,1,opt,name=report,proto3" json:"report,omitempty"` // contains filtered or unexported fields }
func (*EncodeCommitPluginReportInput) Descriptor
deprecated
func (*EncodeCommitPluginReportInput) Descriptor() ([]byte, []int)
Deprecated: Use EncodeCommitPluginReportInput.ProtoReflect.Descriptor instead.
func (*EncodeCommitPluginReportInput) GetReport ¶
func (x *EncodeCommitPluginReportInput) GetReport() *CommitPluginReport
func (*EncodeCommitPluginReportInput) ProtoMessage ¶
func (*EncodeCommitPluginReportInput) ProtoMessage()
func (*EncodeCommitPluginReportInput) ProtoReflect ¶
func (x *EncodeCommitPluginReportInput) ProtoReflect() protoreflect.Message
func (*EncodeCommitPluginReportInput) Reset ¶
func (x *EncodeCommitPluginReportInput) Reset()
func (*EncodeCommitPluginReportInput) String ¶
func (x *EncodeCommitPluginReportInput) String() string
type EncodeCommitPluginReportOutput ¶
type EncodeCommitPluginReportOutput struct { EncodedReport []byte `protobuf:"bytes,1,opt,name=encoded_report,json=encodedReport,proto3" json:"encoded_report,omitempty"` // contains filtered or unexported fields }
func (*EncodeCommitPluginReportOutput) Descriptor
deprecated
func (*EncodeCommitPluginReportOutput) Descriptor() ([]byte, []int)
Deprecated: Use EncodeCommitPluginReportOutput.ProtoReflect.Descriptor instead.
func (*EncodeCommitPluginReportOutput) GetEncodedReport ¶
func (x *EncodeCommitPluginReportOutput) GetEncodedReport() []byte
func (*EncodeCommitPluginReportOutput) ProtoMessage ¶
func (*EncodeCommitPluginReportOutput) ProtoMessage()
func (*EncodeCommitPluginReportOutput) ProtoReflect ¶
func (x *EncodeCommitPluginReportOutput) ProtoReflect() protoreflect.Message
func (*EncodeCommitPluginReportOutput) Reset ¶
func (x *EncodeCommitPluginReportOutput) Reset()
func (*EncodeCommitPluginReportOutput) String ¶
func (x *EncodeCommitPluginReportOutput) String() string
type GasPriceChain ¶
type GasPriceChain struct { ChainSelector uint64 `protobuf:"varint,1,opt,name=chain_selector,json=chainSelector,proto3" json:"chain_selector,omitempty"` Price *BigInt `protobuf:"bytes,2,opt,name=price,proto3" json:"price,omitempty"` // contains filtered or unexported fields }
GasPriceChain is a gRPC adapter to github.com/goplugin/plugin-common/pkg/types/ccipocr3.GasPriceChain.
func (*GasPriceChain) Descriptor
deprecated
func (*GasPriceChain) Descriptor() ([]byte, []int)
Deprecated: Use GasPriceChain.ProtoReflect.Descriptor instead.
func (*GasPriceChain) GetChainSelector ¶
func (x *GasPriceChain) GetChainSelector() uint64
func (*GasPriceChain) GetPrice ¶
func (x *GasPriceChain) GetPrice() *BigInt
func (*GasPriceChain) ProtoMessage ¶
func (*GasPriceChain) ProtoMessage()
func (*GasPriceChain) ProtoReflect ¶
func (x *GasPriceChain) ProtoReflect() protoreflect.Message
func (*GasPriceChain) Reset ¶
func (x *GasPriceChain) Reset()
func (*GasPriceChain) String ¶
func (x *GasPriceChain) String() string
type HashMsgInput ¶
type HashMsgInput struct { Msg *Message `protobuf:"bytes,1,opt,name=msg,proto3" json:"msg,omitempty"` // contains filtered or unexported fields }
func (*HashMsgInput) Descriptor
deprecated
func (*HashMsgInput) Descriptor() ([]byte, []int)
Deprecated: Use HashMsgInput.ProtoReflect.Descriptor instead.
func (*HashMsgInput) GetMsg ¶
func (x *HashMsgInput) GetMsg() *Message
func (*HashMsgInput) ProtoMessage ¶
func (*HashMsgInput) ProtoMessage()
func (*HashMsgInput) ProtoReflect ¶
func (x *HashMsgInput) ProtoReflect() protoreflect.Message
func (*HashMsgInput) Reset ¶
func (x *HashMsgInput) Reset()
func (*HashMsgInput) String ¶
func (x *HashMsgInput) String() string
type HashMsgOutput ¶
type HashMsgOutput struct { Hash []byte `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"` // contains filtered or unexported fields }
func (*HashMsgOutput) Descriptor
deprecated
func (*HashMsgOutput) Descriptor() ([]byte, []int)
Deprecated: Use HashMsgOutput.ProtoReflect.Descriptor instead.
func (*HashMsgOutput) GetHash ¶
func (x *HashMsgOutput) GetHash() []byte
func (*HashMsgOutput) ProtoMessage ¶
func (*HashMsgOutput) ProtoMessage()
func (*HashMsgOutput) ProtoReflect ¶
func (x *HashMsgOutput) ProtoReflect() protoreflect.Message
func (*HashMsgOutput) Reset ¶
func (x *HashMsgOutput) Reset()
func (*HashMsgOutput) String ¶
func (x *HashMsgOutput) String() string
type MerkleRootChain ¶
type MerkleRootChain struct { ChainSelector uint64 `protobuf:"varint,1,opt,name=chain_selector,json=chainSelector,proto3" json:"chain_selector,omitempty"` MerkleRoot []byte `protobuf:"bytes,2,opt,name=merkle_root,json=merkleRoot,proto3" json:"merkle_root,omitempty"` SeqNumRange *SeqNumRange `protobuf:"bytes,3,opt,name=seq_num_range,json=seqNumRange,proto3" json:"seq_num_range,omitempty"` // contains filtered or unexported fields }
MerkleRootChain is a gRPC adapter to github.com/goplugin/plugin-common/pkg/types/ccipocr3.MerkleRootChain.
func (*MerkleRootChain) Descriptor
deprecated
func (*MerkleRootChain) Descriptor() ([]byte, []int)
Deprecated: Use MerkleRootChain.ProtoReflect.Descriptor instead.
func (*MerkleRootChain) GetChainSelector ¶
func (x *MerkleRootChain) GetChainSelector() uint64
func (*MerkleRootChain) GetMerkleRoot ¶
func (x *MerkleRootChain) GetMerkleRoot() []byte
func (*MerkleRootChain) GetSeqNumRange ¶
func (x *MerkleRootChain) GetSeqNumRange() *SeqNumRange
func (*MerkleRootChain) ProtoMessage ¶
func (*MerkleRootChain) ProtoMessage()
func (*MerkleRootChain) ProtoReflect ¶
func (x *MerkleRootChain) ProtoReflect() protoreflect.Message
func (*MerkleRootChain) Reset ¶
func (x *MerkleRootChain) Reset()
func (*MerkleRootChain) String ¶
func (x *MerkleRootChain) String() string
type Message ¶
type Message struct { // Header is the family-agnostic header for OnRamp and OffRamp messages. // This is always set on all CCIP messages. Header *RampMessageHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"` // Sender address on the source chain. // This is an EVM address, so len(Sender) == 20. Sender [][]byte `protobuf:"bytes,2,rep,name=sender,proto3" json:"sender,omitempty"` // Data is the arbitrary data payload supplied by the message sender. Data [][]byte `protobuf:"bytes,3,rep,name=data,proto3" json:"data,omitempty"` // Receiver is the receiver address on the destination chain. // This is encoded in the destination chain family specific encoding. // i.e if the destination is EVM, this is abi.encode(receiver). Receiver [][]byte `protobuf:"bytes,4,rep,name=receiver,proto3" json:"receiver,omitempty"` // ExtraArgs is destination-chain specific extra args, such as the gasLimit for EVM chains ExtraArgs [][]byte `protobuf:"bytes,5,rep,name=extra_args,json=extraArgs,proto3" json:"extra_args,omitempty"` // FeeToken is the fee token address. len(FeeToken) == 20 (i.e, is not abi-encoded) FeeToken [][]byte `protobuf:"bytes,6,rep,name=fee_token,json=feeToken,proto3" json:"fee_token,omitempty"` // FeeTokenAmount is the amount of fee tokens paid. FeeTokenAmount *BigInt `protobuf:"bytes,7,opt,name=fee_token_amount,json=feeTokenAmount,proto3" json:"fee_token_amount,omitempty"` // TokenAmounts is the array of tokens and amounts to transfer. TokenAmounts []*RampTokenAmount `protobuf:"bytes,8,rep,name=token_amounts,json=tokenAmounts,proto3" json:"token_amounts,omitempty"` // contains filtered or unexported fields }
Message is a gRPC adapter to github.com/goplugin/plugin-common/pkg/types/ccipocr3.Message.
func (*Message) Descriptor
deprecated
func (*Message) GetExtraArgs ¶
func (*Message) GetFeeToken ¶
func (*Message) GetFeeTokenAmount ¶
func (*Message) GetHeader ¶
func (x *Message) GetHeader() *RampMessageHeader
func (*Message) GetReceiver ¶
func (*Message) GetTokenAmounts ¶
func (x *Message) GetTokenAmounts() []*RampTokenAmount
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
func (*Message) ProtoReflect ¶
func (x *Message) ProtoReflect() protoreflect.Message
type MsgHasherClient ¶
type MsgHasherClient interface {
HashMsg(ctx context.Context, in *HashMsgInput, opts ...grpc.CallOption) (*HashMsgOutput, error)
}
MsgHasherClient is the client API for MsgHasher service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewMsgHasherClient ¶
func NewMsgHasherClient(cc grpc.ClientConnInterface) MsgHasherClient
type MsgHasherServer ¶
type MsgHasherServer interface { HashMsg(context.Context, *HashMsgInput) (*HashMsgOutput, error) // contains filtered or unexported methods }
MsgHasherServer is the server API for MsgHasher service. All implementations must embed UnimplementedMsgHasherServer for forward compatibility
type PriceUpdates ¶
type PriceUpdates struct { TokenPriceUpdates []*TokenAmount `protobuf:"bytes,1,rep,name=token_price_updates,json=tokenPriceUpdates,proto3" json:"token_price_updates,omitempty"` GasPriceUpdates []*GasPriceChain `protobuf:"bytes,2,rep,name=gas_price_updates,json=gasPriceUpdates,proto3" json:"gas_price_updates,omitempty"` // contains filtered or unexported fields }
PriceUpdates is a gRPC adapter to github.com/goplugin/plugin-common/pkg/types/ccipocr3.PriceUpdates.
func (*PriceUpdates) Descriptor
deprecated
func (*PriceUpdates) Descriptor() ([]byte, []int)
Deprecated: Use PriceUpdates.ProtoReflect.Descriptor instead.
func (*PriceUpdates) GetGasPriceUpdates ¶
func (x *PriceUpdates) GetGasPriceUpdates() []*GasPriceChain
func (*PriceUpdates) GetTokenPriceUpdates ¶
func (x *PriceUpdates) GetTokenPriceUpdates() []*TokenAmount
func (*PriceUpdates) ProtoMessage ¶
func (*PriceUpdates) ProtoMessage()
func (*PriceUpdates) ProtoReflect ¶
func (x *PriceUpdates) ProtoReflect() protoreflect.Message
func (*PriceUpdates) Reset ¶
func (x *PriceUpdates) Reset()
func (*PriceUpdates) String ¶
func (x *PriceUpdates) String() string
type RampMessageHeader ¶
type RampMessageHeader struct { // MessageID is a unique identifier for the message, it should be unique across all chains. // It is generated on the chain that the CCIP send is requested (i.e. the source chain of a message). MessageId [][]byte `protobuf:"bytes,1,rep,name=message_id,json=messageId,proto3" json:"message_id,omitempty"` // SourceChainSelector is the chain selector of the chain that the message originated from. SourceChainSelector uint64 `protobuf:"varint,2,opt,name=source_chain_selector,json=sourceChainSelector,proto3" json:"source_chain_selector,omitempty"` // DestChainSelector is the chain selector of the chain that the message is destined for. DestChainSelector uint64 `protobuf:"varint,3,opt,name=dest_chain_selector,json=destChainSelector,proto3" json:"dest_chain_selector,omitempty"` // SequenceNumber is an auto-incrementing sequence number for the message. // Not unique across lanes. SequenceNumber uint64 `protobuf:"varint,4,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"` // Nonce is the nonce for this lane for this sender, not unique across senders/lanes Nonce uint64 `protobuf:"varint,5,opt,name=nonce,proto3" json:"nonce,omitempty"` // MsgHash is the hash of all the message fields. MessageHash [][]byte `protobuf:"bytes,6,rep,name=message_hash,json=messageHash,proto3" json:"message_hash,omitempty"` // OnRamp is the address of the onramp that sent the message. OnRamp [][]byte `protobuf:"bytes,7,rep,name=on_ramp,json=onRamp,proto3" json:"on_ramp,omitempty"` // contains filtered or unexported fields }
RampMessageHeader is the family-agnostic header for OnRamp and OffRamp messages. The MessageID is not expected to match MsgHash, since it may originate from a different ramp family.
func (*RampMessageHeader) Descriptor
deprecated
func (*RampMessageHeader) Descriptor() ([]byte, []int)
Deprecated: Use RampMessageHeader.ProtoReflect.Descriptor instead.
func (*RampMessageHeader) GetDestChainSelector ¶
func (x *RampMessageHeader) GetDestChainSelector() uint64
func (*RampMessageHeader) GetMessageHash ¶
func (x *RampMessageHeader) GetMessageHash() [][]byte
func (*RampMessageHeader) GetMessageId ¶
func (x *RampMessageHeader) GetMessageId() [][]byte
func (*RampMessageHeader) GetNonce ¶
func (x *RampMessageHeader) GetNonce() uint64
func (*RampMessageHeader) GetOnRamp ¶
func (x *RampMessageHeader) GetOnRamp() [][]byte
func (*RampMessageHeader) GetSequenceNumber ¶
func (x *RampMessageHeader) GetSequenceNumber() uint64
func (*RampMessageHeader) GetSourceChainSelector ¶
func (x *RampMessageHeader) GetSourceChainSelector() uint64
func (*RampMessageHeader) ProtoMessage ¶
func (*RampMessageHeader) ProtoMessage()
func (*RampMessageHeader) ProtoReflect ¶
func (x *RampMessageHeader) ProtoReflect() protoreflect.Message
func (*RampMessageHeader) Reset ¶
func (x *RampMessageHeader) Reset()
func (*RampMessageHeader) String ¶
func (x *RampMessageHeader) String() string
type RampTokenAmount ¶
type RampTokenAmount struct { // SourcePoolAddress is the source pool address, abi encoded. This value is trusted // as it was obtained through the onRamp. It can be relied upon by the destination // pool to validate the source pool. SourcePoolAddress [][]byte `protobuf:"bytes,1,rep,name=source_pool_address,json=sourcePoolAddress,proto3" json:"source_pool_address,omitempty"` // DestTokenAddress is the address of the destination token, abi encoded in the case of EVM chains // This value is UNTRUSTED as any pool owner can return whatever value they want. DestTokenAddress [][]byte `protobuf:"bytes,2,rep,name=dest_token_address,json=destTokenAddress,proto3" json:"dest_token_address,omitempty"` // ExtraData is optional pool data to be transferred to the destination chain. Be default this is capped at // CCIP_LOCK_OR_BURN_V1_RET_BYTES bytes. If more data is required, the TokenTransferFeeConfig.destBytesOverhead // has to be set for the specific token. ExtraData [][]byte `protobuf:"bytes,3,rep,name=extra_data,json=extraData,proto3" json:"extra_data,omitempty"` // Amount is the amount of tokens to be transferred. Amount *BigInt `protobuf:"bytes,4,opt,name=amount,proto3" json:"amount,omitempty"` // contains filtered or unexported fields }
RampTokenAmount represents the family-agnostic token amounts used for both OnRamp & OffRamp messages.
func (*RampTokenAmount) Descriptor
deprecated
func (*RampTokenAmount) Descriptor() ([]byte, []int)
Deprecated: Use RampTokenAmount.ProtoReflect.Descriptor instead.
func (*RampTokenAmount) GetAmount ¶
func (x *RampTokenAmount) GetAmount() *BigInt
func (*RampTokenAmount) GetDestTokenAddress ¶
func (x *RampTokenAmount) GetDestTokenAddress() [][]byte
func (*RampTokenAmount) GetExtraData ¶
func (x *RampTokenAmount) GetExtraData() [][]byte
func (*RampTokenAmount) GetSourcePoolAddress ¶
func (x *RampTokenAmount) GetSourcePoolAddress() [][]byte
func (*RampTokenAmount) ProtoMessage ¶
func (*RampTokenAmount) ProtoMessage()
func (*RampTokenAmount) ProtoReflect ¶
func (x *RampTokenAmount) ProtoReflect() protoreflect.Message
func (*RampTokenAmount) Reset ¶
func (x *RampTokenAmount) Reset()
func (*RampTokenAmount) String ¶
func (x *RampTokenAmount) String() string
type SeqNumRange ¶
type SeqNumRange struct { Start uint64 `protobuf:"varint,1,opt,name=start,proto3" json:"start,omitempty"` End uint64 `protobuf:"varint,2,opt,name=end,proto3" json:"end,omitempty"` // contains filtered or unexported fields }
SeqNumRange defines an inclusive range of sequence numbers.
func (*SeqNumRange) Descriptor
deprecated
func (*SeqNumRange) Descriptor() ([]byte, []int)
Deprecated: Use SeqNumRange.ProtoReflect.Descriptor instead.
func (*SeqNumRange) GetEnd ¶
func (x *SeqNumRange) GetEnd() uint64
func (*SeqNumRange) GetStart ¶
func (x *SeqNumRange) GetStart() uint64
func (*SeqNumRange) ProtoMessage ¶
func (*SeqNumRange) ProtoMessage()
func (*SeqNumRange) ProtoReflect ¶
func (x *SeqNumRange) ProtoReflect() protoreflect.Message
func (*SeqNumRange) Reset ¶
func (x *SeqNumRange) Reset()
func (*SeqNumRange) String ¶
func (x *SeqNumRange) String() string
type TokenAmount ¶
type TokenAmount struct { Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"` // Token address Amount *BigInt `protobuf:"bytes,2,opt,name=amount,proto3" json:"amount,omitempty"` // contains filtered or unexported fields }
TokenAmount is a helper type that defines a token and an amount.
func (*TokenAmount) Descriptor
deprecated
func (*TokenAmount) Descriptor() ([]byte, []int)
Deprecated: Use TokenAmount.ProtoReflect.Descriptor instead.
func (*TokenAmount) GetAmount ¶
func (x *TokenAmount) GetAmount() *BigInt
func (*TokenAmount) GetToken ¶
func (x *TokenAmount) GetToken() string
func (*TokenAmount) ProtoMessage ¶
func (*TokenAmount) ProtoMessage()
func (*TokenAmount) ProtoReflect ¶
func (x *TokenAmount) ProtoReflect() protoreflect.Message
func (*TokenAmount) Reset ¶
func (x *TokenAmount) Reset()
func (*TokenAmount) String ¶
func (x *TokenAmount) String() string
type UnimplementedCommitPluginCodecServer ¶
type UnimplementedCommitPluginCodecServer struct { }
UnimplementedCommitPluginCodecServer must be embedded to have forward compatible implementations.
type UnimplementedMsgHasherServer ¶
type UnimplementedMsgHasherServer struct { }
UnimplementedMsgHasherServer must be embedded to have forward compatible implementations.
func (UnimplementedMsgHasherServer) HashMsg ¶
func (UnimplementedMsgHasherServer) HashMsg(context.Context, *HashMsgInput) (*HashMsgOutput, error)
type UnsafeCommitPluginCodecServer ¶
type UnsafeCommitPluginCodecServer interface {
// contains filtered or unexported methods
}
UnsafeCommitPluginCodecServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to CommitPluginCodecServer will result in compilation errors.
type UnsafeMsgHasherServer ¶
type UnsafeMsgHasherServer interface {
// contains filtered or unexported methods
}
UnsafeMsgHasherServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MsgHasherServer will result in compilation errors.