orderer

package
v0.0.0-...-d2b4260 Latest Latest
Warning

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

Go to latest
Published: Aug 22, 2019 License: Apache-2.0 Imports: 6 Imported by: 23

Documentation

Index

Constants

This section is empty.

Variables

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

Types

type AtomicBroadcastClient

type AtomicBroadcastClient interface {
	// broadcast receives a reply of Acknowledgement for each common.Envelope in order, indicating success or type of failure
	Broadcast(ctx context.Context, opts ...grpc.CallOption) (AtomicBroadcast_BroadcastClient, error)
	// deliver first requires an Envelope of type DELIVER_SEEK_INFO with Payload data as a mashaled SeekInfo message, then a stream of block replies is received.
	Deliver(ctx context.Context, opts ...grpc.CallOption) (AtomicBroadcast_DeliverClient, error)
}

AtomicBroadcastClient is the client API for AtomicBroadcast service.

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

func NewAtomicBroadcastClient

func NewAtomicBroadcastClient(cc *grpc.ClientConn) AtomicBroadcastClient

type AtomicBroadcastServer

type AtomicBroadcastServer interface {
	// broadcast receives a reply of Acknowledgement for each common.Envelope in order, indicating success or type of failure
	Broadcast(AtomicBroadcast_BroadcastServer) error
	// deliver first requires an Envelope of type DELIVER_SEEK_INFO with Payload data as a mashaled SeekInfo message, then a stream of block replies is received.
	Deliver(AtomicBroadcast_DeliverServer) error
}

AtomicBroadcastServer is the server API for AtomicBroadcast service.

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 {
	// 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,proto3" 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,proto3" 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,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 {
	// Any duration string parseable by ParseDuration():
	// https://golang.org/pkg/time/#ParseDuration
	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 code, which may be used to programatically respond to success/failure
	Status common.Status `protobuf:"varint,1,opt,name=status,proto3,enum=sdk.common.Status" json:"status,omitempty"`
	// Info string which may contain additional information about the status returned
	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:"-"`
}

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

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 ConsensusType

type ConsensusType struct {
	// The consensus type: "solo", "kafka" or "etcdraft".
	Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	// Opaque metadata, dependent on the consensus type.
	Metadata []byte `protobuf:"bytes,2,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// The state signals the ordering service to go into maintenance mode, typically for consensus-type migration.
	State                ConsensusType_State `protobuf:"varint,3,opt,name=state,proto3,enum=sdk.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) 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 ConsensusType_State

type ConsensusType_State int32

State defines the orderer mode of operation, typically for consensus-type migration. NORMAL is during normal operation, when consensus-type migration is not, and can not, take place. MAINTENANCE is when the consensus-type can be changed.

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 {
	// Types that are valid to be assigned to Type:
	//	*DeliverResponse_Status
	//	*DeliverResponse_Block
	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{}

XXX_OneofWrappers is for the internal use of the proto package.

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=sdk.common.Status,oneof"`
}

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,proto3" json:"brokers,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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

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 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=sdk.orderer.SeekInfo_SeekBehavior" json:"behavior,omitempty"`
	ErrorResponse        SeekInfo_SeekErrorResponse `` /* 145-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

SeekInfo specifies the range of requested blocks to return If the start position is not found, an error is immediately returned Otherwise, blocks are returned until a missing block is encountered, then behavior is dictated by the SeekBehavior specified.

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

If BLOCK_UNTIL_READY is specified, the reply will block until the requested blocks are available, if FAIL_IF_NOT_READY is specified, the reply will return an error indicating that the block is not found. To request that all blocks be returned indefinitely as they are created, behavior should be set to BLOCK_UNTIL_READY and the stop should be set to specified with a number of MAX_UINT64

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

SeekErrorTolerance indicates to the server how block provider errors should be tolerated. By default, if the deliver service detects a problem in the underlying block source (typically, in the orderer, a consenter error), it will begin to reject deliver requests. This is to prevent a client from waiting for blocks from an orderer which is stuck in an errored state. This is almost always the desired behavior and clients should stick with the default STRICT checking behavior. However, in some scenarios, particularly when attempting to recover from a crash or other corruption, it's desirable to force an orderer to respond with blocks on a best effort basis, even if the backing consensus implementation is in an errored state. In this case, set the SeekErrorResponse to BEST_EFFORT to ignore the consenter errors.

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 {
	// Types that are valid to be assigned to Type:
	//	*SeekPosition_Newest
	//	*SeekPosition_Oldest
	//	*SeekPosition_Specified
	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{}

XXX_OneofWrappers is for the internal use of the proto package.

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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