proto

package
v3.7.1 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCompaction = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCompaction   = fmt.Errorf("proto: integer overflow")
)

Functions

This section is empty.

Types

type CompactionJob 

type CompactionJob struct {
	// Source either defines a single-tenant source to build single-tenant object(s) or read multi-tenant source to build multi-tenant object(s).
	//
	// Types that are valid to be assigned to Source:
	//
	//	*CompactionJob_SingleTenant
	//	*CompactionJob_MultiTenant
	Source          isCompactionJob_Source `protobuf_oneof:"Source"`
	TargetSizeBytes int64                  `protobuf:"varint,3,opt,name=TargetSizeBytes,proto3" json:"target_size_bytes"`
	// ReadRange defines time-range of logs to read from source for building new objects.
	// It could have either From or Through set to 0 to signify no boundaries on either end.
	ReadRange *TimeRange `protobuf:"bytes,4,opt,name=ReadRange,proto3" json:"read_range"`
}

CompactionJob defines a single compaction job to build one or more DataObjects using the data defined in Source.

func (*CompactionJob) Descriptor 

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

func (*CompactionJob) Equal 

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

func (*CompactionJob) GetMultiTenant 

func (m *CompactionJob) GetMultiTenant() *MultiTenantObjectSource

func (*CompactionJob) GetReadRange 

func (m *CompactionJob) GetReadRange() *TimeRange

func (*CompactionJob) GetSingleTenant 

func (m *CompactionJob) GetSingleTenant() *SingleTenantObjectSourceWithTenantID

func (*CompactionJob) GetSource 

func (m *CompactionJob) GetSource() isCompactionJob_Source

func (*CompactionJob) GetTargetSizeBytes 

func (m *CompactionJob) GetTargetSizeBytes() int64

func (*CompactionJob) GoString 

func (this *CompactionJob) GoString() string

func (*CompactionJob) Marshal 

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

func (*CompactionJob) MarshalTo 

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

func (*CompactionJob) MarshalToSizedBuffer 

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

func (*CompactionJob) ProtoMessage 

func (*CompactionJob) ProtoMessage()

func (*CompactionJob) Reset 

func (m *CompactionJob) Reset()

func (*CompactionJob) Size 

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

func (*CompactionJob) String 

func (this *CompactionJob) String() string

func (*CompactionJob) Unmarshal 

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

func (*CompactionJob) XXX_DiscardUnknown 

func (m *CompactionJob) XXX_DiscardUnknown()

func (*CompactionJob) XXX_Marshal 

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

func (*CompactionJob) XXX_Merge 

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

func (*CompactionJob) XXX_OneofWrappers 

func (*CompactionJob) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*CompactionJob) XXX_Size 

func (m *CompactionJob) XXX_Size() int

func (*CompactionJob) XXX_Unmarshal 

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

type CompactionJobResponse 

type CompactionJobResponse struct {
	Paths []string `protobuf:"bytes,1,rep,name=Paths,proto3" json:"paths"`
}

func (*CompactionJobResponse) Descriptor 

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

func (*CompactionJobResponse) Equal 

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

func (*CompactionJobResponse) GetPaths 

func (m *CompactionJobResponse) GetPaths() []string

func (*CompactionJobResponse) GoString 

func (this *CompactionJobResponse) GoString() string

func (*CompactionJobResponse) Marshal 

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

func (*CompactionJobResponse) MarshalTo 

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

func (*CompactionJobResponse) MarshalToSizedBuffer 

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

func (*CompactionJobResponse) ProtoMessage 

func (*CompactionJobResponse) ProtoMessage()

func (*CompactionJobResponse) Reset 

func (m *CompactionJobResponse) Reset()

func (*CompactionJobResponse) Size 

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

func (*CompactionJobResponse) String 

func (this *CompactionJobResponse) String() string

func (*CompactionJobResponse) Unmarshal 

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

func (*CompactionJobResponse) XXX_DiscardUnknown 

