streamsmd

package
v3.4.2 Latest Latest
Warning

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

 Go to latest Published: Feb 14, 2025 License: AGPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthStreamsmd = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStreamsmd   = fmt.Errorf("proto: integer overflow")
)
View Source 
var ColumnType_name = map[int32]string{
	0: "COLUMN_TYPE_UNSPECIFIED",
	1: "COLUMN_TYPE_STREAM_ID",
	2: "COLUMN_TYPE_MIN_TIMESTAMP",
	3: "COLUMN_TYPE_MAX_TIMESTAMP",
	4: "COLUMN_TYPE_LABEL",
	5: "COLUMN_TYPE_ROWS",
}
View Source 
var ColumnType_value = map[string]int32{
	"COLUMN_TYPE_UNSPECIFIED":   0,
	"COLUMN_TYPE_STREAM_ID":     1,
	"COLUMN_TYPE_MIN_TIMESTAMP": 2,
	"COLUMN_TYPE_MAX_TIMESTAMP": 3,
	"COLUMN_TYPE_LABEL":         4,
	"COLUMN_TYPE_ROWS":          5,
}

Functions

This section is empty.

Types

type ColumnDesc 

type ColumnDesc struct {
	// Information about the column.
	Info *datasetmd.ColumnInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	// Column type.
	Type ColumnType `protobuf:"varint,2,opt,name=type,proto3,enum=dataobj.metadata.streams.v1.ColumnType" json:"type,omitempty"`
}

ColumnDesc describes an individual column within the streams table.

func (*ColumnDesc) Descriptor 

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

func (*ColumnDesc) Equal 

func (this *ColumnDesc) Equal(that interface{}) bool

func (*ColumnDesc) GetInfo 

func (m *ColumnDesc) GetInfo() *datasetmd.ColumnInfo

func (*ColumnDesc) GetType 

func (m *ColumnDesc) GetType() ColumnType

func (*ColumnDesc) GoString 

func (this *ColumnDesc) GoString() string

func (*ColumnDesc) Marshal 

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

func (*ColumnDesc) MarshalTo 

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

func (*ColumnDesc) MarshalToSizedBuffer 

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

func (*ColumnDesc) ProtoMessage 

func (*ColumnDesc) ProtoMessage()

func (*ColumnDesc) Reset 

func (m *ColumnDesc) Reset()

func (*ColumnDesc) Size 

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

func (*ColumnDesc) String 

func (this *ColumnDesc) String() string

func (*ColumnDesc) Unmarshal 

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

func (*ColumnDesc) XXX_DiscardUnknown 

func (m *ColumnDesc) XXX_DiscardUnknown()

func (*ColumnDesc) XXX_Marshal 

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

func (*ColumnDesc) XXX_Merge 

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

func (*ColumnDesc) XXX_Size 

func (m *ColumnDesc) XXX_Size() int

func (*ColumnDesc) XXX_Unmarshal 

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

type ColumnMetadata 

type ColumnMetadata struct {
	// Pages within the column.
	Pages []*PageDesc `protobuf:"bytes,1,rep,name=pages,proto3" json:"pages,omitempty"`
}

ColumnMetadata describes the metadata for a column.

func (*ColumnMetadata) Descriptor 

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

func (*ColumnMetadata) Equal 

func (this *ColumnMetadata) Equal(that interface{}) bool

func (*ColumnMetadata) GetPages 

func (m *ColumnMetadata) GetPages() []*PageDesc

func (*ColumnMetadata) GoString 

func (this *ColumnMetadata) GoString() string

func (*ColumnMetadata) Marshal 

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

func (*ColumnMetadata) MarshalTo 

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

func (*ColumnMetadata) MarshalToSizedBuffer 

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

func (*ColumnMetadata) ProtoMessage 

func (*ColumnMetadata) ProtoMessage()

func (*ColumnMetadata) Reset 

func (m *ColumnMetadata) Reset()

func (*ColumnMetadata) Size 

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

func (*ColumnMetadata) String 

func (this *ColumnMetadata) String() string

func (*ColumnMetadata) Unmarshal 

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

func (*ColumnMetadata) XXX_DiscardUnknown 

