Documentation
¶
Index ¶
- Variables
- type AssemblerNodeConfig
- func (*AssemblerNodeConfig) Descriptor() ([]byte, []int)deprecated
- func (x *AssemblerNodeConfig) GetHost() string
- func (x *AssemblerNodeConfig) GetPort() uint32
- func (x *AssemblerNodeConfig) GetTlsCert() []byte
- func (*AssemblerNodeConfig) ProtoMessage()
- func (x *AssemblerNodeConfig) ProtoReflect() protoreflect.Message
- func (x *AssemblerNodeConfig) Reset()
- func (x *AssemblerNodeConfig) String() string
- type BatchSize
- func (*BatchSize) Descriptor() ([]byte, []int)deprecated
- func (x *BatchSize) GetAbsoluteMaxBytes() uint32
- func (x *BatchSize) GetMaxMessageCount() uint32
- func (x *BatchSize) GetPreferredMaxBytes() uint32
- func (*BatchSize) ProtoMessage()
- func (x *BatchSize) ProtoReflect() protoreflect.Message
- func (x *BatchSize) Reset()
- func (x *BatchSize) String() string
- type BatchTimeouts
- func (*BatchTimeouts) Descriptor() ([]byte, []int)deprecated
- func (x *BatchTimeouts) GetAutoRemoveTimeout() string
- func (x *BatchTimeouts) GetBatchCreationTimeout() string
- func (x *BatchTimeouts) GetFirstStrikeThreshold() string
- func (x *BatchTimeouts) GetSecondStrikeThreshold() string
- func (*BatchTimeouts) ProtoMessage()
- func (x *BatchTimeouts) ProtoReflect() protoreflect.Message
- func (x *BatchTimeouts) Reset()
- func (x *BatchTimeouts) String() string
- type BatcherNodeConfig
- func (*BatcherNodeConfig) Descriptor() ([]byte, []int)deprecated
- func (x *BatcherNodeConfig) GetHost() string
- func (x *BatcherNodeConfig) GetPort() uint32
- func (x *BatcherNodeConfig) GetShardID() uint32
- func (x *BatcherNodeConfig) GetSignCert() []byte
- func (x *BatcherNodeConfig) GetTlsCert() []byte
- func (*BatcherNodeConfig) ProtoMessage()
- func (x *BatcherNodeConfig) ProtoReflect() protoreflect.Message
- func (x *BatcherNodeConfig) Reset()
- func (x *BatcherNodeConfig) String() string
- type BatchingConfig
- func (*BatchingConfig) Descriptor() ([]byte, []int)deprecated
- func (x *BatchingConfig) GetBatchSize() *BatchSize
- func (x *BatchingConfig) GetBatchTimeouts() *BatchTimeouts
- func (x *BatchingConfig) GetRequestMaxBytes() uint64
- func (*BatchingConfig) ProtoMessage()
- func (x *BatchingConfig) ProtoReflect() protoreflect.Message
- func (x *BatchingConfig) Reset()
- func (x *BatchingConfig) String() string
- type ConsensusConfig
- func (*ConsensusConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ConsensusConfig) GetSmartBFTConfig() *SmartBFTConfig
- func (*ConsensusConfig) ProtoMessage()
- func (x *ConsensusConfig) ProtoReflect() protoreflect.Message
- func (x *ConsensusConfig) Reset()
- func (x *ConsensusConfig) String() string
- type ConsenterNodeConfig
- func (*ConsenterNodeConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ConsenterNodeConfig) GetHost() string
- func (x *ConsenterNodeConfig) GetPort() uint32
- func (x *ConsenterNodeConfig) GetSignCert() []byte
- func (x *ConsenterNodeConfig) GetTlsCert() []byte
- func (*ConsenterNodeConfig) ProtoMessage()
- func (x *ConsenterNodeConfig) ProtoReflect() protoreflect.Message
- func (x *ConsenterNodeConfig) Reset()
- func (x *ConsenterNodeConfig) String() string
- type PartyConfig
- func (*PartyConfig) Descriptor() ([]byte, []int)deprecated
- func (x *PartyConfig) GetAssemblerConfig() *AssemblerNodeConfig
- func (x *PartyConfig) GetBatchersConfig() []*BatcherNodeConfig
- func (x *PartyConfig) GetCACerts() [][]byte
- func (x *PartyConfig) GetConsenterConfig() *ConsenterNodeConfig
- func (x *PartyConfig) GetPartyID() uint32
- func (x *PartyConfig) GetRouterConfig() *RouterNodeConfig
- func (x *PartyConfig) GetTLSCACerts() [][]byte
- func (*PartyConfig) ProtoMessage()
- func (x *PartyConfig) ProtoReflect() protoreflect.Message
- func (x *PartyConfig) Reset()
- func (x *PartyConfig) String() string
- type RouterNodeConfig
- func (*RouterNodeConfig) Descriptor() ([]byte, []int)deprecated
- func (x *RouterNodeConfig) GetHost() string
- func (x *RouterNodeConfig) GetPort() uint32
- func (x *RouterNodeConfig) GetTlsCert() []byte
- func (*RouterNodeConfig) ProtoMessage()
- func (x *RouterNodeConfig) ProtoReflect() protoreflect.Message
- func (x *RouterNodeConfig) Reset()
- func (x *RouterNodeConfig) String() string
- type SharedConfig
- func (*SharedConfig) Descriptor() ([]byte, []int)deprecated
- func (x *SharedConfig) GetBatchingConfig() *BatchingConfig
- func (x *SharedConfig) GetConsensusConfig() *ConsensusConfig
- func (x *SharedConfig) GetPartiesConfig() []*PartyConfig
- func (*SharedConfig) ProtoMessage()
- func (x *SharedConfig) ProtoReflect() protoreflect.Message
- func (x *SharedConfig) Reset()
- func (x *SharedConfig) String() string
- type SmartBFTConfig
- func (*SmartBFTConfig) Descriptor() ([]byte, []int)deprecated
- func (x *SmartBFTConfig) GetCollectTimeout() string
- func (x *SmartBFTConfig) GetDecisionsPerLeader() uint64
- func (x *SmartBFTConfig) GetIncomingMessageBufferSize() uint64
- func (x *SmartBFTConfig) GetLeaderHeartbeatCount() uint64
- func (x *SmartBFTConfig) GetLeaderHeartbeatTimeout() string
- func (x *SmartBFTConfig) GetLeaderRotation() bool
- func (x *SmartBFTConfig) GetNumOfTicksBehindBeforeSyncing() uint64
- func (x *SmartBFTConfig) GetRequestAutoRemoveTimeout() string
- func (x *SmartBFTConfig) GetRequestBatchMaxBytes() uint64
- func (x *SmartBFTConfig) GetRequestBatchMaxCount() uint64
- func (x *SmartBFTConfig) GetRequestBatchMaxInterval() string
- func (x *SmartBFTConfig) GetRequestComplainTimeout() string
- func (x *SmartBFTConfig) GetRequestForwardTimeout() string
- func (x *SmartBFTConfig) GetRequestMaxBytes() uint64
- func (x *SmartBFTConfig) GetRequestPoolSize() uint64
- func (x *SmartBFTConfig) GetRequestPoolSubmitTimeout() string
- func (x *SmartBFTConfig) GetSpeedUpViewChange() bool
- func (x *SmartBFTConfig) GetSyncOnStart() bool
- func (x *SmartBFTConfig) GetViewChangeResendInterval() string
- func (x *SmartBFTConfig) GetViewChangeTimeout() string
- func (*SmartBFTConfig) ProtoMessage()
- func (x *SmartBFTConfig) ProtoReflect() protoreflect.Message
- func (x *SmartBFTConfig) Reset()
- func (x *SmartBFTConfig) String() string
Constants ¶
This section is empty.
Variables ¶
var File_api_ordererpb_configuration_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type AssemblerNodeConfig ¶
type AssemblerNodeConfig struct {
// the hostname or IP on which the gRPC server will listen
Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
// the port on which the gRPC server will listen
Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
// the certificate used to authenticate with clients
TlsCert []byte `protobuf:"bytes,3,opt,name=tls_cert,json=tlsCert,proto3" json:"tls_cert,omitempty"`
// contains filtered or unexported fields
}
func (*AssemblerNodeConfig) Descriptor
deprecated
func (*AssemblerNodeConfig) Descriptor() ([]byte, []int)
Deprecated: Use AssemblerNodeConfig.ProtoReflect.Descriptor instead.
func (*AssemblerNodeConfig) GetHost ¶
func (x *AssemblerNodeConfig) GetHost() string
func (*AssemblerNodeConfig) GetPort ¶
func (x *AssemblerNodeConfig) GetPort() uint32
func (*AssemblerNodeConfig) GetTlsCert ¶
func (x *AssemblerNodeConfig) GetTlsCert() []byte
func (*AssemblerNodeConfig) ProtoMessage ¶
func (*AssemblerNodeConfig) ProtoMessage()
func (*AssemblerNodeConfig) ProtoReflect ¶
func (x *AssemblerNodeConfig) ProtoReflect() protoreflect.Message
func (*AssemblerNodeConfig) Reset ¶
func (x *AssemblerNodeConfig) Reset()
func (*AssemblerNodeConfig) String ¶
func (x *AssemblerNodeConfig) String() string
type BatchSize ¶
type BatchSize struct {
// MaxMessageCount is the maximum number of messages to permit in a batch. No block will contain more than this number of messages.
MaxMessageCount uint32 `protobuf:"varint,1,opt,name=MaxMessageCount,proto3" json:"MaxMessageCount,omitempty"`
// AbsoluteMaxBytes is the absolute maximum number of bytes allowed for the serialized messages in a batch.
// The maximum block size is this value plus the size of the associated metadata (usually a few KB depending upon the size of the signing identities).
// Any transaction larger than this value will be rejected by ordering.
// It is recommended not to exceed 49 MB, given the default grpc max message size of 100 MB
AbsoluteMaxBytes uint32 `protobuf:"varint,2,opt,name=AbsoluteMaxBytes,proto3" json:"AbsoluteMaxBytes,omitempty"`
// PreferredMaxBytes is the preferred maximum number of bytes allowed for the serialized messages in a batch.
// Roughly, this field may be considered the best effort maximum size of a batch.
// A batch will fill with messages until this size is reached (or the max message count, or batch timeout is exceeded).
// If adding a new message to the batch would cause the batch to exceed the preferred max bytes, then the current batch is closed and written to a block, and a new batch containing the new message is created.
// If a message larger than the preferred max bytes is received, then its batch will contain only that message.
// Because messages may be larger than preferred max bytes (up to AbsoluteMaxBytes), some batches may exceed the preferred max bytes, but will always contain exactly one transaction.
// *** NOTE: This field is not in use. ***
PreferredMaxBytes uint32 `protobuf:"varint,3,opt,name=PreferredMaxBytes,proto3" json:"PreferredMaxBytes,omitempty"`
// contains filtered or unexported fields
}
func (*BatchSize) Descriptor
deprecated
func (*BatchSize) GetAbsoluteMaxBytes ¶
func (*BatchSize) GetMaxMessageCount ¶
func (*BatchSize) GetPreferredMaxBytes ¶
func (*BatchSize) ProtoMessage ¶
func (*BatchSize) ProtoMessage()
func (*BatchSize) ProtoReflect ¶
func (x *BatchSize) ProtoReflect() protoreflect.Message
type BatchTimeouts ¶
type BatchTimeouts struct {
// BatchCreationTimeout is the time a batch can wait before it is created.
BatchCreationTimeout string `protobuf:"bytes,1,opt,name=BatchCreationTimeout,proto3" json:"BatchCreationTimeout,omitempty"`
// FirstStrikeThreshold defines the maximum time a request can remain in the memory pool without being batched.
// After this duration, the request is forwarded to the primary batcher by the secondary batcher.
FirstStrikeThreshold string `protobuf:"bytes,2,opt,name=FirstStrikeThreshold,proto3" json:"FirstStrikeThreshold,omitempty"`
// SecondStrikeThreshold defines the maximum duration that can pass following the FirstStrikeThreshold.
// If this timeout is reached, a complaint is sent to the consensus layer, suspecting primary censorship of the request.
SecondStrikeThreshold string `protobuf:"bytes,3,opt,name=SecondStrikeThreshold,proto3" json:"SecondStrikeThreshold,omitempty"`
// AutoRemoveTimeout defines the maximum time a request can stay in the memory pool after the second threshold is reached.
// If this timeout is reached, the request is removed from the pool.
// NOTE: This timeout's intended purpose is not implemented and is used for GC by the memory pool.
AutoRemoveTimeout string `protobuf:"bytes,4,opt,name=AutoRemoveTimeout,proto3" json:"AutoRemoveTimeout,omitempty"`
// contains filtered or unexported fields
}
func (*BatchTimeouts) Descriptor
deprecated
func (*BatchTimeouts) Descriptor() ([]byte, []int)
Deprecated: Use BatchTimeouts.ProtoReflect.Descriptor instead.
func (*BatchTimeouts) GetAutoRemoveTimeout ¶
func (x *BatchTimeouts) GetAutoRemoveTimeout() string
func (*BatchTimeouts) GetBatchCreationTimeout ¶
func (x *BatchTimeouts) GetBatchCreationTimeout() string
func (*BatchTimeouts) GetFirstStrikeThreshold ¶
func (x *BatchTimeouts) GetFirstStrikeThreshold() string
func (*BatchTimeouts) GetSecondStrikeThreshold ¶
func (x *BatchTimeouts) GetSecondStrikeThreshold() string
func (*BatchTimeouts) ProtoMessage ¶
func (*BatchTimeouts) ProtoMessage()
func (*BatchTimeouts) ProtoReflect ¶
func (x *BatchTimeouts) ProtoReflect() protoreflect.Message
func (*BatchTimeouts) Reset ¶
func (x *BatchTimeouts) Reset()
func (*BatchTimeouts) String ¶
func (x *BatchTimeouts) String() string
type BatcherNodeConfig ¶
type BatcherNodeConfig struct {
// the ID of the shard to which the batcher is associated
ShardID uint32 `protobuf:"varint,1,opt,name=shardID,proto3" json:"shardID,omitempty"`
// the hostname or IP on which the gRPC server will listen
Host string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
// the port on which the gRPC server will listen
Port uint32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
// the signing certificate (that includes the public key) of the batcher used to authenticate signatures on BAS's
SignCert []byte `protobuf:"bytes,4,opt,name=sign_cert,json=signCert,proto3" json:"sign_cert,omitempty"`
// the certificate used to authenticate with clients
TlsCert []byte `protobuf:"bytes,5,opt,name=tls_cert,json=tlsCert,proto3" json:"tls_cert,omitempty"`
// contains filtered or unexported fields
}
func (*BatcherNodeConfig) Descriptor
deprecated
func (*BatcherNodeConfig) Descriptor() ([]byte, []int)
Deprecated: Use BatcherNodeConfig.ProtoReflect.Descriptor instead.
func (*BatcherNodeConfig) GetHost ¶
func (x *BatcherNodeConfig) GetHost() string
func (*BatcherNodeConfig) GetPort ¶
func (x *BatcherNodeConfig) GetPort() uint32
func (*BatcherNodeConfig) GetShardID ¶
func (x *BatcherNodeConfig) GetShardID() uint32
func (*BatcherNodeConfig) GetSignCert ¶
func (x *BatcherNodeConfig) GetSignCert() []byte
func (*BatcherNodeConfig) GetTlsCert ¶
func (x *BatcherNodeConfig) GetTlsCert() []byte
func (*BatcherNodeConfig) ProtoMessage ¶
func (*BatcherNodeConfig) ProtoMessage()
func (*BatcherNodeConfig) ProtoReflect ¶
func (x *BatcherNodeConfig) ProtoReflect() protoreflect.Message
func (*BatcherNodeConfig) Reset ¶
func (x *BatcherNodeConfig) Reset()
func (*BatcherNodeConfig) String ¶
func (x *BatcherNodeConfig) String() string
type BatchingConfig ¶
type BatchingConfig struct {
// BatchTimeouts controls the timeouts of a batch.
BatchTimeouts *BatchTimeouts `protobuf:"bytes,1,opt,name=BatchTimeouts,proto3" json:"BatchTimeouts,omitempty"`
// BatchSize controls the number of messages batched into a block and defines limits on a batch size.
BatchSize *BatchSize `protobuf:"bytes,2,opt,name=BatchSize,proto3" json:"BatchSize,omitempty"`
// RequestMaxBytes is the maximal request size in bytes.
RequestMaxBytes uint64 `protobuf:"varint,3,opt,name=RequestMaxBytes,proto3" json:"RequestMaxBytes,omitempty"`
// contains filtered or unexported fields
}
func (*BatchingConfig) Descriptor
deprecated
func (*BatchingConfig) Descriptor() ([]byte, []int)
Deprecated: Use BatchingConfig.ProtoReflect.Descriptor instead.
func (*BatchingConfig) GetBatchSize ¶
func (x *BatchingConfig) GetBatchSize() *BatchSize
func (*BatchingConfig) GetBatchTimeouts ¶
func (x *BatchingConfig) GetBatchTimeouts() *BatchTimeouts
func (*BatchingConfig) GetRequestMaxBytes ¶
func (x *BatchingConfig) GetRequestMaxBytes() uint64
func (*BatchingConfig) ProtoMessage ¶
func (*BatchingConfig) ProtoMessage()
func (*BatchingConfig) ProtoReflect ¶
func (x *BatchingConfig) ProtoReflect() protoreflect.Message
func (*BatchingConfig) Reset ¶
func (x *BatchingConfig) Reset()
func (*BatchingConfig) String ¶
func (x *BatchingConfig) String() string
type ConsensusConfig ¶
type ConsensusConfig struct {
SmartBFTConfig *SmartBFTConfig `protobuf:"bytes,1,opt,name=SmartBFTConfig,proto3" json:"SmartBFTConfig,omitempty"`
// contains filtered or unexported fields
}
BFT configuration
func (*ConsensusConfig) Descriptor
deprecated
func (*ConsensusConfig) Descriptor() ([]byte, []int)
Deprecated: Use ConsensusConfig.ProtoReflect.Descriptor instead.
func (*ConsensusConfig) GetSmartBFTConfig ¶
func (x *ConsensusConfig) GetSmartBFTConfig() *SmartBFTConfig
func (*ConsensusConfig) ProtoMessage ¶
func (*ConsensusConfig) ProtoMessage()
func (*ConsensusConfig) ProtoReflect ¶
func (x *ConsensusConfig) ProtoReflect() protoreflect.Message
func (*ConsensusConfig) Reset ¶
func (x *ConsensusConfig) Reset()
func (*ConsensusConfig) String ¶
func (x *ConsensusConfig) String() string
type ConsenterNodeConfig ¶
type ConsenterNodeConfig struct {
// the hostname or IP on which the gRPC server will listen
Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
// the port on which the gRPC server will listen
Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
// the signing certificate (that includes the public key) of the consensus used to authenticate signatures on blocks
SignCert []byte `protobuf:"bytes,3,opt,name=sign_cert,json=signCert,proto3" json:"sign_cert,omitempty"`
// the certificate used to authenticate with clients
TlsCert []byte `protobuf:"bytes,4,opt,name=tls_cert,json=tlsCert,proto3" json:"tls_cert,omitempty"`
// contains filtered or unexported fields
}
func (*ConsenterNodeConfig) Descriptor
deprecated
func (*ConsenterNodeConfig) Descriptor() ([]byte, []int)
Deprecated: Use ConsenterNodeConfig.ProtoReflect.Descriptor instead.
func (*ConsenterNodeConfig) GetHost ¶
func (x *ConsenterNodeConfig) GetHost() string
func (*ConsenterNodeConfig) GetPort ¶
func (x *ConsenterNodeConfig) GetPort() uint32
func (*ConsenterNodeConfig) GetSignCert ¶
func (x *ConsenterNodeConfig) GetSignCert() []byte
func (*ConsenterNodeConfig) GetTlsCert ¶
func (x *ConsenterNodeConfig) GetTlsCert() []byte
func (*ConsenterNodeConfig) ProtoMessage ¶
func (*ConsenterNodeConfig) ProtoMessage()
func (*ConsenterNodeConfig) ProtoReflect ¶
func (x *ConsenterNodeConfig) ProtoReflect() protoreflect.Message
func (*ConsenterNodeConfig) Reset ¶
func (x *ConsenterNodeConfig) Reset()
func (*ConsenterNodeConfig) String ¶
func (x *ConsenterNodeConfig) String() string
type PartyConfig ¶
type PartyConfig struct {
// the identity of the party, type unit16, id > 0
PartyID uint32 `protobuf:"varint,1,opt,name=PartyID,proto3" json:"PartyID,omitempty"`
// the certificates of the certificate authorities who generates the party's signing key-pairs
CACerts [][]byte `protobuf:"bytes,2,rep,name=CACerts,proto3" json:"CACerts,omitempty"`
// the certificates of the certificate authorities who generates the party's TLS key-pairs
TLSCACerts [][]byte `protobuf:"bytes,3,rep,name=TLSCACerts,proto3" json:"TLSCACerts,omitempty"`
// the shared configuration of the router
RouterConfig *RouterNodeConfig `protobuf:"bytes,4,opt,name=RouterConfig,proto3" json:"RouterConfig,omitempty"`
// the shared configuration of the batchers
BatchersConfig []*BatcherNodeConfig `protobuf:"bytes,5,rep,name=BatchersConfig,proto3" json:"BatchersConfig,omitempty"`
// the shared configuration of the consenter
ConsenterConfig *ConsenterNodeConfig `protobuf:"bytes,6,opt,name=ConsenterConfig,proto3" json:"ConsenterConfig,omitempty"`
// the shared configuration of the assembler
AssemblerConfig *AssemblerNodeConfig `protobuf:"bytes,7,opt,name=AssemblerConfig,proto3" json:"AssemblerConfig,omitempty"`
// contains filtered or unexported fields
}
PartyConfig carries the identity, certificates and nodes configuration of a party.
func (*PartyConfig) Descriptor
deprecated
func (*PartyConfig) Descriptor() ([]byte, []int)
Deprecated: Use PartyConfig.ProtoReflect.Descriptor instead.
func (*PartyConfig) GetAssemblerConfig ¶
func (x *PartyConfig) GetAssemblerConfig() *AssemblerNodeConfig
func (*PartyConfig) GetBatchersConfig ¶
func (x *PartyConfig) GetBatchersConfig() []*BatcherNodeConfig
func (*PartyConfig) GetCACerts ¶
func (x *PartyConfig) GetCACerts() [][]byte
func (*PartyConfig) GetConsenterConfig ¶
func (x *PartyConfig) GetConsenterConfig() *ConsenterNodeConfig
func (*PartyConfig) GetPartyID ¶
func (x *PartyConfig) GetPartyID() uint32
func (*PartyConfig) GetRouterConfig ¶
func (x *PartyConfig) GetRouterConfig() *RouterNodeConfig
func (*PartyConfig) GetTLSCACerts ¶
func (x *PartyConfig) GetTLSCACerts() [][]byte
func (*PartyConfig) ProtoMessage ¶
func (*PartyConfig) ProtoMessage()
func (*PartyConfig) ProtoReflect ¶
func (x *PartyConfig) ProtoReflect() protoreflect.Message
func (*PartyConfig) Reset ¶
func (x *PartyConfig) Reset()
func (*PartyConfig) String ¶
func (x *PartyConfig) String() string
type RouterNodeConfig ¶
type RouterNodeConfig struct {
// the hostname or IP on which the gRPC server will listen
Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
// the port on which the gRPC server will listen
Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
// the certificate used to authenticate with clients
TlsCert []byte `protobuf:"bytes,3,opt,name=tls_cert,json=tlsCert,proto3" json:"tls_cert,omitempty"`
// contains filtered or unexported fields
}
func (*RouterNodeConfig) Descriptor
deprecated
func (*RouterNodeConfig) Descriptor() ([]byte, []int)
Deprecated: Use RouterNodeConfig.ProtoReflect.Descriptor instead.
func (*RouterNodeConfig) GetHost ¶
func (x *RouterNodeConfig) GetHost() string
func (*RouterNodeConfig) GetPort ¶
func (x *RouterNodeConfig) GetPort() uint32
func (*RouterNodeConfig) GetTlsCert ¶
func (x *RouterNodeConfig) GetTlsCert() []byte
func (*RouterNodeConfig) ProtoMessage ¶
func (*RouterNodeConfig) ProtoMessage()
func (*RouterNodeConfig) ProtoReflect ¶
func (x *RouterNodeConfig) ProtoReflect() protoreflect.Message
func (*RouterNodeConfig) Reset ¶
func (x *RouterNodeConfig) Reset()
func (*RouterNodeConfig) String ¶
func (x *RouterNodeConfig) String() string
type SharedConfig ¶
type SharedConfig struct {
// contains filtered or unexported fields
}
SharedConfig holds the initial configuration that will be used to bootstrap new nodes. This configuration is common to all Arma nodes.
func (*SharedConfig) Descriptor
deprecated
func (*SharedConfig) Descriptor() ([]byte, []int)
Deprecated: Use SharedConfig.ProtoReflect.Descriptor instead.
func (*SharedConfig) GetBatchingConfig ¶
func (x *SharedConfig) GetBatchingConfig() *BatchingConfig
func (*SharedConfig) GetConsensusConfig ¶
func (x *SharedConfig) GetConsensusConfig() *ConsensusConfig
func (*SharedConfig) GetPartiesConfig ¶
func (x *SharedConfig) GetPartiesConfig() []*PartyConfig
func (*SharedConfig) ProtoMessage ¶
func (*SharedConfig) ProtoMessage()
func (*SharedConfig) ProtoReflect ¶
func (x *SharedConfig) ProtoReflect() protoreflect.Message
func (*SharedConfig) Reset ¶
func (x *SharedConfig) Reset()
func (*SharedConfig) String ¶
func (x *SharedConfig) String() string
type SmartBFTConfig ¶
type SmartBFTConfig struct {
// RequestBatchMaxCount is the maximal number of requests in a batch.
// A request batch that reaches this count is proposed immediately.
RequestBatchMaxCount uint64 `protobuf:"varint,1,opt,name=RequestBatchMaxCount,proto3" json:"RequestBatchMaxCount,omitempty"`
// RequestBatchMaxBytes is the maximal total size of requests in a batch, in bytes.
// This is also the maximal size of a request. A request batch that reaches this size is proposed immediately.
RequestBatchMaxBytes uint64 `protobuf:"varint,2,opt,name=RequestBatchMaxBytes,proto3" json:"RequestBatchMaxBytes,omitempty"`
// RequestBatchMaxInterval is the maximal time interval a request batch can wait before it is proposed.
// A request batch is accumulating requests until `RequestBatchMaxInterval` had elapsed from the time the batch was
// first created (i.e. the time the first request was added to it), or until it is of count `RequestBatchMaxCount`,
// or it reaches `RequestBatchMaxBytes`, whichever occurs first.
RequestBatchMaxInterval string `protobuf:"bytes,3,opt,name=RequestBatchMaxInterval,proto3" json:"RequestBatchMaxInterval,omitempty"`
// IncomingMessageBufferSize is the size of the buffer holding incoming messages before they are processed (maximal number of messages).
IncomingMessageBufferSize uint64 `protobuf:"varint,4,opt,name=IncomingMessageBufferSize,proto3" json:"IncomingMessageBufferSize,omitempty"`
// RequestPoolSize is the number of pending requests retained by the node.
// The `RequestPoolSize` is recommended to be at least double (x2) the `RequestBatchMaxCount`.
// This cannot be changed dynamically and the node must be restarted to pick up the change.
RequestPoolSize uint64 `protobuf:"varint,5,opt,name=RequestPoolSize,proto3" json:"RequestPoolSize,omitempty"`
// RequestForwardTimeout is started from the moment a request is submitted, and defines the interval after which a
// request is forwarded to the leader.
RequestForwardTimeout string `protobuf:"bytes,6,opt,name=RequestForwardTimeout,proto3" json:"RequestForwardTimeout,omitempty"`
// RequestComplainTimeout is started when `RequestForwardTimeout` expires, and defines the interval after which the
// node complains about the view leader.
RequestComplainTimeout string `protobuf:"bytes,7,opt,name=RequestComplainTimeout,proto3" json:"RequestComplainTimeout,omitempty"`
// RequestAutoRemoveTimeout is started when `RequestComplainTimeout` expires, and defines the interval after which
// a request is removed (dropped) from the request pool.
RequestAutoRemoveTimeout string `protobuf:"bytes,8,opt,name=RequestAutoRemoveTimeout,proto3" json:"RequestAutoRemoveTimeout,omitempty"`
// ViewChangeResendInterval defines the interval after which the ViewChange message is resent.
ViewChangeResendInterval string `protobuf:"bytes,9,opt,name=ViewChangeResendInterval,proto3" json:"ViewChangeResendInterval,omitempty"`
// ViewChangeTimeout is started when a node first receives a quorum of `ViewChange` messages, and defines the
// interval after which the node will try to initiate a view change with a higher view number.
ViewChangeTimeout string `protobuf:"bytes,10,opt,name=ViewChangeTimeout,proto3" json:"ViewChangeTimeout,omitempty"`
// LeaderHeartbeatTimeout is the interval after which, if nodes do not receive a "sign of life" from the leader,
// they complain about the current leader and try to initiate a view change. A sign of life is either a heartbeat
// or a message from the leader.
LeaderHeartbeatTimeout string `protobuf:"bytes,11,opt,name=LeaderHeartbeatTimeout,proto3" json:"LeaderHeartbeatTimeout,omitempty"`
// LeaderHeartbeatCount is the number of heartbeats per `LeaderHeartbeatTimeout` that the leader should emit.
// The heartbeat-interval is equal to: `LeaderHeartbeatTimeout/LeaderHeartbeatCount`.
LeaderHeartbeatCount uint64 `protobuf:"varint,12,opt,name=LeaderHeartbeatCount,proto3" json:"LeaderHeartbeatCount,omitempty"`
// NumOfTicksBehindBeforeSyncing is the number of follower ticks where the follower is behind the leader
// by one sequence before starting a sync
NumOfTicksBehindBeforeSyncing uint64 `protobuf:"varint,13,opt,name=NumOfTicksBehindBeforeSyncing,proto3" json:"NumOfTicksBehindBeforeSyncing,omitempty"`
// CollectTimeout is the interval after which the node stops listening to `StateTransferResponse` messages,
// stops collecting information about view metadata from remote nodes.
CollectTimeout string `protobuf:"bytes,14,opt,name=CollectTimeout,proto3" json:"CollectTimeout,omitempty"`
// SyncOnStart is a flag indicating whether a sync is required on startup.
SyncOnStart bool `protobuf:"varint,15,opt,name=SyncOnStart,proto3" json:"SyncOnStart,omitempty"`
// SpeedUpViewChange is a flag indicating whether a node waits for only f+1 view change messages to join
// the view change (hence speeds up the view change process), or it waits for a quorum before joining.
// Waiting only for f+1 is considered less safe.
SpeedUpViewChange bool `protobuf:"varint,16,opt,name=SpeedUpViewChange,proto3" json:"SpeedUpViewChange,omitempty"`
// LeaderRotation is a flag indicating whether leader rotation is active.
LeaderRotation bool `protobuf:"varint,17,opt,name=LeaderRotation,proto3" json:"LeaderRotation,omitempty"`
// DecisionsPerLeader is the number of decisions reached by a leader before there is a leader rotation.
DecisionsPerLeader uint64 `protobuf:"varint,18,opt,name=DecisionsPerLeader,proto3" json:"DecisionsPerLeader,omitempty"`
// RequestMaxBytes total allowed size of a single request.
RequestMaxBytes uint64 `protobuf:"varint,19,opt,name=RequestMaxBytes,proto3" json:"RequestMaxBytes,omitempty"`
// RequestPoolSubmitTimeout the total amount of time a client can wait for the submission of a single
// request into the request pool.
RequestPoolSubmitTimeout string `protobuf:"bytes,20,opt,name=RequestPoolSubmitTimeout,proto3" json:"RequestPoolSubmitTimeout,omitempty"`
// contains filtered or unexported fields
}
func (*SmartBFTConfig) Descriptor
deprecated
func (*SmartBFTConfig) Descriptor() ([]byte, []int)
Deprecated: Use SmartBFTConfig.ProtoReflect.Descriptor instead.
func (*SmartBFTConfig) GetCollectTimeout ¶
func (x *SmartBFTConfig) GetCollectTimeout() string
func (*SmartBFTConfig) GetDecisionsPerLeader ¶
func (x *SmartBFTConfig) GetDecisionsPerLeader() uint64
func (*SmartBFTConfig) GetIncomingMessageBufferSize ¶
func (x *SmartBFTConfig) GetIncomingMessageBufferSize() uint64
func (*SmartBFTConfig) GetLeaderHeartbeatCount ¶
func (x *SmartBFTConfig) GetLeaderHeartbeatCount() uint64
func (*SmartBFTConfig) GetLeaderHeartbeatTimeout ¶
func (x *SmartBFTConfig) GetLeaderHeartbeatTimeout() string
func (*SmartBFTConfig) GetLeaderRotation ¶
func (x *SmartBFTConfig) GetLeaderRotation() bool
func (*SmartBFTConfig) GetNumOfTicksBehindBeforeSyncing ¶
func (x *SmartBFTConfig) GetNumOfTicksBehindBeforeSyncing() uint64
func (*SmartBFTConfig) GetRequestAutoRemoveTimeout ¶
func (x *SmartBFTConfig) GetRequestAutoRemoveTimeout() string
func (*SmartBFTConfig) GetRequestBatchMaxBytes ¶
func (x *SmartBFTConfig) GetRequestBatchMaxBytes() uint64
func (*SmartBFTConfig) GetRequestBatchMaxCount ¶
func (x *SmartBFTConfig) GetRequestBatchMaxCount() uint64
func (*SmartBFTConfig) GetRequestBatchMaxInterval ¶
func (x *SmartBFTConfig) GetRequestBatchMaxInterval() string
func (*SmartBFTConfig) GetRequestComplainTimeout ¶
func (x *SmartBFTConfig) GetRequestComplainTimeout() string
func (*SmartBFTConfig) GetRequestForwardTimeout ¶
func (x *SmartBFTConfig) GetRequestForwardTimeout() string
func (*SmartBFTConfig) GetRequestMaxBytes ¶
func (x *SmartBFTConfig) GetRequestMaxBytes() uint64
func (*SmartBFTConfig) GetRequestPoolSize ¶
func (x *SmartBFTConfig) GetRequestPoolSize() uint64
func (*SmartBFTConfig) GetRequestPoolSubmitTimeout ¶
func (x *SmartBFTConfig) GetRequestPoolSubmitTimeout() string
func (*SmartBFTConfig) GetSpeedUpViewChange ¶
func (x *SmartBFTConfig) GetSpeedUpViewChange() bool
func (*SmartBFTConfig) GetSyncOnStart ¶
func (x *SmartBFTConfig) GetSyncOnStart() bool
func (*SmartBFTConfig) GetViewChangeResendInterval ¶
func (x *SmartBFTConfig) GetViewChangeResendInterval() string
func (*SmartBFTConfig) GetViewChangeTimeout ¶
func (x *SmartBFTConfig) GetViewChangeTimeout() string
func (*SmartBFTConfig) ProtoMessage ¶
func (*SmartBFTConfig) ProtoMessage()
func (*SmartBFTConfig) ProtoReflect ¶
func (x *SmartBFTConfig) ProtoReflect() protoreflect.Message
func (*SmartBFTConfig) Reset ¶
func (x *SmartBFTConfig) Reset()
func (*SmartBFTConfig) String ¶
func (x *SmartBFTConfig) String() string