v1

package

Go to main page

Versions in this module

v0

v0.3.25

Jul 25, 2019

Changes in this version

type MtlsConfig

+ MtlsPermissive bool

+ func (m *MtlsConfig) GetMtlsPermissive() bool

v0.3.24

Jun 25, 2019

Changes in this version

type ConfigEmitter

+ CustomResourceDefinition func() ...

type ConfigSnapshot

+ Customresourcedefinition github_com_solo_io_solo_kit_pkg_api_v1_resources_common_kubernetes.CustomResourceDefinitionList

type ConfigSnapshotStringer

+ Customresourcedefinition []string

+ type ConfigSyncDeciderWithContext interface

+ ShouldSync func(ctx context.Context, old, new *ConfigSnapshot) bool

+ type DiscoverySyncDeciderWithContext interface

+ ShouldSync func(ctx context.Context, old, new *DiscoverySnapshot) bool

+ type InstallSyncDeciderWithContext interface

+ ShouldSync func(ctx context.Context, old, new *InstallSnapshot) bool

+ type RegistrationSyncDeciderWithContext interface

+ ShouldSync func(ctx context.Context, old, new *RegistrationSnapshot) bool

v0.3.23

Jun 17, 2019

Changes in this version

type DiscoveryEmitter

+ Deployment func() ...

+ TlsSecret func() TlsSecretClient

+ Upstream func() gloo_solo_io.UpstreamClient

type DiscoverySnapshot

+ Deployments github_com_solo_io_solo_kit_pkg_api_v1_resources_common_kubernetes.DeploymentList

+ Tlssecrets TlsSecretList

+ Upstreams gloo_solo_io.UpstreamList

type DiscoverySnapshotStringer

+ Deployments []string

+ Tlssecrets []string

+ Upstreams []string

v0.3.22

May 21, 2019

Changes in this version

type ConfigEmitter

+ Service func() ...

type ConfigSnapshot

+ Services github_com_solo_io_solo_kit_pkg_api_v1_resources_common_kubernetes.ServiceList

type ConfigSnapshotStringer

+ Services []string

type Mesh

+ SmiEnabled bool

+ func (m *Mesh) GetSmiEnabled() bool

type PodSelector

+ func (m *PodSelector) GetServiceSelector() *PodSelector_ServiceSelector

+ type PodSelector_ServiceSelector struct

+ Services []core.ResourceRef

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PodSelector_ServiceSelector) Descriptor() ([]byte, []int)

+ func (*PodSelector_ServiceSelector) ProtoMessage()

+ func (m *PodSelector_ServiceSelector) GetServices() []core.ResourceRef

+ func (m *PodSelector_ServiceSelector) Reset()

+ func (m *PodSelector_ServiceSelector) String() string

+ func (m *PodSelector_ServiceSelector) XXX_DiscardUnknown()

+ func (m *PodSelector_ServiceSelector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PodSelector_ServiceSelector) XXX_Merge(src proto.Message)

+ func (m *PodSelector_ServiceSelector) XXX_Size() int

+ func (m *PodSelector_ServiceSelector) XXX_Unmarshal(b []byte) error

+ func (this *PodSelector_ServiceSelector) Equal(that interface{}) bool

+ type PodSelector_ServiceSelector_ struct

+ ServiceSelector *PodSelector_ServiceSelector

+ func (this *PodSelector_ServiceSelector_) Equal(that interface{}) bool

v0.3.21

May 14, 2019

v0.3.20

May 14, 2019

v0.3.19

May 14, 2019

v0.3.18

May 9, 2019

Changes in this version

+ func NewAppmeshDiscoverySimpleEventLoop(emitter AppmeshDiscoverySimpleEmitter, syncers ...AppmeshDiscoverySyncer) eventloop.SimpleEventLoop

+ func NewConfigSimpleEventLoop(emitter ConfigSimpleEmitter, syncers ...ConfigSyncer) eventloop.SimpleEventLoop

+ func NewDiscoverySimpleEventLoop(emitter DiscoverySimpleEmitter, syncers ...DiscoverySyncer) eventloop.SimpleEventLoop

+ func NewInstallSimpleEventLoop(emitter InstallSimpleEmitter, syncers ...InstallSyncer) eventloop.SimpleEventLoop

+ func NewIstioDiscoverySimpleEventLoop(emitter IstioDiscoverySimpleEmitter, syncers ...IstioDiscoverySyncer) eventloop.SimpleEventLoop

+ func NewLinkerdDiscoverySimpleEventLoop(emitter LinkerdDiscoverySimpleEmitter, syncers ...LinkerdDiscoverySyncer) eventloop.SimpleEventLoop

+ func NewRegistrationSimpleEventLoop(emitter RegistrationSimpleEmitter, syncers ...RegistrationSyncer) eventloop.SimpleEventLoop

+ type AppmeshDiscoverySimpleEmitter interface

+ Snapshots func(ctx context.Context) (<-chan *AppmeshDiscoverySnapshot, <-chan error, error)

+ func NewAppmeshDiscoverySimpleEmitter(aggregatedWatch clients.ResourceWatch) AppmeshDiscoverySimpleEmitter

+ func NewAppmeshDiscoverySimpleEmitterWithEmit(aggregatedWatch clients.ResourceWatch, emit <-chan struct{}) AppmeshDiscoverySimpleEmitter

+ type AppmeshDiscoverySyncDecider interface

+ ShouldSync func(old, new *AppmeshDiscoverySnapshot) bool

+ type ConfigSimpleEmitter interface

+ Snapshots func(ctx context.Context) (<-chan *ConfigSnapshot, <-chan error, error)

+ func NewConfigSimpleEmitter(aggregatedWatch clients.ResourceWatch) ConfigSimpleEmitter

+ func NewConfigSimpleEmitterWithEmit(aggregatedWatch clients.ResourceWatch, emit <-chan struct{}) ConfigSimpleEmitter

+ type ConfigSyncDecider interface

+ ShouldSync func(old, new *ConfigSnapshot) bool

+ type DiscoverySimpleEmitter interface

+ Snapshots func(ctx context.Context) (<-chan *DiscoverySnapshot, <-chan error, error)

+ func NewDiscoverySimpleEmitter(aggregatedWatch clients.ResourceWatch) DiscoverySimpleEmitter

+ func NewDiscoverySimpleEmitterWithEmit(aggregatedWatch clients.ResourceWatch, emit <-chan struct{}) DiscoverySimpleEmitter

+ type DiscoverySyncDecider interface

+ ShouldSync func(old, new *DiscoverySnapshot) bool

type InstallList

+ func (list InstallList) EachResource(f func(element resources.Resource))

+ type InstallSimpleEmitter interface

+ Snapshots func(ctx context.Context) (<-chan *InstallSnapshot, <-chan error, error)

+ func NewInstallSimpleEmitter(aggregatedWatch clients.ResourceWatch) InstallSimpleEmitter

+ func NewInstallSimpleEmitterWithEmit(aggregatedWatch clients.ResourceWatch, emit <-chan struct{}) InstallSimpleEmitter

+ type InstallSyncDecider interface

+ ShouldSync func(old, new *InstallSnapshot) bool

+ type InstallWatcher interface

+ Watch func(namespace string, opts clients.WatchOpts) (<-chan InstallList, <-chan error, error)

+ type IstioDiscoverySimpleEmitter interface

+ Snapshots func(ctx context.Context) (<-chan *IstioDiscoverySnapshot, <-chan error, error)

+ func NewIstioDiscoverySimpleEmitter(aggregatedWatch clients.ResourceWatch) IstioDiscoverySimpleEmitter

+ func NewIstioDiscoverySimpleEmitterWithEmit(aggregatedWatch clients.ResourceWatch, emit <-chan struct{}) IstioDiscoverySimpleEmitter

+ type IstioDiscoverySyncDecider interface

+ ShouldSync func(old, new *IstioDiscoverySnapshot) bool

+ type LinkerdDiscoverySimpleEmitter interface

+ Snapshots func(ctx context.Context) (<-chan *LinkerdDiscoverySnapshot, <-chan error, error)

+ func NewLinkerdDiscoverySimpleEmitter(aggregatedWatch clients.ResourceWatch) LinkerdDiscoverySimpleEmitter

+ func NewLinkerdDiscoverySimpleEmitterWithEmit(aggregatedWatch clients.ResourceWatch, emit <-chan struct{}) LinkerdDiscoverySimpleEmitter

+ type LinkerdDiscoverySyncDecider interface

+ ShouldSync func(old, new *LinkerdDiscoverySnapshot) bool

type MeshGroupList

+ func (list MeshGroupList) EachResource(f func(element resources.Resource))

+ type MeshGroupWatcher interface

+ Watch func(namespace string, opts clients.WatchOpts) (<-chan MeshGroupList, <-chan error, error)

type MeshIngressList

+ func (list MeshIngressList) EachResource(f func(element resources.Resource))

+ type MeshIngressWatcher interface

+ Watch func(namespace string, opts clients.WatchOpts) (<-chan MeshIngressList, <-chan error, error)

type MeshList

+ func (list MeshList) EachResource(f func(element resources.Resource))

+ type MeshWatcher interface

+ Watch func(namespace string, opts clients.WatchOpts) (<-chan MeshList, <-chan error, error)

+ type RegistrationSimpleEmitter interface

+ Snapshots func(ctx context.Context) (<-chan *RegistrationSnapshot, <-chan error, error)

+ func NewRegistrationSimpleEmitter(aggregatedWatch clients.ResourceWatch) RegistrationSimpleEmitter

+ func NewRegistrationSimpleEmitterWithEmit(aggregatedWatch clients.ResourceWatch, emit <-chan struct{}) RegistrationSimpleEmitter

+ type RegistrationSyncDecider interface

+ ShouldSync func(old, new *RegistrationSnapshot) bool

type RoutingRuleList

+ func (list RoutingRuleList) EachResource(f func(element resources.Resource))

+ type RoutingRuleWatcher interface

+ Watch func(namespace string, opts clients.WatchOpts) (<-chan RoutingRuleList, <-chan error, error)

type SecurityRuleList

+ func (list SecurityRuleList) EachResource(f func(element resources.Resource))

+ type SecurityRuleWatcher interface

+ Watch func(namespace string, opts clients.WatchOpts) (<-chan SecurityRuleList, <-chan error, error)

type TlsSecretList

+ func (list TlsSecretList) EachResource(f func(element resources.Resource))

+ type TlsSecretWatcher interface

+ Watch func(namespace string, opts clients.WatchOpts) (<-chan TlsSecretList, <-chan error, error)

v0.3.17

May 6, 2019

v0.3.16

May 2, 2019

Changes in this version

+ func NewAppmeshDiscoveryEventLoop(emitter AppmeshDiscoveryEmitter, syncer AppmeshDiscoverySyncer) eventloop.EventLoop

+ type AppmeshDiscoveryEmitter interface

