disk

Documentation

Index

• Constants
• type GRPCHealthChecker
  • func (c *GRPCHealthChecker) IsRunning(address string) bool
  • func (c *GRPCHealthChecker) WaitForRunning(address, name string, stopCh chan struct{}) bool
• type HealthChecker
• type Server
  • func NewServer(spdkEnabled bool, spdkServiceAddress string, shutdownCh chan error) (*Server, error)
  • func (s *Server) DiskCreate(ctx context.Context, req *rpc.DiskCreateRequest) (*rpc.Disk, error)
  • func (s *Server) DiskDelete(ctx context.Context, req *rpc.DiskDeleteRequest) (*emptypb.Empty, error)
  • func (s *Server) DiskGet(ctx context.Context, req *rpc.DiskGetRequest) (*rpc.Disk, error)
  • func (s *Server) DiskReplicaInstanceDelete(ctx context.Context, req *rpc.DiskReplicaInstanceDeleteRequest) (*empty.Empty, error)
  • func (s *Server) DiskReplicaInstanceList(ctx context.Context, req *rpc.DiskReplicaInstanceListRequest) (*rpc.DiskReplicaInstanceListResponse, error)
  • func (s *Server) VersionGet(ctx context.Context, req *empty.Empty) (*rpc.DiskVersionResponse, error)

Constants

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

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) DiskReplicaInstanceList

func (s *Server) DiskReplicaInstanceList(ctx context.Context, req *rpc.DiskReplicaInstanceListRequest) (*rpc.DiskReplicaInstanceListResponse, error)

func (*Server) VersionGet

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