adaptive_placementpb

package
v1.10.0 Latest Latest
Warning

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

 Go to latest Published: Nov 9, 2024 License: AGPL-3.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	LoadBalancing_name = map[int32]string{
		0: "LOAD_BALANCING_UNSPECIFIED",
		1: "LOAD_BALANCING_FINGERPRINT",
		2: "LOAD_BALANCING_ROUND_ROBIN",
	}
	LoadBalancing_value = map[string]int32{
		"LOAD_BALANCING_UNSPECIFIED": 0,
		"LOAD_BALANCING_FINGERPRINT": 1,
		"LOAD_BALANCING_ROUND_ROBIN": 2,
	}
)

Enum value maps for LoadBalancing.

View Source 
var File_experiment_distributor_placement_adaptive_placement_adaptive_placementpb_adaptive_placement_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type DatasetPlacement 

type DatasetPlacement struct {
	Tenant            uint32        `protobuf:"varint,1,opt,name=tenant,proto3" json:"tenant,omitempty"`
	Name              string        `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	TenantShardLimit  uint64        `protobuf:"varint,3,opt,name=tenant_shard_limit,json=tenantShardLimit,proto3" json:"tenant_shard_limit,omitempty"`
	DatasetShardLimit uint64        `protobuf:"varint,4,opt,name=dataset_shard_limit,json=datasetShardLimit,proto3" json:"dataset_shard_limit,omitempty"`
	LoadBalancing     LoadBalancing `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DatasetPlacement) Descriptor deprecated 

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

Deprecated: Use DatasetPlacement.ProtoReflect.Descriptor instead.

func (*DatasetPlacement) GetDatasetShardLimit 

func (x *DatasetPlacement) GetDatasetShardLimit() uint64

func (*DatasetPlacement) GetLoadBalancing 

func (x *DatasetPlacement) GetLoadBalancing() LoadBalancing

func (*DatasetPlacement) GetName 

func (x *DatasetPlacement) GetName() string

func (*DatasetPlacement) GetTenant 

func (x *DatasetPlacement) GetTenant() uint32

func (*DatasetPlacement) GetTenantShardLimit 

func (x *DatasetPlacement) GetTenantShardLimit() uint64

func (*DatasetPlacement) MarshalToSizedBufferVT 

func (m *DatasetPlacement) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DatasetPlacement) MarshalToVT 

func (m *DatasetPlacement) MarshalToVT(dAtA []byte) (int, error)

func (*DatasetPlacement) MarshalVT 

func (m *DatasetPlacement) MarshalVT() (dAtA []byte, err error)

func (*DatasetPlacement) ProtoMessage 

func (*DatasetPlacement) ProtoMessage()

func (*DatasetPlacement) ProtoReflect 

func (x *DatasetPlacement) ProtoReflect() protoreflect.Message

func (*DatasetPlacement) Reset 

func (x *DatasetPlacement) Reset()

func (*DatasetPlacement) SizeVT 

func (m *DatasetPlacement) SizeVT() (n int)

func (*DatasetPlacement) String 

func (x *DatasetPlacement) String() string

func (*DatasetPlacement) UnmarshalVT 

func (m *DatasetPlacement) UnmarshalVT(dAtA []byte) error

type DatasetStats 

type DatasetStats struct {
	Tenant uint32 `protobuf:"varint,1,opt,name=tenant,proto3" json:"tenant,omitempty"` // Reference to TenantStats.
	Name   string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Shard value is a reference to ShardStats.
	Shards []uint32 `protobuf:"varint,3,rep,packed,name=shards,proto3" json:"shards,omitempty"`
	// Data rate in bytes per second for each shard.
	// The dataset size is measured after being encoded
	// in the block wire format.
	Usage []uint64 `protobuf:"varint,4,rep,packed,name=usage,proto3" json:"usage,omitempty"`
	// Standard deviation of the data rate across shards
	// aggregated within a sliding time window.
	StdDev uint64 `protobuf:"varint,5,opt,name=std_dev,json=stdDev,proto3" json:"std_dev,omitempty"`
	// contains filtered or unexported fields
}

func (*DatasetStats) Descriptor deprecated 

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

Deprecated: Use DatasetStats.ProtoReflect.Descriptor instead.

func (*DatasetStats) GetName 

func (x *DatasetStats) GetName() string

func (*DatasetStats) GetShards 

func (x *DatasetStats) GetShards() []uint32

func (*DatasetStats) GetStdDev 

func (x *DatasetStats) GetStdDev() uint64

func (*DatasetStats) GetTenant 

func (x *DatasetStats) GetTenant() uint32

func (*DatasetStats) GetUsage 

func (x *DatasetStats) GetUsage() []uint64

func (*DatasetStats) MarshalToSizedBufferVT 

func (m *DatasetStats) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DatasetStats) MarshalToVT 

