types

package
v0.4.0-dev.0 Latest Latest
Warning

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

 Go to latest Published: Oct 16, 2024 License: GPL-3.0 Imports: 35 Imported by: 0

Documentation

Overview

Package types is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	// ModuleName defines the module name.
	ModuleName = "batching"

	// StoreKey defines the primary module store key.
	StoreKey = "batching"
)
View Source 
const (
	DefaultValSetTrimPercent uint32 = 95 // 95%
)

Variables

View Source 
var (
	ErrInvalidLengthBatching        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowBatching          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupBatching = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	Amino     = codec.NewLegacyAmino()
	ModuleCdc = codec.NewProtoCodec(cdctypes.NewInterfaceRegistry())
)
View Source 
var (
	ErrBatchingHasNotStarted = errors.Register("batching", 2, "batching has not begun - there is no batch in the store")
	ErrInvalidBatchNumber    = errors.Register("batching", 3, "invalid batch number")
	ErrBatchAlreadyExists    = errors.Register("batching", 4, "batch already exists at the given block height")
	ErrInvalidPublicKey      = errors.Register("batching", 5, "invalid public key")
)
View Source 
var (
	ErrInvalidLengthGenesis        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowGenesis          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupGenesis = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var (
	DataResultsPrefix        = collections.NewPrefix(0)
	BatchAssignmentsPrefix   = collections.NewPrefix(1)
	CurrentBatchNumberKey    = collections.NewPrefix(2)
	BatchesKeyPrefix         = collections.NewPrefix(3)
	BatchNumberKeyPrefix     = collections.NewPrefix(4)
	TreeEntriesKeyPrefix     = collections.NewPrefix(5)
	BatchSignaturesKeyPrefix = collections.NewPrefix(6)
	ParamsKey                = collections.NewPrefix(7)
)
View Source 
var (
	ErrInvalidLengthQuery        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowQuery          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupQuery = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterCodec 

func RegisterCodec(_ *codec.LegacyAmino)

func RegisterQueryHandler 

func RegisterQueryHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterQueryHandler registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterQueryHandlerClient 

func RegisterQueryHandlerClient(ctx context.Context, mux *runtime.ServeMux, client QueryClient) error

RegisterQueryHandlerClient registers the http handlers for service Query to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "QueryClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "QueryClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "QueryClient" to call the correct interceptors.

func RegisterQueryHandlerFromEndpoint 

func RegisterQueryHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterQueryHandlerFromEndpoint is same as RegisterQueryHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterQueryHandlerServer 

func RegisterQueryHandlerServer(ctx context.Context, mux *runtime.ServeMux, server QueryServer) error

RegisterQueryHandlerServer registers the http handlers for service Query to "mux". UnaryRPC :call QueryServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterQueryHandlerFromEndpoint instead.

func RegisterQueryServer 

func RegisterQueryServer(s grpc1.Server, srv QueryServer)

func ValidateGenesis 

func ValidateGenesis(_ GenesisState) error

ValidateGenesis validates batching genesis data.

Types

type Batch 

type Batch struct {
	// batch_number is a unique identifier of the batch incremented
	// every time a batch is created.
	BatchNumber uint64 `protobuf:"varint,1,opt,name=batch_number,json=batchNumber,proto3" json:"batch_number,omitempty"`
	// block_height is the height at which the batch was created.
	BlockHeight int64 `protobuf:"varint,2,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
	// data_result_root is the hex-encoded root of the data result
	// merkle tree.
	DataResultRoot string `protobuf:"bytes,3,opt,name=data_result_root,json=dataResultRoot,proto3" json:"data_result_root,omitempty"`
	// validator_root is the hex-encoded root of the validator merkle
	// tree.
	ValidatorRoot string `protobuf:"bytes,4,opt,name=validator_root,json=validatorRoot,proto3" json:"validator_root,omitempty"`
	// batch_id is the Keccack-256 hash of the batch content.
	BatchId []byte `protobuf:"bytes,5,opt,name=batch_id,json=batchId,proto3" json:"batch_id,omitempty"`
	// proving_medatada is a field for additional proving data.
	ProvingMedatada []byte `protobuf:"bytes,6,opt,name=proving_medatada,json=provingMedatada,proto3" json:"proving_medatada,omitempty"`
}

Batch is an aggregation of data request results along with validator signatures used to prove these results on destination chains.

func (*Batch) Descriptor 

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

func (*Batch) GetBatchId 

func (m *Batch) GetBatchId() []byte

func (*Batch) GetBatchNumber 

func (m *Batch) GetBatchNumber() uint64

func (*Batch) GetBlockHeight 

func (m *Batch) GetBlockHeight() int64

func (*Batch) GetDataResultRoot 

func (m *Batch) GetDataResultRoot() string

func (*Batch) GetProvingMedatada 

func (m *Batch) GetProvingMedatada() []byte

func (*Batch) GetValidatorRoot 

func (m *Batch) GetValidatorRoot() string

func (*Batch) Marshal 

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

func (*Batch) MarshalTo 

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

func (*Batch) MarshalToSizedBuffer 

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

func (*Batch) ProtoMessage 

func (*Batch) ProtoMessage()

func (*Batch) Reset 

func (m *Batch) Reset()

func (*Batch) Size 

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

func (*Batch) String 

func (m *Batch) String() string

func (*Batch) Unmarshal 

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

func (*Batch) XXX_DiscardUnknown 

func (m *Batch) XXX_DiscardUnknown()

func (*Batch) XXX_Marshal 

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

func (*Batch) XXX_Merge 

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

func (*Batch) XXX_Size 

func (m *Batch) XXX_Size() int

func (*Batch) XXX_Unmarshal 

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

type BatchAssignment 

type BatchAssignment struct {
	BatchNumber   uint64 `protobuf:"varint,1,opt,name=batch_number,json=batchNumber,proto3" json:"batch_number,omitempty"`
	DataRequestId string `protobuf:"bytes,2,opt,name=data_request_id,json=dataRequestId,proto3" json:"data_request_id,omitempty"`
}

BatchAssignment represents a batch assignment for genesis export and import.

func (*BatchAssignment) Descriptor 

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

func (*BatchAssignment) GetBatchNumber 

func (m *BatchAssignment) GetBatchNumber() uint64

func (*BatchAssignment) GetDataRequestId 

func (m *BatchAssignment) GetDataRequestId() string

func (*BatchAssignment) Marshal 

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

func (*BatchAssignment) MarshalTo 

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

func (*BatchAssignment) MarshalToSizedBuffer 

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

func (*BatchAssignment) ProtoMessage 

func (*BatchAssignment) ProtoMessage()

func (*BatchAssignment) Reset 

func (m *BatchAssignment) Reset()

func (*BatchAssignment) Size 

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

func (*BatchAssignment) String 

func (m *BatchAssignment) String() string

func (*BatchAssignment) Unmarshal 

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

func (*BatchAssignment) XXX_DiscardUnknown 

func (m *BatchAssignment) XXX_DiscardUnknown()

func (*BatchAssignment) XXX_Marshal 

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

func (*BatchAssignment) XXX_Merge 

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

func (*BatchAssignment) XXX_Size 

func (m *BatchAssignment) XXX_Size() int

func (*BatchAssignment) XXX_Unmarshal 

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

type BatchSignatures 

type BatchSignatures struct {
	ValidatorAddr string `protobuf:"bytes,1,opt,name=validator_addr,json=validatorAddr,proto3" json:"validator_addr,omitempty"`
	VotingPower   int64  `protobuf:"varint,2,opt,name=voting_power,json=votingPower,proto3" json:"voting_power,omitempty"`
	Signatures    []byte `protobuf:"bytes,3,opt,name=signatures,proto3" json:"signatures,omitempty"`
}

BatchSignatures contains basic validator data and its batch signatures under various cryptographic schemes.

func (*BatchSignatures) Descriptor 

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

func (*BatchSignatures) GetSignatures 

func (m *BatchSignatures) GetSignatures() []byte

func (*BatchSignatures) GetValidatorAddr 

func (m *BatchSignatures) GetValidatorAddr() string

func (*BatchSignatures) GetVotingPower 

func (m *BatchSignatures) GetVotingPower() int64

func (*BatchSignatures) Marshal 

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

func (*BatchSignatures) MarshalTo 

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

func (*BatchSignatures) MarshalToSizedBuffer 

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

func (*BatchSignatures) ProtoMessage 

func (*BatchSignatures) ProtoMessage()

func (*BatchSignatures) Reset 

func (m *BatchSignatures) Reset()

func (*BatchSignatures) Size 

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

func (*BatchSignatures) String 

func (m *BatchSignatures) String() string

func (*BatchSignatures) Unmarshal 

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

func (*BatchSignatures) XXX_DiscardUnknown 

func (m *BatchSignatures) XXX_DiscardUnknown()

func (*BatchSignatures) XXX_Marshal 

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

func (*BatchSignatures) XXX_Merge 

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

func (*BatchSignatures) XXX_Size 

func (m *BatchSignatures) XXX_Size() int

func (*BatchSignatures) XXX_Unmarshal 

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

type DataResult 

type DataResult struct {
	// id is the Keccack-256 hash of the data result.
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// dr_id is the data request identifier.
	DrId string `protobuf:"bytes,2,opt,name=dr_id,json=drId,proto3" json:"dr_id,omitempty"`
	// version is a semantic version string.
	Version string `protobuf:"bytes,3,opt,name=version,proto3" json:"version,omitempty"`
	// block_height is the height at which the data request was tallied.
	BlockHeight uint64 `protobuf:"varint,4,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
	// exit_code is the exit code of the tally wasm binary execution.
	ExitCode uint32 `protobuf:"varint,5,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	// gas_used is the gas used by the data request execution.
	GasUsed uint64 `protobuf:"varint,6,opt,name=gas_used,json=gasUsed,proto3" json:"gas_used,omitempty"`
	// result is the result of the tally wasm binary execution.
	Result []byte `protobuf:"bytes,7,opt,name=result,proto3" json:"result,omitempty"`
	// payback_address is the payback address set by the relayer.
	PaybackAddress string `protobuf:"bytes,8,opt,name=payback_address,json=paybackAddress,proto3" json:"payback_address,omitempty"`
	// seda_payload is the payload set by SEDA Protocol (e.g. OEV-enabled
	// data requests)
	SedaPayload string `protobuf:"bytes,9,opt,name=seda_payload,json=sedaPayload,proto3" json:"seda_payload,omitempty"`
	// consensus indicates whether consensus was reached in the tally
	// process.
	Consensus bool `protobuf:"varint,10,opt,name=consensus,proto3" json:"consensus,omitempty"`
}

DataResult represents the result of a resolved data request.

func (*DataResult) Descriptor 

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

func (*DataResult) GetBlockHeight 

func (m *DataResult) GetBlockHeight() uint64

func (*DataResult) GetConsensus 

func (m *DataResult) GetConsensus() bool

func (*DataResult) GetDrId 

func (m *DataResult) GetDrId() string

func (*DataResult) GetExitCode 

func (m *DataResult) GetExitCode() uint32

func (*DataResult) GetGasUsed 

func (m *DataResult) GetGasUsed() uint64

func (*DataResult) GetId 

func (m *DataResult) GetId() string

func (*DataResult) GetPaybackAddress 

func (m *DataResult) GetPaybackAddress() string

func (*DataResult) GetResult 

func (m *DataResult) GetResult() []byte

func (*DataResult) GetSedaPayload 

func (m *DataResult) GetSedaPayload() string

func (*DataResult) GetVersion 

func (m *DataResult) GetVersion() string

func (*DataResult) Marshal 

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

func (*DataResult) MarshalTo 

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

func (*DataResult) MarshalToSizedBuffer 

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

func (*DataResult) ProtoMessage 

func (*DataResult) ProtoMessage()

func (*DataResult) Reset 

func (m *DataResult) Reset()

func (*DataResult) Size 

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

func (*DataResult) String 

func (m *DataResult) String() string

func (*DataResult) TryHash 

func (dr *DataResult) TryHash() (string, error)

TryHash returns a hex-encoded hash of the DataResult.

func (*DataResult) Unmarshal 

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

func (*DataResult) XXX_DiscardUnknown 

func (m *DataResult) XXX_DiscardUnknown()

func (*DataResult) XXX_Marshal 

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

func (*DataResult) XXX_Merge 

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

func (*DataResult) XXX_Size 

func (m *DataResult) XXX_Size() int

func (*DataResult) XXX_Unmarshal 

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

type GenesisState 

type GenesisState struct {
	// current_batch_number is the batch number of the most recently-
	// created batch.
	CurrentBatchNumber uint64            `protobuf:"varint,1,opt,name=current_batch_number,json=currentBatchNumber,proto3" json:"current_batch_number,omitempty"`
	Batches            []Batch           `protobuf:"bytes,2,rep,name=batches,proto3" json:"batches"`
	TreeEntries        []TreeEntries     `protobuf:"bytes,3,rep,name=tree_entries,json=treeEntries,proto3" json:"tree_entries"`
	DataResults        []DataResult      `protobuf:"bytes,4,rep,name=data_results,json=dataResults,proto3" json:"data_results"`
	BatchAssignments   []BatchAssignment `protobuf:"bytes,5,rep,name=batch_assignments,json=batchAssignments,proto3" json:"batch_assignments"`
	Params             Params            `protobuf:"bytes,6,opt,name=params,proto3" json:"params"`
}

GenesisState defines the batching module's genesis state.

func DefaultGenesisState 

func DefaultGenesisState() *GenesisState

DefaultGenesisState creates a default GenesisState object.

func NewGenesisState 

func NewGenesisState(
	curBatchNum uint64,
	batches []Batch,
	entries []TreeEntries,
	dataResults []DataResult,
	batchAssignments []BatchAssignment,
	params Params,
) GenesisState

NewGenesisState constructs a GenesisState object.

func (*GenesisState) Descriptor 

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

func (*GenesisState) GetBatchAssignments 

func (m *GenesisState) GetBatchAssignments() []BatchAssignment

func (*GenesisState) GetBatches 

func (m *GenesisState) GetBatches() []Batch

func (*GenesisState) GetCurrentBatchNumber 

func (m *GenesisState) GetCurrentBatchNumber() uint64

func (*GenesisState) GetDataResults 

func (m *GenesisState) GetDataResults() []DataResult

func (*GenesisState) GetParams 

func (m *GenesisState) GetParams() Params

func (*GenesisState) GetTreeEntries 

func (m *GenesisState) GetTreeEntries() []TreeEntries

func (*GenesisState) Marshal 

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

func (*GenesisState) MarshalTo 

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

func (*GenesisState) MarshalToSizedBuffer 

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

func (*GenesisState) ProtoMessage 

func (*GenesisState) ProtoMessage()

func (*GenesisState) Reset 

func (m *GenesisState) Reset()

func (*GenesisState) Size 

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

func (*GenesisState) String 

func (m *GenesisState) String() string

func (*GenesisState) Unmarshal 

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

func (*GenesisState) XXX_DiscardUnknown 

func (m *GenesisState) XXX_DiscardUnknown()

func (*GenesisState) XXX_Marshal 

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

func (*GenesisState) XXX_Merge 

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

func (*GenesisState) XXX_Size 

func (m *GenesisState) XXX_Size() int

func (*GenesisState) XXX_Unmarshal 

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

type Params 

type Params struct {
	// validator_set_trim_percent is the percentage of the validator
	// set to store in the validator merkle tree in the batch.
	ValidatorSetTrimPercent uint32 `` /* 135-byte string literal not displayed */
}

Params is a list of parameters which can be changed through governance.

func DefaultParams 

func DefaultParams() Params

DefaultParams returns default batching module parameters.

func (*Params) Descriptor 

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

func (*Params) Equal 

func (this *Params) Equal(that interface{}) bool

func (*Params) GetValidatorSetTrimPercent 

func (m *Params) GetValidatorSetTrimPercent() uint32

func (*Params) Marshal 

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

func (*Params) MarshalTo 

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

func (*Params) MarshalToSizedBuffer 

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

func (*Params) ProtoMessage 

func (*Params) ProtoMessage()

func (*Params) Reset 

func (m *Params) Reset()

func (*Params) Size 

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

func (*Params) String 

func (m *Params) String() string

func (*Params) Unmarshal 

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

func (*Params) Validate 

func (p *Params) Validate() error

Validate validates the batching module parameters.

func (*Params) XXX_DiscardUnknown 

func (m *Params) XXX_DiscardUnknown()

func (*Params) XXX_Marshal 

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

func (*Params) XXX_Merge 

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

func (*Params) XXX_Size 

func (m *Params) XXX_Size() int

func (*Params) XXX_Unmarshal 

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

type PubKeyKeeper 

type PubKeyKeeper interface {
	GetValidatorKeyAtIndex(ctx context.Context, validatorAddr sdk.ValAddress, index utils.SEDAKeyIndex) (cryptotypes.PubKey, error)
}

type QueryBatchAssignmentRequest 

type QueryBatchAssignmentRequest struct {
	DataRequestId string `protobuf:"bytes,1,opt,name=data_request_id,json=dataRequestId,proto3" json:"data_request_id,omitempty"`
}

The request message for QueryBatchAssignment RPC.

func (*QueryBatchAssignmentRequest) Descriptor 

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

func (*QueryBatchAssignmentRequest) GetDataRequestId 

func (m *QueryBatchAssignmentRequest) GetDataRequestId() string

func (*QueryBatchAssignmentRequest) Marshal 

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

func (*QueryBatchAssignmentRequest) MarshalTo 

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

func (*QueryBatchAssignmentRequest) MarshalToSizedBuffer 

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

func (*QueryBatchAssignmentRequest) ProtoMessage 

func (*QueryBatchAssignmentRequest) ProtoMessage()

func (*QueryBatchAssignmentRequest) Reset 

func (m *QueryBatchAssignmentRequest) Reset()

func (*QueryBatchAssignmentRequest) Size 

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

func (*QueryBatchAssignmentRequest) String 

func (m *QueryBatchAssignmentRequest) String() string

func (*QueryBatchAssignmentRequest) Unmarshal 

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

func (*QueryBatchAssignmentRequest) XXX_DiscardUnknown 

func (m *QueryBatchAssignmentRequest) XXX_DiscardUnknown()

func (*QueryBatchAssignmentRequest) XXX_Marshal 

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

func (*QueryBatchAssignmentRequest) XXX_Merge 

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

func (*QueryBatchAssignmentRequest) XXX_Size 

func (m *QueryBatchAssignmentRequest) XXX_Size() int

func (*QueryBatchAssignmentRequest) XXX_Unmarshal 

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

type QueryBatchAssignmentResponse 

type QueryBatchAssignmentResponse struct {
	BatchNumber uint64 `protobuf:"varint,1,opt,name=batch_number,json=batchNumber,proto3" json:"batch_number,omitempty"`
}

The response message for QueryBatchAssignment RPC.

func (*QueryBatchAssignmentResponse) Descriptor 

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

func (*QueryBatchAssignmentResponse) GetBatchNumber 

func (m *QueryBatchAssignmentResponse) GetBatchNumber() uint64

func (*QueryBatchAssignmentResponse) Marshal 

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

func (*QueryBatchAssignmentResponse) MarshalTo 

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

func (*QueryBatchAssignmentResponse) MarshalToSizedBuffer 

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

func (*QueryBatchAssignmentResponse) ProtoMessage 

func (*QueryBatchAssignmentResponse) ProtoMessage()

func (*QueryBatchAssignmentResponse) Reset 

func (m *QueryBatchAssignmentResponse) Reset()

func (*QueryBatchAssignmentResponse) Size 

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

func (*QueryBatchAssignmentResponse) String 

func (m *QueryBatchAssignmentResponse) String() string

func (*QueryBatchAssignmentResponse) Unmarshal 

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

func (*QueryBatchAssignmentResponse) XXX_DiscardUnknown 

func (m *QueryBatchAssignmentResponse) XXX_DiscardUnknown()

func (*QueryBatchAssignmentResponse) XXX_Marshal 

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

func (*QueryBatchAssignmentResponse) XXX_Merge 

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

func (*QueryBatchAssignmentResponse) XXX_Size 

func (m *QueryBatchAssignmentResponse) XXX_Size() int

func (*QueryBatchAssignmentResponse) XXX_Unmarshal 

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

type QueryBatchForHeightRequest 

type QueryBatchForHeightRequest struct {
	BlockHeight int64 `protobuf:"varint,1,opt,name=block_height,json=blockHeight,proto3" json:"block_height,omitempty"`
}

The request message for BatchForHeight RPC.

func (*QueryBatchForHeightRequest) Descriptor 

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

func (*QueryBatchForHeightRequest) GetBlockHeight 

func (m *QueryBatchForHeightRequest) GetBlockHeight() int64

func (*QueryBatchForHeightRequest) Marshal 

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

func (*QueryBatchForHeightRequest) MarshalTo 

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

func (*QueryBatchForHeightRequest) MarshalToSizedBuffer 

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

func (*QueryBatchForHeightRequest) ProtoMessage 

func (*QueryBatchForHeightRequest) ProtoMessage()

func (*QueryBatchForHeightRequest) Reset 

func (m *QueryBatchForHeightRequest) Reset()

func (*QueryBatchForHeightRequest) Size 

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

func (*QueryBatchForHeightRequest) String 

func (m *QueryBatchForHeightRequest) String() string

func (*QueryBatchForHeightRequest) Unmarshal 

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

func (*QueryBatchForHeightRequest) XXX_DiscardUnknown 

func (m *QueryBatchForHeightRequest) XXX_DiscardUnknown()

func (*QueryBatchForHeightRequest) XXX_Marshal 

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

func (*QueryBatchForHeightRequest) XXX_Merge 

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

func (*QueryBatchForHeightRequest) XXX_Size 

func (m *QueryBatchForHeightRequest) XXX_Size() int

func (*QueryBatchForHeightRequest) XXX_Unmarshal 

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

type QueryBatchForHeightResponse 

type QueryBatchForHeightResponse struct {
	Batch Batch `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch"`
}

The response message for BatchForHeight RPC.

func (*QueryBatchForHeightResponse) Descriptor 

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

func (*QueryBatchForHeightResponse) GetBatch 

func (m *QueryBatchForHeightResponse) GetBatch() Batch

func (*QueryBatchForHeightResponse) Marshal 

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

func (*QueryBatchForHeightResponse) MarshalTo 

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

func (*QueryBatchForHeightResponse) MarshalToSizedBuffer 

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

func (*QueryBatchForHeightResponse) ProtoMessage 

func (*QueryBatchForHeightResponse) ProtoMessage()

func (*QueryBatchForHeightResponse) Reset 

func (m *QueryBatchForHeightResponse) Reset()

func (*QueryBatchForHeightResponse) Size 

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

func (*QueryBatchForHeightResponse) String 

func (m *QueryBatchForHeightResponse) String() string

func (*QueryBatchForHeightResponse) Unmarshal 

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

func (*QueryBatchForHeightResponse) XXX_DiscardUnknown 

func (m *QueryBatchForHeightResponse) XXX_DiscardUnknown()

func (*QueryBatchForHeightResponse) XXX_Marshal 

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

func (*QueryBatchForHeightResponse) XXX_Merge 

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

func (*QueryBatchForHeightResponse) XXX_Size 

func (m *QueryBatchForHeightResponse) XXX_Size() int

func (*QueryBatchForHeightResponse) XXX_Unmarshal 

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

type QueryBatchRequest 

type QueryBatchRequest struct {
	BatchNumber uint64 `protobuf:"varint,1,opt,name=batch_number,json=batchNumber,proto3" json:"batch_number,omitempty"`
}

The request message for QueryBatch RPC.

func (*QueryBatchRequest) Descriptor 

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

func (*QueryBatchRequest) GetBatchNumber 

func (m *QueryBatchRequest) GetBatchNumber() uint64

func (*QueryBatchRequest) Marshal 

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

func (*QueryBatchRequest) MarshalTo 

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

func (*QueryBatchRequest) MarshalToSizedBuffer 

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

func (*QueryBatchRequest) ProtoMessage 

func (*QueryBatchRequest) ProtoMessage()

func (*QueryBatchRequest) Reset 

func (m *QueryBatchRequest) Reset()

func (*QueryBatchRequest) Size 

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

func (*QueryBatchRequest) String 

func (m *QueryBatchRequest) String() string

func (*QueryBatchRequest) Unmarshal 

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

func (*QueryBatchRequest) XXX_DiscardUnknown 

func (m *QueryBatchRequest) XXX_DiscardUnknown()

func (*QueryBatchRequest) XXX_Marshal 

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

func (*QueryBatchRequest) XXX_Merge 

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

func (*QueryBatchRequest) XXX_Size 

func (m *QueryBatchRequest) XXX_Size() int

func (*QueryBatchRequest) XXX_Unmarshal 

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

type QueryBatchResponse 

type QueryBatchResponse struct {
	Batch Batch `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch"`
}

The response message for QueryBatch RPC.

func (*QueryBatchResponse) Descriptor 

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

func (*QueryBatchResponse) GetBatch 

func (m *QueryBatchResponse) GetBatch() Batch

func (*QueryBatchResponse) Marshal 

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

func (*QueryBatchResponse) MarshalTo 

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

func (*QueryBatchResponse) MarshalToSizedBuffer 

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

func (*QueryBatchResponse) ProtoMessage 

func (*QueryBatchResponse) ProtoMessage()

func (*QueryBatchResponse) Reset 

func (m *QueryBatchResponse) Reset()

func (*QueryBatchResponse) Size 

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

func (*QueryBatchResponse) String 

func (m *QueryBatchResponse) String() string

func (*QueryBatchResponse) Unmarshal 

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

func (*QueryBatchResponse) XXX_DiscardUnknown 

func (m *QueryBatchResponse) XXX_DiscardUnknown()

func (*QueryBatchResponse) XXX_Marshal 

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

func (*QueryBatchResponse) XXX_Merge 

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

func (*QueryBatchResponse) XXX_Size 

func (m *QueryBatchResponse) XXX_Size() int

func (*QueryBatchResponse) XXX_Unmarshal 

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

type QueryBatchSignaturesRequest 

type QueryBatchSignaturesRequest struct {
	BatchNumber uint64 `protobuf:"varint,1,opt,name=batch_number,json=batchNumber,proto3" json:"batch_number,omitempty"`
}

The request message for QueryBatchSignaturesRequest RPC.

func (*QueryBatchSignaturesRequest) Descriptor 

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

func (*QueryBatchSignaturesRequest) GetBatchNumber 

func (m *QueryBatchSignaturesRequest) GetBatchNumber() uint64

func (*QueryBatchSignaturesRequest) Marshal 

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

func (*QueryBatchSignaturesRequest) MarshalTo 

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

func (*QueryBatchSignaturesRequest) MarshalToSizedBuffer 

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

func (*QueryBatchSignaturesRequest) ProtoMessage 

func (*QueryBatchSignaturesRequest) ProtoMessage()

func (*QueryBatchSignaturesRequest) Reset 

func (m *QueryBatchSignaturesRequest) Reset()

func (*QueryBatchSignaturesRequest) Size 

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

func (*QueryBatchSignaturesRequest) String 

func (m *QueryBatchSignaturesRequest) String() string

func (*QueryBatchSignaturesRequest) Unmarshal 

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

func (*QueryBatchSignaturesRequest) XXX_DiscardUnknown 

func (m *QueryBatchSignaturesRequest) XXX_DiscardUnknown()

func (*QueryBatchSignaturesRequest) XXX_Marshal 

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

func (*QueryBatchSignaturesRequest) XXX_Merge 

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

func (*QueryBatchSignaturesRequest) XXX_Size 

func (m *QueryBatchSignaturesRequest) XXX_Size() int

func (*QueryBatchSignaturesRequest) XXX_Unmarshal 

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

type QueryBatchSignaturesResponse 

type QueryBatchSignaturesResponse struct {
	BatchSigs []BatchSignatures `protobuf:"bytes,1,rep,name=batch_sigs,json=batchSigs,proto3" json:"batch_sigs"`
}

The response message for QueryQueryBatchSignatures RPC.

func (*QueryBatchSignaturesResponse) Descriptor 

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

func (*QueryBatchSignaturesResponse) GetBatchSigs 

func (m *QueryBatchSignaturesResponse) GetBatchSigs() []BatchSignatures

func (*QueryBatchSignaturesResponse) Marshal 

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

func (*QueryBatchSignaturesResponse) MarshalTo 

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

func (*QueryBatchSignaturesResponse) MarshalToSizedBuffer 

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

func (*QueryBatchSignaturesResponse) ProtoMessage 

func (*QueryBatchSignaturesResponse) ProtoMessage()

func (*QueryBatchSignaturesResponse) Reset 

func (m *QueryBatchSignaturesResponse) Reset()

func (*QueryBatchSignaturesResponse) Size 

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

func (*QueryBatchSignaturesResponse) String 

func (m *QueryBatchSignaturesResponse) String() string

func (*QueryBatchSignaturesResponse) Unmarshal 

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

func (*QueryBatchSignaturesResponse) XXX_DiscardUnknown 

func (m *QueryBatchSignaturesResponse) XXX_DiscardUnknown()

func (*QueryBatchSignaturesResponse) XXX_Marshal 

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

func (*QueryBatchSignaturesResponse) XXX_Merge 

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

func (*QueryBatchSignaturesResponse) XXX_Size 

func (m *QueryBatchSignaturesResponse) XXX_Size() int

func (*QueryBatchSignaturesResponse) XXX_Unmarshal 

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

type QueryBatchesRequest 

type QueryBatchesRequest struct {
}

The request message for QueryBatches RPC.

func (*QueryBatchesRequest) Descriptor 

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

func (*QueryBatchesRequest) Marshal 

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

func (*QueryBatchesRequest) MarshalTo 

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

func (*QueryBatchesRequest) MarshalToSizedBuffer 

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

func (*QueryBatchesRequest) ProtoMessage 

func (*QueryBatchesRequest) ProtoMessage()

func (*QueryBatchesRequest) Reset 

func (m *QueryBatchesRequest) Reset()

func (*QueryBatchesRequest) Size 

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

func (*QueryBatchesRequest) String 

func (m *QueryBatchesRequest) String() string

func (*QueryBatchesRequest) Unmarshal 

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

func (*QueryBatchesRequest) XXX_DiscardUnknown 

func (m *QueryBatchesRequest) XXX_DiscardUnknown()

func (*QueryBatchesRequest) XXX_Marshal 

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

func (*QueryBatchesRequest) XXX_Merge 

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

func (*QueryBatchesRequest) XXX_Size 

func (m *QueryBatchesRequest) XXX_Size() int

func (*QueryBatchesRequest) XXX_Unmarshal 

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

type QueryBatchesResponse 

type QueryBatchesResponse struct {
	Batches []Batch `protobuf:"bytes,1,rep,name=batches,proto3" json:"batches"`
}

The response message for QueryBatches RPC.

func (*QueryBatchesResponse) Descriptor 

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

func (*QueryBatchesResponse) GetBatches 

func (m *QueryBatchesResponse) GetBatches() []Batch

func (*QueryBatchesResponse) Marshal 

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

func (*QueryBatchesResponse) MarshalTo 

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

func (*QueryBatchesResponse) MarshalToSizedBuffer 

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

func (*QueryBatchesResponse) ProtoMessage 

func (*QueryBatchesResponse) ProtoMessage()

func (*QueryBatchesResponse) Reset 

func (m *QueryBatchesResponse) Reset()

func (*QueryBatchesResponse) Size 

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

func (*QueryBatchesResponse) String 

func (m *QueryBatchesResponse) String() string

func (*QueryBatchesResponse) Unmarshal 

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

func (*QueryBatchesResponse) XXX_DiscardUnknown 

func (m *QueryBatchesResponse) XXX_DiscardUnknown()

func (*QueryBatchesResponse) XXX_Marshal 

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

func (*QueryBatchesResponse) XXX_Merge 

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

func (*QueryBatchesResponse) XXX_Size 

func (m *QueryBatchesResponse) XXX_Size() int

func (*QueryBatchesResponse) XXX_Unmarshal 

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

type QueryClient 

type QueryClient interface {
	// Batch returns a batch given the batch number.
	Batch(ctx context.Context, in *QueryBatchRequest, opts ...grpc.CallOption) (*QueryBatchResponse, error)
	// BatchForHeight returns a batch created at a given block height.
	BatchForHeight(ctx context.Context, in *QueryBatchForHeightRequest, opts ...grpc.CallOption) (*QueryBatchForHeightResponse, error)
	// Batch returns all batches in the store.
	Batches(ctx context.Context, in *QueryBatchesRequest, opts ...grpc.CallOption) (*QueryBatchesResponse, error)
	// TreeEntries returns the tree entries from the given batch number.
	TreeEntries(ctx context.Context, in *QueryTreeEntriesRequest, opts ...grpc.CallOption) (*QueryTreeEntriesResponse, error)
	// BatchSignatures returns the batch signatures for the given batch
	// and the
	BatchSignatures(ctx context.Context, in *QueryBatchSignaturesRequest, opts ...grpc.CallOption) (*QueryBatchSignaturesResponse, error)
	// DataResult returns a data result given its associated data request's
	// ID.
	DataResult(ctx context.Context, in *QueryDataResultRequest, opts ...grpc.CallOption) (*QueryDataResultResponse, error)
	// BatchAssignment returns the batch number that a given data request
	// has been assigned to.
	BatchAssignment(ctx context.Context, in *QueryBatchAssignmentRequest, opts ...grpc.CallOption) (*QueryBatchAssignmentResponse, error)
}

QueryClient is the client API for Query service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewQueryClient 

func NewQueryClient(cc grpc1.ClientConn) QueryClient

type QueryDataResultRequest 

type QueryDataResultRequest struct {
	DataRequestId string `protobuf:"bytes,1,opt,name=data_request_id,json=dataRequestId,proto3" json:"data_request_id,omitempty"`
}

The request message for QueryDataResult RPC.

func (*QueryDataResultRequest) Descriptor 

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

func (*QueryDataResultRequest) GetDataRequestId 

func (m *QueryDataResultRequest) GetDataRequestId() string

func (*QueryDataResultRequest) Marshal 

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

func (*QueryDataResultRequest) MarshalTo 

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

func (*QueryDataResultRequest) MarshalToSizedBuffer 

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

func (*QueryDataResultRequest) ProtoMessage 

func (*QueryDataResultRequest) ProtoMessage()

func (*QueryDataResultRequest) Reset 

func (m *QueryDataResultRequest) Reset()

func (*QueryDataResultRequest) Size 

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

func (*QueryDataResultRequest) String 

func (m *QueryDataResultRequest) String() string

func (*QueryDataResultRequest) Unmarshal 

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

func (*QueryDataResultRequest) XXX_DiscardUnknown 

func (m *QueryDataResultRequest) XXX_DiscardUnknown()

func (*QueryDataResultRequest) XXX_Marshal 

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

func (*QueryDataResultRequest) XXX_Merge 

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

func (*QueryDataResultRequest) XXX_Size 

func (m *QueryDataResultRequest) XXX_Size() int

func (*QueryDataResultRequest) XXX_Unmarshal 

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

type QueryDataResultResponse 

type QueryDataResultResponse struct {
	DataResult DataResult `protobuf:"bytes,1,opt,name=data_result,json=dataResult,proto3" json:"data_result"`
}

The response message for QueryDataResult RPC.

func (*QueryDataResultResponse) Descriptor 

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

func (*QueryDataResultResponse) GetDataResult 

func (m *QueryDataResultResponse) GetDataResult() DataResult

func (*QueryDataResultResponse) Marshal 

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

func (*QueryDataResultResponse) MarshalTo 

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

func (*QueryDataResultResponse) MarshalToSizedBuffer 

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

func (*QueryDataResultResponse) ProtoMessage 

func (*QueryDataResultResponse) ProtoMessage()

func (*QueryDataResultResponse) Reset 

func (m *QueryDataResultResponse) Reset()

func (*QueryDataResultResponse) Size 

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

func (*QueryDataResultResponse) String 

func (m *QueryDataResultResponse) String() string

func (*QueryDataResultResponse) Unmarshal 

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

func (*QueryDataResultResponse) XXX_DiscardUnknown 

func (m *QueryDataResultResponse) XXX_DiscardUnknown()

func (*QueryDataResultResponse) XXX_Marshal 

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

func (*QueryDataResultResponse) XXX_Merge 

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

func (*QueryDataResultResponse) XXX_Size 

func (m *QueryDataResultResponse) XXX_Size() int

func (*QueryDataResultResponse) XXX_Unmarshal 

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

type QueryServer 

type QueryServer interface {
	// Batch returns a batch given the batch number.
	Batch(context.Context, *QueryBatchRequest) (*QueryBatchResponse, error)
	// BatchForHeight returns a batch created at a given block height.
	BatchForHeight(context.Context, *QueryBatchForHeightRequest) (*QueryBatchForHeightResponse, error)
	// Batch returns all batches in the store.
	Batches(context.Context, *QueryBatchesRequest) (*QueryBatchesResponse, error)
	// TreeEntries returns the tree entries from the given batch number.
	TreeEntries(context.Context, *QueryTreeEntriesRequest) (*QueryTreeEntriesResponse, error)
	// BatchSignatures returns the batch signatures for the given batch
	// and the
	BatchSignatures(context.Context, *QueryBatchSignaturesRequest) (*QueryBatchSignaturesResponse, error)
	// DataResult returns a data result given its associated data request's
	// ID.
	DataResult(context.Context, *QueryDataResultRequest) (*QueryDataResultResponse, error)
	// BatchAssignment returns the batch number that a given data request
	// has been assigned to.
	BatchAssignment(context.Context, *QueryBatchAssignmentRequest) (*QueryBatchAssignmentResponse, error)
}

QueryServer is the server API for Query service.

type QueryTreeEntriesRequest 

type QueryTreeEntriesRequest struct {
	BatchNumber uint64 `protobuf:"varint,1,opt,name=batch_number,json=batchNumber,proto3" json:"batch_number,omitempty"`
}

The request message for QueryTreeEntries RPC.

func (*QueryTreeEntriesRequest) Descriptor 

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

func (*QueryTreeEntriesRequest) GetBatchNumber 

func (m *QueryTreeEntriesRequest) GetBatchNumber() uint64

func (*QueryTreeEntriesRequest) Marshal 

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

func (*QueryTreeEntriesRequest) MarshalTo 

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

func (*QueryTreeEntriesRequest) MarshalToSizedBuffer 

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

func (*QueryTreeEntriesRequest) ProtoMessage 

func (*QueryTreeEntriesRequest) ProtoMessage()

func (*QueryTreeEntriesRequest) Reset 

func (m *QueryTreeEntriesRequest) Reset()

func (*QueryTreeEntriesRequest) Size 

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

func (*QueryTreeEntriesRequest) String 

func (m *QueryTreeEntriesRequest) String() string

func (*QueryTreeEntriesRequest) Unmarshal 

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

func (*QueryTreeEntriesRequest) XXX_DiscardUnknown 

func (m *QueryTreeEntriesRequest) XXX_DiscardUnknown()

func (*QueryTreeEntriesRequest) XXX_Marshal 

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

func (*QueryTreeEntriesRequest) XXX_Merge 

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

func (*QueryTreeEntriesRequest) XXX_Size 

func (m *QueryTreeEntriesRequest) XXX_Size() int

func (*QueryTreeEntriesRequest) XXX_Unmarshal 

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

type QueryTreeEntriesResponse 

type QueryTreeEntriesResponse struct {
	Entries TreeEntries `protobuf:"bytes,1,opt,name=entries,proto3" json:"entries"`
}

The response message for QueryTreeEntries RPC.

func (*QueryTreeEntriesResponse) Descriptor 

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

func (*QueryTreeEntriesResponse) GetEntries 

func (m *QueryTreeEntriesResponse) GetEntries() TreeEntries

func (*QueryTreeEntriesResponse) Marshal 

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

func (*QueryTreeEntriesResponse) MarshalTo 

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

func (*QueryTreeEntriesResponse) MarshalToSizedBuffer 

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

func (*QueryTreeEntriesResponse) ProtoMessage 

func (*QueryTreeEntriesResponse) ProtoMessage()

func (*QueryTreeEntriesResponse) Reset 

func (m *QueryTreeEntriesResponse) Reset()

func (*QueryTreeEntriesResponse) Size 

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

func (*QueryTreeEntriesResponse) String 

func (m *QueryTreeEntriesResponse) String() string

func (*QueryTreeEntriesResponse) Unmarshal 

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

func (*QueryTreeEntriesResponse) XXX_DiscardUnknown 

func (m *QueryTreeEntriesResponse) XXX_DiscardUnknown()

func (*QueryTreeEntriesResponse) XXX_Marshal 

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

func (*QueryTreeEntriesResponse) XXX_Merge 

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

func (*QueryTreeEntriesResponse) XXX_Size 

func (m *QueryTreeEntriesResponse) XXX_Size() int

func (*QueryTreeEntriesResponse) XXX_Unmarshal 

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

type StakingKeeper 

type StakingKeeper interface {
	GetBondedValidatorsByPower(ctx context.Context) ([]stakingtypes.Validator, error)
	GetValidatorUpdates(ctx context.Context) ([]abci.ValidatorUpdate, error)
	IterateLastValidatorPowers(ctx context.Context, handler func(operator sdk.ValAddress, power int64) (stop bool)) error
	GetLastTotalPower(ctx context.Context) (math.Int, error)
}

type TreeEntries 

type TreeEntries struct {
	// batch_number is the identifier of the batch the tree entries from.
	BatchNumber uint64 `protobuf:"varint,1,opt,name=batch_number,json=batchNumber,proto3" json:"batch_number,omitempty"`
	// data_result_entries are the entries (unhashed leaf contents) of
	// the data result tree.
	DataResultEntries [][]byte `protobuf:"bytes,2,rep,name=data_result_entries,json=dataResultEntries,proto3" json:"data_result_entries,omitempty"`
	// validator_entries are the entries (unhashed leaf contents) of
	// the validator tree.
	ValidatorEntries [][]byte `protobuf:"bytes,3,rep,name=validator_entries,json=validatorEntries,proto3" json:"validator_entries,omitempty"`
}

TreeEntries are the given batch's data result tree entries and validator tree entries.

func (*TreeEntries) Descriptor 

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

func (*TreeEntries) GetBatchNumber 

func (m *TreeEntries) GetBatchNumber() uint64

func (*TreeEntries) GetDataResultEntries 

func (m *TreeEntries) GetDataResultEntries() [][]byte

func (*TreeEntries) GetValidatorEntries 

func (m *TreeEntries) GetValidatorEntries() [][]byte

func (*TreeEntries) Marshal 

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

func (*TreeEntries) MarshalTo 

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

func (*TreeEntries) MarshalToSizedBuffer 

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

func (*TreeEntries) ProtoMessage 

func (*TreeEntries) ProtoMessage()

func (*TreeEntries) Reset 

func (m *TreeEntries) Reset()

func (*TreeEntries) Size 

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

func (*TreeEntries) String 

func (m *TreeEntries) String() string

func (*TreeEntries) Unmarshal 

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

func (*TreeEntries) XXX_DiscardUnknown 

func (m *TreeEntries) XXX_DiscardUnknown()

func (*TreeEntries) XXX_Marshal 

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

func (*TreeEntries) XXX_Merge 

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

func (*TreeEntries) XXX_Size 

func (m *TreeEntries) XXX_Size() int

func (*TreeEntries) XXX_Unmarshal 

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

type UnimplementedQueryServer 

type UnimplementedQueryServer struct {
}

UnimplementedQueryServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServer) Batch 

func (*UnimplementedQueryServer) Batch(ctx context.Context, req *QueryBatchRequest) (*QueryBatchResponse, error)

func (*UnimplementedQueryServer) BatchAssignment 

func (*UnimplementedQueryServer) BatchAssignment(ctx context.Context, req *QueryBatchAssignmentRequest) (*QueryBatchAssignmentResponse, error)

func (*UnimplementedQueryServer) BatchForHeight 

func (*UnimplementedQueryServer) BatchForHeight(ctx context.Context, req *QueryBatchForHeightRequest) (*QueryBatchForHeightResponse, error)

func (*UnimplementedQueryServer) BatchSignatures 

func (*UnimplementedQueryServer) BatchSignatures(ctx context.Context, req *QueryBatchSignaturesRequest) (*QueryBatchSignaturesResponse, error)

func (*UnimplementedQueryServer) Batches 

func (*UnimplementedQueryServer) Batches(ctx context.Context, req *QueryBatchesRequest) (*QueryBatchesResponse, error)

func (*UnimplementedQueryServer) DataResult 

func (*UnimplementedQueryServer) DataResult(ctx context.Context, req *QueryDataResultRequest) (*QueryDataResultResponse, error)

func (*UnimplementedQueryServer) TreeEntries 

func (*UnimplementedQueryServer) TreeEntries(ctx context.Context, req *QueryTreeEntriesRequest) (*QueryTreeEntriesResponse, error)

type WasmStorageKeeper 

type WasmStorageKeeper interface {
	GetCoreContractAddr(ctx context.Context) (sdk.AccAddress, error)
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.