crd

Documentation

Index

• func NodeNameFilter(nodeName string) internalinterfaces.TweakListOptionsFunc
• type Client
  • func NewCRDClient(config *rest.Config, eventCh chan aadpodid.EventType, log inlog.Logger) (crdClient *Client, err error)
  • func NewCRDClientLite(config *rest.Config, log inlog.Logger, nodeName string, scale bool) (crdClient *Client, err error)
  • func (c *Client) CreateAssignedIdentity(assignedIdentity *aadpodid.AzureAssignedIdentity) error
  • func (c *Client) ListAssignedIDs() (res *[]aadpodid.AzureAssignedIdentity, err error)
  • func (c *Client) ListAssignedIDsInMap() (map[string]aadpodid.AzureAssignedIdentity, error)
  • func (c *Client) ListBindings() (res *[]aadpodid.AzureIdentityBinding, err error)
  • func (c *Client) ListIds() (res *[]aadpodid.AzureIdentity, err error)
  • func (c *Client) ListPodIdentityExceptions(ns string) (res *[]aadpodid.AzurePodIdentityException, err error)
  • func (c *Client) ListPodIds(podns, podname string) (map[string][]aadpodid.AzureIdentity, error)
  • func (c *Client) RemoveAssignedIdentity(assignedIdentity *aadpodid.AzureAssignedIdentity) error
  • func (c *Client) Start(exit <-chan struct{})
  • func (c *Client) StartLite(exit <-chan struct{})
  • func (c *Client) SyncCache(exit <-chan struct{})
  • func (c *Client) SyncCacheLite(exit <-chan struct{})
  • func (c *Client) UpdateAzureAssignedIdentityStatus(assignedIdentity *aadpodid.AzureAssignedIdentity, status string) error
• type ClientInt

Functions

func NodeNameFilter

func NodeNameFilter(nodeName string) internalinterfaces.TweakListOptionsFunc

NodeNameFilter - CRDs do not yet support field selectors. Instead of that we apply labels with node name and then later use the NodeNameFilter to tweak options to filter using nodename label.

Types

type Client

type Client struct {
	BindingInformer              cache.SharedInformer
	IDInformer                   cache.SharedInformer
	AssignedIDInformer           cache.SharedInformer
	PodIdentityExceptionInformer cache.SharedInformer
	// contains filtered or unexported fields
}

Client represents all the watchers

func NewCRDClient

func NewCRDClient(config *rest.Config, eventCh chan aadpodid.EventType, log inlog.Logger) (crdClient *Client, err error)

NewCRDClient returns a new crd client and error if any

func NewCRDClientLite

func NewCRDClientLite(config *rest.Config, log inlog.Logger, nodeName string, scale bool) (crdClient *Client, err error)

NewCRDClientLite ...

func (*Client) CreateAssignedIdentity

func (c *Client) CreateAssignedIdentity(assignedIdentity *aadpodid.AzureAssignedIdentity) error

CreateAssignedIdentity creates new assigned identity

func (*Client) ListAssignedIDs

func (c *Client) ListAssignedIDs() (res *[]aadpodid.AzureAssignedIdentity, err error)

ListAssignedIDs returns a list of azureassignedidentities

func (*Client) ListAssignedIDsInMap

func (c *Client) ListAssignedIDsInMap() (map[string]aadpodid.AzureAssignedIdentity, error)

ListAssignedIDsInMap gets the list of current assigned ids, adds it to a map with assigned identity name as key and assigned identity as value.

func (*Client) ListBindings

func (c *Client) ListBindings() (res *[]aadpodid.AzureIdentityBinding, err error)

ListBindings returns a list of azureidentitybindings

func (*Client) ListIds

func (c *Client) ListIds() (res *[]aadpodid.AzureIdentity, err error)

ListIds returns a list of azureidentities

func (*Client) ListPodIdentityExceptions

func (c *Client) ListPodIdentityExceptions(ns string) (res *[]aadpodid.AzurePodIdentityException, err error)

ListPodIdentityExceptions returns list of azurepodidentityexceptions

func (*Client) ListPodIds

func (c *Client) ListPodIds(podns, podname string) (map[string][]aadpodid.AzureIdentity, error)

ListPodIds - given a pod with pod name space returns a map with list of azure identities in each state

func (*Client) RemoveAssignedIdentity

func (c *Client) RemoveAssignedIdentity(assignedIdentity *aadpodid.AzureAssignedIdentity) error

RemoveAssignedIdentity removes the assigned identity

func (*Client) Start

func (c *Client) Start(exit <-chan struct{})

Start ...

func (*Client) StartLite

func (c *Client) StartLite(exit <-chan struct{})

StartLite to be used only case of lite client

func (*Client) SyncCache

func (c *Client) SyncCache(exit <-chan struct{})

func (*Client) SyncCacheLite

func (c *Client) SyncCacheLite(exit <-chan struct{})

func (*Client) UpdateAzureAssignedIdentityStatus

func (c *Client) UpdateAzureAssignedIdentityStatus(assignedIdentity *aadpodid.AzureAssignedIdentity, status string) error

UpdateAzureAssignedIdentityStatus updates the status field in AzureAssignedIdentity to indicate current status

type ClientInt

type ClientInt interface {
	Start(exit <-chan struct{})
	SyncCache(exit <-chan struct{})
	SyncCacheLite(exit <-chan struct{})
	RemoveAssignedIdentity(assignedIdentity *aadpodid.AzureAssignedIdentity) error
	CreateAssignedIdentity(assignedIdentity *aadpodid.AzureAssignedIdentity) error
	UpdateAzureAssignedIdentityStatus(assignedIdentity *aadpodid.AzureAssignedIdentity, status string) error
	ListBindings() (res *[]aadpodid.AzureIdentityBinding, err error)
	ListAssignedIDs() (res *[]aadpodid.AzureAssignedIdentity, err error)
	ListAssignedIDsInMap() (res map[string]aadpodid.AzureAssignedIdentity, err error)
	ListIds() (res *[]aadpodid.AzureIdentity, err error)
	ListPodIds(podns, podname string) (map[string][]aadpodid.AzureIdentity, error)
	ListPodIdentityExceptions(ns string) (res *[]aadpodid.AzurePodIdentityException, err error)
}

ClientInt ...