protos

package
v3.3.1 Latest Latest
Warning

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

Go to latest
Published: Dec 4, 2024 License: AGPL-3.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthService = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowService   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthTypes = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTypes   = fmt.Errorf("proto: integer overflow")
)

Functions

func FromProtoDayTableToDayTable added in v3.3.0

func FromProtoDayTableToDayTable(proto DayTable) config.DayTable

func RegisterPlannerForBuilderServer

func RegisterPlannerForBuilderServer(s *grpc.Server, srv PlannerForBuilderServer)

Types

type BuilderToPlanner

type BuilderToPlanner struct {
	BuilderID string          `protobuf:"bytes,1,opt,name=builderID,proto3" json:"builderID,omitempty"`
	Result    ProtoTaskResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result"`
}

func (*BuilderToPlanner) Descriptor

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

func (*BuilderToPlanner) Equal

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

func (*BuilderToPlanner) GetBuilderID

func (m *BuilderToPlanner) GetBuilderID() string

func (*BuilderToPlanner) GetResult

func (m *BuilderToPlanner) GetResult() ProtoTaskResult

func (*BuilderToPlanner) GoString

func (this *BuilderToPlanner) GoString() string

func (*BuilderToPlanner) Marshal

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

func (*BuilderToPlanner) MarshalTo

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

func (*BuilderToPlanner) MarshalToSizedBuffer

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

func (*BuilderToPlanner) ProtoMessage

func (*BuilderToPlanner) ProtoMessage()

func (*BuilderToPlanner) Reset

func (m *BuilderToPlanner) Reset()

func (*BuilderToPlanner) Size

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

func (*BuilderToPlanner) String

func (this *BuilderToPlanner) String() string

func (*BuilderToPlanner) Unmarshal

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

func (*BuilderToPlanner) XXX_DiscardUnknown

func (m *BuilderToPlanner) XXX_DiscardUnknown()

func (*BuilderToPlanner) XXX_Marshal

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

func (*BuilderToPlanner) XXX_Merge

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

func (*BuilderToPlanner) XXX_Size

func (m *BuilderToPlanner) XXX_Size() int

func (*BuilderToPlanner) XXX_Unmarshal

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

type DayTable

