psmartbft

Documentation

Index

• Variables
• type Options
  • func (*Options) Descriptor() ([]byte, []int)
  • func (x *Options) GetCollectTimeout() string
  • func (x *Options) GetDecisionsPerLeader() uint64
  • func (x *Options) GetIncomingMessageBufferSize() uint64
  • func (x *Options) GetLeaderHeartbeatCount() uint64
  • func (x *Options) GetLeaderHeartbeatTimeout() string
  • func (x *Options) GetLeaderRotation() Options_Rotation
  • func (x *Options) GetRequestAutoRemoveTimeout() string
  • func (x *Options) GetRequestBatchMaxBytes() uint64
  • func (x *Options) GetRequestBatchMaxCount() uint64
  • func (x *Options) GetRequestBatchMaxInterval() string
  • func (x *Options) GetRequestComplainTimeout() string
  • func (x *Options) GetRequestForwardTimeout() string
  • func (x *Options) GetRequestMaxBytes() uint64
  • func (x *Options) GetRequestPoolSize() uint64
  • func (x *Options) GetSpeedUpViewChange() bool
  • func (x *Options) GetSyncOnStart() bool
  • func (x *Options) GetViewChangeResendInterval() string
  • func (x *Options) GetViewChangeTimeout() string
  • func (*Options) ProtoMessage()
  • func (x *Options) ProtoReflect() protoreflect.Message
  • func (x *Options) Reset()
  • func (x *Options) String() string
• type Options_Rotation
  • func (Options_Rotation) Descriptor() protoreflect.EnumDescriptor
  • func (x Options_Rotation) Enum() *Options_Rotation
  • func (Options_Rotation) EnumDescriptor() ([]byte, []int)
  • func (x Options_Rotation) Number() protoreflect.EnumNumber
  • func (x Options_Rotation) String() string
  • func (Options_Rotation) Type() protoreflect.EnumType

Variables

var (
	Options_Rotation_name = map[int32]string{
		0: "ROTATION_UNSPECIFIED",
		1: "ROTATION_OFF",
		2: "ROTATION_ON",
	}
	Options_Rotation_value = map[string]int32{
		"ROTATION_UNSPECIFIED": 0,
		"ROTATION_OFF":         1,
		"ROTATION_ON":          2,
	}
)

Enum value maps for Options_Rotation.

var File_configuration_proto protoreflect.FileDescriptor

Types

type Options

type Options struct {

	// RequestBatchMaxCount 指定了一个批次中请求的最大数量。
	RequestBatchMaxCount uint64 `` /* 126-byte string literal not displayed */
	// RequestBatchMaxBytes 指定了一个请求批次中的最大字节数。
	RequestBatchMaxBytes uint64 `` /* 126-byte string literal not displayed */
	// RequestBatchMaxInterval 指定了请求批次的最大时间间隔。
	RequestBatchMaxInterval string `` /* 134-byte string literal not displayed */
	// IncomingMessageBufferSize 指定了传入消息缓冲区的大小。
	IncomingMessageBufferSize uint64 `` /* 141-byte string literal not displayed */
	// RequestPoolSize 指定了请求池的大小。
	RequestPoolSize uint64 `protobuf:"varint,5,opt,name=request_pool_size,json=requestPoolSize,proto3" json:"request_pool_size,omitempty"`
	// RequestForwardTimeout 指定了转发请求的超时时间。
	RequestForwardTimeout string `` /* 126-byte string literal not displayed */
	// RequestComplainTimeout 指定了处理投诉的超时时间。
	RequestComplainTimeout string `` /* 129-byte string literal not displayed */
	// RequestAutoRemoveTimeout 指定了自动移除请求的超时时间。
	RequestAutoRemoveTimeout string `` /* 137-byte string literal not displayed */
	// RequestMaxBytes 指定了一个请求的最大字节数。
	RequestMaxBytes uint64 `protobuf:"varint,9,opt,name=request_max_bytes,json=requestMaxBytes,proto3" json:"request_max_bytes,omitempty"`
	// ViewChangeResendInterval 指定了重发更改视图请求的时间间隔。
	ViewChangeResendInterval string `` /* 138-byte string literal not displayed */
	// ViewChangeTimeout 指定了更换视图的超时时间。
	ViewChangeTimeout string `protobuf:"bytes,11,opt,name=view_change_timeout,json=viewChangeTimeout,proto3" json:"view_change_timeout,omitempty"`
	// LeaderHeartbeatTimeout 指定了 leader 心跳的超时时间。
	LeaderHeartbeatTimeout string `` /* 130-byte string literal not displayed */
	// LeaderHeartbeatCount 记录 leader 的心跳次数。
	LeaderHeartbeatCount uint64 `protobuf:"varint,13,opt,name=leader_heartbeat_count,json=leaderHeartbeatCount,proto3" json:"leader_heartbeat_count,omitempty"`
	// CollectTimeout 指定了收集响应的超时时间。
	CollectTimeout string `protobuf:"bytes,14,opt,name=collect_timeout,json=collectTimeout,proto3" json:"collect_timeout,omitempty"`
	// SyncOnStart 指定是否在启动时同步。
	SyncOnStart bool `protobuf:"varint,15,opt,name=sync_on_start,json=syncOnStart,proto3" json:"sync_on_start,omitempty"`
	// SpeedUpViewChange 指定是否加快视图更换。
	SpeedUpViewChange bool `protobuf:"varint,16,opt,name=speed_up_view_change,json=speedUpViewChange,proto3" json:"speed_up_view_change,omitempty"`
	// LeaderRotation 指定了 leader 的轮换模式，即确定何时以及如何进行领导者的轮换。
	// 这对于确保系统的高可用性和安全性非常重要，因为领导者的轮换可以帮助分散风险，防
	// 止单点故障，并提高系统的稳定性。
	LeaderRotation Options_Rotation `` /* 137-byte string literal not displayed */
	// DecisionsPerLeader 指定了每个 leader 的决策数量。
	DecisionsPerLeader uint64 `protobuf:"varint,18,opt,name=decisions_per_leader,json=decisionsPerLeader,proto3" json:"decisions_per_leader,omitempty"`
	// contains filtered or unexported fields
}

