client

Documentation

Index

• Constants
• type FakeClient
  • func (c *FakeClient) Delete(volumeId string) error
  • func (c *FakeClient) Provision(opts map[string]string) (string, error)
• type SdsClient
  • func (c *SdsClient) Delete(volumeId string) error
  • func (c *SdsClient) Provision(opts map[string]string) (string, error)
• type WarpOpensdsClient
  • func NewFakeClient(endpoint string, authStrategy string) WarpOpensdsClient
  • func NewSdsClient(endpoint string, authStrategy string) WarpOpensdsClient

Constants

const (
	// OpenSDSEndPoint environment variable name
	OpenSDSEndPoint = "OPENSDS_ENDPOINT"

	// OpenSDSAuthStrategy environment variable name
	OpenSDSAuthStrategy = "OPENSDS_AUTH_STRATEGY"
)

const (
	KVolumeName       = "kubernetes.io/volumeName"
	KVolumeSize       = "kubernetes.io/size"
	KAvailabilityZone = "kubernetes.io/availabilityZone"
	KVolumeId         = "volumeId"
	KFsType           = "kubernetes.io/type"
)

Types

type FakeClient

type FakeClient struct {
}

func (*FakeClient) Delete

func (c *FakeClient) Delete(volumeId string) error

func (*FakeClient) Provision

func (c *FakeClient) Provision(opts map[string]string) (string, error)

type SdsClient

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

func (*SdsClient) Delete

func (c *SdsClient) Delete(volumeId string) error

func (*SdsClient) Provision

func (c *SdsClient) Provision(opts map[string]string) (string, error)

type WarpOpensdsClient

type WarpOpensdsClient interface {
	Provision(opts map[string]string) (string, error)
	Delete(volumeId string) error
}

func NewFakeClient

func NewFakeClient(endpoint string, authStrategy string) WarpOpensdsClient

func NewSdsClient

func NewSdsClient(endpoint string, authStrategy string) WarpOpensdsClient