fabric-protos-go: github.com/hyperledger/fabric-protos-go/orderer/etcdraft Index | Files

package etcdraft

import "github.com/hyperledger/fabric-protos-go/orderer/etcdraft"

Index

Package Files

configuration.pb.go metadata.pb.go

type BlockMetadata Uses

type BlockMetadata struct {
    // Maintains a mapping between the cluster's OSNs
    // and their Raft IDs.
    ConsenterIds []uint64 `protobuf:"varint,1,rep,packed,name=consenter_ids,json=consenterIds,proto3" json:"consenter_ids,omitempty"`
    // 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"`
    // Index of etcd/raft entry for current block.
    RaftIndex            uint64   `protobuf:"varint,3,opt,name=raft_index,json=raftIndex,proto3" json:"raft_index,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

BlockMetadata 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 (*BlockMetadata) Descriptor Uses

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

func (*BlockMetadata) GetConsenterIds Uses

func (m *BlockMetadata) GetConsenterIds() []uint64

func (*BlockMetadata) GetNextConsenterId Uses

func (m *BlockMetadata) GetNextConsenterId() uint64

func (*BlockMetadata) GetRaftIndex Uses

func (m *BlockMetadata) GetRaftIndex() uint64

func (*BlockMetadata) ProtoMessage Uses

func (*BlockMetadata) ProtoMessage()

func (*BlockMetadata) Reset Uses

func (m *BlockMetadata) Reset()

func (*BlockMetadata) String Uses

func (m *BlockMetadata) String() string

func (*BlockMetadata) XXX_DiscardUnknown Uses

func (m *BlockMetadata) XXX_DiscardUnknown()

func (*BlockMetadata) XXX_Marshal Uses

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

func (*BlockMetadata) XXX_Merge Uses

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

func (*BlockMetadata) XXX_Size Uses

func (m *BlockMetadata) XXX_Size() int

func (*BlockMetadata) XXX_Unmarshal Uses

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

type ClusterMetadata Uses

type ClusterMetadata struct {
    // Indicates active nodes in cluster that are reacheable by Raft leader
    ActiveNodes          []uint64 `protobuf:"varint,1,rep,packed,name=active_nodes,json=activeNodes,proto3" json:"active_nodes,omitempty"`
    XXX_NoUnkeyedLiteral struct{} `json:"-"`
    XXX_unrecognized     []byte   `json:"-"`
    XXX_sizecache        int32    `json:"-"`
}

ClusterMetadata encapsulates metadata that is exchanged among cluster nodes

func (*ClusterMetadata) Descriptor Uses

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

func (*ClusterMetadata) GetActiveNodes Uses

func (m *ClusterMetadata) GetActiveNodes() []uint64

func (*ClusterMetadata) ProtoMessage Uses

func (*ClusterMetadata) ProtoMessage()

func (*ClusterMetadata) Reset Uses

func (m *ClusterMetadata) Reset()

func (*ClusterMetadata) String Uses

func (m *ClusterMetadata) String() string

func (*ClusterMetadata) XXX_DiscardUnknown Uses

func (m *ClusterMetadata) XXX_DiscardUnknown()

func (*ClusterMetadata) XXX_Marshal Uses

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

func (*ClusterMetadata) XXX_Merge Uses

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

func (*ClusterMetadata) XXX_Size Uses

func (m *ClusterMetadata) XXX_Size() int

func (*ClusterMetadata) XXX_Unmarshal Uses

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

type ConfigMetadata Uses

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 "etcdraft".

func (*ConfigMetadata) Descriptor Uses

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

func (*ConfigMetadata) GetConsenters Uses

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

func (*ConfigMetadata) GetOptions Uses

func (m *ConfigMetadata) GetOptions() *Options

func (*ConfigMetadata) ProtoMessage Uses

func (*ConfigMetadata) ProtoMessage()

func (*ConfigMetadata) Reset Uses

func (m *ConfigMetadata) Reset()

func (*ConfigMetadata) String Uses

func (m *ConfigMetadata) String() string

func (*ConfigMetadata) XXX_DiscardUnknown Uses

func (m *ConfigMetadata) XXX_DiscardUnknown()

func (*ConfigMetadata) XXX_Marshal Uses

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

func (*ConfigMetadata) XXX_Merge Uses

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

func (*ConfigMetadata) XXX_Size Uses

func (m *ConfigMetadata) XXX_Size() int

func (*ConfigMetadata) XXX_Unmarshal Uses

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

type Consenter Uses

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) Descriptor Uses

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

func (*Consenter) GetClientTlsCert Uses

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

func (*Consenter) GetHost Uses

func (m *Consenter) GetHost() string

func (*Consenter) GetPort Uses

func (m *Consenter) GetPort() uint32

func (*Consenter) GetServerTlsCert Uses

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

func (*Consenter) ProtoMessage Uses

func (*Consenter) ProtoMessage()

func (*Consenter) Reset Uses

func (m *Consenter) Reset()

func (*Consenter) String Uses

func (m *Consenter) String() string

func (*Consenter) XXX_DiscardUnknown Uses

func (m *Consenter) XXX_DiscardUnknown()

func (*Consenter) XXX_Marshal Uses

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

func (*Consenter) XXX_Merge Uses

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

func (*Consenter) XXX_Size Uses

func (m *Consenter) XXX_Size() int

func (*Consenter) XXX_Unmarshal Uses

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

type Options Uses

type Options struct {
    TickInterval      string `protobuf:"bytes,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"`
    MaxInflightBlocks uint32 `protobuf:"varint,4,opt,name=max_inflight_blocks,json=maxInflightBlocks,proto3" json:"max_inflight_blocks,omitempty"`
    // Take snapshot when cumulative data exceeds certain size in bytes.
    SnapshotIntervalSize uint32   `protobuf:"varint,5,opt,name=snapshot_interval_size,json=snapshotIntervalSize,proto3" json:"snapshot_interval_size,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) Descriptor Uses

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

func (*Options) GetElectionTick Uses

func (m *Options) GetElectionTick() uint32

func (*Options) GetHeartbeatTick Uses

func (m *Options) GetHeartbeatTick() uint32

func (*Options) GetMaxInflightBlocks Uses

func (m *Options) GetMaxInflightBlocks() uint32

func (*Options) GetSnapshotIntervalSize Uses

func (m *Options) GetSnapshotIntervalSize() uint32

func (*Options) GetTickInterval Uses

func (m *Options) GetTickInterval() string

func (*Options) ProtoMessage Uses

func (*Options) ProtoMessage()

func (*Options) Reset Uses

func (m *Options) Reset()

func (*Options) String Uses

func (m *Options) String() string

func (*Options) XXX_DiscardUnknown Uses

func (m *Options) XXX_DiscardUnknown()

func (*Options) XXX_Marshal Uses

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

func (*Options) XXX_Merge Uses

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

func (*Options) XXX_Size Uses

func (m *Options) XXX_Size() int

func (*Options) XXX_Unmarshal Uses

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

Package etcdraft imports 3 packages (graph) and is imported by 10 packages. Updated 2019-08-23. Refresh now. Tools for package owners.