smartbft

package
v0.0.0-...-f69b815 Latest Latest
Warning

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

 Go to latest Published: Jun 12, 2023 License: Apache-2.0, Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

View Source 
const TypeKey = "smartbft"

TypeKey is the string with which this consensus implementation is identified across Fabric.

Variables

View Source 
var Options_Rotation_name = map[int32]string{
	0: "UNDEFINED",
	1: "OFF",
	2: "ON",
}
View Source 
var Options_Rotation_value = map[string]int32{
	"UNDEFINED": 0,
	"OFF":       1,
	"ON":        2,
}

Functions

func Marshal 

func Marshal(md *ConfigMetadata) ([]byte, error)

Marshal serializes this implementation's proto messages. It is called by the encoder package during the creation of the Orderer ConfigGroup.

Types

type ConfigMetadata 

type ConfigMetadata struct {
	Consenters           []*Consenter `protobuf:"bytes,1,rep,name=consenters,proto3" json:"consenters,omitempty"`
	Options              *Options     `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

ConfigMetadata is serialized and set as the value of ConsensusType.Metadata in a channel configuration when the ConsensusType.Type is set "smartbft".

func (*ConfigMetadata) Descriptor 

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

func (*ConfigMetadata) GetConsenters 

func (m *ConfigMetadata) GetConsenters() []*Consenter

func (*ConfigMetadata) GetOptions 

func (m *ConfigMetadata) GetOptions() *Options

func (*ConfigMetadata) ProtoMessage 

func (*ConfigMetadata) ProtoMessage()

func (*ConfigMetadata) Reset 

func (m *ConfigMetadata) Reset()

func (*ConfigMetadata) String 

func (m *ConfigMetadata) String() string

func (*ConfigMetadata) XXX_DiscardUnknown 

func (m *ConfigMetadata) XXX_DiscardUnknown()

func (*ConfigMetadata) XXX_Marshal 

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

func (*ConfigMetadata) XXX_Merge 

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

func (*ConfigMetadata) XXX_Size 

func (m *ConfigMetadata) XXX_Size() int

func (*ConfigMetadata) XXX_Unmarshal 

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

type ConsensusTypeMetadataFactory 

type ConsensusTypeMetadataFactory struct{}

ConsensusTypeMetadataFactory allows this implementation's proto messages to register their type with the orderer's proto messages. This is needed for protolator to work.

func (ConsensusTypeMetadataFactory) NewMessage 

func (dogf ConsensusTypeMetadataFactory) NewMessage() proto.Message

NewMessage implements the Orderer.ConsensusTypeMetadataFactory interface.

type Consenter 

type Consenter struct {
	ConsenterId          uint64   `protobuf:"varint,1,opt,name=consenter_id,json=consenterId,proto3" json:"consenter_id,omitempty"`
	Host                 string   `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	Port                 uint32   `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	MspId                string   `protobuf:"bytes,4,opt,name=msp_id,json=mspId,proto3" json:"msp_id,omitempty"`
	Identity             []byte   `protobuf:"bytes,5,opt,name=identity,proto3" json:"identity,omitempty"`
	ClientTlsCert        []byte   `protobuf:"bytes,6,opt,name=client_tls_cert,json=clientTlsCert,proto3" json:"client_tls_cert,omitempty"`
	ServerTlsCert        []byte   `protobuf:"bytes,7,opt,name=server_tls_cert,json=serverTlsCert,proto3" json:"server_tls_cert,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Consenter represents a consenting node (i.e. replica).

func (*Consenter) Descriptor 

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

func (*Consenter) GetClientTlsCert 

func (m *Consenter) GetClientTlsCert() []byte

func (*Consenter) GetConsenterId 

func (m *Consenter) GetConsenterId() uint64

func (*Consenter) GetHost 

func (m *Consenter) GetHost() string

func (*Consenter) GetIdentity 

func (m *Consenter) GetIdentity() []byte

func (*Consenter) GetMspId 

func (m *Consenter) GetMspId() string

func (*Consenter) GetPort 

func (m *Consenter) GetPort() uint32

func (*Consenter) GetServerTlsCert 

func (m *Consenter) GetServerTlsCert() []byte

func (*Consenter) ProtoMessage 

func (*Consenter) ProtoMessage()

func (*Consenter) Reset 

func (m *Consenter) Reset()

func (*Consenter) String 

func (m *Consenter) String() string

func (*Consenter) XXX_DiscardUnknown 

func (m *Consenter) XXX_DiscardUnknown()

func (*Consenter) XXX_Marshal 

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

func (*Consenter) XXX_Merge 

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

func (*Consenter) XXX_Size 

func (m *Consenter) XXX_Size() int

func (*Consenter) XXX_Unmarshal 

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

type Options 

type Options struct {
	RequestBatchMaxCount      uint64           `` /* 126-byte string literal not displayed */
	RequestBatchMaxBytes      uint64           `` /* 126-byte string literal not displayed */
	RequestBatchMaxInterval   string           `` /* 134-byte string literal not displayed */
	IncomingMessageBufferSize uint64           `` /* 141-byte string literal not displayed */
	RequestPoolSize           uint64           `protobuf:"varint,6,opt,name=request_pool_size,json=requestPoolSize,proto3" json:"request_pool_size,omitempty"`
	RequestForwardTimeout     string           `` /* 126-byte string literal not displayed */
	RequestComplainTimeout    string           `` /* 129-byte string literal not displayed */
	RequestAutoRemoveTimeout  string           `` /* 137-byte string literal not displayed */
	ViewChangeResendInterval  string           `` /* 138-byte string literal not displayed */
	ViewChangeTimeout         string           `protobuf:"bytes,11,opt,name=view_change_timeout,json=viewChangeTimeout,proto3" json:"view_change_timeout,omitempty"`
	LeaderHeartbeatTimeout    string           `` /* 130-byte string literal not displayed */
	LeaderHeartbeatCount      uint64           `protobuf:"varint,13,opt,name=leader_heartbeat_count,json=leaderHeartbeatCount,proto3" json:"leader_heartbeat_count,omitempty"`
	CollectTimeout            string           `protobuf:"bytes,14,opt,name=collect_timeout,json=collectTimeout,proto3" json:"collect_timeout,omitempty"`
	SyncOnStart               bool             `protobuf:"varint,15,opt,name=sync_on_start,json=syncOnStart,proto3" json:"sync_on_start,omitempty"`
	SpeedUpViewChange         bool             `protobuf:"varint,16,opt,name=speed_up_view_change,json=speedUpViewChange,proto3" json:"speed_up_view_change,omitempty"`
	LeaderRotation            Options_Rotation `` /* 136-byte string literal not displayed */
	DecisionsPerLeader        uint64           `protobuf:"varint,18,opt,name=decisions_per_leader,json=decisionsPerLeader,proto3" json:"decisions_per_leader,omitempty"`
	XXX_NoUnkeyedLiteral      struct{}         `json:"-"`
	XXX_unrecognized          []byte           `json:"-"`
	XXX_sizecache             int32            `json:"-"`
}

Options to be specified for all the smartbft nodes. These can be modified on a per-channel basis.

func (*Options) Descriptor 

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

func (*Options) GetCollectTimeout 

func (m *Options) GetCollectTimeout() string

func (*Options) GetDecisionsPerLeader 

func (m *Options) GetDecisionsPerLeader() uint64

func (*Options) GetIncomingMessageBufferSize 

func (m *Options) GetIncomingMessageBufferSize() uint64

func (*Options) GetLeaderHeartbeatCount 

func (m *Options) GetLeaderHeartbeatCount() uint64

func (*Options) GetLeaderHeartbeatTimeout 

func (m *Options) GetLeaderHeartbeatTimeout() string

func (*Options) GetLeaderRotation 

func (m *Options) GetLeaderRotation() Options_Rotation

func (*Options) GetRequestAutoRemoveTimeout 

func (m *Options) GetRequestAutoRemoveTimeout() string

func (*Options) GetRequestBatchMaxBytes 

func (m *Options) GetRequestBatchMaxBytes() uint64

func (*Options) GetRequestBatchMaxCount 

func (m *Options) GetRequestBatchMaxCount() uint64

func (*Options) GetRequestBatchMaxInterval 

func (m *Options) GetRequestBatchMaxInterval() string

func (*Options) GetRequestComplainTimeout 

func (m *Options) GetRequestComplainTimeout() string

func (*Options) GetRequestForwardTimeout 

func (m *Options) GetRequestForwardTimeout() string

func (*Options) GetRequestPoolSize 

func (m *Options) GetRequestPoolSize() uint64

func (*Options) GetSpeedUpViewChange 

func (m *Options) GetSpeedUpViewChange() bool

func (*Options) GetSyncOnStart 

func (m *Options) GetSyncOnStart() bool

func (*Options) GetViewChangeResendInterval 

func (m *Options) GetViewChangeResendInterval() string

func (*Options) GetViewChangeTimeout 

func (m *Options) GetViewChangeTimeout() string

func (*Options) ProtoMessage 

func (*Options) ProtoMessage()

func (*Options) Reset 

func (m *Options) Reset()

func (*Options) String 

func (m *Options) String() string

func (*Options) XXX_DiscardUnknown 

func (m *Options) XXX_DiscardUnknown()

func (*Options) XXX_Marshal 

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

func (*Options) XXX_Merge 

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

func (*Options) XXX_Size 

func (m *Options) XXX_Size() int

func (*Options) XXX_Unmarshal 

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

type Options_Rotation 

type Options_Rotation int32
const (
	Options_UNDEFINED Options_Rotation = 0
	Options_OFF       Options_Rotation = 1
	Options_ON        Options_Rotation = 2
)

func (Options_Rotation) EnumDescriptor 

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

func (Options_Rotation) String 

func (x Options_Rotation) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.