type DayTable struct {
	DayTimestampMS int64  `protobuf:"varint,1,opt,name=dayTimestampMS,proto3" json:"dayTimestampMS,omitempty"`
	Prefix         string `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
}

func (*DayTable) Descriptor

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

func (*DayTable) Equal

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

func (*DayTable) GetDayTimestampMS

func (m *DayTable) GetDayTimestampMS() int64

func (*DayTable) GetPrefix

func (m *DayTable) GetPrefix() string

func (*DayTable) GoString

func (this *DayTable) GoString() string

func (*DayTable) Marshal

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

func (*DayTable) MarshalTo

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

func (*DayTable) MarshalToSizedBuffer

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

func (*DayTable) ProtoMessage

func (*DayTable) ProtoMessage()

func (*DayTable) Reset

func (m *DayTable) Reset()

func (*DayTable) Size

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

func (*DayTable) String

func (this *DayTable) String() string

func (*DayTable) Unmarshal

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

func (*DayTable) XXX_DiscardUnknown

func (m *DayTable) XXX_DiscardUnknown()

func (*DayTable) XXX_Marshal

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

func (*DayTable) XXX_Merge

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

func (*DayTable) XXX_Size

func (m *DayTable) XXX_Size() int

func (*DayTable) XXX_Unmarshal

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

type Gap added in v3.2.0

type Gap struct {
	Bounds v1.FingerprintBounds
	Series []*v1.Series
	Blocks []bloomshipper.BlockRef
}

type NotifyBuilderShutdownRequest

type NotifyBuilderShutdownRequest struct {
	BuilderID string `protobuf:"bytes,1,opt,name=builderID,proto3" json:"builderID,omitempty"`
}

func (*NotifyBuilderShutdownRequest) Descriptor

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

func (*NotifyBuilderShutdownRequest) Equal

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

func (*NotifyBuilderShutdownRequest) GetBuilderID

func (m *NotifyBuilderShutdownRequest) GetBuilderID() string

func (*NotifyBuilderShutdownRequest) GoString

func (this *NotifyBuilderShutdownRequest) GoString() string

func (*NotifyBuilderShutdownRequest) Marshal

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

func (*NotifyBuilderShutdownRequest) MarshalTo

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

func (*NotifyBuilderShutdownRequest) MarshalToSizedBuffer

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

func (*NotifyBuilderShutdownRequest) ProtoMessage

func (*NotifyBuilderShutdownRequest) ProtoMessage()

func (*NotifyBuilderShutdownRequest) Reset

func (m *NotifyBuilderShutdownRequest) Reset()

func (*NotifyBuilderShutdownRequest) Size

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

func (*NotifyBuilderShutdownRequest) String

func (this *NotifyBuilderShutdownRequest) String() string

func (*NotifyBuilderShutdownRequest) Unmarshal

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

func (*NotifyBuilderShutdownRequest) XXX_DiscardUnknown

func (m *NotifyBuilderShutdownRequest) XXX_DiscardUnknown()

func (*NotifyBuilderShutdownRequest) XXX_Marshal

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

func (*NotifyBuilderShutdownRequest) XXX_Merge

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

func (*NotifyBuilderShutdownRequest) XXX_Size

func (m *NotifyBuilderShutdownRequest) XXX_Size() int

func (*NotifyBuilderShutdownRequest) XXX_Unmarshal

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

type NotifyBuilderShutdownResponse

type NotifyBuilderShutdownResponse struct {
}

func (*NotifyBuilderShutdownResponse) Descriptor

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

func (*NotifyBuilderShutdownResponse) Equal

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

func (*NotifyBuilderShutdownResponse) GoString

func (this *NotifyBuilderShutdownResponse) GoString() string

func (*NotifyBuilderShutdownResponse) Marshal

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

func (*NotifyBuilderShutdownResponse) MarshalTo

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

func (*NotifyBuilderShutdownResponse) MarshalToSizedBuffer

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

func (*NotifyBuilderShutdownResponse) ProtoMessage

func (*NotifyBuilderShutdownResponse) ProtoMessage()

func (*NotifyBuilderShutdownResponse) Reset

func (m *NotifyBuilderShutdownResponse) Reset()

func (*NotifyBuilderShutdownResponse) Size

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

func (*NotifyBuilderShutdownResponse) String

func (this *NotifyBuilderShutdownResponse) String() string

func (*NotifyBuilderShutdownResponse) Unmarshal

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

func (*NotifyBuilderShutdownResponse) XXX_DiscardUnknown

func (m *NotifyBuilderShutdownResponse) XXX_DiscardUnknown()

func (*NotifyBuilderShutdownResponse) XXX_Marshal

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

func (*NotifyBuilderShutdownResponse) XXX_Merge

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

func (*NotifyBuilderShutdownResponse) XXX_Size

func (m *NotifyBuilderShutdownResponse) XXX_Size() int

func (*NotifyBuilderShutdownResponse) XXX_Unmarshal

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

type PlannerForBuilderClient

type PlannerForBuilderClient interface {
	BuilderLoop(ctx context.Context, opts ...grpc.CallOption) (PlannerForBuilder_BuilderLoopClient, error)
	NotifyBuilderShutdown(ctx context.Context, in *NotifyBuilderShutdownRequest, opts ...grpc.CallOption) (*NotifyBuilderShutdownResponse, error)
}

PlannerForBuilderClient is the client API for PlannerForBuilder service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewPlannerForBuilderClient

func NewPlannerForBuilderClient(cc *grpc.ClientConn) PlannerForBuilderClient

type PlannerForBuilderServer

type PlannerForBuilderServer interface {
	BuilderLoop(PlannerForBuilder_BuilderLoopServer) error
	NotifyBuilderShutdown(context.Context, *NotifyBuilderShutdownRequest) (*NotifyBuilderShutdownResponse, error)
}

PlannerForBuilderServer is the server API for PlannerForBuilder service.

type PlannerForBuilder_BuilderLoopClient

type PlannerForBuilder_BuilderLoopClient interface {
	Send(*BuilderToPlanner) error
	Recv() (*PlannerToBuilder, error)
	grpc.ClientStream
}

type PlannerForBuilder_BuilderLoopServer

type PlannerForBuilder_BuilderLoopServer interface {
	Send(*PlannerToBuilder) error
	Recv() (*BuilderToPlanner, error)
	grpc.ServerStream
}

type PlannerToBuilder

type PlannerToBuilder struct {
	Task *ProtoTask `protobuf:"bytes,1,opt,name=task,proto3" json:"task,omitempty"`
}

func (*PlannerToBuilder) Descriptor

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

func (*PlannerToBuilder) Equal

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

func (*PlannerToBuilder) GetTask

func (m *PlannerToBuilder) GetTask() *ProtoTask

func (*PlannerToBuilder) GoString

func (this *PlannerToBuilder) GoString() string

func (*PlannerToBuilder) Marshal

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

func (*PlannerToBuilder) MarshalTo

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

func (*PlannerToBuilder) MarshalToSizedBuffer

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

func (*PlannerToBuilder) ProtoMessage

func (*PlannerToBuilder) ProtoMessage()

func (*PlannerToBuilder) Reset

func (m *PlannerToBuilder) Reset()

func (*PlannerToBuilder) Size

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

func (*PlannerToBuilder) String

func (this *PlannerToBuilder) String() string

func (*PlannerToBuilder) Unmarshal

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

func (*PlannerToBuilder) XXX_DiscardUnknown

func (m *PlannerToBuilder) XXX_DiscardUnknown()

func (*PlannerToBuilder) XXX_Marshal

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

func (*PlannerToBuilder) XXX_Merge

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

func (*PlannerToBuilder) XXX_Size

func (m *PlannerToBuilder) XXX_Size() int

func (*PlannerToBuilder) XXX_Unmarshal

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

type ProtoFingerprintBounds

type ProtoFingerprintBounds struct {
	Min github_com_prometheus_common_model.Fingerprint `protobuf:"varint,1,opt,name=min,proto3,casttype=github.com/prometheus/common/model.Fingerprint" json:"min"`
	Max github_com_prometheus_common_model.Fingerprint `protobuf:"varint,2,opt,name=max,proto3,casttype=github.com/prometheus/common/model.Fingerprint" json:"max"`
}

FPBounds is identical to the definition in `pkg/storage/bloom/v1/bounds.FingerprintBounds` which ensures we can cast between them without allocations. TODO(salvacorts): Reuse from `pkg/logproto/indexgateway.proto`

func (*ProtoFingerprintBounds) Descriptor

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

func (*ProtoFingerprintBounds) Equal

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

func (*ProtoFingerprintBounds) GetMax

func (*ProtoFingerprintBounds) GetMin

func (*ProtoFingerprintBounds) GoString

func (this *ProtoFingerprintBounds) GoString() string

func (*ProtoFingerprintBounds) Marshal

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

func (*ProtoFingerprintBounds) MarshalTo

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

func (*ProtoFingerprintBounds) MarshalToSizedBuffer

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

func (*ProtoFingerprintBounds) ProtoMessage

func (*ProtoFingerprintBounds) ProtoMessage()

func (*ProtoFingerprintBounds) Reset

func (m *ProtoFingerprintBounds) Reset()

func (*ProtoFingerprintBounds) Size

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

func (*ProtoFingerprintBounds) String

func (this *ProtoFingerprintBounds) String() string

func (*ProtoFingerprintBounds) Unmarshal

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

func (*ProtoFingerprintBounds) XXX_DiscardUnknown

func (m *ProtoFingerprintBounds) XXX_DiscardUnknown()

func (*ProtoFingerprintBounds) XXX_Marshal

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

func (*ProtoFingerprintBounds) XXX_Merge

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

func (*ProtoFingerprintBounds) XXX_Size

func (m *ProtoFingerprintBounds) XXX_Size() int

func (*ProtoFingerprintBounds) XXX_Unmarshal

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

type ProtoGapWithBlocks

type ProtoGapWithBlocks struct {
	Bounds   ProtoFingerprintBounds `protobuf:"bytes,1,opt,name=bounds,proto3" json:"bounds"`
	Series   []*ProtoSeries         `protobuf:"bytes,2,rep,name=series,proto3" json:"series,omitempty"`
	BlockRef []string               `protobuf:"bytes,3,rep,name=blockRef,proto3" json:"blockRef,omitempty"`
}

func (*ProtoGapWithBlocks) Descriptor

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

func (*ProtoGapWithBlocks) Equal

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

func (*ProtoGapWithBlocks) GetBlockRef

func (m *ProtoGapWithBlocks) GetBlockRef() []string

func (*ProtoGapWithBlocks) GetBounds

func (*ProtoGapWithBlocks) GetSeries added in v3.2.0

func (m *ProtoGapWithBlocks) GetSeries() []*ProtoSeries

func (*ProtoGapWithBlocks) GoString

func (this *ProtoGapWithBlocks) GoString() string

func (*ProtoGapWithBlocks) Marshal

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

func (*ProtoGapWithBlocks) MarshalTo

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

func (*ProtoGapWithBlocks) MarshalToSizedBuffer

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

func (*ProtoGapWithBlocks) ProtoMessage

func (*ProtoGapWithBlocks) ProtoMessage()

func (*ProtoGapWithBlocks) Reset

func (m *ProtoGapWithBlocks) Reset()

func (*ProtoGapWithBlocks) Size

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

func (*ProtoGapWithBlocks) String

func (this *ProtoGapWithBlocks) String() string

func (*ProtoGapWithBlocks) Unmarshal

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

func (*ProtoGapWithBlocks) XXX_DiscardUnknown

func (m *ProtoGapWithBlocks) XXX_DiscardUnknown()

func (*ProtoGapWithBlocks) XXX_Marshal

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

func (*ProtoGapWithBlocks) XXX_Merge

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

func (*ProtoGapWithBlocks) XXX_Size

func (m *ProtoGapWithBlocks) XXX_Size() int

func (*ProtoGapWithBlocks) XXX_Unmarshal

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

type ProtoMeta

type ProtoMeta struct {
	MetaRef      string   `protobuf:"bytes,1,opt,name=metaRef,proto3" json:"metaRef,omitempty"`
	SourcesTSDBs []string `protobuf:"bytes,2,rep,name=sourcesTSDBs,proto3" json:"sourcesTSDBs,omitempty"`
	BlockRefs    []string `protobuf:"bytes,3,rep,name=blockRefs,proto3" json:"blockRefs,omitempty"`
}

func (*ProtoMeta) Descriptor

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

func (*ProtoMeta) Equal

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

func (*ProtoMeta) GetBlockRefs

func (m *ProtoMeta) GetBlockRefs() []string

func (*ProtoMeta) GetMetaRef

func (m *ProtoMeta) GetMetaRef() string

func (*ProtoMeta) GetSourcesTSDBs

func (m *ProtoMeta) GetSourcesTSDBs() []string

func (*ProtoMeta) GoString

func (this *ProtoMeta) GoString() string

func (*ProtoMeta) Marshal

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

func (*ProtoMeta) MarshalTo

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

func (*ProtoMeta) MarshalToSizedBuffer

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

func (*ProtoMeta) ProtoMessage

func (*ProtoMeta) ProtoMessage()

func (*ProtoMeta) Reset

func (m *ProtoMeta) Reset()

func (*ProtoMeta) Size

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

func (*ProtoMeta) String

func (this *ProtoMeta) String() string

func (*ProtoMeta) Unmarshal

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

func (*ProtoMeta) XXX_DiscardUnknown

func (m *ProtoMeta) XXX_DiscardUnknown()

func (*ProtoMeta) XXX_Marshal

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

func (*ProtoMeta) XXX_Merge

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

func (*ProtoMeta) XXX_Size

func (m *ProtoMeta) XXX_Size() int

func (*ProtoMeta) XXX_Unmarshal

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

type ProtoSeries added in v3.2.0

type ProtoSeries struct {
	Fingerprint uint64               `protobuf:"varint,1,opt,name=fingerprint,proto3" json:"fingerprint,omitempty"`
	Chunks      []*logproto.ShortRef `protobuf:"bytes,2,rep,name=chunks,proto3" json:"chunks,omitempty"`
}

func (*ProtoSeries) Descriptor added in v3.2.0

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

func (*ProtoSeries) Equal added in v3.2.0

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

func (*ProtoSeries) GetChunks added in v3.2.0

func (m *ProtoSeries) GetChunks() []*logproto.ShortRef

func (*ProtoSeries) GetFingerprint added in v3.2.0

func (m *ProtoSeries) GetFingerprint() uint64

func (*ProtoSeries) GoString added in v3.2.0

func (this *ProtoSeries) GoString() string

func (*ProtoSeries) Marshal added in v3.2.0

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

func (*ProtoSeries) MarshalTo added in v3.2.0

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

func (*ProtoSeries) MarshalToSizedBuffer added in v3.2.0

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

func (*ProtoSeries) ProtoMessage added in v3.2.0

func (*ProtoSeries) ProtoMessage()

func (*ProtoSeries) Reset added in v3.2.0

func (m *ProtoSeries) Reset()

func (*ProtoSeries) Size added in v3.2.0

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

func (*ProtoSeries) String added in v3.2.0

func (this *ProtoSeries) String() string

func (*ProtoSeries) Unmarshal added in v3.2.0

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

func (*ProtoSeries) XXX_DiscardUnknown added in v3.2.0

func (m *ProtoSeries) XXX_DiscardUnknown()

func (*ProtoSeries) XXX_Marshal added in v3.2.0

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

func (*ProtoSeries) XXX_Merge added in v3.2.0

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

func (*ProtoSeries) XXX_Size added in v3.2.0

func (m *ProtoSeries) XXX_Size() int

func (*ProtoSeries) XXX_Unmarshal added in v3.2.0

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

type ProtoTask

type ProtoTask struct {
	Id     string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Table  DayTable               `protobuf:"bytes,2,opt,name=table,proto3" json:"table"`
	Tenant string                 `protobuf:"bytes,3,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Bounds ProtoFingerprintBounds `protobuf:"bytes,4,opt,name=bounds,proto3" json:"bounds"`
	Tsdb   string                 `protobuf:"bytes,5,opt,name=tsdb,proto3" json:"tsdb,omitempty"`
	Gaps   []*ProtoGapWithBlocks  `protobuf:"bytes,6,rep,name=gaps,proto3" json:"gaps,omitempty"`
}