+ Mesh func() MeshClient

+ Pod func() github_com_solo_io_solo_kit_pkg_api_v1_resources_common_kubernetes.PodClient

+ Register func() error

+ Snapshots func(watchNamespaces []string, opts clients.WatchOpts) (<-chan *AppmeshDiscoverySnapshot, <-chan error, error)

+ Upstream func() gloo_solo_io.UpstreamClient

+ func NewAppmeshDiscoveryEmitter(meshClient MeshClient, ...) AppmeshDiscoveryEmitter

+ func NewAppmeshDiscoveryEmitterWithEmit(meshClient MeshClient, ...) AppmeshDiscoveryEmitter

+ type AppmeshDiscoverySnapshot struct

+ Meshes MeshesByNamespace

+ Pods github_com_solo_io_solo_kit_pkg_api_v1_resources_common_kubernetes.PodsByNamespace

+ Upstreams gloo_solo_io.UpstreamsByNamespace

+ func (s AppmeshDiscoverySnapshot) Clone() AppmeshDiscoverySnapshot

+ func (s AppmeshDiscoverySnapshot) Hash() uint64

+ func (s AppmeshDiscoverySnapshot) HashFields() []zap.Field

+ func (s AppmeshDiscoverySnapshot) Stringer() AppmeshDiscoverySnapshotStringer

+ type AppmeshDiscoverySnapshotStringer struct

+ Meshes []string

+ Pods []string

+ Upstreams []string

+ Version uint64

+ func (ss AppmeshDiscoverySnapshotStringer) String() string

+ type AppmeshDiscoverySyncer interface

+ Sync func(context.Context, *AppmeshDiscoverySnapshot) error

+ type AppmeshDiscoverySyncers []AppmeshDiscoverySyncer

+ func (s AppmeshDiscoverySyncers) Sync(ctx context.Context, snapshot *AppmeshDiscoverySnapshot) error

type DiscoveryEmitter

+ ConfigMap func() ...

type DiscoverySnapshot

+ Configmaps github_com_solo_io_solo_kit_pkg_api_v1_resources_common_kubernetes.ConfigmapsByNamespace

type DiscoverySnapshotStringer

+ Configmaps []string

v0.3.15

Apr 27, 2019

Changes in this version

type IstioInstall

+ EnableEgress bool

+ EnableIngress bool

+ func (m *IstioInstall) GetEnableEgress() bool

+ func (m *IstioInstall) GetEnableIngress() bool

v0.3.14

Apr 26, 2019

Changes in this version

type DiscoveryMetadata

+ Upstreams []*core.ResourceRef

+ func (m *DiscoveryMetadata) GetUpstreams() []*core.ResourceRef

type GlooInstall

+ Version string

+ func (m *GlooInstall) GetVersion() string

type IstioDiscoveryEmitter

+ Pod func() github_com_solo_io_solo_kit_pkg_api_v1_resources_common_kubernetes.PodClient

+ Upstream func() gloo_solo_io.UpstreamClient

type IstioDiscoverySnapshot

+ Pods github_com_solo_io_solo_kit_pkg_api_v1_resources_common_kubernetes.PodsByNamespace

+ Upstreams gloo_solo_io.UpstreamsByNamespace

type IstioDiscoverySnapshotStringer

+ Pods []string

+ Upstreams []string

type IstioInstall

+ Version string

+ func (m *IstioInstall) GetVersion() string

type IstioMesh

+ Version string

+ func (m *IstioMesh) GetVersion() string

type LinkerdDiscoveryEmitter

+ Pod func() github_com_solo_io_solo_kit_pkg_api_v1_resources_common_kubernetes.PodClient

+ Upstream func() gloo_solo_io.UpstreamClient

type LinkerdDiscoverySnapshot

+ Pods github_com_solo_io_solo_kit_pkg_api_v1_resources_common_kubernetes.PodsByNamespace

+ Upstreams gloo_solo_io.UpstreamsByNamespace

type LinkerdDiscoverySnapshotStringer

+ Pods []string

+ Upstreams []string

type LinkerdInstall

+ Version string

+ func (m *LinkerdInstall) GetVersion() string

type LinkerdMesh

+ Version string

+ func (m *LinkerdMesh) GetVersion() string

type Mesh

+ func (m *Mesh) GetLinkerd() *LinkerdMesh

type MeshInstall

+ func (m *MeshInstall) GetIstio() *IstioInstall

+ func (m *MeshInstall) GetLinkerd() *LinkerdInstall

+ type MeshInstall_Istio struct

+ Istio *IstioInstall

+ func (this *MeshInstall_Istio) Equal(that interface{}) bool

+ type MeshInstall_Linkerd struct

+ Linkerd *LinkerdInstall

+ func (this *MeshInstall_Linkerd) Equal(that interface{}) bool

+ type Mesh_Linkerd struct

+ Linkerd *LinkerdMesh

+ func (this *Mesh_Linkerd) Equal(that interface{}) bool

v0.3.13

Apr 22, 2019

v0.3.12

Apr 19, 2019

v0.3.11

Apr 18, 2019

Changes in this version

+ func NewIstioDiscoveryEventLoop(emitter IstioDiscoveryEmitter, syncer IstioDiscoverySyncer) eventloop.EventLoop

+ func NewLinkerdDiscoveryEventLoop(emitter LinkerdDiscoveryEmitter, syncer LinkerdDiscoverySyncer) eventloop.EventLoop

+ type CloneableServiceProfile interface

+ Clone func() *github_com_solo_io_supergloo_api_custom_linkerd.ServiceProfile

type DiscoveryMetadata

+ EnableAutoInject bool

+ func (m *DiscoveryMetadata) GetEnableAutoInject() bool

+ type IstioDiscoveryEmitter interface

+ Install func() InstallClient

+ Mesh func() MeshClient

+ MeshPolicy func() istio_authentication_v1alpha1.MeshPolicyClient

+ Register func() error

+ Snapshots func(watchNamespaces []string, opts clients.WatchOpts) (<-chan *IstioDiscoverySnapshot, <-chan error, error)

+ func NewIstioDiscoveryEmitter(meshClient MeshClient, installClient InstallClient, ...) IstioDiscoveryEmitter

+ func NewIstioDiscoveryEmitterWithEmit(meshClient MeshClient, installClient InstallClient, ...) IstioDiscoveryEmitter

+ type IstioDiscoverySnapshot struct

+ Installs InstallsByNamespace

+ Meshes MeshesByNamespace

+ Meshpolicies istio_authentication_v1alpha1.MeshPolicyList

+ func (s IstioDiscoverySnapshot) Clone() IstioDiscoverySnapshot

+ func (s IstioDiscoverySnapshot) Hash() uint64

+ func (s IstioDiscoverySnapshot) HashFields() []zap.Field

+ func (s IstioDiscoverySnapshot) Stringer() IstioDiscoverySnapshotStringer

+ type IstioDiscoverySnapshotStringer struct

+ Installs []string

+ Meshes []string

+ Meshpolicies []string

+ Version uint64

+ func (ss IstioDiscoverySnapshotStringer) String() string

+ type IstioDiscoverySyncer interface

+ Sync func(context.Context, *IstioDiscoverySnapshot) error

+ type IstioDiscoverySyncers []IstioDiscoverySyncer

+ func (s IstioDiscoverySyncers) Sync(ctx context.Context, snapshot *IstioDiscoverySnapshot) error

+ type LinkerdDiscoveryEmitter interface

+ Install func() InstallClient

+ Mesh func() MeshClient

+ Register func() error

+ Snapshots func(watchNamespaces []string, opts clients.WatchOpts) (<-chan *LinkerdDiscoverySnapshot, <-chan error, error)

+ func NewLinkerdDiscoveryEmitter(meshClient MeshClient, installClient InstallClient) LinkerdDiscoveryEmitter

+ func NewLinkerdDiscoveryEmitterWithEmit(meshClient MeshClient, installClient InstallClient, emit <-chan struct{}) LinkerdDiscoveryEmitter

+ type LinkerdDiscoverySnapshot struct

+ Installs InstallsByNamespace

+ Meshes MeshesByNamespace

+ func (s LinkerdDiscoverySnapshot) Clone() LinkerdDiscoverySnapshot

+ func (s LinkerdDiscoverySnapshot) Hash() uint64

+ func (s LinkerdDiscoverySnapshot) HashFields() []zap.Field

+ func (s LinkerdDiscoverySnapshot) Stringer() LinkerdDiscoverySnapshotStringer

+ type LinkerdDiscoverySnapshotStringer struct

+ Installs []string

+ Meshes []string

+ Version uint64

+ func (ss LinkerdDiscoverySnapshotStringer) String() string

+ type LinkerdDiscoverySyncer interface

+ Sync func(context.Context, *LinkerdDiscoverySnapshot) error

+ type LinkerdDiscoverySyncers []LinkerdDiscoverySyncer

+ func (s LinkerdDiscoverySyncers) Sync(ctx context.Context, snapshot *LinkerdDiscoverySnapshot) error

type LinkerdMesh

+ LinkerdVersion string

+ func (m *LinkerdMesh) GetLinkerdVersion() string

+ type RetryBudget struct

+ MinRetriesPerSecond uint32

+ RetryRatio float32

+ Ttl time.Duration

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RetryBudget) Descriptor() ([]byte, []int)

+ func (*RetryBudget) ProtoMessage()

+ func (m *RetryBudget) GetMinRetriesPerSecond() uint32

+ func (m *RetryBudget) GetRetryRatio() float32

+ func (m *RetryBudget) GetTtl() time.Duration

+ func (m *RetryBudget) Reset()

+ func (m *RetryBudget) String() string

+ func (m *RetryBudget) XXX_DiscardUnknown()

+ func (m *RetryBudget) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RetryBudget) XXX_Merge(src proto.Message)

+ func (m *RetryBudget) XXX_Size() int

+ func (m *RetryBudget) XXX_Unmarshal(b []byte) error

+ func (this *RetryBudget) Equal(that interface{}) bool

+ type RetryPolicy struct

+ MaxRetries *v1alpha3.HTTPRetry

+ RetryBudget *RetryBudget

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RetryPolicy) Descriptor() ([]byte, []int)

+ func (*RetryPolicy) ProtoMessage()

+ func (m *RetryPolicy) GetMaxRetries() *v1alpha3.HTTPRetry

+ func (m *RetryPolicy) GetRetryBudget() *RetryBudget

+ func (m *RetryPolicy) Reset()

+ func (m *RetryPolicy) String() string

+ func (m *RetryPolicy) XXX_DiscardUnknown()

+ func (m *RetryPolicy) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RetryPolicy) XXX_Merge(src proto.Message)

+ func (m *RetryPolicy) XXX_Size() int

+ func (m *RetryPolicy) XXX_Unmarshal(b []byte) error

+ func (this *RetryPolicy) Equal(that interface{}) bool

+ type ServiceProfile struct

