admin

package
v1.11.0 Latest Latest
Warning

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

 Go to latest Published: Feb 17, 2026 License: AGPL-3.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type LRDBStore added in v1.8.0 

type LRDBStore interface {
	workqueue.EnqueueDB
	WorkQueueStatus(ctx context.Context) ([]lrdb.WorkQueueStatusRow, error)
	ListLogSegsForRecompact(ctx context.Context, arg lrdb.ListLogSegsForRecompactParams) ([]lrdb.LogSeg, error)
}

LRDBStore defines the lrdb operations needed by the admin service.

type Service 

type Service struct {
	adminproto.UnimplementedAdminServiceServer
	// contains filtered or unexported fields
}

func NewService 

func NewService(addr string, configDB configdb.StoreFull, lrDB LRDBStore) (*Service, error)

func (*Service) AddOrganizationBucket added in v1.4.0 

func (s *Service) AddOrganizationBucket(ctx context.Context, req *adminproto.AddOrganizationBucketRequest) (*adminproto.AddOrganizationBucketResponse, error)

AddOrganizationBucket adds a bucket to an organization

func (*Service) CreateBucketConfiguration added in v1.4.0 

func (s *Service) CreateBucketConfiguration(ctx context.Context, req *adminproto.CreateBucketConfigurationRequest) (*adminproto.CreateBucketConfigurationResponse, error)

CreateBucketConfiguration creates a new bucket configuration

func (*Service) CreateBucketPrefixMapping added in v1.4.0 

func (s *Service) CreateBucketPrefixMapping(ctx context.Context, req *adminproto.CreateBucketPrefixMappingRequest) (*adminproto.CreateBucketPrefixMappingResponse, error)

CreateBucketPrefixMapping creates a new bucket prefix mapping

func (*Service) CreateOrganization 

func (s *Service) CreateOrganization(ctx context.Context, req *adminproto.CreateOrganizationRequest) (*adminproto.CreateOrganizationResponse, error)

func (*Service) CreateOrganizationAPIKey added in v1.4.0 

func (s *Service) CreateOrganizationAPIKey(ctx context.Context, req *adminproto.CreateOrganizationAPIKeyRequest) (*adminproto.CreateOrganizationAPIKeyResponse, error)

CreateOrganizationAPIKey creates a new API key for an organization

func (*Service) DeleteBucketConfiguration added in v1.4.0 

func (s *Service) DeleteBucketConfiguration(ctx context.Context, req *adminproto.DeleteBucketConfigurationRequest) (*adminproto.DeleteBucketConfigurationResponse, error)

DeleteBucketConfiguration deletes a bucket configuration

func (*Service) DeleteBucketPrefixMapping added in v1.4.0 

func (s *Service) DeleteBucketPrefixMapping(ctx context.Context, req *adminproto.DeleteBucketPrefixMappingRequest) (*adminproto.DeleteBucketPrefixMappingResponse, error)

DeleteBucketPrefixMapping deletes a bucket prefix mapping

func (*Service) DeleteLogStreamConfig added in v1.7.0 

func (s *Service) DeleteLogStreamConfig(ctx context.Context, req *adminproto.DeleteLogStreamConfigRequest) (*adminproto.DeleteLogStreamConfigResponse, error)

DeleteLogStreamConfig deletes the org-specific log stream configuration. After deletion, the org will use the system default.

func (*Service) DeleteOrganizationAPIKey added in v1.4.0 

func (s *Service) DeleteOrganizationAPIKey(ctx context.Context, req *adminproto.DeleteOrganizationAPIKeyRequest) (*adminproto.DeleteOrganizationAPIKeyResponse, error)

DeleteOrganizationAPIKey deletes an API key

func (*Service) DeleteOrganizationBucket added in v1.4.0 

func (s *Service) DeleteOrganizationBucket(ctx context.Context, req *adminproto.DeleteOrganizationBucketRequest) (*adminproto.DeleteOrganizationBucketResponse, error)

DeleteOrganizationBucket removes a bucket from an organization

func (*Service) GetConsumerLag added in v1.3.6 

func (s *Service) GetConsumerLag(ctx context.Context, req *adminproto.GetConsumerLagRequest) (*adminproto.GetConsumerLagResponse, error)

func (*Service) GetLogStreamConfig added in v1.7.0 

func (s *Service) GetLogStreamConfig(ctx context.Context, req *adminproto.GetLogStreamConfigRequest) (*adminproto.GetLogStreamConfigResponse, error)

GetLogStreamConfig gets the log stream configuration for an organization. If no org-specific config exists, returns the system default or hardcoded fallback.

func (*Service) GetWorkQueueStatus added in v1.7.0 

func (s *Service) GetWorkQueueStatus(ctx context.Context, _ *adminproto.GetWorkQueueStatusRequest) (*adminproto.GetWorkQueueStatusResponse, error)

func (*Service) InQueueStatus 

func (s *Service) InQueueStatus(ctx context.Context, req *adminproto.InQueueStatusRequest) (*adminproto.InQueueStatusResponse, error)

func (*Service) ListBucketConfigurations added in v1.4.0 

func (s *Service) ListBucketConfigurations(ctx context.Context, req *adminproto.ListBucketConfigurationsRequest) (*adminproto.ListBucketConfigurationsResponse, error)

ListBucketConfigurations lists all bucket configurations

func (*Service) ListBucketPrefixMappings added in v1.4.0 

func (s *Service) ListBucketPrefixMappings(ctx context.Context, req *adminproto.ListBucketPrefixMappingsRequest) (*adminproto.ListBucketPrefixMappingsResponse, error)

ListBucketPrefixMappings lists bucket prefix mappings

func (*Service) ListOrganizationAPIKeys added in v1.4.0 

func (s *Service) ListOrganizationAPIKeys(ctx context.Context, req *adminproto.ListOrganizationAPIKeysRequest) (*adminproto.ListOrganizationAPIKeysResponse, error)

ListOrganizationAPIKeys lists all API keys for an organization

func (*Service) ListOrganizationBuckets added in v1.4.0 

func (s *Service) ListOrganizationBuckets(ctx context.Context, req *adminproto.ListOrganizationBucketsRequest) (*adminproto.ListOrganizationBucketsResponse, error)

ListOrganizationBuckets lists all buckets for an organization

func (*Service) ListOrganizations 

func (s *Service) ListOrganizations(ctx context.Context, _ *adminproto.ListOrganizationsRequest) (*adminproto.ListOrganizationsResponse, error)

func (*Service) Ping 

func (s *Service) Ping(ctx context.Context, req *adminproto.PingRequest) (*adminproto.PingResponse, error)

func (*Service) QueueLogRecompact added in v1.8.0 

func (s *Service) QueueLogRecompact(ctx context.Context, req *adminproto.QueueLogRecompactRequest) (*adminproto.QueueLogRecompactResponse, error)

func (*Service) Run 

func (s *Service) Run(ctx context.Context) error

func (*Service) SetLogStreamConfig added in v1.7.0 

func (s *Service) SetLogStreamConfig(ctx context.Context, req *adminproto.SetLogStreamConfigRequest) (*adminproto.SetLogStreamConfigResponse, error)

SetLogStreamConfig sets or updates the log stream configuration for an organization.

func (*Service) UpdateOrganization 

func (s *Service) UpdateOrganization(ctx context.Context, req *adminproto.UpdateOrganizationRequest) (*adminproto.UpdateOrganizationResponse, 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.