func (m *CompactionJobResponse) XXX_DiscardUnknown()

func (*CompactionJobResponse) XXX_Marshal 

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

func (*CompactionJobResponse) XXX_Merge 

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

func (*CompactionJobResponse) XXX_Size 

func (m *CompactionJobResponse) XXX_Size() int

func (*CompactionJobResponse) XXX_Unmarshal 

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

type CompactionJob_MultiTenant 

type CompactionJob_MultiTenant struct {
	MultiTenant *MultiTenantObjectSource `protobuf:"bytes,2,opt,name=MultiTenant,proto3,oneof"`
}

func (*CompactionJob_MultiTenant) Equal 

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

func (*CompactionJob_MultiTenant) GoString 

func (this *CompactionJob_MultiTenant) GoString() string

func (*CompactionJob_MultiTenant) MarshalTo 

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

func (*CompactionJob_MultiTenant) MarshalToSizedBuffer 

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

func (*CompactionJob_MultiTenant) Size 

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

func (*CompactionJob_MultiTenant) String 

func (this *CompactionJob_MultiTenant) String() string

type CompactionJob_SingleTenant 

type CompactionJob_SingleTenant struct {
	SingleTenant *SingleTenantObjectSourceWithTenantID `protobuf:"bytes,1,opt,name=SingleTenant,proto3,oneof"`
}

func (*CompactionJob_SingleTenant) Equal 

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

func (*CompactionJob_SingleTenant) GoString 

func (this *CompactionJob_SingleTenant) GoString() string

func (*CompactionJob_SingleTenant) MarshalTo 

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

func (*CompactionJob_SingleTenant) MarshalToSizedBuffer 

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

func (*CompactionJob_SingleTenant) Size 

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

func (*CompactionJob_SingleTenant) String 

func (this *CompactionJob_SingleTenant) String() string

type CompactionManifest 

type CompactionManifest struct {
	TimeRange       *TimeRange `protobuf:"bytes,1,opt,name=TimeRange,proto3" json:"time_range"`
	TargetSizeBytes int64      `protobuf:"varint,2,opt,name=TargetSizeBytes,proto3" json:"target_size_bytes"`
	SourceIndexes   []string   `protobuf:"bytes,3,rep,name=SourceIndexes,proto3" json:"source_indexes"`
}

CompactionManifest represents the completion of compaction planning stage and summarizes the compaction plan. It serves two purposes: 1. Acts as a marker indicating all the relevant data has been scanned for building a compaction plan 2. Stores a summary of data being compacted:

  • Time Range of compaction window
  • Configured target size while planning the compaction
  • List of source indexes considered for planning the compaction

func (*CompactionManifest) Descriptor 

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

func (*CompactionManifest) Equal 

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

func (*CompactionManifest) GetSourceIndexes 

func (m *CompactionManifest) GetSourceIndexes() []string

func (*CompactionManifest) GetTargetSizeBytes 

func (m *CompactionManifest) GetTargetSizeBytes() int64

func (*CompactionManifest) GetTimeRange 

func (m *CompactionManifest) GetTimeRange() *TimeRange

func (*CompactionManifest) GoString 

func (this *CompactionManifest) GoString() string

func (*CompactionManifest) Marshal 

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

func (*CompactionManifest) MarshalTo 

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

func (*CompactionManifest) MarshalToSizedBuffer 

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

func (*CompactionManifest) ProtoMessage 

func (*CompactionManifest) ProtoMessage()

func (*CompactionManifest) Reset 

func (m *CompactionManifest) Reset()

func (*CompactionManifest) Size 

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

func (*CompactionManifest) String 

func (this *CompactionManifest) String() string

func (*CompactionManifest) Unmarshal 

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

func (*CompactionManifest) XXX_DiscardUnknown 

func (m *CompactionManifest) XXX_DiscardUnknown()

func (*CompactionManifest) XXX_Marshal 

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

func (*CompactionManifest) XXX_Merge 

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