+ func NewServiceProfile(namespace, name string) *ServiceProfile

+ func (r *ServiceProfile) Clone() resources.Resource

+ func (r *ServiceProfile) Hash() uint64

+ type ServiceProfileClient interface

+ BaseClient func() clients.ResourceClient

+ Delete func(namespace, name string, opts clients.DeleteOpts) error

+ List func(namespace string, opts clients.ListOpts) (ServiceProfileList, error)

+ Read func(namespace, name string, opts clients.ReadOpts) (*ServiceProfile, error)

+ Register func() error

+ Watch func(namespace string, opts clients.WatchOpts) (<-chan ServiceProfileList, <-chan error, error)

+ Write func(resource *ServiceProfile, opts clients.WriteOpts) (*ServiceProfile, error)

+ func NewServiceProfileClient(rcFactory factory.ResourceClientFactory) (ServiceProfileClient, error)

+ func NewServiceProfileClientWithBase(rc clients.ResourceClient) ServiceProfileClient

+ func NewServiceProfileClientWithToken(rcFactory factory.ResourceClientFactory, token string) (ServiceProfileClient, error)

+ type ServiceProfileList []*ServiceProfile

+ func (list ServiceProfileList) AsInterfaces() []interface{}

+ func (list ServiceProfileList) AsResources() resources.ResourceList

+ func (list ServiceProfileList) Clone() ServiceProfileList

+ func (list ServiceProfileList) Each(f func(element *ServiceProfile))

+ func (list ServiceProfileList) Find(namespace, name string) (*ServiceProfile, error)

+ func (list ServiceProfileList) Names() []string

+ func (list ServiceProfileList) NamespacesDotNames() []string

+ func (list ServiceProfileList) Sort() ServiceProfileList

+ type ServiceProfileReconciler interface

+ Reconcile func(namespace string, desiredResources ServiceProfileList, ...) error

+ func NewServiceProfileReconciler(client ServiceProfileClient) ServiceProfileReconciler

+ type ServiceprofilesByNamespace map[string]ServiceProfileList

+ func (byNamespace ServiceprofilesByNamespace) Add(serviceProfile ...*ServiceProfile)

+ func (byNamespace ServiceprofilesByNamespace) Clear(namespace string)

+ func (byNamespace ServiceprofilesByNamespace) Clone() ServiceprofilesByNamespace

+ func (byNamespace ServiceprofilesByNamespace) List() ServiceProfileList

+ type TransitionServiceProfileFunc func(original, desired *ServiceProfile) (bool, error)

v0.3.10

Apr 15, 2019

v0.3.9

Apr 15, 2019

Changes in this version

+ type CloneablePod interface

+ Clone func() *github_com_solo_io_supergloo_api_custom_kubepod.Pod

+ type DiscoveryEmitter interface

+ Install func() InstallClient

+ Mesh func() MeshClient

+ Pod func() PodClient

+ Register func() error

+ Snapshots func(watchNamespaces []string, opts clients.WatchOpts) (<-chan *DiscoverySnapshot, <-chan error, error)

+ func NewDiscoveryEmitter(podClient PodClient, meshClient MeshClient, installClient InstallClient) DiscoveryEmitter

+ func NewDiscoveryEmitterWithEmit(podClient PodClient, meshClient MeshClient, installClient InstallClient, ...) DiscoveryEmitter

+ type DiscoveryEventLoop interface

+ Run func(namespaces []string, opts clients.WatchOpts) (<-chan error, error)

+ func NewDiscoveryEventLoop(emitter DiscoveryEmitter, syncer DiscoverySyncer) DiscoveryEventLoop

+ type DiscoveryMetadata struct

+ InjectedNamespaceLabel string

+ InstallationNamespace string

+ MeshVersion string

+ MtlsConfig *MtlsConfig

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*DiscoveryMetadata) Descriptor() ([]byte, []int)

+ func (*DiscoveryMetadata) ProtoMessage()

+ func (m *DiscoveryMetadata) GetInjectedNamespaceLabel() string

+ func (m *DiscoveryMetadata) GetInstallationNamespace() string

+ func (m *DiscoveryMetadata) GetMeshVersion() string

+ func (m *DiscoveryMetadata) GetMtlsConfig() *MtlsConfig

+ func (m *DiscoveryMetadata) Reset()

+ func (m *DiscoveryMetadata) String() string

+ func (m *DiscoveryMetadata) XXX_DiscardUnknown()

+ func (m *DiscoveryMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *DiscoveryMetadata) XXX_Merge(src proto.Message)

+ func (m *DiscoveryMetadata) XXX_Size() int

+ func (m *DiscoveryMetadata) XXX_Unmarshal(b []byte) error

+ func (this *DiscoveryMetadata) Equal(that interface{}) bool

+ type DiscoverySnapshot struct

+ Installs InstallsByNamespace

+ Meshes MeshesByNamespace

+ Pods PodsByNamespace

+ func (s DiscoverySnapshot) Clone() DiscoverySnapshot

+ func (s DiscoverySnapshot) Hash() uint64

+ func (s DiscoverySnapshot) HashFields() []zap.Field

+ func (s DiscoverySnapshot) Stringer() DiscoverySnapshotStringer

+ type DiscoverySnapshotStringer struct

+ Installs []string

+ Meshes []string

+ Pods []string

+ Version uint64

+ func (ss DiscoverySnapshotStringer) String() string

+ type DiscoverySyncer interface

+ Sync func(context.Context, *DiscoverySnapshot) error

+ type DiscoverySyncers []DiscoverySyncer

+ func (s DiscoverySyncers) Sync(ctx context.Context, snapshot *DiscoverySnapshot) error

type IstioMesh

+ IstioVersion string

+ func (m *IstioMesh) GetIstioVersion() string

+ type LinkerdInstall struct

+ EnableAutoInject bool

+ EnableMtls bool

+ LinkerdVersion string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LinkerdInstall) Descriptor() ([]byte, []int)

+ func (*LinkerdInstall) ProtoMessage()

+ func (m *LinkerdInstall) GetEnableAutoInject() bool

+ func (m *LinkerdInstall) GetEnableMtls() bool

+ func (m *LinkerdInstall) GetLinkerdVersion() string

+ func (m *LinkerdInstall) Reset()

+ func (m *LinkerdInstall) String() string

+ func (m *LinkerdInstall) XXX_DiscardUnknown()

+ func (m *LinkerdInstall) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LinkerdInstall) XXX_Merge(src proto.Message)

+ func (m *LinkerdInstall) XXX_Size() int

+ func (m *LinkerdInstall) XXX_Unmarshal(b []byte) error

+ func (this *LinkerdInstall) Equal(that interface{}) bool

+ type LinkerdMesh struct

+ InstallationNamespace string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*LinkerdMesh) Descriptor() ([]byte, []int)

+ func (*LinkerdMesh) ProtoMessage()

+ func (m *LinkerdMesh) GetInstallationNamespace() string

+ func (m *LinkerdMesh) Reset()

+ func (m *LinkerdMesh) String() string

+ func (m *LinkerdMesh) XXX_DiscardUnknown()

+ func (m *LinkerdMesh) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *LinkerdMesh) XXX_Merge(src proto.Message)

+ func (m *LinkerdMesh) XXX_Size() int

+ func (m *LinkerdMesh) XXX_Unmarshal(b []byte) error

+ func (this *LinkerdMesh) Equal(that interface{}) bool

type Mesh

+ DiscoveryMetadata *DiscoveryMetadata

+ func (m *Mesh) GetDiscoveryMetadata() *DiscoveryMetadata

+ func (m *Mesh) GetLinkerdMesh() *LinkerdMesh

type MeshInstall

+ func (m *MeshInstall) GetLinkerdMesh() *LinkerdInstall

+ type MeshInstall_LinkerdMesh struct

+ LinkerdMesh *LinkerdInstall

+ func (this *MeshInstall_LinkerdMesh) Equal(that interface{}) bool

+ type Mesh_LinkerdMesh struct

+ LinkerdMesh *LinkerdMesh

+ func (this *Mesh_LinkerdMesh) Equal(that interface{}) bool

+ type Pod struct

+ func NewPod(namespace, name string) *Pod

+ func (r *Pod) Clone() resources.Resource

+ func (r *Pod) Hash() uint64

+ type PodClient interface

+ BaseClient func() clients.ResourceClient

+ Delete func(namespace, name string, opts clients.DeleteOpts) error

+ List func(namespace string, opts clients.ListOpts) (PodList, error)

+ Read func(namespace, name string, opts clients.ReadOpts) (*Pod, error)

+ Register func() error

+ Watch func(namespace string, opts clients.WatchOpts) (<-chan PodList, <-chan error, error)

+ Write func(resource *Pod, opts clients.WriteOpts) (*Pod, error)

+ func NewPodClient(rcFactory factory.ResourceClientFactory) (PodClient, error)

+ func NewPodClientWithBase(rc clients.ResourceClient) PodClient

+ func NewPodClientWithToken(rcFactory factory.ResourceClientFactory, token string) (PodClient, error)

+ type PodList []*Pod

+ func (list PodList) AsInterfaces() []interface{}

+ func (list PodList) AsResources() resources.ResourceList

+ func (list PodList) Clone() PodList

+ func (list PodList) Each(f func(element *Pod))

+ func (list PodList) Find(namespace, name string) (*Pod, error)

+ func (list PodList) Names() []string

+ func (list PodList) NamespacesDotNames() []string

+ func (list PodList) Sort() PodList

+ type PodReconciler interface

+ Reconcile func(namespace string, desiredResources PodList, transition TransitionPodFunc, ...) error

+ func NewPodReconciler(client PodClient) PodReconciler

+ type PodsByNamespace map[string]PodList

+ func (byNamespace PodsByNamespace) Add(pod ...*Pod)

+ func (byNamespace PodsByNamespace) Clear(namespace string)

+ func (byNamespace PodsByNamespace) Clone() PodsByNamespace

+ func (byNamespace PodsByNamespace) List() PodList

+ type TransitionPodFunc func(original, desired *Pod) (bool, error)

v0.3.8

Apr 10, 2019

v0.3.7

Apr 3, 2019

Changes in this version

+ var FaultInjection_Delay_Type_name = map[int32]string

+ var FaultInjection_Delay_Type_value = map[string]int32

+ var InstallCrd = crd.NewCrd("supergloo.solo.io", "installs", "supergloo.solo.io", "v1", "Install", "i", ...)

+ var MeshCrd = crd.NewCrd("supergloo.solo.io", "meshes", "supergloo.solo.io", "v1", "Mesh", "m", false, ...)

+ var MeshGroupCrd = crd.NewCrd("supergloo.solo.io", "meshgroups", "supergloo.solo.io", "v1", "MeshGroup", ...)

+ var MeshIngressCrd = crd.NewCrd("supergloo.solo.io", "meshingresses", "supergloo.solo.io", "v1", "MeshIngress", ...)

