orderer

package
v0.0.0-...-95b87ed Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ConsensusTypeMetadataMap = map[string]ConsensusTypeMetadataFactory{}
View Source
var ConsensusType_State_name = map[int32]string{
	0: "STATE_NORMAL",
	1: "STATE_MAINTENANCE",
}
View Source
var ConsensusType_State_value = map[string]int32{
	"STATE_NORMAL":      0,
	"STATE_MAINTENANCE": 1,
}
View Source
var KafkaMessageRegular_Class_name = map[int32]string{
	0: "UNKNOWN",
	1: "NORMAL",
	2: "CONFIG",
}
View Source
var KafkaMessageRegular_Class_value = map[string]int32{
	"UNKNOWN": 0,
	"NORMAL":  1,
	"CONFIG":  2,
}
View Source
var SeekInfo_SeekBehavior_name = map[int32]string{
	0: "BLOCK_UNTIL_READY",
	1: "FAIL_IF_NOT_READY",
}
View Source
var SeekInfo_SeekBehavior_value = map[string]int32{
	"BLOCK_UNTIL_READY": 0,
	"FAIL_IF_NOT_READY": 1,
}
View Source
var SeekInfo_SeekErrorResponse_name = map[int32]string{
	0: "STRICT",
	1: "BEST_EFFORT",
}
View Source
var SeekInfo_SeekErrorResponse_value = map[string]int32{
	"STRICT":      0,
	"BEST_EFFORT": 1,
}

Functions

func RegisterAtomicBroadcastServer

func RegisterAtomicBroadcastServer(s *grpc.Server, srv AtomicBroadcastServer)

func RegisterClusterServer

func RegisterClusterServer(s *grpc.Server, srv ClusterServer)

Types

type AtomicBroadcastClient

type AtomicBroadcastClient interface {
	Broadcast(ctx context.Context, opts ...grpc.CallOption) (AtomicBroadcast_BroadcastClient, error)

	Deliver(ctx context.Context, opts ...grpc.CallOption) (AtomicBroadcast_DeliverClient, error)
}

func NewAtomicBroadcastClient

func NewAtomicBroadcastClient(cc *grpc.ClientConn) AtomicBroadcastClient

type AtomicBroadcastServer

type AtomicBroadcastServer interface {
	Broadcast(AtomicBroadcast_BroadcastServer) error

	Deliver(AtomicBroadcast_DeliverServer) error
}

type AtomicBroadcast_BroadcastClient

type AtomicBroadcast_BroadcastClient interface {
	Send(*common.Envelope) error
	Recv() (*BroadcastResponse, error)
	grpc.ClientStream
}

type AtomicBroadcast_BroadcastServer

type AtomicBroadcast_BroadcastServer interface {
	Send(*BroadcastResponse) error
	Recv() (*common.Envelope, error)
	grpc.ServerStream
}

type AtomicBroadcast_DeliverClient

type AtomicBroadcast_DeliverClient interface {
	Send(*common.Envelope) error
	Recv() (*DeliverResponse, error)
	grpc.ClientStream
}

type AtomicBroadcast_DeliverServer

type AtomicBroadcast_DeliverServer interface {
	Send(*DeliverResponse) error
	Recv() (*common.Envelope, error)
	grpc.ServerStream
}

type BatchSize

