types

type ABCIApplicationClient ¶

type ABCIApplicationClient interface {
	// Echo a string to test an abci client/server implementation
	Echo(ctx context.Context, in *RequestEcho, opts ...grpc.CallOption) (*ResponseEcho, error)
	Flush(ctx context.Context, in *RequestFlush, opts ...grpc.CallOption) (*ResponseFlush, error)
	Info(ctx context.Context, in *RequestInfo, opts ...grpc.CallOption) (*ResponseInfo, error)
	CheckTx(ctx context.Context, in *RequestCheckTx, opts ...grpc.CallOption) (*ResponseCheckTx, error)
	Query(ctx context.Context, in *RequestQuery, opts ...grpc.CallOption) (*ResponseQuery, error)
	InitChain(ctx context.Context, in *RequestInitChain, opts ...grpc.CallOption) (*ResponseInitChain, error)
	ListSnapshots(ctx context.Context, in *RequestListSnapshots, opts ...grpc.CallOption) (*ResponseListSnapshots, error)
	OfferSnapshot(ctx context.Context, in *RequestOfferSnapshot, opts ...grpc.CallOption) (*ResponseOfferSnapshot, error)
	LoadSnapshotChunk(ctx context.Context, in *RequestLoadSnapshotChunk, opts ...grpc.CallOption) (*ResponseLoadSnapshotChunk, error)
	ApplySnapshotChunk(ctx context.Context, in *RequestApplySnapshotChunk, opts ...grpc.CallOption) (*ResponseApplySnapshotChunk, error)
	PrepareProposal(ctx context.Context, in *RequestPrepareProposal, opts ...grpc.CallOption) (*ResponsePrepareProposal, error)
	ProcessProposal(ctx context.Context, in *RequestProcessProposal, opts ...grpc.CallOption) (*ResponseProcessProposal, error)
	ExtendVote(ctx context.Context, in *RequestExtendVote, opts ...grpc.CallOption) (*ResponseExtendVote, error)
	VerifyVoteExtension(ctx context.Context, in *RequestVerifyVoteExtension, opts ...grpc.CallOption) (*ResponseVerifyVoteExtension, error)
	FinalizeBlock(ctx context.Context, in *RequestFinalizeBlock, opts ...grpc.CallOption) (*ResponseFinalizeBlock, error)
}

ABCIApplicationClient is the client API for ABCIApplication service.

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

func NewABCIApplicationClient(cc *grpc.ClientConn) ABCIApplicationClient

type ABCIApplicationServer ¶

type ABCIApplicationServer interface {
	// Echo a string to test an abci client/server implementation
	Echo(context.Context, *RequestEcho) (*ResponseEcho, error)
	Flush(context.Context, *RequestFlush) (*ResponseFlush, error)
	Info(context.Context, *RequestInfo) (*ResponseInfo, error)
	CheckTx(context.Context, *RequestCheckTx) (*ResponseCheckTx, error)
	Query(context.Context, *RequestQuery) (*ResponseQuery, error)
	InitChain(context.Context, *RequestInitChain) (*ResponseInitChain, error)
	ListSnapshots(context.Context, *RequestListSnapshots) (*ResponseListSnapshots, error)
	OfferSnapshot(context.Context, *RequestOfferSnapshot) (*ResponseOfferSnapshot, error)
	LoadSnapshotChunk(context.Context, *RequestLoadSnapshotChunk) (*ResponseLoadSnapshotChunk, error)
	ApplySnapshotChunk(context.Context, *RequestApplySnapshotChunk) (*ResponseApplySnapshotChunk, error)
	PrepareProposal(context.Context, *RequestPrepareProposal) (*ResponsePrepareProposal, error)
	ProcessProposal(context.Context, *RequestProcessProposal) (*ResponseProcessProposal, error)
	ExtendVote(context.Context, *RequestExtendVote) (*ResponseExtendVote, error)
	VerifyVoteExtension(context.Context, *RequestVerifyVoteExtension) (*ResponseVerifyVoteExtension, error)
	FinalizeBlock(context.Context, *RequestFinalizeBlock) (*ResponseFinalizeBlock, error)
}

ABCIApplicationServer is the server API for ABCIApplication service.

type Application ¶

type Application interface {
	StateSyncer

	// Info/Query Connection
	Info(context.Context, *RequestInfo) (*ResponseInfo, error)    // Return application info
	Query(context.Context, *RequestQuery) (*ResponseQuery, error) // Query for state

	// Mempool Connection
	CheckTx(context.Context, *RequestCheckTx) (*ResponseCheckTx, error) // Validate a tx for the mempool

	// Consensus Connection
	InitChain(context.Context, *RequestInitChain) (*ResponseInitChain, error) // Initialize blockchain w validators/other info from TendermintCore
	PrepareProposal(context.Context, *RequestPrepareProposal) (*ResponsePrepareProposal, error)
	ProcessProposal(context.Context, *RequestProcessProposal) (*ResponseProcessProposal, error)
	// Create application specific vote extension
	ExtendVote(context.Context, *RequestExtendVote) (*ResponseExtendVote, error)
	// Verify application's vote extension data
	VerifyVoteExtension(context.Context, *RequestVerifyVoteExtension) (*ResponseVerifyVoteExtension, error)
	// Deliver the decided block with its txs to the Application
	FinalizeBlock(context.Context, *RequestFinalizeBlock) (*ResponseFinalizeBlock, error)
}

Application is an interface that enables any finite, deterministic state machine to be driven by a blockchain-based replication engine via the ABCI.

type BaseApplication ¶

type BaseApplication struct{}

func NewBaseApplication() *BaseApplication

func (BaseApplication) ApplySnapshotChunk(_ context.Context, req *RequestApplySnapshotChunk) (*ResponseApplySnapshotChunk, error)

func (BaseApplication) CheckTx(_ context.Context, req *RequestCheckTx) (*ResponseCheckTx, error)

func (BaseApplication) ExtendVote(_ context.Context, req *RequestExtendVote) (*ResponseExtendVote, error)

func (BaseApplication) FinalizeBlock(_ context.Context, req *RequestFinalizeBlock) (*ResponseFinalizeBlock, error)

func (BaseApplication) Info(_ context.Context, req *RequestInfo) (*ResponseInfo, error)

func (BaseApplication) InitChain(_ context.Context, req *RequestInitChain) (*ResponseInitChain, error)

func (BaseApplication) ListSnapshots(_ context.Context, req *RequestListSnapshots) (*ResponseListSnapshots, error)

func (BaseApplication) LoadSnapshotChunk(_ context.Context, _ *RequestLoadSnapshotChunk) (*ResponseLoadSnapshotChunk, error)

func (BaseApplication) OfferSnapshot(_ context.Context, req *RequestOfferSnapshot) (*ResponseOfferSnapshot, error)

func (BaseApplication) PrepareProposal(_ context.Context, req *RequestPrepareProposal) (*ResponsePrepareProposal, error)

func (BaseApplication) ProcessProposal(_ context.Context, req *RequestProcessProposal) (*ResponseProcessProposal, error)

func (BaseApplication) Query(_ context.Context, req *RequestQuery) (*ResponseQuery, error)

func (BaseApplication) VerifyVoteExtension(_ context.Context, req *RequestVerifyVoteExtension) (*ResponseVerifyVoteExtension, error)

type CheckTxType ¶

type CheckTxType int32

Type of transaction check

const (
	// NEW is the default and means that a full check of the tranasaction is required.
	CheckTxType_New CheckTxType = 0
	// RECHECK is used when the mempool is initiating a normal recheck of a transaction.
	CheckTxType_Recheck CheckTxType = 1
)

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

func (x CheckTxType) String() string

type CommitInfo ¶

type CommitInfo struct {
	Round                   int32                   `protobuf:"varint,1,opt,name=round,proto3" json:"round,omitempty"`
	QuorumHash              []byte                  `protobuf:"bytes,2,opt,name=quorum_hash,json=quorumHash,proto3" json:"quorum_hash,omitempty"`
	BlockSignature          []byte                  `protobuf:"bytes,3,opt,name=block_signature,json=blockSignature,proto3" json:"block_signature,omitempty"`
	ThresholdVoteExtensions []*types1.VoteExtension `` /* 132-byte string literal not displayed */
}

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

func (m *CommitInfo) GetBlockSignature() []byte

func (m *CommitInfo) GetQuorumHash() []byte

func (m *CommitInfo) GetRound() int32

func (m *CommitInfo) GetThresholdVoteExtensions() []*types1.VoteExtension

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

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

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

func (*CommitInfo) ProtoMessage()

func (m *CommitInfo) Reset()

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

func (m *CommitInfo) String() string

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

func (m *CommitInfo) XXX_DiscardUnknown()

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

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

func (m *CommitInfo) XXX_Size() int

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

type Event ¶

type Event struct {
	Type       string           `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Attributes []EventAttribute `protobuf:"bytes,2,rep,name=attributes,proto3" json:"attributes,omitempty"`
}

Event allows application developers to attach additional information to ResponseCheckTx, ResponsePrepareProposal, ResponseProcessProposal and ResponseFinalizeBlock.

Later, transactions may be queried using these events.

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

func (m *Event) GetAttributes() []EventAttribute

func (m *Event) GetType() string

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

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

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

func (*Event) ProtoMessage()

func (m *Event) Reset()

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

func (m *Event) String() string

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

func (m *Event) XXX_DiscardUnknown()

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

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

func (m *Event) XXX_Size() int

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

type EventAttribute ¶

type EventAttribute struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Index bool   `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"`
}

EventAttribute is a single key-value pair, associated with an event.

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

func (m *EventAttribute) GetIndex() bool

func (m *EventAttribute) GetKey() string

func (m *EventAttribute) GetValue() string

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

func (r *EventAttribute) MarshalJSON() ([]byte, error)

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

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

func (*EventAttribute) ProtoMessage()

func (m *EventAttribute) Reset()

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

func (m *EventAttribute) String() string

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

func (r *EventAttribute) UnmarshalJSON(b []byte) error

func (m *EventAttribute) XXX_DiscardUnknown()

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

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

func (m *EventAttribute) XXX_Size() int

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

type ExecTxResult ¶

type ExecTxResult struct {
	Code      uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Data      []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Log       string `protobuf:"bytes,3,opt,name=log,proto3" json:"log,omitempty"`
	Info      string `protobuf:"bytes,4,opt,name=info,proto3" json:"info,omitempty"`
	GasWanted int64  `protobuf:"varint,5,opt,name=gas_wanted,json=gasWanted,proto3" json:"gas_wanted,omitempty"`
	GasUsed   int64  `protobuf:"varint,6,opt,name=gas_used,json=gasUsed,proto3" json:"gas_used,omitempty"`
	// Type & Key-Value events for indexing transactions (e.g. by account).
	Events    []Event `protobuf:"bytes,7,rep,name=events,proto3" json:"events,omitempty"`
	Codespace string  `protobuf:"bytes,8,opt,name=codespace,proto3" json:"codespace,omitempty"`
}

ExecTxResult contains results of executing one individual transaction.

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

func (m *ExecTxResult) GetCode() uint32

func (m *ExecTxResult) GetCodespace() string

func (m *ExecTxResult) GetData() []byte

func (m *ExecTxResult) GetEvents() []Event

func (m *ExecTxResult) GetGasUsed() int64

func (m *ExecTxResult) GetGasWanted() int64

func (m *ExecTxResult) GetInfo() string

func (m *ExecTxResult) GetLog() string

func (r ExecTxResult) IsErr() bool

func (r ExecTxResult) IsOK() bool

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

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

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

func (*ExecTxResult) ProtoMessage()

func (m *ExecTxResult) Reset()

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

func (m *ExecTxResult) String() string

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

func (m *ExecTxResult) XXX_DiscardUnknown()

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

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

func (m *ExecTxResult) XXX_Size() int

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