+ var RoutingRuleCrd = crd.NewCrd("supergloo.solo.io", "routingrules", "supergloo.solo.io", "v1", "RoutingRule", ...)

+ var SecurityRuleCrd = crd.NewCrd("supergloo.solo.io", "securityrules", "supergloo.solo.io", "v1", ...)

+ var TlsSecretCrd = crd.NewCrd("supergloo.solo.io", "tlssecrets", "supergloo.solo.io", "v1", "TlsSecret", ...)

+ type AwsAppMesh struct

+ AwsSecret *core.ResourceRef

+ EnableAutoInject bool

+ InjectionSelector *PodSelector

+ Region string

+ SidecarPatchConfigMap *core.ResourceRef

+ VirtualNodeLabel string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*AwsAppMesh) Descriptor() ([]byte, []int)

+ func (*AwsAppMesh) ProtoMessage()

+ func (m *AwsAppMesh) GetAwsSecret() *core.ResourceRef

+ func (m *AwsAppMesh) GetEnableAutoInject() bool

+ func (m *AwsAppMesh) GetInjectionSelector() *PodSelector

+ func (m *AwsAppMesh) GetRegion() string

+ func (m *AwsAppMesh) GetSidecarPatchConfigMap() *core.ResourceRef

+ func (m *AwsAppMesh) GetVirtualNodeLabel() string

+ func (m *AwsAppMesh) Reset()

+ func (m *AwsAppMesh) String() string

+ func (m *AwsAppMesh) XXX_DiscardUnknown()

+ func (m *AwsAppMesh) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *AwsAppMesh) XXX_Merge(src proto.Message)

+ func (m *AwsAppMesh) XXX_Size() int

+ func (m *AwsAppMesh) XXX_Unmarshal(b []byte) error

+ func (this *AwsAppMesh) Equal(that interface{}) bool

+ type ConfigEmitter interface

+ Mesh func() MeshClient

+ MeshGroup func() MeshGroupClient

+ MeshIngress func() MeshIngressClient

+ Pod func() core_kubernetes_io.PodClient

+ Register func() error

+ RoutingRule func() RoutingRuleClient

+ SecurityRule func() SecurityRuleClient

+ Snapshots func(watchNamespaces []string, opts clients.WatchOpts) (<-chan *ConfigSnapshot, <-chan error, error)

+ TlsSecret func() TlsSecretClient

+ Upstream func() gloo_solo_io.UpstreamClient

+ func NewConfigEmitter(meshClient MeshClient, meshIngressClient MeshIngressClient, ...) ConfigEmitter

+ func NewConfigEmitterWithEmit(meshClient MeshClient, meshIngressClient MeshIngressClient, ...) ConfigEmitter

+ type ConfigEventLoop interface

+ Run func(namespaces []string, opts clients.WatchOpts) (<-chan error, error)

+ func NewConfigEventLoop(emitter ConfigEmitter, syncer ConfigSyncer) ConfigEventLoop

+ type ConfigSnapshot struct

+ Meshes MeshesByNamespace

+ Meshgroups MeshgroupsByNamespace

+ Meshingresses MeshingressesByNamespace

+ Pods core_kubernetes_io.PodsByNamespace

+ Routingrules RoutingrulesByNamespace

+ Securityrules SecurityrulesByNamespace

+ Tlssecrets TlssecretsByNamespace

+ Upstreams gloo_solo_io.UpstreamsByNamespace

+ func (s ConfigSnapshot) Clone() ConfigSnapshot

+ func (s ConfigSnapshot) Hash() uint64

+ func (s ConfigSnapshot) HashFields() []zap.Field

+ func (s ConfigSnapshot) Stringer() ConfigSnapshotStringer

+ type ConfigSnapshotStringer struct

+ Meshes []string

+ Meshgroups []string

+ Meshingresses []string

+ Pods []string

+ Routingrules []string

+ Securityrules []string

+ Tlssecrets []string

+ Upstreams []string

+ Version uint64

+ func (ss ConfigSnapshotStringer) String() string

+ type ConfigSyncer interface

+ Sync func(context.Context, *ConfigSnapshot) error

+ type ConfigSyncers []ConfigSyncer

+ func (s ConfigSyncers) Sync(ctx context.Context, snapshot *ConfigSnapshot) error

+ type FaultInjection struct

+ FaultInjectionType isFaultInjection_FaultInjectionType

+ Percentage float64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*FaultInjection) Descriptor() ([]byte, []int)

+ func (*FaultInjection) ProtoMessage()

+ func (*FaultInjection) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *FaultInjection) GetAbort() *FaultInjection_Abort

+ func (m *FaultInjection) GetDelay() *FaultInjection_Delay

+ func (m *FaultInjection) GetFaultInjectionType() isFaultInjection_FaultInjectionType

+ func (m *FaultInjection) GetPercentage() float64

+ func (m *FaultInjection) Reset()

+ func (m *FaultInjection) String() string

+ func (m *FaultInjection) XXX_DiscardUnknown()

+ func (m *FaultInjection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FaultInjection) XXX_Merge(src proto.Message)

+ func (m *FaultInjection) XXX_Size() int

+ func (m *FaultInjection) XXX_Unmarshal(b []byte) error

+ func (this *FaultInjection) Equal(that interface{}) bool

+ type FaultInjection_Abort struct

+ ErrorType isFaultInjection_Abort_ErrorType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*FaultInjection_Abort) Descriptor() ([]byte, []int)

+ func (*FaultInjection_Abort) ProtoMessage()

+ func (*FaultInjection_Abort) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *FaultInjection_Abort) GetErrorType() isFaultInjection_Abort_ErrorType

+ func (m *FaultInjection_Abort) GetHttpStatus() int32

+ func (m *FaultInjection_Abort) Reset()

+ func (m *FaultInjection_Abort) String() string

+ func (m *FaultInjection_Abort) XXX_DiscardUnknown()

+ func (m *FaultInjection_Abort) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FaultInjection_Abort) XXX_Merge(src proto.Message)

+ func (m *FaultInjection_Abort) XXX_Size() int

+ func (m *FaultInjection_Abort) XXX_Unmarshal(b []byte) error

+ func (this *FaultInjection_Abort) Equal(that interface{}) bool

+ type FaultInjection_Abort_ struct

+ Abort *FaultInjection_Abort

+ func (this *FaultInjection_Abort_) Equal(that interface{}) bool

+ type FaultInjection_Abort_HttpStatus struct

+ HttpStatus int32

+ func (this *FaultInjection_Abort_HttpStatus) Equal(that interface{}) bool

+ type FaultInjection_Delay struct

+ DelayType FaultInjection_Delay_Type

+ Duration time.Duration

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*FaultInjection_Delay) Descriptor() ([]byte, []int)

+ func (*FaultInjection_Delay) ProtoMessage()

+ func (m *FaultInjection_Delay) GetDelayType() FaultInjection_Delay_Type

+ func (m *FaultInjection_Delay) GetDuration() time.Duration

+ func (m *FaultInjection_Delay) Reset()

+ func (m *FaultInjection_Delay) String() string

+ func (m *FaultInjection_Delay) XXX_DiscardUnknown()

+ func (m *FaultInjection_Delay) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *FaultInjection_Delay) XXX_Merge(src proto.Message)

+ func (m *FaultInjection_Delay) XXX_Size() int

+ func (m *FaultInjection_Delay) XXX_Unmarshal(b []byte) error

+ func (this *FaultInjection_Delay) Equal(that interface{}) bool

+ type FaultInjection_Delay_ struct

+ Delay *FaultInjection_Delay

+ func (this *FaultInjection_Delay_) Equal(that interface{}) bool

+ type FaultInjection_Delay_Type int32

+ const FaultInjection_Delay_FIXED

+ func (FaultInjection_Delay_Type) EnumDescriptor() ([]byte, []int)

+ func (x FaultInjection_Delay_Type) String() string

+ type GlooInstall struct

+ GlooVersion string

+ Meshes []*core.ResourceRef

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GlooInstall) Descriptor() ([]byte, []int)

+ func (*GlooInstall) ProtoMessage()

+ func (m *GlooInstall) GetGlooVersion() string

+ func (m *GlooInstall) GetMeshes() []*core.ResourceRef

+ func (m *GlooInstall) Reset()

+ func (m *GlooInstall) String() string

+ func (m *GlooInstall) XXX_DiscardUnknown()

+ func (m *GlooInstall) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GlooInstall) XXX_Merge(src proto.Message)

+ func (m *GlooInstall) XXX_Size() int

+ func (m *GlooInstall) XXX_Unmarshal(b []byte) error

+ func (this *GlooInstall) Equal(that interface{}) bool

+ type GlooMeshIngress struct

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*GlooMeshIngress) Descriptor() ([]byte, []int)

+ func (*GlooMeshIngress) ProtoMessage()

+ func (m *GlooMeshIngress) Reset()

+ func (m *GlooMeshIngress) String() string

+ func (m *GlooMeshIngress) XXX_DiscardUnknown()

+ func (m *GlooMeshIngress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *GlooMeshIngress) XXX_Merge(src proto.Message)

+ func (m *GlooMeshIngress) XXX_Size() int

+ func (m *GlooMeshIngress) XXX_Unmarshal(b []byte) error

+ func (this *GlooMeshIngress) Equal(that interface{}) bool

+ type HeaderManipulation struct

+ AppendRequestHeaders map[string]string

+ AppendResponseHeaders map[string]string

+ RemoveRequestHeaders []string

+ RemoveResponseHeaders []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*HeaderManipulation) Descriptor() ([]byte, []int)

+ func (*HeaderManipulation) ProtoMessage()

+ func (m *HeaderManipulation) GetAppendRequestHeaders() map[string]string

+ func (m *HeaderManipulation) GetAppendResponseHeaders() map[string]string

+ func (m *HeaderManipulation) GetRemoveRequestHeaders() []string

+ func (m *HeaderManipulation) GetRemoveResponseHeaders() []string

+ func (m *HeaderManipulation) Reset()

+ func (m *HeaderManipulation) String() string

+ func (m *HeaderManipulation) XXX_DiscardUnknown()

+ func (m *HeaderManipulation) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *HeaderManipulation) XXX_Merge(src proto.Message)

+ func (m *HeaderManipulation) XXX_Size() int

+ func (m *HeaderManipulation) XXX_Unmarshal(b []byte) error

+ func (this *HeaderManipulation) Equal(that interface{}) bool

+ type Install struct

+ Disabled bool

+ InstallType isInstall_InstallType

+ InstallationNamespace string

+ InstalledManifest string

+ Metadata core.Metadata

+ Status core.Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func NewInstall(namespace, name string) *Install

+ func (*Install) Descriptor() ([]byte, []int)

+ func (*Install) ProtoMessage()

+ func (*Install) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *Install) GetDisabled() bool

+ func (m *Install) GetIngress() *MeshIngressInstall

