reconciler

package

Go to main page

Versions in this module

v0

v0.5.5

Sep 7, 2023

v0.5.4

May 16, 2023

v0.5.3

Mar 29, 2023

v0.5.2

Mar 3, 2023

Changes in this version

type DeployerConfig

+ ConsulPartitionInfo consul.PartitionInfo

v0.5.1

Nov 22, 2022

v0.5.0

Nov 17, 2022

Changes in this version

+ func NewBinder(client gatewayclient.Client) *binder

+ type DeployerConfig struct

+ Client gatewayclient.Client

+ Consul consul.Client

+ ConsulCA string

+ ConsulNamespaceMirroring bool

+ Logger hclog.Logger

+ PrimaryDatacenter string

+ SDSHost string

+ SDSPort int

+ type GatewayDeployer struct

+ func NewDeployer(config DeployerConfig) *GatewayDeployer

+ func (d *GatewayDeployer) Deploy(ctx context.Context, gateway *K8sGateway) error

+ func (d *GatewayDeployer) Deployment(namespace string, config apigwv1alpha1.GatewayClassConfig, ...) *apps.Deployment

+ func (d *GatewayDeployer) Service(config apigwv1alpha1.GatewayClassConfig, gateway *gwv1beta1.Gateway) *core.Service

type K8sGateway

+ Config apigwv1alpha1.GatewayClassConfig

+ GatewayState *state.GatewayState

+ func (g *K8sGateway) CanFetchSecrets(secrets []string) (bool, error)

+ func (g *K8sGateway) Resolve() core.ResolvedGateway

type K8sRoute

+ RouteState *state.RouteState

+ func (r *K8sRoute) UnmarshalJSON(b []byte) error

+ func (r K8sRoute) MarshalJSON() ([]byte, error)

type K8sRouteConfig

+ State *state.RouteState

type ManagerConfig

+ ConsulNamespaceMirroring bool

+ PrimaryDatacenter string

+ type Marshaler struct

+ func NewMarshaler() *Marshaler

+ func (m *Marshaler) MarshalGateway(gateway store.Gateway) ([]byte, error)

+ func (m *Marshaler) MarshalRoute(route store.Route) ([]byte, error)

+ func (m *Marshaler) UnmarshalGateway(data []byte) (store.Gateway, error)

+ func (m *Marshaler) UnmarshalRoute(data []byte) (store.Route, error)

+ type StatusUpdater struct

+ func NewStatusUpdater(logger hclog.Logger, client gatewayclient.Client, deployer *GatewayDeployer, ...) *StatusUpdater

+ func (s *StatusUpdater) UpdateGatewayStatusOnSync(ctx context.Context, gateway store.Gateway, sync func() (bool, error)) error

+ func (s *StatusUpdater) UpdateRouteStatus(ctx context.Context, route store.Route) error

v0.4.0

Aug 16, 2022

Changes in this version

+ const RouteConditionReasonBackendNotFound

+ const RouteConditionReasonInvalidKind

type RouteResolvedRefsStatus

+ BackendNotFound error

+ InvalidKind error

v0.3.0

Jun 21, 2022

Changes in this version

type CertificateResolutionError

+ func NewCertificateResolutionErrorNotPermitted(inner string) CertificateResolutionError

type CertificateResolutionErrorType

+ const CertificateResolutionErrorTypeNotPermitted

v0.2.1

Apr 29, 2022

v0.2.0

Apr 27, 2022

Changes in this version

+ const RouteConditionReasonRefNotPermitted

type K8sGateway

+ func (g *K8sGateway) ShouldUpdate(other store.Gateway) bool

type RouteResolvedRefsStatus

+ RefNotPermitted error

v0.1.0

Feb 23, 2022

Changes in this version

+ const GatewayClassConditionAccepted

+ const GatewayClassConditionReasonAccepted

+ const GatewayClassConditionReasonInvalidParameters

+ const GatewayClassConditionReasonWaiting

+ const GatewayConditionInSync

+ const GatewayConditionReady

+ const GatewayConditionReasonAddressNotAssigned

+ const GatewayConditionReasonInSync

+ const GatewayConditionReasonListenersNotReady

+ const GatewayConditionReasonListenersNotValid

+ const GatewayConditionReasonNoResources

+ const GatewayConditionReasonNotReconciled

+ const GatewayConditionReasonPodFailed

+ const GatewayConditionReasonReady

+ const GatewayConditionReasonScheduled

+ const GatewayConditionReasonSyncError

+ const GatewayConditionReasonUnknown

