file

Documentation

Index

• func ApplyFilter(ops []*filev1beta1.Operation, uri string, opType string, done bool) ([]*filev1beta1.Operation, error)
• func CompareInstances(a, b *ServiceInstance) error
• func CompareMultishareInstances(a, b *MultishareInstance) error
• func CompareShares(a, b *Share) error
• func CreateBackpURI(obj *ServiceInstance, backupName, backupLocation string) (string, string, error)
• func GenerateMultishareInstanceURI(m *MultishareInstance) (string, error)
• func GenerateShareURI(s *Share) (string, error)
• func GetMultishareInstanceHandle(m *MultishareInstance) (string, error)
• func IsInstanceTarget(target string) bool
• func IsNotFoundErr(err error) bool
• func IsShareTarget(target string) bool
• func IsUserError(err error) *codes.Code
• func ParseShare(s *Share) (string, string, string, string, error)
• type BackupInfo
• type ListFilter
• type MultishareInstance
  • func (i *MultishareInstance) String() string
• type Network
• type PollOpts
• type Service
  • func NewFakeBlockingService(operationUnblocker chan chan struct{}) (Service, error)
  • func NewFakeBlockingServiceForMultishare(unblocker chan chan Signal) (Service, error)
  • func NewFakeService() (Service, error)
  • func NewFakeServiceForMultishare(instances []*MultishareInstance, shares []*Share, ...) (Service, error)
  • func NewGCFSService(version string, client *http.Client, endpoint string) (Service, error)
• type ServiceInstance
• type Share
• type Signal
• type Volume

Functions

func ApplyFilter

func ApplyFilter(ops []*filev1beta1.Operation, uri string, opType string, done bool) ([]*filev1beta1.Operation, error)

func CompareInstances

func CompareInstances(a, b *ServiceInstance) error

func CompareMultishareInstances

func CompareMultishareInstances(a, b *MultishareInstance) error

func CompareShares

func CompareShares(a, b *Share) error

func CreateBackpURI

func CreateBackpURI(obj *ServiceInstance, backupName, backupLocation string) (string, string, error)

This function returns the backup URI, the region that was picked to be the backup resource location and error.

func GenerateMultishareInstanceURI

func GenerateMultishareInstanceURI(m *MultishareInstance) (string, error)

func GenerateShareURI

func GenerateShareURI(s *Share) (string, error)

func GetMultishareInstanceHandle

func GetMultishareInstanceHandle(m *MultishareInstance) (string, error)

func IsInstanceTarget

func IsInstanceTarget(target string) bool

func IsNotFoundErr

func IsNotFoundErr(err error) bool

func IsShareTarget

func IsShareTarget(target string) bool

func IsUserError

func IsUserError(err error) *codes.Code

IsUserError returns a pointer to the grpc error code that maps to the http error code for the passed in user googleapi error. Returns nil if the given error is not a googleapi error caused by the user. The following http error codes are considered user errors: (1) http 400 Bad Request, returns grpc InvalidArgument, (2) http 403 Forbidden, returns grpc PermissionDenied, (3) http 404 Not Found, returns grpc NotFound (4) http 429 Too Many Requests, returns grpc ResourceExhausted

func ParseShare

func ParseShare(s *Share) (string, string, string, string, error)

Types

type BackupInfo

type BackupInfo struct {
	Backup             *filev1beta1.Backup
	SourceVolumeHandle string
}

type ListFilter

type ListFilter struct {
	Project      string
	Location     string
	InstanceName string
}

type MultishareInstance

type MultishareInstance struct {
	Project            string
	Name               string
	Location           string
	Tier               string
	Network            Network
	CapacityBytes      int64
	MaxCapacityBytes   int64
	CapacityStepSizeGb int64
	Labels             map[string]string
	State              string
	KmsKeyName         string
	Description        string
}

func (*MultishareInstance) String

func (i *MultishareInstance) String() string

type Network

type Network struct {
	Name            string
	ConnectMode     string
	ReservedIpRange string
	Ip              string
}

type PollOpts

type PollOpts struct {
	Interval time.Duration
	Timeout  time.Duration
}

type Service

type Service interface {
	CreateInstance(ctx context.Context, obj *ServiceInstance) (*ServiceInstance, error)
	DeleteInstance(ctx context.Context, obj *ServiceInstance) error
	GetInstance(ctx context.Context, obj *ServiceInstance) (*ServiceInstance, error)
	ListInstances(ctx context.Context, obj *ServiceInstance) ([]*ServiceInstance, error)
	ResizeInstance(ctx context.Context, obj *ServiceInstance) (*ServiceInstance, error)
	GetBackup(ctx context.Context, backupUri string) (*BackupInfo, error)
	CreateBackup(ctx context.Context, obj *ServiceInstance, backupId, backupLocation string) (*filev1beta1.Backup, error)
	DeleteBackup(ctx context.Context, backupId string) error
	CreateInstanceFromBackupSource(ctx context.Context, obj *ServiceInstance, volumeSourceSnapshotId string) (*ServiceInstance, error)
	HasOperations(ctx context.Context, obj *ServiceInstance, operationType string, done bool) (bool, error)
	// Multishare ops
	GetMultishareInstance(ctx context.Context, obj *MultishareInstance) (*MultishareInstance, error)
	ListMultishareInstances(ctx context.Context, filter *ListFilter) ([]*MultishareInstance, error)
	StartCreateMultishareInstanceOp(ctx context.Context, obj *MultishareInstance) (*filev1beta1multishare.Operation, error)
	StartDeleteMultishareInstanceOp(ctx context.Context, obj *MultishareInstance) (*filev1beta1multishare.Operation, error)
	StartResizeMultishareInstanceOp(ctx context.Context, obj *MultishareInstance) (*filev1beta1multishare.Operation, error)
	ListShares(ctx context.Context, filter *ListFilter) ([]*Share, error)
	GetShare(ctx context.Context, obj *Share) (*Share, error)
	StartCreateShareOp(ctx context.Context, obj *Share) (*filev1beta1multishare.Operation, error)
	StartDeleteShareOp(ctx context.Context, obj *Share) (*filev1beta1multishare.Operation, error)
	StartResizeShareOp(ctx context.Context, obj *Share) (*filev1beta1multishare.Operation, error)
	WaitForOpWithOpts(ctx context.Context, op string, opts PollOpts) error
	GetOp(ctx context.Context, op string) (*filev1beta1multishare.Operation, error)
	IsOpDone(op *filev1beta1multishare.Operation) (bool, error)
	ListOps(ctx context.Context, resource *ListFilter) ([]*filev1beta1multishare.Operation, error)
}

func NewFakeBlockingService

func NewFakeBlockingService(operationUnblocker chan chan struct{}) (Service, error)

func NewFakeBlockingServiceForMultishare

func NewFakeBlockingServiceForMultishare(unblocker chan chan Signal) (Service, error)

func NewFakeService

func NewFakeService() (Service, error)

func NewFakeServiceForMultishare

func NewFakeServiceForMultishare(instances []*MultishareInstance, shares []*Share, ops []*filev1beta1multishare.Operation) (Service, error)

func NewGCFSService

func NewGCFSService(version string, client *http.Client, endpoint string) (Service, error)

type ServiceInstance

type ServiceInstance struct {
	Project    string
	Name       string
	Location   string
	Tier       string
	Network    Network
	Volume     Volume
	Labels     map[string]string
	State      string
	KmsKeyName string
}

type Share

type Share struct {
	Name           string              // only the share name
	Parent         *MultishareInstance // parent captures the project, location details.
	State          string
	MountPointName string
	Labels         map[string]string
	CapacityBytes  int64
}

type Signal

type Signal struct {
	ReportError             bool
	ReportNotFoundError     bool
	ReportRunning           bool
	ReportOpWithErrorStatus bool
}

type Volume

type Volume struct {
	Name      string
	SizeBytes int64
}