follower

package

v0.7.0 Latest Latest Go to latest Published: Dec 14, 2021 License: Apache-2.0 Imports: 18 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type Follower struct {
	// contains filtered or unexported fields
}

Follower encapsulate the function of tailing the logs for Pods derived from BuildRuns

func NewFollower(
	ctx context.Context,
	buildRunName string,
	ioStreams *genericclioptions.IOStreams,
	params *params.Params,
) (*Follower, error)

NewFollower returns a Follower instance

func (f *Follower) GetLogLock() *sync.Mutex

GetLogLock returns the mutex used for coordinating access to log buffers.

func (f *Follower) Log(msg string)

Log prints a message

func (f *Follower) OnEvent(pod *corev1.Pod) error

OnEvent reacts on pod state changes, to start and stop tailing container logs.

func (f *Follower) OnNoPodEventsYet()

OnNoPodEventsYet reacts to the pod watcher telling us it has not received any pod events for our build run

func (f *Follower) OnTimeout(msg string)

OnTimeout reacts to either the context or request timeout causing the pod watcher to exit

func (f *Follower) Start(lo metav1.ListOptions) (*corev1.Pod, error)

Start initiates the log following for the referenced BuildRun's Pod