adminproto

type AddOrganizationBucketRequest struct {
	OrganizationId string `protobuf:"bytes,1,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
	BucketName     string `protobuf:"bytes,2,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	InstanceNum    int32  `protobuf:"varint,3,opt,name=instance_num,json=instanceNum,proto3" json:"instance_num,omitempty"`
	CollectorName  string `protobuf:"bytes,4,opt,name=collector_name,json=collectorName,proto3" json:"collector_name,omitempty"`
	// contains filtered or unexported fields
}

type AddOrganizationBucketResponse struct {
	Bucket *OrganizationBucket `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	// contains filtered or unexported fields
}

type AdminServiceClient interface {
	// Ping endpoint for connectivity testing
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	// Get inqueue status/summary
	InQueueStatus(ctx context.Context, in *InQueueStatusRequest, opts ...grpc.CallOption) (*InQueueStatusResponse, error)
	// List organizations in the system
	ListOrganizations(ctx context.Context, in *ListOrganizationsRequest, opts ...grpc.CallOption) (*ListOrganizationsResponse, error)
	// Create a new organization
	CreateOrganization(ctx context.Context, in *CreateOrganizationRequest, opts ...grpc.CallOption) (*CreateOrganizationResponse, error)
	// Update fields on an existing organization
	UpdateOrganization(ctx context.Context, in *UpdateOrganizationRequest, opts ...grpc.CallOption) (*UpdateOrganizationResponse, error)
	// Get Kafka consumer group lag information
	GetConsumerLag(ctx context.Context, in *GetConsumerLagRequest, opts ...grpc.CallOption) (*GetConsumerLagResponse, error)
	// Organization API Keys Management
	ListOrganizationAPIKeys(ctx context.Context, in *ListOrganizationAPIKeysRequest, opts ...grpc.CallOption) (*ListOrganizationAPIKeysResponse, error)
	CreateOrganizationAPIKey(ctx context.Context, in *CreateOrganizationAPIKeyRequest, opts ...grpc.CallOption) (*CreateOrganizationAPIKeyResponse, error)
	DeleteOrganizationAPIKey(ctx context.Context, in *DeleteOrganizationAPIKeyRequest, opts ...grpc.CallOption) (*DeleteOrganizationAPIKeyResponse, error)
	// Organization Buckets Management
	ListOrganizationBuckets(ctx context.Context, in *ListOrganizationBucketsRequest, opts ...grpc.CallOption) (*ListOrganizationBucketsResponse, error)
	AddOrganizationBucket(ctx context.Context, in *AddOrganizationBucketRequest, opts ...grpc.CallOption) (*AddOrganizationBucketResponse, error)
	DeleteOrganizationBucket(ctx context.Context, in *DeleteOrganizationBucketRequest, opts ...grpc.CallOption) (*DeleteOrganizationBucketResponse, error)
	// Bucket Configuration Management
	ListBucketConfigurations(ctx context.Context, in *ListBucketConfigurationsRequest, opts ...grpc.CallOption) (*ListBucketConfigurationsResponse, error)
	CreateBucketConfiguration(ctx context.Context, in *CreateBucketConfigurationRequest, opts ...grpc.CallOption) (*CreateBucketConfigurationResponse, error)
	DeleteBucketConfiguration(ctx context.Context, in *DeleteBucketConfigurationRequest, opts ...grpc.CallOption) (*DeleteBucketConfigurationResponse, error)
	// Bucket Prefix Mappings Management
	ListBucketPrefixMappings(ctx context.Context, in *ListBucketPrefixMappingsRequest, opts ...grpc.CallOption) (*ListBucketPrefixMappingsResponse, error)
	CreateBucketPrefixMapping(ctx context.Context, in *CreateBucketPrefixMappingRequest, opts ...grpc.CallOption) (*CreateBucketPrefixMappingResponse, error)
	DeleteBucketPrefixMapping(ctx context.Context, in *DeleteBucketPrefixMappingRequest, opts ...grpc.CallOption) (*DeleteBucketPrefixMappingResponse, error)
	// Log Stream Configuration Management
	GetLogStreamConfig(ctx context.Context, in *GetLogStreamConfigRequest, opts ...grpc.CallOption) (*GetLogStreamConfigResponse, error)
	SetLogStreamConfig(ctx context.Context, in *SetLogStreamConfigRequest, opts ...grpc.CallOption) (*SetLogStreamConfigResponse, error)
	DeleteLogStreamConfig(ctx context.Context, in *DeleteLogStreamConfigRequest, opts ...grpc.CallOption) (*DeleteLogStreamConfigResponse, error)
	// Work Queue Status
	GetWorkQueueStatus(ctx context.Context, in *GetWorkQueueStatusRequest, opts ...grpc.CallOption) (*GetWorkQueueStatusResponse, error)
	// Queue log segments for recompaction
	QueueLogRecompact(ctx context.Context, in *QueueLogRecompactRequest, opts ...grpc.CallOption) (*QueueLogRecompactResponse, error)
}

type AdminServiceServer interface {
	// Ping endpoint for connectivity testing
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	// Get inqueue status/summary
	InQueueStatus(context.Context, *InQueueStatusRequest) (*InQueueStatusResponse, error)
	// List organizations in the system
	ListOrganizations(context.Context, *ListOrganizationsRequest) (*ListOrganizationsResponse, error)
	// Create a new organization
	CreateOrganization(context.Context, *CreateOrganizationRequest) (*CreateOrganizationResponse, error)
	// Update fields on an existing organization
	UpdateOrganization(context.Context, *UpdateOrganizationRequest) (*UpdateOrganizationResponse, error)
	// Get Kafka consumer group lag information
	GetConsumerLag(context.Context, *GetConsumerLagRequest) (*GetConsumerLagResponse, error)
	// Organization API Keys Management
	ListOrganizationAPIKeys(context.Context, *ListOrganizationAPIKeysRequest) (*ListOrganizationAPIKeysResponse, error)
	CreateOrganizationAPIKey(context.Context, *CreateOrganizationAPIKeyRequest) (*CreateOrganizationAPIKeyResponse, error)
	DeleteOrganizationAPIKey(context.Context, *DeleteOrganizationAPIKeyRequest) (*DeleteOrganizationAPIKeyResponse, error)
	// Organization Buckets Management
	ListOrganizationBuckets(context.Context, *ListOrganizationBucketsRequest) (*ListOrganizationBucketsResponse, error)
	AddOrganizationBucket(context.Context, *AddOrganizationBucketRequest) (*AddOrganizationBucketResponse, error)
	DeleteOrganizationBucket(context.Context, *DeleteOrganizationBucketRequest) (*DeleteOrganizationBucketResponse, error)
	// Bucket Configuration Management
	ListBucketConfigurations(context.Context, *ListBucketConfigurationsRequest) (*ListBucketConfigurationsResponse, error)
	CreateBucketConfiguration(context.Context, *CreateBucketConfigurationRequest) (*CreateBucketConfigurationResponse, error)
	DeleteBucketConfiguration(context.Context, *DeleteBucketConfigurationRequest) (*DeleteBucketConfigurationResponse, error)
	// Bucket Prefix Mappings Management
	ListBucketPrefixMappings(context.Context, *ListBucketPrefixMappingsRequest) (*ListBucketPrefixMappingsResponse, error)
	CreateBucketPrefixMapping(context.Context, *CreateBucketPrefixMappingRequest) (*CreateBucketPrefixMappingResponse, error)
	DeleteBucketPrefixMapping(context.Context, *DeleteBucketPrefixMappingRequest) (*DeleteBucketPrefixMappingResponse, error)
	// Log Stream Configuration Management
	GetLogStreamConfig(context.Context, *GetLogStreamConfigRequest) (*GetLogStreamConfigResponse, error)
	SetLogStreamConfig(context.Context, *SetLogStreamConfigRequest) (*SetLogStreamConfigResponse, error)
	DeleteLogStreamConfig(context.Context, *DeleteLogStreamConfigRequest) (*DeleteLogStreamConfigResponse, error)
	// Work Queue Status
	GetWorkQueueStatus(context.Context, *GetWorkQueueStatusRequest) (*GetWorkQueueStatusResponse, error)
	// Queue log segments for recompaction
	QueueLogRecompact(context.Context, *QueueLogRecompactRequest) (*QueueLogRecompactResponse, error)
	// contains filtered or unexported methods
}

type BucketConfiguration struct {
	BucketName    string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	CloudProvider string `protobuf:"bytes,2,opt,name=cloud_provider,json=cloudProvider,proto3" json:"cloud_provider,omitempty"`
	Region        string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
	Endpoint      string `protobuf:"bytes,4,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Role          string `protobuf:"bytes,5,opt,name=role,proto3" json:"role,omitempty"`
	UsePathStyle  bool   `protobuf:"varint,6,opt,name=use_path_style,json=usePathStyle,proto3" json:"use_path_style,omitempty"`
	InsecureTls   bool   `protobuf:"varint,7,opt,name=insecure_tls,json=insecureTls,proto3" json:"insecure_tls,omitempty"`
	// contains filtered or unexported fields
}

