logsmd

package
v3.4.1 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthLogsmd = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLogsmd   = 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_TIMESTAMP",
	3: "COLUMN_TYPE_METADATA",
	4: "COLUMN_TYPE_MESSAGE",
}
View Source 
var ColumnType_value = map[string]int32{
	"COLUMN_TYPE_UNSPECIFIED": 0,
	"COLUMN_TYPE_STREAM_ID":   1,
	"COLUMN_TYPE_TIMESTAMP":   2,
	"COLUMN_TYPE_METADATA":    3,
	"COLUMN_TYPE_MESSAGE":     4,
}

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.logs.v1.ColumnType" json:"type,omitempty"`
}

ColumnDesc describes an individual column within the logs 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 logs column can have. 

const (
	// Invalid column type.
	COLUMN_TYPE_UNSPECIFIED ColumnType = 0
	// COLUMN_TYPE_STREAM_ID is a column containing the stream the log record
	// belongs to.
	COLUMN_TYPE_STREAM_ID ColumnType = 1
	// COLUMN_TYPE_TIMESTAMP is a column containing the timestamp of the log
	// record.
	COLUMN_TYPE_TIMESTAMP ColumnType = 2
	// COLUMN_TYPE_METADATA is a column containing structured metadata values for
	// a specific key.
	COLUMN_TYPE_METADATA ColumnType = 3
	// COLUMN_TYPE_MESSAGE is a column containing the message of the log record.
	COLUMN_TYPE_MESSAGE ColumnType = 4
)

func (ColumnType) EnumDescriptor 

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

func (ColumnType) String 

func (x ColumnType) String() string

type Metadata 

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

Metadata describes the metadata for the logs 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.