type ExtendVoteExtension ¶

type ExtendVoteExtension struct {
	// Vote extension type can be either DEFAULT or THRESHOLD_RECOVER.
	// The Tenderdash supports only THRESHOLD_RECOVER at this moment.
	Type types1.VoteExtensionType `protobuf:"varint,1,opt,name=type,proto3,enum=tendermint.types.VoteExtensionType" json:"type,omitempty"`
	// Deterministic or (Non-Deterministic) extension provided by the sending validator's Application.
	Extension []byte `protobuf:"bytes,2,opt,name=extension,proto3" json:"extension,omitempty"`
}

Provides a vote extension for signing. Each field is mandatory for filling

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

func (m *ExtendVoteExtension) GetExtension() []byte

func (m *ExtendVoteExtension) GetType() types1.VoteExtensionType

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

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

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

func (*ExtendVoteExtension) ProtoMessage()

func (m *ExtendVoteExtension) Reset()

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

func (m *ExtendVoteExtension) String() string

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

func (m *ExtendVoteExtension) XXX_DiscardUnknown()

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

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

func (m *ExtendVoteExtension) XXX_Size() int

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

type ExtendedVoteInfo ¶

type ExtendedVoteInfo struct {
	// The validator that sent the vote.
	Validator Validator `protobuf:"bytes,1,opt,name=validator,proto3" json:"validator"`
	// Indicates whether the validator signed the last block, allowing for rewards based on validator availability.
	SignedLastBlock bool `protobuf:"varint,2,opt,name=signed_last_block,json=signedLastBlock,proto3" json:"signed_last_block,omitempty"`
	// Non-deterministic extension provided by the sending validator's application.
	VoteExtension []byte `protobuf:"bytes,3,opt,name=vote_extension,json=voteExtension,proto3" json:"vote_extension,omitempty"`
}

ExtendedVoteInfo

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

func (m *ExtendedVoteInfo) GetSignedLastBlock() bool

func (m *ExtendedVoteInfo) GetValidator() Validator

func (m *ExtendedVoteInfo) GetVoteExtension() []byte

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

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

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

func (*ExtendedVoteInfo) ProtoMessage()

func (m *ExtendedVoteInfo) Reset()

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

func (m *ExtendedVoteInfo) String() string

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

func (m *ExtendedVoteInfo) XXX_DiscardUnknown()

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

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

func (m *ExtendedVoteInfo) XXX_Size() int

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

type Misbehavior ¶

type Misbehavior struct {
	Type MisbehaviorType `protobuf:"varint,1,opt,name=type,proto3,enum=tendermint.abci.MisbehaviorType" json:"type,omitempty"`
	// The offending validator
	Validator Validator `protobuf:"bytes,2,opt,name=validator,proto3" json:"validator"`
	// The height when the offense occurred
	Height int64 `protobuf:"varint,3,opt,name=height,proto3" json:"height,omitempty"`
	// The corresponding time where the offense occurred
	Time time.Time `protobuf:"bytes,4,opt,name=time,proto3,stdtime" json:"time"`
	// Total voting power of the validator set in case the ABCI application does
	// not store historical validators.
	// https://github.com/tendermint/tendermint/issues/4581
	TotalVotingPower int64 `protobuf:"varint,5,opt,name=total_voting_power,json=totalVotingPower,proto3" json:"total_voting_power,omitempty"`
}

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

func (m *Misbehavior) GetHeight() int64

func (m *Misbehavior) GetTime() time.Time

func (m *Misbehavior) GetTotalVotingPower() int64

func (m *Misbehavior) GetType() MisbehaviorType

func (m *Misbehavior) GetValidator() Validator

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

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

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

func (*Misbehavior) ProtoMessage()

func (m *Misbehavior) Reset()

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

func (m *Misbehavior) String() string

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

func (m *Misbehavior) XXX_DiscardUnknown()

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

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

func (m *Misbehavior) XXX_Size() int

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

type MisbehaviorType ¶

type MisbehaviorType int32

const (
	MisbehaviorType_UNKNOWN             MisbehaviorType = 0
	MisbehaviorType_DUPLICATE_VOTE      MisbehaviorType = 1
	MisbehaviorType_LIGHT_CLIENT_ATTACK MisbehaviorType = 2
)

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

func (x MisbehaviorType) String() string

type QuorumHashUpdate ¶

type QuorumHashUpdate struct {
	QuorumHash []byte `protobuf:"bytes,1,opt,name=quorum_hash,json=quorumHash,proto3" json:"quorum_hash,omitempty"`
}

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

func (m *QuorumHashUpdate) GetQuorumHash() []byte

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

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

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

func (*QuorumHashUpdate) ProtoMessage()

func (m *QuorumHashUpdate) Reset()

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

func (m *QuorumHashUpdate) String() string

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

func (m *QuorumHashUpdate) XXX_DiscardUnknown()

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

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

func (m *QuorumHashUpdate) XXX_Size() int

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

type QuorumOptionFunc ¶

type QuorumOptionFunc func(conf *quorumConfig)

QuorumOptionFunc is an option function for quorum config

func WithNodeAddrs(addrs []string) QuorumOptionFunc

func WithPower(power int64) QuorumOptionFunc

func WithQuorumHash(quorumHash crypto.QuorumHash) QuorumOptionFunc

func WithRandQuorumHash() QuorumOptionFunc

type Request ¶

type Request struct {
	// Types that are valid to be assigned to Value:
	//	*Request_Echo
	//	*Request_Flush
	//	*Request_Info
	//	*Request_InitChain
	//	*Request_Query
	//	*Request_CheckTx
	//	*Request_ListSnapshots
	//	*Request_OfferSnapshot
	//	*Request_LoadSnapshotChunk
	//	*Request_ApplySnapshotChunk
	//	*Request_PrepareProposal
	//	*Request_ProcessProposal
	//	*Request_ExtendVote
	//	*Request_VerifyVoteExtension
	//	*Request_FinalizeBlock
	Value isRequest_Value `protobuf_oneof:"value"`
}