+ const GatewayConditionScheduled

+ const ListenerConditionConflicted

+ const ListenerConditionDetached

+ const ListenerConditionReady

+ const ListenerConditionReasonAttached

+ const ListenerConditionReasonHostnameConflict

+ const ListenerConditionReasonInvalid

+ const ListenerConditionReasonInvalidCertificateRef

+ const ListenerConditionReasonInvalidRouteKinds

+ const ListenerConditionReasonNoConflicts

+ const ListenerConditionReasonPending

+ const ListenerConditionReasonPortUnavailable

+ const ListenerConditionReasonProtocolConflict

+ const ListenerConditionReasonReady

+ const ListenerConditionReasonRefNotPermitted

+ const ListenerConditionReasonResolvedRefs

+ const ListenerConditionReasonRouteConflict

+ const ListenerConditionReasonUnsupportedAddress

+ const ListenerConditionReasonUnsupportedExtension

+ const ListenerConditionReasonUnsupportedProtocol

+ const ListenerConditionResolvedRefs

+ const NamespaceNameLabel

+ const RouteConditionAccepted

+ const RouteConditionReasonAccepted

+ const RouteConditionReasonBindError

+ const RouteConditionReasonConsulServiceNotFound

+ const RouteConditionReasonErrors

+ const RouteConditionReasonInvalidRouteKind

+ const RouteConditionReasonListenerHostnameMismatch

+ const RouteConditionReasonListenerNamespacePolicy

+ const RouteConditionReasonResolvedRefs

+ const RouteConditionReasonServiceNotFound

+ const RouteConditionResolvedRefs

+ func HTTPRouteID(namespacedName types.NamespacedName) string

+ func TCPRouteID(namespacedName types.NamespacedName) string

+ func TLSRouteID(namespacedName types.NamespacedName) string

+ func UDPRouteID(namespacedName types.NamespacedName) string

+ type BindError struct

+ func NewBindErrorHostnameMismatch(inner string) BindError

+ func NewBindErrorListenerNamespacePolicy(inner string) BindError

+ func NewBindErrorRouteInvalid(inner string) BindError

+ func NewBindErrorRouteKind(inner string) BindError

+ func (r BindError) Error() string

+ func (r BindError) Kind() BindErrorType

+ type BindErrorType int

+ const BindErrorTypeHostnameMismatch

+ const BindErrorTypeListenerNamespacePolicy

+ const BindErrorTypeRouteInvalid

+ const BindErrorTypeRouteKind

+ type CertificateResolutionError struct

+ func NewCertificateResolutionErrorNotFound(inner string) CertificateResolutionError

+ func NewCertificateResolutionErrorUnsupported(inner string) CertificateResolutionError

+ func (r CertificateResolutionError) Error() string

+ func (r CertificateResolutionError) Kind() CertificateResolutionErrorType

+ type CertificateResolutionErrorType int

+ const CertificateResolutionErrorTypeNotFound

+ const CertificateResolutionErrorTypeUnsupported

+ type GatewayClassAcceptedStatus struct

+ InvalidParameters error

+ Waiting error

+ func (s GatewayClassAcceptedStatus) Condition(generation int64) meta.Condition

+ func (s GatewayClassAcceptedStatus) HasError() bool

+ type GatewayClassStatus struct

+ Accepted GatewayClassAcceptedStatus

+ func (s GatewayClassStatus) Conditions(generation int64) []meta.Condition

+ type GatewayInSyncStatus struct

+ SyncError error

+ func (s GatewayInSyncStatus) Condition(generation int64) meta.Condition

+ func (s GatewayInSyncStatus) HasError() bool

+ type GatewayReadyStatus struct

+ AddressNotAssigned error

+ ListenersNotReady error

+ ListenersNotValid error

+ func (s GatewayReadyStatus) Condition(generation int64) meta.Condition

+ func (s GatewayReadyStatus) HasError() bool

+ type GatewayReconcileManager struct

+ func NewReconcileManager(config ManagerConfig) *GatewayReconcileManager

+ func (m *GatewayReconcileManager) DeleteGateway(ctx context.Context, name types.NamespacedName) error

+ func (m *GatewayReconcileManager) DeleteGatewayClass(ctx context.Context, name string) error

+ func (m *GatewayReconcileManager) DeleteHTTPRoute(ctx context.Context, name types.NamespacedName) error

+ func (m *GatewayReconcileManager) DeleteTCPRoute(ctx context.Context, name types.NamespacedName) error

+ func (m *GatewayReconcileManager) DeleteTLSRoute(ctx context.Context, name types.NamespacedName) error

+ func (m *GatewayReconcileManager) UpsertGateway(ctx context.Context, g *gw.Gateway) error

+ func (m *GatewayReconcileManager) UpsertGatewayClass(ctx context.Context, gc *gw.GatewayClass) error

+ func (m *GatewayReconcileManager) UpsertHTTPRoute(ctx context.Context, r Route) error

+ func (m *GatewayReconcileManager) UpsertTCPRoute(ctx context.Context, r Route) error

+ func (m *GatewayReconcileManager) UpsertTLSRoute(ctx context.Context, r Route) error

+ type GatewayScheduledStatus struct

+ NoResources error

+ NotReconciled error

+ PodFailed error

+ Unknown error

+ func (s GatewayScheduledStatus) Condition(generation int64) meta.Condition

+ func (s GatewayScheduledStatus) HasError() bool

+ type GatewayStatus struct

+ InSync GatewayInSyncStatus

+ Ready GatewayReadyStatus

+ Scheduled GatewayScheduledStatus

+ func (s GatewayStatus) Conditions(generation int64) []meta.Condition

+ type K8sGateway struct

+ func NewK8sGateway(gateway *gw.Gateway, config K8sGatewayConfig) *K8sGateway

+ func (g *K8sGateway) Compare(other store.Gateway) store.CompareResult

+ func (g *K8sGateway) ID() core.GatewayID

+ func (g *K8sGateway) Listeners() []store.Listener

+ func (g *K8sGateway) Meta() map[string]string

+ func (g *K8sGateway) ShouldBind(route store.Route) bool

+ func (g *K8sGateway) Status() gw.GatewayStatus

+ func (g *K8sGateway) TrackSync(ctx context.Context, sync func() (bool, error)) error

+ func (g *K8sGateway) Validate(ctx context.Context) error

+ type K8sGatewayClass struct

+ func NewK8sGatewayClass(class *gw.GatewayClass, config K8sGatewayClassConfig) *K8sGatewayClass

+ func (c *K8sGatewayClass) IsValid() bool

+ func (c *K8sGatewayClass) SyncStatus(ctx context.Context) error

+ func (c *K8sGatewayClass) Validate(ctx context.Context) error

+ type K8sGatewayClassConfig struct

+ Client gatewayclient.Client

+ Logger hclog.Logger

+ type K8sGatewayClasses struct

+ func NewK8sGatewayClasses(logger hclog.Logger, client gatewayclient.Client) *K8sGatewayClasses

+ func (g *K8sGatewayClasses) Delete(name string)

+ func (g *K8sGatewayClasses) GetConfig(name string) (apigwv1alpha1.GatewayClassConfig, bool)

+ func (g *K8sGatewayClasses) Upsert(ctx context.Context, class *K8sGatewayClass) error

+ type K8sGatewayConfig struct

+ Client gatewayclient.Client

+ Config apigwv1alpha1.GatewayClassConfig

+ ConsulCA string

+ ConsulNamespace string

+ Logger hclog.Logger

+ SDSHost string

+ SDSPort int

+ type K8sListener struct

+ func NewK8sListener(gateway *gw.Gateway, listener gw.Listener, config K8sListenerConfig) *K8sListener

+ func (l *K8sListener) CanBind(route store.Route) (bool, error)

+ func (l *K8sListener) Config() store.ListenerConfig

+ func (l *K8sListener) ID() string

+ func (l *K8sListener) IsValid() bool

+ func (l *K8sListener) OnRouteAdded(_ store.Route)

+ func (l *K8sListener) OnRouteRemoved(_ string)

+ func (l *K8sListener) Status() gw.ListenerStatus

+ func (l *K8sListener) Validate(ctx context.Context) error

+ type K8sListenerConfig struct

+ Client gatewayclient.Client

+ ConsulNamespace string

+ Logger hclog.Logger

+ type K8sRoute struct

+ func NewK8sRoute(route Route, config K8sRouteConfig) *K8sRoute

+ func (r *K8sRoute) CommonRouteSpec() gw.CommonRouteSpec

+ func (r *K8sRoute) Compare(other store.Route) store.CompareResult

+ func (r *K8sRoute) FilterParentStatuses() []gw.RouteParentStatus

+ func (r *K8sRoute) ID() string

+ func (r *K8sRoute) IsValid() bool

+ func (r *K8sRoute) MatchesHostname(hostname *gw.Hostname) bool

+ func (r *K8sRoute) MergedStatus() gw.RouteStatus

+ func (r *K8sRoute) NeedsStatusUpdate() bool

+ func (r *K8sRoute) OnBindFailed(err error, gateway store.Gateway)

+ func (r *K8sRoute) OnBound(gateway store.Gateway)

+ func (r *K8sRoute) OnGatewayRemoved(gateway store.Gateway)

+ func (r *K8sRoute) ParentStatuses() []gw.RouteParentStatus

+ func (r *K8sRoute) Parents() []gw.ParentRef

+ func (r *K8sRoute) Resolve(listener store.Listener) *core.ResolvedRoute

+ func (r *K8sRoute) SetStatus(updated gw.RouteStatus)

+ func (r *K8sRoute) SyncStatus(ctx context.Context) error

+ func (r *K8sRoute) Validate(ctx context.Context) error

+ type K8sRouteConfig struct

+ Client gatewayclient.Client

+ ControllerName string

+ Logger hclog.Logger

+ Resolver service.BackendResolver

+ type ListenerConflictedStatus struct

+ HostnameConflict error

+ ProtocolConflict error

+ RouteConflict error

+ func (s ListenerConflictedStatus) Condition(generation int64) meta.Condition

+ func (s ListenerConflictedStatus) HasError() bool

+ type ListenerDetachedStatus struct

+ PortUnavailable error

+ UnsupportedAddress error

+ UnsupportedExtension error

+ UnsupportedProtocol error

+ func (s ListenerDetachedStatus) Condition(generation int64) meta.Condition

+ func (s ListenerDetachedStatus) HasError() bool

+ type ListenerReadyStatus struct

+ Invalid error

+ Pending error

+ func (s ListenerReadyStatus) Condition(generation int64) meta.Condition

+ func (s ListenerReadyStatus) HasError() bool

+ type ListenerResolvedRefsStatus struct

+ InvalidCertificateRef error

+ InvalidRouteKinds error

+ RefNotPermitted error

+ func (s ListenerResolvedRefsStatus) Condition(generation int64) meta.Condition

+ func (s ListenerResolvedRefsStatus) HasError() bool

+ type ListenerStatus struct

+ Conflicted ListenerConflictedStatus

+ Detached ListenerDetachedStatus

+ Ready ListenerReadyStatus

+ ResolvedRefs ListenerResolvedRefsStatus

+ func (s ListenerStatus) Conditions(generation int64) []meta.Condition

+ func (s ListenerStatus) Valid() bool

+ type ManagerConfig struct

+ Client gatewayclient.Client

+ Consul *api.Client

+ ConsulCA string

+ ConsulNamespaceMapper common.ConsulNamespaceMapper

+ ControllerName string

+ Logger hclog.Logger

+ SDSHost string

+ SDSPort int

+ Store store.Store

+ type ReconcileManager interface

+ DeleteGateway func(ctx context.Context, name types.NamespacedName) error

+ DeleteGatewayClass func(ctx context.Context, name string) error

+ DeleteHTTPRoute func(ctx context.Context, name types.NamespacedName) error

+ DeleteTCPRoute func(ctx context.Context, name types.NamespacedName) error

+ DeleteTLSRoute func(ctx context.Context, name types.NamespacedName) error

+ UpsertGateway func(ctx context.Context, g *gw.Gateway) error

+ UpsertGatewayClass func(ctx context.Context, gc *gw.GatewayClass) error

+ UpsertHTTPRoute func(ctx context.Context, r Route) error

+ UpsertTCPRoute func(ctx context.Context, r Route) error

+ UpsertTLSRoute func(ctx context.Context, r Route) error

+ type Route interface

+ type RouteAcceptedStatus struct

+ BindError error

+ InvalidRouteKind error

+ ListenerHostnameMismatch error

+ ListenerNamespacePolicy error

+ func (s RouteAcceptedStatus) Condition(generation int64) meta.Condition

+ type RouteResolvedRefsStatus struct

+ ConsulServiceNotFound error

+ Errors error

+ ServiceNotFound error

+ func (s RouteResolvedRefsStatus) Condition(generation int64) meta.Condition

+ func (s RouteResolvedRefsStatus) HasError() bool

+ type RouteStatus struct

+ Accepted RouteAcceptedStatus

+ ResolvedRefs RouteResolvedRefsStatus

+ func (s RouteStatus) Conditions(generation int64) []meta.Condition

v0.1.0-techpreview

Nov 11, 2021

v0.1.0-beta

Jan 26, 2022

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