fluentd

Documentation

Index

• func CreateAssets(client kubernetes.Interface, namespace string) error
• func DeleteAssets(client kubernetes.Interface, namespace string) error
• func GetNodeAddressWithMaster(client kubernetes.Interface, namespace string) (string, error)

Functions

func CreateAssets

func CreateAssets(client kubernetes.Interface, namespace string) error

CreateAssets creates fluentd master deployment and fluentd worker daemonset. all fluentd workers stream their local logs to the fluentd master. fluentd master writes all the logs to the disk at `/var/log/log-collector/` fluentd master is pinned to a master node with annotation `log-collector.github.com/fluentd-master`.

CreateAssets waits for fluentd master pod and at least one fluentd worker pod to be running.

func DeleteAssets

func DeleteAssets(client kubernetes.Interface, namespace string) error

DeleteAssets deletes all the fluentd assets. Also removes all node annotations.

func GetNodeAddressWithMaster

func GetNodeAddressWithMaster(client kubernetes.Interface, namespace string) (string, error)

GetNodeAddressWithMaster returns PublicAddressableIP of the master node that is running fluent master.