client

Documentation

Index

• type Client
  • func New(addr string, timeout time.Duration, metricsmanager metrics.CSIMetricsManager) (Client, error)
• type FakeClient
  • func NewFakeClient(name string, driverSupportsModification bool, modificationShouldFail bool) *FakeClient
  • func (f *FakeClient) CloseConnection()
  • func (f *FakeClient) GetDriverName(context.Context) (string, error)
  • func (f *FakeClient) GetModifyCallCount() int
  • func (f *FakeClient) GetParams() map[string]string
  • func (f *FakeClient) GetReqContext() map[string]string
  • func (f *FakeClient) GetVolumeName() string
  • func (f *FakeClient) Modify(ctx context.Context, volumeID string, params, reqContext map[string]string) error
  • func (f *FakeClient) SupportsVolumeModification(context.Context) error

Types

type Client

type Client interface {
	GetDriverName(context.Context) (string, error)

	SupportsVolumeModification(context.Context) error

	Modify(ctx context.Context, volumeID string, params, reqContext map[string]string) error

	CloseConnection()
}

func New

func New(addr string, timeout time.Duration, metricsmanager metrics.CSIMetricsManager) (Client, error)

type FakeClient

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

func NewFakeClient

func NewFakeClient(
	name string,
	driverSupportsModification bool,
	modificationShouldFail bool,
) *FakeClient

func (*FakeClient) CloseConnection

func (f *FakeClient) CloseConnection()

func (*FakeClient) GetDriverName

func (f *FakeClient) GetDriverName(context.Context) (string, error)

func (*FakeClient) GetModifyCallCount

func (f *FakeClient) GetModifyCallCount() int

func (*FakeClient) GetParams

func (f *FakeClient) GetParams() map[string]string

func (*FakeClient) GetReqContext

func (f *FakeClient) GetReqContext() map[string]string

func (*FakeClient) GetVolumeName

func (f *FakeClient) GetVolumeName() string

func (*FakeClient) Modify

func (f *FakeClient) Modify(ctx context.Context, volumeID string, params, reqContext map[string]string) error

func (*FakeClient) SupportsVolumeModification

func (f *FakeClient) SupportsVolumeModification(context.Context) error