Documentation ¶
Overview ¶
Copyright 2018 The Knative Authors
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright 2018 The Knative Authors ¶
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright 2018 The Knative Authors ¶
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright 2018 The Knative Authors ¶
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Index ¶
Constants ¶
const ( // TODO: allow these to be configurable ConfigMapName = "fluent-bit" DaemonSetName = "fluent-bit" )
Variables ¶
This section is empty.
Functions ¶
func SetClusterNameFilter ¶
func SetClusterNameFilter( cmp ConfigMapPatcher, dsp DaemonSetPodDeleter, clusterName string, )
Types ¶
type ClusterController ¶
type ClusterController struct {
// contains filtered or unexported fields
}
func NewClusterController ¶
func NewClusterController(cmp ConfigMapPatcher, dsp DaemonSetPodDeleter, sc *Config) *ClusterController
func (*ClusterController) OnAdd ¶
func (c *ClusterController) OnAdd(o interface{})
func (*ClusterController) OnDelete ¶
func (c *ClusterController) OnDelete(o interface{})
func (*ClusterController) OnUpdate ¶
func (c *ClusterController) OnUpdate(old, new interface{})
type Config ¶
type Config struct {
// contains filtered or unexported fields
}
func (*Config) DeleteClusterSink ¶
func (sc *Config) DeleteClusterSink(s *v1alpha1.ClusterLogSink)
func (*Config) DeleteSink ¶
func (*Config) UpsertClusterSink ¶
func (sc *Config) UpsertClusterSink(cs *v1alpha1.ClusterLogSink)
func (*Config) UpsertSink ¶
type ConfigMapPatcher ¶
type Controller ¶
type Controller struct {
// contains filtered or unexported fields
}
func NewController ¶
func NewController(cmp ConfigMapPatcher, dsp DaemonSetPodDeleter, sc *Config) *Controller
func (*Controller) OnAdd ¶
func (c *Controller) OnAdd(o interface{})
func (*Controller) OnDelete ¶
func (c *Controller) OnDelete(o interface{})
func (*Controller) OnUpdate ¶
func (c *Controller) OnUpdate(old, new interface{})
type DaemonSetPodDeleter ¶
type DaemonSetPodDeleter interface { DeleteCollection( options *metav1.DeleteOptions, listOptions metav1.ListOptions, ) error }