+ func (m *Install) GetInstallType() isInstall_InstallType

+ func (m *Install) GetInstallationNamespace() string

+ func (m *Install) GetInstalledManifest() string

+ func (m *Install) GetMesh() *MeshInstall

+ func (m *Install) GetMetadata() core.Metadata

+ func (m *Install) GetStatus() core.Status

+ func (m *Install) Reset()

+ func (m *Install) String() string

+ func (m *Install) XXX_DiscardUnknown()

+ func (m *Install) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Install) XXX_Merge(src proto.Message)

+ func (m *Install) XXX_Size() int

+ func (m *Install) XXX_Unmarshal(b []byte) error

+ func (o *Install) DeepCopyObject() runtime.Object

+ func (o *Install) GetObjectKind() schema.ObjectKind

+ func (r *Install) Hash() uint64

+ func (r *Install) SetMetadata(meta core.Metadata)

+ func (r *Install) SetStatus(status core.Status)

+ func (this *Install) Equal(that interface{}) bool

+ type InstallClient interface

+ BaseClient func() clients.ResourceClient

+ Delete func(namespace, name string, opts clients.DeleteOpts) error

+ List func(namespace string, opts clients.ListOpts) (InstallList, error)

+ Read func(namespace, name string, opts clients.ReadOpts) (*Install, error)

+ Register func() error

+ Watch func(namespace string, opts clients.WatchOpts) (<-chan InstallList, <-chan error, error)

+ Write func(resource *Install, opts clients.WriteOpts) (*Install, error)

+ func NewInstallClient(rcFactory factory.ResourceClientFactory) (InstallClient, error)

+ func NewInstallClientWithBase(rc clients.ResourceClient) InstallClient

+ func NewInstallClientWithToken(rcFactory factory.ResourceClientFactory, token string) (InstallClient, error)

+ type InstallEmitter interface

+ Install func() InstallClient

+ Mesh func() MeshClient

+ MeshIngress func() MeshIngressClient

+ Register func() error

+ Snapshots func(watchNamespaces []string, opts clients.WatchOpts) (<-chan *InstallSnapshot, <-chan error, error)

+ func NewInstallEmitter(installClient InstallClient, meshClient MeshClient, ...) InstallEmitter

+ func NewInstallEmitterWithEmit(installClient InstallClient, meshClient MeshClient, ...) InstallEmitter

+ type InstallEventLoop interface

+ Run func(namespaces []string, opts clients.WatchOpts) (<-chan error, error)

+ func NewInstallEventLoop(emitter InstallEmitter, syncer InstallSyncer) InstallEventLoop

+ type InstallList []*Install

+ func (list InstallList) AsInputResources() resources.InputResourceList

+ func (list InstallList) AsInterfaces() []interface{}

+ func (list InstallList) AsResources() resources.ResourceList

+ func (list InstallList) Clone() InstallList

+ func (list InstallList) Each(f func(element *Install))

+ func (list InstallList) Find(namespace, name string) (*Install, error)

+ func (list InstallList) Names() []string

+ func (list InstallList) NamespacesDotNames() []string

+ func (list InstallList) Sort() InstallList

+ type InstallReconciler interface

+ Reconcile func(namespace string, desiredResources InstallList, ...) error

+ func NewInstallReconciler(client InstallClient) InstallReconciler

+ type InstallSnapshot struct

+ Installs InstallsByNamespace

+ Meshes MeshesByNamespace

+ Meshingresses MeshingressesByNamespace

+ func (s InstallSnapshot) Clone() InstallSnapshot

+ func (s InstallSnapshot) Hash() uint64

+ func (s InstallSnapshot) HashFields() []zap.Field

+ func (s InstallSnapshot) Stringer() InstallSnapshotStringer

+ type InstallSnapshotStringer struct

+ Installs []string

+ Meshes []string

+ Meshingresses []string

+ Version uint64

+ func (ss InstallSnapshotStringer) String() string

+ type InstallSyncer interface

+ Sync func(context.Context, *InstallSnapshot) error

+ type InstallSyncers []InstallSyncer

+ func (s InstallSyncers) Sync(ctx context.Context, snapshot *InstallSnapshot) error

+ type Install_Ingress struct

+ Ingress *MeshIngressInstall

+ func (this *Install_Ingress) Equal(that interface{}) bool

+ type Install_Mesh struct

+ Mesh *MeshInstall

+ func (this *Install_Mesh) Equal(that interface{}) bool

+ type InstallsByNamespace map[string]InstallList

+ func (byNamespace InstallsByNamespace) Add(install ...*Install)

+ func (byNamespace InstallsByNamespace) Clear(namespace string)

+ func (byNamespace InstallsByNamespace) Clone() InstallsByNamespace

+ func (byNamespace InstallsByNamespace) List() InstallList

+ type IstioInstall struct

+ CustomRootCert *core.ResourceRef

+ EnableAutoInject bool

+ EnableMtls bool

+ InstallGrafana bool

+ InstallJaeger bool

+ InstallPrometheus bool

+ IstioVersion string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*IstioInstall) Descriptor() ([]byte, []int)

+ func (*IstioInstall) ProtoMessage()

+ func (m *IstioInstall) GetCustomRootCert() *core.ResourceRef

+ func (m *IstioInstall) GetEnableAutoInject() bool

+ func (m *IstioInstall) GetEnableMtls() bool

+ func (m *IstioInstall) GetInstallGrafana() bool

+ func (m *IstioInstall) GetInstallJaeger() bool

+ func (m *IstioInstall) GetInstallPrometheus() bool

+ func (m *IstioInstall) GetIstioVersion() string

+ func (m *IstioInstall) Reset()

+ func (m *IstioInstall) String() string

+ func (m *IstioInstall) XXX_DiscardUnknown()

+ func (m *IstioInstall) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *IstioInstall) XXX_Merge(src proto.Message)

+ func (m *IstioInstall) XXX_Size() int

+ func (m *IstioInstall) XXX_Unmarshal(b []byte) error

+ func (this *IstioInstall) Equal(that interface{}) bool

+ type IstioMesh struct

+ InstallationNamespace string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*IstioMesh) Descriptor() ([]byte, []int)

+ func (*IstioMesh) ProtoMessage()

+ func (m *IstioMesh) GetInstallationNamespace() string

+ func (m *IstioMesh) Reset()

+ func (m *IstioMesh) String() string

+ func (m *IstioMesh) XXX_DiscardUnknown()

+ func (m *IstioMesh) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *IstioMesh) XXX_Merge(src proto.Message)

+ func (m *IstioMesh) XXX_Size() int

+ func (m *IstioMesh) XXX_Unmarshal(b []byte) error

+ func (this *IstioMesh) Equal(that interface{}) bool

+ type Mesh struct

+ MeshType isMesh_MeshType

+ Metadata core.Metadata

+ MonitoringConfig *MonitoringConfig

+ MtlsConfig *MtlsConfig

+ Status core.Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func NewMesh(namespace, name string) *Mesh

+ func (*Mesh) Descriptor() ([]byte, []int)

+ func (*Mesh) ProtoMessage()

+ func (*Mesh) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *Mesh) GetAwsAppMesh() *AwsAppMesh

+ func (m *Mesh) GetIstio() *IstioMesh

+ func (m *Mesh) GetMeshType() isMesh_MeshType

+ func (m *Mesh) GetMetadata() core.Metadata

+ func (m *Mesh) GetMonitoringConfig() *MonitoringConfig

+ func (m *Mesh) GetMtlsConfig() *MtlsConfig

+ func (m *Mesh) GetStatus() core.Status

+ func (m *Mesh) Reset()

+ func (m *Mesh) String() string

+ func (m *Mesh) XXX_DiscardUnknown()

+ func (m *Mesh) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *Mesh) XXX_Merge(src proto.Message)

+ func (m *Mesh) XXX_Size() int

+ func (m *Mesh) XXX_Unmarshal(b []byte) error

+ func (o *Mesh) DeepCopyObject() runtime.Object

+ func (o *Mesh) GetObjectKind() schema.ObjectKind

+ func (r *Mesh) Hash() uint64

+ func (r *Mesh) SetMetadata(meta core.Metadata)

+ func (r *Mesh) SetStatus(status core.Status)

+ func (this *Mesh) Equal(that interface{}) bool

+ type MeshClient interface

+ BaseClient func() clients.ResourceClient

+ Delete func(namespace, name string, opts clients.DeleteOpts) error

+ List func(namespace string, opts clients.ListOpts) (MeshList, error)

+ Read func(namespace, name string, opts clients.ReadOpts) (*Mesh, error)

+ Register func() error

+ Watch func(namespace string, opts clients.WatchOpts) (<-chan MeshList, <-chan error, error)

+ Write func(resource *Mesh, opts clients.WriteOpts) (*Mesh, error)

+ func NewMeshClient(rcFactory factory.ResourceClientFactory) (MeshClient, error)

+ func NewMeshClientWithBase(rc clients.ResourceClient) MeshClient

+ func NewMeshClientWithToken(rcFactory factory.ResourceClientFactory, token string) (MeshClient, error)

+ type MeshGroup struct

+ Meshes []*core.ResourceRef

+ Metadata core.Metadata

+ Status core.Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func NewMeshGroup(namespace, name string) *MeshGroup

+ func (*MeshGroup) Descriptor() ([]byte, []int)

+ func (*MeshGroup) ProtoMessage()

+ func (m *MeshGroup) GetMeshes() []*core.ResourceRef

+ func (m *MeshGroup) GetMetadata() core.Metadata

+ func (m *MeshGroup) GetStatus() core.Status

+ func (m *MeshGroup) Reset()

+ func (m *MeshGroup) String() string

+ func (m *MeshGroup) XXX_DiscardUnknown()

+ func (m *MeshGroup) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MeshGroup) XXX_Merge(src proto.Message)

+ func (m *MeshGroup) XXX_Size() int

+ func (m *MeshGroup) XXX_Unmarshal(b []byte) error

+ func (o *MeshGroup) DeepCopyObject() runtime.Object

+ func (o *MeshGroup) GetObjectKind() schema.ObjectKind

+ func (r *MeshGroup) Hash() uint64

+ func (r *MeshGroup) SetMetadata(meta core.Metadata)

+ func (r *MeshGroup) SetStatus(status core.Status)

+ func (this *MeshGroup) Equal(that interface{}) bool

+ type MeshGroupClient interface

+ BaseClient func() clients.ResourceClient

+ Delete func(namespace, name string, opts clients.DeleteOpts) error

+ List func(namespace string, opts clients.ListOpts) (MeshGroupList, error)

+ Read func(namespace, name string, opts clients.ReadOpts) (*MeshGroup, error)

+ Register func() error

+ Watch func(namespace string, opts clients.WatchOpts) (<-chan MeshGroupList, <-chan error, error)

+ Write func(resource *MeshGroup, opts clients.WriteOpts) (*MeshGroup, error)

