controller

Documentation

Index

• type DestinationService
• type EndpointsReconciler
  • func NewEndpointsReconciler(opts ...EndpointsReconcilerOpts) *EndpointsReconciler
  • func (r *EndpointsReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)
  • func (r *EndpointsReconciler) SetupWithManager(mgr ctrl.Manager) error
• type EndpointsReconcilerOpts
• type HTTPAccessLogEntryWrapper
• type LogEntry
  • func NewLogEntry(client client.Client, scheme *runtime.Scheme, sidecar *iistio.Sidecar, ...) *LogEntry
  • func (l *LogEntry) StreamLogEntry(logEntrys []*data_accesslog.HTTPAccessLogEntry)
• type NamespaceReconciler
  • func NewNamespaceReconciler(opts ...NamespaceReconcilerOpts) *NamespaceReconciler
  • func (r *NamespaceReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)
  • func (r *NamespaceReconciler) SetupWithManager(mgr ctrl.Manager) error
• type NamespaceReconcilerOpts
• type Resource
  • func NewResource(client client.Client, sidecar *iistio.Sidecar, namespaceCache *cache.Namespace, ...) *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
  • func New(server config.Server) *Runner
  • func (r *Runner) Name() string
  • func (r *Runner) Start(ctx context.Context) error
• type VarNamespace

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) Reconcile

func (r *EndpointsReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)

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

type LogEntry struct {
	config.Server
	client.Client
	// contains filtered or unexported fields
}

func NewLogEntry

func NewLogEntry(client client.Client, scheme *runtime.Scheme, sidecar *iistio.Sidecar, namespaceCache *cache.Namespace, ipServiceCache *cache.IpService, resource *Resource, server config.Server) *LogEntry

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) Reconcile

func (r *NamespaceReconciler) Reconcile(ctx context.Context, request ctrl.Request) (ctrl.Result, error)

func (*NamespaceReconciler) SetupWithManager

func (r *NamespaceReconciler) SetupWithManager(mgr ctrl.Manager) error

type NamespaceReconcilerOpts

type NamespaceReconcilerOpts func(*NamespaceReconciler)

type Resource

type Resource struct {
	config.Server
	client.Client
	// contains filtered or unexported fields
}

func NewResource

func NewResource(client client.Client, sidecar *iistio.Sidecar, namespaceCache *cache.Namespace, server config.Server, scheme *runtime.Scheme) *Resource

func (*Resource) AddDestinationServiceToSidecar

func (r *Resource) AddDestinationServiceToSidecar(entry *HTTPAccessLogEntryWrapper) error

func (*Resource) AddExternalServiceToEnvoyFilter

func (r *Resource) AddExternalServiceToEnvoyFilter(entry *HTTPAccessLogEntryWrapper) error

func (*Resource) AddServiceToEnvoyFilter

func (r *Resource) AddServiceToEnvoyFilter(ctx context.Context, svc *corev1.Service) error

func (*Resource) BindPortToFence

func (r *Resource) BindPortToFence(ctx context.Context, sps []corev1.ServicePort) error

func (*Resource) CreateSidecar

func (r *Resource) CreateSidecar(ctx context.Context, svc *corev1.Service) error

func (*Resource) RefreshByHTTPAccessLogEntryWrapper

func (r *Resource) RefreshByHTTPAccessLogEntryWrapper(ctx context.Context, obj *HTTPAccessLogEntryWrapper) error

func (*Resource) RefreshByService

func (r *Resource) RefreshByService(ctx context.Context, obj *corev1.Service) error

type Runner

type Runner struct {
	config.Server
}

func New

func New(server config.Server) *Runner

func (*Runner) Name

func (r *Runner) Name() string

func (*Runner) Start

func (r *Runner) Start(ctx context.Context) error

type VarNamespace

type VarNamespace interface {
	*corev1.Namespace | *cache.Namespace
}