orderer

Documentation

Index

• type BatchSize
  • func (*BatchSize) Descriptor() ([]byte, []int)
  • func (m *BatchSize) GetAbsoluteMaxBytes() uint32
  • func (m *BatchSize) GetMaxMessageCount() uint32
  • func (m *BatchSize) GetPreferredMaxBytes() uint32
  • func (*BatchSize) ProtoMessage()
  • func (m *BatchSize) Reset()
  • func (m *BatchSize) String() string
• type BatchTimeout
  • func (*BatchTimeout) Descriptor() ([]byte, []int)
  • func (m *BatchTimeout) GetTimeout() string
  • func (*BatchTimeout) ProtoMessage()
  • func (m *BatchTimeout) Reset()
  • func (m *BatchTimeout) String() string
• type ChannelRestrictions
  • func (*ChannelRestrictions) Descriptor() ([]byte, []int)
  • func (m *ChannelRestrictions) GetMaxCount() uint64
  • func (*ChannelRestrictions) ProtoMessage()
  • func (m *ChannelRestrictions) Reset()
  • func (m *ChannelRestrictions) String() string
• type ConsensusType
  • func (*ConsensusType) Descriptor() ([]byte, []int)
  • func (m *ConsensusType) GetType() string
  • func (*ConsensusType) ProtoMessage()
  • func (m *ConsensusType) Reset()
  • func (m *ConsensusType) String() string
• type KafkaBrokers
  • func (*KafkaBrokers) Descriptor() ([]byte, []int)
  • func (m *KafkaBrokers) GetBrokers() []string
  • func (*KafkaBrokers) ProtoMessage()
  • func (m *KafkaBrokers) Reset()
  • func (m *KafkaBrokers) String() string

Types

type BatchSize

type BatchSize struct {
	// Simply specified as number of messages for now, in the future
	// we may want to allow this to be specified by size in bytes
	MaxMessageCount uint32 `protobuf:"varint,1,opt,name=max_message_count,json=maxMessageCount" json:"max_message_count,omitempty"`
	// The byte count of the serialized messages in a batch cannot
	// exceed this value.
	AbsoluteMaxBytes uint32 `protobuf:"varint,2,opt,name=absolute_max_bytes,json=absoluteMaxBytes" json:"absolute_max_bytes,omitempty"`
	// The byte count of the serialized messages in a batch should not
	// exceed this value.
	PreferredMaxBytes uint32 `protobuf:"varint,3,opt,name=preferred_max_bytes,json=preferredMaxBytes" json:"preferred_max_bytes,omitempty"`
}

func (*BatchSize) Descriptor

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

func (*BatchSize) GetAbsoluteMaxBytes

func (m *BatchSize) GetAbsoluteMaxBytes() uint32

func (*BatchSize) GetMaxMessageCount

func (m *BatchSize) GetMaxMessageCount() uint32

func (*BatchSize) GetPreferredMaxBytes

func (m *BatchSize) GetPreferredMaxBytes() uint32

func (*BatchSize) ProtoMessage

func (*BatchSize) ProtoMessage()

func (*BatchSize) Reset

func (m *BatchSize) Reset()

func (*BatchSize) String

func (m *BatchSize) String() string

type BatchTimeout

type BatchTimeout struct {
	// Any duration string parseable by ParseDuration():
	// https://golang.org/pkg/time/#ParseDuration
	Timeout string `protobuf:"bytes,1,opt,name=timeout" json:"timeout,omitempty"`
}

func (*BatchTimeout) Descriptor

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

func (*BatchTimeout) GetTimeout

func (m *BatchTimeout) GetTimeout() string

func (*BatchTimeout) ProtoMessage

func (*BatchTimeout) ProtoMessage()

func (*BatchTimeout) Reset

func (m *BatchTimeout) Reset()

func (*BatchTimeout) String

func (m *BatchTimeout) String() string

type ChannelRestrictions

type ChannelRestrictions struct {
	MaxCount uint64 `protobuf:"varint,1,opt,name=max_count,json=maxCount" json:"max_count,omitempty"`
}

ChannelRestrictions is the mssage which conveys restrictions on channel creation for an orderer

func (*ChannelRestrictions) Descriptor

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

func (*ChannelRestrictions) GetMaxCount

func (m *ChannelRestrictions) GetMaxCount() uint64

func (*ChannelRestrictions) ProtoMessage

func (*ChannelRestrictions) ProtoMessage()

func (*ChannelRestrictions) Reset

func (m *ChannelRestrictions) Reset()

func (*ChannelRestrictions) String

func (m *ChannelRestrictions) String() string

type ConsensusType

type ConsensusType struct {
	Type string `protobuf:"bytes,1,opt,name=type" json:"type,omitempty"`
}

func (*ConsensusType) Descriptor

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

func (*ConsensusType) GetType

func (m *ConsensusType) GetType() string

func (*ConsensusType) ProtoMessage

func (*ConsensusType) ProtoMessage()

func (*ConsensusType) Reset

func (m *ConsensusType) Reset()

func (*ConsensusType) String

func (m *ConsensusType) String() string

type KafkaBrokers

type KafkaBrokers struct {
	// Each broker here should be identified using the (IP|host):port notation,
	// e.g. 127.0.0.1:7050, or localhost:7050 are valid entries
	Brokers []string `protobuf:"bytes,1,rep,name=brokers" json:"brokers,omitempty"`
}

Carries a list of bootstrap brokers, i.e. this is not the exclusive set of brokers an ordering service

func (*KafkaBrokers) Descriptor

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

func (*KafkaBrokers) GetBrokers

func (m *KafkaBrokers) GetBrokers() []string

func (*KafkaBrokers) ProtoMessage

func (*KafkaBrokers) ProtoMessage()

func (*KafkaBrokers) Reset

func (m *KafkaBrokers) Reset()

func (*KafkaBrokers) String

func (m *KafkaBrokers) String() string