etcdraft

package
v0.0.0-...-fbe82ab Latest Latest
Warning

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

 Go to latest Published: Mar 16, 2019 License: Apache-2.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

View Source 
const TypeKey = "etcdraft"

typekey是一个字符串，用于跨结构标识此一致性实现。

Variables

This section is empty.

Functions

func Marshal 

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

marshal序列化此实现的原型消息。它由编码器包调用 在创建医嘱者配置组的过程中。

Types

type ConsensusTypeMetadataFactory 

type ConsensusTypeMetadataFactory struct{}

ConsensistypeMetadataFactory允许此实现的协议消息注册 他们的类型和订购者的原型消息。这是原生动物工作所必需的。

func (ConsensusTypeMetadataFactory) NewMessage 

func (dogf ConsensusTypeMetadataFactory) NewMessage() proto.Message

newmessage实现order.conensustypemetadatafactory接口。

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:"-"`
}

同意者表示同意节点（即副本）。

func (*Consenter) Descriptor 

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

func (*Consenter) GetClientTlsCert 

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

func (*Consenter) GetHost 

func (m *Consenter) GetHost() 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 (dst *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 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:"-"`
}

元数据已序列化并设置为ConsensusType的值。中的元数据 当consensistype.type设置为“etcdraft”时的信道配置。

func (*Metadata) Descriptor 

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

func (*Metadata) GetConsenters 

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

func (*Metadata) GetOptions 

func (m *Metadata) GetOptions() *Options

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) Reset 

func (m *Metadata) Reset()

func (*Metadata) String 

func (m *Metadata) String() string

func (*Metadata) XXX_DiscardUnknown 

func (m *Metadata) XXX_DiscardUnknown()

func (*Metadata) XXX_Marshal 

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

func (*Metadata) XXX_Merge 

func (dst *Metadata) XXX_Merge(src proto.Message)

func (*Metadata) XXX_Size 

func (m *Metadata) XXX_Size() int

func (*Metadata) XXX_Unmarshal 

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

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:"-"`
}

为所有ETCD/RAFT节点指定选项。这些可以在 每通道基础。

func (*Options) Descriptor 

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

func (*Options) GetElectionTick 

func (m *Options) GetElectionTick() uint32

func (*Options) GetHeartbeatTick 

func (m *Options) GetHeartbeatTick() uint32

func (*Options) GetMaxInflightMsgs 

func (m *Options) GetMaxInflightMsgs() uint32

func (*Options) GetMaxSizePerMsg 

func (m *Options) GetMaxSizePerMsg() uint64

func (*Options) GetSnapshotInterval 

func (m *Options) GetSnapshotInterval() uint64

func (*Options) GetTickInterval 

func (m *Options) GetTickInterval() uint64

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 (dst *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 RaftMetadata 

type RaftMetadata struct {
	//在集群的OSN之间维护映射
	//还有他们的救生筏ID。
	Consenters map[uint64]*Consenter `` /* 162-byte string literal not displayed */
	//携带将分配的筏板ID值
	//到将加入该集群的下一个OSN。
	NextConsenterId uint64 `protobuf:"varint,2,opt,name=next_consenter_id,json=nextConsenterId,proto3" json:"next_consenter_id,omitempty"`
	//筏组配置计数
	ConfChangeCounts uint64 `protobuf:"varint,3,opt,name=conf_change_counts,json=confChangeCounts,proto3" json:"conf_change_counts,omitempty"`
	//当前区块ETCD/筏入口索引。
	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存储raft osn在以下情况下使用的数据： 相互协调，连载成 阻止meta dta字段，并在failres和restart之后使用。

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

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.