v1

package
v1.6.0-beta17 Latest Latest
Warning

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

Go to latest
Published: Dec 8, 2020 License: Apache-2.0 Imports: 28 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewTranslatorEventLoop

func NewTranslatorEventLoop(emitter TranslatorSnapshotEmitter, 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 (*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 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

func (TranslatorSnapshot) Clone

func (TranslatorSnapshot) Hash

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

func (TranslatorSnapshot) HashFields

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

func (TranslatorSnapshot) Stringer

type TranslatorSnapshotEmitter added in v0.18.44

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

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

Deprecated: use TranslatorSyncDeciderWithContext

type TranslatorSyncDeciderWithContext added in v0.15.0

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

Jump to

Keyboard shortcuts

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