v1

package
v0.13.18 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 22, 2019 License: Apache-2.0 Imports: 30 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ClusterIngressCrd = crd.NewCrd("clusteringress.gloo.solo.io",
	"clusteringresses",
	"clusteringress.gloo.solo.io",
	"v1",
	"ClusterIngress",
	"cig",
	true,
	&ClusterIngress{})

Functions

func NewTranslatorEventLoop

func NewTranslatorEventLoop(emitter TranslatorEmitter, syncer TranslatorSyncer) eventloop.EventLoop

Types

type ClusterIngress

type ClusterIngress struct {
	Metadata core.Metadata `protobuf:"bytes,1,opt,name=metadata,proto3" json:"metadata"`
	Status   core.Status   `protobuf:"bytes,4,opt,name=status,proto3" json:"status"`
	// a raw byte representation of the cluster ingress this resource wraps
	ClusterIngressSpec *types.Any `protobuf:"bytes,2,opt,name=cluster_ingress_spec,json=clusterIngressSpec,proto3" json:"cluster_ingress_spec,omitempty"`
	// a raw byte representation of the ingress status of the cluster ingress object
	ClusterIngressStatus *types.Any `protobuf:"bytes,3,opt,name=cluster_ingress_status,json=clusterIngressStatus,proto3" json:"cluster_ingress_status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

A simple wrapper for a kNative ClusterIngress Object.

func NewClusterIngress

func NewClusterIngress(namespace, name string) *ClusterIngress

func (*ClusterIngress) DeepCopyObject

func (o *ClusterIngress) DeepCopyObject() runtime.Object

func (*ClusterIngress) Descriptor

func (*ClusterIngress) Descriptor() ([]byte, []int)

func (*ClusterIngress) Equal

func (this *ClusterIngress) Equal(that interface{}) bool

func (*ClusterIngress) GetClusterIngressSpec

func (m *ClusterIngress) GetClusterIngressSpec() *types.Any

func (*ClusterIngress) GetClusterIngressStatus

func (m *ClusterIngress) GetClusterIngressStatus() *types.Any

func (*ClusterIngress) GetMetadata

func (m *ClusterIngress) GetMetadata() core.Metadata

func (*ClusterIngress) GetObjectKind

func (o *ClusterIngress) GetObjectKind() schema.ObjectKind

func (*ClusterIngress) GetStatus

func (m *ClusterIngress) GetStatus() core.Status

func (*ClusterIngress) Hash

func (r *ClusterIngress) Hash() uint64

func (*ClusterIngress) ProtoMessage

func (*ClusterIngress) ProtoMessage()

func (*ClusterIngress) Reset

func (m *ClusterIngress) Reset()

func (*ClusterIngress) SetMetadata

func (r *ClusterIngress) SetMetadata(meta core.Metadata)

func (*ClusterIngress) SetStatus

func (r *ClusterIngress) SetStatus(status core.Status)

func (*ClusterIngress) String

func (m *ClusterIngress) String() string

func (*ClusterIngress) XXX_DiscardUnknown

func (m *ClusterIngress) XXX_DiscardUnknown()

func (*ClusterIngress) XXX_Marshal

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

func (*ClusterIngress) XXX_Merge

func (m *ClusterIngress) XXX_Merge(src proto.Message)

func (*ClusterIngress) XXX_Size

func (m *ClusterIngress) XXX_Size() int

func (*ClusterIngress) XXX_Unmarshal

func (m *ClusterIngress) XXX_Unmarshal(b []byte) error

type ClusterIngressClient

type ClusterIngressClient interface {
	BaseClient() clients.ResourceClient
	Register() error
	Read(name string, opts clients.ReadOpts) (*ClusterIngress, error)
	Write(resource *ClusterIngress, opts clients.WriteOpts) (*ClusterIngress, error)
	Delete(name string, opts clients.DeleteOpts) error
	List(opts clients.ListOpts) (ClusterIngressList, error)
	Watch(opts clients.WatchOpts) (<-chan ClusterIngressList, <-chan error, error)
}

func NewClusterIngressClient

func NewClusterIngressClient(rcFactory factory.ResourceClientFactory) (ClusterIngressClient, error)

func NewClusterIngressClientWithBase

func NewClusterIngressClientWithBase(rc clients.ResourceClient) ClusterIngressClient

func NewClusterIngressClientWithToken

func NewClusterIngressClientWithToken(rcFactory factory.ResourceClientFactory, token string) (ClusterIngressClient, error)

type ClusterIngressList

type ClusterIngressList []*ClusterIngress

func (ClusterIngressList) AsInputResources

func (list ClusterIngressList) AsInputResources() resources.InputResourceList

func (ClusterIngressList) AsInterfaces

func (list ClusterIngressList) AsInterfaces() []interface{}

func (ClusterIngressList) AsResources

func (list ClusterIngressList) AsResources() resources.ResourceList

func (ClusterIngressList) Clone

func (ClusterIngressList) Each

func (list ClusterIngressList) Each(f func(element *ClusterIngress))

func (ClusterIngressList) Find

func (list ClusterIngressList) Find(namespace, name string) (*ClusterIngress, error)

namespace is optional, if left empty, names can collide if the list contains more than one with the same name

func (ClusterIngressList) Names

func (list ClusterIngressList) Names() []string

func (ClusterIngressList) NamespacesDotNames

func (list ClusterIngressList) NamespacesDotNames() []string

func (ClusterIngressList) Sort

type ClusterIngressReconciler

type ClusterIngressReconciler interface {
	Reconcile(namespace string, desiredResources ClusterIngressList, transition TransitionClusterIngressFunc, opts clients.ListOpts) error
}

func NewClusterIngressReconciler

func NewClusterIngressReconciler(client ClusterIngressClient) ClusterIngressReconciler

type ClusteringressesByNamespace

type ClusteringressesByNamespace map[string]ClusterIngressList

func (ClusteringressesByNamespace) Add

func (byNamespace ClusteringressesByNamespace) Add(clusterIngress ...*ClusterIngress)

func (ClusteringressesByNamespace) Clear

func (byNamespace ClusteringressesByNamespace) Clear(namespace string)

func (ClusteringressesByNamespace) Clone

func (ClusteringressesByNamespace) List

type TransitionClusterIngressFunc

type TransitionClusterIngressFunc func(original, desired *ClusterIngress) (bool, error)

Option to copy anything from the original to the desired before writing. Return value of false means don't update

type TranslatorEmitter

type TranslatorEmitter interface {
	Register() error
	Secret() gloo_solo_io.SecretClient
	Upstream() gloo_solo_io.UpstreamClient
	ClusterIngress() ClusterIngressClient
	Snapshots(watchNamespaces []string, opts clients.WatchOpts) (<-chan *TranslatorSnapshot, <-chan error, error)
}

func NewTranslatorEmitter

func NewTranslatorEmitter(secretClient gloo_solo_io.SecretClient, upstreamClient gloo_solo_io.UpstreamClient, clusterIngressClient ClusterIngressClient) TranslatorEmitter

func NewTranslatorEmitterWithEmit

func NewTranslatorEmitterWithEmit(secretClient gloo_solo_io.SecretClient, upstreamClient gloo_solo_io.UpstreamClient, clusterIngressClient ClusterIngressClient, emit <-chan struct{}) TranslatorEmitter

type TranslatorSnapshot

type TranslatorSnapshot struct {
	Secrets          gloo_solo_io.SecretsByNamespace
	Upstreams        gloo_solo_io.UpstreamsByNamespace
	Clusteringresses ClusterIngressList
}

func (TranslatorSnapshot) Clone

func (TranslatorSnapshot) Hash

func (s TranslatorSnapshot) Hash() uint64

func (TranslatorSnapshot) HashFields

func (s TranslatorSnapshot) HashFields() []zap.Field

func (TranslatorSnapshot) Stringer

type TranslatorSnapshotStringer

type TranslatorSnapshotStringer struct {
	Version          uint64
	Secrets          []string
	Upstreams        []string
	Clusteringresses []string
}

func (TranslatorSnapshotStringer) String

func (ss TranslatorSnapshotStringer) String() string

type TranslatorSyncer

type TranslatorSyncer interface {
	Sync(context.Context, *TranslatorSnapshot) error
}

type TranslatorSyncers

type TranslatorSyncers []TranslatorSyncer

func (TranslatorSyncers) Sync

func (s TranslatorSyncers) Sync(ctx context.Context, snapshot *TranslatorSnapshot) error

Jump to

Keyboard shortcuts

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