disk

Documentation

Index

• type API
• type Server
  • func NewServer(hostAPI API) (*Server, error)
  • func (s *Server) DiskStats(context context.Context, request *internal.DiskStatsRequest, ...) (*internal.DiskStatsResponse, error)
  • func (s *Server) GetDiskNumberByName(context context.Context, request *internal.GetDiskNumberByNameRequest, ...) (*internal.GetDiskNumberByNameResponse, error)
  • func (s *Server) ListDiskIDs(context context.Context, request *internal.ListDiskIDsRequest, ...) (*internal.ListDiskIDsResponse, error)
  • func (s *Server) ListDiskLocations(context context.Context, request *internal.ListDiskLocationsRequest, ...) (*internal.ListDiskLocationsResponse, error)
  • func (s *Server) PartitionDisk(context context.Context, request *internal.PartitionDiskRequest, ...) (*internal.PartitionDiskResponse, error)
  • func (s *Server) Rescan(context context.Context, request *internal.RescanRequest, ...) (*internal.RescanResponse, error)
  • func (s *Server) VersionedAPIs() []*srvtypes.VersionedAPI

Types

type API

type API interface {
	ListDiskLocations() (map[string]shared.DiskLocation, error)
	IsDiskInitialized(diskID string) (bool, error)
	InitializeDisk(diskID string) error
	PartitionsExist(diskID string) (bool, error)
	CreatePartition(diskID string) error
	Rescan() error
	GetDiskNumberByName(diskName string) (string, error)
	ListDiskIDs() (map[string]shared.DiskIDs, error)
	DiskStats(diskID string) (int64, error)
}

type Server

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

func NewServer

func NewServer(hostAPI API) (*Server, error)

func (*Server) DiskStats

func (s *Server) DiskStats(context context.Context, request *internal.DiskStatsRequest, version apiversion.Version) (*internal.DiskStatsResponse, error)

func (*Server) GetDiskNumberByName

func (s *Server) GetDiskNumberByName(context context.Context, request *internal.GetDiskNumberByNameRequest, version apiversion.Version) (*internal.GetDiskNumberByNameResponse, error)

func (*Server) ListDiskIDs

func (s *Server) ListDiskIDs(context context.Context, request *internal.ListDiskIDsRequest, version apiversion.Version) (*internal.ListDiskIDsResponse, error)

func (*Server) ListDiskLocations

func (s *Server) ListDiskLocations(context context.Context, request *internal.ListDiskLocationsRequest, version apiversion.Version) (*internal.ListDiskLocationsResponse, error)

func (*Server) PartitionDisk

func (s *Server) PartitionDisk(context context.Context, request *internal.PartitionDiskRequest, version apiversion.Version) (*internal.PartitionDiskResponse, error)

func (*Server) Rescan

func (s *Server) Rescan(context context.Context, request *internal.RescanRequest, version apiversion.Version) (*internal.RescanResponse, error)

func (*Server) VersionedAPIs

func (s *Server) VersionedAPIs() []*srvtypes.VersionedAPI