disk

package
v1.5.2-rc1 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 27, 2023 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DiskTypeFilesystem = "filesystem"
	DiskTypeBlock      = "block"
)

Variables

This section is empty.

Functions

This section is empty.

Types

type GRPCHealthChecker

type GRPCHealthChecker struct{}

func (*GRPCHealthChecker) IsRunning

func (c *GRPCHealthChecker) IsRunning(address string) bool

func (*GRPCHealthChecker) WaitForRunning

func (c *GRPCHealthChecker) WaitForRunning(address, name string, stopCh chan struct{}) bool

type HealthChecker

type HealthChecker interface {
	IsRunning(address string) bool
	WaitForRunning(address, name string, stopCh chan struct{}) bool
}

type Server

type Server struct {
	sync.RWMutex

	HealthChecker HealthChecker
	// contains filtered or unexported fields
}

func NewServer

func NewServer(spdkEnabled bool, spdkServiceAddress string, shutdownCh chan error) (*Server, error)

func (*Server) DiskCreate

func (s *Server) DiskCreate(ctx context.Context, req *rpc.DiskCreateRequest) (*rpc.Disk, error)

func (*Server) DiskDelete

func (s *Server) DiskDelete(ctx context.Context, req *rpc.DiskDeleteRequest) (*emptypb.Empty, error)

func (*Server) DiskGet

func (s *Server) DiskGet(ctx context.Context, req *rpc.DiskGetRequest) (*rpc.Disk, error)

func (*Server) DiskReplicaInstanceDelete

func (s *Server) DiskReplicaInstanceDelete(ctx context.Context, req *rpc.DiskReplicaInstanceDeleteRequest) (*empty.Empty, error)

func (*Server) VersionGet

func (s *Server) VersionGet(ctx context.Context, req *empty.Empty) (*rpc.DiskVersionResponse, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL