 Documentation
      ¶
      Documentation
      ¶
    
    
  
    
  
    Index ¶
- Constants
- func Marshal(md *Metadata) ([]byte, error)
- type ConsensusTypeMetadataFactory
- type Consenter
- func (*Consenter) Descriptor() ([]byte, []int)
- func (m *Consenter) GetClientTlsCert() []byte
- func (m *Consenter) GetHost() string
- func (m *Consenter) GetPort() uint32
- func (m *Consenter) GetServerTlsCert() []byte
- func (*Consenter) ProtoMessage()
- func (m *Consenter) Reset()
- func (m *Consenter) String() string
- func (m *Consenter) XXX_DiscardUnknown()
- func (m *Consenter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Consenter) XXX_Merge(src proto.Message)
- func (m *Consenter) XXX_Size() int
- func (m *Consenter) XXX_Unmarshal(b []byte) error
 
- type Metadata
- func (*Metadata) Descriptor() ([]byte, []int)
- func (m *Metadata) GetConsenters() []*Consenter
- func (m *Metadata) GetOptions() *Options
- func (*Metadata) ProtoMessage()
- func (m *Metadata) Reset()
- func (m *Metadata) String() string
- func (m *Metadata) XXX_DiscardUnknown()
- func (m *Metadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Metadata) XXX_Merge(src proto.Message)
- func (m *Metadata) XXX_Size() int
- func (m *Metadata) XXX_Unmarshal(b []byte) error
 
- type Options
- func (*Options) Descriptor() ([]byte, []int)
- func (m *Options) GetElectionTick() uint32
- func (m *Options) GetHeartbeatTick() uint32
- func (m *Options) GetMaxInflightMsgs() uint32
- func (m *Options) GetMaxSizePerMsg() uint64
- func (m *Options) GetSnapshotInterval() uint64
- func (m *Options) GetTickInterval() uint64
- func (*Options) ProtoMessage()
- func (m *Options) Reset()
- func (m *Options) String() string
- func (m *Options) XXX_DiscardUnknown()
- func (m *Options) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *Options) XXX_Merge(src proto.Message)
- func (m *Options) XXX_Size() int
- func (m *Options) XXX_Unmarshal(b []byte) error
 
- type RaftMetadata
- func (*RaftMetadata) Descriptor() ([]byte, []int)
- func (m *RaftMetadata) GetConfChangeCounts() uint64
- func (m *RaftMetadata) GetConsenters() map[uint64]*Consenter
- func (m *RaftMetadata) GetNextConsenterId() uint64
- func (m *RaftMetadata) GetRaftIndex() uint64
- func (*RaftMetadata) ProtoMessage()
- func (m *RaftMetadata) Reset()
- func (m *RaftMetadata) String() string
- func (m *RaftMetadata) XXX_DiscardUnknown()
- func (m *RaftMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *RaftMetadata) XXX_Merge(src proto.Message)
- func (m *RaftMetadata) XXX_Size() int
- func (m *RaftMetadata) XXX_Unmarshal(b []byte) error
 
Constants ¶
const TypeKey = "etcdraft"
    TypeKey is the string with which this consensus implementation is identified across Fabric.
Variables ¶
This section is empty.
Functions ¶
Types ¶
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 {
	Host                 string   `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Port                 uint32   `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	ClientTlsCert        []byte   `protobuf:"bytes,3,opt,name=client_tls_cert,json=clientTlsCert,proto3" json:"client_tls_cert,omitempty"`
	ServerTlsCert        []byte   `protobuf:"bytes,4,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) XXX_Marshal ¶
type Metadata ¶
type Metadata 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:"-"`
}
    Metadata is serialized and set as the value of ConsensusType.Metadata in a channel configuration when the ConsensusType.Type is set "etcdraft".
func (*Metadata) XXX_Marshal ¶
type Options ¶
type Options struct {
	TickInterval         uint64   `protobuf:"varint,1,opt,name=tick_interval,json=tickInterval,proto3" json:"tick_interval,omitempty"`
	ElectionTick         uint32   `protobuf:"varint,2,opt,name=election_tick,json=electionTick,proto3" json:"election_tick,omitempty"`
	HeartbeatTick        uint32   `protobuf:"varint,3,opt,name=heartbeat_tick,json=heartbeatTick,proto3" json:"heartbeat_tick,omitempty"`
	MaxInflightMsgs      uint32   `protobuf:"varint,4,opt,name=max_inflight_msgs,json=maxInflightMsgs,proto3" json:"max_inflight_msgs,omitempty"`
	MaxSizePerMsg        uint64   `protobuf:"varint,5,opt,name=max_size_per_msg,json=maxSizePerMsg,proto3" json:"max_size_per_msg,omitempty"`
	SnapshotInterval     uint64   `protobuf:"varint,6,opt,name=snapshot_interval,json=snapshotInterval,proto3" json:"snapshot_interval,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}
    Options to be specified for all the etcd/raft nodes. These can be modified on a per-channel basis.
func (*Options) XXX_Marshal ¶
type RaftMetadata ¶
type RaftMetadata struct {
	// Maintains a mapping between the cluster's OSNs
	// and their Raft IDs.
	Consenters map[uint64]*Consenter `` /* 162-byte string literal not displayed */
	// Carries the Raft ID value that will be assigned
	// to the next OSN that will join this cluster.
	NextConsenterId uint64 `protobuf:"varint,2,opt,name=next_consenter_id,json=nextConsenterId,proto3" json:"next_consenter_id,omitempty"`
	// Raft cluster configurations count
	ConfChangeCounts uint64 `protobuf:"varint,3,opt,name=conf_change_counts,json=confChangeCounts,proto3" json:"conf_change_counts,omitempty"`
	// Index of etcd/raft entry for current block.
	RaftIndex            uint64   `protobuf:"varint,4,opt,name=raft_index,json=raftIndex,proto3" json:"raft_index,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}
    RaftMetadata stores data used by the Raft OSNs when coordinating with each other, to be serialized into block meta dta field and used after failres and restarts.
func (*RaftMetadata) Descriptor ¶
func (*RaftMetadata) Descriptor() ([]byte, []int)
func (*RaftMetadata) GetConfChangeCounts ¶
func (m *RaftMetadata) GetConfChangeCounts() uint64
func (*RaftMetadata) GetConsenters ¶
func (m *RaftMetadata) GetConsenters() map[uint64]*Consenter
func (*RaftMetadata) GetNextConsenterId ¶
func (m *RaftMetadata) GetNextConsenterId() uint64
func (*RaftMetadata) GetRaftIndex ¶
func (m *RaftMetadata) GetRaftIndex() uint64
func (*RaftMetadata) ProtoMessage ¶
func (*RaftMetadata) ProtoMessage()
func (*RaftMetadata) Reset ¶
func (m *RaftMetadata) Reset()
func (*RaftMetadata) String ¶
func (m *RaftMetadata) String() string
func (*RaftMetadata) XXX_DiscardUnknown ¶
func (m *RaftMetadata) XXX_DiscardUnknown()
func (*RaftMetadata) XXX_Marshal ¶
func (m *RaftMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*RaftMetadata) XXX_Merge ¶
func (dst *RaftMetadata) XXX_Merge(src proto.Message)
func (*RaftMetadata) XXX_Size ¶
func (m *RaftMetadata) XXX_Size() int
func (*RaftMetadata) XXX_Unmarshal ¶
func (m *RaftMetadata) XXX_Unmarshal(b []byte) error
       Source Files
      ¶
      Source Files
      ¶
    
- configuration.go
- configuration.pb.go