logging

Documentation

Index

• Variables
• func CreateLoggingHandler(path string) http.Handler
• func GenLoggingSessionId() (string, error)
• func WaitForLoggingStream(k8sClient kubernetes.Interface, namespace string, pod string, container string, ...)
• type LogMessage
• type LogSession
• type SessionMap
  • func (sm *SessionMap) Close(sessionId, reason string, status uint32)
  • func (sm *SessionMap) Get(sessionId string) LogSession
  • func (sm *SessionMap) Set(sessionId string, session LogSession)

Variables

var LogSessions = SessionMap{Sessions: make(map[string]LogSession)}

Functions

func CreateLoggingHandler

func CreateLoggingHandler(path string) http.Handler

func GenLoggingSessionId

func GenLoggingSessionId() (string, error)

func WaitForLoggingStream

func WaitForLoggingStream(k8sClient kubernetes.Interface, namespace string, pod string, container string, tailLines int, follow bool, sessionId string)

Types

type LogMessage

type LogMessage struct {
	SessionID string
	Data      string
}

type LogSession

type LogSession struct {
	Id    string
	Bound chan error
	// contains filtered or unexported fields
}

type SessionMap

type SessionMap struct {
	Sessions map[string]LogSession
	Lock     sync.Mutex
}

func (*SessionMap) Close

func (sm *SessionMap) Close(sessionId, reason string, status uint32)

func (*SessionMap) Get

func (sm *SessionMap) Get(sessionId string) LogSession

func (*SessionMap) Set

func (sm *SessionMap) Set(sessionId string, session LogSession)