reporter

Documentation

Index

• type Reporter
  • func NewReporter(token string, rabbit *mq.Rabbit, client *client.Client, ...) (*Reporter, error)
  • func (r *Reporter) GetPodLogs(ctx context.Context, clientSet *kubernetes.Clientset, pod *corev1.Pod, ...) error
  • func (r *Reporter) Report(ctx context.Context, room *hubv1.Room) (bool, error)
  • func (r *Reporter) ReportTimeout(room *hubv1.Room, threshold uint64) error

Types

type Reporter

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

func NewReporter

func NewReporter(token string, rabbit *mq.Rabbit, client *client.Client, k8sClientSet *kubernetes.Clientset) (*Reporter, error)

func (*Reporter) GetPodLogs

func (r *Reporter) GetPodLogs(ctx context.Context, clientSet *kubernetes.Clientset, pod *corev1.Pod, options *corev1.PodLogOptions, reader *io.ReadCloser) error

func (*Reporter) Report

func (r *Reporter) Report(ctx context.Context, room *hubv1.Room) (bool, error)

func (*Reporter) ReportTimeout

func (r *Reporter) ReportTimeout(room *hubv1.Room, threshold uint64) error