v1

package
v0.13.24 Latest Latest
Warning

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

 Go to latest Published: May 10, 2019 License: Apache-2.0 Imports: 30 Imported by: 0

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

func NewTranslatorSimpleEventLoop added in v0.13.21 

func NewTranslatorSimpleEventLoop(emitter TranslatorSimpleEmitter, syncers ...TranslatorSyncer) eventloop.SimpleEventLoop

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)
	ClusterIngressWatcher
}

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 (list ClusterIngressList) Clone() ClusterIngressList

func (ClusterIngressList) Each 

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

func (ClusterIngressList) EachResource added in v0.13.21 

func (list ClusterIngressList) EachResource(f func(element resources.Resource))

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 

func (list ClusterIngressList) Sort() ClusterIngressList

type ClusterIngressReconciler 

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

func NewClusterIngressReconciler 

func NewClusterIngressReconciler(client ClusterIngressClient) ClusterIngressReconciler

type ClusterIngressWatcher added in v0.13.21 

type ClusterIngressWatcher interface {
	// watch cluster-scoped Clusteringresses
	Watch(opts clients.WatchOpts) (<-chan ClusterIngressList, <-chan error, error)
}

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 TranslatorSimpleEmitter added in v0.13.21 

type TranslatorSimpleEmitter interface {
	Snapshots(ctx context.Context) (<-chan *TranslatorSnapshot, <-chan error, error)
}

func NewTranslatorSimpleEmitter added in v0.13.21 

func NewTranslatorSimpleEmitter(aggregatedWatch clients.ResourceWatch) TranslatorSimpleEmitter

func NewTranslatorSimpleEmitterWithEmit added in v0.13.21 

func NewTranslatorSimpleEmitterWithEmit(aggregatedWatch clients.ResourceWatch, emit <-chan struct{}) TranslatorSimpleEmitter

type TranslatorSnapshot 

type TranslatorSnapshot struct {
	Secrets          gloo_solo_io.SecretList
	Upstreams        gloo_solo_io.UpstreamList
	Clusteringresses ClusterIngressList
}

func (TranslatorSnapshot) Clone 

func (s TranslatorSnapshot) Clone() TranslatorSnapshot

func (TranslatorSnapshot) Hash 

func (s TranslatorSnapshot) Hash() uint64

func (TranslatorSnapshot) HashFields 

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

func (TranslatorSnapshot) Stringer 

func (s TranslatorSnapshot) Stringer() TranslatorSnapshotStringer

type TranslatorSnapshotStringer 

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

func (TranslatorSnapshotStringer) String 

func (ss TranslatorSnapshotStringer) String() string

type TranslatorSyncDecider added in v0.13.21 

type TranslatorSyncDecider interface {
	TranslatorSyncer
	ShouldSync(old, new *TranslatorSnapshot) bool
}

a Syncer which implements this interface can make smarter decisions over whether it should be restarted (including having its context cancelled) based on a diff of the previous and current snapshot

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.