ucallbackv1

package
v0.0.45 Latest Latest
Warning

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

Go to latest
Published: Aug 19, 2026 License: MIT Imports: 19 Imported by: 0

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

View Source
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"
)
View Source
const (
	Msg_VoteReadResult_FullMethodName  = "/ucallback.v1.Msg/VoteReadResult"
	Msg_RetryReadExpiry_FullMethodName = "/ucallback.v1.Msg/RetryReadExpiry"
	Msg_UpdateParams_FullMethodName    = "/ucallback.v1.Msg/UpdateParams"
)

Variables

View Source
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.

View Source
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.

View Source
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.

View Source
var File_ucallback_v1_genesis_proto protoreflect.FileDescriptor
View Source
var File_ucallback_v1_query_proto protoreflect.FileDescriptor
View Source
var File_ucallback_v1_tx_proto protoreflect.FileDescriptor
View Source
var File_ucallback_v1_types_proto protoreflect.FileDescriptor
View Source
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)

View Source
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 (*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 (*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) Descriptor() ([]byte, []int)

Deprecated: Use Params.ProtoReflect.Descriptor instead.

func (*Params) GetSomeValue

func (x *Params) GetSomeValue() bool

func (*Params) ProtoMessage

func (*Params) ProtoMessage()

func (*Params) ProtoReflect

func (x *Params) ProtoReflect() protoreflect.Message

func (*Params) Reset

func (x *Params) Reset()

func (*Params) String

func (x *Params) String() string

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 (*QueryAllAbortedReadRequestsRequest) ProtoMessage

func (*QueryAllAbortedReadRequestsRequest) ProtoMessage()

func (*QueryAllAbortedReadRequestsRequest) ProtoReflect

func (*QueryAllAbortedReadRequestsRequest) Reset

func (*QueryAllAbortedReadRequestsRequest) 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 (*QueryAllAbortedReadRequestsResponse) GetReads

func (*QueryAllAbortedReadRequestsResponse) ProtoMessage

func (*QueryAllAbortedReadRequestsResponse) ProtoMessage()

func (*QueryAllAbortedReadRequestsResponse) ProtoReflect

func (*QueryAllAbortedReadRequestsResponse) Reset

func (*QueryAllAbortedReadRequestsResponse) 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 (*QueryAllPendingReadRequestsRequest) ProtoMessage

func (*QueryAllPendingReadRequestsRequest) ProtoMessage()

func (*QueryAllPendingReadRequestsRequest) ProtoReflect

func (*QueryAllPendingReadRequestsRequest) Reset

func (*QueryAllPendingReadRequestsRequest) 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 (*QueryAllPendingReadRequestsResponse) GetReads

func (*QueryAllPendingReadRequestsResponse) ProtoMessage

func (*QueryAllPendingReadRequestsResponse) ProtoMessage()

func (*QueryAllPendingReadRequestsResponse) ProtoReflect

func (*QueryAllPendingReadRequestsResponse) Reset

func (*QueryAllPendingReadRequestsResponse) 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 (*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 (*QueryUniversalReadResponse) ProtoMessage

func (*QueryUniversalReadResponse) ProtoMessage()

func (*QueryUniversalReadResponse) ProtoReflect

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

func (x ReadErrorCode) Enum() *ReadErrorCode

func (ReadErrorCode) EnumDescriptor deprecated

func (ReadErrorCode) EnumDescriptor() ([]byte, []int)

Deprecated: Use ReadErrorCode.Descriptor instead.

func (ReadErrorCode) Number

func (ReadErrorCode) String

func (x ReadErrorCode) String() string

func (ReadErrorCode) Type

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

type UnimplementedMsgServer

type UnimplementedMsgServer struct {
}

UnimplementedMsgServer must be embedded to have forward compatible implementations.

func (UnimplementedMsgServer) RetryReadExpiry

func (UnimplementedMsgServer) UpdateParams

func (UnimplementedMsgServer) VoteReadResult

type UnimplementedQueryServer

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer must be embedded to have forward compatible implementations.

func (UnimplementedQueryServer) Params

func (UnimplementedQueryServer) ReadsByTx

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

func (UniversalReadStatus) EnumDescriptor deprecated

func (UniversalReadStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use UniversalReadStatus.Descriptor instead.

func (UniversalReadStatus) Number

func (UniversalReadStatus) String

func (x UniversalReadStatus) String() string

func (UniversalReadStatus) Type

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL