fastpb

package
v1.27.1 Latest Latest
Warning

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

 Go to latest Published: Apr 12, 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 (m *RedundancyScheme) GetType() RedundancyScheme_SchemeType

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 

func (x RedundancyScheme_SchemeType) String() 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

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.