Options 定义了共识过程的配置选项。

func (*Options) Descriptor

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

Deprecated: Use Options.ProtoReflect.Descriptor instead.

func (*Options) GetCollectTimeout

func (x *Options) GetCollectTimeout() string

func (*Options) GetDecisionsPerLeader

func (x *Options) GetDecisionsPerLeader() uint64

func (*Options) GetIncomingMessageBufferSize

func (x *Options) GetIncomingMessageBufferSize() uint64

func (*Options) GetLeaderHeartbeatCount

func (x *Options) GetLeaderHeartbeatCount() uint64

func (*Options) GetLeaderHeartbeatTimeout

func (x *Options) GetLeaderHeartbeatTimeout() string

func (*Options) GetLeaderRotation

func (x *Options) GetLeaderRotation() Options_Rotation

func (*Options) GetRequestAutoRemoveTimeout

func (x *Options) GetRequestAutoRemoveTimeout() string

func (*Options) GetRequestBatchMaxBytes

func (x *Options) GetRequestBatchMaxBytes() uint64

func (*Options) GetRequestBatchMaxCount

func (x *Options) GetRequestBatchMaxCount() uint64

func (*Options) GetRequestBatchMaxInterval

func (x *Options) GetRequestBatchMaxInterval() string

func (*Options) GetRequestComplainTimeout

func (x *Options) GetRequestComplainTimeout() string

func (*Options) GetRequestForwardTimeout

func (x *Options) GetRequestForwardTimeout() string

func (*Options) GetRequestMaxBytes

func (x *Options) GetRequestMaxBytes() uint64

func (*Options) GetRequestPoolSize

func (x *Options) GetRequestPoolSize() uint64

func (*Options) GetSpeedUpViewChange

func (x *Options) GetSpeedUpViewChange() bool

func (*Options) GetSyncOnStart

func (x *Options) GetSyncOnStart() bool

func (*Options) GetViewChangeResendInterval

func (x *Options) GetViewChangeResendInterval() string

func (*Options) GetViewChangeTimeout

func (x *Options) GetViewChangeTimeout() string

func (*Options) ProtoMessage

func (*Options) ProtoMessage()

func (*Options) ProtoReflect

func (x *Options) ProtoReflect() protoreflect.Message

func (*Options) Reset

func (x *Options) Reset()

func (*Options) String

func (x *Options) String() string

type Options_Rotation

type Options_Rotation int32

Rotation 定义了三种 leader 的轮换模式。

1. UNSPECIFIED：未指定轮换模式；
2. OFF：关闭轮换；
3. 开启轮换。

const (
	Options_ROTATION_UNSPECIFIED Options_Rotation = 0
	Options_ROTATION_OFF         Options_Rotation = 1
	Options_ROTATION_ON          Options_Rotation = 2
)

func (Options_Rotation) Descriptor

func (Options_Rotation) Descriptor() protoreflect.EnumDescriptor

func (Options_Rotation) Enum

func (x Options_Rotation) Enum() *Options_Rotation

func (Options_Rotation) EnumDescriptor

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

Deprecated: Use Options_Rotation.Descriptor instead.

func (Options_Rotation) Number

func (x Options_Rotation) Number() protoreflect.EnumNumber

func (Options_Rotation) String

func (x Options_Rotation) String() string

func (Options_Rotation) Type

func (Options_Rotation) Type() protoreflect.EnumType