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 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 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 {
	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 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

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.