builder

Documentation

Index

• func ParseSources(sourcesFlag string) ([]sync.SourceConfig, error)
• func ParseSyncProviderURIs(uris []string) ([]sync.SourceConfig, error)
• type IK8sClientBuilder
• type ISyncBuilder
• type KubernetesClientBuilder
  • func (kcb KubernetesClientBuilder) GetK8sClient() (dynamic.Interface, error)
• type SyncBuilder
  • func NewSyncBuilder() *SyncBuilder
  • func (sb *SyncBuilder) SyncFromURI(uri string, logger *logger.Logger) (sync.ISync, error)
  • func (sb *SyncBuilder) SyncsFromConfig(sourceConfigs []sync.SourceConfig, logger *logger.Logger) ([]sync.ISync, error)

Functions

func ParseSources

func ParseSources(sourcesFlag string) ([]sync.SourceConfig, error)

ParseSources parse a json formatted SourceConfig array string and performs validations on the content

func ParseSyncProviderURIs

func ParseSyncProviderURIs(uris []string) ([]sync.SourceConfig, error)

ParseSyncProviderURIs uri flag based sync sources to SourceConfig array. Replaces uri prefixes where necessary to derive SourceConfig

Types

type IK8sClientBuilder

type IK8sClientBuilder interface {
	GetK8sClient() (dynamic.Interface, error)
}

type ISyncBuilder

type ISyncBuilder interface {
	SyncFromURI(uri string, logger *logger.Logger) (sync.ISync, error)
	SyncsFromConfig(sourceConfig []sync.SourceConfig, logger *logger.Logger) ([]sync.ISync, error)
}

type KubernetesClientBuilder

type KubernetesClientBuilder struct{}

func (KubernetesClientBuilder) GetK8sClient

func (kcb KubernetesClientBuilder) GetK8sClient() (dynamic.Interface, error)

type SyncBuilder

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

func NewSyncBuilder

func NewSyncBuilder() *SyncBuilder

func (*SyncBuilder) SyncFromURI

func (sb *SyncBuilder) SyncFromURI(uri string, logger *logger.Logger) (sync.ISync, error)

func (*SyncBuilder) SyncsFromConfig

func (sb *SyncBuilder) SyncsFromConfig(sourceConfigs []sync.SourceConfig, logger *logger.Logger) ([]sync.ISync, error)