type BatchSize struct {
	MaxMessageCount uint32 `protobuf:"varint,1,opt,name=max_message_count,json=maxMessageCount,proto3" json:"max_message_count,omitempty"`

	AbsoluteMaxBytes uint32 `protobuf:"varint,2,opt,name=absolute_max_bytes,json=absoluteMaxBytes,proto3" json:"absolute_max_bytes,omitempty"`

	PreferredMaxBytes    uint32   `protobuf:"varint,3,opt,name=preferred_max_bytes,json=preferredMaxBytes,proto3" json:"preferred_max_bytes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*BatchSize) XXX_DiscardUnknown

func (m *BatchSize) XXX_DiscardUnknown()

func (*BatchSize) XXX_Marshal

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

func (*BatchSize) XXX_Merge

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

func (*BatchSize) XXX_Size

func (m *BatchSize) XXX_Size() int

func (*BatchSize) XXX_Unmarshal

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

type BatchTimeout

type BatchTimeout struct {
	Timeout              string   `protobuf:"bytes,1,opt,name=timeout,proto3" json:"timeout,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*BatchTimeout) XXX_DiscardUnknown

func (m *BatchTimeout) XXX_DiscardUnknown()

func (*BatchTimeout) XXX_Marshal

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

func (*BatchTimeout) XXX_Merge

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

func (*BatchTimeout) XXX_Size

func (m *BatchTimeout) XXX_Size() int

func (*BatchTimeout) XXX_Unmarshal

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

type BroadcastResponse

type BroadcastResponse struct {
	Status common.Status `protobuf:"varint,1,opt,name=status,proto3,enum=common.Status" json:"status,omitempty"`

	Info                 string   `protobuf:"bytes,2,opt,name=info,proto3" json:"info,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BroadcastResponse) Descriptor

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

func (*BroadcastResponse) GetInfo

func (m *BroadcastResponse) GetInfo() string

func (*BroadcastResponse) GetStatus

func (m *BroadcastResponse) GetStatus() common.Status

func (*BroadcastResponse) ProtoMessage

func (*BroadcastResponse) ProtoMessage()

func (*BroadcastResponse) Reset

func (m *BroadcastResponse) Reset()

func (*BroadcastResponse) String

func (m *BroadcastResponse) String() string

func (*BroadcastResponse) XXX_DiscardUnknown

func (m *BroadcastResponse) XXX_DiscardUnknown()

func (*BroadcastResponse) XXX_Marshal

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

func (*BroadcastResponse) XXX_Merge

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

func (*BroadcastResponse) XXX_Size

func (m *BroadcastResponse) XXX_Size() int

func (*BroadcastResponse) XXX_Unmarshal

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

type ChannelRestrictions

type ChannelRestrictions struct {
	MaxCount             uint64   `protobuf:"varint,1,opt,name=max_count,json=maxCount,proto3" json:"max_count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*ChannelRestrictions) XXX_DiscardUnknown

func (m *ChannelRestrictions) XXX_DiscardUnknown()

func (*ChannelRestrictions) XXX_Marshal

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

func (*ChannelRestrictions) XXX_Merge

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

func (*ChannelRestrictions) XXX_Size

func (m *ChannelRestrictions) XXX_Size() int

func (*ChannelRestrictions) XXX_Unmarshal

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

type ClusterClient

type ClusterClient interface {
	Step(ctx context.Context, opts ...grpc.CallOption) (Cluster_StepClient, error)
}

func NewClusterClient

func NewClusterClient(cc *grpc.ClientConn) ClusterClient

type ClusterServer

type ClusterServer interface {
	Step(Cluster_StepServer) error
}

type Cluster_StepClient

type Cluster_StepClient interface {
	Send(*StepRequest) error
	Recv() (*StepResponse, error)
	grpc.ClientStream
}

type Cluster_StepServer

type Cluster_StepServer interface {
	Send(*StepResponse) error
	Recv() (*StepRequest, error)
	grpc.ServerStream
}

type ConsensusRequest

type ConsensusRequest struct {
	Channel              string   `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	Payload              []byte   `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	Metadata             []byte   `protobuf:"bytes,3,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ConsensusRequest) Descriptor

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

func (*ConsensusRequest) GetChannel

func (m *ConsensusRequest) GetChannel() string

func (*ConsensusRequest) GetMetadata

func (m *ConsensusRequest) GetMetadata() []byte

func (*ConsensusRequest) GetPayload

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

func (*ConsensusRequest) ProtoMessage

func (*ConsensusRequest) ProtoMessage()

func (*ConsensusRequest) Reset

func (m *ConsensusRequest) Reset()

func (*ConsensusRequest) String

func (m *ConsensusRequest) String() string

func (*ConsensusRequest) XXX_DiscardUnknown

func (m *ConsensusRequest) XXX_DiscardUnknown()

func (*ConsensusRequest) XXX_Marshal

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

func (*ConsensusRequest) XXX_Merge

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

func (*ConsensusRequest) XXX_Size

func (m *ConsensusRequest) XXX_Size() int

func (*ConsensusRequest) XXX_Unmarshal

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

type ConsensusType

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

	Metadata []byte `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`

	State                ConsensusType_State `protobuf:"varint,3,opt,name=state,proto3,enum=orderer.ConsensusType_State" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*ConsensusType) Descriptor

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

func (*ConsensusType) GetMetadata

func (m *ConsensusType) GetMetadata() []byte

func (*ConsensusType) GetState

func (m *ConsensusType) GetState() ConsensusType_State

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

func (*ConsensusType) VariablyOpaqueFieldProto

func (ct *ConsensusType) VariablyOpaqueFieldProto(name string) (proto.Message, error)

func (*ConsensusType) VariablyOpaqueFields

func (ct *ConsensusType) VariablyOpaqueFields() []string

func (*ConsensusType) XXX_DiscardUnknown

func (m *ConsensusType) XXX_DiscardUnknown()

func (*ConsensusType) XXX_Marshal

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

func (*ConsensusType) XXX_Merge

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

func (*ConsensusType) XXX_Size

func (m *ConsensusType) XXX_Size() int

func (*ConsensusType) XXX_Unmarshal

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

type ConsensusTypeMetadataFactory

type ConsensusTypeMetadataFactory interface {
	NewMessage() proto.Message
}

type ConsensusType_State

type ConsensusType_State int32
const (
	ConsensusType_STATE_NORMAL      ConsensusType_State = 0
	ConsensusType_STATE_MAINTENANCE ConsensusType_State = 1
)

func (ConsensusType_State) EnumDescriptor

func (ConsensusType_State) EnumDescriptor() ([]byte, []int)

func (ConsensusType_State) String

func (x ConsensusType_State) String() string

type DeliverResponse

type DeliverResponse struct {
	Type                 isDeliverResponse_Type `protobuf_oneof:"Type"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*DeliverResponse) Descriptor

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

func (*DeliverResponse) GetBlock

func (m *DeliverResponse) GetBlock() *common.Block

func (*DeliverResponse) GetStatus

func (m *DeliverResponse) GetStatus() common.Status

func (*DeliverResponse) GetType

func (m *DeliverResponse) GetType() isDeliverResponse_Type

func (*DeliverResponse) ProtoMessage

func (*DeliverResponse) ProtoMessage()

func (*DeliverResponse) Reset

func (m *DeliverResponse) Reset()

func (*DeliverResponse) String

func (m *DeliverResponse) String() string

func (*DeliverResponse) XXX_DiscardUnknown

func (m *DeliverResponse) XXX_DiscardUnknown()

func (*DeliverResponse) XXX_Marshal

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

func (*DeliverResponse) XXX_Merge

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

func (*DeliverResponse) XXX_OneofWrappers

func (*DeliverResponse) XXX_OneofWrappers() []interface{}

func (*DeliverResponse) XXX_Size

func (m *DeliverResponse) XXX_Size() int

func (*DeliverResponse) XXX_Unmarshal

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

type DeliverResponse_Block

type DeliverResponse_Block struct {
	Block *common.Block `protobuf:"bytes,2,opt,name=block,proto3,oneof"`
}

type DeliverResponse_Status

type DeliverResponse_Status struct {
	Status common.Status `protobuf:"varint,1,opt,name=status,proto3,enum=common.Status,oneof"`
}

type DynamicOrdererConfigValue

type DynamicOrdererConfigValue struct {
	*common.ConfigValue
	// contains filtered or unexported fields
}

func (*DynamicOrdererConfigValue) VariablyOpaqueFieldProto

func (docv *DynamicOrdererConfigValue) VariablyOpaqueFieldProto(name string) (proto.Message, error)

type DynamicOrdererGroup

type DynamicOrdererGroup struct {
	*common.ConfigGroup
}

func (*DynamicOrdererGroup) DynamicMapFieldProto

func (dcg *DynamicOrdererGroup) DynamicMapFieldProto(name string, key string, base proto.Message) (proto.Message, error)

type DynamicOrdererGroupFactory

type DynamicOrdererGroupFactory struct{}

func (DynamicOrdererGroupFactory) DynamicConfigGroup

func (dogf DynamicOrdererGroupFactory) DynamicConfigGroup(cg *common.ConfigGroup) proto.Message

type DynamicOrdererOrgConfigValue

type DynamicOrdererOrgConfigValue struct {
	*common.ConfigValue
	// contains filtered or unexported fields
}

func (*DynamicOrdererOrgConfigValue) VariablyOpaqueFieldProto

func (doocv *DynamicOrdererOrgConfigValue) VariablyOpaqueFieldProto(name string) (proto.Message, error)

type DynamicOrdererOrgGroup

type DynamicOrdererOrgGroup struct {
	*common.ConfigGroup
}

func (*DynamicOrdererOrgGroup) DynamicMapFieldProto

func (dcg *DynamicOrdererOrgGroup) DynamicMapFieldProto(name string, key string, base proto.Message) (proto.Message, error)

type KafkaBrokers

type KafkaBrokers struct {
	Brokers              []string `protobuf:"bytes,1,rep,name=brokers,proto3" json:"brokers,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

func (*KafkaBrokers) XXX_DiscardUnknown

func (m *KafkaBrokers) XXX_DiscardUnknown()

func (*KafkaBrokers) XXX_Marshal

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

func (*KafkaBrokers) XXX_Merge

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

func (*KafkaBrokers) XXX_Size

func (m *KafkaBrokers) XXX_Size() int

func (*KafkaBrokers) XXX_Unmarshal

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

type KafkaMessage

type KafkaMessage struct {
	Type                 isKafkaMessage_Type `protobuf_oneof:"Type"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*KafkaMessage) Descriptor

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

func (*KafkaMessage) GetConnect

func (m *KafkaMessage) GetConnect() *KafkaMessageConnect

func (*KafkaMessage) GetRegular

func (m *KafkaMessage) GetRegular() *KafkaMessageRegular

func (*KafkaMessage) GetTimeToCut

func (m *KafkaMessage) GetTimeToCut() *KafkaMessageTimeToCut

func (*KafkaMessage) GetType

func (m *KafkaMessage) GetType() isKafkaMessage_Type

func (*KafkaMessage) ProtoMessage

func (*KafkaMessage) ProtoMessage()

func (*KafkaMessage) Reset

func (m *KafkaMessage) Reset()

func (*KafkaMessage) String

func (m *KafkaMessage) String() string

func (*KafkaMessage) XXX_DiscardUnknown

func (m *KafkaMessage) XXX_DiscardUnknown()

func (*KafkaMessage) XXX_Marshal

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

func (*KafkaMessage) XXX_Merge

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

func (*KafkaMessage) XXX_OneofWrappers

func (*KafkaMessage) XXX_OneofWrappers() []interface{}

func (*KafkaMessage) XXX_Size

func (m *KafkaMessage) XXX_Size() int

func (*KafkaMessage) XXX_Unmarshal

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

type KafkaMessageConnect

type KafkaMessageConnect 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 (*KafkaMessageConnect) Descriptor

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

func (*KafkaMessageConnect) GetPayload

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

func (*KafkaMessageConnect) ProtoMessage

func (*KafkaMessageConnect) ProtoMessage()

func (*KafkaMessageConnect) Reset

func (m *KafkaMessageConnect) Reset()

func (*KafkaMessageConnect) String

func (m *KafkaMessageConnect) String() string

func (*KafkaMessageConnect) XXX_DiscardUnknown

func (m *KafkaMessageConnect) XXX_DiscardUnknown()

func (*KafkaMessageConnect) XXX_Marshal

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

func (*KafkaMessageConnect) XXX_Merge

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

func (*KafkaMessageConnect) XXX_Size

func (m *KafkaMessageConnect) XXX_Size() int

func (*KafkaMessageConnect) XXX_Unmarshal

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

type KafkaMessageRegular

type KafkaMessageRegular struct {
	Payload              []byte                    `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	ConfigSeq            uint64                    `protobuf:"varint,2,opt,name=config_seq,json=configSeq,proto3" json:"config_seq,omitempty"`
	Class                KafkaMessageRegular_Class `protobuf:"varint,3,opt,name=class,proto3,enum=orderer.KafkaMessageRegular_Class" json:"class,omitempty"`
	OriginalOffset       int64                     `protobuf:"varint,4,opt,name=original_offset,json=originalOffset,proto3" json:"original_offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*KafkaMessageRegular) Descriptor

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

func (*KafkaMessageRegular) GetClass

func (*KafkaMessageRegular) GetConfigSeq

func (m *KafkaMessageRegular) GetConfigSeq() uint64

func (*KafkaMessageRegular) GetOriginalOffset

func (m *KafkaMessageRegular) GetOriginalOffset() int64

func (*KafkaMessageRegular) GetPayload

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

func (*KafkaMessageRegular) ProtoMessage

func (*KafkaMessageRegular) ProtoMessage()

func (*KafkaMessageRegular) Reset

func (m *KafkaMessageRegular) Reset()

func (*KafkaMessageRegular) String

func (m *KafkaMessageRegular) String() string

func (*KafkaMessageRegular) XXX_DiscardUnknown

func (m *KafkaMessageRegular) XXX_DiscardUnknown()

func (*KafkaMessageRegular) XXX_Marshal

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

func (*KafkaMessageRegular) XXX_Merge

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

func (*KafkaMessageRegular) XXX_Size

func (m *KafkaMessageRegular) XXX_Size() int

func (*KafkaMessageRegular) XXX_Unmarshal

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

type KafkaMessageRegular_Class

type KafkaMessageRegular_Class int32
const (
	KafkaMessageRegular_UNKNOWN KafkaMessageRegular_Class = 0
	KafkaMessageRegular_NORMAL  KafkaMessageRegular_Class = 1
	KafkaMessageRegular_CONFIG  KafkaMessageRegular_Class = 2
)

func (KafkaMessageRegular_Class) EnumDescriptor

func (KafkaMessageRegular_Class) EnumDescriptor() ([]byte, []int)

func (KafkaMessageRegular_Class) String

func (x KafkaMessageRegular_Class) String() string

type KafkaMessageTimeToCut

type KafkaMessageTimeToCut struct {
	BlockNumber          uint64   `protobuf:"varint,1,opt,name=block_number,json=blockNumber,proto3" json:"block_number,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*KafkaMessageTimeToCut) Descriptor

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

func (*KafkaMessageTimeToCut) GetBlockNumber

func (m *KafkaMessageTimeToCut) GetBlockNumber() uint64

func (*KafkaMessageTimeToCut) ProtoMessage

func (*KafkaMessageTimeToCut) ProtoMessage()

func (*KafkaMessageTimeToCut) Reset

func (m *KafkaMessageTimeToCut) Reset()

func (*KafkaMessageTimeToCut) String

func (m *KafkaMessageTimeToCut) String() string

func (*KafkaMessageTimeToCut) XXX_DiscardUnknown

func (m *KafkaMessageTimeToCut) XXX_DiscardUnknown()

func (*KafkaMessageTimeToCut) XXX_Marshal

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

func (*KafkaMessageTimeToCut) XXX_Merge

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

func (*KafkaMessageTimeToCut) XXX_Size

func (m *KafkaMessageTimeToCut) XXX_Size() int

func (*KafkaMessageTimeToCut) XXX_Unmarshal

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

type KafkaMessage_Connect

type KafkaMessage_Connect struct {
	Connect *KafkaMessageConnect `protobuf:"bytes,3,opt,name=connect,proto3,oneof"`
}

type KafkaMessage_Regular

type KafkaMessage_Regular struct {
	Regular *KafkaMessageRegular `protobuf:"bytes,1,opt,name=regular,proto3,oneof"`
}

type KafkaMessage_TimeToCut

type KafkaMessage_TimeToCut struct {
	TimeToCut *KafkaMessageTimeToCut `protobuf:"bytes,2,opt,name=time_to_cut,json=timeToCut,proto3,oneof"`
}

type KafkaMetadata

type KafkaMetadata struct {
	LastOffsetPersisted int64 `protobuf:"varint,1,opt,name=last_offset_persisted,json=lastOffsetPersisted,proto3" json:"last_offset_persisted,omitempty"`

	LastOriginalOffsetProcessed int64 `` /* 147-byte string literal not displayed */

	LastResubmittedConfigOffset int64    `` /* 147-byte string literal not displayed */
	XXX_NoUnkeyedLiteral        struct{} `json:"-"`
	XXX_unrecognized            []byte   `json:"-"`
	XXX_sizecache               int32    `json:"-"`
}

func (*KafkaMetadata) Descriptor

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

func (*KafkaMetadata) GetLastOffsetPersisted

func (m *KafkaMetadata) GetLastOffsetPersisted() int64

func (*KafkaMetadata) GetLastOriginalOffsetProcessed

func (m *KafkaMetadata) GetLastOriginalOffsetProcessed() int64

func (*KafkaMetadata) GetLastResubmittedConfigOffset

func (m *KafkaMetadata) GetLastResubmittedConfigOffset() int64

func (*KafkaMetadata) ProtoMessage

func (*KafkaMetadata) ProtoMessage()

func (*KafkaMetadata) Reset

func (m *KafkaMetadata) Reset()

func (*KafkaMetadata) String

func (m *KafkaMetadata) String() string

func (*KafkaMetadata) XXX_DiscardUnknown

func (m *KafkaMetadata) XXX_DiscardUnknown()

func (*KafkaMetadata) XXX_Marshal

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

func (*KafkaMetadata) XXX_Merge

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

func (*KafkaMetadata) XXX_Size

func (m *KafkaMetadata) XXX_Size() int

func (*KafkaMetadata) XXX_Unmarshal

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

type SeekInfo

type SeekInfo struct {
	Start                *SeekPosition              `protobuf:"bytes,1,opt,name=start,proto3" json:"start,omitempty"`
	Stop                 *SeekPosition              `protobuf:"bytes,2,opt,name=stop,proto3" json:"stop,omitempty"`
	Behavior             SeekInfo_SeekBehavior      `protobuf:"varint,3,opt,name=behavior,proto3,enum=orderer.SeekInfo_SeekBehavior" json:"behavior,omitempty"`
	ErrorResponse        SeekInfo_SeekErrorResponse `` /* 141-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*SeekInfo) Descriptor

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

func (*SeekInfo) GetBehavior

func (m *SeekInfo) GetBehavior() SeekInfo_SeekBehavior

func (*SeekInfo) GetErrorResponse

func (m *SeekInfo) GetErrorResponse() SeekInfo_SeekErrorResponse

func (*SeekInfo) GetStart

func (m *SeekInfo) GetStart() *SeekPosition

func (*SeekInfo) GetStop

func (m *SeekInfo) GetStop() *SeekPosition

func (*SeekInfo) ProtoMessage

func (*SeekInfo) ProtoMessage()

func (*SeekInfo) Reset

func (m *SeekInfo) Reset()

func (*SeekInfo) String

func (m *SeekInfo) String() string

func (*SeekInfo) XXX_DiscardUnknown

func (m *SeekInfo) XXX_DiscardUnknown()

func (*SeekInfo) XXX_Marshal

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

func (*SeekInfo) XXX_Merge

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

func (*SeekInfo) XXX_Size

func (m *SeekInfo) XXX_Size() int

func (*SeekInfo) XXX_Unmarshal

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

type SeekInfo_SeekBehavior

type SeekInfo_SeekBehavior int32
const (
	SeekInfo_BLOCK_UNTIL_READY SeekInfo_SeekBehavior = 0
	SeekInfo_FAIL_IF_NOT_READY SeekInfo_SeekBehavior = 1
)

func (SeekInfo_SeekBehavior) EnumDescriptor

func (SeekInfo_SeekBehavior) EnumDescriptor() ([]byte, []int)

func (SeekInfo_SeekBehavior) String

func (x SeekInfo_SeekBehavior) String() string

type SeekInfo_SeekErrorResponse

type SeekInfo_SeekErrorResponse int32
const (
	SeekInfo_STRICT      SeekInfo_SeekErrorResponse = 0
	SeekInfo_BEST_EFFORT SeekInfo_SeekErrorResponse = 1
)

func (SeekInfo_SeekErrorResponse) EnumDescriptor

func (SeekInfo_SeekErrorResponse) EnumDescriptor() ([]byte, []int)

func (SeekInfo_SeekErrorResponse) String

type SeekNewest

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

func (*SeekNewest) Descriptor

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

func (*SeekNewest) ProtoMessage

func (*SeekNewest) ProtoMessage()

func (*SeekNewest) Reset

func (m *SeekNewest) Reset()

func (*SeekNewest) String

func (m *SeekNewest) String() string

func (*SeekNewest) XXX_DiscardUnknown

func (m *SeekNewest) XXX_DiscardUnknown()

func (*SeekNewest) XXX_Marshal

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

func (*SeekNewest) XXX_Merge

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

func (*SeekNewest) XXX_Size

func (m *SeekNewest) XXX_Size() int

func (*SeekNewest) XXX_Unmarshal

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

type SeekOldest

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

func (*SeekOldest) Descriptor

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

func (*SeekOldest) ProtoMessage

func (*SeekOldest) ProtoMessage()

func (*SeekOldest) Reset

func (m *SeekOldest) Reset()

func (*SeekOldest) String

func (m *SeekOldest) String() string

func (*SeekOldest) XXX_DiscardUnknown

func (m *SeekOldest) XXX_DiscardUnknown()

func (*SeekOldest) XXX_Marshal

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

func (*SeekOldest) XXX_Merge

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

func (*SeekOldest) XXX_Size

func (m *SeekOldest) XXX_Size() int

func (*SeekOldest) XXX_Unmarshal

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

type SeekPosition

type SeekPosition struct {
	Type                 isSeekPosition_Type `protobuf_oneof:"Type"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*SeekPosition) Descriptor

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

func (*SeekPosition) GetNewest

func (m *SeekPosition) GetNewest() *SeekNewest

func (*SeekPosition) GetOldest

func (m *SeekPosition) GetOldest() *SeekOldest

func (*SeekPosition) GetSpecified

func (m *SeekPosition) GetSpecified() *SeekSpecified

func (*SeekPosition) GetType

func (m *SeekPosition) GetType() isSeekPosition_Type

func (*SeekPosition) ProtoMessage

func (*SeekPosition) ProtoMessage()

func (*SeekPosition) Reset

func (m *SeekPosition) Reset()

func (*SeekPosition) String

func (m *SeekPosition) String() string

func (*SeekPosition) XXX_DiscardUnknown

func (m *SeekPosition) XXX_DiscardUnknown()

func (*SeekPosition) XXX_Marshal

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

func (*SeekPosition) XXX_Merge

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

func (*SeekPosition) XXX_OneofWrappers

func (*SeekPosition) XXX_OneofWrappers() []interface{}

func (*SeekPosition) XXX_Size

func (m *SeekPosition) XXX_Size() int

func (*SeekPosition) XXX_Unmarshal

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

type SeekPosition_Newest

type SeekPosition_Newest struct {
	Newest *SeekNewest `protobuf:"bytes,1,opt,name=newest,proto3,oneof"`
}

type SeekPosition_Oldest

type SeekPosition_Oldest struct {
	Oldest *SeekOldest `protobuf:"bytes,2,opt,name=oldest,proto3,oneof"`
}

type SeekPosition_Specified

type SeekPosition_Specified struct {
	Specified *SeekSpecified `protobuf:"bytes,3,opt,name=specified,proto3,oneof"`
}

type SeekSpecified

type SeekSpecified struct {
	Number               uint64   `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SeekSpecified) Descriptor

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

func (*SeekSpecified) GetNumber

func (m *SeekSpecified) GetNumber() uint64

func (*SeekSpecified) ProtoMessage

func (*SeekSpecified) ProtoMessage()

func (*SeekSpecified) Reset

func (m *SeekSpecified) Reset()

func (*SeekSpecified) String

func (m *SeekSpecified) String() string

func (*SeekSpecified) XXX_DiscardUnknown

func (m *SeekSpecified) XXX_DiscardUnknown()

func (*SeekSpecified) XXX_Marshal

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

func (*SeekSpecified) XXX_Merge

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

func (*SeekSpecified) XXX_Size

func (m *SeekSpecified) XXX_Size() int

func (*SeekSpecified) XXX_Unmarshal

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

type StepRequest

type StepRequest struct {
	Payload              isStepRequest_Payload `protobuf_oneof:"payload"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*StepRequest) Descriptor

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

func (*StepRequest) GetConsensusRequest

func (m *StepRequest) GetConsensusRequest() *ConsensusRequest

func (*StepRequest) GetPayload

func (m *StepRequest) GetPayload() isStepRequest_Payload

func (*StepRequest) GetSubmitRequest

func (m *StepRequest) GetSubmitRequest() *SubmitRequest

func (*StepRequest) ProtoMessage

func (*StepRequest) ProtoMessage()

func (*StepRequest) Reset

func (m *StepRequest) Reset()

func (*StepRequest) String

func (m *StepRequest) String() string

func (*StepRequest) XXX_DiscardUnknown

func (m *StepRequest) XXX_DiscardUnknown()

func (*StepRequest) XXX_Marshal

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

func (*StepRequest) XXX_Merge

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

func (*StepRequest) XXX_OneofWrappers

func (*StepRequest) XXX_OneofWrappers() []interface{}

func (*StepRequest) XXX_Size

func (m *StepRequest) XXX_Size() int

func (*StepRequest) XXX_Unmarshal

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

type StepRequest_ConsensusRequest

type StepRequest_ConsensusRequest struct {
	ConsensusRequest *ConsensusRequest `protobuf:"bytes,1,opt,name=consensus_request,json=consensusRequest,proto3,oneof"`
}

type StepRequest_SubmitRequest

type StepRequest_SubmitRequest struct {
	SubmitRequest *SubmitRequest `protobuf:"bytes,2,opt,name=submit_request,json=submitRequest,proto3,oneof"`
}

type StepResponse

type StepResponse struct {
	Payload              isStepResponse_Payload `protobuf_oneof:"payload"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*StepResponse) Descriptor

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

func (*StepResponse) GetPayload

func (m *StepResponse) GetPayload() isStepResponse_Payload

func (*StepResponse) GetSubmitRes

func (m *StepResponse) GetSubmitRes() *SubmitResponse

func (*StepResponse) ProtoMessage

func (*StepResponse) ProtoMessage()

func (*StepResponse) Reset

func (m *StepResponse) Reset()

func (*StepResponse) String

func (m *StepResponse) String() string

func (*StepResponse) XXX_DiscardUnknown

func (m *StepResponse) XXX_DiscardUnknown()

func (*StepResponse) XXX_Marshal

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

func (*StepResponse) XXX_Merge

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

func (*StepResponse) XXX_OneofWrappers

func (*StepResponse) XXX_OneofWrappers() []interface{}

func (*StepResponse) XXX_Size

func (m *StepResponse) XXX_Size() int

func (*StepResponse) XXX_Unmarshal

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

type StepResponse_SubmitRes

type StepResponse_SubmitRes struct {
	SubmitRes *SubmitResponse `protobuf:"bytes,1,opt,name=submit_res,json=submitRes,proto3,oneof"`
}

type SubmitRequest

type SubmitRequest struct {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`

	LastValidationSeq uint64 `protobuf:"varint,2,opt,name=last_validation_seq,json=lastValidationSeq,proto3" json:"last_validation_seq,omitempty"`

	Payload              *common.Envelope `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*SubmitRequest) Descriptor

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

func (*SubmitRequest) GetChannel

func (m *SubmitRequest) GetChannel() string

func (*SubmitRequest) GetLastValidationSeq

func (m *SubmitRequest) GetLastValidationSeq() uint64

func (*SubmitRequest) GetPayload

func (m *SubmitRequest) GetPayload() *common.Envelope

func (*SubmitRequest) ProtoMessage

func (*SubmitRequest) ProtoMessage()

func (*SubmitRequest) Reset

func (m *SubmitRequest) Reset()

func (*SubmitRequest) String

func (m *SubmitRequest) String() string

func (*SubmitRequest) XXX_DiscardUnknown

func (m *SubmitRequest) XXX_DiscardUnknown()

func (*SubmitRequest) XXX_Marshal

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

func (*SubmitRequest) XXX_Merge

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

func (*SubmitRequest) XXX_Size

func (m *SubmitRequest) XXX_Size() int

func (*SubmitRequest) XXX_Unmarshal

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

type SubmitResponse

type SubmitResponse struct {
	Channel string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`

	Status common.Status `protobuf:"varint,2,opt,name=status,proto3,enum=common.Status" json:"status,omitempty"`

	Info                 string   `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SubmitResponse) Descriptor

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

func (*SubmitResponse) GetChannel

func (m *SubmitResponse) GetChannel() string

func (*SubmitResponse) GetInfo

func (m *SubmitResponse) GetInfo() string

func (*SubmitResponse) GetStatus

func (m *SubmitResponse) GetStatus() common.Status

func (*SubmitResponse) ProtoMessage

func (*SubmitResponse) ProtoMessage()

func (*SubmitResponse) Reset

func (m *SubmitResponse) Reset()

func (*SubmitResponse) String

func (m *SubmitResponse) String() string

func (*SubmitResponse) XXX_DiscardUnknown

func (m *SubmitResponse) XXX_DiscardUnknown()

func (*SubmitResponse) XXX_Marshal

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

func (*SubmitResponse) XXX_Merge

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

func (*SubmitResponse) XXX_Size

func (m *SubmitResponse) XXX_Size() int

func (*SubmitResponse) XXX_Unmarshal

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL