Documentation ¶
Index ¶
- type DestinationService
- type EndpointsReconciler
- type EndpointsReconcilerOpts
- type HTTPAccessLogEntryWrapper
- type LogEntry
- type NamespaceReconciler
- type NamespaceReconcilerOpts
- type Resource
- func (r *Resource) AddDestinationServiceToSidecar(entry *HTTPAccessLogEntryWrapper) error
- func (r *Resource) AddExternalServiceToEnvoyFilter(entry *HTTPAccessLogEntryWrapper) error
- func (r *Resource) AddServiceToEnvoyFilter(ctx context.Context, svc *corev1.Service) error
- func (r *Resource) BindPortToFence(ctx context.Context, sps []corev1.ServicePort) error
- func (r *Resource) CreateSidecar(ctx context.Context, svc *corev1.Service) error
- func (r *Resource) RefreshByHTTPAccessLogEntryWrapper(ctx context.Context, obj *HTTPAccessLogEntryWrapper) error
- func (r *Resource) RefreshByService(ctx context.Context, obj *corev1.Service) error
- type Runner
- type VarNamespace
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DestinationService ¶
type DestinationService int
const ( Internal DestinationService = iota External )
type EndpointsReconciler ¶
type EndpointsReconciler struct { client.Client config.Server Scheme *runtime.Scheme Sidecar *istio.Sidecar NamespaceCache *cache.Namespace Resource *Resource }
func NewEndpointsReconciler ¶
func NewEndpointsReconciler(opts ...EndpointsReconcilerOpts) *EndpointsReconciler
func (*EndpointsReconciler) SetupWithManager ¶
func (r *EndpointsReconciler) SetupWithManager(mgr ctrl.Manager) error
type EndpointsReconcilerOpts ¶
type EndpointsReconcilerOpts func(*EndpointsReconciler)
type HTTPAccessLogEntryWrapper ¶
type HTTPAccessLogEntryWrapper struct { types.NamespacedName *data_accesslog.HTTPAccessLogEntry DestinationService DestinationService }
type LogEntry ¶
func NewLogEntry ¶
func (*LogEntry) StreamLogEntry ¶
func (l *LogEntry) StreamLogEntry(logEntrys []*data_accesslog.HTTPAccessLogEntry)
type NamespaceReconciler ¶
type NamespaceReconciler struct { config.Server client.Client Scheme *runtime.Scheme Sidecar *istio.Sidecar NamespaceCache *cache.Namespace Resource *Resource }
func NewNamespaceReconciler ¶
func NewNamespaceReconciler(opts ...NamespaceReconcilerOpts) *NamespaceReconciler
func (*NamespaceReconciler) SetupWithManager ¶
func (r *NamespaceReconciler) SetupWithManager(mgr ctrl.Manager) error
type NamespaceReconcilerOpts ¶
type NamespaceReconcilerOpts func(*NamespaceReconciler)
type Resource ¶
func NewResource ¶
func (*Resource) AddDestinationServiceToSidecar ¶
func (r *Resource) AddDestinationServiceToSidecar(entry *HTTPAccessLogEntryWrapper) error
func (*Resource) AddExternalServiceToEnvoyFilter ¶
func (r *Resource) AddExternalServiceToEnvoyFilter(entry *HTTPAccessLogEntryWrapper) error
func (*Resource) AddServiceToEnvoyFilter ¶
func (*Resource) BindPortToFence ¶
func (*Resource) CreateSidecar ¶
func (*Resource) RefreshByHTTPAccessLogEntryWrapper ¶
func (r *Resource) RefreshByHTTPAccessLogEntryWrapper(ctx context.Context, obj *HTTPAccessLogEntryWrapper) error
Click to show internal directories.
Click to hide internal directories.