func (m *ColumnMetadata) XXX_DiscardUnknown()

func (*ColumnMetadata) XXX_Marshal 

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

func (*ColumnMetadata) XXX_Merge 

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

func (*ColumnMetadata) XXX_Size 

func (m *ColumnMetadata) XXX_Size() int

func (*ColumnMetadata) XXX_Unmarshal 

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

type ColumnType 

type ColumnType int32

ColumnType represents the valid types that a stream's column can have. 

const (
	// Invalid column type.
	COLUMN_TYPE_UNSPECIFIED ColumnType = 0
	// COLUMN_TYPE_STREAM_ID is a column containing the stream ID. Stream IDs are
	// unique across the entire data object.
	COLUMN_TYPE_STREAM_ID ColumnType = 1
	// COLUMN_TYPE_MIN_TIMESTAMP is a column containing the minimum timestamp of
	// a stream.
	COLUMN_TYPE_MIN_TIMESTAMP ColumnType = 2
	// COLUMN_TYPE_MAX_TIMESTAMP is a column containing the maximum timestamp of
	// a stream.
	COLUMN_TYPE_MAX_TIMESTAMP ColumnType = 3
	// COLUMN_TYPE_LABEL is a column containing a label.
	COLUMN_TYPE_LABEL ColumnType = 4
	// COLUMN_TYPE_ROWS is a column indicating the number of rows for a stream.
	COLUMN_TYPE_ROWS ColumnType = 5
)

func (ColumnType) EnumDescriptor 

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

func (ColumnType) String 

func (x ColumnType) String() string

type Metadata 

type Metadata struct {
	// Columns within the stream.
	Columns []*ColumnDesc `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
}

Metadata describes the metadata for the streams section.

func (*Metadata) Descriptor 

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

func (*Metadata) Equal 

func (this *Metadata) Equal(that interface{}) bool

func (*Metadata) GetColumns 

func (m *Metadata) GetColumns() []*ColumnDesc

func (*Metadata) GoString 

func (this *Metadata) GoString() string

func (*Metadata) Marshal 

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

func (*Metadata) MarshalTo 

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

func (*Metadata) MarshalToSizedBuffer 

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

func (*Metadata) ProtoMessage 

func (*Metadata) ProtoMessage()

func (*Metadata) Reset 

func (m *Metadata) Reset()

func (*Metadata) Size 

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

func (*Metadata) String 

func (this *Metadata) String() string

func (*Metadata) Unmarshal 

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

func (*Metadata) XXX_DiscardUnknown 

func (m *Metadata) XXX_DiscardUnknown()

func (*Metadata) XXX_Marshal 

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

func (*Metadata) XXX_Merge 

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

func (*Metadata) XXX_Size 

func (m *Metadata) XXX_Size() int

func (*Metadata) XXX_Unmarshal 

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

type PageDesc 

type PageDesc struct {
	// Information about the page.
	Info *datasetmd.PageInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
}

PageDesc describes an individual page within a column.

func (*PageDesc) Descriptor 

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

func (*PageDesc) Equal 

func (this *PageDesc) Equal(that interface{}) bool

func (*PageDesc) GetInfo 

func (m *PageDesc) GetInfo() *datasetmd.PageInfo

func (*PageDesc) GoString 

func (this *PageDesc) GoString() string

func (*PageDesc) Marshal 

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

func (*PageDesc) MarshalTo 

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

func (*PageDesc) MarshalToSizedBuffer 

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

func (*PageDesc) ProtoMessage 

func (*PageDesc) ProtoMessage()

func (*PageDesc) Reset 

func (m *PageDesc) Reset()

func (*PageDesc) Size 

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

func (*PageDesc) String 

func (this *PageDesc) String() string

func (*PageDesc) Unmarshal 

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

func (*PageDesc) XXX_DiscardUnknown 

func (m *PageDesc) XXX_DiscardUnknown()

func (*PageDesc) XXX_Marshal 

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

func (*PageDesc) XXX_Merge 

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

func (*PageDesc) XXX_Size 

func (m *PageDesc) XXX_Size() int

func (*PageDesc) XXX_Unmarshal 

func (m *PageDesc) 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.