Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

lambda

package module

Go to main page

Versions in this module

v1

v1.1.0

Apr 16, 2018

Changes in this version

+ var HorizontalPodAutoscalerV1 = Resource

+ var HorizontalPodAutoscalerV2 = Resource

+ func NewFakes(objects ...runtime.Object) (dynamic.ClientPool, kubernetes.Interface)

+ type FakeClient struct

+ func (c *FakeClient) GetRateLimiter() flowcontrol.RateLimiter

+ func (c *FakeClient) ParameterCodec(parameterCodec runtime.ParameterCodec) dynamic.Interface

+ func (c *FakeClient) Resource(resource *metav1.APIResource, namespace string) dynamic.ResourceInterface

+ type FakeClientPool struct

+ func (p *FakeClientPool) ClientForGroupVersionKind(kind schema.GroupVersionKind) (dynamic.Interface, error)

+ func (p *FakeClientPool) ClientForGroupVersionResource(resource schema.GroupVersionResource) (dynamic.Interface, error)

+ type FakeResourceClient struct

+ func (c *FakeResourceClient) Get(name string, opts metav1.GetOptions) (*unstructured.Unstructured, error)

+ func (c *FakeResourceClient) List(opts metav1.ListOptions) (runtime.Object, error)

type Lambda

+ func (lambda *Lambda) Element() (runtime.Object, error)

+ func (lambda *Lambda) Elements() ([]runtime.Object, error)

+ func (lambda *Lambda) LatestCreated() *Lambda

+ func (lambda *Lambda) ListWithLabelSelector(selector labels.Selector) *Lambda

type Resource

+ Name string

+ Version string

+ func (r Resource) GetAPIVersion() string

+ func (r Resource) GetKind() string

+ func (r Resource) GetResource() string

+ type Version string

+ func (v Version) GetNumericVersion() string

+ func (v Version) GetSuffix() string

v1.0.0

Mar 15, 2018

Changes in this version

+ func NewFakeClientPool() *dynamic_fake.FakeClientPool

type Lambda

+ func (lambda *Lambda) List() *Lambda

+ func (lambda *Lambda) UpdateOrCreate() (updated, created bool, err error)

type Resource

+ func GetResources() []Resource

+ type ResourceIndexer interface

+ GetAPIResource func(resource Resource) *metav1.APIResource

+ GetGroupVersionKind func(resource Resource) schema.GroupVersionKind

+ GetGroupVersionResource func(resource Resource) schema.GroupVersionResource

+ IsNamespaced func(resource Resource) bool

+ func GetResouceIndexerInstance() (indexer ResourceIndexer)

+ type SortedGVKs []schema.GroupVersionKind

+ func (s SortedGVKs) Len() int

+ func (s SortedGVKs) Less(i, j int) bool

+ func (s SortedGVKs) Swap(i, j int)

v0

v0.0.0

Feb 9, 2018

Changes in this version

+ type Consumer interface

+ type ErrMultiLambdaFailure struct

+ func (e ErrMultiLambdaFailure) Error() string

+ type Function interface

+ type KubernetesClientLambda interface

+ Type func(Resource) KubernetesLambda

+ func InCluster() KubernetesClientLambda

+ func Mock() KubernetesClientLambda

+ func OutOfCluster(config *rest.Config) KubernetesClientLambda

+ func OutOfClusterDefault() KubernetesClientLambda

+ func OutOfClusterInContext(context string) KubernetesClientLambda

+ type KubernetesClientLambdaImpl struct

+ func (kcl *KubernetesClientLambdaImpl) Type(rs Resource) KubernetesLambda

+ type KubernetesClientLambdaMock struct

+ func (kcl *KubernetesClientLambdaMock) Type(rs Resource) KubernetesLambda

+ type KubernetesLambda interface

+ InNamespace func(namespace string) *Lambda

+ WatchNamespace func(namespace string) KubernetesWatch

+ type KubernetesWatch interface

+ Register func(t watch.EventType, function Function) error

+ Unregister func(t watch.EventType, function Function) error

+ type Lambda struct

+ Errors []error

+ func (lambda *Lambda) Add(producer Producer) *Lambda

+ func (lambda *Lambda) Any(predicate Predicate) (bool, error)

+ func (lambda *Lambda) Collect() *Lambda

+ func (lambda *Lambda) Create() (allCreated bool, err error)

+ func (lambda *Lambda) CreateIfNotExist() (success bool, err error)

+ func (lambda *Lambda) Delete() (deleted bool, err error)

+ func (lambda *Lambda) DeleteIfExist() (deleted bool, err error)

+ func (lambda *Lambda) Dummy() *Lambda

+ func (lambda *Lambda) Each(function Function) error

+ func (lambda *Lambda) Every(predicate Predicate) (bool, error)

+ func (lambda *Lambda) First(predicate Predicate) *Lambda

+ func (lambda *Lambda) Grep(predicate Predicate) *Lambda

+ func (lambda *Lambda) HasAnnotation(key, value string) *Lambda

+ func (lambda *Lambda) HasAnnotationKey(key string) *Lambda

+ func (lambda *Lambda) HasLabel(key, value string) *Lambda

+ func (lambda *Lambda) HasLabelKey(key string) *Lambda

+ func (lambda *Lambda) Iter(function Function) *Lambda

+ func (lambda *Lambda) Map(consumer Consumer) *Lambda

+ func (lambda *Lambda) MustNoError() *Lambda

+ func (lambda *Lambda) NameEqual(name string) *Lambda

+ func (lambda *Lambda) NamePrefix(prefix string) *Lambda

+ func (lambda *Lambda) NameRegex(regex string) *Lambda

+ func (lambda *Lambda) NoError() bool

+ func (lambda *Lambda) NotEmpty() (bool, error)

+ func (lambda *Lambda) Update() (updated bool, err error)

+ func (lambda *Lambda) UpdateIfExist() (updated bool, err error)

+ type ListPageFunc interface

+ type ListPager struct

+ PageFn ListPageFunc

+ PageSize int64

+ func (p *ListPager) List(options meta_v1.ListOptions) (<-chan kubernetesResource, error)

+ type Predicate interface

+ type Producer interface

+ type Resource string

+ const ClusterRole

+ const ClusterRoleBinding

+ const ConfigMap

+ const ControllerRevision

+ const CronJob

+ const DaemonSet

+ const Deployment

+ const Endpoints

+ const Event

+ const HorizontalPodAutoscaler

+ const Ingress

+ const Job

+ const LimitRange

+ const Namespace

+ const NetworkPolicy

+ const Node

+ const PersistentVolume

+ const PersistentVolumeClaim

+ const Pod

+ const PodSecurityPolicy

+ const PodTemplate

+ const ReplicaSet

+ const ReplicationController

+ const ResourceQuota

+ const Role

+ const RoleBinding

+ const Secret

+ const Service

+ const ServiceAccout

+ const StatefulSet

+ const StorageClass

+ func (rs Resource) GetApiGroupInterface(clientset kubernetes.Interface) kubernetesApiGroupInterface

+ func (rs Resource) GetObject() runtime.Object

+ func (rs Resource) IsNamespaced(i kubernetesApiGroupInterface) (bool, error)

+ func (rs Resource) ResetMock()

v0.0.0-rc4

Jan 8, 2018

v0.0.0-rc3

Dec 29, 2017

v0.0.0-rc2

Dec 29, 2017

v0.0.0-rc1

Dec 29, 2017