type BucketPrefixMapping struct {
	Id             string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	BucketName     string `protobuf:"bytes,2,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	OrganizationId string `protobuf:"bytes,3,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
	PathPrefix     string `protobuf:"bytes,4,opt,name=path_prefix,json=pathPrefix,proto3" json:"path_prefix,omitempty"`
	Signal         string `protobuf:"bytes,5,opt,name=signal,proto3" json:"signal,omitempty"`
	// contains filtered or unexported fields
}

type ConsumerPartitionLag struct {
	Topic         string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Partition     int32  `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"`
	CurrentOffset int64  `protobuf:"varint,3,opt,name=current_offset,json=currentOffset,proto3" json:"current_offset,omitempty"`
	HighWaterMark int64  `protobuf:"varint,4,opt,name=high_water_mark,json=highWaterMark,proto3" json:"high_water_mark,omitempty"`
	Lag           int64  `protobuf:"varint,5,opt,name=lag,proto3" json:"lag,omitempty"`
	ConsumerGroup string `protobuf:"bytes,6,opt,name=consumer_group,json=consumerGroup,proto3" json:"consumer_group,omitempty"`
	// contains filtered or unexported fields
}

type CreateBucketConfigurationRequest struct {
	BucketName    string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	CloudProvider string `protobuf:"bytes,2,opt,name=cloud_provider,json=cloudProvider,proto3" json:"cloud_provider,omitempty"`
	Region        string `protobuf:"bytes,3,opt,name=region,proto3" json:"region,omitempty"`
	Endpoint      string `protobuf:"bytes,4,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Role          string `protobuf:"bytes,5,opt,name=role,proto3" json:"role,omitempty"`
	UsePathStyle  bool   `protobuf:"varint,6,opt,name=use_path_style,json=usePathStyle,proto3" json:"use_path_style,omitempty"`
	InsecureTls   bool   `protobuf:"varint,7,opt,name=insecure_tls,json=insecureTls,proto3" json:"insecure_tls,omitempty"`
	// contains filtered or unexported fields
}

type CreateBucketConfigurationResponse struct {
	Configuration *BucketConfiguration `protobuf:"bytes,1,opt,name=configuration,proto3" json:"configuration,omitempty"`
	// contains filtered or unexported fields
}

type CreateBucketPrefixMappingRequest struct {
	BucketName     string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	OrganizationId string `protobuf:"bytes,2,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
	PathPrefix     string `protobuf:"bytes,3,opt,name=path_prefix,json=pathPrefix,proto3" json:"path_prefix,omitempty"`
	Signal         string `protobuf:"bytes,4,opt,name=signal,proto3" json:"signal,omitempty"`
	// contains filtered or unexported fields
}

