server

Documentation

Index

• Constants
• type AggregatedImage
• type CephVolumeConfig
• type Options
• type Server
  • func New(imageStore store.Store[*cephapi.Image], ...) (*Server, error)
  • func (s *Server) CreateVolume(ctx context.Context, req *ori.CreateVolumeRequest) (res *ori.CreateVolumeResponse, retErr error)
  • func (s *Server) DeleteVolume(ctx context.Context, req *ori.DeleteVolumeRequest) (*ori.DeleteVolumeResponse, error)
  • func (s *Server) ExpandVolume(ctx context.Context, req *ori.ExpandVolumeRequest) (*ori.ExpandVolumeResponse, error)
  • func (s *Server) ListVolumes(ctx context.Context, req *ori.ListVolumesRequest) (*ori.ListVolumesResponse, error)
  • func (s *Server) Status(ctx context.Context, req *ori.StatusRequest) (*ori.StatusResponse, error)
• type VolumeClassRegistry

Constants

const (
	MonitorsKey = "monitors"
	ImageKey    = "image"
	UserIDKey   = "userID"
	UserKeyKey  = "userKey"
	DriverName  = "ceph"
)

const (
	EncryptionSecretDataPassphraseKey = "encryptionKey"
)

Types

type AggregatedImage

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

type CephVolumeConfig

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

type Options

type Options struct {
	IDGen idgen.IDGen

	BurstFactor            int64
	BurstDurationInSeconds int64
}

type Server

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

func New

func New(imageStore store.Store[*cephapi.Image],
	snapshotStore store.Store[*cephapi.Snapshot],
	volumeClassRegistry VolumeClassRegistry,
	keyEncryption encryption.Encryptor,
	cephCommandClient ceph.Command,
	opts Options,
) (*Server, error)

func (*Server) CreateVolume

func (s *Server) CreateVolume(ctx context.Context, req *ori.CreateVolumeRequest) (res *ori.CreateVolumeResponse, retErr error)

func (*Server) DeleteVolume

func (s *Server) DeleteVolume(ctx context.Context, req *ori.DeleteVolumeRequest) (*ori.DeleteVolumeResponse, error)

func (*Server) ExpandVolume

func (s *Server) ExpandVolume(ctx context.Context, req *ori.ExpandVolumeRequest) (*ori.ExpandVolumeResponse, error)

func (*Server) ListVolumes

func (s *Server) ListVolumes(ctx context.Context, req *ori.ListVolumesRequest) (*ori.ListVolumesResponse, error)

func (*Server) Status

func (s *Server) Status(ctx context.Context, req *ori.StatusRequest) (*ori.StatusResponse, error)

type VolumeClassRegistry

type VolumeClassRegistry interface {
	Get(volumeClassName string) (*ori.VolumeClass, bool)
	List() []*ori.VolumeClass
}