Documentation
¶
Index ¶
- func InitMinioConfig(conf *object.MinioConfig) (*object.MinioConfig, error)
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
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
}
Source Files
Click to show internal directories.
Click to hide internal directories.