protos

package
v3.2.1 Latest Latest
Warning

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

 Go to latest Published: Oct 17, 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 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 (m *ProtoFingerprintBounds) GetMax() github_com_prometheus_common_model.Fingerprint

func (*ProtoFingerprintBounds) GetMin 

func (m *ProtoFingerprintBounds) GetMin() github_com_prometheus_common_model.Fingerprint

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 (m *ProtoGapWithBlocks) GetBounds() ProtoFingerprintBounds

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) BuilderLoop(srv PlannerForBuilder_BuilderLoopServer) error

func (*UnimplementedPlannerForBuilderServer) NotifyBuilderShutdown 

func (*UnimplementedPlannerForBuilderServer) NotifyBuilderShutdown(ctx context.Context, req *NotifyBuilderShutdownRequest) (*NotifyBuilderShutdownResponse, 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.