+ func NewMeshGroupClient(rcFactory factory.ResourceClientFactory) (MeshGroupClient, error)

+ func NewMeshGroupClientWithBase(rc clients.ResourceClient) MeshGroupClient

+ func NewMeshGroupClientWithToken(rcFactory factory.ResourceClientFactory, token string) (MeshGroupClient, error)

+ type MeshGroupList []*MeshGroup

+ func (list MeshGroupList) AsInputResources() resources.InputResourceList

+ func (list MeshGroupList) AsInterfaces() []interface{}

+ func (list MeshGroupList) AsResources() resources.ResourceList

+ func (list MeshGroupList) Clone() MeshGroupList

+ func (list MeshGroupList) Each(f func(element *MeshGroup))

+ func (list MeshGroupList) Find(namespace, name string) (*MeshGroup, error)

+ func (list MeshGroupList) Names() []string

+ func (list MeshGroupList) NamespacesDotNames() []string

+ func (list MeshGroupList) Sort() MeshGroupList

+ type MeshGroupReconciler interface

+ Reconcile func(namespace string, desiredResources MeshGroupList, ...) error

+ func NewMeshGroupReconciler(client MeshGroupClient) MeshGroupReconciler

+ type MeshIngress struct

+ InstallationNamespace string

+ MeshIngressType isMeshIngress_MeshIngressType

+ Meshes []*core.ResourceRef

+ Metadata core.Metadata

+ Status core.Status

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func NewMeshIngress(namespace, name string) *MeshIngress

+ func (*MeshIngress) Descriptor() ([]byte, []int)

+ func (*MeshIngress) ProtoMessage()

+ func (*MeshIngress) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *MeshIngress) GetGloo() *GlooMeshIngress

+ func (m *MeshIngress) GetInstallationNamespace() string

+ func (m *MeshIngress) GetMeshIngressType() isMeshIngress_MeshIngressType

+ func (m *MeshIngress) GetMeshes() []*core.ResourceRef

+ func (m *MeshIngress) GetMetadata() core.Metadata

+ func (m *MeshIngress) GetStatus() core.Status

+ func (m *MeshIngress) Reset()

+ func (m *MeshIngress) String() string

+ func (m *MeshIngress) XXX_DiscardUnknown()

+ func (m *MeshIngress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MeshIngress) XXX_Merge(src proto.Message)

+ func (m *MeshIngress) XXX_Size() int

+ func (m *MeshIngress) XXX_Unmarshal(b []byte) error

+ func (o *MeshIngress) DeepCopyObject() runtime.Object

+ func (o *MeshIngress) GetObjectKind() schema.ObjectKind

+ func (r *MeshIngress) Hash() uint64

+ func (r *MeshIngress) SetMetadata(meta core.Metadata)

+ func (r *MeshIngress) SetStatus(status core.Status)

+ func (this *MeshIngress) Equal(that interface{}) bool

+ type MeshIngressClient interface

+ BaseClient func() clients.ResourceClient

+ Delete func(namespace, name string, opts clients.DeleteOpts) error

+ List func(namespace string, opts clients.ListOpts) (MeshIngressList, error)

+ Read func(namespace, name string, opts clients.ReadOpts) (*MeshIngress, error)

+ Register func() error

+ Watch func(namespace string, opts clients.WatchOpts) (<-chan MeshIngressList, <-chan error, error)

+ Write func(resource *MeshIngress, opts clients.WriteOpts) (*MeshIngress, error)

+ func NewMeshIngressClient(rcFactory factory.ResourceClientFactory) (MeshIngressClient, error)

+ func NewMeshIngressClientWithBase(rc clients.ResourceClient) MeshIngressClient

+ func NewMeshIngressClientWithToken(rcFactory factory.ResourceClientFactory, token string) (MeshIngressClient, error)

+ type MeshIngressInstall struct

+ IngressInstallType isMeshIngressInstall_IngressInstallType

+ InstalledIngress *core.ResourceRef

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*MeshIngressInstall) Descriptor() ([]byte, []int)

+ func (*MeshIngressInstall) ProtoMessage()

+ func (*MeshIngressInstall) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *MeshIngressInstall) GetGloo() *GlooInstall

+ func (m *MeshIngressInstall) GetIngressInstallType() isMeshIngressInstall_IngressInstallType

+ func (m *MeshIngressInstall) GetInstalledIngress() *core.ResourceRef

+ func (m *MeshIngressInstall) Reset()

+ func (m *MeshIngressInstall) String() string

+ func (m *MeshIngressInstall) XXX_DiscardUnknown()

+ func (m *MeshIngressInstall) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MeshIngressInstall) XXX_Merge(src proto.Message)

+ func (m *MeshIngressInstall) XXX_Size() int

+ func (m *MeshIngressInstall) XXX_Unmarshal(b []byte) error

+ func (this *MeshIngressInstall) Equal(that interface{}) bool

+ type MeshIngressInstall_Gloo struct

+ Gloo *GlooInstall

+ func (this *MeshIngressInstall_Gloo) Equal(that interface{}) bool

+ type MeshIngressList []*MeshIngress

+ func (list MeshIngressList) AsInputResources() resources.InputResourceList

+ func (list MeshIngressList) AsInterfaces() []interface{}

+ func (list MeshIngressList) AsResources() resources.ResourceList

+ func (list MeshIngressList) Clone() MeshIngressList

+ func (list MeshIngressList) Each(f func(element *MeshIngress))

+ func (list MeshIngressList) Find(namespace, name string) (*MeshIngress, error)

+ func (list MeshIngressList) Names() []string

+ func (list MeshIngressList) NamespacesDotNames() []string

+ func (list MeshIngressList) Sort() MeshIngressList

+ type MeshIngressReconciler interface

+ Reconcile func(namespace string, desiredResources MeshIngressList, ...) error

+ func NewMeshIngressReconciler(client MeshIngressClient) MeshIngressReconciler

+ type MeshIngress_Gloo struct

+ Gloo *GlooMeshIngress

+ func (this *MeshIngress_Gloo) Equal(that interface{}) bool

+ type MeshInstall struct

+ InstalledMesh *core.ResourceRef

+ MeshInstallType isMeshInstall_MeshInstallType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*MeshInstall) Descriptor() ([]byte, []int)

+ func (*MeshInstall) ProtoMessage()

+ func (*MeshInstall) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *MeshInstall) GetInstalledMesh() *core.ResourceRef

+ func (m *MeshInstall) GetIstioMesh() *IstioInstall

+ func (m *MeshInstall) GetMeshInstallType() isMeshInstall_MeshInstallType

+ func (m *MeshInstall) Reset()

+ func (m *MeshInstall) String() string

+ func (m *MeshInstall) XXX_DiscardUnknown()

+ func (m *MeshInstall) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MeshInstall) XXX_Merge(src proto.Message)

+ func (m *MeshInstall) XXX_Size() int

+ func (m *MeshInstall) XXX_Unmarshal(b []byte) error

+ func (this *MeshInstall) Equal(that interface{}) bool

+ type MeshInstall_IstioMesh struct

+ IstioMesh *IstioInstall

+ func (this *MeshInstall_IstioMesh) Equal(that interface{}) bool

+ type MeshList []*Mesh

+ func (list MeshList) AsInputResources() resources.InputResourceList

+ func (list MeshList) AsInterfaces() []interface{}

+ func (list MeshList) AsResources() resources.ResourceList

+ func (list MeshList) Clone() MeshList

+ func (list MeshList) Each(f func(element *Mesh))

+ func (list MeshList) Find(namespace, name string) (*Mesh, error)

+ func (list MeshList) Names() []string

+ func (list MeshList) NamespacesDotNames() []string

+ func (list MeshList) Sort() MeshList

+ type MeshReconciler interface

+ Reconcile func(namespace string, desiredResources MeshList, transition TransitionMeshFunc, ...) error

+ func NewMeshReconciler(client MeshClient) MeshReconciler

+ type Mesh_AwsAppMesh struct

+ AwsAppMesh *AwsAppMesh

+ func (this *Mesh_AwsAppMesh) Equal(that interface{}) bool

+ type Mesh_Istio struct

+ Istio *IstioMesh

+ func (this *Mesh_Istio) Equal(that interface{}) bool

+ type MeshesByNamespace map[string]MeshList

+ func (byNamespace MeshesByNamespace) Add(mesh ...*Mesh)

+ func (byNamespace MeshesByNamespace) Clear(namespace string)

+ func (byNamespace MeshesByNamespace) Clone() MeshesByNamespace

+ func (byNamespace MeshesByNamespace) List() MeshList

+ type MeshgroupsByNamespace map[string]MeshGroupList

+ func (byNamespace MeshgroupsByNamespace) Add(meshGroup ...*MeshGroup)

+ func (byNamespace MeshgroupsByNamespace) Clear(namespace string)

+ func (byNamespace MeshgroupsByNamespace) Clone() MeshgroupsByNamespace

+ func (byNamespace MeshgroupsByNamespace) List() MeshGroupList

+ type MeshingressesByNamespace map[string]MeshIngressList

+ func (byNamespace MeshingressesByNamespace) Add(meshIngress ...*MeshIngress)

+ func (byNamespace MeshingressesByNamespace) Clear(namespace string)

+ func (byNamespace MeshingressesByNamespace) Clone() MeshingressesByNamespace

+ func (byNamespace MeshingressesByNamespace) List() MeshIngressList

+ type MonitoringConfig struct

+ PrometheusConfigmaps []core.ResourceRef

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*MonitoringConfig) Descriptor() ([]byte, []int)

+ func (*MonitoringConfig) ProtoMessage()

+ func (m *MonitoringConfig) GetPrometheusConfigmaps() []core.ResourceRef

+ func (m *MonitoringConfig) Reset()

+ func (m *MonitoringConfig) String() string

+ func (m *MonitoringConfig) XXX_DiscardUnknown()

+ func (m *MonitoringConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MonitoringConfig) XXX_Merge(src proto.Message)

+ func (m *MonitoringConfig) XXX_Size() int

+ func (m *MonitoringConfig) XXX_Unmarshal(b []byte) error

+ func (this *MonitoringConfig) Equal(that interface{}) bool

+ type MtlsConfig struct

+ MtlsEnabled bool

+ RootCertificate *core.ResourceRef

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*MtlsConfig) Descriptor() ([]byte, []int)

+ func (*MtlsConfig) ProtoMessage()

+ func (m *MtlsConfig) GetMtlsEnabled() bool

+ func (m *MtlsConfig) GetRootCertificate() *core.ResourceRef

+ func (m *MtlsConfig) Reset()

+ func (m *MtlsConfig) String() string

+ func (m *MtlsConfig) XXX_DiscardUnknown()

+ func (m *MtlsConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *MtlsConfig) XXX_Merge(src proto.Message)

+ func (m *MtlsConfig) XXX_Size() int

+ func (m *MtlsConfig) XXX_Unmarshal(b []byte) error