TODO: Define BlockRef and SingleTenantTSDBIdentifier as messages so we can use them right away

instead of unmarshaling them from strings or doing unsafe casts.

func (*ProtoTask) Descriptor

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

func (*ProtoTask) Equal

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

func (*ProtoTask) GetBounds

func (m *ProtoTask) GetBounds() ProtoFingerprintBounds

func (*ProtoTask) GetGaps

func (m *ProtoTask) GetGaps() []*ProtoGapWithBlocks

func (*ProtoTask) GetId

func (m *ProtoTask) GetId() string

func (*ProtoTask) GetTable

func (m *ProtoTask) GetTable() DayTable

func (*ProtoTask) GetTenant

func (m *ProtoTask) GetTenant() string

func (*ProtoTask) GetTsdb

func (m *ProtoTask) GetTsdb() string

func (*ProtoTask) GoString

func (this *ProtoTask) GoString() string

func (*ProtoTask) Marshal

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

func (*ProtoTask) MarshalTo

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

func (*ProtoTask) MarshalToSizedBuffer

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

func (*ProtoTask) ProtoMessage

func (*ProtoTask) ProtoMessage()

func (*ProtoTask) Reset

func (m *ProtoTask) Reset()

func (*ProtoTask) Size

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

func (*ProtoTask) String

