factory

Documentation

Index

• type ConsulResourceClientFactory
  • func (f *ConsulResourceClientFactory) NewResourceClient(ctx context.Context, params NewResourceClientParams) (clients.ResourceClient, error)
• type FileResourceClientFactory
  • func (f *FileResourceClientFactory) NewResourceClient(ctx context.Context, params NewResourceClientParams) (clients.ResourceClient, error)
• type KubeConfigMapClientFactory
  • func (f *KubeConfigMapClientFactory) NewResourceClient(ctx context.Context, params NewResourceClientParams) (clients.ResourceClient, error)
• type KubeResourceClientFactory
  • func (f *KubeResourceClientFactory) NewResourceClient(ctx context.Context, params NewResourceClientParams) (clients.ResourceClient, error)
• type KubeSecretClientFactory
  • func (f *KubeSecretClientFactory) NewResourceClient(ctx context.Context, params NewResourceClientParams) (clients.ResourceClient, error)
• type MemoryResourceClientFactory
  • func (f *MemoryResourceClientFactory) NewResourceClient(ctx context.Context, params NewResourceClientParams) (clients.ResourceClient, error)
• type NewResourceClientParams
• type ResourceClientFactory
• type VaultSecretClientFactory
  • func (f *VaultSecretClientFactory) NewResourceClient(ctx context.Context, params NewResourceClientParams) (clients.ResourceClient, error)

Types

type ConsulResourceClientFactory

type ConsulResourceClientFactory struct {
	Consul       *api.Client
	RootKey      string
	QueryOptions *api.QueryOptions
}

func (*ConsulResourceClientFactory) NewResourceClient

func (f *ConsulResourceClientFactory) NewResourceClient(ctx context.Context, params NewResourceClientParams) (clients.ResourceClient, error)

type FileResourceClientFactory

type FileResourceClientFactory struct {
	RootDir string
}

func (*FileResourceClientFactory) NewResourceClient

func (f *FileResourceClientFactory) NewResourceClient(ctx context.Context, params NewResourceClientParams) (clients.ResourceClient, error)

type KubeConfigMapClientFactory

type KubeConfigMapClientFactory struct {
	Clientset kubernetes.Interface
	Cache     cache.KubeCoreCache
	// set this  to true if resource fields are all strings
	// resources will be stored as plain kubernetes configmaps without serializing/deserializing as objects
	PlainConfigmaps bool
	// a custom handler to define how configmaps are serialized/deserialized out of resources
	// if set, Plain is ignored
	CustomConverter configmap.ConfigMapConverter
	// the cluster that these resources belong to
	// all resources written and read by the resource client
	// will be marked with this cluster
	Cluster string
}

func (*KubeConfigMapClientFactory) NewResourceClient

func (f *KubeConfigMapClientFactory) NewResourceClient(ctx context.Context, params NewResourceClientParams) (clients.ResourceClient, error)

type KubeResourceClientFactory

type KubeResourceClientFactory struct {
	Crd                crd.Crd
	Cfg                *rest.Config
	SharedCache        kube.SharedCache
	NamespaceWhitelist []string
	ResyncPeriod       time.Duration
	// the cluster that these resources belong to
	// all resources written and read by the resource client
	// will be marked with this cluster
	Cluster string
}

Clients built with this factory will be able to access only resources the given namespace list. If no value is provided, clients will be able to access resources in all namespaces.

func (*KubeResourceClientFactory) NewResourceClient

func (f *KubeResourceClientFactory) NewResourceClient(ctx context.Context, params NewResourceClientParams) (clients.ResourceClient, error)

type KubeSecretClientFactory

type KubeSecretClientFactory struct {
	Clientset kubernetes.Interface
	// set this  to true if resource fields are all strings
	// resources will be stored as plain kubernetes secrets without serializing/deserializing as objects
	PlainSecrets    bool
	SecretConverter kubesecret.SecretConverter
	Cache           cache.KubeCoreCache
	// the cluster that these resources belong to
	// all resources written and read by the resource client
	// will be marked with this cluster
	Cluster string
}

func (*KubeSecretClientFactory) NewResourceClient

func (f *KubeSecretClientFactory) NewResourceClient(ctx context.Context, params NewResourceClientParams) (clients.ResourceClient, error)

type MemoryResourceClientFactory

type MemoryResourceClientFactory struct {
	Cache memory.InMemoryResourceCache
}

func (*MemoryResourceClientFactory) NewResourceClient

func (f *MemoryResourceClientFactory) NewResourceClient(ctx context.Context, params NewResourceClientParams) (clients.ResourceClient, error)

type NewResourceClientParams

type NewResourceClientParams struct {
	ResourceType resources.Resource
	Token        string
}

type ResourceClientFactory

type ResourceClientFactory interface {
	NewResourceClient(ctx context.Context, params NewResourceClientParams) (clients.ResourceClient, error)
}

https://golang.org/doc/faq#generics

type VaultSecretClientFactory

type VaultSecretClientFactory struct {
	Vault      *vaultapi.Client
	PathPrefix string
	RootKey    string
}

func (*VaultSecretClientFactory) NewResourceClient

func (f *VaultSecretClientFactory) NewResourceClient(ctx context.Context, params NewResourceClientParams) (clients.ResourceClient, error)