+ func (this *MtlsConfig) Equal(that interface{}) bool

+ type PodSelector struct

+ SelectorType isPodSelector_SelectorType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PodSelector) Descriptor() ([]byte, []int)

+ func (*PodSelector) ProtoMessage()

+ func (*PodSelector) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *PodSelector) GetLabelSelector() *PodSelector_LabelSelector

+ func (m *PodSelector) GetNamespaceSelector() *PodSelector_NamespaceSelector

+ func (m *PodSelector) GetSelectorType() isPodSelector_SelectorType

+ func (m *PodSelector) GetUpstreamSelector() *PodSelector_UpstreamSelector

+ func (m *PodSelector) Reset()

+ func (m *PodSelector) String() string

+ func (m *PodSelector) XXX_DiscardUnknown()

+ func (m *PodSelector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PodSelector) XXX_Merge(src proto.Message)

+ func (m *PodSelector) XXX_Size() int

+ func (m *PodSelector) XXX_Unmarshal(b []byte) error

+ func (this *PodSelector) Equal(that interface{}) bool

+ type PodSelector_LabelSelector struct

+ LabelsToMatch map[string]string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PodSelector_LabelSelector) Descriptor() ([]byte, []int)

+ func (*PodSelector_LabelSelector) ProtoMessage()

+ func (m *PodSelector_LabelSelector) GetLabelsToMatch() map[string]string

+ func (m *PodSelector_LabelSelector) Reset()

+ func (m *PodSelector_LabelSelector) String() string

+ func (m *PodSelector_LabelSelector) XXX_DiscardUnknown()

+ func (m *PodSelector_LabelSelector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PodSelector_LabelSelector) XXX_Merge(src proto.Message)

+ func (m *PodSelector_LabelSelector) XXX_Size() int

+ func (m *PodSelector_LabelSelector) XXX_Unmarshal(b []byte) error

+ func (this *PodSelector_LabelSelector) Equal(that interface{}) bool

+ type PodSelector_LabelSelector_ struct

+ LabelSelector *PodSelector_LabelSelector

+ func (this *PodSelector_LabelSelector_) Equal(that interface{}) bool

+ type PodSelector_NamespaceSelector struct

+ Namespaces []string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PodSelector_NamespaceSelector) Descriptor() ([]byte, []int)

+ func (*PodSelector_NamespaceSelector) ProtoMessage()

+ func (m *PodSelector_NamespaceSelector) GetNamespaces() []string

+ func (m *PodSelector_NamespaceSelector) Reset()

+ func (m *PodSelector_NamespaceSelector) String() string

+ func (m *PodSelector_NamespaceSelector) XXX_DiscardUnknown()

+ func (m *PodSelector_NamespaceSelector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PodSelector_NamespaceSelector) XXX_Merge(src proto.Message)

+ func (m *PodSelector_NamespaceSelector) XXX_Size() int

+ func (m *PodSelector_NamespaceSelector) XXX_Unmarshal(b []byte) error

+ func (this *PodSelector_NamespaceSelector) Equal(that interface{}) bool

+ type PodSelector_NamespaceSelector_ struct

+ NamespaceSelector *PodSelector_NamespaceSelector

+ func (this *PodSelector_NamespaceSelector_) Equal(that interface{}) bool

+ type PodSelector_UpstreamSelector struct

+ Upstreams []core.ResourceRef

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*PodSelector_UpstreamSelector) Descriptor() ([]byte, []int)

+ func (*PodSelector_UpstreamSelector) ProtoMessage()

+ func (m *PodSelector_UpstreamSelector) GetUpstreams() []core.ResourceRef

+ func (m *PodSelector_UpstreamSelector) Reset()

+ func (m *PodSelector_UpstreamSelector) String() string

+ func (m *PodSelector_UpstreamSelector) XXX_DiscardUnknown()

+ func (m *PodSelector_UpstreamSelector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *PodSelector_UpstreamSelector) XXX_Merge(src proto.Message)

+ func (m *PodSelector_UpstreamSelector) XXX_Size() int

+ func (m *PodSelector_UpstreamSelector) XXX_Unmarshal(b []byte) error

+ func (this *PodSelector_UpstreamSelector) Equal(that interface{}) bool

+ type PodSelector_UpstreamSelector_ struct

+ UpstreamSelector *PodSelector_UpstreamSelector

+ func (this *PodSelector_UpstreamSelector_) Equal(that interface{}) bool

+ type RegistrationEmitter interface

+ Mesh func() MeshClient

+ MeshIngress func() MeshIngressClient

+ Register func() error

+ Snapshots func(watchNamespaces []string, opts clients.WatchOpts) (<-chan *RegistrationSnapshot, <-chan error, error)

+ func NewRegistrationEmitter(meshClient MeshClient, meshIngressClient MeshIngressClient) RegistrationEmitter

+ func NewRegistrationEmitterWithEmit(meshClient MeshClient, meshIngressClient MeshIngressClient, ...) RegistrationEmitter

+ type RegistrationEventLoop interface

+ Run func(namespaces []string, opts clients.WatchOpts) (<-chan error, error)

+ func NewRegistrationEventLoop(emitter RegistrationEmitter, syncer RegistrationSyncer) RegistrationEventLoop

+ type RegistrationSnapshot struct

+ Meshes MeshesByNamespace

+ Meshingresses MeshingressesByNamespace

+ func (s RegistrationSnapshot) Clone() RegistrationSnapshot

+ func (s RegistrationSnapshot) Hash() uint64

+ func (s RegistrationSnapshot) HashFields() []zap.Field

+ func (s RegistrationSnapshot) Stringer() RegistrationSnapshotStringer

+ type RegistrationSnapshotStringer struct

+ Meshes []string

+ Meshingresses []string

+ Version uint64

+ func (ss RegistrationSnapshotStringer) String() string

+ type RegistrationSyncer interface

+ Sync func(context.Context, *RegistrationSnapshot) error

+ type RegistrationSyncers []RegistrationSyncer

+ func (s RegistrationSyncers) Sync(ctx context.Context, snapshot *RegistrationSnapshot) error

+ type RoutingRule struct

+ DestinationSelector *PodSelector

+ Metadata core.Metadata

+ RequestMatchers []*v1.Matcher

+ SourceSelector *PodSelector

+ Spec *RoutingRuleSpec

+ Status core.Status

+ TargetMesh *core.ResourceRef

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func NewRoutingRule(namespace, name string) *RoutingRule

+ func (*RoutingRule) Descriptor() ([]byte, []int)

+ func (*RoutingRule) ProtoMessage()

+ func (m *RoutingRule) GetDestinationSelector() *PodSelector

+ func (m *RoutingRule) GetMetadata() core.Metadata

+ func (m *RoutingRule) GetRequestMatchers() []*v1.Matcher

+ func (m *RoutingRule) GetSourceSelector() *PodSelector

+ func (m *RoutingRule) GetSpec() *RoutingRuleSpec

+ func (m *RoutingRule) GetStatus() core.Status

+ func (m *RoutingRule) GetTargetMesh() *core.ResourceRef

+ func (m *RoutingRule) Reset()

+ func (m *RoutingRule) String() string

+ func (m *RoutingRule) XXX_DiscardUnknown()

+ func (m *RoutingRule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RoutingRule) XXX_Merge(src proto.Message)

+ func (m *RoutingRule) XXX_Size() int

+ func (m *RoutingRule) XXX_Unmarshal(b []byte) error

+ func (o *RoutingRule) DeepCopyObject() runtime.Object

+ func (o *RoutingRule) GetObjectKind() schema.ObjectKind

+ func (r *RoutingRule) Hash() uint64

+ func (r *RoutingRule) SetMetadata(meta core.Metadata)

+ func (r *RoutingRule) SetStatus(status core.Status)

+ func (this *RoutingRule) Equal(that interface{}) bool

+ type RoutingRuleClient interface

+ BaseClient func() clients.ResourceClient

+ Delete func(namespace, name string, opts clients.DeleteOpts) error

+ List func(namespace string, opts clients.ListOpts) (RoutingRuleList, error)

+ Read func(namespace, name string, opts clients.ReadOpts) (*RoutingRule, error)

+ Register func() error

+ Watch func(namespace string, opts clients.WatchOpts) (<-chan RoutingRuleList, <-chan error, error)

+ Write func(resource *RoutingRule, opts clients.WriteOpts) (*RoutingRule, error)

+ func NewRoutingRuleClient(rcFactory factory.ResourceClientFactory) (RoutingRuleClient, error)

+ func NewRoutingRuleClientWithBase(rc clients.ResourceClient) RoutingRuleClient

+ func NewRoutingRuleClientWithToken(rcFactory factory.ResourceClientFactory, token string) (RoutingRuleClient, error)

+ type RoutingRuleList []*RoutingRule

+ func (list RoutingRuleList) AsInputResources() resources.InputResourceList

+ func (list RoutingRuleList) AsInterfaces() []interface{}

+ func (list RoutingRuleList) AsResources() resources.ResourceList

+ func (list RoutingRuleList) Clone() RoutingRuleList

+ func (list RoutingRuleList) Each(f func(element *RoutingRule))

+ func (list RoutingRuleList) Find(namespace, name string) (*RoutingRule, error)

+ func (list RoutingRuleList) Names() []string

+ func (list RoutingRuleList) NamespacesDotNames() []string

+ func (list RoutingRuleList) Sort() RoutingRuleList

+ type RoutingRuleReconciler interface

+ Reconcile func(namespace string, desiredResources RoutingRuleList, ...) error

+ func NewRoutingRuleReconciler(client RoutingRuleClient) RoutingRuleReconciler

+ type RoutingRuleSpec struct

+ RuleType isRoutingRuleSpec_RuleType

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*RoutingRuleSpec) Descriptor() ([]byte, []int)

+ func (*RoutingRuleSpec) ProtoMessage()

+ func (*RoutingRuleSpec) XXX_OneofFuncs() (func(msg proto.Message, b *proto.Buffer) error, ...)

+ func (m *RoutingRuleSpec) GetCorsPolicy() *v1alpha3.CorsPolicy

+ func (m *RoutingRuleSpec) GetFaultInjection() *FaultInjection

+ func (m *RoutingRuleSpec) GetHeaderManipulation() *HeaderManipulation

+ func (m *RoutingRuleSpec) GetMirror() *v1.Destination

+ func (m *RoutingRuleSpec) GetRequestTimeout() *types.Duration

+ func (m *RoutingRuleSpec) GetRetries() *v1alpha3.HTTPRetry

+ func (m *RoutingRuleSpec) GetRuleType() isRoutingRuleSpec_RuleType

+ func (m *RoutingRuleSpec) GetTrafficShifting() *TrafficShifting

+ func (m *RoutingRuleSpec) Reset()

+ func (m *RoutingRuleSpec) String() string

+ func (m *RoutingRuleSpec) XXX_DiscardUnknown()