func (this *ProtoTask) String() string

func (*ProtoTask) Unmarshal

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

func (*ProtoTask) XXX_DiscardUnknown

func (m *ProtoTask) XXX_DiscardUnknown()

func (*ProtoTask) XXX_Marshal

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

func (*ProtoTask) XXX_Merge

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

func (*ProtoTask) XXX_Size

func (m *ProtoTask) XXX_Size() int

func (*ProtoTask) XXX_Unmarshal

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

type ProtoTaskResult

type ProtoTaskResult struct {
	TaskID       string       `protobuf:"bytes,1,opt,name=taskID,proto3" json:"taskID,omitempty"`
	Error        string       `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	CreatedMetas []*ProtoMeta `protobuf:"bytes,3,rep,name=createdMetas,proto3" json:"createdMetas,omitempty"`
}

func (*ProtoTaskResult) Descriptor

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

func (*ProtoTaskResult) Equal

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

func (*ProtoTaskResult) GetCreatedMetas

func (m *ProtoTaskResult) GetCreatedMetas() []*ProtoMeta

func (*ProtoTaskResult) GetError

func (m *ProtoTaskResult) GetError() string

func (*ProtoTaskResult) GetTaskID

func (m *ProtoTaskResult) GetTaskID() string

func (*ProtoTaskResult) GoString

func (this *ProtoTaskResult) GoString() string

func (*ProtoTaskResult) Marshal

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

func (*ProtoTaskResult) MarshalTo

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

func (*ProtoTaskResult) MarshalToSizedBuffer

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

func (*ProtoTaskResult) ProtoMessage

func (*ProtoTaskResult) ProtoMessage()

func (*ProtoTaskResult) Reset

func (m *ProtoTaskResult) Reset()

func (*ProtoTaskResult) Size

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

func (*ProtoTaskResult) String

func (this *ProtoTaskResult) String() string

func (*ProtoTaskResult) Unmarshal

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

func (*ProtoTaskResult) XXX_DiscardUnknown

func (m *ProtoTaskResult) XXX_DiscardUnknown()

func (*ProtoTaskResult) XXX_Marshal

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

func (*ProtoTaskResult) XXX_Merge

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

func (*ProtoTaskResult) XXX_Size

func (m *ProtoTaskResult) XXX_Size() int

func (*ProtoTaskResult) XXX_Unmarshal

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

type Task

type Task struct {
	ID string

	Table           config.DayTable
	Tenant          string
	OwnershipBounds v1.FingerprintBounds
	TSDB            tsdb.SingleTenantTSDBIdentifier
	Gaps            []Gap
}

func FromProtoTask

func FromProtoTask(task *ProtoTask) (*Task, error)

func NewTask

func NewTask(
	table config.DayTable,
	tenant string,
	bounds v1.FingerprintBounds,
	tsdb tsdb.SingleTenantTSDBIdentifier,
	gaps []Gap,
) *Task

func (*Task) GetLogger added in v3.2.0

func (t *Task) GetLogger(logger log.Logger) log.Logger

func (*Task) ToProtoTask

func (t *Task) ToProtoTask() *ProtoTask

type TaskResult

type TaskResult struct {
	TaskID       string
	Error        error
	CreatedMetas []bloomshipper.Meta
}

func FromProtoTaskResult

func FromProtoTaskResult(result *ProtoTaskResult) (*TaskResult, error)

func (*TaskResult) ToProtoTaskResult

func (r *TaskResult) ToProtoTaskResult() *ProtoTaskResult

type UnimplementedPlannerForBuilderServer

type UnimplementedPlannerForBuilderServer struct {
}

UnimplementedPlannerForBuilderServer can be embedded to have forward compatible implementations.

func (*UnimplementedPlannerForBuilderServer) BuilderLoop

func (*UnimplementedPlannerForBuilderServer) NotifyBuilderShutdown

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL