grpc

Documentation

Index

• func InitMinioConfig(conf *object.MinioConfig) (*object.MinioConfig, error)
• type ObjectHandler
  • func NewObjectHandlerWithPreset(mc *object.MinioConfig) *ObjectHandler
  • func NewSharedObjectHandler(resolver *source.Resolver[*RunningMinioHandler]) *ObjectHandler
  • func (o *ObjectHandler) CleanResourcesBeforeDelete(ctx context.Context, request *object.CleanResourcesRequest) (resp *object.CleanResourcesResponse, err error)
  • func (o *ObjectHandler) GetMinioConfig(ctx context.Context, _ *object.GetMinioConfigRequest) (*object.GetMinioConfigResponse, error)
  • func (o *ObjectHandler) MinioStaleDataCleaner(ctx context.Context, rootFolder string)
  • func (o *ObjectHandler) Ready(ctx context.Context, req *server.ReadyCheckRequest) (*server.ReadyCheckResponse, error)
  • func (o *ObjectHandler) StartMinioServer(ctx context.Context, conf *object.MinioConfig, minioServiceName string) error
  • func (o *ObjectHandler) StorageStats(ctx context.Context, _ *object.StorageStatsRequest) (*object.StorageStatsResponse, error)
• type RunningMinioHandler

Functions

func InitMinioConfig

func InitMinioConfig(conf *object.MinioConfig) (*object.MinioConfig, error)

Types

type ObjectHandler

type ObjectHandler struct {
	grpc_health_v1.HealthServer
	object.UnimplementedObjectsEndpointServer
	object.UnimplementedResourceCleanerEndpointServer
	*source.Resolver[*RunningMinioHandler]
	PresetConfig *object.MinioConfig
	server.UnimplementedReadyzServer
}

ObjectHandler definition

func NewObjectHandlerWithPreset

func NewObjectHandlerWithPreset(mc *object.MinioConfig) *ObjectHandler

func NewSharedObjectHandler

func NewSharedObjectHandler(resolver *source.Resolver[*RunningMinioHandler]) *ObjectHandler

NewSharedObjectHandler creates a stateless handler for exposing configs

func (*ObjectHandler) CleanResourcesBeforeDelete

func (o *ObjectHandler) CleanResourcesBeforeDelete(ctx context.Context, request *object.CleanResourcesRequest) (resp *object.CleanResourcesResponse, err error)

CleanResourcesBeforeDelete removes the .minio.sys/config folder if it exists

func (*ObjectHandler) GetMinioConfig

func (o *ObjectHandler) GetMinioConfig(ctx context.Context, _ *object.GetMinioConfigRequest) (*object.GetMinioConfigResponse, error)

GetMinioConfig returns current configuration

func (*ObjectHandler) MinioStaleDataCleaner

func (o *ObjectHandler) MinioStaleDataCleaner(ctx context.Context, rootFolder string)

MinioStaleDataCleaner looks up for stala data inside .minio.sys/tmp and .minio.sys/multipart on a regular basis. Defaults are 48h for expiry and 12h for interval. Expiry can be overriden with the CELLS_MINIO_STALE_DATA_EXPIRY env variable, in which case interval = expiry / 2

func (*ObjectHandler) Ready

func (o *ObjectHandler) Ready(ctx context.Context, req *server.ReadyCheckRequest) (*server.ReadyCheckResponse, error)

Ready overrides ReadyzServer.Ready by getting minio config

func (*ObjectHandler) StartMinioServer

func (o *ObjectHandler) StartMinioServer(ctx context.Context, conf *object.MinioConfig, minioServiceName string) error

StartMinioServer handler

func (*ObjectHandler) StorageStats

func (o *ObjectHandler) StorageStats(ctx context.Context, _ *object.StorageStatsRequest) (*object.StorageStatsResponse, error)

StorageStats returns statistics about storage

type RunningMinioHandler

type RunningMinioHandler struct {
	*object.MinioConfig
	Cancel context.CancelFunc
}