grpc

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)

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

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

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