provider

Documentation

Index

• type Attributes
• type ConfigClient
• type Raw
• type SpringCloudConfigCSIProviderServer
  • func NewSpringCloudConfigCSIProviderServer(socketPath string, httpClient *http.Client, retryBaseWait time.Duration, ...) (*SpringCloudConfigCSIProviderServer, error)
  • func (m *SpringCloudConfigCSIProviderServer) Mount(ctx context.Context, req *v1alpha1.MountRequest) (*v1alpha1.MountResponse, error)
  • func (m *SpringCloudConfigCSIProviderServer) Start() error
  • func (m *SpringCloudConfigCSIProviderServer) Stop()
  • func (m *SpringCloudConfigCSIProviderServer) Version(ctx context.Context, req *v1alpha1.VersionRequest) (*v1alpha1.VersionResponse, error)
• type SpringCloudConfigClient
  • func NewSpringCloudConfigClient(c *http.Client, retryBaseWait time.Duration, retryMax uint64) SpringCloudConfigClient
  • func (c *SpringCloudConfigClient) GetConfig(attributes Attributes) (io.ReadCloser, error)
  • func (c *SpringCloudConfigClient) GetConfigRaw(attributes Attributes, source string) (io.ReadCloser, error)

Types

type Attributes

type Attributes struct {
	ServerAddress string `json:"serverAddress,omitempty"`
	Application   string `json:"application,omitempty"`
	Profile       string `json:"profile,omitempty"`
	FileName      string `json:"fileName,omitempty"`
	FileType      string `json:"fileType,omitempty"`
	Raw           string `json:"raw"`
}

type ConfigClient

type ConfigClient interface {
	GetConfig(attributes Attributes) (io.ReadCloser, error)
	GetConfigRaw(attributes Attributes, source string) (io.ReadCloser, error)
}

type Raw

type Raw struct {
	Source string `json:"source,omitempty"`
	Target string `json:"target,omitempty"`
}

type SpringCloudConfigCSIProviderServer

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

func NewSpringCloudConfigCSIProviderServer

func NewSpringCloudConfigCSIProviderServer(socketPath string, httpClient *http.Client, retryBaseWait time.Duration, retryMax uint64) (*SpringCloudConfigCSIProviderServer, error)

NewSpringCloudConfigCSIProviderServer returns CSI provider that uses the spring as the secret backend

func (*SpringCloudConfigCSIProviderServer) Mount

func (m *SpringCloudConfigCSIProviderServer) Mount(ctx context.Context, req *v1alpha1.MountRequest) (*v1alpha1.MountResponse, error)

Mount implements a provider csi-provider method

func (*SpringCloudConfigCSIProviderServer) Start

func (m *SpringCloudConfigCSIProviderServer) Start() error

func (*SpringCloudConfigCSIProviderServer) Stop

func (m *SpringCloudConfigCSIProviderServer) Stop()

func (*SpringCloudConfigCSIProviderServer) Version

func (m *SpringCloudConfigCSIProviderServer) Version(ctx context.Context, req *v1alpha1.VersionRequest) (*v1alpha1.VersionResponse, error)

Version implements a provider csi-provider method

type SpringCloudConfigClient

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

func NewSpringCloudConfigClient

func NewSpringCloudConfigClient(c *http.Client, retryBaseWait time.Duration, retryMax uint64) SpringCloudConfigClient

func (*SpringCloudConfigClient) GetConfig

func (c *SpringCloudConfigClient) GetConfig(attributes Attributes) (io.ReadCloser, error)

GetConfig pulls the config from spring-cloud config server and the server parses it to the specified format if the config contains secrets they are decoded on the server side

func (*SpringCloudConfigClient) GetConfigRaw

func (c *SpringCloudConfigClient) GetConfigRaw(attributes Attributes, source string) (io.ReadCloser, error)

GetConfigRaw pulls the config from spring-cloud-config without parsing or decrypting the secrets