sse

Documentation

Index

• func HeadersMiddleware() gin.HandlerFunc
• type ProxyChan
  • func NewProxyChan(ctx context.Context, input <-chan watch.Event, interval time.Duration) ProxyChan
  • func (p ProxyChan) Events() chan any
• type Server
  • func NewServer(k8sClient k8sclient.IKubernetesClient) *Server
  • func (s *Server) ReleaseResources(ctx *gin.Context)
  • func (s *Server) Resources(ctx *gin.Context)
  • func (s *Server) SingleResource(ctx *gin.Context)

Functions

func HeadersMiddleware

func HeadersMiddleware() gin.HandlerFunc

Types

type ProxyChan

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

func NewProxyChan

func NewProxyChan(ctx context.Context, input <-chan watch.Event, interval time.Duration) ProxyChan

func (ProxyChan) Events

func (p ProxyChan) Events() chan any

type Server

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

func NewServer

func NewServer(k8sClient k8sclient.IKubernetesClient) *Server

Initialize event and Start procnteessing requests

func (*Server) ReleaseResources

func (s *Server) ReleaseResources(ctx *gin.Context)

func (*Server) Resources

func (s *Server) Resources(ctx *gin.Context)

func (*Server) SingleResource

func (s *Server) SingleResource(ctx *gin.Context)