fastpb

package
v1.25.4-rc-multipart Latest Latest
Warning

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

Go to latest
Published: Mar 23, 2021 License: AGPL-3.0 Imports: 8 Imported by: 0

Documentation

Overview

Package fastpb contains generated marshaling for Pointers.

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthPointerdb = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowPointerdb   = fmt.Errorf("proto: integer overflow")
)
View Source
var Pointer_DataType_name = map[int32]string{
	0: "INLINE",
	1: "REMOTE",
}
View Source
var Pointer_DataType_value = map[string]int32{
	"INLINE": 0,
	"REMOTE": 1,
}
View Source
var RedundancyScheme_SchemeType_name = map[int32]string{
	0: "INVALID",
	1: "RS",
}
View Source
var RedundancyScheme_SchemeType_value = map[string]int32{
	"INVALID": 0,
	"RS":      1,
}

Functions

This section is empty.

Types

type NodeID

type NodeID = storj.NodeID

NodeID is a unique node identifier.

type PieceID

type PieceID = storj.PieceID

PieceID is a unique identifier for pieces.

type Pointer

type Pointer struct {
	Type           Pointer_DataType `protobuf:"varint,1,opt,name=type,proto3,enum=fastpb.Pointer_DataType" json:"type,omitempty"`
	InlineSegment  []byte           `protobuf:"bytes,3,opt,name=inline_segment,json=inlineSegment,proto3" json:"inline_segment,omitempty"`
	Remote         *RemoteSegment   `protobuf:"bytes,4,opt,name=remote,proto3" json:"remote,omitempty"`
	SegmentSize    int64            `protobuf:"varint,5,opt,name=segment_size,json=segmentSize,proto3" json:"segment_size,omitempty"`
	CreationDate   time.Time        `protobuf:"bytes,6,opt,name=creation_date,json=creationDate,proto3,stdtime" json:"creation_date"`
	ExpirationDate time.Time        `protobuf:"bytes,7,opt,name=expiration_date,json=expirationDate,proto3,stdtime" json:"expiration_date"`
	Metadata       []byte           `protobuf:"bytes,8,opt,name=metadata,proto3" json:"metadata,omitempty"`
}

func (*Pointer) Descriptor

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

func (*Pointer) GetCreationDate

func (m *Pointer) GetCreationDate() time.Time

func (*Pointer) GetExpirationDate

func (m *Pointer) GetExpirationDate() time.Time

func (*Pointer) GetInlineSegment

func (m *Pointer) GetInlineSegment() []byte

func (*Pointer) GetMetadata

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

func (*Pointer) GetRemote

func (m *Pointer) GetRemote() *RemoteSegment

func (*Pointer) GetSegmentSize

func (m *Pointer) GetSegmentSize() int64

func (*Pointer) GetType

func (m *Pointer) GetType() Pointer_DataType

func (*Pointer) Marshal

func (m *Pointer) Marshal() (dAtA []byte, err error)

func (*Pointer) MarshalTo

func (m *Pointer) MarshalTo(dAtA []byte) (int, error)

func (*Pointer) MarshalToSizedBuffer

func (m *Pointer) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Pointer) ProtoMessage

func (*Pointer) ProtoMessage()

func (*Pointer) Reset

func (m *Pointer) Reset()

func (*Pointer) Size

func (m *Pointer) Size() (n int)

func (*Pointer) String

func (m *Pointer) String() string

func (*Pointer) Unmarshal

func (m *Pointer) Unmarshal(dAtA []byte) error

func (*Pointer) XXX_DiscardUnknown

func (m *Pointer) XXX_DiscardUnknown()

func (*Pointer) XXX_Marshal

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

func (*Pointer) XXX_Merge

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

func (*Pointer) XXX_Size

func (m *Pointer) XXX_Size() int

func (*Pointer) XXX_Unmarshal

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

type Pointer_DataType

type Pointer_DataType int32
const (
	Pointer_INLINE Pointer_DataType = 0
	Pointer_REMOTE Pointer_DataType = 1
)

func (Pointer_DataType) EnumDescriptor

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

func (Pointer_DataType) String

func (x Pointer_DataType) String() string

type RedundancyScheme

type RedundancyScheme struct {
	Type RedundancyScheme_SchemeType `protobuf:"varint,1,opt,name=type,proto3,enum=fastpb.RedundancyScheme_SchemeType" json:"type,omitempty"`
	// these values apply to RS encoding
	MinReq           int32 `protobuf:"varint,2,opt,name=min_req,json=minReq,proto3" json:"min_req,omitempty"`
	Total            int32 `protobuf:"varint,3,opt,name=total,proto3" json:"total,omitempty"`
	RepairThreshold  int32 `protobuf:"varint,4,opt,name=repair_threshold,json=repairThreshold,proto3" json:"repair_threshold,omitempty"`
	SuccessThreshold int32 `protobuf:"varint,5,opt,name=success_threshold,json=successThreshold,proto3" json:"success_threshold,omitempty"`
	ErasureShareSize int32 `protobuf:"varint,6,opt,name=erasure_share_size,json=erasureShareSize,proto3" json:"erasure_share_size,omitempty"`
}

func (*RedundancyScheme) Descriptor

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

func (*RedundancyScheme) GetErasureShareSize

func (m *RedundancyScheme) GetErasureShareSize() int32

func (*RedundancyScheme) GetMinReq

func (m *RedundancyScheme) GetMinReq() int32

func (*RedundancyScheme) GetRepairThreshold

func (m *RedundancyScheme) GetRepairThreshold() int32

func (*RedundancyScheme) GetSuccessThreshold

func (m *RedundancyScheme) GetSuccessThreshold() int32

func (*RedundancyScheme) GetTotal

func (m *RedundancyScheme) GetTotal() int32

func (*RedundancyScheme) GetType

func (*RedundancyScheme) Marshal

func (m *RedundancyScheme) Marshal() (dAtA []byte, err error)

func (*RedundancyScheme) MarshalTo

func (m *RedundancyScheme) MarshalTo(dAtA []byte) (int, error)

func (*RedundancyScheme) MarshalToSizedBuffer

func (m *RedundancyScheme) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RedundancyScheme) ProtoMessage

func (*RedundancyScheme) ProtoMessage()

func (*RedundancyScheme) Reset

func (m *RedundancyScheme) Reset()

func (*RedundancyScheme) Size

func (m *RedundancyScheme) Size() (n int)

func (*RedundancyScheme) String

func (m *RedundancyScheme) String() string

func (*RedundancyScheme) Unmarshal

func (m *RedundancyScheme) Unmarshal(dAtA []byte) error

func (*RedundancyScheme) XXX_DiscardUnknown

func (m *RedundancyScheme) XXX_DiscardUnknown()

func (*RedundancyScheme) XXX_Marshal

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

func (*RedundancyScheme) XXX_Merge

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

func (*RedundancyScheme) XXX_Size

func (m *RedundancyScheme) XXX_Size() int

func (*RedundancyScheme) XXX_Unmarshal

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

type RedundancyScheme_SchemeType

type RedundancyScheme_SchemeType int32
const (
	RedundancyScheme_INVALID RedundancyScheme_SchemeType = 0
	RedundancyScheme_RS      RedundancyScheme_SchemeType = 1
)

func (RedundancyScheme_SchemeType) EnumDescriptor

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

func (RedundancyScheme_SchemeType) String

type RemotePiece

type RemotePiece struct {
	PieceNum int32  `protobuf:"varint,1,opt,name=piece_num,json=pieceNum,proto3" json:"piece_num,omitempty"`
	NodeId   NodeID `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3,customtype=NodeID" json:"node_id"`
}

func (*RemotePiece) Descriptor

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

func (*RemotePiece) GetPieceNum

func (m *RemotePiece) GetPieceNum() int32

func (*RemotePiece) Marshal

func (m *RemotePiece) Marshal() (dAtA []byte, err error)

func (*RemotePiece) MarshalTo

func (m *RemotePiece) MarshalTo(dAtA []byte) (int, error)

func (*RemotePiece) MarshalToSizedBuffer

func (m *RemotePiece) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RemotePiece) ProtoMessage

func (*RemotePiece) ProtoMessage()

func (*RemotePiece) Reset

func (m *RemotePiece) Reset()

func (*RemotePiece) Size

func (m *RemotePiece) Size() (n int)

func (*RemotePiece) String

func (m *RemotePiece) String() string

func (*RemotePiece) Unmarshal

func (m *RemotePiece) Unmarshal(dAtA []byte) error

func (*RemotePiece) XXX_DiscardUnknown

func (m *RemotePiece) XXX_DiscardUnknown()

func (*RemotePiece) XXX_Marshal

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

func (*RemotePiece) XXX_Merge

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

func (*RemotePiece) XXX_Size