func (m *DatasetStats) MarshalToVT(dAtA []byte) (int, error)

func (*DatasetStats) MarshalVT 

func (m *DatasetStats) MarshalVT() (dAtA []byte, err error)

func (*DatasetStats) ProtoMessage 

func (*DatasetStats) ProtoMessage()

func (*DatasetStats) ProtoReflect 

func (x *DatasetStats) ProtoReflect() protoreflect.Message

func (*DatasetStats) Reset 

func (x *DatasetStats) Reset()

func (*DatasetStats) SizeVT 

func (m *DatasetStats) SizeVT() (n int)

func (*DatasetStats) String 

func (x *DatasetStats) String() string

func (*DatasetStats) UnmarshalVT 

func (m *DatasetStats) UnmarshalVT(dAtA []byte) error

type DistributionStats 

type DistributionStats struct {
	Tenants   []*TenantStats  `protobuf:"bytes,1,rep,name=tenants,proto3" json:"tenants,omitempty"`
	Datasets  []*DatasetStats `protobuf:"bytes,2,rep,name=datasets,proto3" json:"datasets,omitempty"`
	Shards    []*ShardStats   `protobuf:"bytes,3,rep,name=shards,proto3" json:"shards,omitempty"`
	CreatedAt int64           `protobuf:"varint,4,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

DistributionStats includes the data the Placement is built based on.

func (*DistributionStats) Descriptor deprecated 

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

Deprecated: Use DistributionStats.ProtoReflect.Descriptor instead.

func (*DistributionStats) GetCreatedAt 

func (x *DistributionStats) GetCreatedAt() int64

func (*DistributionStats) GetDatasets 

func (x *DistributionStats) GetDatasets() []*DatasetStats

func (*DistributionStats) GetShards 

func (x *DistributionStats) GetShards() []*ShardStats

func (*DistributionStats) GetTenants 

func (x *DistributionStats) GetTenants() []*TenantStats

func (*DistributionStats) MarshalToSizedBufferVT 

func (m *DistributionStats) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*DistributionStats) MarshalToVT 

func (m *DistributionStats) MarshalToVT(dAtA []byte) (int, error)

func (*DistributionStats) MarshalVT 

func (m *DistributionStats) MarshalVT() (dAtA []byte, err error)

func (*DistributionStats) ProtoMessage 

func (*DistributionStats) ProtoMessage()

func (*DistributionStats) ProtoReflect 

func (x *DistributionStats) ProtoReflect() protoreflect.Message

func (*DistributionStats) Reset 

func (x *DistributionStats) Reset()

func (*DistributionStats) SizeVT 

func (m *DistributionStats) SizeVT() (n int)

func (*DistributionStats) String 

func (x *DistributionStats) String() string

func (*DistributionStats) UnmarshalVT 

func (m *DistributionStats) UnmarshalVT(dAtA []byte) error

type LoadBalancing 

type LoadBalancing int32
const (
	LoadBalancing_LOAD_BALANCING_UNSPECIFIED LoadBalancing = 0
	LoadBalancing_LOAD_BALANCING_FINGERPRINT LoadBalancing = 1
	LoadBalancing_LOAD_BALANCING_ROUND_ROBIN LoadBalancing = 2
)

func (LoadBalancing) Descriptor 

func (LoadBalancing) Descriptor() protoreflect.EnumDescriptor

func (LoadBalancing) Enum 

func (x LoadBalancing) Enum() *LoadBalancing

func (LoadBalancing) EnumDescriptor deprecated 

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

Deprecated: Use LoadBalancing.Descriptor instead.

func (LoadBalancing) Number 

func (x LoadBalancing) Number() protoreflect.EnumNumber

func (LoadBalancing) String 

func (x LoadBalancing) String() string

func (LoadBalancing) Type 

func (LoadBalancing) Type() protoreflect.EnumType

type PlacementRules 

type PlacementRules struct {
	Tenants   []*TenantPlacement  `protobuf:"bytes,1,rep,name=tenants,proto3" json:"tenants,omitempty"`
	Datasets  []*DatasetPlacement `protobuf:"bytes,2,rep,name=datasets,proto3" json:"datasets,omitempty"`
	CreatedAt int64               `protobuf:"varint,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*PlacementRules) Descriptor deprecated 

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

Deprecated: Use PlacementRules.ProtoReflect.Descriptor instead.

func (*PlacementRules) GetCreatedAt 

func (x *PlacementRules) GetCreatedAt() int64

func (*PlacementRules) GetDatasets 

func (x *PlacementRules) GetDatasets() []*DatasetPlacement

func (*PlacementRules) GetTenants 

func (x *PlacementRules) GetTenants() []*TenantPlacement

func (*PlacementRules) MarshalToSizedBufferVT 

func (m *PlacementRules) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*PlacementRules) MarshalToVT 

func (m *PlacementRules) MarshalToVT(dAtA []byte) (int, error)

func (*PlacementRules) MarshalVT 

func (m *PlacementRules) MarshalVT() (dAtA []byte, err error)

func (*PlacementRules) ProtoMessage 

func (*PlacementRules) ProtoMessage()

func (*PlacementRules) ProtoReflect 

func (x *PlacementRules) ProtoReflect() protoreflect.Message

func (*PlacementRules) Reset 

func (x *PlacementRules) Reset()

func (*PlacementRules) SizeVT 

func (m *PlacementRules) SizeVT() (n int)

func (*PlacementRules) String 

func (x *PlacementRules) String() string

func (*PlacementRules) UnmarshalVT 

func (m *PlacementRules) UnmarshalVT(dAtA []byte) error

type ShardStats 

type ShardStats struct {

	// Shard ID.
	Id uint32 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	// Owner represents the node that hosted the shard.
	// There may be multiple entries for a single shard
	// if it was relocated across different nodes.
	Owner string `protobuf:"bytes,2,opt,name=owner,proto3" json:"owner,omitempty"`
	// contains filtered or unexported fields
}

func (*ShardStats) Descriptor deprecated 

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

Deprecated: Use ShardStats.ProtoReflect.Descriptor instead.

func (*ShardStats) GetId 

func (x *ShardStats) GetId() uint32

func (*ShardStats) GetOwner 

func (x *ShardStats) GetOwner() string

func (*ShardStats) MarshalToSizedBufferVT 

func (m *ShardStats) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*ShardStats) MarshalToVT 

func (m *ShardStats) MarshalToVT(dAtA []byte) (int, error)

func (*ShardStats) MarshalVT 

func (m *ShardStats) MarshalVT() (dAtA []byte, err error)

func (*ShardStats) ProtoMessage 

func (*ShardStats) ProtoMessage()

func (*ShardStats) ProtoReflect 

func (x *ShardStats) ProtoReflect() protoreflect.Message

func (*ShardStats) Reset 

func (x *ShardStats) Reset()

func (*ShardStats) SizeVT 

func (m *ShardStats) SizeVT() (n int)

func (*ShardStats) String 

func (x *ShardStats) String() string

func (*ShardStats) UnmarshalVT 

func (m *ShardStats) UnmarshalVT(dAtA []byte) error

type TenantPlacement 

type TenantPlacement struct {
	TenantId string `protobuf:"bytes,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TenantPlacement) Descriptor deprecated 

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

Deprecated: Use TenantPlacement.ProtoReflect.Descriptor instead.

func (*TenantPlacement) GetTenantId 

func (x *TenantPlacement) GetTenantId() string

func (*TenantPlacement) MarshalToSizedBufferVT 

func (m *TenantPlacement) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TenantPlacement) MarshalToVT 

func (m *TenantPlacement) MarshalToVT(dAtA []byte) (int, error)

func (*TenantPlacement) MarshalVT 

func (m *TenantPlacement) MarshalVT() (dAtA []byte, err error)

func (*TenantPlacement) ProtoMessage 

func (*TenantPlacement) ProtoMessage()

func (*TenantPlacement) ProtoReflect 

func (x *TenantPlacement) ProtoReflect() protoreflect.Message

func (*TenantPlacement) Reset 

func (x *TenantPlacement) Reset()

func (*TenantPlacement) SizeVT 

func (m *TenantPlacement) SizeVT() (n int)

func (*TenantPlacement) String 

func (x *TenantPlacement) String() string

func (*TenantPlacement) UnmarshalVT 

func (m *TenantPlacement) UnmarshalVT(dAtA []byte) error

type TenantStats 

type TenantStats struct {
	TenantId string `protobuf:"bytes,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	// contains filtered or unexported fields
}

func (*TenantStats) Descriptor deprecated 

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

Deprecated: Use TenantStats.ProtoReflect.Descriptor instead.

func (*TenantStats) GetTenantId 

func (x *TenantStats) GetTenantId() string

func (*TenantStats) MarshalToSizedBufferVT 

func (m *TenantStats) MarshalToSizedBufferVT(dAtA []byte) (int, error)

func (*TenantStats) MarshalToVT 

func (m *TenantStats) MarshalToVT(dAtA []byte) (int, error)

func (*TenantStats) MarshalVT 

func (m *TenantStats) MarshalVT() (dAtA []byte, err error)

func (*TenantStats) ProtoMessage 

func (*TenantStats) ProtoMessage()

func (*TenantStats) ProtoReflect 

func (x *TenantStats) ProtoReflect() protoreflect.Message

func (*TenantStats) Reset 

func (x *TenantStats) Reset()

func (*TenantStats) SizeVT 

func (m *TenantStats) SizeVT() (n int)

func (*TenantStats) String 

func (x *TenantStats) String() string

func (*TenantStats) UnmarshalVT 

func (m *TenantStats) UnmarshalVT(dAtA []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.