func (*CompactionManifest) XXX_Size 

func (m *CompactionManifest) XXX_Size() int

func (*CompactionManifest) XXX_Unmarshal 

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

type IndexInfo 

type IndexInfo struct {
	Tenant    string     `protobuf:"bytes,1,opt,name=Tenant,proto3" json:"tenant"`
	Path      string     `protobuf:"bytes,2,opt,name=Path,proto3" json:"path"`
	TimeRange *TimeRange `protobuf:"bytes,3,opt,name=TimeRange,proto3" json:"time_range"`
}

func (*IndexInfo) Descriptor 

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

func (*IndexInfo) Equal 

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

func (*IndexInfo) GetPath 

func (m *IndexInfo) GetPath() string

func (*IndexInfo) GetTenant 

func (m *IndexInfo) GetTenant() string

func (*IndexInfo) GetTimeRange 

func (m *IndexInfo) GetTimeRange() *TimeRange

func (*IndexInfo) GoString 

func (this *IndexInfo) GoString() string

func (*IndexInfo) Marshal 

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

func (*IndexInfo) MarshalTo 

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

func (*IndexInfo) MarshalToSizedBuffer 

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

func (*IndexInfo) ProtoMessage 

func (*IndexInfo) ProtoMessage()

func (*IndexInfo) Reset 

func (m *IndexInfo) Reset()

func (*IndexInfo) Size 

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

func (*IndexInfo) String 

func (this *IndexInfo) String() string

func (*IndexInfo) Unmarshal 

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

func (*IndexInfo) XXX_DiscardUnknown 

func (m *IndexInfo) XXX_DiscardUnknown()

func (*IndexInfo) XXX_Marshal 

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

func (*IndexInfo) XXX_Merge 

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

func (*IndexInfo) XXX_Size 

func (m *IndexInfo) XXX_Size() int

func (*IndexInfo) XXX_Unmarshal 

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

type IndexingJob 

type IndexingJob struct {
	Paths []string `protobuf:"bytes,1,rep,name=Paths,proto3" json:"paths"`
}

func (*IndexingJob) Descriptor 

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

func (*IndexingJob) Equal 

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

func (*IndexingJob) GetPaths 

func (m *IndexingJob) GetPaths() []string

func (*IndexingJob) GoString 

func (this *IndexingJob) GoString() string

func (*IndexingJob) Marshal 

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

func (*IndexingJob) MarshalTo 

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

func (*IndexingJob) MarshalToSizedBuffer 

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

func (*IndexingJob) ProtoMessage 

func (*IndexingJob) ProtoMessage()

func (*IndexingJob) Reset 

func (m *IndexingJob) Reset()

func (*IndexingJob) Size 

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

func (*IndexingJob) String 

func (this *IndexingJob) String() string

func (*IndexingJob) Unmarshal 

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

func (*IndexingJob) XXX_DiscardUnknown 

func (m *IndexingJob) XXX_DiscardUnknown()

func (*IndexingJob) XXX_Marshal 

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

func (*IndexingJob) XXX_Merge 

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

func (*IndexingJob) XXX_Size 

func (m *IndexingJob) XXX_Size() int

func (*IndexingJob) XXX_Unmarshal 

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

type IndexingJobResponse 

type IndexingJobResponse struct {
	Indexes []*IndexInfo `protobuf:"bytes,1,rep,name=Indexes,proto3" json:"indexes"`
}

func (*IndexingJobResponse) Descriptor 

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

func (*IndexingJobResponse) Equal 

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

func (*IndexingJobResponse) GetIndexes 

func (m *IndexingJobResponse) GetIndexes() []*IndexInfo

func (*IndexingJobResponse) GoString 

func (this *IndexingJobResponse) GoString() string

func (*IndexingJobResponse) Marshal 

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

func (*IndexingJobResponse) MarshalTo 

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

func (*IndexingJobResponse) MarshalToSizedBuffer 

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

