request

Documentation

Index

• type MultiClusterRequests
  • func (s *MultiClusterRequests) All() Requests
  • func (s *MultiClusterRequests) Append(cluster string, req reconcile.Request)
  • func (s *MultiClusterRequests) Each(fn func(string, reconcile.Request))
  • func (s *MultiClusterRequests) Remove(cluster string, reqToDelete reconcile.Request)
  • func (s *MultiClusterRequests) Requests(cluster string) Requests
• type Requests
• type SyncRequests
  • func (s *SyncRequests) Append(req reconcile.Request)
  • func (s *SyncRequests) Each(fn func(reconcile.Request))
  • func (s *SyncRequests) Remove(reqToDelete reconcile.Request)
  • func (s *SyncRequests) Requests() []reconcile.Request

Types

type MultiClusterRequests

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

MultiClusterRequests multiplexes reconcile Requests for multiple k8s clusters.

func (*MultiClusterRequests) All

func (s *MultiClusterRequests) All() Requests

func (*MultiClusterRequests) Append

func (s *MultiClusterRequests) Append(cluster string, req reconcile.Request)

append a request to a cluster

func (*MultiClusterRequests) Each

func (s *MultiClusterRequests) Each(fn func(string, reconcile.Request))

convenience function for iterating over the stored requests, by cluster

func (*MultiClusterRequests) Remove

func (s *MultiClusterRequests) Remove(cluster string, reqToDelete reconcile.Request)

remove a request from a cluster

func (*MultiClusterRequests) Requests

func (s *MultiClusterRequests) Requests(cluster string) Requests

get the stored requests for the cluster

type Requests

type Requests []reconcile.Request

Requests wraps a slice of reconcile.Requests

type SyncRequests

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

SyncRequests is a threadsafe wrapper for

func (*SyncRequests) Append

func (s *SyncRequests) Append(req reconcile.Request)

append a request

func (*SyncRequests) Each

func (s *SyncRequests) Each(fn func(reconcile.Request))

convenience function for iterating over the stored requests

func (*SyncRequests) Remove

func (s *SyncRequests) Remove(reqToDelete reconcile.Request)

remove a request

func (*SyncRequests) Requests

func (s *SyncRequests) Requests() []reconcile.Request

get the stored requests