Request types

func ToRequestApplySnapshotChunk(req *RequestApplySnapshotChunk) *Request

func ToRequestCheckTx(req *RequestCheckTx) *Request

func ToRequestEcho(message string) *Request

func ToRequestExtendVote(req *RequestExtendVote) *Request

func ToRequestFinalizeBlock(req *RequestFinalizeBlock) *Request

func ToRequestFlush() *Request

func ToRequestInfo(req *RequestInfo) *Request

func ToRequestInitChain(req *RequestInitChain) *Request

func ToRequestListSnapshots(req *RequestListSnapshots) *Request

func ToRequestLoadSnapshotChunk(req *RequestLoadSnapshotChunk) *Request

func ToRequestOfferSnapshot(req *RequestOfferSnapshot) *Request

func ToRequestPrepareProposal(req *RequestPrepareProposal) *Request

func ToRequestProcessProposal(req *RequestProcessProposal) *Request

func ToRequestQuery(req *RequestQuery) *Request

func ToRequestVerifyVoteExtension(req *RequestVerifyVoteExtension) *Request

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

func (m *Request) GetApplySnapshotChunk() *RequestApplySnapshotChunk

func (m *Request) GetCheckTx() *RequestCheckTx

func (m *Request) GetEcho() *RequestEcho

func (m *Request) GetExtendVote() *RequestExtendVote

func (m *Request) GetFinalizeBlock() *RequestFinalizeBlock

func (m *Request) GetFlush() *RequestFlush

func (m *Request) GetInfo() *RequestInfo

func (m *Request) GetInitChain() *RequestInitChain

func (m *Request) GetListSnapshots() *RequestListSnapshots

func (m *Request) GetLoadSnapshotChunk() *RequestLoadSnapshotChunk

func (m *Request) GetOfferSnapshot() *RequestOfferSnapshot

func (m *Request) GetPrepareProposal() *RequestPrepareProposal

func (m *Request) GetProcessProposal() *RequestProcessProposal

func (m *Request) GetQuery() *RequestQuery

func (m *Request) GetValue() isRequest_Value

func (m *Request) GetVerifyVoteExtension() *RequestVerifyVoteExtension

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

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

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

func (*Request) ProtoMessage()

func (m *Request) Reset()

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

func (m *Request) String() string

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

func (m *Request) XXX_DiscardUnknown()

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

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

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

func (m *Request) XXX_Size() int

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

type RequestApplySnapshotChunk ¶

type RequestApplySnapshotChunk struct {
	ChunkId []byte `protobuf:"bytes,1,opt,name=chunk_id,json=chunkId,proto3" json:"chunk_id,omitempty"`
	Chunk   []byte `protobuf:"bytes,2,opt,name=chunk,proto3" json:"chunk,omitempty"`
	Sender  string `protobuf:"bytes,3,opt,name=sender,proto3" json:"sender,omitempty"`
}

Applies a snapshot chunk.

• The application can choose to refetch chunks and/or ban P2P peers as appropriate. Tenderdash will not do this unless instructed by the application.
• The application may want to verify each chunk, e.g. by attaching chunk hashes in `Snapshot.Metadata“ and/or incrementally verifying contents against AppHash.
• When all chunks have been accepted, Tenderdash will make an ABCI Info call to verify that LastBlockAppHash and LastBlockHeight matches the expected values, and record the AppVersion in the node state. It then switches to fast sync or consensus and joins the network.
• If Tenderdash is unable to retrieve the next chunk after some time (e.g. because no suitable peers are available), it will reject the snapshot and try a different one via OfferSnapshot. The application should be prepared to reset and accept it or abort as appropriate.

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

func (m *RequestApplySnapshotChunk) GetChunk() []byte

func (m *RequestApplySnapshotChunk) GetChunkId() []byte

func (m *RequestApplySnapshotChunk) GetSender() string

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

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

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

func (*RequestApplySnapshotChunk) ProtoMessage()

func (m *RequestApplySnapshotChunk) Reset()

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

func (m *RequestApplySnapshotChunk) String() string

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

func (m *RequestApplySnapshotChunk) XXX_DiscardUnknown()

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

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

func (m *RequestApplySnapshotChunk) XXX_Size() int

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

type RequestCheckTx ¶

type RequestCheckTx struct {
	// The request transaction bytes.
	Tx []byte `protobuf:"bytes,1,opt,name=tx,proto3" json:"tx,omitempty"`
	// Type or transaction check to execute.
	Type CheckTxType `protobuf:"varint,2,opt,name=type,proto3,enum=tendermint.abci.CheckTxType" json:"type,omitempty"`
}

Check if transaction is valid.

• Technically optional - not involved in processing blocks.
• Guardian of the mempool: every node runs CheckTx before letting a transaction into its local mempool.
• The transaction may come from an external user or another node
• CheckTx validates the transaction against the current state of the application, for example, checking signatures and account balances, but does not apply any of the state changes described in the transaction.
• Transactions where ResponseCheckTx.Code != 0 will be rejected - they will not be broadcast to other nodes or included in a proposal block.
• Tendermint attributes no other value to the response code

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

func (m *RequestCheckTx) GetTx() []byte

func (m *RequestCheckTx) GetType() CheckTxType

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

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

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

func (*RequestCheckTx) ProtoMessage()

func (m *RequestCheckTx) Reset()

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

func (m *RequestCheckTx) String() string

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

func (m *RequestCheckTx) XXX_DiscardUnknown()

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

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

func (m *RequestCheckTx) XXX_Size() int

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

type RequestEcho ¶

type RequestEcho struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
}

Echo a string to test an abci client/server implementation

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

func (m *RequestEcho) GetMessage() string

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

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

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

func (*RequestEcho) ProtoMessage()

func (m *RequestEcho) Reset()

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

func (m *RequestEcho) String() string

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

func (m *RequestEcho) XXX_DiscardUnknown()

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

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

func (m *RequestEcho) XXX_Size() int

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

type RequestExtendVote ¶

type RequestExtendVote struct {
	Hash   []byte `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	Height int64  `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
	Round  int32  `protobuf:"varint,3,opt,name=round,proto3" json:"round,omitempty"`
}

Extends a vote with application-side injection

#### Usage

• `ResponseExtendVote.vote_extensions` is optional information that, if present, will be signed by Tenderdash and attached to the Precommit message.
• `RequestExtendVote.hash` corresponds to the hash of a proposed block that was made available to the application in a previous call to `ProcessProposal` or `PrepareProposal` for the current height.
• `ResponseExtendVote.vote_extensions` will only be attached to a non-`nil` Precommit message. If Tenderdash is to precommit `nil`, it will not call `RequestExtendVote`.
• The Application logic that creates the extensions can be non-deterministic.

#### When does Tenderdash call it?

When a validator _p_ is in Tenderdash consensus state _prevote_ of round _r_, height _h_, in which _q_ is the proposer; and _p_ has received

- the Proposal message _v_ for round _r_, height _h_, along with all the block parts, from _q_, - `Prevote` messages from _2f + 1_ validators' voting power for round _r_, height _h_, prevoting for the same block _id(v)_,

then _p_'s Tenderdash locks _v_ and sends a Precommit message in the following way

1. _p_'s Tenderdash sets _lockedValue_ and _validValue_ to _v_, and sets _lockedRound_ and _validRound_ to _r_
2. _p_'s Tenderdash calls `RequestExtendVote` with _id(v)_ (`RequestExtendVote.hash`). The call is synchronous.
3. The Application optionally returns an array of bytes, `ResponseExtendVote.extension`, which is not interpreted by Tenderdash.
4. _p_'s Tenderdash includes `ResponseExtendVote.extension` in a field of type [CanonicalVoteExtension](#canonicalvoteextension), it then populates the other fields in [CanonicalVoteExtension](#canonicalvoteextension), and signs the populated data structure.
5. _p_'s Tenderdash constructs and signs the [CanonicalVote](../core/data_structures.md#canonicalvote) structure.
6. _p_'s Tenderdash constructs the Precommit message (i.e. [Vote](../core/data_structures.md#vote) structure) using [CanonicalVoteExtension](#canonicalvoteextension) and [CanonicalVote](../core/data_structures.md#canonicalvote).
7. _p_'s Tenderdash broadcasts the Precommit message.

In the cases when _p_'s Tenderdash is to broadcast `precommit nil` messages (either _2f+1_ `prevote nil` messages received, or _timeoutPrevote_ triggered), _p_'s Tenderdash does **not** call `RequestExtendVote` and will not include a [CanonicalVoteExtension](#canonicalvoteextension) field in the `precommit nil` message.

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

func (m *RequestExtendVote) GetHash() []byte

func (m *RequestExtendVote) GetHeight() int64

func (m *RequestExtendVote) GetRound() int32

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

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

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

func (*RequestExtendVote) ProtoMessage()

func (m *RequestExtendVote) Reset()

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

func (m *RequestExtendVote) String() string

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

func (m *RequestExtendVote) XXX_DiscardUnknown()

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

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

func (m *RequestExtendVote) XXX_Size() int

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

type RequestFinalizeBlock ¶

type RequestFinalizeBlock struct {
	// Info about the current commit
	Commit CommitInfo `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit"`
	// List of information about validators that acted incorrectly.
	Misbehavior []Misbehavior `protobuf:"bytes,2,rep,name=misbehavior,proto3" json:"misbehavior"`
	// The block header's hash. Present for convenience (can be derived from the block header).
	Hash []byte `protobuf:"bytes,3,opt,name=hash,proto3" json:"hash,omitempty"`
	// The height of the finalized block.
	Height int64 `protobuf:"varint,4,opt,name=height,proto3" json:"height,omitempty"`
	// Round number for the block
	Round int32 `protobuf:"varint,5,opt,name=round,proto3" json:"round,omitempty"`
	// The block that was finalized
	Block *types1.Block `protobuf:"bytes,6,opt,name=block,proto3" json:"block,omitempty"`
	// The block ID that was finalized
	BlockID *types1.BlockID `protobuf:"bytes,7,opt,name=block_id,json=blockId,proto3" json:"block_id,omitempty"`
}

Finalize newly decided block.

#### Usage

• Contains the fields of the newly decided block.
• The height and timestamp values match the values from the header of the proposed block.
• The Application can use `RequestFinalizeBlock.decided_last_commit` and `RequestFinalizeBlock.byzantine_validators` to determine rewards and punishments for the validators.
• The application must execute the transactions in full, in the order they appear in `RequestFinalizeBlock.txs`, before returning control to Tenderdash. Alternatively, it can commit the candidate state corresponding to the same block previously executed via `PrepareProposal` or `ProcessProposal`.
• `ResponseFinalizeBlock.tx_results[i].Code == 0` only if the _i_-th transaction is fully valid.
• Application is expected to persist its state at the end of this call, before calling `ResponseFinalizeBlock`.
• Later calls to `Query` can return proofs about the application state anchored in this Merkle root hash.
• Use `ResponseFinalizeBlock.retain_height` with caution! If all nodes in the network remove historical blocks then this data is permanently lost, and no new nodes will be able to join the network and bootstrap. Historical blocks may also be required for other purposes, e.g. auditing, replay of non-persisted heights, light client verification, and so on.
• Just as `ProcessProposal`, the implementation of `FinalizeBlock` MUST be deterministic, since it is making the Application's state evolve in the context of state machine replication.
• Currently, Tenderdash will fill up all fields in `RequestFinalizeBlock`, even if they were already passed on to the Application via `RequestPrepareProposal` or `RequestProcessProposal`. If the Application is in same-block execution mode, it applies the right candidate state here (rather than executing the whole block). In this case the Application disregards all parameters in `RequestFinalizeBlock` except `RequestFinalizeBlock.hash`.

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

func (m *RequestFinalizeBlock) GetBlock() *types1.Block

func (m *RequestFinalizeBlock) GetBlockID() *types1.BlockID

func (m *RequestFinalizeBlock) GetCommit() CommitInfo

func (m *RequestFinalizeBlock) GetHash() []byte

func (m *RequestFinalizeBlock) GetHeight() int64

func (m *RequestFinalizeBlock) GetMisbehavior() []Misbehavior

func (m *RequestFinalizeBlock) GetRound() int32

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

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

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

func (*RequestFinalizeBlock) ProtoMessage()

func (m *RequestFinalizeBlock) Reset()

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

func (m *RequestFinalizeBlock) String() string

func (m *RequestFinalizeBlock) ToCanonicalVote() (types.CanonicalVote, error)

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

func (m *RequestFinalizeBlock) XXX_DiscardUnknown()

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

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

func (m *RequestFinalizeBlock) XXX_Size() int

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

type RequestFlush ¶

type RequestFlush struct {
}

Signals that messages queued on the client should be flushed to the server. It is called periodically by the client implementation to ensure asynchronous requests are actually sent, and is called immediately to make a synchronous request, which returns when the Flush response comes back.

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

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

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

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

func (*RequestFlush) ProtoMessage()

func (m *RequestFlush) Reset()

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

func (m *RequestFlush) String() string

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

func (m *RequestFlush) XXX_DiscardUnknown()

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

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

func (m *RequestFlush) XXX_Size() int

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

type RequestInfo ¶

type RequestInfo struct {
	Version      string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	BlockVersion uint64 `protobuf:"varint,2,opt,name=block_version,json=blockVersion,proto3" json:"block_version,omitempty"`
	P2PVersion   uint64 `protobuf:"varint,3,opt,name=p2p_version,json=p2pVersion,proto3" json:"p2p_version,omitempty"`
	AbciVersion  string `protobuf:"bytes,4,opt,name=abci_version,json=abciVersion,proto3" json:"abci_version,omitempty"`
}

Return information about the application state.

Used to sync Tenderdash with the application during a handshake that happens on startup. The returned app_version will be included in the Header of every block. Tenderdsah expects last_block_app_hash and last_block_height to be updated during Commit, ensuring that Commit is never called twice for the same block height.

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

func (m *RequestInfo) GetAbciVersion() string

func (m *RequestInfo) GetBlockVersion() uint64

func (m *RequestInfo) GetP2PVersion() uint64

func (m *RequestInfo) GetVersion() string

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

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

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

func (*RequestInfo) ProtoMessage()

func (m *RequestInfo) Reset()

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

func (m *RequestInfo) String() string

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

func (m *RequestInfo) XXX_DiscardUnknown()

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

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

func (m *RequestInfo) XXX_Size() int

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

type RequestInitChain ¶

