Documentation
¶
Overview ¶
Code generated by protoc-gen-go-pulsar. DO NOT EDIT.
Code generated by protoc-gen-go-pulsar. DO NOT EDIT.
Code generated by protoc-gen-go-pulsar. DO NOT EDIT.
Code generated by protoc-gen-go-pulsar. DO NOT EDIT.
Index ¶
- Constants
- Variables
- func RegisterMsgServer(s grpc.ServiceRegistrar, srv MsgServer)
- func RegisterQueryServer(s grpc.ServiceRegistrar, srv QueryServer)
- type AggregateValue
- func (*AggregateValue) Descriptor() ([]byte, []int)deprecated
- func (x *AggregateValue) GetExtractIndex() uint32
- func (x *AggregateValue) GetMode() uint32
- func (x *AggregateValue) GetValue() []byte
- func (*AggregateValue) ProtoMessage()
- func (x *AggregateValue) ProtoReflect() protoreflect.Message
- func (x *AggregateValue) Reset()
- func (x *AggregateValue) String() string
- type GenesisState
- func (*GenesisState) Descriptor() ([]byte, []int)deprecated
- func (x *GenesisState) GetModuleAccountNonce() uint64
- func (x *GenesisState) GetParams() *Params
- func (x *GenesisState) GetUniversalReads() []*UniversalReadEntry
- func (*GenesisState) ProtoMessage()
- func (x *GenesisState) ProtoReflect() protoreflect.Message
- func (x *GenesisState) Reset()
- func (x *GenesisState) String() string
- type MsgClient
- type MsgRetryReadExpiry
- func (*MsgRetryReadExpiry) Descriptor() ([]byte, []int)deprecated
- func (x *MsgRetryReadExpiry) GetRequestId() string
- func (x *MsgRetryReadExpiry) GetSigner() string
- func (*MsgRetryReadExpiry) ProtoMessage()
- func (x *MsgRetryReadExpiry) ProtoReflect() protoreflect.Message
- func (x *MsgRetryReadExpiry) Reset()
- func (x *MsgRetryReadExpiry) String() string
- type MsgRetryReadExpiryResponse
- func (*MsgRetryReadExpiryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MsgRetryReadExpiryResponse) GetSettled() bool
- func (*MsgRetryReadExpiryResponse) ProtoMessage()
- func (x *MsgRetryReadExpiryResponse) ProtoReflect() protoreflect.Message
- func (x *MsgRetryReadExpiryResponse) Reset()
- func (x *MsgRetryReadExpiryResponse) String() string
- type MsgServer
- type MsgUpdateParams
- func (*MsgUpdateParams) Descriptor() ([]byte, []int)deprecated
- func (x *MsgUpdateParams) GetAuthority() string
- func (x *MsgUpdateParams) GetParams() *Params
- func (*MsgUpdateParams) ProtoMessage()
- func (x *MsgUpdateParams) ProtoReflect() protoreflect.Message
- func (x *MsgUpdateParams) Reset()
- func (x *MsgUpdateParams) String() string
- type MsgUpdateParamsResponse
- type MsgVoteReadResult
- func (*MsgVoteReadResult) Descriptor() ([]byte, []int)deprecated
- func (x *MsgVoteReadResult) GetRequestId() string
- func (x *MsgVoteReadResult) GetResult() *ReadResult
- func (x *MsgVoteReadResult) GetSigner() string
- func (*MsgVoteReadResult) ProtoMessage()
- func (x *MsgVoteReadResult) ProtoReflect() protoreflect.Message
- func (x *MsgVoteReadResult) Reset()
- func (x *MsgVoteReadResult) String() string
- type MsgVoteReadResultResponse
- func (*MsgVoteReadResultResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MsgVoteReadResultResponse) GetFinalized() bool
- func (*MsgVoteReadResultResponse) ProtoMessage()
- func (x *MsgVoteReadResultResponse) ProtoReflect() protoreflect.Message
- func (x *MsgVoteReadResultResponse) Reset()
- func (x *MsgVoteReadResultResponse) String() string
- type Params
- type QueryAllAbortedReadRequestsRequest
- func (*QueryAllAbortedReadRequestsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryAllAbortedReadRequestsRequest) GetPagination() *v1beta1.PageRequest
- func (*QueryAllAbortedReadRequestsRequest) ProtoMessage()
- func (x *QueryAllAbortedReadRequestsRequest) ProtoReflect() protoreflect.Message
- func (x *QueryAllAbortedReadRequestsRequest) Reset()
- func (x *QueryAllAbortedReadRequestsRequest) String() string
- type QueryAllAbortedReadRequestsResponse
- func (*QueryAllAbortedReadRequestsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryAllAbortedReadRequestsResponse) GetPagination() *v1beta1.PageResponse
- func (x *QueryAllAbortedReadRequestsResponse) GetReads() []*UniversalRead
- func (*QueryAllAbortedReadRequestsResponse) ProtoMessage()
- func (x *QueryAllAbortedReadRequestsResponse) ProtoReflect() protoreflect.Message
- func (x *QueryAllAbortedReadRequestsResponse) Reset()
- func (x *QueryAllAbortedReadRequestsResponse) String() string
- type QueryAllPendingReadRequestsRequest
- func (*QueryAllPendingReadRequestsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryAllPendingReadRequestsRequest) GetPagination() *v1beta1.PageRequest
- func (*QueryAllPendingReadRequestsRequest) ProtoMessage()
- func (x *QueryAllPendingReadRequestsRequest) ProtoReflect() protoreflect.Message
- func (x *QueryAllPendingReadRequestsRequest) Reset()
- func (x *QueryAllPendingReadRequestsRequest) String() string
- type QueryAllPendingReadRequestsResponse
- func (*QueryAllPendingReadRequestsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryAllPendingReadRequestsResponse) GetPagination() *v1beta1.PageResponse
- func (x *QueryAllPendingReadRequestsResponse) GetReads() []*UniversalRead
- func (*QueryAllPendingReadRequestsResponse) ProtoMessage()
- func (x *QueryAllPendingReadRequestsResponse) ProtoReflect() protoreflect.Message
- func (x *QueryAllPendingReadRequestsResponse) Reset()
- func (x *QueryAllPendingReadRequestsResponse) String() string
- type QueryClient
- type QueryParamsRequest
- type QueryParamsResponse
- func (*QueryParamsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryParamsResponse) GetParams() *Params
- func (*QueryParamsResponse) ProtoMessage()
- func (x *QueryParamsResponse) ProtoReflect() protoreflect.Message
- func (x *QueryParamsResponse) Reset()
- func (x *QueryParamsResponse) String() string
- type QueryReadsByTxRequest
- func (*QueryReadsByTxRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryReadsByTxRequest) GetTxHash() string
- func (*QueryReadsByTxRequest) ProtoMessage()
- func (x *QueryReadsByTxRequest) ProtoReflect() protoreflect.Message
- func (x *QueryReadsByTxRequest) Reset()
- func (x *QueryReadsByTxRequest) String() string
- type QueryReadsByTxResponse
- func (*QueryReadsByTxResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryReadsByTxResponse) GetReads() []*UniversalRead
- func (*QueryReadsByTxResponse) ProtoMessage()
- func (x *QueryReadsByTxResponse) ProtoReflect() protoreflect.Message
- func (x *QueryReadsByTxResponse) Reset()
- func (x *QueryReadsByTxResponse) String() string
- type QueryServer
- type QueryUniversalReadRequest
- func (*QueryUniversalReadRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryUniversalReadRequest) GetRequestId() string
- func (*QueryUniversalReadRequest) ProtoMessage()
- func (x *QueryUniversalReadRequest) ProtoReflect() protoreflect.Message
- func (x *QueryUniversalReadRequest) Reset()
- func (x *QueryUniversalReadRequest) String() string
- type QueryUniversalReadResponse
- func (*QueryUniversalReadResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryUniversalReadResponse) GetRead() *UniversalRead
- func (*QueryUniversalReadResponse) ProtoMessage()
- func (x *QueryUniversalReadResponse) ProtoReflect() protoreflect.Message
- func (x *QueryUniversalReadResponse) Reset()
- func (x *QueryUniversalReadResponse) String() string
- type ReadErrorCode
- func (ReadErrorCode) Descriptor() protoreflect.EnumDescriptor
- func (x ReadErrorCode) Enum() *ReadErrorCode
- func (ReadErrorCode) EnumDescriptor() ([]byte, []int)deprecated
- func (x ReadErrorCode) Number() protoreflect.EnumNumber
- func (x ReadErrorCode) String() string
- func (ReadErrorCode) Type() protoreflect.EnumType
- type ReadRequest
- func (*ReadRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReadRequest) GetCallbackBudget() string
- func (x *ReadRequest) GetCallbackGasLimit() uint64
- func (x *ReadRequest) GetCallbackTarget() string
- func (x *ReadRequest) GetCreatedAtHeight() uint64
- func (x *ReadRequest) GetDestinationBlockHeight() uint64
- func (x *ReadRequest) GetDestinationChain() string
- func (x *ReadRequest) GetExpiryBlockHeight() uint64
- func (x *ReadRequest) GetFeesDeposited() string
- func (x *ReadRequest) GetMaxFee() string
- func (x *ReadRequest) GetMinConfirmations() uint32
- func (x *ReadRequest) GetOriginalFunder() string
- func (x *ReadRequest) GetOwner() []byte
- func (x *ReadRequest) GetProtocolFee() string
- func (x *ReadRequest) GetQuery() []byte
- func (x *ReadRequest) GetRequestId() string
- func (x *ReadRequest) GetRequestedLogIndex() uint64
- func (x *ReadRequest) GetRequestedTxHash() string
- func (x *ReadRequest) GetRevertRecipient() string
- func (*ReadRequest) ProtoMessage()
- func (x *ReadRequest) ProtoReflect() protoreflect.Message
- func (x *ReadRequest) Reset()
- func (x *ReadRequest) String() string
- type ReadResult
- func (*ReadResult) Descriptor() ([]byte, []int)deprecated
- func (x *ReadResult) GetAggregates() []*AggregateValue
- func (x *ReadResult) GetErrorCode() ReadErrorCode
- func (x *ReadResult) GetResultData() []byte
- func (x *ReadResult) GetStatus() ReadStatus
- func (*ReadResult) ProtoMessage()
- func (x *ReadResult) ProtoReflect() protoreflect.Message
- func (x *ReadResult) Reset()
- func (x *ReadResult) String() string
- type ReadStatus
- type UnimplementedMsgServer
- func (UnimplementedMsgServer) RetryReadExpiry(context.Context, *MsgRetryReadExpiry) (*MsgRetryReadExpiryResponse, error)
- func (UnimplementedMsgServer) UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
- func (UnimplementedMsgServer) VoteReadResult(context.Context, *MsgVoteReadResult) (*MsgVoteReadResultResponse, error)
- type UnimplementedQueryServer
- func (UnimplementedQueryServer) AllAbortedReadRequests(context.Context, *QueryAllAbortedReadRequestsRequest) (*QueryAllAbortedReadRequestsResponse, error)
- func (UnimplementedQueryServer) AllPendingReadRequests(context.Context, *QueryAllPendingReadRequestsRequest) (*QueryAllPendingReadRequestsResponse, error)
- func (UnimplementedQueryServer) Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
- func (UnimplementedQueryServer) ReadsByTx(context.Context, *QueryReadsByTxRequest) (*QueryReadsByTxResponse, error)
- func (UnimplementedQueryServer) UniversalRead(context.Context, *QueryUniversalReadRequest) (*QueryUniversalReadResponse, error)
- type UniversalRead
- func (*UniversalRead) Descriptor() ([]byte, []int)deprecated
- func (x *UniversalRead) GetBallotKey() string
- func (x *UniversalRead) GetErrorMsg() string
- func (x *UniversalRead) GetExpiryAttempts() uint32
- func (x *UniversalRead) GetId() string
- func (x *UniversalRead) GetPcTx() []*v1.PCTx
- func (x *UniversalRead) GetRequest() *ReadRequest
- func (x *UniversalRead) GetResult() *ReadResult
- func (x *UniversalRead) GetStatus() UniversalReadStatus
- func (*UniversalRead) ProtoMessage()
- func (x *UniversalRead) ProtoReflect() protoreflect.Message
- func (x *UniversalRead) Reset()
- func (x *UniversalRead) String() string
- type UniversalReadEntry
- func (*UniversalReadEntry) Descriptor() ([]byte, []int)deprecated
- func (x *UniversalReadEntry) GetKey() string
- func (x *UniversalReadEntry) GetValue() *UniversalRead
- func (*UniversalReadEntry) ProtoMessage()
- func (x *UniversalReadEntry) ProtoReflect() protoreflect.Message
- func (x *UniversalReadEntry) Reset()
- func (x *UniversalReadEntry) String() string
- type UniversalReadStatus
- func (UniversalReadStatus) Descriptor() protoreflect.EnumDescriptor
- func (x UniversalReadStatus) Enum() *UniversalReadStatus
- func (UniversalReadStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x UniversalReadStatus) Number() protoreflect.EnumNumber
- func (x UniversalReadStatus) String() string
- func (UniversalReadStatus) Type() protoreflect.EnumType
- type UnsafeMsgServer
- type UnsafeQueryServer
Constants ¶
const ( Query_Params_FullMethodName = "/ucallback.v1.Query/Params" Query_AllPendingReadRequests_FullMethodName = "/ucallback.v1.Query/AllPendingReadRequests" Query_UniversalRead_FullMethodName = "/ucallback.v1.Query/UniversalRead" Query_AllAbortedReadRequests_FullMethodName = "/ucallback.v1.Query/AllAbortedReadRequests" Query_ReadsByTx_FullMethodName = "/ucallback.v1.Query/ReadsByTx" )
const ( Msg_VoteReadResult_FullMethodName = "/ucallback.v1.Msg/VoteReadResult" Msg_RetryReadExpiry_FullMethodName = "/ucallback.v1.Msg/RetryReadExpiry" Msg_UpdateParams_FullMethodName = "/ucallback.v1.Msg/UpdateParams" )
Variables ¶
var ( ReadErrorCode_name = map[int32]string{ 0: "READ_ERROR_UNSPECIFIED", 1: "READ_ERROR_INVALID_QUERY", 2: "READ_ERROR_UNSUPPORTED", 3: "READ_ERROR_REVERTED", 4: "READ_ERROR_NOT_FOUND", 5: "READ_ERROR_INVALID_RESULT", 6: "READ_ERROR_REJECTED", } ReadErrorCode_value = map[string]int32{ "READ_ERROR_UNSPECIFIED": 0, "READ_ERROR_INVALID_QUERY": 1, "READ_ERROR_UNSUPPORTED": 2, "READ_ERROR_REVERTED": 3, "READ_ERROR_NOT_FOUND": 4, "READ_ERROR_INVALID_RESULT": 5, "READ_ERROR_REJECTED": 6, } )
Enum value maps for ReadErrorCode.
var ( ReadStatus_name = map[int32]string{ 0: "READ_STATUS_UNSPECIFIED", 1: "READ_STATUS_SUCCESS", 2: "READ_STATUS_ERROR", } ReadStatus_value = map[string]int32{ "READ_STATUS_UNSPECIFIED": 0, "READ_STATUS_SUCCESS": 1, "READ_STATUS_ERROR": 2, } )
Enum value maps for ReadStatus.
var ( UniversalReadStatus_name = map[int32]string{ 0: "UNIVERSAL_READ_STATUS_UNSPECIFIED", 1: "UNIVERSAL_READ_STATUS_PENDING", 2: "UNIVERSAL_READ_STATUS_VOTING", 3: "UNIVERSAL_READ_STATUS_FULFILLED", 4: "UNIVERSAL_READ_STATUS_EXPIRED", 5: "UNIVERSAL_READ_STATUS_FAILED", 6: "UNIVERSAL_READ_STATUS_ABORTED", } UniversalReadStatus_value = map[string]int32{ "UNIVERSAL_READ_STATUS_UNSPECIFIED": 0, "UNIVERSAL_READ_STATUS_PENDING": 1, "UNIVERSAL_READ_STATUS_VOTING": 2, "UNIVERSAL_READ_STATUS_FULFILLED": 3, "UNIVERSAL_READ_STATUS_EXPIRED": 4, "UNIVERSAL_READ_STATUS_FAILED": 5, "UNIVERSAL_READ_STATUS_ABORTED": 6, } )
Enum value maps for UniversalReadStatus.
var File_ucallback_v1_genesis_proto protoreflect.FileDescriptor
var File_ucallback_v1_query_proto protoreflect.FileDescriptor
var File_ucallback_v1_tx_proto protoreflect.FileDescriptor
var File_ucallback_v1_types_proto protoreflect.FileDescriptor
var Msg_ServiceDesc = grpc.ServiceDesc{ ServiceName: "ucallback.v1.Msg", HandlerType: (*MsgServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "VoteReadResult", Handler: _Msg_VoteReadResult_Handler, }, { MethodName: "RetryReadExpiry", Handler: _Msg_RetryReadExpiry_Handler, }, { MethodName: "UpdateParams", Handler: _Msg_UpdateParams_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "ucallback/v1/tx.proto", }
Msg_ServiceDesc is the grpc.ServiceDesc for Msg service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Query_ServiceDesc = grpc.ServiceDesc{ ServiceName: "ucallback.v1.Query", HandlerType: (*QueryServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Params", Handler: _Query_Params_Handler, }, { MethodName: "AllPendingReadRequests", Handler: _Query_AllPendingReadRequests_Handler, }, { MethodName: "UniversalRead", Handler: _Query_UniversalRead_Handler, }, { MethodName: "AllAbortedReadRequests", Handler: _Query_AllAbortedReadRequests_Handler, }, { MethodName: "ReadsByTx", Handler: _Query_ReadsByTx_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "ucallback/v1/query.proto", }
Query_ServiceDesc is the grpc.ServiceDesc for Query service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterMsgServer ¶
func RegisterMsgServer(s grpc.ServiceRegistrar, srv MsgServer)
func RegisterQueryServer ¶
func RegisterQueryServer(s grpc.ServiceRegistrar, srv QueryServer)
Types ¶
type AggregateValue ¶
type AggregateValue struct {
ExtractIndex uint32 `protobuf:"varint,1,opt,name=extract_index,json=extractIndex,proto3" json:"extract_index,omitempty"` // index into the query envelope's extract list
Mode uint32 `protobuf:"varint,2,opt,name=mode,proto3" json:"mode,omitempty"` // aggregation mode; only MEDIAN is planned
Value []byte `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` // big-endian uint256/int256
// contains filtered or unexported fields
}
AggregateValue is one field the module combines across validators instead of requiring byte-equality on — a price, say, where honest nodes legitimately differ.
NOT USED IN v1. The universal client rejects any extract mode other than IDENTICAL (externalchains/web2/read_envelope.go), so this list is always empty today. The field is reserved now because adding it later would change how ballots are keyed on a live chain, which is consensus-breaking. In v1 the ballot key covers all of fields 1-4; in v2 it must cover only fields 1-4 with `aggregates` EXCLUDED, so computing the key over "the identical subset" from the start keeps v2 purely additive.
v2 ALSO REQUIRES REPLACING THE BALLOT MECHANISM, not just populating this field. Ballots today store a binary VoteResult{SUCCESS|FAILURE} against an ID that encodes the observation, so distinct observations produce distinct ballots and none reaches quorum when validators report different numbers. Ballots therefore cannot retain per-validator values, which is exactly what a median needs. v2 has to keep each validator's AggregateValue set in module state and reduce at quorum — the pattern x/uexecutor already uses for gas-price medians in keeper/chain_meta.go, which bypasses ballots for the same reason.
func (*AggregateValue) Descriptor
deprecated
func (*AggregateValue) Descriptor() ([]byte, []int)
Deprecated: Use AggregateValue.ProtoReflect.Descriptor instead.
func (*AggregateValue) GetExtractIndex ¶
func (x *AggregateValue) GetExtractIndex() uint32
func (*AggregateValue) GetMode ¶
func (x *AggregateValue) GetMode() uint32
func (*AggregateValue) GetValue ¶
func (x *AggregateValue) GetValue() []byte
func (*AggregateValue) ProtoMessage ¶
func (*AggregateValue) ProtoMessage()
func (*AggregateValue) ProtoReflect ¶
func (x *AggregateValue) ProtoReflect() protoreflect.Message
func (*AggregateValue) Reset ¶
func (x *AggregateValue) Reset()
func (*AggregateValue) String ¶
func (x *AggregateValue) String() string
type GenesisState ¶
type GenesisState struct {
// Params defines all the parameters of the module.
Params *Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"`
// universal_reads are key-value pairs from the UniversalReads map.
//
// Only the canonical records are exported. PendingByExpiry and ReadsByTxHash
// are indexes derived from these, and are rebuilt during InitGenesis rather
// than exported — so they cannot be imported out of sync with the records they
// point at.
UniversalReads []*UniversalReadEntry `protobuf:"bytes,2,rep,name=universal_reads,json=universalReads,proto3" json:"universal_reads,omitempty"`
// module_account_nonce is the EVM nonce of the x/ucallback module account.
//
// Must round-trip through genesis: it is the nonce of a real EVM account, and
// exporting state without it would make every module call after an import reuse
// nonces the chain had already consumed.
ModuleAccountNonce uint64 `protobuf:"varint,3,opt,name=module_account_nonce,json=moduleAccountNonce,proto3" json:"module_account_nonce,omitempty"`
// contains filtered or unexported fields
}
GenesisState defines the module genesis state
func (*GenesisState) Descriptor
deprecated
func (*GenesisState) Descriptor() ([]byte, []int)
Deprecated: Use GenesisState.ProtoReflect.Descriptor instead.
func (*GenesisState) GetModuleAccountNonce ¶
func (x *GenesisState) GetModuleAccountNonce() uint64
func (*GenesisState) GetParams ¶
func (x *GenesisState) GetParams() *Params
func (*GenesisState) GetUniversalReads ¶
func (x *GenesisState) GetUniversalReads() []*UniversalReadEntry
func (*GenesisState) ProtoMessage ¶
func (*GenesisState) ProtoMessage()
func (*GenesisState) ProtoReflect ¶
func (x *GenesisState) ProtoReflect() protoreflect.Message
func (*GenesisState) Reset ¶
func (x *GenesisState) Reset()
func (*GenesisState) String ¶
func (x *GenesisState) String() string
type MsgClient ¶
type MsgClient interface {
// VoteReadResult submits one universal validator's observation of a read
// request's outcome on the destination chain.
VoteReadResult(ctx context.Context, in *MsgVoteReadResult, opts ...grpc.CallOption) (*MsgVoteReadResultResponse, error)
// RetryReadExpiry reopens the expiry of a read the chain abandoned.
RetryReadExpiry(ctx context.Context, in *MsgRetryReadExpiry, opts ...grpc.CallOption) (*MsgRetryReadExpiryResponse, error)
// UpdateParams defines a governance operation for updating the parameters.
//
// Since: cosmos-sdk 0.47
UpdateParams(ctx context.Context, in *MsgUpdateParams, opts ...grpc.CallOption) (*MsgUpdateParamsResponse, error)
}
MsgClient is the client API for Msg 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 NewMsgClient ¶
func NewMsgClient(cc grpc.ClientConnInterface) MsgClient
type MsgRetryReadExpiry ¶
type MsgRetryReadExpiry struct {
// signer must equal uvalidator Params.Admin
Signer string `protobuf:"bytes,1,opt,name=signer,proto3" json:"signer,omitempty"`
// request_id of the abandoned read.
RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// contains filtered or unexported fields
}
MsgRetryReadExpiry is an admin escape hatch. For a read left ABORTED after MaxExpiryAttempts, this makes one more attempt at expireExternalRead.
Needed because ABORTED is a dead end that nothing else can leave. The contract may still hold the request as pending with the funder's refund uncredited, and expireExternalRead is module-gated — no user, relayer or admin can call it directly. The sweeper will not retry either: ABORTED is terminal, so the record is out of PendingByExpiry.
Each message is worth exactly one attempt: the attempt count is the record's own PCTx history, which is already at the limit, so a failure returns it to ABORTED with the new reason rather than granting a fresh budget.
func (*MsgRetryReadExpiry) Descriptor
deprecated
func (*MsgRetryReadExpiry) Descriptor() ([]byte, []int)
Deprecated: Use MsgRetryReadExpiry.ProtoReflect.Descriptor instead.
func (*MsgRetryReadExpiry) GetRequestId ¶
func (x *MsgRetryReadExpiry) GetRequestId() string
func (*MsgRetryReadExpiry) GetSigner ¶
func (x *MsgRetryReadExpiry) GetSigner() string
func (*MsgRetryReadExpiry) ProtoMessage ¶
func (*MsgRetryReadExpiry) ProtoMessage()
func (*MsgRetryReadExpiry) ProtoReflect ¶
func (x *MsgRetryReadExpiry) ProtoReflect() protoreflect.Message
func (*MsgRetryReadExpiry) Reset ¶
func (x *MsgRetryReadExpiry) Reset()
func (*MsgRetryReadExpiry) String ¶
func (x *MsgRetryReadExpiry) String() string
type MsgRetryReadExpiryResponse ¶
type MsgRetryReadExpiryResponse struct {
// settled reports whether the contract accepted the expiry this time.
Settled bool `protobuf:"varint,1,opt,name=settled,proto3" json:"settled,omitempty"`
// contains filtered or unexported fields
}
func (*MsgRetryReadExpiryResponse) Descriptor
deprecated
func (*MsgRetryReadExpiryResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgRetryReadExpiryResponse.ProtoReflect.Descriptor instead.
func (*MsgRetryReadExpiryResponse) GetSettled ¶
func (x *MsgRetryReadExpiryResponse) GetSettled() bool
func (*MsgRetryReadExpiryResponse) ProtoMessage ¶
func (*MsgRetryReadExpiryResponse) ProtoMessage()
func (*MsgRetryReadExpiryResponse) ProtoReflect ¶
func (x *MsgRetryReadExpiryResponse) ProtoReflect() protoreflect.Message
func (*MsgRetryReadExpiryResponse) Reset ¶
func (x *MsgRetryReadExpiryResponse) Reset()
func (*MsgRetryReadExpiryResponse) String ¶
func (x *MsgRetryReadExpiryResponse) String() string
type MsgServer ¶
type MsgServer interface {
// VoteReadResult submits one universal validator's observation of a read
// request's outcome on the destination chain.
VoteReadResult(context.Context, *MsgVoteReadResult) (*MsgVoteReadResultResponse, error)
// RetryReadExpiry reopens the expiry of a read the chain abandoned.
RetryReadExpiry(context.Context, *MsgRetryReadExpiry) (*MsgRetryReadExpiryResponse, error)
// UpdateParams defines a governance operation for updating the parameters.
//
// Since: cosmos-sdk 0.47
UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
// contains filtered or unexported methods
}
MsgServer is the server API for Msg service. All implementations must embed UnimplementedMsgServer for forward compatibility
type MsgUpdateParams ¶
type MsgUpdateParams struct {
// authority is the address of the governance account.
Authority string `protobuf:"bytes,1,opt,name=authority,proto3" json:"authority,omitempty"`
// params defines the parameters to update.
//
// NOTE: All parameters must be supplied.
Params *Params `protobuf:"bytes,2,opt,name=params,proto3" json:"params,omitempty"`
// contains filtered or unexported fields
}
MsgUpdateParams is the Msg/UpdateParams request type.
Since: cosmos-sdk 0.47
func (*MsgUpdateParams) Descriptor
deprecated
func (*MsgUpdateParams) Descriptor() ([]byte, []int)
Deprecated: Use MsgUpdateParams.ProtoReflect.Descriptor instead.
func (*MsgUpdateParams) GetAuthority ¶
func (x *MsgUpdateParams) GetAuthority() string
func (*MsgUpdateParams) GetParams ¶
func (x *MsgUpdateParams) GetParams() *Params
func (*MsgUpdateParams) ProtoMessage ¶
func (*MsgUpdateParams) ProtoMessage()
func (*MsgUpdateParams) ProtoReflect ¶
func (x *MsgUpdateParams) ProtoReflect() protoreflect.Message
func (*MsgUpdateParams) Reset ¶
func (x *MsgUpdateParams) Reset()
func (*MsgUpdateParams) String ¶
func (x *MsgUpdateParams) String() string
type MsgUpdateParamsResponse ¶
type MsgUpdateParamsResponse struct {
// contains filtered or unexported fields
}
MsgUpdateParamsResponse defines the response structure for executing a MsgUpdateParams message.
Since: cosmos-sdk 0.47
func (*MsgUpdateParamsResponse) Descriptor
deprecated
func (*MsgUpdateParamsResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgUpdateParamsResponse.ProtoReflect.Descriptor instead.
func (*MsgUpdateParamsResponse) ProtoMessage ¶
func (*MsgUpdateParamsResponse) ProtoMessage()
func (*MsgUpdateParamsResponse) ProtoReflect ¶
func (x *MsgUpdateParamsResponse) ProtoReflect() protoreflect.Message
func (*MsgUpdateParamsResponse) Reset ¶
func (x *MsgUpdateParamsResponse) Reset()
func (*MsgUpdateParamsResponse) String ¶
func (x *MsgUpdateParamsResponse) String() string
type MsgVoteReadResult ¶
type MsgVoteReadResult struct {
// signer is the Cosmos address of the voting universal validator.
Signer string `protobuf:"bytes,1,opt,name=signer,proto3" json:"signer,omitempty"`
// request_id identifies the read request being voted on.
RequestId string `protobuf:"bytes,2,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// result is the observation. Every field participates in the ballot key.
Result *ReadResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"`
// contains filtered or unexported fields
}
MsgVoteReadResult is broadcast by a universal validator that has executed a read request against the destination chain.
The ballot the vote lands on is derived from (request_id, result), so two validators reporting the same observation converge on one ballot and any disagreement produces a distinct ballot that never reaches quorum. Nothing validator-local may appear in `result` for that reason — notably there is no error message field.
func (*MsgVoteReadResult) Descriptor
deprecated
func (*MsgVoteReadResult) Descriptor() ([]byte, []int)
Deprecated: Use MsgVoteReadResult.ProtoReflect.Descriptor instead.
func (*MsgVoteReadResult) GetRequestId ¶
func (x *MsgVoteReadResult) GetRequestId() string
func (*MsgVoteReadResult) GetResult ¶
func (x *MsgVoteReadResult) GetResult() *ReadResult
func (*MsgVoteReadResult) GetSigner ¶
func (x *MsgVoteReadResult) GetSigner() string
func (*MsgVoteReadResult) ProtoMessage ¶
func (*MsgVoteReadResult) ProtoMessage()
func (*MsgVoteReadResult) ProtoReflect ¶
func (x *MsgVoteReadResult) ProtoReflect() protoreflect.Message
func (*MsgVoteReadResult) Reset ¶
func (x *MsgVoteReadResult) Reset()
func (*MsgVoteReadResult) String ¶
func (x *MsgVoteReadResult) String() string
type MsgVoteReadResultResponse ¶
type MsgVoteReadResultResponse struct {
// finalized reports whether this vote carried the ballot to quorum.
Finalized bool `protobuf:"varint,1,opt,name=finalized,proto3" json:"finalized,omitempty"`
// contains filtered or unexported fields
}
func (*MsgVoteReadResultResponse) Descriptor
deprecated
func (*MsgVoteReadResultResponse) Descriptor() ([]byte, []int)
Deprecated: Use MsgVoteReadResultResponse.ProtoReflect.Descriptor instead.
func (*MsgVoteReadResultResponse) GetFinalized ¶
func (x *MsgVoteReadResultResponse) GetFinalized() bool
func (*MsgVoteReadResultResponse) ProtoMessage ¶
func (*MsgVoteReadResultResponse) ProtoMessage()
func (*MsgVoteReadResultResponse) ProtoReflect ¶
func (x *MsgVoteReadResultResponse) ProtoReflect() protoreflect.Message
func (*MsgVoteReadResultResponse) Reset ¶
func (x *MsgVoteReadResultResponse) Reset()
func (*MsgVoteReadResultResponse) String ¶
func (x *MsgVoteReadResultResponse) String() string
type Params ¶
type Params struct {
SomeValue bool `protobuf:"varint,2,opt,name=some_value,json=someValue,proto3" json:"some_value,omitempty"`
// contains filtered or unexported fields
}
Params defines the set of module parameters.
func (*Params) Descriptor
deprecated
func (*Params) GetSomeValue ¶
func (*Params) ProtoMessage ¶
func (*Params) ProtoMessage()
func (*Params) ProtoReflect ¶
func (x *Params) ProtoReflect() protoreflect.Message
type QueryAllAbortedReadRequestsRequest ¶
type QueryAllAbortedReadRequestsRequest struct {
Pagination *v1beta1.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
// contains filtered or unexported fields
}
func (*QueryAllAbortedReadRequestsRequest) Descriptor
deprecated
func (*QueryAllAbortedReadRequestsRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryAllAbortedReadRequestsRequest.ProtoReflect.Descriptor instead.
func (*QueryAllAbortedReadRequestsRequest) GetPagination ¶
func (x *QueryAllAbortedReadRequestsRequest) GetPagination() *v1beta1.PageRequest
func (*QueryAllAbortedReadRequestsRequest) ProtoMessage ¶
func (*QueryAllAbortedReadRequestsRequest) ProtoMessage()
func (*QueryAllAbortedReadRequestsRequest) ProtoReflect ¶
func (x *QueryAllAbortedReadRequestsRequest) ProtoReflect() protoreflect.Message
func (*QueryAllAbortedReadRequestsRequest) Reset ¶
func (x *QueryAllAbortedReadRequestsRequest) Reset()
func (*QueryAllAbortedReadRequestsRequest) String ¶
func (x *QueryAllAbortedReadRequestsRequest) String() string
type QueryAllAbortedReadRequestsResponse ¶
type QueryAllAbortedReadRequestsResponse struct {
// Reads whose expiry call never landed. Each carries error_msg explaining why.
Reads []*UniversalRead `protobuf:"bytes,1,rep,name=reads,proto3" json:"reads,omitempty"`
Pagination *v1beta1.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
// contains filtered or unexported fields
}
func (*QueryAllAbortedReadRequestsResponse) Descriptor
deprecated
func (*QueryAllAbortedReadRequestsResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryAllAbortedReadRequestsResponse.ProtoReflect.Descriptor instead.
func (*QueryAllAbortedReadRequestsResponse) GetPagination ¶
func (x *QueryAllAbortedReadRequestsResponse) GetPagination() *v1beta1.PageResponse
func (*QueryAllAbortedReadRequestsResponse) GetReads ¶
func (x *QueryAllAbortedReadRequestsResponse) GetReads() []*UniversalRead
func (*QueryAllAbortedReadRequestsResponse) ProtoMessage ¶
func (*QueryAllAbortedReadRequestsResponse) ProtoMessage()
func (*QueryAllAbortedReadRequestsResponse) ProtoReflect ¶
func (x *QueryAllAbortedReadRequestsResponse) ProtoReflect() protoreflect.Message
func (*QueryAllAbortedReadRequestsResponse) Reset ¶
func (x *QueryAllAbortedReadRequestsResponse) Reset()
func (*QueryAllAbortedReadRequestsResponse) String ¶
func (x *QueryAllAbortedReadRequestsResponse) String() string
type QueryAllPendingReadRequestsRequest ¶
type QueryAllPendingReadRequestsRequest struct {
Pagination *v1beta1.PageRequest `protobuf:"bytes,1,opt,name=pagination,proto3" json:"pagination,omitempty"`
// contains filtered or unexported fields
}
func (*QueryAllPendingReadRequestsRequest) Descriptor
deprecated
func (*QueryAllPendingReadRequestsRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryAllPendingReadRequestsRequest.ProtoReflect.Descriptor instead.
func (*QueryAllPendingReadRequestsRequest) GetPagination ¶
func (x *QueryAllPendingReadRequestsRequest) GetPagination() *v1beta1.PageRequest
func (*QueryAllPendingReadRequestsRequest) ProtoMessage ¶
func (*QueryAllPendingReadRequestsRequest) ProtoMessage()
func (*QueryAllPendingReadRequestsRequest) ProtoReflect ¶
func (x *QueryAllPendingReadRequestsRequest) ProtoReflect() protoreflect.Message
func (*QueryAllPendingReadRequestsRequest) Reset ¶
func (x *QueryAllPendingReadRequestsRequest) Reset()
func (*QueryAllPendingReadRequestsRequest) String ¶
func (x *QueryAllPendingReadRequestsRequest) String() string
type QueryAllPendingReadRequestsResponse ¶
type QueryAllPendingReadRequestsResponse struct {
// Reads that are unsettled AND not yet past their expiry height. Requests past
// expiry are withheld here even before the sweeper retires them, so validators
// never take on work that can no longer be fulfilled in time.
Reads []*UniversalRead `protobuf:"bytes,1,rep,name=reads,proto3" json:"reads,omitempty"`
Pagination *v1beta1.PageResponse `protobuf:"bytes,2,opt,name=pagination,proto3" json:"pagination,omitempty"`
// contains filtered or unexported fields
}
func (*QueryAllPendingReadRequestsResponse) Descriptor
deprecated
func (*QueryAllPendingReadRequestsResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryAllPendingReadRequestsResponse.ProtoReflect.Descriptor instead.
func (*QueryAllPendingReadRequestsResponse) GetPagination ¶
func (x *QueryAllPendingReadRequestsResponse) GetPagination() *v1beta1.PageResponse
func (*QueryAllPendingReadRequestsResponse) GetReads ¶
func (x *QueryAllPendingReadRequestsResponse) GetReads() []*UniversalRead
func (*QueryAllPendingReadRequestsResponse) ProtoMessage ¶
func (*QueryAllPendingReadRequestsResponse) ProtoMessage()
func (*QueryAllPendingReadRequestsResponse) ProtoReflect ¶
func (x *QueryAllPendingReadRequestsResponse) ProtoReflect() protoreflect.Message
func (*QueryAllPendingReadRequestsResponse) Reset ¶
func (x *QueryAllPendingReadRequestsResponse) Reset()
func (*QueryAllPendingReadRequestsResponse) String ¶
func (x *QueryAllPendingReadRequestsResponse) String() string
type QueryClient ¶
type QueryClient interface {
// Params queries all parameters of the module.
Params(ctx context.Context, in *QueryParamsRequest, opts ...grpc.CallOption) (*QueryParamsResponse, error)
// AllPendingReadRequests lists read requests still awaiting an observation.
// This is the endpoint universal validators poll.
AllPendingReadRequests(ctx context.Context, in *QueryAllPendingReadRequestsRequest, opts ...grpc.CallOption) (*QueryAllPendingReadRequestsResponse, error)
// UniversalRead returns one read by request id, at any point in its lifecycle.
UniversalRead(ctx context.Context, in *QueryUniversalReadRequest, opts ...grpc.CallOption) (*QueryUniversalReadResponse, error)
// AllAbortedReadRequests lists reads the chain gave up on. These need manual
// intervention: the contract may still hold them as pending and the funder's
// refund is unsettled.
AllAbortedReadRequests(ctx context.Context, in *QueryAllAbortedReadRequestsRequest, opts ...grpc.CallOption) (*QueryAllAbortedReadRequestsResponse, error)
// ReadsByTxHash returns every read requested by one Push transaction. A single
// transaction can emit several ReadRequested logs; this reassembles that batch.
ReadsByTx(ctx context.Context, in *QueryReadsByTxRequest, opts ...grpc.CallOption) (*QueryReadsByTxResponse, error)
}
QueryClient is the client API for Query 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 NewQueryClient ¶
func NewQueryClient(cc grpc.ClientConnInterface) QueryClient
type QueryParamsRequest ¶
type QueryParamsRequest struct {
// contains filtered or unexported fields
}
QueryParamsRequest is the request type for the Query/Params RPC method.
func (*QueryParamsRequest) Descriptor
deprecated
func (*QueryParamsRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryParamsRequest.ProtoReflect.Descriptor instead.
func (*QueryParamsRequest) ProtoMessage ¶
func (*QueryParamsRequest) ProtoMessage()
func (*QueryParamsRequest) ProtoReflect ¶
func (x *QueryParamsRequest) ProtoReflect() protoreflect.Message
func (*QueryParamsRequest) Reset ¶
func (x *QueryParamsRequest) Reset()
func (*QueryParamsRequest) String ¶
func (x *QueryParamsRequest) String() string
type QueryParamsResponse ¶
type QueryParamsResponse struct {
// params defines the parameters of the module.
Params *Params `protobuf:"bytes,1,opt,name=params,proto3" json:"params,omitempty"`
// contains filtered or unexported fields
}
QueryParamsResponse is the response type for the Query/Params RPC method.
func (*QueryParamsResponse) Descriptor
deprecated
func (*QueryParamsResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryParamsResponse.ProtoReflect.Descriptor instead.
func (*QueryParamsResponse) GetParams ¶
func (x *QueryParamsResponse) GetParams() *Params
func (*QueryParamsResponse) ProtoMessage ¶
func (*QueryParamsResponse) ProtoMessage()
func (*QueryParamsResponse) ProtoReflect ¶
func (x *QueryParamsResponse) ProtoReflect() protoreflect.Message
func (*QueryParamsResponse) Reset ¶
func (x *QueryParamsResponse) Reset()
func (*QueryParamsResponse) String ¶
func (x *QueryParamsResponse) String() string
type QueryReadsByTxRequest ¶
type QueryReadsByTxRequest struct {
TxHash string `protobuf:"bytes,1,opt,name=tx_hash,json=txHash,proto3" json:"tx_hash,omitempty"`
// contains filtered or unexported fields
}
func (*QueryReadsByTxRequest) Descriptor
deprecated
func (*QueryReadsByTxRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryReadsByTxRequest.ProtoReflect.Descriptor instead.
func (*QueryReadsByTxRequest) GetTxHash ¶
func (x *QueryReadsByTxRequest) GetTxHash() string
func (*QueryReadsByTxRequest) ProtoMessage ¶
func (*QueryReadsByTxRequest) ProtoMessage()
func (*QueryReadsByTxRequest) ProtoReflect ¶
func (x *QueryReadsByTxRequest) ProtoReflect() protoreflect.Message
func (*QueryReadsByTxRequest) Reset ¶
func (x *QueryReadsByTxRequest) Reset()
func (*QueryReadsByTxRequest) String ¶
func (x *QueryReadsByTxRequest) String() string
type QueryReadsByTxResponse ¶
type QueryReadsByTxResponse struct {
// Every read the transaction requested, settled or not, in request-id order.
Reads []*UniversalRead `protobuf:"bytes,1,rep,name=reads,proto3" json:"reads,omitempty"`
// contains filtered or unexported fields
}
func (*QueryReadsByTxResponse) Descriptor
deprecated
func (*QueryReadsByTxResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryReadsByTxResponse.ProtoReflect.Descriptor instead.
func (*QueryReadsByTxResponse) GetReads ¶
func (x *QueryReadsByTxResponse) GetReads() []*UniversalRead
func (*QueryReadsByTxResponse) ProtoMessage ¶
func (*QueryReadsByTxResponse) ProtoMessage()
func (*QueryReadsByTxResponse) ProtoReflect ¶
func (x *QueryReadsByTxResponse) ProtoReflect() protoreflect.Message
func (*QueryReadsByTxResponse) Reset ¶
func (x *QueryReadsByTxResponse) Reset()
func (*QueryReadsByTxResponse) String ¶
func (x *QueryReadsByTxResponse) String() string
type QueryServer ¶
type QueryServer interface {
// Params queries all parameters of the module.
Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
// AllPendingReadRequests lists read requests still awaiting an observation.
// This is the endpoint universal validators poll.
AllPendingReadRequests(context.Context, *QueryAllPendingReadRequestsRequest) (*QueryAllPendingReadRequestsResponse, error)
// UniversalRead returns one read by request id, at any point in its lifecycle.
UniversalRead(context.Context, *QueryUniversalReadRequest) (*QueryUniversalReadResponse, error)
// AllAbortedReadRequests lists reads the chain gave up on. These need manual
// intervention: the contract may still hold them as pending and the funder's
// refund is unsettled.
AllAbortedReadRequests(context.Context, *QueryAllAbortedReadRequestsRequest) (*QueryAllAbortedReadRequestsResponse, error)
// ReadsByTxHash returns every read requested by one Push transaction. A single
// transaction can emit several ReadRequested logs; this reassembles that batch.
ReadsByTx(context.Context, *QueryReadsByTxRequest) (*QueryReadsByTxResponse, error)
// contains filtered or unexported methods
}
QueryServer is the server API for Query service. All implementations must embed UnimplementedQueryServer for forward compatibility
type QueryUniversalReadRequest ¶
type QueryUniversalReadRequest struct {
RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
// contains filtered or unexported fields
}
func (*QueryUniversalReadRequest) Descriptor
deprecated
func (*QueryUniversalReadRequest) Descriptor() ([]byte, []int)
Deprecated: Use QueryUniversalReadRequest.ProtoReflect.Descriptor instead.
func (*QueryUniversalReadRequest) GetRequestId ¶
func (x *QueryUniversalReadRequest) GetRequestId() string
func (*QueryUniversalReadRequest) ProtoMessage ¶
func (*QueryUniversalReadRequest) ProtoMessage()
func (*QueryUniversalReadRequest) ProtoReflect ¶
func (x *QueryUniversalReadRequest) ProtoReflect() protoreflect.Message
func (*QueryUniversalReadRequest) Reset ¶
func (x *QueryUniversalReadRequest) Reset()
func (*QueryUniversalReadRequest) String ¶
func (x *QueryUniversalReadRequest) String() string
type QueryUniversalReadResponse ¶
type QueryUniversalReadResponse struct {
Read *UniversalRead `protobuf:"bytes,1,opt,name=read,proto3" json:"read,omitempty"`
// contains filtered or unexported fields
}
func (*QueryUniversalReadResponse) Descriptor
deprecated
func (*QueryUniversalReadResponse) Descriptor() ([]byte, []int)
Deprecated: Use QueryUniversalReadResponse.ProtoReflect.Descriptor instead.
func (*QueryUniversalReadResponse) GetRead ¶
func (x *QueryUniversalReadResponse) GetRead() *UniversalRead
func (*QueryUniversalReadResponse) ProtoMessage ¶
func (*QueryUniversalReadResponse) ProtoMessage()
func (*QueryUniversalReadResponse) ProtoReflect ¶
func (x *QueryUniversalReadResponse) ProtoReflect() protoreflect.Message
func (*QueryUniversalReadResponse) Reset ¶
func (x *QueryUniversalReadResponse) Reset()
func (*QueryUniversalReadResponse) String ¶
func (x *QueryUniversalReadResponse) String() string
type ReadErrorCode ¶
type ReadErrorCode int32
ReadStatus is the outcome a universal validator observed for a read. ReadErrorCode is the deterministic reason a read produced an ERROR observation. Only non-transient failures appear here; transient failures never vote — the validator retries locally instead.
const ( ReadErrorCode_READ_ERROR_UNSPECIFIED ReadErrorCode = 0 // catch-all / other ReadErrorCode_READ_ERROR_INVALID_QUERY ReadErrorCode = 1 // envelope or params could not be decoded for this chain ReadErrorCode_READ_ERROR_UNSUPPORTED ReadErrorCode = 2 // chain does not support this query type or option ReadErrorCode_READ_ERROR_REVERTED ReadErrorCode = 3 // destination executed the request and returned a failure (EVM revert, HTTP 4xx) ReadErrorCode_READ_ERROR_NOT_FOUND ReadErrorCode = 4 // queried account, state, or field does not exist at the pinned point ReadErrorCode_READ_ERROR_INVALID_RESULT ReadErrorCode = 5 // destination returned data that could not be interpreted or encoded ReadErrorCode_READ_ERROR_REJECTED ReadErrorCode = 6 // request refused by validator policy before execution (web2 SSRF/blacklist) )
func (ReadErrorCode) Descriptor ¶
func (ReadErrorCode) Descriptor() protoreflect.EnumDescriptor
func (ReadErrorCode) Enum ¶
func (x ReadErrorCode) Enum() *ReadErrorCode
func (ReadErrorCode) EnumDescriptor
deprecated
func (ReadErrorCode) EnumDescriptor() ([]byte, []int)
Deprecated: Use ReadErrorCode.Descriptor instead.
func (ReadErrorCode) Number ¶
func (x ReadErrorCode) Number() protoreflect.EnumNumber
func (ReadErrorCode) String ¶
func (x ReadErrorCode) String() string
func (ReadErrorCode) Type ¶
func (ReadErrorCode) Type() protoreflect.EnumType
type ReadRequest ¶
type ReadRequest struct {
RequestId string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"` // uint256 requestId as 0x-prefixed hex
DestinationChain string `protobuf:"bytes,2,opt,name=destination_chain,json=destinationChain,proto3" json:"destination_chain,omitempty"` // CAIP-2, e.g. "eip155:1"; web2 uses "web2:https"
Owner []byte `protobuf:"bytes,3,opt,name=owner,proto3" json:"owner,omitempty"` // 20-byte address or 32-byte pubkey
Query []byte `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"` // chain-specific envelope, abi.encode(...)
MinConfirmations uint32 `protobuf:"varint,5,opt,name=min_confirmations,json=minConfirmations,proto3" json:"min_confirmations,omitempty"` // uint16 on the contract; proto3 has no uint16
DestinationBlockHeight uint64 `` // height on the destination chain; unused for web2
/* 130-byte string literal not displayed */
ExpiryBlockHeight uint64 `protobuf:"varint,7,opt,name=expiry_block_height,json=expiryBlockHeight,proto3" json:"expiry_block_height,omitempty"` // Push Chain height at which the request expires
CreatedAtHeight uint64 `protobuf:"varint,8,opt,name=created_at_height,json=createdAtHeight,proto3" json:"created_at_height,omitempty"` // Push Chain height the request was observed at
// Bookkeeping — recorded for operators, not consumed by universal validators.
CallbackTarget string `protobuf:"bytes,9,opt,name=callback_target,json=callbackTarget,proto3" json:"callback_target,omitempty"` // the app contract the callback routes to
OriginalFunder string `protobuf:"bytes,10,opt,name=original_funder,json=originalFunder,proto3" json:"original_funder,omitempty"` // who paid the fee (the app, not the end user)
FeesDeposited string `protobuf:"bytes,11,opt,name=fees_deposited,json=feesDeposited,proto3" json:"fees_deposited,omitempty"` // total msg.value paid, uint256 decimal string
MaxFee string `protobuf:"bytes,12,opt,name=max_fee,json=maxFee,proto3" json:"max_fee,omitempty"` // uint256 as a decimal string
RequestedTxHash string `protobuf:"bytes,13,opt,name=requested_tx_hash,json=requestedTxHash,proto3" json:"requested_tx_hash,omitempty"` // Push Chain tx that emitted ReadRequested
RequestedLogIndex uint64 `protobuf:"varint,14,opt,name=requested_log_index,json=requestedLogIndex,proto3" json:"requested_log_index,omitempty"` // log index within that tx
// Fee split, taken from ReadRequested. protocol_fee is already in VaultPC by the
// time we see the log; only callback_budget is still escrowed on the contract.
ProtocolFee string `protobuf:"bytes,15,opt,name=protocol_fee,json=protocolFee,proto3" json:"protocol_fee,omitempty"` // uint256 decimal string
CallbackBudget string `protobuf:"bytes,16,opt,name=callback_budget,json=callbackBudget,proto3" json:"callback_budget,omitempty"` // uint256 decimal string — funds the callback
// Gas ceiling the app declared for its own callback. The contract caps the inner
// call at this; we size the fulfil transaction from it.
CallbackGasLimit uint64 `protobuf:"varint,17,opt,name=callback_gas_limit,json=callbackGasLimit,proto3" json:"callback_gas_limit,omitempty"`
// Where an unspent budget is refunded. From ReadSpec, not necessarily the funder.
RevertRecipient string `protobuf:"bytes,18,opt,name=revert_recipient,json=revertRecipient,proto3" json:"revert_recipient,omitempty"`
// contains filtered or unexported fields
}
ReadRequest is one external read requested by an app on Push Chain.
Every field is derived from the UniversalCallback.ReadRequested event, except created_at_height / requested_tx_hash / requested_log_index which come from the block the log was emitted in.
NOTE: callbackGasLimit is deliberately absent. It is an argument to requestExternalReadSelf and is stored in the contract's _pending entry, but it is NOT emitted in ReadRequested. It has to be read back via getPendingRead(requestId) at fulfilment time, when the gas budget is actually needed.
func (*ReadRequest) Descriptor
deprecated
func (*ReadRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadRequest.ProtoReflect.Descriptor instead.
func (*ReadRequest) GetCallbackBudget ¶
func (x *ReadRequest) GetCallbackBudget() string
func (*ReadRequest) GetCallbackGasLimit ¶
func (x *ReadRequest) GetCallbackGasLimit() uint64
func (*ReadRequest) GetCallbackTarget ¶
func (x *ReadRequest) GetCallbackTarget() string
func (*ReadRequest) GetCreatedAtHeight ¶
func (x *ReadRequest) GetCreatedAtHeight() uint64
func (*ReadRequest) GetDestinationBlockHeight ¶
func (x *ReadRequest) GetDestinationBlockHeight() uint64
func (*ReadRequest) GetDestinationChain ¶
func (x *ReadRequest) GetDestinationChain() string
func (*ReadRequest) GetExpiryBlockHeight ¶
func (x *ReadRequest) GetExpiryBlockHeight() uint64
func (*ReadRequest) GetFeesDeposited ¶
func (x *ReadRequest) GetFeesDeposited() string
func (*ReadRequest) GetMaxFee ¶
func (x *ReadRequest) GetMaxFee() string
func (*ReadRequest) GetMinConfirmations ¶
func (x *ReadRequest) GetMinConfirmations() uint32
func (*ReadRequest) GetOriginalFunder ¶
func (x *ReadRequest) GetOriginalFunder() string
func (*ReadRequest) GetOwner ¶
func (x *ReadRequest) GetOwner() []byte
func (*ReadRequest) GetProtocolFee ¶
func (x *ReadRequest) GetProtocolFee() string
func (*ReadRequest) GetQuery ¶
func (x *ReadRequest) GetQuery() []byte
func (*ReadRequest) GetRequestId ¶
func (x *ReadRequest) GetRequestId() string
func (*ReadRequest) GetRequestedLogIndex ¶
func (x *ReadRequest) GetRequestedLogIndex() uint64
func (*ReadRequest) GetRequestedTxHash ¶
func (x *ReadRequest) GetRequestedTxHash() string
func (*ReadRequest) GetRevertRecipient ¶
func (x *ReadRequest) GetRevertRecipient() string
func (*ReadRequest) ProtoMessage ¶
func (*ReadRequest) ProtoMessage()
func (*ReadRequest) ProtoReflect ¶
func (x *ReadRequest) ProtoReflect() protoreflect.Message
func (*ReadRequest) Reset ¶
func (x *ReadRequest) Reset()
func (*ReadRequest) String ¶
func (x *ReadRequest) String() string
type ReadResult ¶
type ReadResult struct {
Status ReadStatus `protobuf:"varint,1,opt,name=status,proto3,enum=ucallback.v1.ReadStatus" json:"status,omitempty"`
ResultData []byte `protobuf:"bytes,2,opt,name=result_data,json=resultData,proto3" json:"result_data,omitempty"` // ABI-encoded payload delivered to the app
// v2 ONLY — always empty in v1. See AggregateValue.
Aggregates []*AggregateValue `protobuf:"bytes,5,rep,name=aggregates,proto3" json:"aggregates,omitempty"`
// Why the read failed. Meaningful only when status is READ_STATUS_ERROR, and
// must be READ_ERROR_UNSPECIFIED otherwise — a SUCCESS vote carrying a code
// would hash to a different ballot than an honest SUCCESS vote and split quorum.
//
// An enum rather than free text on purpose: it participates in the ballot key,
// so it must be a value validators independently converge on. A string invites
// fmt.Sprintf("%v", err), whose text varies by RPC provider even for identical
// on-chain failures.
ErrorCode ReadErrorCode `protobuf:"varint,6,opt,name=error_code,json=errorCode,proto3,enum=ucallback.v1.ReadErrorCode" json:"error_code,omitempty"`
// contains filtered or unexported fields
}
ReadResult is the observation a universal validator votes on.
Every field here is covered by the ballot key, so they must be byte-identical across validators for a ballot to converge. There is deliberately no error message field: local error text differs per node and would prevent agreement.
func (*ReadResult) Descriptor
deprecated
func (*ReadResult) Descriptor() ([]byte, []int)
Deprecated: Use ReadResult.ProtoReflect.Descriptor instead.
func (*ReadResult) GetAggregates ¶
func (x *ReadResult) GetAggregates() []*AggregateValue
func (*ReadResult) GetErrorCode ¶
func (x *ReadResult) GetErrorCode() ReadErrorCode
func (*ReadResult) GetResultData ¶
func (x *ReadResult) GetResultData() []byte
func (*ReadResult) GetStatus ¶
func (x *ReadResult) GetStatus() ReadStatus
func (*ReadResult) ProtoMessage ¶
func (*ReadResult) ProtoMessage()
func (*ReadResult) ProtoReflect ¶
func (x *ReadResult) ProtoReflect() protoreflect.Message
func (*ReadResult) Reset ¶
func (x *ReadResult) Reset()
func (*ReadResult) String ¶
func (x *ReadResult) String() string
type ReadStatus ¶
type ReadStatus int32
const ( ReadStatus_READ_STATUS_UNSPECIFIED ReadStatus = 0 ReadStatus_READ_STATUS_SUCCESS ReadStatus = 1 ReadStatus_READ_STATUS_ERROR ReadStatus = 2 )
func (ReadStatus) Descriptor ¶
func (ReadStatus) Descriptor() protoreflect.EnumDescriptor
func (ReadStatus) Enum ¶
func (x ReadStatus) Enum() *ReadStatus
func (ReadStatus) EnumDescriptor
deprecated
func (ReadStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use ReadStatus.Descriptor instead.
func (ReadStatus) Number ¶
func (x ReadStatus) Number() protoreflect.EnumNumber
func (ReadStatus) String ¶
func (x ReadStatus) String() string
func (ReadStatus) Type ¶
func (ReadStatus) Type() protoreflect.EnumType
type UnimplementedMsgServer ¶
type UnimplementedMsgServer struct {
}
UnimplementedMsgServer must be embedded to have forward compatible implementations.
func (UnimplementedMsgServer) RetryReadExpiry ¶
func (UnimplementedMsgServer) RetryReadExpiry(context.Context, *MsgRetryReadExpiry) (*MsgRetryReadExpiryResponse, error)
func (UnimplementedMsgServer) UpdateParams ¶
func (UnimplementedMsgServer) UpdateParams(context.Context, *MsgUpdateParams) (*MsgUpdateParamsResponse, error)
func (UnimplementedMsgServer) VoteReadResult ¶
func (UnimplementedMsgServer) VoteReadResult(context.Context, *MsgVoteReadResult) (*MsgVoteReadResultResponse, error)
type UnimplementedQueryServer ¶
type UnimplementedQueryServer struct {
}
UnimplementedQueryServer must be embedded to have forward compatible implementations.
func (UnimplementedQueryServer) AllAbortedReadRequests ¶
func (UnimplementedQueryServer) AllAbortedReadRequests(context.Context, *QueryAllAbortedReadRequestsRequest) (*QueryAllAbortedReadRequestsResponse, error)
func (UnimplementedQueryServer) AllPendingReadRequests ¶
func (UnimplementedQueryServer) AllPendingReadRequests(context.Context, *QueryAllPendingReadRequestsRequest) (*QueryAllPendingReadRequestsResponse, error)
func (UnimplementedQueryServer) Params ¶
func (UnimplementedQueryServer) Params(context.Context, *QueryParamsRequest) (*QueryParamsResponse, error)
func (UnimplementedQueryServer) ReadsByTx ¶
func (UnimplementedQueryServer) ReadsByTx(context.Context, *QueryReadsByTxRequest) (*QueryReadsByTxResponse, error)
func (UnimplementedQueryServer) UniversalRead ¶
func (UnimplementedQueryServer) UniversalRead(context.Context, *QueryUniversalReadRequest) (*QueryUniversalReadResponse, error)
type UniversalRead ¶
type UniversalRead struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // requestId, same value as request.request_id
Request *ReadRequest `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"`
Result *ReadResult `protobuf:"bytes,3,opt,name=result,proto3" json:"result,omitempty"` // set once the ballot finalises
Status UniversalReadStatus `protobuf:"varint,4,opt,name=status,proto3,enum=ucallback.v1.UniversalReadStatus" json:"status,omitempty"`
BallotKey string `protobuf:"bytes,5,opt,name=ballot_key,json=ballotKey,proto3" json:"ballot_key,omitempty"`
// Push Chain execution attempts — fulfilExternalCallback and expireExternalRead.
// Repeated because fulfilment can be retried and may be followed by an expiry.
PcTx []*v1.PCTx `protobuf:"bytes,6,rep,name=pc_tx,json=pcTx,proto3" json:"pc_tx,omitempty"`
// Why the chain stopped acting on this read. Populated on the ABORTED and FAILED
// paths from the EVM result, so it is identical on every node — this is our own
// execution outcome, not a validator's observation, and it never touches a ballot.
ErrorMsg string `protobuf:"bytes,7,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
// How many times the sweeper has called expireExternalRead for this read.
//
// An explicit counter rather than len(pc_tx): pc_tx accumulates every EVM attempt
// on the request, including a failed fulfilment that left it in flight, so
// counting entries would silently shorten the retry budget for exactly the reads
// that already had trouble.
ExpiryAttempts uint32 `protobuf:"varint,8,opt,name=expiry_attempts,json=expiryAttempts,proto3" json:"expiry_attempts,omitempty"`
// contains filtered or unexported fields
}
UniversalRead is the full lifecycle record of one read request.
The read-side sibling of uexecutor's UniversalTx, but deliberately not the same shape: a read is triggered by a Push Chain event rather than an external inbound, performs no external write, and settles in exactly one Push Chain transaction.
func (*UniversalRead) Descriptor
deprecated
func (*UniversalRead) Descriptor() ([]byte, []int)
Deprecated: Use UniversalRead.ProtoReflect.Descriptor instead.
func (*UniversalRead) GetBallotKey ¶
func (x *UniversalRead) GetBallotKey() string
func (*UniversalRead) GetErrorMsg ¶
func (x *UniversalRead) GetErrorMsg() string
func (*UniversalRead) GetExpiryAttempts ¶
func (x *UniversalRead) GetExpiryAttempts() uint32
func (*UniversalRead) GetId ¶
func (x *UniversalRead) GetId() string
func (*UniversalRead) GetPcTx ¶
func (x *UniversalRead) GetPcTx() []*v1.PCTx
func (*UniversalRead) GetRequest ¶
func (x *UniversalRead) GetRequest() *ReadRequest
func (*UniversalRead) GetResult ¶
func (x *UniversalRead) GetResult() *ReadResult
func (*UniversalRead) GetStatus ¶
func (x *UniversalRead) GetStatus() UniversalReadStatus
func (*UniversalRead) ProtoMessage ¶
func (*UniversalRead) ProtoMessage()
func (*UniversalRead) ProtoReflect ¶
func (x *UniversalRead) ProtoReflect() protoreflect.Message
func (*UniversalRead) Reset ¶
func (x *UniversalRead) Reset()
func (*UniversalRead) String ¶
func (x *UniversalRead) String() string
type UniversalReadEntry ¶
type UniversalReadEntry struct {
Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
Value *UniversalRead `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
UniversalReadEntry is one key-value pair from the UniversalReads map.
func (*UniversalReadEntry) Descriptor
deprecated
func (*UniversalReadEntry) Descriptor() ([]byte, []int)
Deprecated: Use UniversalReadEntry.ProtoReflect.Descriptor instead.
func (*UniversalReadEntry) GetKey ¶
func (x *UniversalReadEntry) GetKey() string
func (*UniversalReadEntry) GetValue ¶
func (x *UniversalReadEntry) GetValue() *UniversalRead
func (*UniversalReadEntry) ProtoMessage ¶
func (*UniversalReadEntry) ProtoMessage()
func (*UniversalReadEntry) ProtoReflect ¶
func (x *UniversalReadEntry) ProtoReflect() protoreflect.Message
func (*UniversalReadEntry) Reset ¶
func (x *UniversalReadEntry) Reset()
func (*UniversalReadEntry) String ¶
func (x *UniversalReadEntry) String() string
type UniversalReadStatus ¶
type UniversalReadStatus int32
UniversalReadStatus is the lifecycle state of a read request on Push Chain.
const ( UniversalReadStatus_UNIVERSAL_READ_STATUS_UNSPECIFIED UniversalReadStatus = 0 UniversalReadStatus_UNIVERSAL_READ_STATUS_PENDING UniversalReadStatus = 1 // ingested, awaiting votes UniversalReadStatus_UNIVERSAL_READ_STATUS_VOTING UniversalReadStatus = 2 // at least one vote, no quorum yet UniversalReadStatus_UNIVERSAL_READ_STATUS_FULFILLED UniversalReadStatus = 3 // callback dispatched successfully UniversalReadStatus_UNIVERSAL_READ_STATUS_EXPIRED UniversalReadStatus = 4 // expireExternalRead accepted by the contract UniversalReadStatus_UNIVERSAL_READ_STATUS_FAILED UniversalReadStatus = 5 // quorum reached but the callback reverted // Gave up: expireExternalRead failed MaxExpiryAttempts times and the contract // never acknowledged the request. Distinct from EXPIRED because the contract may // still hold it as pending — and since expireExternalRead is module-gated, no // other caller can settle it. Requires manual intervention, the same sense as // uexecutor's ABORTED. See error_msg on UniversalRead for the last failure. UniversalReadStatus_UNIVERSAL_READ_STATUS_ABORTED UniversalReadStatus = 6 )
func (UniversalReadStatus) Descriptor ¶
func (UniversalReadStatus) Descriptor() protoreflect.EnumDescriptor
func (UniversalReadStatus) Enum ¶
func (x UniversalReadStatus) Enum() *UniversalReadStatus
func (UniversalReadStatus) EnumDescriptor
deprecated
func (UniversalReadStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use UniversalReadStatus.Descriptor instead.
func (UniversalReadStatus) Number ¶
func (x UniversalReadStatus) Number() protoreflect.EnumNumber
func (UniversalReadStatus) String ¶
func (x UniversalReadStatus) String() string
func (UniversalReadStatus) Type ¶
func (UniversalReadStatus) Type() protoreflect.EnumType
type UnsafeMsgServer ¶
type UnsafeMsgServer interface {
// contains filtered or unexported methods
}
UnsafeMsgServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MsgServer will result in compilation errors.
type UnsafeQueryServer ¶
type UnsafeQueryServer interface {
// contains filtered or unexported methods
}
UnsafeQueryServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to QueryServer will result in compilation errors.