+ func (m *RoutingRuleSpec) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *RoutingRuleSpec) XXX_Merge(src proto.Message)

+ func (m *RoutingRuleSpec) XXX_Size() int

+ func (m *RoutingRuleSpec) XXX_Unmarshal(b []byte) error

+ func (this *RoutingRuleSpec) Equal(that interface{}) bool

+ type RoutingRuleSpec_CorsPolicy struct

+ CorsPolicy *v1alpha3.CorsPolicy

+ func (this *RoutingRuleSpec_CorsPolicy) Equal(that interface{}) bool

+ type RoutingRuleSpec_FaultInjection struct

+ FaultInjection *FaultInjection

+ func (this *RoutingRuleSpec_FaultInjection) Equal(that interface{}) bool

+ type RoutingRuleSpec_HeaderManipulation struct

+ HeaderManipulation *HeaderManipulation

+ func (this *RoutingRuleSpec_HeaderManipulation) Equal(that interface{}) bool

+ type RoutingRuleSpec_Mirror struct

+ Mirror *v1.Destination

+ func (this *RoutingRuleSpec_Mirror) Equal(that interface{}) bool

+ type RoutingRuleSpec_RequestTimeout struct

+ RequestTimeout *types.Duration

+ func (this *RoutingRuleSpec_RequestTimeout) Equal(that interface{}) bool

+ type RoutingRuleSpec_Retries struct

+ Retries *v1alpha3.HTTPRetry

+ func (this *RoutingRuleSpec_Retries) Equal(that interface{}) bool

+ type RoutingRuleSpec_TrafficShifting struct

+ TrafficShifting *TrafficShifting

+ func (this *RoutingRuleSpec_TrafficShifting) Equal(that interface{}) bool

+ type RoutingrulesByNamespace map[string]RoutingRuleList

+ func (byNamespace RoutingrulesByNamespace) Add(routingRule ...*RoutingRule)

+ func (byNamespace RoutingrulesByNamespace) Clear(namespace string)

+ func (byNamespace RoutingrulesByNamespace) Clone() RoutingrulesByNamespace

+ func (byNamespace RoutingrulesByNamespace) List() RoutingRuleList

+ type SecurityRule struct

+ AllowedMethods []string

+ AllowedPaths []string

+ DestinationSelector *PodSelector

+ Metadata core.Metadata

+ SourceSelector *PodSelector

+ Status core.Status

+ TargetMesh *core.ResourceRef

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func NewSecurityRule(namespace, name string) *SecurityRule

+ func (*SecurityRule) Descriptor() ([]byte, []int)

+ func (*SecurityRule) ProtoMessage()

+ func (m *SecurityRule) GetAllowedMethods() []string

+ func (m *SecurityRule) GetAllowedPaths() []string

+ func (m *SecurityRule) GetDestinationSelector() *PodSelector

+ func (m *SecurityRule) GetMetadata() core.Metadata

+ func (m *SecurityRule) GetSourceSelector() *PodSelector

+ func (m *SecurityRule) GetStatus() core.Status

+ func (m *SecurityRule) GetTargetMesh() *core.ResourceRef

+ func (m *SecurityRule) Reset()

+ func (m *SecurityRule) String() string

+ func (m *SecurityRule) XXX_DiscardUnknown()

+ func (m *SecurityRule) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *SecurityRule) XXX_Merge(src proto.Message)

+ func (m *SecurityRule) XXX_Size() int

+ func (m *SecurityRule) XXX_Unmarshal(b []byte) error

+ func (o *SecurityRule) DeepCopyObject() runtime.Object

+ func (o *SecurityRule) GetObjectKind() schema.ObjectKind

+ func (r *SecurityRule) Hash() uint64

+ func (r *SecurityRule) SetMetadata(meta core.Metadata)

+ func (r *SecurityRule) SetStatus(status core.Status)

+ func (this *SecurityRule) Equal(that interface{}) bool

+ type SecurityRuleClient interface

+ BaseClient func() clients.ResourceClient

+ Delete func(namespace, name string, opts clients.DeleteOpts) error

+ List func(namespace string, opts clients.ListOpts) (SecurityRuleList, error)

+ Read func(namespace, name string, opts clients.ReadOpts) (*SecurityRule, error)

+ Register func() error

+ Watch func(namespace string, opts clients.WatchOpts) (<-chan SecurityRuleList, <-chan error, error)

+ Write func(resource *SecurityRule, opts clients.WriteOpts) (*SecurityRule, error)

+ func NewSecurityRuleClient(rcFactory factory.ResourceClientFactory) (SecurityRuleClient, error)

+ func NewSecurityRuleClientWithBase(rc clients.ResourceClient) SecurityRuleClient

+ func NewSecurityRuleClientWithToken(rcFactory factory.ResourceClientFactory, token string) (SecurityRuleClient, error)

+ type SecurityRuleList []*SecurityRule

+ func (list SecurityRuleList) AsInputResources() resources.InputResourceList

+ func (list SecurityRuleList) AsInterfaces() []interface{}

+ func (list SecurityRuleList) AsResources() resources.ResourceList

+ func (list SecurityRuleList) Clone() SecurityRuleList

+ func (list SecurityRuleList) Each(f func(element *SecurityRule))

+ func (list SecurityRuleList) Find(namespace, name string) (*SecurityRule, error)

+ func (list SecurityRuleList) Names() []string

+ func (list SecurityRuleList) NamespacesDotNames() []string

+ func (list SecurityRuleList) Sort() SecurityRuleList

+ type SecurityRuleReconciler interface

+ Reconcile func(namespace string, desiredResources SecurityRuleList, ...) error

+ func NewSecurityRuleReconciler(client SecurityRuleClient) SecurityRuleReconciler

+ type SecurityrulesByNamespace map[string]SecurityRuleList

+ func (byNamespace SecurityrulesByNamespace) Add(securityRule ...*SecurityRule)

+ func (byNamespace SecurityrulesByNamespace) Clear(namespace string)

+ func (byNamespace SecurityrulesByNamespace) Clone() SecurityrulesByNamespace

+ func (byNamespace SecurityrulesByNamespace) List() SecurityRuleList

+ type TlsSecret struct

+ CaCert string

+ CaKey string

+ CertChain string

+ Metadata core.Metadata

+ RootCert string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func NewTlsSecret(namespace, name string) *TlsSecret

+ func (*TlsSecret) Descriptor() ([]byte, []int)

+ func (*TlsSecret) ProtoMessage()

+ func (m *TlsSecret) GetCaCert() string

+ func (m *TlsSecret) GetCaKey() string

+ func (m *TlsSecret) GetCertChain() string

+ func (m *TlsSecret) GetMetadata() core.Metadata

+ func (m *TlsSecret) GetRootCert() string

+ func (m *TlsSecret) Reset()

+ func (m *TlsSecret) String() string

+ func (m *TlsSecret) XXX_DiscardUnknown()

+ func (m *TlsSecret) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TlsSecret) XXX_Merge(src proto.Message)

+ func (m *TlsSecret) XXX_Size() int

+ func (m *TlsSecret) XXX_Unmarshal(b []byte) error

+ func (o *TlsSecret) DeepCopyObject() runtime.Object

+ func (o *TlsSecret) GetObjectKind() schema.ObjectKind

+ func (r *TlsSecret) Hash() uint64

+ func (r *TlsSecret) SetMetadata(meta core.Metadata)

+ func (this *TlsSecret) Equal(that interface{}) bool

+ type TlsSecretClient interface

+ BaseClient func() clients.ResourceClient

+ Delete func(namespace, name string, opts clients.DeleteOpts) error

+ List func(namespace string, opts clients.ListOpts) (TlsSecretList, error)

+ Read func(namespace, name string, opts clients.ReadOpts) (*TlsSecret, error)

+ Register func() error

+ Watch func(namespace string, opts clients.WatchOpts) (<-chan TlsSecretList, <-chan error, error)

+ Write func(resource *TlsSecret, opts clients.WriteOpts) (*TlsSecret, error)

+ func NewTlsSecretClient(rcFactory factory.ResourceClientFactory) (TlsSecretClient, error)

+ func NewTlsSecretClientWithBase(rc clients.ResourceClient) TlsSecretClient

+ func NewTlsSecretClientWithToken(rcFactory factory.ResourceClientFactory, token string) (TlsSecretClient, error)

+ type TlsSecretList []*TlsSecret

+ func (list TlsSecretList) AsInterfaces() []interface{}

+ func (list TlsSecretList) AsResources() resources.ResourceList

+ func (list TlsSecretList) Clone() TlsSecretList

+ func (list TlsSecretList) Each(f func(element *TlsSecret))

+ func (list TlsSecretList) Find(namespace, name string) (*TlsSecret, error)

+ func (list TlsSecretList) Names() []string

+ func (list TlsSecretList) NamespacesDotNames() []string

+ func (list TlsSecretList) Sort() TlsSecretList

+ type TlsSecretReconciler interface

+ Reconcile func(namespace string, desiredResources TlsSecretList, ...) error

+ func NewTlsSecretReconciler(client TlsSecretClient) TlsSecretReconciler

+ type TlssecretsByNamespace map[string]TlsSecretList

+ func (byNamespace TlssecretsByNamespace) Add(tlsSecret ...*TlsSecret)

+ func (byNamespace TlssecretsByNamespace) Clear(namespace string)

+ func (byNamespace TlssecretsByNamespace) Clone() TlssecretsByNamespace

+ func (byNamespace TlssecretsByNamespace) List() TlsSecretList

+ type TrafficShifting struct

+ Destinations *v1.MultiDestination

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

+ func (*TrafficShifting) Descriptor() ([]byte, []int)

+ func (*TrafficShifting) ProtoMessage()

+ func (m *TrafficShifting) GetDestinations() *v1.MultiDestination

+ func (m *TrafficShifting) Reset()

+ func (m *TrafficShifting) String() string

+ func (m *TrafficShifting) XXX_DiscardUnknown()

+ func (m *TrafficShifting) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

+ func (m *TrafficShifting) XXX_Merge(src proto.Message)

+ func (m *TrafficShifting) XXX_Size() int

+ func (m *TrafficShifting) XXX_Unmarshal(b []byte) error

+ func (this *TrafficShifting) Equal(that interface{}) bool

+ type TransitionInstallFunc func(original, desired *Install) (bool, error)

+ type TransitionMeshFunc func(original, desired *Mesh) (bool, error)

+ type TransitionMeshGroupFunc func(original, desired *MeshGroup) (bool, error)

+ type TransitionMeshIngressFunc func(original, desired *MeshIngress) (bool, error)

+ type TransitionRoutingRuleFunc func(original, desired *RoutingRule) (bool, error)

+ type TransitionSecurityRuleFunc func(original, desired *SecurityRule) (bool, error)

+ type TransitionTlsSecretFunc func(original, desired *TlsSecret) (bool, error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL