Documentation
¶
Overview ¶
Package grpc wraps a Minio server for exposing the content of the datasource with the S3 protocol.
Index ¶
- type ObjectHandler
- func (o *ObjectHandler) CleanResourcesBeforeDelete(ctx context.Context, request *object.CleanResourcesRequest) (resp *object.CleanResourcesResponse, err error)
- func (o *ObjectHandler) GetMinioConfig(_ context.Context, _ *object.GetMinioConfigRequest) (*object.GetMinioConfigResponse, error)
- func (o *ObjectHandler) MinioStaleDataCleaner(ctx context.Context, rootFolder string)
- func (o *ObjectHandler) Name() string
- func (o *ObjectHandler) StartMinioServer(ctx context.Context, minioServiceName string) error
- func (o *ObjectHandler) StorageStats(_ context.Context, _ *object.StorageStatsRequest) (*object.StorageStatsResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ObjectHandler ¶
type ObjectHandler struct {
object.UnimplementedObjectsEndpointServer
object.UnimplementedResourceCleanerEndpointServer
Config *object.MinioConfig
MinioConsolePort int
// contains filtered or unexported fields
}
ObjectHandler definition
func (*ObjectHandler) CleanResourcesBeforeDelete ¶ added in v4.0.6
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(_ context.Context, _ *object.GetMinioConfigRequest) (*object.GetMinioConfigResponse, error)
GetMinioConfig returns current configuration
func (*ObjectHandler) MinioStaleDataCleaner ¶ added in v4.3.1
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) Name ¶
func (o *ObjectHandler) Name() string
func (*ObjectHandler) StartMinioServer ¶
func (o *ObjectHandler) StartMinioServer(ctx context.Context, minioServiceName string) error
StartMinioServer handler
func (*ObjectHandler) StorageStats ¶
func (o *ObjectHandler) StorageStats(_ context.Context, _ *object.StorageStatsRequest) (*object.StorageStatsResponse, error)
StorageStats returns statistics about storage
Source Files
Click to show internal directories.
Click to hide internal directories.