func (*IndexingJobResponse) ProtoMessage 

func (*IndexingJobResponse) ProtoMessage()

func (*IndexingJobResponse) Reset 

func (m *IndexingJobResponse) Reset()

func (*IndexingJobResponse) Size 

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

func (*IndexingJobResponse) String 

func (this *IndexingJobResponse) String() string

func (*IndexingJobResponse) Unmarshal 

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

func (*IndexingJobResponse) XXX_DiscardUnknown 

func (m *IndexingJobResponse) XXX_DiscardUnknown()

func (*IndexingJobResponse) XXX_Marshal 

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

func (*IndexingJobResponse) XXX_Merge 

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

func (*IndexingJobResponse) XXX_Size 

func (m *IndexingJobResponse) XXX_Size() int

func (*IndexingJobResponse) XXX_Unmarshal 

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

type MultiTenantObjectSource 

type MultiTenantObjectSource struct {
	TenantStreams    []*TenantStream `protobuf:"bytes,1,rep,name=TenantStreams,proto3" json:"tenant_streams"`
	NumOutputObjects int32           `protobuf:"varint,2,opt,name=NumOutputObjects,proto3" json:"num_output_objects"`
}

MultiTenantObjectSource holds all the required info to build one or more multi-tenant output objects. To avoid repetition, common info like time-range and target size of objects are to be referenced from CompactionManifest and added separately where relevant.

func (*MultiTenantObjectSource) Descriptor 

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

func (*MultiTenantObjectSource) Equal 

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

func (*MultiTenantObjectSource) GetNumOutputObjects 

func (m *MultiTenantObjectSource) GetNumOutputObjects() int32

func (*MultiTenantObjectSource) GetTenantStreams 

func (m *MultiTenantObjectSource) GetTenantStreams() []*TenantStream

func (*MultiTenantObjectSource) GoString 

func (this *MultiTenantObjectSource) GoString() string

func (*MultiTenantObjectSource) Marshal 

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

func (*MultiTenantObjectSource) MarshalTo 

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

func (*MultiTenantObjectSource) MarshalToSizedBuffer 

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

func (*MultiTenantObjectSource) ProtoMessage 

func (*MultiTenantObjectSource) ProtoMessage()

func (*MultiTenantObjectSource) Reset 

func (m *MultiTenantObjectSource) Reset()

func (*MultiTenantObjectSource) Size 

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

func (*MultiTenantObjectSource) String 

func (this *MultiTenantObjectSource) String() string

func (*MultiTenantObjectSource) Unmarshal 

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

func (*MultiTenantObjectSource) XXX_DiscardUnknown 

func (m *MultiTenantObjectSource) XXX_DiscardUnknown()

func (*MultiTenantObjectSource) XXX_Marshal 

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

func (*MultiTenantObjectSource) XXX_Merge 

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

func (*MultiTenantObjectSource) XXX_Size 

func (m *MultiTenantObjectSource) XXX_Size() int

func (*MultiTenantObjectSource) XXX_Unmarshal 

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

type SingleTenantObjectSource 

type SingleTenantObjectSource struct {
	Streams          []*Stream `protobuf:"bytes,1,rep,name=Streams,proto3" json:"streams"`
	NumOutputObjects int32     `protobuf:"varint,2,opt,name=NumOutputObjects,proto3" json:"num_output_objects"`
}

SingleTenantObjectSource holds all the required info to build one or more output objects for a single tenant. To avoid repetition, common info like time-range and target size of objects are to be referenced from CompactionManifest and added separately where relevant.

func (*SingleTenantObjectSource) Descriptor 

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

func (*SingleTenantObjectSource) Equal 

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

func (*SingleTenantObjectSource) GetNumOutputObjects 

func (m *SingleTenantObjectSource) GetNumOutputObjects() int32

func (*SingleTenantObjectSource) GetStreams 

func (m *SingleTenantObjectSource) GetStreams() []*Stream

func (*SingleTenantObjectSource) GoString 

