compact_blockv1alpha1

package
v2.5.2 Latest Latest
Warning

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

 Go to latest Published: Feb 28, 2024 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCompactBlock        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCompactBlock          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCompactBlock = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterQueryServiceServer 

func RegisterQueryServiceServer(s grpc1.Server, srv QueryServiceServer)

Types

type CompactBlock 

type CompactBlock struct {
	Height uint64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	// State payloads describing new state fragments.
	StatePayloads []*StatePayload `protobuf:"bytes,2,rep,name=state_payloads,json=statePayloads,proto3" json:"state_payloads,omitempty"`
	// Nullifiers identifying spent notes.
	Nullifiers []*v1alpha1.Nullifier `protobuf:"bytes,3,rep,name=nullifiers,proto3" json:"nullifiers,omitempty"`
	// The block root of this block.
	BlockRoot *v1alpha11.MerkleRoot `protobuf:"bytes,4,opt,name=block_root,json=blockRoot,proto3" json:"block_root,omitempty"`
	// The epoch root of this epoch (only present when the block is the last in an epoch).
	EpochRoot *v1alpha11.MerkleRoot `protobuf:"bytes,17,opt,name=epoch_root,json=epochRoot,proto3" json:"epoch_root,omitempty"`
	// If a proposal started voting in this block, this is set to `true`.
	ProposalStarted bool `protobuf:"varint,20,opt,name=proposal_started,json=proposalStarted,proto3" json:"proposal_started,omitempty"`
	// Latest Fuzzy Message Detection parameters.
	FmdParameters *v1alpha12.FmdParameters `protobuf:"bytes,100,opt,name=fmd_parameters,json=fmdParameters,proto3" json:"fmd_parameters,omitempty"`
	// Price data for swaps executed in this block.
	SwapOutputs []*v1alpha13.BatchSwapOutputData `protobuf:"bytes,5,rep,name=swap_outputs,json=swapOutputs,proto3" json:"swap_outputs,omitempty"`
	// Indicates updated app parameters.
	AppParametersUpdated bool `protobuf:"varint,6,opt,name=app_parameters_updated,json=appParametersUpdated,proto3" json:"app_parameters_updated,omitempty"`
	// Updated gas prices, if they have changed.
	GasPrices *v1alpha14.GasPrices `protobuf:"bytes,7,opt,name=gas_prices,json=gasPrices,proto3" json:"gas_prices,omitempty"`
}

Contains the minimum data needed to update client state.

func (*CompactBlock) Descriptor 

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

func (*CompactBlock) GetAppParametersUpdated 

func (m *CompactBlock) GetAppParametersUpdated() bool

func (*CompactBlock) GetBlockRoot 

func (m *CompactBlock) GetBlockRoot() *v1alpha11.MerkleRoot

func (*CompactBlock) GetEpochRoot 

func (m *CompactBlock) GetEpochRoot() *v1alpha11.MerkleRoot

func (*CompactBlock) GetFmdParameters 

func (m *CompactBlock) GetFmdParameters() *v1alpha12.FmdParameters

func (*CompactBlock) GetGasPrices 

func (m *CompactBlock) GetGasPrices() *v1alpha14.GasPrices

func (*CompactBlock) GetHeight 

func (m *CompactBlock) GetHeight() uint64

func (*CompactBlock) GetNullifiers 

func (m *CompactBlock) GetNullifiers() []*v1alpha1.Nullifier

func (*CompactBlock) GetProposalStarted 

func (m *CompactBlock) GetProposalStarted() bool

func (*CompactBlock) GetStatePayloads 

func (m *CompactBlock) GetStatePayloads() []*StatePayload

func (*CompactBlock) GetSwapOutputs 

func (m *CompactBlock) GetSwapOutputs() []*v1alpha13.BatchSwapOutputData

func (*CompactBlock) Marshal 

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

func (*CompactBlock) MarshalTo 

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

func (*CompactBlock) MarshalToSizedBuffer 

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

func (*CompactBlock) ProtoMessage 

func (*CompactBlock) ProtoMessage()

func (*CompactBlock) Reset 

func (m *CompactBlock) Reset()

func (*CompactBlock) Size 

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

func (*CompactBlock) String 

func (m *CompactBlock) String() string

func (*CompactBlock) Unmarshal 

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

func (*CompactBlock) XXX_DiscardUnknown 

func (m *CompactBlock) XXX_DiscardUnknown()

func (*CompactBlock) XXX_Marshal 

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

func (*CompactBlock) XXX_Merge 

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

