miniod

Documentation

Index

• func StopAll()
• type Process
  • func EnsureRunning(s *state.State, bucketVol storageDrivers.Volume) (*Process, error)
  • func Get(bucketName string) *Process
  • func (p *Process) AdminClient() (*madmin.AdminClient, error)
  • func (p *Process) AdminUser() string
  • func (p *Process) S3Client() (*minio.Client, error)
  • func (p *Process) Stop(ctx context.Context) error
  • func (p *Process) URL() url.URL
  • func (p *Process) WaitReady(ctx context.Context) error

Functions

func StopAll

func StopAll()

StopAll stops all MinIO processes cleanly.

Types

type Process

type Process struct {
	// contains filtered or unexported fields
}

Process represents a running minio process.

func EnsureRunning

func EnsureRunning(s *state.State, bucketVol storageDrivers.Volume) (*Process, error)

EnsureRunning starts a MinIO process for the bucket (if not already running) and returns running Process.

func Get

func Get(bucketName string) *Process

Get returns an existing MinIO process if it exists.

func (*Process) AdminClient

func (p *Process) AdminClient() (*madmin.AdminClient, error)

AdminClient returns admin client for the minio process.

func (*Process) AdminUser

func (p *Process) AdminUser() string

AdminUser returns admin user name.

func (*Process) S3Client

func (p *Process) S3Client() (*minio.Client, error)

S3Client returns S3 client for the minio process.

func (*Process) Stop

func (p *Process) Stop(ctx context.Context) error

Stop will try and cleanly stop the service and if context is cancelled then it forcefully kills the process. If ctx doesn't have a deadline then a default timeout of 5s is added.

func (*Process) URL

func (p *Process) URL() url.URL

URL of MinIO process.

func (*Process) WaitReady

func (p *Process) WaitReady(ctx context.Context) error

WaitReady waits until process is ready.