Help us shape the future of Go! Take the 2026 Go Developer Survey

proto

package
v3.7.9 Latest Latest
Warning

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

 Go to latest Published: Oct 20, 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.