func (this *SingleTenantObjectSource) GoString() string

func (*SingleTenantObjectSource) Marshal 

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

func (*SingleTenantObjectSource) MarshalTo 

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

func (*SingleTenantObjectSource) MarshalToSizedBuffer 

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

func (*SingleTenantObjectSource) ProtoMessage 

func (*SingleTenantObjectSource) ProtoMessage()

func (*SingleTenantObjectSource) Reset 

func (m *SingleTenantObjectSource) Reset()

func (*SingleTenantObjectSource) Size 

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

func (*SingleTenantObjectSource) String 

func (this *SingleTenantObjectSource) String() string

func (*SingleTenantObjectSource) Unmarshal 

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

func (*SingleTenantObjectSource) XXX_DiscardUnknown 

func (m *SingleTenantObjectSource) XXX_DiscardUnknown()

func (*SingleTenantObjectSource) XXX_Marshal 

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

func (*SingleTenantObjectSource) XXX_Merge 

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

func (*SingleTenantObjectSource) XXX_Size 

func (m *SingleTenantObjectSource) XXX_Size() int

func (*SingleTenantObjectSource) XXX_Unmarshal 

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

type SingleTenantObjectSourceWithTenantID 

type SingleTenantObjectSourceWithTenantID struct {
	Tenant string                    `protobuf:"bytes,1,opt,name=Tenant,proto3" json:"tenant"`
	Source *SingleTenantObjectSource `protobuf:"bytes,2,opt,name=Source,proto3" json:"source"`
}

func (*SingleTenantObjectSourceWithTenantID) Descriptor 

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

func (*SingleTenantObjectSourceWithTenantID) Equal 

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

func (*SingleTenantObjectSourceWithTenantID) GetSource 

func (m *SingleTenantObjectSourceWithTenantID) GetSource() *SingleTenantObjectSource

func (*SingleTenantObjectSourceWithTenantID) GetTenant 

func (m *SingleTenantObjectSourceWithTenantID) GetTenant() string

func (*SingleTenantObjectSourceWithTenantID) GoString 

func (this *SingleTenantObjectSourceWithTenantID) GoString() string

func (*SingleTenantObjectSourceWithTenantID) Marshal 

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

func (*SingleTenantObjectSourceWithTenantID) MarshalTo 

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

func (*SingleTenantObjectSourceWithTenantID) MarshalToSizedBuffer 

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

func (*SingleTenantObjectSourceWithTenantID) ProtoMessage 

func (*SingleTenantObjectSourceWithTenantID) ProtoMessage()

func (*SingleTenantObjectSourceWithTenantID) Reset 

func (m *SingleTenantObjectSourceWithTenantID) Reset()

func (*SingleTenantObjectSourceWithTenantID) Size 

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

func (*SingleTenantObjectSourceWithTenantID) String 

func (this *SingleTenantObjectSourceWithTenantID) String() string

func (*SingleTenantObjectSourceWithTenantID) Unmarshal 

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

func (*SingleTenantObjectSourceWithTenantID) XXX_DiscardUnknown 

func (m *SingleTenantObjectSourceWithTenantID) XXX_DiscardUnknown()

func (*SingleTenantObjectSourceWithTenantID) XXX_Marshal 

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

func (*SingleTenantObjectSourceWithTenantID) XXX_Merge 

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

func (*SingleTenantObjectSourceWithTenantID) XXX_Size 

func (m *SingleTenantObjectSourceWithTenantID) XXX_Size() int

func (*SingleTenantObjectSourceWithTenantID) XXX_Unmarshal 

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

type Stream 

type Stream struct {
	ID    int64  `protobuf:"varint,1,opt,name=ID,proto3" json:"id"`
	Index string `protobuf:"bytes,2,opt,name=Index,proto3" json:"index"`
}

Stream identifies a single stream from an index. It does not include Tenant ID to let us store group of streams for same Tenant without repeating the ID.