func (m *RemotePiece) XXX_Size() int

func (*RemotePiece) XXX_Unmarshal

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

type RemoteSegment

type RemoteSegment struct {
	Redundancy   *RedundancyScheme `protobuf:"bytes,1,opt,name=redundancy,proto3" json:"redundancy,omitempty"`
	RootPieceId  PieceID           `protobuf:"bytes,2,opt,name=root_piece_id,json=rootPieceId,proto3,customtype=PieceID" json:"root_piece_id"`
	RemotePieces []RemotePiece     `protobuf:"bytes,3,rep,name=remote_pieces,json=remotePieces,proto3" json:"remote_pieces"`
}

func (*RemoteSegment) Descriptor

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

func (*RemoteSegment) GetRedundancy

func (m *RemoteSegment) GetRedundancy() *RedundancyScheme

func (*RemoteSegment) GetRemotePieces

func (m *RemoteSegment) GetRemotePieces() []RemotePiece

func (*RemoteSegment) Marshal

func (m *RemoteSegment) Marshal() (dAtA []byte, err error)

func (*RemoteSegment) MarshalTo

func (m *RemoteSegment) MarshalTo(dAtA []byte) (int, error)

func (*RemoteSegment) MarshalToSizedBuffer

func (m *RemoteSegment) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RemoteSegment) ProtoMessage

func (*RemoteSegment) ProtoMessage()

func (*RemoteSegment) Reset

func (m *RemoteSegment) Reset()

func (*RemoteSegment) Size

func (m *RemoteSegment) Size() (n int)

func (*RemoteSegment) String

func (m *RemoteSegment) String() string

func (*RemoteSegment) Unmarshal

func (m *RemoteSegment) Unmarshal(dAtA []byte) error

func (*RemoteSegment) XXX_DiscardUnknown

func (m *RemoteSegment) XXX_DiscardUnknown()

func (*RemoteSegment) XXX_Marshal

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

func (*RemoteSegment) XXX_Merge

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

func (*RemoteSegment) XXX_Size

func (m *RemoteSegment) XXX_Size() int

func (*RemoteSegment) XXX_Unmarshal

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

type SegmentMeta

type SegmentMeta struct {
	EncryptedKey []byte `protobuf:"bytes,1,opt,name=encrypted_key,json=encryptedKey,proto3" json:"encrypted_key,omitempty"`
	KeyNonce     []byte `protobuf:"bytes,2,opt,name=key_nonce,json=keyNonce,proto3" json:"key_nonce,omitempty"`
}

func (*SegmentMeta) Descriptor

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

func (*SegmentMeta) GetEncryptedKey

func (m *SegmentMeta) GetEncryptedKey() []byte

func (*SegmentMeta) GetKeyNonce

func (m *SegmentMeta) GetKeyNonce() []byte

func (*SegmentMeta) Marshal

func (m *SegmentMeta) Marshal() (dAtA []byte, err error)

func (*SegmentMeta) MarshalTo

func (m *SegmentMeta) MarshalTo(dAtA []byte) (int, error)

func (*SegmentMeta) MarshalToSizedBuffer

func (m *SegmentMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SegmentMeta) ProtoMessage

func (*SegmentMeta) ProtoMessage()

func (*SegmentMeta) Reset

func (m *SegmentMeta) Reset()

func (*SegmentMeta) Size

func (m *SegmentMeta) Size() (n int)

func (*SegmentMeta) String

func (m *SegmentMeta) String() string

func (*SegmentMeta) Unmarshal

func (m *SegmentMeta) Unmarshal(dAtA []byte) error

func (*SegmentMeta) XXX_DiscardUnknown

func (m *SegmentMeta) XXX_DiscardUnknown()

func (*SegmentMeta) XXX_Marshal

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

func (*SegmentMeta) XXX_Merge

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

func (*SegmentMeta) XXX_Size

func (m *SegmentMeta) XXX_Size() int

func (*SegmentMeta) XXX_Unmarshal

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

type StreamInfo

type StreamInfo struct {
	DeprecatedNumberOfSegments int64  `` /* 144-byte string literal not displayed */
	SegmentsSize               int64  `protobuf:"varint,2,opt,name=segments_size,json=segmentsSize,proto3" json:"segments_size,omitempty"`
	LastSegmentSize            int64  `protobuf:"varint,3,opt,name=last_segment_size,json=lastSegmentSize,proto3" json:"last_segment_size,omitempty"`
	Metadata                   []byte `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"`
}

func (*StreamInfo) Descriptor

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

func (*StreamInfo) GetDeprecatedNumberOfSegments

func (m *StreamInfo) GetDeprecatedNumberOfSegments() int64

func (*StreamInfo) GetLastSegmentSize

func (m *StreamInfo) GetLastSegmentSize() int64

func (*StreamInfo) GetMetadata

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

func (*StreamInfo) GetSegmentsSize

func (m *StreamInfo) GetSegmentsSize() int64

func (*StreamInfo) Marshal

func (m *StreamInfo) Marshal() (dAtA []byte, err error)

func (*StreamInfo) MarshalTo

func (m *StreamInfo) MarshalTo(dAtA []byte) (int, error)

func (*StreamInfo) MarshalToSizedBuffer

func (m *StreamInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StreamInfo) ProtoMessage

func (*StreamInfo) ProtoMessage()

func (*StreamInfo) Reset

func (m *StreamInfo) Reset()

func (*StreamInfo) Size

func (m *StreamInfo) Size() (n int)

func (*StreamInfo) String

func (m *StreamInfo) String() string

func (*StreamInfo) Unmarshal

func (m *StreamInfo) Unmarshal(dAtA []byte) error

func (*StreamInfo) XXX_DiscardUnknown

func (m *StreamInfo) XXX_DiscardUnknown()

func (*StreamInfo) XXX_Marshal

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

func (*StreamInfo) XXX_Merge

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

func (*StreamInfo) XXX_Size

func (m *StreamInfo) XXX_Size() int

func (*StreamInfo) XXX_Unmarshal

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

type StreamMeta

type StreamMeta struct {
	EncryptedStreamInfo []byte       `protobuf:"bytes,1,opt,name=encrypted_stream_info,json=encryptedStreamInfo,proto3" json:"encrypted_stream_info,omitempty"`
	EncryptionType      int32        `protobuf:"varint,2,opt,name=encryption_type,json=encryptionType,proto3" json:"encryption_type,omitempty"`
	EncryptionBlockSize int32        `protobuf:"varint,3,opt,name=encryption_block_size,json=encryptionBlockSize,proto3" json:"encryption_block_size,omitempty"`
	LastSegmentMeta     *SegmentMeta `protobuf:"bytes,4,opt,name=last_segment_meta,json=lastSegmentMeta,proto3" json:"last_segment_meta,omitempty"`
	NumberOfSegments    int64        `protobuf:"varint,5,opt,name=number_of_segments,json=numberOfSegments,proto3" json:"number_of_segments,omitempty"`
}

func (*StreamMeta) Descriptor

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

func (*StreamMeta) GetEncryptedStreamInfo

func (m *StreamMeta) GetEncryptedStreamInfo() []byte

func (*StreamMeta) GetEncryptionBlockSize

func (m *StreamMeta) GetEncryptionBlockSize() int32

func (*StreamMeta) GetEncryptionType

func (m *StreamMeta) GetEncryptionType() int32

func (*StreamMeta) GetLastSegmentMeta

func (m *StreamMeta) GetLastSegmentMeta() *SegmentMeta

func (*StreamMeta) GetNumberOfSegments

func (m *StreamMeta) GetNumberOfSegments() int64

func (*StreamMeta) Marshal

func (m *StreamMeta) Marshal() (dAtA []byte, err error)

func (*StreamMeta) MarshalTo

func (m *StreamMeta) MarshalTo(dAtA []byte) (int, error)

func (*StreamMeta) MarshalToSizedBuffer

func (m *StreamMeta) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*StreamMeta) ProtoMessage

func (*StreamMeta) ProtoMessage()

func (*StreamMeta) Reset

func (m *StreamMeta) Reset()

func (*StreamMeta) Size

func (m *StreamMeta) Size() (n int)

func (*StreamMeta) String

func (m *StreamMeta) String() string

func (*StreamMeta) Unmarshal

func (m *StreamMeta) Unmarshal(dAtA []byte) error

func (*StreamMeta) XXX_DiscardUnknown

func (m *StreamMeta) XXX_DiscardUnknown()

func (*StreamMeta) XXX_Marshal

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

func (*StreamMeta) XXX_Merge

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

func (*StreamMeta) XXX_Size

func (m *StreamMeta) XXX_Size() int

func (*StreamMeta) XXX_Unmarshal

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

Jump to

Keyboard shortcuts

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