type RequestInitChain struct {
	// Genesis time
	Time time.Time `protobuf:"bytes,1,opt,name=time,proto3,stdtime" json:"time"`
	// ID of the blockchain.
	ChainId string `protobuf:"bytes,2,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
	// Initial consensus-critical parameters.
	ConsensusParams *types1.ConsensusParams `protobuf:"bytes,3,opt,name=consensus_params,json=consensusParams,proto3" json:"consensus_params,omitempty"`
	// Initial genesis validators, sorted by voting power.
	ValidatorSet *ValidatorSetUpdate `protobuf:"bytes,4,opt,name=validator_set,json=validatorSet,proto3" json:"validator_set,omitempty"`
	// Serialized initial application state. JSON bytes.
	AppStateBytes []byte `protobuf:"bytes,5,opt,name=app_state_bytes,json=appStateBytes,proto3" json:"app_state_bytes,omitempty"`
	// Height of the initial block (typically `1`).
	InitialHeight int64 `protobuf:"varint,6,opt,name=initial_height,json=initialHeight,proto3" json:"initial_height,omitempty"`
	// Initial core chain lock height.
	InitialCoreHeight uint32 `protobuf:"varint,7,opt,name=initial_core_height,json=initialCoreHeight,proto3" json:"initial_core_height,omitempty"`
}

Called once upon genesis.

• If ResponseInitChain.Validators is empty, the initial validator set will be the RequestInitChain.Validators
• If ResponseInitChain.Validators is not empty, it will be the initial validator set (regardless of what is in RequestInitChain.Validators).
• This allows the app to decide if it wants to accept the initial validator set proposed by Tenderdash (ie. in the genesis file), or if it wants to use a different one (perhaps computed based on some application specific information in the genesis file).

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

func (m *RequestInitChain) GetAppStateBytes() []byte

func (m *RequestInitChain) GetChainId() string

func (m *RequestInitChain) GetConsensusParams() *types1.ConsensusParams

func (m *RequestInitChain) GetInitialCoreHeight() uint32

func (m *RequestInitChain) GetInitialHeight() int64

func (m *RequestInitChain) GetTime() time.Time

func (m *RequestInitChain) GetValidatorSet() *ValidatorSetUpdate

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

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

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

func (*RequestInitChain) ProtoMessage()

func (m *RequestInitChain) Reset()

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

func (m *RequestInitChain) String() string

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

func (m *RequestInitChain) XXX_DiscardUnknown()

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

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

func (m *RequestInitChain) XXX_Size() int

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

type RequestListSnapshots ¶

type RequestListSnapshots struct {
}

Lists available snapshots

- Used during state sync to discover available snapshots on peers. - See Snapshot data type for details.

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

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

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

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

func (*RequestListSnapshots) ProtoMessage()

func (m *RequestListSnapshots) Reset()

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

func (m *RequestListSnapshots) String() string

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

func (m *RequestListSnapshots) XXX_DiscardUnknown()

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

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

func (m *RequestListSnapshots) XXX_Size() int

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

type RequestLoadSnapshotChunk ¶

type RequestLoadSnapshotChunk struct {
	Height  uint64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
	Version uint32 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	ChunkId []byte `protobuf:"bytes,3,opt,name=chunk_id,json=chunkId,proto3" json:"chunk_id,omitempty"`
}

Used during state sync to retrieve snapshot chunks from peers.

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

func (m *RequestLoadSnapshotChunk) GetChunkId() []byte

func (m *RequestLoadSnapshotChunk) GetHeight() uint64

func (m *RequestLoadSnapshotChunk) GetVersion() uint32

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

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

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

func (*RequestLoadSnapshotChunk) ProtoMessage()

func (m *RequestLoadSnapshotChunk) Reset()

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

func (m *RequestLoadSnapshotChunk) String() string

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

func (m *RequestLoadSnapshotChunk) XXX_DiscardUnknown()

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

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

func (m *RequestLoadSnapshotChunk) XXX_Size() int

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

type RequestOfferSnapshot ¶

type RequestOfferSnapshot struct {
	// The snapshot offered for restoration.
	Snapshot *Snapshot `protobuf:"bytes,1,opt,name=snapshot,proto3" json:"snapshot,omitempty"`
	// The light client-verified app hash for this height, from the blockchain. 32 bytes.
	AppHash []byte `protobuf:"bytes,2,opt,name=app_hash,json=appHash,proto3" json:"app_hash,omitempty"`
}

Offers a snapshot to the application.

• OfferSnapshot is called when bootstrapping a node using state sync. The application may accept or reject snapshots as appropriate. Upon accepting, Tenderdash will retrieve and apply snapshot chunks via ApplySnapshotChunk. The application may also choose to reject a snapshot in the chunk response, in which case it should be prepared to accept further OfferSnapshot calls.
• Only AppHash can be trusted, as it has been verified by the light client. Any other data can be spoofed by adversaries, so applications should employ additional verification schemes to avoid denial-of-service attacks. The verified AppHash is automatically checked against the restored application at the end of snapshot restoration.
• For more information, see the Snapshot data type or the state sync section.

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

func (m *RequestOfferSnapshot) GetAppHash() []byte

func (m *RequestOfferSnapshot) GetSnapshot() *Snapshot

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

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

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

func (*RequestOfferSnapshot) ProtoMessage()

func (m *RequestOfferSnapshot) Reset()

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

func (m *RequestOfferSnapshot) String() string

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

func (m *RequestOfferSnapshot) XXX_DiscardUnknown()

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

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

func (m *RequestOfferSnapshot) XXX_Size() int

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

type RequestPrepareProposal ¶

type RequestPrepareProposal struct {
	// Currently configured maximum size in bytes taken by the modified transactions.
	// The modified transactions cannot exceed this size.
	MaxTxBytes int64 `protobuf:"varint,1,opt,name=max_tx_bytes,json=maxTxBytes,proto3" json:"max_tx_bytes,omitempty"`
	// Preliminary list of transactions that have been picked as part of the block to propose.
	// Sent to the app for possible modifications.
	Txs [][]byte `protobuf:"bytes,2,rep,name=txs,proto3" json:"txs,omitempty"`
	// Info about the last commit, obtained locally from Tenderdash's data structures.
	LocalLastCommit CommitInfo `protobuf:"bytes,3,opt,name=local_last_commit,json=localLastCommit,proto3" json:"local_last_commit"`
	// List of information about validators that acted incorrectly.
	Misbehavior []Misbehavior `protobuf:"bytes,4,rep,name=misbehavior,proto3" json:"misbehavior"`
	// The height of the block that will be proposed.
	Height int64 `protobuf:"varint,5,opt,name=height,proto3" json:"height,omitempty"`
	// Timestamp of the block that that will be proposed.
	Time time.Time `protobuf:"bytes,6,opt,name=time,proto3,stdtime" json:"time"`
	// Merkle root of the next validator set.
	NextValidatorsHash []byte `protobuf:"bytes,7,opt,name=next_validators_hash,json=nextValidatorsHash,proto3" json:"next_validators_hash,omitempty"`
	// Round number for the block.
	Round int32 `protobuf:"varint,8,opt,name=round,proto3" json:"round,omitempty"`
	// Core chain lock height to be used when signing this block.
	CoreChainLockedHeight uint32 `` /* 129-byte string literal not displayed */
	// ProTxHash of the original proposer of the block.
	ProposerProTxHash []byte `protobuf:"bytes,10,opt,name=proposer_pro_tx_hash,json=proposerProTxHash,proto3" json:"proposer_pro_tx_hash,omitempty"`
	// Proposer's latest available app protocol version.
	ProposedAppVersion uint64 `protobuf:"varint,11,opt,name=proposed_app_version,json=proposedAppVersion,proto3" json:"proposed_app_version,omitempty"`
	// App and block version used to generate the block.
	Version *version.Consensus `protobuf:"bytes,12,opt,name=version,proto3" json:"version,omitempty"`
	// quorum_hash contains hash of validator quorum that will sign the block
	QuorumHash []byte `protobuf:"bytes,13,opt,name=quorum_hash,json=quorumHash,proto3" json:"quorum_hash,omitempty"`
}

Prepare new block proposal, potentially altering list of transactions.

#### Usage

• The first six parameters of `RequestPrepareProposal` are the same as `RequestProcessProposal` and `RequestFinalizeBlock`.
• The height and time values match the values from the header of the proposed block.
• `RequestPrepareProposal` contains a preliminary set of transactions `txs` that Tenderdash considers to be a good block proposal, called _raw proposal_. The Application can modify this set via `ResponsePrepareProposal.tx_records` (see TxRecord(#txrecord)).
• The Application _can_ reorder, remove or add transactions to the raw proposal. Let `tx` be a transaction in `txs`:
• If the Application considers that `tx` should not be proposed in this block, e.g., there are other transactions with higher priority, then it should not include it in `tx_records`. In this case, Tenderdash won't remove `tx` from the mempool. The Application should be extra-careful, as abusing this feature may cause transactions to stay forever in the mempool.
• If the Application considers that a `tx` should not be included in the proposal and removed from the mempool, then the Application should include it in `tx_records` and _mark_ it as `REMOVED`. In this case, Tenderdash will remove `tx` from the mempool.
• If the Application wants to add a new transaction, then the Application should include it in `tx_records` and _mark_ it as `ADD`. In this case, Tenderdash will add it to the mempool.
• The Application should be aware that removing and adding transactions may compromise _traceability_. > Consider the following example: the Application transforms a client-submitted transaction `t1` into a second transaction `t2`, i.e., the Application asks Tenderdash to remove `t1` and add `t2` to the mempool. If a client wants to eventually check what happened to `t1`, it will discover that `t_1` is not in the mempool or in a committed block, getting the wrong idea that `t_1` did not make it into a block. Note that `t_2` _will be_ in a committed block, but unless the Application tracks this information, no component will be aware of it. Thus, if the Application wants traceability, it is its responsability to support it. For instance, the Application could attach to a transformed transaction a list with the hashes of the transactions it derives from.
• Tenderdash MAY include a list of transactions in `RequestPrepareProposal.txs` whose total size in bytes exceeds `RequestPrepareProposal.max_tx_bytes`. Therefore, if the size of `RequestPrepareProposal.txs` is greater than `RequestPrepareProposal.max_tx_bytes`, the Application MUST make sure that the `RequestPrepareProposal.max_tx_bytes` limit is respected by those transaction records returned in `ResponsePrepareProposal.tx_records` that are marked as `UNMODIFIED` or `ADDED`.
• In same-block execution mode, the Application must provide values for `ResponsePrepareProposal.app_hash`, `ResponsePrepareProposal.tx_results`, `ResponsePrepareProposal.validator_updates`, `ResponsePrepareProposal.core_chain_lock_update` and `ResponsePrepareProposal.consensus_param_updates`, as a result of fully executing the block.
• The values for `ResponsePrepareProposal.validator_updates`, `ResponsePrepareProposal.core_chain_lock_update` or `ResponsePrepareProposal.consensus_param_updates` may be empty. In this case, Tenderdash will keep the current values.
• `ResponsePrepareProposal.validator_updates`, triggered by block `H`, affect validation for blocks `H+1`, and `H+2`. Heights following a validator update are affected in the following way:
• `H`: `NextValidatorsHash` includes the new `validator_updates` value.
• `H+1`: The validator set change takes effect and `ValidatorsHash` is updated.
• `H+2`: `local_last_commit` now includes the altered validator set.
• `ResponseFinalizeBlock.consensus_param_updates` returned for block `H` apply to the consensus params for block `H+1` even if the change is agreed in block `H`. For more information on the consensus parameters, see the [application spec entry on consensus parameters](../abci/apps.md#consensus-parameters).
• It is the responsibility of the Application to set the right value for _TimeoutPropose_ so that the (synchronous) execution of the block does not cause other processes to prevote `nil` because their propose timeout goes off.
• As a result of executing the prepared proposal, the Application may produce header events or transaction events. The Application must keep those events until a block is decided and then pass them on to Tenderdash via `ResponseFinalizeBlock`.
• As a sanity check, Tenderdash will check the returned parameters for validity if the Application modified them. In particular, `ResponsePrepareProposal.tx_records` will be deemed invalid if
• There is a duplicate transaction in the list.
• A new or modified transaction is marked as `UNMODIFIED` or `REMOVED`.
• An unmodified transaction is marked as `ADDED`.
• A transaction is marked as `UNKNOWN`.
• `ResponsePrepareProposal.tx_results` contains only results of `UNMODIFIED` and `ADDED` transactions.

`REMOVED` transactions are omitted. The length of `tx_results` can be different than the length of `tx_records`. - If Tenderdash fails to validate the `ResponsePrepareProposal`, Tenderdash will assume the application is faulty and crash.

• The implementation of `PrepareProposal` can be non-deterministic.

#### When does Tenderdash call it?

When a validator _p_ enters Tenderdash consensus round _r_, height _h_, in which _p_ is the proposer, and _p_'s _validValue_ is `nil`:

1. _p_'s Tenderdash collects outstanding transactions from the mempool

• The transactions will be collected in order of priority
• Let $C$ the list of currently collected transactions
• The collection stops when any of the following conditions are met
• the mempool is empty
• the total size of transactions $\in C$ is greater than or equal to `consensusParams.block.max_bytes`
• the sum of `GasWanted` field of transactions $\in C$ is greater than or equal to `consensusParams.block.max_gas`
• _p_'s Tenderdash creates a block header. 2. _p_'s Tenderdash calls `RequestPrepareProposal` with the newly generated block. The call is synchronous: Tenderdash's execution will block until the Application returns from the call. 3. The Application checks the block (hashes, transactions, commit info, misbehavior). Besides,
• in same-block execution mode, the Application can (and should) provide `ResponsePrepareProposal.app_hash`, `ResponsePrepareProposal.validator_updates`, or `ResponsePrepareProposal.consensus_param_updates`.
• the Application can manipulate transactions
• leave transactions untouched - `TxAction = UNMODIFIED`
• add new transactions directly to the proposal - `TxAction = ADDED`
• remove transactions (invalid) from the proposal and from the mempool - `TxAction = REMOVED`
• remove transactions from the proposal but not from the mempool (effectively _delaying_ them) - the Application removes the transaction from the list
• modify transactions (e.g. aggregate them) - `TxAction = ADDED` followed by `TxAction = REMOVED`. As explained above, this compromises client traceability, unless it is implemented at the Application level.
• reorder transactions - the Application reorders transactions in the list 4. If the block is modified, the Application includes the modified block in the return parameters (see the rules in section _Usage_). The Application returns from the call. 5. _p_'s Tenderdash uses the (possibly) modified block as _p_'s proposal in round _r_, height _h_.

Note that, if _p_ has a non-`nil` _validValue_, Tenderdash will use it as proposal and will not call `RequestPrepareProposal`.

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

func (m *RequestPrepareProposal) GetCoreChainLockedHeight() uint32

func (m *RequestPrepareProposal) GetHeight() int64

func (m *RequestPrepareProposal) GetLocalLastCommit() CommitInfo