Documentation
¶
Index ¶
- Variables
- type ClientOpts
- func (*ClientOpts) Descriptor() ([]byte, []int)deprecated
- func (x *ClientOpts) GetConnectTimeout() *durationpb.Duration
- func (x *ClientOpts) GetID() uint32
- func (x *ClientOpts) GetMaxConcurrent() uint32
- func (x *ClientOpts) GetPayloadSize() uint32
- func (x *ClientOpts) GetRateLimit() float64
- func (x *ClientOpts) GetRateStep() float64
- func (x *ClientOpts) GetRateStepInterval() *durationpb.Duration
- func (x *ClientOpts) GetTimeout() *durationpb.Duration
- func (x *ClientOpts) GetUseTLS() bool
- func (*ClientOpts) ProtoMessage()
- func (x *ClientOpts) ProtoReflect() protoreflect.Message
- func (x *ClientOpts) Reset()
- func (x *ClientOpts) String() string
- type CreateReplicaRequest
- func (*CreateReplicaRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateReplicaRequest) GetReplicas() map[uint32]*ReplicaOpts
- func (*CreateReplicaRequest) ProtoMessage()
- func (x *CreateReplicaRequest) ProtoReflect() protoreflect.Message
- func (x *CreateReplicaRequest) Reset()
- func (x *CreateReplicaRequest) String() string
- type CreateReplicaResponse
- func (*CreateReplicaResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateReplicaResponse) GetReplicas() map[uint32]*ReplicaInfo
- func (*CreateReplicaResponse) ProtoMessage()
- func (x *CreateReplicaResponse) ProtoReflect() protoreflect.Message
- func (x *CreateReplicaResponse) Reset()
- func (x *CreateReplicaResponse) String() string
- type QuitRequest
- type ReplicaConfiguration
- func (*ReplicaConfiguration) Descriptor() ([]byte, []int)deprecated
- func (x *ReplicaConfiguration) GetReplicas() map[uint32]*ReplicaInfo
- func (*ReplicaConfiguration) ProtoMessage()
- func (x *ReplicaConfiguration) ProtoReflect() protoreflect.Message
- func (x *ReplicaConfiguration) Reset()
- func (x *ReplicaConfiguration) String() string
- type ReplicaInfo
- func (*ReplicaInfo) Descriptor() ([]byte, []int)deprecated
- func (x *ReplicaInfo) GetAddress() string
- func (x *ReplicaInfo) GetClientPort() uint32
- func (x *ReplicaInfo) GetID() uint32
- func (x *ReplicaInfo) GetPublicKey() []byte
- func (x *ReplicaInfo) GetReplicaPort() uint32
- func (*ReplicaInfo) ProtoMessage()
- func (x *ReplicaInfo) ProtoReflect() protoreflect.Message
- func (x *ReplicaInfo) Reset()
- func (x *ReplicaInfo) String() string
- type ReplicaOpts
- func (*ReplicaOpts) Descriptor() ([]byte, []int)deprecated
- func (x *ReplicaOpts) GetAggregationTime() bool
- func (x *ReplicaOpts) GetBatchSize() uint32
- func (x *ReplicaOpts) GetBranchFactor() uint32
- func (x *ReplicaOpts) GetByzantineStrategy() string
- func (x *ReplicaOpts) GetCertificate() []byte
- func (x *ReplicaOpts) GetCertificateAuthority() []byte
- func (x *ReplicaOpts) GetCertificateKey() []byte
- func (x *ReplicaOpts) GetConnectTimeout() *durationpb.Duration
- func (x *ReplicaOpts) GetConsensus() string
- func (x *ReplicaOpts) GetCrypto() string
- func (x *ReplicaOpts) GetDelayType() isReplicaOpts_DelayType
- func (x *ReplicaOpts) GetID() uint32
- func (x *ReplicaOpts) GetInitialTimeout() *durationpb.Duration
- func (x *ReplicaOpts) GetLeaderRotation() string
- func (x *ReplicaOpts) GetLocations() []string
- func (x *ReplicaOpts) GetMaxTimeout() *durationpb.Duration
- func (x *ReplicaOpts) GetModules() []string
- func (x *ReplicaOpts) GetPrivateKey() []byte
- func (x *ReplicaOpts) GetPublicKey() []byte
- func (x *ReplicaOpts) GetSharedSeed() int64
- func (x *ReplicaOpts) GetTimeoutMultiplier() float32
- func (x *ReplicaOpts) GetTimeoutSamples() uint32
- func (x *ReplicaOpts) GetTreeDelta() *durationpb.Duration
- func (x *ReplicaOpts) GetTreeHeightTime() bool
- func (x *ReplicaOpts) GetTreePositions() []uint32
- func (x *ReplicaOpts) GetUseTLS() bool
- func (x *ReplicaOpts) HotstuffID() hotstuff.ID
- func (x *ReplicaOpts) New(replicaID hotstuff.ID, locations []string) *ReplicaOpts
- func (*ReplicaOpts) ProtoMessage()
- func (x *ReplicaOpts) ProtoReflect() protoreflect.Message
- func (x *ReplicaOpts) Reset()
- func (x *ReplicaOpts) SetAggregationWaitTime()
- func (x *ReplicaOpts) SetByzantineStrategy(strategy string)
- func (x *ReplicaOpts) SetReplicaCertificates(host string, ca *x509.Certificate, caKey *ecdsa.PrivateKey) error
- func (x *ReplicaOpts) SetTreeHeightWaitTime()
- func (x *ReplicaOpts) SetTreeOptions(branchFactor uint32, positions []uint32, treeDelta time.Duration)
- func (x *ReplicaOpts) String() string
- func (x *ReplicaOpts) StringID() string
- func (x *ReplicaOpts) StringLocations() string
- func (x *ReplicaOpts) TreeDeltaDuration() time.Duration
- func (x *ReplicaOpts) TreePositionIDs() []hotstuff.ID
- type ReplicaOpts_AggregationTime
- type ReplicaOpts_TreeHeightTime
- type StartClientRequest
- func (*StartClientRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartClientRequest) GetCertificateAuthority() []byte
- func (x *StartClientRequest) GetClients() map[uint32]*ClientOpts
- func (x *StartClientRequest) GetConfiguration() map[uint32]*ReplicaInfo
- func (*StartClientRequest) ProtoMessage()
- func (x *StartClientRequest) ProtoReflect() protoreflect.Message
- func (x *StartClientRequest) Reset()
- func (x *StartClientRequest) String() string
- type StartClientResponse
- type StartReplicaRequest
- func (*StartReplicaRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartReplicaRequest) GetConfiguration() map[uint32]*ReplicaInfo
- func (x *StartReplicaRequest) GetIDs() []uint32
- func (*StartReplicaRequest) ProtoMessage()
- func (x *StartReplicaRequest) ProtoReflect() protoreflect.Message
- func (x *StartReplicaRequest) Reset()
- func (x *StartReplicaRequest) String() string
- type StartReplicaResponse
- type StopClientRequest
- type StopClientResponse
- type StopReplicaRequest
- func (*StopReplicaRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StopReplicaRequest) GetIDs() []uint32
- func (*StopReplicaRequest) ProtoMessage()
- func (x *StopReplicaRequest) ProtoReflect() protoreflect.Message
- func (x *StopReplicaRequest) Reset()
- func (x *StopReplicaRequest) String() string
- type StopReplicaResponse
- func (*StopReplicaResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StopReplicaResponse) GetCounts() map[uint32]uint32
- func (x *StopReplicaResponse) GetHashes() map[uint32][]byte
- func (*StopReplicaResponse) ProtoMessage()
- func (x *StopReplicaResponse) ProtoReflect() protoreflect.Message
- func (x *StopReplicaResponse) Reset()
- func (x *StopReplicaResponse) String() string
Constants ¶
This section is empty.
Variables ¶
var File_internal_proto_orchestrationpb_orchestration_proto protoreflect.FileDescriptor
Functions ¶
This section is empty.
Types ¶
type ClientOpts ¶
type ClientOpts struct {
// The client's ID.
ID uint32 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
// Determines whether TLS should be used.
UseTLS bool `protobuf:"varint,4,opt,name=UseTLS,proto3" json:"UseTLS,omitempty"`
// The maximum number of concurrent requests.
MaxConcurrent uint32 `protobuf:"varint,8,opt,name=MaxConcurrent,proto3" json:"MaxConcurrent,omitempty"`
// The size in bytes of each command.
PayloadSize uint32 `protobuf:"varint,9,opt,name=PayloadSize,proto3" json:"PayloadSize,omitempty"`
// The timeout of the initial connection.
ConnectTimeout *durationpb.Duration `protobuf:"bytes,10,opt,name=ConnectTimeout,proto3" json:"ConnectTimeout,omitempty"`
// The limit on how many commands can be sent per second.
RateLimit float64 `protobuf:"fixed64,11,opt,name=RateLimit,proto3" json:"RateLimit,omitempty"`
// The amount of commands per second to increase the rate limit by.
RateStep float64 `protobuf:"fixed64,12,opt,name=RateStep,proto3" json:"RateStep,omitempty"`
// How often to increase the rate limit.
RateStepInterval *durationpb.Duration `protobuf:"bytes,13,opt,name=RateStepInterval,proto3" json:"RateStepInterval,omitempty"`
// The timeout for a command.
Timeout *durationpb.Duration `protobuf:"bytes,14,opt,name=Timeout,proto3" json:"Timeout,omitempty"`
// contains filtered or unexported fields
}
func (*ClientOpts) Descriptor
deprecated
func (*ClientOpts) Descriptor() ([]byte, []int)
Deprecated: Use ClientOpts.ProtoReflect.Descriptor instead.
func (*ClientOpts) GetConnectTimeout ¶
func (x *ClientOpts) GetConnectTimeout() *durationpb.Duration
func (*ClientOpts) GetID ¶
func (x *ClientOpts) GetID() uint32
func (*ClientOpts) GetMaxConcurrent ¶
func (x *ClientOpts) GetMaxConcurrent() uint32
func (*ClientOpts) GetPayloadSize ¶
func (x *ClientOpts) GetPayloadSize() uint32
func (*ClientOpts) GetRateLimit ¶
func (x *ClientOpts) GetRateLimit() float64
func (*ClientOpts) GetRateStep ¶
func (x *ClientOpts) GetRateStep() float64
func (*ClientOpts) GetRateStepInterval ¶
func (x *ClientOpts) GetRateStepInterval() *durationpb.Duration
func (*ClientOpts) GetTimeout ¶ added in v0.5.0
func (x *ClientOpts) GetTimeout() *durationpb.Duration
func (*ClientOpts) GetUseTLS ¶
func (x *ClientOpts) GetUseTLS() bool
func (*ClientOpts) ProtoMessage ¶
func (*ClientOpts) ProtoMessage()
func (*ClientOpts) ProtoReflect ¶
func (x *ClientOpts) ProtoReflect() protoreflect.Message
func (*ClientOpts) Reset ¶
func (x *ClientOpts) Reset()
func (*ClientOpts) String ¶
func (x *ClientOpts) String() string
type CreateReplicaRequest ¶
type CreateReplicaRequest struct {
Replicas map[uint32]*ReplicaOpts `` /* 144-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*CreateReplicaRequest) Descriptor
deprecated
func (*CreateReplicaRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateReplicaRequest.ProtoReflect.Descriptor instead.
func (*CreateReplicaRequest) GetReplicas ¶
func (x *CreateReplicaRequest) GetReplicas() map[uint32]*ReplicaOpts
func (*CreateReplicaRequest) ProtoMessage ¶
func (*CreateReplicaRequest) ProtoMessage()
func (*CreateReplicaRequest) ProtoReflect ¶
func (x *CreateReplicaRequest) ProtoReflect() protoreflect.Message
func (*CreateReplicaRequest) Reset ¶
func (x *CreateReplicaRequest) Reset()
func (*CreateReplicaRequest) String ¶
func (x *CreateReplicaRequest) String() string
type CreateReplicaResponse ¶
type CreateReplicaResponse struct {
Replicas map[uint32]*ReplicaInfo `` /* 144-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*CreateReplicaResponse) Descriptor
deprecated
func (*CreateReplicaResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateReplicaResponse.ProtoReflect.Descriptor instead.
func (*CreateReplicaResponse) GetReplicas ¶
func (x *CreateReplicaResponse) GetReplicas() map[uint32]*ReplicaInfo
func (*CreateReplicaResponse) ProtoMessage ¶
func (*CreateReplicaResponse) ProtoMessage()
func (*CreateReplicaResponse) ProtoReflect ¶
func (x *CreateReplicaResponse) ProtoReflect() protoreflect.Message
func (*CreateReplicaResponse) Reset ¶
func (x *CreateReplicaResponse) Reset()
func (*CreateReplicaResponse) String ¶
func (x *CreateReplicaResponse) String() string
type QuitRequest ¶
type QuitRequest struct {
// contains filtered or unexported fields
}
func (*QuitRequest) Descriptor
deprecated
func (*QuitRequest) Descriptor() ([]byte, []int)
Deprecated: Use QuitRequest.ProtoReflect.Descriptor instead.
func (*QuitRequest) ProtoMessage ¶
func (*QuitRequest) ProtoMessage()
func (*QuitRequest) ProtoReflect ¶
func (x *QuitRequest) ProtoReflect() protoreflect.Message
func (*QuitRequest) Reset ¶
func (x *QuitRequest) Reset()
func (*QuitRequest) String ¶
func (x *QuitRequest) String() string
type ReplicaConfiguration ¶
type ReplicaConfiguration struct {
Replicas map[uint32]*ReplicaInfo `` /* 144-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*ReplicaConfiguration) Descriptor
deprecated
func (*ReplicaConfiguration) Descriptor() ([]byte, []int)
Deprecated: Use ReplicaConfiguration.ProtoReflect.Descriptor instead.
func (*ReplicaConfiguration) GetReplicas ¶
func (x *ReplicaConfiguration) GetReplicas() map[uint32]*ReplicaInfo
func (*ReplicaConfiguration) ProtoMessage ¶
func (*ReplicaConfiguration) ProtoMessage()
func (*ReplicaConfiguration) ProtoReflect ¶
func (x *ReplicaConfiguration) ProtoReflect() protoreflect.Message
func (*ReplicaConfiguration) Reset ¶
func (x *ReplicaConfiguration) Reset()
func (*ReplicaConfiguration) String ¶
func (x *ReplicaConfiguration) String() string
type ReplicaInfo ¶
type ReplicaInfo struct {
// The ID of the replica.
ID uint32 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
// The IP address of the replica.
Address string `protobuf:"bytes,2,opt,name=Address,proto3" json:"Address,omitempty"`
// The public key of the replica.
PublicKey []byte `protobuf:"bytes,3,opt,name=PublicKey,proto3" json:"PublicKey,omitempty"`
// The port that other replicas should connect to.
ReplicaPort uint32 `protobuf:"varint,4,opt,name=ReplicaPort,proto3" json:"ReplicaPort,omitempty"`
// The port that clients should connect to.
ClientPort uint32 `protobuf:"varint,5,opt,name=ClientPort,proto3" json:"ClientPort,omitempty"`
// contains filtered or unexported fields
}
ReplicaInfo is the information that the replicas need about each other.
func (*ReplicaInfo) Descriptor
deprecated
func (*ReplicaInfo) Descriptor() ([]byte, []int)
Deprecated: Use ReplicaInfo.ProtoReflect.Descriptor instead.
func (*ReplicaInfo) GetAddress ¶
func (x *ReplicaInfo) GetAddress() string
func (*ReplicaInfo) GetClientPort ¶
func (x *ReplicaInfo) GetClientPort() uint32
func (*ReplicaInfo) GetID ¶
func (x *ReplicaInfo) GetID() uint32
func (*ReplicaInfo) GetPublicKey ¶
func (x *ReplicaInfo) GetPublicKey() []byte
func (*ReplicaInfo) GetReplicaPort ¶
func (x *ReplicaInfo) GetReplicaPort() uint32
func (*ReplicaInfo) ProtoMessage ¶
func (*ReplicaInfo) ProtoMessage()
func (*ReplicaInfo) ProtoReflect ¶
func (x *ReplicaInfo) ProtoReflect() protoreflect.Message
func (*ReplicaInfo) Reset ¶
func (x *ReplicaInfo) Reset()
func (*ReplicaInfo) String ¶
func (x *ReplicaInfo) String() string
type ReplicaOpts ¶
type ReplicaOpts struct {
// The replica's ID.
ID uint32 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"`
// The replica's private key.
PrivateKey []byte `protobuf:"bytes,3,opt,name=PrivateKey,proto3" json:"PrivateKey,omitempty"`
// The replica's public key.
PublicKey []byte `protobuf:"bytes,16,opt,name=PublicKey,proto3" json:"PublicKey,omitempty"`
// Determines whether TLS should be used.
UseTLS bool `protobuf:"varint,4,opt,name=UseTLS,proto3" json:"UseTLS,omitempty"`
// The replica's TLS certificate.
Certificate []byte `protobuf:"bytes,5,opt,name=Certificate,proto3" json:"Certificate,omitempty"`
// The private key of the TLS certificate.
CertificateKey []byte `protobuf:"bytes,6,opt,name=CertificateKey,proto3" json:"CertificateKey,omitempty"`
// The certificate authority that created the TLS certificates.
CertificateAuthority []byte `protobuf:"bytes,7,opt,name=CertificateAuthority,proto3" json:"CertificateAuthority,omitempty"`
// The name of the crypto implementation to use.
Crypto string `protobuf:"bytes,8,opt,name=Crypto,proto3" json:"Crypto,omitempty"`
// The name of the consensus implementation to use.
Consensus string `protobuf:"bytes,9,opt,name=Consensus,proto3" json:"Consensus,omitempty"`
// The name of the leader rotation algorithm to use.
LeaderRotation string `protobuf:"bytes,10,opt,name=LeaderRotation,proto3" json:"LeaderRotation,omitempty"`
// The number of client commands that should be batched together.
BatchSize uint32 `protobuf:"varint,11,opt,name=BatchSize,proto3" json:"BatchSize,omitempty"`
// The timeout of the initial connection setup.
ConnectTimeout *durationpb.Duration `protobuf:"bytes,17,opt,name=ConnectTimeout,proto3" json:"ConnectTimeout,omitempty"`
// The initial view duration.
InitialTimeout *durationpb.Duration `protobuf:"bytes,12,opt,name=InitialTimeout,proto3" json:"InitialTimeout,omitempty"`
// The maximum view timeout.
MaxTimeout *durationpb.Duration `protobuf:"bytes,19,opt,name=MaxTimeout,proto3" json:"MaxTimeout,omitempty"`
// The number of samples used to calculate view duration.
TimeoutSamples uint32 `protobuf:"varint,13,opt,name=TimeoutSamples,proto3" json:"TimeoutSamples,omitempty"`
// The number that the old view duration should be multiplied by when a new
// timeout happens.
TimeoutMultiplier float32 `protobuf:"fixed32,14,opt,name=TimeoutMultiplier,proto3" json:"TimeoutMultiplier,omitempty"`
// The byzantine strategy to use. If empty, the replica will act normally.
ByzantineStrategy string `protobuf:"bytes,18,opt,name=ByzantineStrategy,proto3" json:"ByzantineStrategy,omitempty"`
SharedSeed int64 `protobuf:"varint,20,opt,name=SharedSeed,proto3" json:"SharedSeed,omitempty"`
// A list of modules to load.
Modules []string `protobuf:"bytes,21,rep,name=Modules,proto3" json:"Modules,omitempty"`
// Replica locations indexed by replica ID.
Locations []string `protobuf:"bytes,22,rep,name=Locations,proto3" json:"Locations,omitempty"`
// Tree positions of the replica.
TreePositions []uint32 `protobuf:"varint,23,rep,packed,name=TreePositions,proto3" json:"TreePositions,omitempty"`
// Branch Factor in tree communication
BranchFactor uint32 `protobuf:"varint,24,opt,name=BranchFactor,proto3" json:"BranchFactor,omitempty"`
// Tree Duration in tree communication
TreeDelta *durationpb.Duration `protobuf:"bytes,25,opt,name=TreeDelta,proto3" json:"TreeDelta,omitempty"`
// DelayType is the type of delay to use for the wait time.
//
// Types that are valid to be assigned to DelayType:
//
// *ReplicaOpts_AggregationTime
// *ReplicaOpts_TreeHeightTime
DelayType isReplicaOpts_DelayType `protobuf_oneof:"DelayType"`
// contains filtered or unexported fields
}
ReplicaOpts contains the configuration options for a replica.
func (*ReplicaOpts) Descriptor
deprecated
func (*ReplicaOpts) Descriptor() ([]byte, []int)
Deprecated: Use ReplicaOpts.ProtoReflect.Descriptor instead.
func (*ReplicaOpts) GetAggregationTime ¶ added in v0.5.0
func (x *ReplicaOpts) GetAggregationTime() bool
func (*ReplicaOpts) GetBatchSize ¶
func (x *ReplicaOpts) GetBatchSize() uint32
func (*ReplicaOpts) GetBranchFactor ¶ added in v0.5.0
func (x *ReplicaOpts) GetBranchFactor() uint32
func (*ReplicaOpts) GetByzantineStrategy ¶
func (x *ReplicaOpts) GetByzantineStrategy() string
func (*ReplicaOpts) GetCertificate ¶
func (x *ReplicaOpts) GetCertificate() []byte
func (*ReplicaOpts) GetCertificateAuthority ¶
func (x *ReplicaOpts) GetCertificateAuthority() []byte
func (*ReplicaOpts) GetCertificateKey ¶
func (x *ReplicaOpts) GetCertificateKey() []byte
func (*ReplicaOpts) GetConnectTimeout ¶
func (x *ReplicaOpts) GetConnectTimeout() *durationpb.Duration
func (*ReplicaOpts) GetConsensus ¶
func (x *ReplicaOpts) GetConsensus() string
func (*ReplicaOpts) GetCrypto ¶
func (x *ReplicaOpts) GetCrypto() string
func (*ReplicaOpts) GetDelayType ¶ added in v0.5.0
func (x *ReplicaOpts) GetDelayType() isReplicaOpts_DelayType
func (*ReplicaOpts) GetID ¶
func (x *ReplicaOpts) GetID() uint32
func (*ReplicaOpts) GetInitialTimeout ¶
func (x *ReplicaOpts) GetInitialTimeout() *durationpb.Duration
func (*ReplicaOpts) GetLeaderRotation ¶
func (x *ReplicaOpts) GetLeaderRotation() string
func (*ReplicaOpts) GetLocations ¶ added in v0.5.0
func (x *ReplicaOpts) GetLocations() []string
func (*ReplicaOpts) GetMaxTimeout ¶
func (x *ReplicaOpts) GetMaxTimeout() *durationpb.Duration
func (*ReplicaOpts) GetModules ¶ added in v0.5.0
func (x *ReplicaOpts) GetModules() []string
func (*ReplicaOpts) GetPrivateKey ¶
func (x *ReplicaOpts) GetPrivateKey() []byte
func (*ReplicaOpts) GetPublicKey ¶
func (x *ReplicaOpts) GetPublicKey() []byte
func (*ReplicaOpts) GetSharedSeed ¶ added in v0.5.0
func (x *ReplicaOpts) GetSharedSeed() int64
func (*ReplicaOpts) GetTimeoutMultiplier ¶
func (x *ReplicaOpts) GetTimeoutMultiplier() float32
func (*ReplicaOpts) GetTimeoutSamples ¶
func (x *ReplicaOpts) GetTimeoutSamples() uint32
func (*ReplicaOpts) GetTreeDelta ¶ added in v0.5.0
func (x *ReplicaOpts) GetTreeDelta() *durationpb.Duration
func (*ReplicaOpts) GetTreeHeightTime ¶ added in v0.5.0
func (x *ReplicaOpts) GetTreeHeightTime() bool
func (*ReplicaOpts) GetTreePositions ¶ added in v0.5.0
func (x *ReplicaOpts) GetTreePositions() []uint32
func (*ReplicaOpts) GetUseTLS ¶
func (x *ReplicaOpts) GetUseTLS() bool
func (*ReplicaOpts) HotstuffID ¶ added in v0.5.0
func (x *ReplicaOpts) HotstuffID() hotstuff.ID
func (*ReplicaOpts) New ¶ added in v0.5.0
func (x *ReplicaOpts) New(replicaID hotstuff.ID, locations []string) *ReplicaOpts
New creates a new ReplicaOpts with the given replicaID and locations. The locations are shared between all replicas, and are indexed by the replicaID.
func (*ReplicaOpts) ProtoMessage ¶
func (*ReplicaOpts) ProtoMessage()
func (*ReplicaOpts) ProtoReflect ¶
func (x *ReplicaOpts) ProtoReflect() protoreflect.Message
func (*ReplicaOpts) Reset ¶
func (x *ReplicaOpts) Reset()
func (*ReplicaOpts) SetAggregationWaitTime ¶ added in v0.5.0
func (x *ReplicaOpts) SetAggregationWaitTime()
func (*ReplicaOpts) SetByzantineStrategy ¶ added in v0.5.0
func (x *ReplicaOpts) SetByzantineStrategy(strategy string)
func (*ReplicaOpts) SetReplicaCertificates ¶ added in v0.5.0
func (x *ReplicaOpts) SetReplicaCertificates(host string, ca *x509.Certificate, caKey *ecdsa.PrivateKey) error
func (*ReplicaOpts) SetTreeHeightWaitTime ¶ added in v0.5.0
func (x *ReplicaOpts) SetTreeHeightWaitTime()
func (*ReplicaOpts) SetTreeOptions ¶ added in v0.5.0
func (x *ReplicaOpts) SetTreeOptions(branchFactor uint32, positions []uint32, treeDelta time.Duration)
func (*ReplicaOpts) String ¶
func (x *ReplicaOpts) String() string
func (*ReplicaOpts) StringID ¶ added in v0.5.0
func (x *ReplicaOpts) StringID() string
func (*ReplicaOpts) StringLocations ¶ added in v0.5.0
func (x *ReplicaOpts) StringLocations() string
func (*ReplicaOpts) TreeDeltaDuration ¶ added in v0.5.0
func (x *ReplicaOpts) TreeDeltaDuration() time.Duration
TreeDeltaDuration returns the tree delta as a time.Duration.
func (*ReplicaOpts) TreePositionIDs ¶ added in v0.5.0
func (x *ReplicaOpts) TreePositionIDs() []hotstuff.ID
TreePositionIDs returns the tree positions as a slice of hotstuff.ID.
type ReplicaOpts_AggregationTime ¶ added in v0.5.0
type ReplicaOpts_AggregationTime struct {
// AggregationTime computes the wait time based on the latency of links in the tree.
AggregationTime bool `protobuf:"varint,26,opt,name=AggregationTime,proto3,oneof"`
}
type ReplicaOpts_TreeHeightTime ¶ added in v0.5.0
type ReplicaOpts_TreeHeightTime struct {
// TreeHeightTime computes the wait time only based on the height of the tree.
TreeHeightTime bool `protobuf:"varint,27,opt,name=TreeHeightTime,proto3,oneof"`
}
type StartClientRequest ¶
type StartClientRequest struct {
// The clients to create.
Clients map[uint32]*ClientOpts `` /* 142-byte string literal not displayed */
// The certificate authority that created the TLS certificates.
CertificateAuthority []byte `protobuf:"bytes,7,opt,name=CertificateAuthority,proto3" json:"CertificateAuthority,omitempty"`
// The replicas to connect to.
Configuration map[uint32]*ReplicaInfo `` /* 155-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*StartClientRequest) Descriptor
deprecated
func (*StartClientRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartClientRequest.ProtoReflect.Descriptor instead.
func (*StartClientRequest) GetCertificateAuthority ¶
func (x *StartClientRequest) GetCertificateAuthority() []byte
func (*StartClientRequest) GetClients ¶
func (x *StartClientRequest) GetClients() map[uint32]*ClientOpts
func (*StartClientRequest) GetConfiguration ¶
func (x *StartClientRequest) GetConfiguration() map[uint32]*ReplicaInfo
func (*StartClientRequest) ProtoMessage ¶
func (*StartClientRequest) ProtoMessage()
func (*StartClientRequest) ProtoReflect ¶
func (x *StartClientRequest) ProtoReflect() protoreflect.Message
func (*StartClientRequest) Reset ¶
func (x *StartClientRequest) Reset()
func (*StartClientRequest) String ¶
func (x *StartClientRequest) String() string
type StartClientResponse ¶
type StartClientResponse struct {
// contains filtered or unexported fields
}
func (*StartClientResponse) Descriptor
deprecated
func (*StartClientResponse) Descriptor() ([]byte, []int)
Deprecated: Use StartClientResponse.ProtoReflect.Descriptor instead.
func (*StartClientResponse) ProtoMessage ¶
func (*StartClientResponse) ProtoMessage()
func (*StartClientResponse) ProtoReflect ¶
func (x *StartClientResponse) ProtoReflect() protoreflect.Message
func (*StartClientResponse) Reset ¶
func (x *StartClientResponse) Reset()
func (*StartClientResponse) String ¶
func (x *StartClientResponse) String() string
type StartReplicaRequest ¶
type StartReplicaRequest struct {
// The replica IDs that should be started.
IDs []uint32 `protobuf:"varint,1,rep,packed,name=IDs,proto3" json:"IDs,omitempty"`
// The configuration of replicas to connect to.
Configuration map[uint32]*ReplicaInfo `` /* 154-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*StartReplicaRequest) Descriptor
deprecated
func (*StartReplicaRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartReplicaRequest.ProtoReflect.Descriptor instead.
func (*StartReplicaRequest) GetConfiguration ¶
func (x *StartReplicaRequest) GetConfiguration() map[uint32]*ReplicaInfo
func (*StartReplicaRequest) GetIDs ¶
func (x *StartReplicaRequest) GetIDs() []uint32
func (*StartReplicaRequest) ProtoMessage ¶
func (*StartReplicaRequest) ProtoMessage()
func (*StartReplicaRequest) ProtoReflect ¶
func (x *StartReplicaRequest) ProtoReflect() protoreflect.Message
func (*StartReplicaRequest) Reset ¶
func (x *StartReplicaRequest) Reset()
func (*StartReplicaRequest) String ¶
func (x *StartReplicaRequest) String() string
type StartReplicaResponse ¶
type StartReplicaResponse struct {
// contains filtered or unexported fields
}
func (*StartReplicaResponse) Descriptor
deprecated
func (*StartReplicaResponse) Descriptor() ([]byte, []int)
Deprecated: Use StartReplicaResponse.ProtoReflect.Descriptor instead.
func (*StartReplicaResponse) ProtoMessage ¶
func (*StartReplicaResponse) ProtoMessage()
func (*StartReplicaResponse) ProtoReflect ¶
func (x *StartReplicaResponse) ProtoReflect() protoreflect.Message
func (*StartReplicaResponse) Reset ¶
func (x *StartReplicaResponse) Reset()
func (*StartReplicaResponse) String ¶
func (x *StartReplicaResponse) String() string
type StopClientRequest ¶
type StopClientRequest struct {
IDs []uint32 `protobuf:"varint,1,rep,packed,name=IDs,proto3" json:"IDs,omitempty"`
// contains filtered or unexported fields
}
func (*StopClientRequest) Descriptor
deprecated
func (*StopClientRequest) Descriptor() ([]byte, []int)
Deprecated: Use StopClientRequest.ProtoReflect.Descriptor instead.
func (*StopClientRequest) GetIDs ¶
func (x *StopClientRequest) GetIDs() []uint32
func (*StopClientRequest) ProtoMessage ¶
func (*StopClientRequest) ProtoMessage()
func (*StopClientRequest) ProtoReflect ¶
func (x *StopClientRequest) ProtoReflect() protoreflect.Message
func (*StopClientRequest) Reset ¶
func (x *StopClientRequest) Reset()
func (*StopClientRequest) String ¶
func (x *StopClientRequest) String() string
type StopClientResponse ¶
type StopClientResponse struct {
// contains filtered or unexported fields
}
func (*StopClientResponse) Descriptor
deprecated
func (*StopClientResponse) Descriptor() ([]byte, []int)
Deprecated: Use StopClientResponse.ProtoReflect.Descriptor instead.
func (*StopClientResponse) ProtoMessage ¶
func (*StopClientResponse) ProtoMessage()
func (*StopClientResponse) ProtoReflect ¶
func (x *StopClientResponse) ProtoReflect() protoreflect.Message
func (*StopClientResponse) Reset ¶
func (x *StopClientResponse) Reset()
func (*StopClientResponse) String ¶
func (x *StopClientResponse) String() string
type StopReplicaRequest ¶
type StopReplicaRequest struct {
IDs []uint32 `protobuf:"varint,1,rep,packed,name=IDs,proto3" json:"IDs,omitempty"`
// contains filtered or unexported fields
}
func (*StopReplicaRequest) Descriptor
deprecated
func (*StopReplicaRequest) Descriptor() ([]byte, []int)
Deprecated: Use StopReplicaRequest.ProtoReflect.Descriptor instead.
func (*StopReplicaRequest) GetIDs ¶
func (x *StopReplicaRequest) GetIDs() []uint32
func (*StopReplicaRequest) ProtoMessage ¶
func (*StopReplicaRequest) ProtoMessage()
func (*StopReplicaRequest) ProtoReflect ¶
func (x *StopReplicaRequest) ProtoReflect() protoreflect.Message
func (*StopReplicaRequest) Reset ¶
func (x *StopReplicaRequest) Reset()
func (*StopReplicaRequest) String ¶
func (x *StopReplicaRequest) String() string
type StopReplicaResponse ¶
type StopReplicaResponse struct {
// The final state hash of all executed commands
Hashes map[uint32][]byte `` /* 140-byte string literal not displayed */
// The final count of executed commands
Counts map[uint32]uint32 `` /* 141-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*StopReplicaResponse) Descriptor
deprecated
func (*StopReplicaResponse) Descriptor() ([]byte, []int)
Deprecated: Use StopReplicaResponse.ProtoReflect.Descriptor instead.
func (*StopReplicaResponse) GetCounts ¶ added in v0.5.0
func (x *StopReplicaResponse) GetCounts() map[uint32]uint32
func (*StopReplicaResponse) GetHashes ¶
func (x *StopReplicaResponse) GetHashes() map[uint32][]byte
func (*StopReplicaResponse) ProtoMessage ¶
func (*StopReplicaResponse) ProtoMessage()
func (*StopReplicaResponse) ProtoReflect ¶
func (x *StopReplicaResponse) ProtoReflect() protoreflect.Message
func (*StopReplicaResponse) Reset ¶
func (x *StopReplicaResponse) Reset()
func (*StopReplicaResponse) String ¶
func (x *StopReplicaResponse) String() string