crd

Documentation

Index

• 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) (crdClient *Client, err error)
  • func (c *Client) CreateAssignedIdentity(assignedIdentity *aadpodid.AzureAssignedIdentity) error
  • func (c *Client) ListAssignedIDs() (res *[]aadpodid.AzureAssignedIdentity, err 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{}, initial bool)
  • func (c *Client) UpdateAzureAssignedIdentityStatus(assignedIdentity *aadpodid.AzureAssignedIdentity, status string) error
• type ClientInt

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) (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) 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{}, initial bool)

SyncCache synchronizes cache

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{}, initial bool)
	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)
	ListIds() (res *[]aadpodid.AzureIdentity, err error)
	ListPodIds(podns, podname string) (map[string][]aadpodid.AzureIdentity, error)
	ListPodIdentityExceptions(ns string) (res *[]aadpodid.AzurePodIdentityException, err error)
}

ClientInt ...