client

Documentation

Index

• func DoRequest(url string) ([]byte, error)
• func MustRunThisWhenTest()
• type Connection
  • func NewGrpcConnection(address string, timeout time.Duration) (Connection, error)
• type LVMOptions

Functions

func DoRequest

func DoRequest(url string) ([]byte, error)

DoRequest Http Post Request

func MustRunThisWhenTest

func MustRunThisWhenTest()

Types

type Connection

type Connection interface {
	GetVolume(ctx context.Context, volGroup string, volumeID string) (string, error)
	CreateVolume(ctx context.Context, opt *LVMOptions) (string, error)
	DeleteVolume(ctx context.Context, volGroup string, volumeID string) error
	CreateSnapshot(ctx context.Context, vgName string, snapshotName string, srcVolumeName string, readonly bool, roInitSize int64, secrets map[string]string) (int64, error)
	DeleteSnapshot(ctx context.Context, volGroup string, snapVolumeID string, readonly bool, secrets map[string]string) error
	ExpandVolume(ctx context.Context, volGroup string, volumeID string, size uint64) error
	CleanPath(ctx context.Context, path string) error
	CleanDevice(ctx context.Context, device string) error
	Close() error
}

Connection lvm connection interface

func NewGrpcConnection

func NewGrpcConnection(address string, timeout time.Duration) (Connection, error)

NewGrpcConnection lvm connection

type LVMOptions

type LVMOptions struct {
	VolumeGroup string   `json:"volumeGroup,omitempty"`
	Name        string   `json:"name,omitempty"`
	Size        uint64   `json:"size,omitempty"`
	Tags        []string `json:"tags,omitempty"`
	Striping    bool     `json:"striping,omitempty"`
}

LVMOptions lvm options