type CreateBucketPrefixMappingResponse struct {
	Mapping *BucketPrefixMapping `protobuf:"bytes,1,opt,name=mapping,proto3" json:"mapping,omitempty"`
	// contains filtered or unexported fields
}

type CreateOrganizationAPIKeyRequest struct {
	OrganizationId string `protobuf:"bytes,1,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
	Name           string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description    string `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// contains filtered or unexported fields
}

type CreateOrganizationAPIKeyResponse struct {
	ApiKey  *OrganizationAPIKey `protobuf:"bytes,1,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"`
	FullKey string              `protobuf:"bytes,2,opt,name=full_key,json=fullKey,proto3" json:"full_key,omitempty"` // The actual key, only returned on creation
	// contains filtered or unexported fields
}

type CreateOrganizationRequest struct {
	Name    string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Enabled bool   `protobuf:"varint,2,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// contains filtered or unexported fields
}

type CreateOrganizationResponse struct {
	Organization *Organization `protobuf:"bytes,1,opt,name=organization,proto3" json:"organization,omitempty"`
	// contains filtered or unexported fields
}

type DeleteBucketConfigurationRequest struct {
	BucketName string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	// contains filtered or unexported fields
}

type DeleteBucketConfigurationResponse struct {
	// contains filtered or unexported fields
}

type DeleteBucketPrefixMappingRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type DeleteBucketPrefixMappingResponse struct {
	// contains filtered or unexported fields
}

type DeleteLogStreamConfigRequest struct {
	OrganizationId string `protobuf:"bytes,1,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
	// contains filtered or unexported fields
}

type DeleteLogStreamConfigResponse struct {
	// contains filtered or unexported fields
}

type DeleteOrganizationAPIKeyRequest struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type DeleteOrganizationAPIKeyResponse struct {
	// contains filtered or unexported fields
}

type DeleteOrganizationBucketRequest struct {
	OrganizationId string `protobuf:"bytes,1,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
	BucketName     string `protobuf:"bytes,2,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	InstanceNum    int32  `protobuf:"varint,3,opt,name=instance_num,json=instanceNum,proto3" json:"instance_num,omitempty"`
	CollectorName  string `protobuf:"bytes,4,opt,name=collector_name,json=collectorName,proto3" json:"collector_name,omitempty"`
	// contains filtered or unexported fields
}

type DeleteOrganizationBucketResponse struct {
	// contains filtered or unexported fields
}

type GetConsumerLagRequest struct {
	GroupFilter string `protobuf:"bytes,1,opt,name=group_filter,json=groupFilter,proto3" json:"group_filter,omitempty"`
	TopicFilter string `protobuf:"bytes,2,opt,name=topic_filter,json=topicFilter,proto3" json:"topic_filter,omitempty"`
	// contains filtered or unexported fields
}

type GetConsumerLagResponse struct {
	Lags []*ConsumerPartitionLag `protobuf:"bytes,1,rep,name=lags,proto3" json:"lags,omitempty"`
	// contains filtered or unexported fields
}