func (*CompactBlock) XXX_Size 

func (m *CompactBlock) XXX_Size() int

func (*CompactBlock) XXX_Unmarshal 

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

type CompactBlockRangeRequest 

type CompactBlockRangeRequest struct {
	// The expected chain id (empty string if no expectation).
	ChainId string `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	// The start height of the range.
	StartHeight uint64 `protobuf:"varint,2,opt,name=start_height,json=startHeight,proto3" json:"start_height,omitempty"`
	// The end height of the range, defaults to the latest block height.
	EndHeight uint64 `protobuf:"varint,3,opt,name=end_height,json=endHeight,proto3" json:"end_height,omitempty"`
	// If set, keeps the connection alive past `end_height`,
	// streaming new compact blocks as they are created.
	KeepAlive bool `protobuf:"varint,4,opt,name=keep_alive,json=keepAlive,proto3" json:"keep_alive,omitempty"`
}

Requests a range of compact block data.

func (*CompactBlockRangeRequest) Descriptor 

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

func (*CompactBlockRangeRequest) GetChainId 

func (m *CompactBlockRangeRequest) GetChainId() string

func (*CompactBlockRangeRequest) GetEndHeight 

func (m *CompactBlockRangeRequest) GetEndHeight() uint64

func (*CompactBlockRangeRequest) GetKeepAlive 

func (m *CompactBlockRangeRequest) GetKeepAlive() bool

func (*CompactBlockRangeRequest) GetStartHeight 

func (m *CompactBlockRangeRequest) GetStartHeight() uint64

func (*CompactBlockRangeRequest) Marshal 

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

func (*CompactBlockRangeRequest) MarshalTo 

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

func (*CompactBlockRangeRequest) MarshalToSizedBuffer 

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

func (*CompactBlockRangeRequest) ProtoMessage 

func (*CompactBlockRangeRequest) ProtoMessage()

func (*CompactBlockRangeRequest) Reset 

func (m *CompactBlockRangeRequest) Reset()

func (*CompactBlockRangeRequest) Size 

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

func (*CompactBlockRangeRequest) String 

func (m *CompactBlockRangeRequest) String() string

func (*CompactBlockRangeRequest) Unmarshal 

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

func (*CompactBlockRangeRequest) XXX_DiscardUnknown 

func (m *CompactBlockRangeRequest) XXX_DiscardUnknown()

func (*CompactBlockRangeRequest) XXX_Marshal 

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

func (*CompactBlockRangeRequest) XXX_Merge 

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

func (*CompactBlockRangeRequest) XXX_Size 

func (m *CompactBlockRangeRequest) XXX_Size() int

func (*CompactBlockRangeRequest) XXX_Unmarshal 

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

type CompactBlockRangeResponse 

type CompactBlockRangeResponse struct {
	CompactBlock *CompactBlock `protobuf:"bytes,1,opt,name=compact_block,json=compactBlock,proto3" json:"compact_block,omitempty"`
}

func (*CompactBlockRangeResponse) Descriptor 

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

func (*CompactBlockRangeResponse) GetCompactBlock 

func (m *CompactBlockRangeResponse) GetCompactBlock() *CompactBlock

func (*CompactBlockRangeResponse) Marshal 

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

func (*CompactBlockRangeResponse) MarshalTo 

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

func (*CompactBlockRangeResponse) MarshalToSizedBuffer 

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

func (*CompactBlockRangeResponse) ProtoMessage 

func (*CompactBlockRangeResponse) ProtoMessage()

func (*CompactBlockRangeResponse) Reset 

func (m *CompactBlockRangeResponse) Reset()

func (*CompactBlockRangeResponse) Size 

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

func (*CompactBlockRangeResponse) String 

func (m *CompactBlockRangeResponse) String() string

func (*CompactBlockRangeResponse) Unmarshal 

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

func (*CompactBlockRangeResponse) XXX_DiscardUnknown 

func (m *CompactBlockRangeResponse) XXX_DiscardUnknown()

func (*CompactBlockRangeResponse) XXX_Marshal 

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

func (*CompactBlockRangeResponse) XXX_Merge 

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

func (*CompactBlockRangeResponse) XXX_Size 

func (m *CompactBlockRangeResponse) XXX_Size() int

func (*CompactBlockRangeResponse) XXX_Unmarshal 

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

type QueryServiceClient 

type QueryServiceClient interface {
	// Returns a stream of `CompactBlockRangeResponse`s.
	CompactBlockRange(ctx context.Context, in *CompactBlockRangeRequest, opts ...grpc.CallOption) (QueryService_CompactBlockRangeClient, error)
}

QueryServiceClient is the client API for QueryService service.

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

func NewQueryServiceClient 

func NewQueryServiceClient(cc grpc1.ClientConn) QueryServiceClient

type QueryServiceServer 

type QueryServiceServer interface {
	// Returns a stream of `CompactBlockRangeResponse`s.
	CompactBlockRange(*CompactBlockRangeRequest, QueryService_CompactBlockRangeServer) error
}

QueryServiceServer is the server API for QueryService service.

type QueryService_CompactBlockRangeClient 

type QueryService_CompactBlockRangeClient interface {
	Recv() (*CompactBlockRangeResponse, error)
	grpc.ClientStream
}

type QueryService_CompactBlockRangeServer 

type QueryService_CompactBlockRangeServer interface {
	Send(*CompactBlockRangeResponse) error
	grpc.ServerStream
}

type StatePayload 

type StatePayload struct {
	// The source of the payload, if known.
	Source *v1alpha1.CommitmentSource `protobuf:"bytes,1,opt,name=source,proto3" json:"source,omitempty"`
	// The state payload itself.
	//
	// Types that are valid to be assigned to StatePayload:
	//	*StatePayload_RolledUp_
	//	*StatePayload_Note_
	//	*StatePayload_Swap_
	StatePayload isStatePayload_StatePayload `protobuf_oneof:"state_payload"`
}

An encrypted payload, corresponding to a single commitment in the state commitment tree.

func (*StatePayload) Descriptor 

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

func (*StatePayload) GetNote 

func (m *StatePayload) GetNote() *StatePayload_Note

func (*StatePayload) GetRolledUp 

func (m *StatePayload) GetRolledUp() *StatePayload_RolledUp

func (*StatePayload) GetSource 

func (m *StatePayload) GetSource() *v1alpha1.CommitmentSource

func (*StatePayload) GetStatePayload 

func (m *StatePayload) GetStatePayload() isStatePayload_StatePayload

func (*StatePayload) GetSwap 

func (m *StatePayload) GetSwap() *StatePayload_Swap

func (*StatePayload) Marshal 

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

func (*StatePayload) MarshalTo 

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

func (*StatePayload) MarshalToSizedBuffer 

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

func (*StatePayload) ProtoMessage 

func (*StatePayload) ProtoMessage()

func (*StatePayload) Reset 

func (m *StatePayload) Reset()

func (*StatePayload) Size 

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

func (*StatePayload) String 

func (m *StatePayload) String() string

func (*StatePayload) Unmarshal 

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

func (*StatePayload) XXX_DiscardUnknown 

func (m *StatePayload) XXX_DiscardUnknown()

func (*StatePayload) XXX_Marshal 

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

func (*StatePayload) XXX_Merge 

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

func (*StatePayload) XXX_OneofWrappers 

func (*StatePayload) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*StatePayload) XXX_Size 

func (m *StatePayload) XXX_Size() int

func (*StatePayload) XXX_Unmarshal 

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

type StatePayload_Note 

type StatePayload_Note struct {
	Note *v1alpha15.NotePayload `protobuf:"bytes,2,opt,name=note,proto3" json:"note,omitempty"`
}

func (*StatePayload_Note) Descriptor 

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

func (*StatePayload_Note) GetNote 

func (m *StatePayload_Note) GetNote() *v1alpha15.NotePayload

func (*StatePayload_Note) Marshal 

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

func (*StatePayload_Note) MarshalTo 

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

func (*StatePayload_Note) MarshalToSizedBuffer 

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

func (*StatePayload_Note) ProtoMessage 

func (*StatePayload_Note) ProtoMessage()

func (*StatePayload_Note) Reset 

func (m *StatePayload_Note) Reset()

func (*StatePayload_Note) Size 

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

func (*StatePayload_Note) String 

func (m *StatePayload_Note) String() string

func (*StatePayload_Note) Unmarshal 

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

func (*StatePayload_Note) XXX_DiscardUnknown 

func (m *StatePayload_Note) XXX_DiscardUnknown()

func (*StatePayload_Note) XXX_Marshal 

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

func (*StatePayload_Note) XXX_Merge 

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

func (*StatePayload_Note) XXX_Size 

func (m *StatePayload_Note) XXX_Size() int

func (*StatePayload_Note) XXX_Unmarshal 

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

type StatePayload_Note_ 

type StatePayload_Note_ struct {
	Note *StatePayload_Note `protobuf:"bytes,3,opt,name=note,proto3,oneof" json:"note,omitempty"`
}

func (*StatePayload_Note_) MarshalTo 

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

func (*StatePayload_Note_) MarshalToSizedBuffer 

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

func (*StatePayload_Note_) Size 

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

type StatePayload_RolledUp 

type StatePayload_RolledUp struct {
	Commitment *v1alpha11.StateCommitment `protobuf:"bytes,1,opt,name=commitment,proto3" json:"commitment,omitempty"`
}

func (*StatePayload_RolledUp) Descriptor 

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

func (*StatePayload_RolledUp) GetCommitment 

func (m *StatePayload_RolledUp) GetCommitment() *v1alpha11.StateCommitment

func (*StatePayload_RolledUp) Marshal 

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

func (*StatePayload_RolledUp) MarshalTo 

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

func (*StatePayload_RolledUp) MarshalToSizedBuffer 

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

func (*StatePayload_RolledUp) ProtoMessage 

func (*StatePayload_RolledUp) ProtoMessage()

func (*StatePayload_RolledUp) Reset 

func (m *StatePayload_RolledUp) Reset()

func (*StatePayload_RolledUp) Size 

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

func (*StatePayload_RolledUp) String 

func (m *StatePayload_RolledUp) String() string

func (*StatePayload_RolledUp) Unmarshal 

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

func (*StatePayload_RolledUp) XXX_DiscardUnknown 

func (m *StatePayload_RolledUp) XXX_DiscardUnknown()

func (*StatePayload_RolledUp) XXX_Marshal 

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

func (*StatePayload_RolledUp) XXX_Merge 

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

func (*StatePayload_RolledUp) XXX_Size 

func (m *StatePayload_RolledUp) XXX_Size() int

func (*StatePayload_RolledUp) XXX_Unmarshal 

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

type StatePayload_RolledUp_ 

type StatePayload_RolledUp_ struct {
	RolledUp *StatePayload_RolledUp `protobuf:"bytes,2,opt,name=rolled_up,json=rolledUp,proto3,oneof" json:"rolled_up,omitempty"`
}

func (*StatePayload_RolledUp_) MarshalTo 

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

func (*StatePayload_RolledUp_) MarshalToSizedBuffer 

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

func (*StatePayload_RolledUp_) Size 

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

type StatePayload_Swap 

type StatePayload_Swap struct {
	Swap *v1alpha13.SwapPayload `protobuf:"bytes,2,opt,name=swap,proto3" json:"swap,omitempty"`
}

func (*StatePayload_Swap) Descriptor 

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

func (*StatePayload_Swap) GetSwap 

func (m *StatePayload_Swap) GetSwap() *v1alpha13.SwapPayload

func (*StatePayload_Swap) Marshal 

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

func (*StatePayload_Swap) MarshalTo 

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

func (*StatePayload_Swap) MarshalToSizedBuffer 

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

func (*StatePayload_Swap) ProtoMessage 

func (*StatePayload_Swap) ProtoMessage()

func (*StatePayload_Swap) Reset 

func (m *StatePayload_Swap) Reset()

func (*StatePayload_Swap) Size 

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

func (*StatePayload_Swap) String 

func (m *StatePayload_Swap) String() string

func (*StatePayload_Swap) Unmarshal 

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

func (*StatePayload_Swap) XXX_DiscardUnknown 

func (m *StatePayload_Swap) XXX_DiscardUnknown()

func (*StatePayload_Swap) XXX_Marshal 

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

func (*StatePayload_Swap) XXX_Merge 

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

func (*StatePayload_Swap) XXX_Size 

func (m *StatePayload_Swap) XXX_Size() int

func (*StatePayload_Swap) XXX_Unmarshal 

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

type StatePayload_Swap_ 

type StatePayload_Swap_ struct {
	Swap *StatePayload_Swap `protobuf:"bytes,4,opt,name=swap,proto3,oneof" json:"swap,omitempty"`
}

func (*StatePayload_Swap_) MarshalTo 

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

func (*StatePayload_Swap_) MarshalToSizedBuffer 

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

func (*StatePayload_Swap_) Size 

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

type UnimplementedQueryServiceServer 

type UnimplementedQueryServiceServer struct {
}

UnimplementedQueryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedQueryServiceServer) CompactBlockRange 

func (*UnimplementedQueryServiceServer) CompactBlockRange(req *CompactBlockRangeRequest, srv QueryService_CompactBlockRangeServer) 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.