-
Notifications
You must be signed in to change notification settings - Fork 230
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Add fluentd examples #194
Add fluentd examples #194
Conversation
Signed-off-by: zhu733756 <zhu733756@kubesphere.io>
Signed-off-by: zhu733756 <zhu733756@kubesphere.io>
@@ -163,7 +169,24 @@ func (b *Buffer) Params(_ plugins.SecretLoader) (*params.PluginStore, error) { | |||
} | |||
|
|||
if b.Path != nil { | |||
ps.InsertPairs("path", *b.Path) | |||
if strings.HasPrefix(*b.Path, "/buffers") { |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Buffer PVC mounts with /buffers.
f533a64
to
fdd6de8
Compare
controllers/fluentd_controller.go
Outdated
@@ -197,7 +197,7 @@ func (r *FluentdReconciler) SetupWithManager(mgr ctrl.Manager) error { | |||
return ctrl.NewControllerManagedBy(mgr). | |||
For(&fluentdv1alpha1.Fluentd{}). | |||
Owns(&corev1.ServiceAccount{}). | |||
Owns(&appsv1.Deployment{}). | |||
Owns(&appsv1.StatefulSet{}). | |||
Owns(&corev1.Service{}). | |||
Owns(&corev1.PersistentVolumeClaim{}). |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
no need to owns PersistentVolumeClaim
now?
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Done
Signed-off-by: zhu733756 <zhu733756@kubesphere.io>
fdd6de8
to
535716d
Compare
@@ -34,6 +34,8 @@ type FluentdSpec struct { | |||
DisableService bool `json:"disableService,omitempty"` | |||
// Numbers of the Fluentd instance | |||
Replicas *int32 `json:"replicas,omitempty"` | |||
// Numbers of the workers in Fluentd instance | |||
Workers *int32 `json:"workers,omitempty"` |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
Support multi workers in a single pod.
Signed-off-by: zhu733756 zhu733756@kubesphere.io
Points:
This pr needs to be merged before #192