sbft

package
v0.0.0-...-7491e2d Latest Latest
Warning

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

 Go to latest Published: Sep 28, 2020 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const TypeKey = "sbft"

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

Variables

This section is empty.

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.

func RegisterConsensusServer 

func RegisterConsensusServer(s *grpc.Server, srv ConsensusServer)

Types

type Batch 

type Batch struct {
	Header               []byte            `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	Payloads             [][]byte          `protobuf:"bytes,2,rep,name=payloads,proto3" json:"payloads,omitempty"`
	Signatures           map[uint64][]byte `` /* 162-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Batch) DecodeHeader 

func (m *Batch) DecodeHeader() *BatchHeader

func (*Batch) Descriptor 

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

func (*Batch) GetHeader 

func (m *Batch) GetHeader() []byte

func (*Batch) GetPayloads 

func (m *Batch) GetPayloads() [][]byte

func (*Batch) GetSignatures 

func (m *Batch) GetSignatures() map[uint64][]byte

func (*Batch) Hash 

func (m *Batch) Hash() []byte

Hash returns the hash of the Batch.

func (*Batch) ProtoMessage 

func (*Batch) ProtoMessage()

func (*Batch) Reset 

func (m *Batch) Reset()

func (*Batch) String 

func (m *Batch) String() string

func (*Batch) XXX_DiscardUnknown 

func (m *Batch) XXX_DiscardUnknown()

func (*Batch) XXX_Marshal 

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

func (*Batch) XXX_Merge 

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

func (*Batch) XXX_Size 

func (m *Batch) XXX_Size() int

func (*Batch) XXX_Unmarshal 

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

type BatchHeader 

type BatchHeader struct {
	Seq                  uint64   `protobuf:"varint,1,opt,name=seq,proto3" json:"seq,omitempty"`
	PrevHash             []byte   `protobuf:"bytes,2,opt,name=prev_hash,json=prevHash,proto3" json:"prev_hash,omitempty"`
	DataHash             []byte   `protobuf:"bytes,3,opt,name=data_hash,json=dataHash,proto3" json:"data_hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BatchHeader) Descriptor 

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

func (*BatchHeader) GetDataHash 

func (m *BatchHeader) GetDataHash() []byte

func (*BatchHeader) GetPrevHash 

func (m *BatchHeader) GetPrevHash() []byte

func (*BatchHeader) GetSeq 

func (m *BatchHeader) GetSeq() uint64

func (*BatchHeader) ProtoMessage 

func (*BatchHeader) ProtoMessage()

func (*BatchHeader) Reset 

func (m *BatchHeader) Reset()

func (*BatchHeader) String 

func (m *BatchHeader) String() string

func (*BatchHeader) XXX_DiscardUnknown 

func (m *BatchHeader) XXX_DiscardUnknown()

func (*BatchHeader) XXX_Marshal 

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

func (*BatchHeader) XXX_Merge 

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

func (*BatchHeader) XXX_Size 

func (m *BatchHeader) XXX_Size() int

func (*BatchHeader) XXX_Unmarshal 

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

type Checkpoint 

type Checkpoint struct {
	Seq                  uint64   `protobuf:"varint,1,opt,name=seq,proto3" json:"seq,omitempty"`
	Digest               []byte   `protobuf:"bytes,2,opt,name=digest,proto3" json:"digest,omitempty"`
	Signature            []byte   `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Checkpoint) Descriptor 

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

func (*Checkpoint) GetDigest 

func (m *Checkpoint) GetDigest() []byte

func (*Checkpoint) GetSeq 

func (m *Checkpoint) GetSeq() uint64

func (*Checkpoint) GetSignature 

func (m *Checkpoint) GetSignature() []byte

func (*Checkpoint) ProtoMessage 

func (*Checkpoint) ProtoMessage()

func (*Checkpoint) Reset 

func (m *Checkpoint) Reset()

func (*Checkpoint) String 

func (m *Checkpoint) String() string

func (*Checkpoint) XXX_DiscardUnknown 

func (m *Checkpoint) XXX_DiscardUnknown()

func (*Checkpoint) XXX_Marshal 

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

func (*Checkpoint) XXX_Merge 

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

func (*Checkpoint) XXX_Size 

func (m *Checkpoint) XXX_Size() int

func (*Checkpoint) XXX_Unmarshal 

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

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

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

type ConsensusClient interface {
	Consensus(ctx context.Context, in *Handshake, opts ...grpc.CallOption) (Consensus_ConsensusClient, error)
}

ConsensusClient is the client API for Consensus service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewConsensusClient 

func NewConsensusClient(cc *grpc.ClientConn) ConsensusClient

type ConsensusConfig 

type ConsensusConfig struct {
	Consensus            *Options              `protobuf:"bytes,1,opt,name=consensus,proto3" json:"consensus,omitempty"`
	Peers                map[string]*Consenter `` /* 151-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func ReadJsonConfig 

func ReadJsonConfig(file string) (*ConsensusConfig, error)

func (*ConsensusConfig) Descriptor 

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

func (*ConsensusConfig) GetConsensus 

func (m *ConsensusConfig) GetConsensus() *Options

func (*ConsensusConfig) GetPeers 

func (m *ConsensusConfig) GetPeers() map[string]*Consenter

func (*ConsensusConfig) ProtoMessage 

func (*ConsensusConfig) ProtoMessage()

func (*ConsensusConfig) Reset 

func (m *ConsensusConfig) Reset()

func (*ConsensusConfig) String 

func (m *ConsensusConfig) String() string

func (*ConsensusConfig) XXX_DiscardUnknown 

func (m *ConsensusConfig) XXX_DiscardUnknown()

func (*ConsensusConfig) XXX_Marshal 

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

func (*ConsensusConfig) XXX_Merge 

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

func (*ConsensusConfig) XXX_Size 

func (m *ConsensusConfig) XXX_Size() int

func (*ConsensusConfig) XXX_Unmarshal 

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

type ConsensusServer 

type ConsensusServer interface {
	Consensus(*Handshake, Consensus_ConsensusServer) error
}

ConsensusServer is the server API for Consensus service.

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 Consensus_ConsensusClient 

type Consensus_ConsensusClient interface {
	Recv() (*MultiChainMsg, error)
	grpc.ClientStream
}

type Consensus_ConsensusServer 

type Consensus_ConsensusServer interface {
	Send(*MultiChainMsg) error
	grpc.ServerStream
}

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"`
	ClientSignCert       []byte   `protobuf:"bytes,3,opt,name=client_sign_cert,json=clientSignCert,proto3" json:"client_sign_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 

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

func (*Consenter) GetClientSignCert 

func (m *Consenter) GetClientSignCert() []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 Handshake 

type Handshake struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Handshake) Descriptor 

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

func (*Handshake) ProtoMessage 

func (*Handshake) ProtoMessage()

func (*Handshake) Reset 

func (m *Handshake) Reset()

func (*Handshake) String 

func (m *Handshake) String() string

func (*Handshake) XXX_DiscardUnknown 

func (m *Handshake) XXX_DiscardUnknown()

func (*Handshake) XXX_Marshal 

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

func (*Handshake) XXX_Merge 

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

func (*Handshake) XXX_Size 

func (m *Handshake) XXX_Size() int

func (*Handshake) XXX_Unmarshal 

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

type Hello 

type Hello struct {
	Batch                *Batch   `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch,omitempty"`
	NewView              *NewView `protobuf:"bytes,2,opt,name=new_view,json=newView,proto3" json:"new_view,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Hello) Descriptor 

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

func (*Hello) GetBatch 

func (m *Hello) GetBatch() *Batch

func (*Hello) GetNewView 

func (m *Hello) GetNewView() *NewView

func (*Hello) ProtoMessage 

func (*Hello) ProtoMessage()

func (*Hello) Reset 

func (m *Hello) Reset()

func (*Hello) String 

func (m *Hello) String() string

func (*Hello) XXX_DiscardUnknown 

func (m *Hello) XXX_DiscardUnknown()

func (*Hello) XXX_Marshal 

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

func (*Hello) XXX_Merge 

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

func (*Hello) XXX_Size 

func (m *Hello) XXX_Size() int

func (*Hello) XXX_Unmarshal 

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

type JsonConfig 

type JsonConfig struct {
	Consensus            *Options `protobuf:"bytes,1,opt,name=consensus,proto3" json:"consensus,omitempty"`
	Peers                []*Peer  `protobuf:"bytes,2,rep,name=peers,proto3" json:"peers,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JsonConfig) Descriptor 

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

func (*JsonConfig) GetConsensus 

func (m *JsonConfig) GetConsensus() *Options

func (*JsonConfig) GetPeers 

func (m *JsonConfig) GetPeers() []*Peer

func (*JsonConfig) ProtoMessage 

func (*JsonConfig) ProtoMessage()

func (*JsonConfig) Reset 

func (m *JsonConfig) Reset()

func (*JsonConfig) String 

func (m *JsonConfig) String() string

func (*JsonConfig) XXX_DiscardUnknown 

func (m *JsonConfig) XXX_DiscardUnknown()

func (*JsonConfig) XXX_Marshal 

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

func (*JsonConfig) XXX_Merge 

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

func (*JsonConfig) XXX_Size 

func (m *JsonConfig) XXX_Size() int

func (*JsonConfig) XXX_Unmarshal 

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

type Msg 

type Msg struct {
	// Types that are valid to be assigned to Type:
	//	*Msg_Request
	//	*Msg_Preprepare
	//	*Msg_Prepare
	//	*Msg_Commit
	//	*Msg_ViewChange
	//	*Msg_NewView
	//	*Msg_Checkpoint
	//	*Msg_Hello
	Type                 isMsg_Type `protobuf_oneof:"type"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Msg) Descriptor 

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

func (*Msg) GetCheckpoint 

func (m *Msg) GetCheckpoint() *Checkpoint

func (*Msg) GetCommit 

func (m *Msg) GetCommit() *Subject

func (*Msg) GetHello 

func (m *Msg) GetHello() *Hello

func (*Msg) GetNewView 

func (m *Msg) GetNewView() *NewView

func (*Msg) GetPrepare 

func (m *Msg) GetPrepare() *Subject

func (*Msg) GetPreprepare 

func (m *Msg) GetPreprepare() *Preprepare

func (*Msg) GetRequest 

func (m *Msg) GetRequest() *Request

func (*Msg) GetType 

func (m *Msg) GetType() isMsg_Type

func (*Msg) GetViewChange 

func (m *Msg) GetViewChange() *Signed

func (*Msg) ProtoMessage 

func (*Msg) ProtoMessage()

func (*Msg) Reset 

func (m *Msg) Reset()

func (*Msg) String 

func (m *Msg) String() string

func (*Msg) XXX_DiscardUnknown 

func (m *Msg) XXX_DiscardUnknown()

func (*Msg) XXX_Marshal 

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

func (*Msg) XXX_Merge 

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

func (*Msg) XXX_OneofFuncs 

func (*Msg) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, func(msg proto.Message, tag, wire int, b *proto.Buffer) (bool, error), func(msg proto.Message) (n int), []interface{})

XXX_OneofFuncs is for the internal use of the proto package.

func (*Msg) XXX_Size 

func (m *Msg) XXX_Size() int

func (*Msg) XXX_Unmarshal 

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

type Msg_Checkpoint 

type Msg_Checkpoint struct {
	Checkpoint *Checkpoint `protobuf:"bytes,7,opt,name=checkpoint,proto3,oneof"`
}

type Msg_Commit 

type Msg_Commit struct {
	Commit *Subject `protobuf:"bytes,4,opt,name=commit,proto3,oneof"`
}

type Msg_Hello 

type Msg_Hello struct {
	Hello *Hello `protobuf:"bytes,8,opt,name=hello,proto3,oneof"`
}

type Msg_NewView 

type Msg_NewView struct {
	NewView *NewView `protobuf:"bytes,6,opt,name=new_view,json=newView,proto3,oneof"`
}

type Msg_Prepare 

type Msg_Prepare struct {
	Prepare *Subject `protobuf:"bytes,3,opt,name=prepare,proto3,oneof"`
}

type Msg_Preprepare 

type Msg_Preprepare struct {
	Preprepare *Preprepare `protobuf:"bytes,2,opt,name=preprepare,proto3,oneof"`
}

type Msg_Request 

type Msg_Request struct {
	Request *Request `protobuf:"bytes,1,opt,name=request,proto3,oneof"`
}

type Msg_ViewChange 

type Msg_ViewChange struct {
	ViewChange *Signed `protobuf:"bytes,5,opt,name=view_change,json=viewChange,proto3,oneof"`
}

type MultiChainMsg 

type MultiChainMsg struct {
	ChainID              string   `protobuf:"bytes,1,opt,name=chainID,proto3" json:"chainID,omitempty"`
	Msg                  *Msg     `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MultiChainMsg) Descriptor 

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

func (*MultiChainMsg) GetChainID 

func (m *MultiChainMsg) GetChainID() string

func (*MultiChainMsg) GetMsg 

func (m *MultiChainMsg) GetMsg() *Msg

func (*MultiChainMsg) ProtoMessage 

func (*MultiChainMsg) ProtoMessage()

func (*MultiChainMsg) Reset 

func (m *MultiChainMsg) Reset()

func (*MultiChainMsg) String 

func (m *MultiChainMsg) String() string

func (*MultiChainMsg) XXX_DiscardUnknown 

func (m *MultiChainMsg) XXX_DiscardUnknown()

func (*MultiChainMsg) XXX_Marshal 

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

func (*MultiChainMsg) XXX_Merge 

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

func (*MultiChainMsg) XXX_Size 

func (m *MultiChainMsg) XXX_Size() int

func (*MultiChainMsg) XXX_Unmarshal 

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

type NewView 

type NewView struct {
	View                 uint64             `protobuf:"varint,1,opt,name=view,proto3" json:"view,omitempty"`
	Vset                 map[uint64]*Signed `` /* 150-byte string literal not displayed */
	Xset                 *Subject           `protobuf:"bytes,3,opt,name=xset,proto3" json:"xset,omitempty"`
	Batch                *Batch             `protobuf:"bytes,4,opt,name=batch,proto3" json:"batch,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*NewView) Descriptor 

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

func (*NewView) GetBatch 

func (m *NewView) GetBatch() *Batch

func (*NewView) GetView 

func (m *NewView) GetView() uint64

func (*NewView) GetVset 

func (m *NewView) GetVset() map[uint64]*Signed

func (*NewView) GetXset 

func (m *NewView) GetXset() *Subject

func (*NewView) ProtoMessage 

func (*NewView) ProtoMessage()

func (*NewView) Reset 

func (m *NewView) Reset()

func (*NewView) String 

func (m *NewView) String() string

func (*NewView) XXX_DiscardUnknown 

func (m *NewView) XXX_DiscardUnknown()

func (*NewView) XXX_Marshal 

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

func (*NewView) XXX_Merge 

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

func (*NewView) XXX_Size 

func (m *NewView) XXX_Size() int

func (*NewView) XXX_Unmarshal 

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

type Options 

type Options struct {
	N                    uint64   `protobuf:"varint,1,opt,name=n,proto3" json:"n,omitempty"`
	F                    uint64   `protobuf:"varint,2,opt,name=f,proto3" json:"f,omitempty"`
	RequestTimeoutNsec   uint64   `protobuf:"varint,3,opt,name=request_timeout_nsec,json=requestTimeoutNsec,proto3" json:"request_timeout_nsec,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Defines the SBFT parameters when 'sbft' is specified as the 'OrdererType'

func (*Options) Descriptor 

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

func (*Options) GetF 

func (m *Options) GetF() uint64

func (*Options) GetN 

func (m *Options) GetN() uint64

func (*Options) GetRequestTimeoutNsec 

func (m *Options) GetRequestTimeoutNsec() 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 Peer 

type Peer struct {
	Address              string     `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	Cert                 *Consenter `protobuf:"bytes,2,opt,name=cert,proto3" json:"cert,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*Peer) Descriptor 

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

func (*Peer) GetAddress 

func (m *Peer) GetAddress() string

func (*Peer) GetCert 

func (m *Peer) GetCert() *Consenter

func (*Peer) ProtoMessage 

func (*Peer) ProtoMessage()

func (*Peer) Reset 

func (m *Peer) Reset()

func (*Peer) String 

func (m *Peer) String() string

func (*Peer) XXX_DiscardUnknown 

func (m *Peer) XXX_DiscardUnknown()

func (*Peer) XXX_Marshal 

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

func (*Peer) XXX_Merge 

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

func (*Peer) XXX_Size 

func (m *Peer) XXX_Size() int

func (*Peer) XXX_Unmarshal 

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

type Preprepare 

type Preprepare struct {
	Seq                  *SeqView `protobuf:"bytes,1,opt,name=seq,proto3" json:"seq,omitempty"`
	Batch                *Batch   `protobuf:"bytes,2,opt,name=batch,proto3" json:"batch,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Preprepare) Descriptor 

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

func (*Preprepare) GetBatch 

func (m *Preprepare) GetBatch() *Batch

func (*Preprepare) GetSeq 

func (m *Preprepare) GetSeq() *SeqView

func (*Preprepare) ProtoMessage 

func (*Preprepare) ProtoMessage()

func (*Preprepare) Reset 

func (m *Preprepare) Reset()

func (*Preprepare) String 

func (m *Preprepare) String() string

func (*Preprepare) XXX_DiscardUnknown 

func (m *Preprepare) XXX_DiscardUnknown()

func (*Preprepare) XXX_Marshal 

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

func (*Preprepare) XXX_Merge 

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

func (*Preprepare) XXX_Size 

func (m *Preprepare) XXX_Size() int

func (*Preprepare) XXX_Unmarshal 

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

type Request 

type Request struct {
	Payload              []byte   `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Request) Descriptor 

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

func (*Request) GetPayload 

func (m *Request) GetPayload() []byte

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) Reset 

func (m *Request) Reset()

func (*Request) String 

func (m *Request) String() string

func (*Request) XXX_DiscardUnknown 

func (m *Request) XXX_DiscardUnknown()

func (*Request) XXX_Marshal 

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

func (*Request) XXX_Merge 

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

func (*Request) XXX_Size 

func (m *Request) XXX_Size() int

func (*Request) XXX_Unmarshal 

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

type SeqView 

type SeqView struct {
	View                 uint64   `protobuf:"varint,1,opt,name=view,proto3" json:"view,omitempty"`
	Seq                  uint64   `protobuf:"varint,2,opt,name=seq,proto3" json:"seq,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SeqView) Descriptor 

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

func (*SeqView) GetSeq 

func (m *SeqView) GetSeq() uint64

func (*SeqView) GetView 

func (m *SeqView) GetView() uint64

func (*SeqView) ProtoMessage 

func (*SeqView) ProtoMessage()

func (*SeqView) Reset 

func (m *SeqView) Reset()

func (*SeqView) String 

func (m *SeqView) String() string

func (*SeqView) XXX_DiscardUnknown 

func (m *SeqView) XXX_DiscardUnknown()

func (*SeqView) XXX_Marshal 

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

func (*SeqView) XXX_Merge 

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

func (*SeqView) XXX_Size 

func (m *SeqView) XXX_Size() int

func (*SeqView) XXX_Unmarshal 

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

type Signed 

type Signed struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Signature            []byte   `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Signed) Descriptor 

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

func (*Signed) GetData 

func (m *Signed) GetData() []byte

func (*Signed) GetSignature 

func (m *Signed) GetSignature() []byte

func (*Signed) ProtoMessage 

func (*Signed) ProtoMessage()

func (*Signed) Reset 

func (m *Signed) Reset()

func (*Signed) String 

func (m *Signed) String() string

func (*Signed) XXX_DiscardUnknown 

func (m *Signed) XXX_DiscardUnknown()

func (*Signed) XXX_Marshal 

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

func (*Signed) XXX_Merge 

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

func (*Signed) XXX_Size 

func (m *Signed) XXX_Size() int

func (*Signed) XXX_Unmarshal 

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

type Subject 

type Subject struct {
	Seq                  *SeqView `protobuf:"bytes,1,opt,name=seq,proto3" json:"seq,omitempty"`
	Digest               []byte   `protobuf:"bytes,2,opt,name=digest,proto3" json:"digest,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Subject) Descriptor 

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

func (*Subject) GetDigest 

func (m *Subject) GetDigest() []byte

func (*Subject) GetSeq 

func (m *Subject) GetSeq() *SeqView

func (*Subject) ProtoMessage 

func (*Subject) ProtoMessage()

func (*Subject) Reset 

func (m *Subject) Reset()

func (*Subject) String 

func (m *Subject) String() string

func (*Subject) XXX_DiscardUnknown 

func (m *Subject) XXX_DiscardUnknown()

func (*Subject) XXX_Marshal 

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

func (*Subject) XXX_Merge 

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

func (*Subject) XXX_Size 

func (m *Subject) XXX_Size() int

func (*Subject) XXX_Unmarshal 

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

type ViewChange 

type ViewChange struct {
	View                 uint64     `protobuf:"varint,1,opt,name=view,proto3" json:"view,omitempty"`
	Pset                 []*Subject `protobuf:"bytes,2,rep,name=pset,proto3" json:"pset,omitempty"`
	Qset                 []*Subject `protobuf:"bytes,3,rep,name=qset,proto3" json:"qset,omitempty"`
	Checkpoint           *Batch     `protobuf:"bytes,4,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ViewChange) Descriptor 

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

func (*ViewChange) GetCheckpoint 

func (m *ViewChange) GetCheckpoint() *Batch

func (*ViewChange) GetPset 

func (m *ViewChange) GetPset() []*Subject

func (*ViewChange) GetQset 

func (m *ViewChange) GetQset() []*Subject

func (*ViewChange) GetView 

func (m *ViewChange) GetView() uint64

func (*ViewChange) ProtoMessage 

func (*ViewChange) ProtoMessage()

func (*ViewChange) Reset 

func (m *ViewChange) Reset()

func (*ViewChange) String 

func (m *ViewChange) String() string

func (*ViewChange) XXX_DiscardUnknown 

func (m *ViewChange) XXX_DiscardUnknown()

func (*ViewChange) XXX_Marshal 

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

func (*ViewChange) XXX_Merge 

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

func (*ViewChange) XXX_Size 

func (m *ViewChange) XXX_Size() int

func (*ViewChange) XXX_Unmarshal 

func (m *ViewChange) 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.