func (*Stream) Descriptor 

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

func (*Stream) Equal 

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

func (*Stream) GetID 

func (m *Stream) GetID() int64

func (*Stream) GetIndex 

func (m *Stream) GetIndex() string

func (*Stream) GoString 

func (this *Stream) GoString() string

func (*Stream) Marshal 

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

func (*Stream) MarshalTo 

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

func (*Stream) MarshalToSizedBuffer 

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

func (*Stream) ProtoMessage 

func (*Stream) ProtoMessage()

func (*Stream) Reset 

func (m *Stream) Reset()

func (*Stream) Size 

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

func (*Stream) String 

func (this *Stream) String() string

func (*Stream) Unmarshal 

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

func (*Stream) XXX_DiscardUnknown 

func (m *Stream) XXX_DiscardUnknown()

func (*Stream) XXX_Marshal 

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

func (*Stream) XXX_Merge 

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

func (*Stream) XXX_Size 

func (m *Stream) XXX_Size() int

func (*Stream) XXX_Unmarshal 

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

type TenantStream 

type TenantStream struct {
	Tenant string  `protobuf:"bytes,1,opt,name=Tenant,proto3" json:"tenant"`
	Stream *Stream `protobuf:"bytes,2,opt,name=Stream,proto3" json:"stream"`
}

TenantStream identifies a single stream from an index belonging to a specific Tenant.

func (*TenantStream) Descriptor 

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

func (*TenantStream) Equal 

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

func (*TenantStream) GetStream 

func (m *TenantStream) GetStream() *Stream

func (*TenantStream) GetTenant 

func (m *TenantStream) GetTenant() string

func (*TenantStream) GoString 

func (this *TenantStream) GoString() string

func (*TenantStream) Marshal 

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

func (*TenantStream) MarshalTo 

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

func (*TenantStream) MarshalToSizedBuffer 

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

func (*TenantStream) ProtoMessage 

func (*TenantStream) ProtoMessage()

func (*TenantStream) Reset 

func (m *TenantStream) Reset()

func (*TenantStream) Size 

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

func (*TenantStream) String 

func (this *TenantStream) String() string

func (*TenantStream) Unmarshal 

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

func (*TenantStream) XXX_DiscardUnknown 

func (m *TenantStream) XXX_DiscardUnknown()

func (*TenantStream) XXX_Marshal 

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

func (*TenantStream) XXX_Merge 

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

func (*TenantStream) XXX_Size 

func (m *TenantStream) XXX_Size() int

func (*TenantStream) XXX_Unmarshal 

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

type TimeRange 

type TimeRange struct {
	From    int64 `protobuf:"varint,1,opt,name=From,proto3" json:"from"`
	Through int64 `protobuf:"varint,2,opt,name=Through,proto3" json:"through"`
}

func (*TimeRange) Descriptor 

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

func (*TimeRange) Equal 

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

func (*TimeRange) GetFrom 

func (m *TimeRange) GetFrom() int64

func (*TimeRange) GetThrough 

func (m *TimeRange) GetThrough() int64

func (*TimeRange) GoString 

func (this *TimeRange) GoString() string

func (*TimeRange) Marshal 

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

func (*TimeRange) MarshalTo 

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

func (*TimeRange) MarshalToSizedBuffer 

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

func (*TimeRange) ProtoMessage 

func (*TimeRange) ProtoMessage()

func (*TimeRange) Reset 

func (m *TimeRange) Reset()

func (*TimeRange) Size 

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

func (*TimeRange) String 

func (this *TimeRange) String() string

func (*TimeRange) Unmarshal 

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

func (*TimeRange) XXX_DiscardUnknown 

func (m *TimeRange) XXX_DiscardUnknown()

func (*TimeRange) XXX_Marshal 

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

func (*TimeRange) XXX_Merge 

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

func (*TimeRange) XXX_Size 

func (m *TimeRange) XXX_Size() int

func (*TimeRange) XXX_Unmarshal 

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