 Documentation
      ¶
      Documentation
      ¶
    
    
  
    
  
    Index ¶
- Variables
- type DatasetPlacement
- func (*DatasetPlacement) Descriptor() ([]byte, []int)deprecated
- func (x *DatasetPlacement) GetDatasetShardLimit() uint64
- func (x *DatasetPlacement) GetLoadBalancing() LoadBalancing
- func (x *DatasetPlacement) GetName() string
- func (x *DatasetPlacement) GetTenant() uint32
- func (x *DatasetPlacement) GetTenantShardLimit() uint64
- func (m *DatasetPlacement) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *DatasetPlacement) MarshalToVT(dAtA []byte) (int, error)
- func (m *DatasetPlacement) MarshalVT() (dAtA []byte, err error)
- func (*DatasetPlacement) ProtoMessage()
- func (x *DatasetPlacement) ProtoReflect() protoreflect.Message
- func (x *DatasetPlacement) Reset()
- func (m *DatasetPlacement) SizeVT() (n int)
- func (x *DatasetPlacement) String() string
- func (m *DatasetPlacement) UnmarshalVT(dAtA []byte) error
 
- type DatasetStats
- func (*DatasetStats) Descriptor() ([]byte, []int)deprecated
- func (x *DatasetStats) GetName() string
- func (x *DatasetStats) GetShards() []uint32
- func (x *DatasetStats) GetStdDev() uint64
- func (x *DatasetStats) GetTenant() uint32
- func (x *DatasetStats) GetUsage() []uint64
- func (m *DatasetStats) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *DatasetStats) MarshalToVT(dAtA []byte) (int, error)
- func (m *DatasetStats) MarshalVT() (dAtA []byte, err error)
- func (*DatasetStats) ProtoMessage()
- func (x *DatasetStats) ProtoReflect() protoreflect.Message
- func (x *DatasetStats) Reset()
- func (m *DatasetStats) SizeVT() (n int)
- func (x *DatasetStats) String() string
- func (m *DatasetStats) UnmarshalVT(dAtA []byte) error
 
- type DistributionStats
- func (*DistributionStats) Descriptor() ([]byte, []int)deprecated
- func (x *DistributionStats) GetCreatedAt() int64
- func (x *DistributionStats) GetDatasets() []*DatasetStats
- func (x *DistributionStats) GetShards() []*ShardStats
- func (x *DistributionStats) GetTenants() []*TenantStats
- func (m *DistributionStats) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *DistributionStats) MarshalToVT(dAtA []byte) (int, error)
- func (m *DistributionStats) MarshalVT() (dAtA []byte, err error)
- func (*DistributionStats) ProtoMessage()
- func (x *DistributionStats) ProtoReflect() protoreflect.Message
- func (x *DistributionStats) Reset()
- func (m *DistributionStats) SizeVT() (n int)
- func (x *DistributionStats) String() string
- func (m *DistributionStats) UnmarshalVT(dAtA []byte) error
 
- type LoadBalancing
- func (LoadBalancing) Descriptor() protoreflect.EnumDescriptor
- func (x LoadBalancing) Enum() *LoadBalancing
- func (LoadBalancing) EnumDescriptor() ([]byte, []int)deprecated
- func (x LoadBalancing) Number() protoreflect.EnumNumber
- func (x LoadBalancing) String() string
- func (LoadBalancing) Type() protoreflect.EnumType
 
- type PlacementRules
- func (*PlacementRules) Descriptor() ([]byte, []int)deprecated
- func (x *PlacementRules) GetCreatedAt() int64
- func (x *PlacementRules) GetDatasets() []*DatasetPlacement
- func (x *PlacementRules) GetTenants() []*TenantPlacement
- func (m *PlacementRules) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *PlacementRules) MarshalToVT(dAtA []byte) (int, error)
- func (m *PlacementRules) MarshalVT() (dAtA []byte, err error)
- func (*PlacementRules) ProtoMessage()
- func (x *PlacementRules) ProtoReflect() protoreflect.Message
- func (x *PlacementRules) Reset()
- func (m *PlacementRules) SizeVT() (n int)
- func (x *PlacementRules) String() string
- func (m *PlacementRules) UnmarshalVT(dAtA []byte) error
 
- type ShardStats
- func (*ShardStats) Descriptor() ([]byte, []int)deprecated
- func (x *ShardStats) GetId() uint32
- func (x *ShardStats) GetOwner() string
- func (m *ShardStats) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *ShardStats) MarshalToVT(dAtA []byte) (int, error)
- func (m *ShardStats) MarshalVT() (dAtA []byte, err error)
- func (*ShardStats) ProtoMessage()
- func (x *ShardStats) ProtoReflect() protoreflect.Message
- func (x *ShardStats) Reset()
- func (m *ShardStats) SizeVT() (n int)
- func (x *ShardStats) String() string
- func (m *ShardStats) UnmarshalVT(dAtA []byte) error
 
- type TenantPlacement
- func (*TenantPlacement) Descriptor() ([]byte, []int)deprecated
- func (x *TenantPlacement) GetTenantId() string
- func (m *TenantPlacement) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TenantPlacement) MarshalToVT(dAtA []byte) (int, error)
- func (m *TenantPlacement) MarshalVT() (dAtA []byte, err error)
- func (*TenantPlacement) ProtoMessage()
- func (x *TenantPlacement) ProtoReflect() protoreflect.Message
- func (x *TenantPlacement) Reset()
- func (m *TenantPlacement) SizeVT() (n int)
- func (x *TenantPlacement) String() string
- func (m *TenantPlacement) UnmarshalVT(dAtA []byte) error
 
- type TenantStats
- func (*TenantStats) Descriptor() ([]byte, []int)deprecated
- func (x *TenantStats) GetTenantId() string
- func (m *TenantStats) MarshalToSizedBufferVT(dAtA []byte) (int, error)
- func (m *TenantStats) MarshalToVT(dAtA []byte) (int, error)
- func (m *TenantStats) MarshalVT() (dAtA []byte, err error)
- func (*TenantStats) ProtoMessage()
- func (x *TenantStats) ProtoReflect() protoreflect.Message
- func (x *TenantStats) Reset()
- func (m *TenantStats) SizeVT() (n int)
- func (x *TenantStats) String() string
- func (m *TenantStats) UnmarshalVT(dAtA []byte) error
 
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_segmentwriter_client_distributor_placement_adaptiveplacement_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
 Click to show internal directories. 
   Click to hide internal directories.