type GetLogStreamConfigRequest struct {
	OrganizationId string `protobuf:"bytes,1,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
	// contains filtered or unexported fields
}

type GetLogStreamConfigResponse struct {
	Config    *LogStreamConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	IsDefault bool             `protobuf:"varint,2,opt,name=is_default,json=isDefault,proto3" json:"is_default,omitempty"` // True if returning the system default (no org-specific config)
	// contains filtered or unexported fields
}

type GetWorkQueueStatusRequest struct {
	// contains filtered or unexported fields
}

type GetWorkQueueStatusResponse struct {
	Tasks []*WorkQueueTaskStatus `protobuf:"bytes,1,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

type InQueueItem struct {
	Count         int64  `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	TelemetryType string `protobuf:"bytes,2,opt,name=telemetry_type,json=telemetryType,proto3" json:"telemetry_type,omitempty"`
	// contains filtered or unexported fields
}

type InQueueStatusRequest struct {
	// contains filtered or unexported fields
}

type InQueueStatusResponse struct {
	Items []*InQueueItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

type ListBucketConfigurationsRequest struct {
	// contains filtered or unexported fields
}

type ListBucketConfigurationsResponse struct {
	Configurations []*BucketConfiguration `protobuf:"bytes,1,rep,name=configurations,proto3" json:"configurations,omitempty"`
	// contains filtered or unexported fields
}

type ListBucketPrefixMappingsRequest struct {
	BucketName     string `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`             // Optional filter
	OrganizationId string `protobuf:"bytes,2,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"` // Optional filter
	// contains filtered or unexported fields
}

type ListBucketPrefixMappingsResponse struct {
	Mappings []*BucketPrefixMapping `protobuf:"bytes,1,rep,name=mappings,proto3" json:"mappings,omitempty"`
	// contains filtered or unexported fields
}

type ListOrganizationAPIKeysRequest struct {
	OrganizationId string `protobuf:"bytes,1,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
	// contains filtered or unexported fields
}

type ListOrganizationAPIKeysResponse struct {
	ApiKeys []*OrganizationAPIKey `protobuf:"bytes,1,rep,name=api_keys,json=apiKeys,proto3" json:"api_keys,omitempty"`
	// contains filtered or unexported fields
}

type ListOrganizationBucketsRequest struct {
	OrganizationId string `protobuf:"bytes,1,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
	// contains filtered or unexported fields
}

type ListOrganizationBucketsResponse struct {
	Buckets []*OrganizationBucket `protobuf:"bytes,1,rep,name=buckets,proto3" json:"buckets,omitempty"`
	// contains filtered or unexported fields
}

type ListOrganizationsRequest struct {
	// contains filtered or unexported fields
}

type ListOrganizationsResponse struct {
	Organizations []*Organization `protobuf:"bytes,1,rep,name=organizations,proto3" json:"organizations,omitempty"`
	// contains filtered or unexported fields
}

type LogSegmentInfo struct {
	SegmentId    int64 `protobuf:"varint,1,opt,name=segment_id,json=segmentId,proto3" json:"segment_id,omitempty"`
	Dateint      int32 `protobuf:"varint,2,opt,name=dateint,proto3" json:"dateint,omitempty"`
	InstanceNum  int32 `protobuf:"varint,3,opt,name=instance_num,json=instanceNum,proto3" json:"instance_num,omitempty"`
	RecordCount  int64 `protobuf:"varint,4,opt,name=record_count,json=recordCount,proto3" json:"record_count,omitempty"`
	SortVersion  int32 `protobuf:"varint,5,opt,name=sort_version,json=sortVersion,proto3" json:"sort_version,omitempty"`
	HasAggFields bool  `protobuf:"varint,6,opt,name=has_agg_fields,json=hasAggFields,proto3" json:"has_agg_fields,omitempty"`
	// contains filtered or unexported fields
}

type LogStreamConfig struct {
	OrganizationId string `protobuf:"bytes,1,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
	FieldName      string `protobuf:"bytes,2,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"` // The field used for stream identification (e.g., "resource_service_name")
	// contains filtered or unexported fields
}

type Organization struct {
	Id      string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name    string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Enabled bool   `protobuf:"varint,3,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// contains filtered or unexported fields
}

type OrganizationAPIKey struct {
	Id             string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	OrganizationId string `protobuf:"bytes,2,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
	Name           string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Description    string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"`
	KeyPreview     string `protobuf:"bytes,5,opt,name=key_preview,json=keyPreview,proto3" json:"key_preview,omitempty"` // First few chars of the key for display
	// contains filtered or unexported fields
}

type OrganizationBucket struct {
	OrganizationId string `protobuf:"bytes,1,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
	BucketName     string `protobuf:"bytes,2,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
	InstanceNum    int32  `protobuf:"varint,3,opt,name=instance_num,json=instanceNum,proto3" json:"instance_num,omitempty"`
	CollectorName  string `protobuf:"bytes,4,opt,name=collector_name,json=collectorName,proto3" json:"collector_name,omitempty"`
	// contains filtered or unexported fields
}

type PingRequest struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

type PingResponse struct {
	Message   string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Timestamp int64  `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	ServerId  string `protobuf:"bytes,3,opt,name=server_id,json=serverId,proto3" json:"server_id,omitempty"`
	// contains filtered or unexported fields
}

type QueueLogRecompactRequest struct {
	OrganizationId          string `protobuf:"bytes,1,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
	StartDateint            int32  `protobuf:"varint,2,opt,name=start_dateint,json=startDateint,proto3" json:"start_dateint,omitempty"`
	EndDateint              int32  `protobuf:"varint,3,opt,name=end_dateint,json=endDateint,proto3" json:"end_dateint,omitempty"`
	MissingAggFields        bool   `protobuf:"varint,4,opt,name=missing_agg_fields,json=missingAggFields,proto3" json:"missing_agg_fields,omitempty"` // Filter: segments where agg_fields IS NULL
	SortVersionBelowCurrent bool   ``                                                                                                                 // Filter: segments where sort_version < current
	/* 135-byte string literal not displayed */
	DryRun bool `protobuf:"varint,6,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"` // If true, return matching segments without queueing
	// contains filtered or unexported fields
}

type QueueLogRecompactResponse struct {
	SegmentsQueued int32             `protobuf:"varint,1,opt,name=segments_queued,json=segmentsQueued,proto3" json:"segments_queued,omitempty"`
	Segments       []*LogSegmentInfo `protobuf:"bytes,2,rep,name=segments,proto3" json:"segments,omitempty"` // Segments that were (or would be) queued
	// contains filtered or unexported fields
}

type SetLogStreamConfigRequest struct {
	OrganizationId string `protobuf:"bytes,1,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
	FieldName      string `protobuf:"bytes,2,opt,name=field_name,json=fieldName,proto3" json:"field_name,omitempty"`
	// contains filtered or unexported fields
}

type SetLogStreamConfigResponse struct {
	Config *LogStreamConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedAdminServiceServer struct{}

type UnsafeAdminServiceServer interface {
	// contains filtered or unexported methods
}

type UpdateOrganizationRequest struct {
	Id      string                  `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name    *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Enabled *wrapperspb.BoolValue   `protobuf:"bytes,3,opt,name=enabled,proto3" json:"enabled,omitempty"`
	// contains filtered or unexported fields
}

type UpdateOrganizationResponse struct {
	Organization *Organization `protobuf:"bytes,1,opt,name=organization,proto3" json:"organization,omitempty"`
	// contains filtered or unexported fields
}

type WorkQueueTaskStatus struct {
	TaskName   string `protobuf:"bytes,1,opt,name=task_name,json=taskName,proto3" json:"task_name,omitempty"`
	Pending    int64  `protobuf:"varint,2,opt,name=pending,proto3" json:"pending,omitempty"`
	InProgress int64  `protobuf:"varint,3,opt,name=in_progress,json=inProgress,proto3" json:"in_progress,omitempty"`
	Failed     int64  `protobuf:"varint,4,opt,name=failed,proto3" json:"failed,omitempty"`
	Workers    int64  `protobuf:"varint,5,opt,name=workers,proto3" json:"workers,omitempty"`
	Priority   int32  `protobuf:"varint,6,opt,name=priority,proto3" json:"priority,omitempty"` // Priority level (lower = higher priority)
	// contains filtered or unexported fields
}