v1

Documentation

Index

• func NewTranslatorEventLoop(emitter TranslatorSnapshotEmitter, syncer TranslatorSyncer) eventloop.EventLoop
• func NewTranslatorSimpleEventLoop(emitter TranslatorSimpleEmitter, syncers ...TranslatorSyncer) eventloop.SimpleEventLoop
• type ClusterIngress
  • func (*ClusterIngress) Descriptor() ([]byte, []int)
  • func (this *ClusterIngress) Equal(that interface{}) bool
  • func (m *ClusterIngress) GetClusterIngressSpec() *types.Any
  • func (m *ClusterIngress) GetClusterIngressStatus() *types.Any
  • func (m *ClusterIngress) GetMetadata() core.Metadata
  • func (m *ClusterIngress) GetStatus() core.Status
  • func (*ClusterIngress) ProtoMessage()
  • func (m *ClusterIngress) Reset()
  • func (m *ClusterIngress) String() string
  • func (m *ClusterIngress) XXX_DiscardUnknown()
  • func (m *ClusterIngress) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ClusterIngress) XXX_Merge(src proto.Message)
  • func (m *ClusterIngress) XXX_Size() int
  • func (m *ClusterIngress) XXX_Unmarshal(b []byte) error
• type TranslatorEmitter
  • func NewTranslatorEmitter(...) TranslatorEmitter
  • func NewTranslatorEmitterWithEmit(...) TranslatorEmitter
• type TranslatorSimpleEmitter
  • func NewTranslatorSimpleEmitter(aggregatedWatch clients.ResourceWatch) TranslatorSimpleEmitter
  • func NewTranslatorSimpleEmitterWithEmit(aggregatedWatch clients.ResourceWatch, emit <-chan struct{}) TranslatorSimpleEmitter
• type TranslatorSnapshot
  • func (s TranslatorSnapshot) Clone() TranslatorSnapshot
  • func (s TranslatorSnapshot) Hash(hasher hash.Hash64) (uint64, error)
  • func (s TranslatorSnapshot) HashFields() []zap.Field
  • func (s TranslatorSnapshot) Stringer() TranslatorSnapshotStringer
• type TranslatorSnapshotEmitter
• type TranslatorSnapshotStringer
  • func (ss TranslatorSnapshotStringer) String() string
• type TranslatorSyncDecider
• type TranslatorSyncDeciderWithContext
• type TranslatorSyncer
• type TranslatorSyncers
  • func (s TranslatorSyncers) Sync(ctx context.Context, snapshot *TranslatorSnapshot) error

Functions

func NewTranslatorEventLoop

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

func NewTranslatorSimpleEventLoop

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 (*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) GetStatus

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

func (*ClusterIngress) ProtoMessage

func (*ClusterIngress) ProtoMessage()

func (*ClusterIngress) Reset

func (m *ClusterIngress) Reset()

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 TranslatorEmitter

type TranslatorEmitter interface {
	TranslatorSnapshotEmitter
	Register() error
	ClusterIngress() github_com_solo_io_gloo_projects_clusteringress_pkg_api_external_knative.ClusterIngressClient
}

func NewTranslatorEmitter

func NewTranslatorEmitter(clusterIngressClient github_com_solo_io_gloo_projects_clusteringress_pkg_api_external_knative.ClusterIngressClient) TranslatorEmitter

func NewTranslatorEmitterWithEmit

func NewTranslatorEmitterWithEmit(clusterIngressClient github_com_solo_io_gloo_projects_clusteringress_pkg_api_external_knative.ClusterIngressClient, emit <-chan struct{}) TranslatorEmitter

type TranslatorSimpleEmitter

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

func NewTranslatorSimpleEmitter

func NewTranslatorSimpleEmitter(aggregatedWatch clients.ResourceWatch) TranslatorSimpleEmitter

func NewTranslatorSimpleEmitterWithEmit

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

type TranslatorSnapshot

type TranslatorSnapshot struct {
	Clusteringresses github_com_solo_io_gloo_projects_clusteringress_pkg_api_external_knative.ClusterIngressList
}

func (TranslatorSnapshot) Clone

func (s TranslatorSnapshot) Clone() TranslatorSnapshot

func (TranslatorSnapshot) Hash

func (s TranslatorSnapshot) Hash(hasher hash.Hash64) (uint64, error)

func (TranslatorSnapshot) HashFields

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

func (TranslatorSnapshot) Stringer

func (s TranslatorSnapshot) Stringer() TranslatorSnapshotStringer

type TranslatorSnapshotEmitter

type TranslatorSnapshotEmitter interface {
	Snapshots(watchNamespaces []string, opts clients.WatchOpts) (<-chan *TranslatorSnapshot, <-chan error, error)
}

type TranslatorSnapshotStringer

type TranslatorSnapshotStringer struct {
	Version          uint64
	Clusteringresses []string
}

func (TranslatorSnapshotStringer) String

func (ss TranslatorSnapshotStringer) String() string

type TranslatorSyncDecider

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

Deprecated: use TranslatorSyncDeciderWithContext

type TranslatorSyncDeciderWithContext

type TranslatorSyncDeciderWithContext interface {
	TranslatorSyncer
	ShouldSync(ctx context.Context, old, new *TranslatorSnapshot) bool
}

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