reportserver

Documentation

Index

• func Init(ctx context.Context, webSocket *melody.Melody, workspace *workspace.Workspace, ...)
• func StartAPI(ctx context.Context, webSocket *melody.Melody)
• type AvailableReportsPayload
• type ClientRequest
• type ClientRequestPayload
• type ClientRequestReportPayload
• type ErrorPayload
• type ExecutionPayload
• type ReportClientInfo
• type Server
  • func NewServer(ctx context.Context) (*Server, error)
  • func (s *Server) HandleWorkspaceUpdate(event reportevents.ReportEvent)
  • func (s *Server) Shutdown()
  • func (s *Server) Start()

Functions

func Init

func Init(ctx context.Context, webSocket *melody.Melody, workspace *workspace.Workspace, dbClient db_common.Client, socketSessions map[*melody.Session]*ReportClientInfo, mutex *sync.Mutex)

func StartAPI

func StartAPI(ctx context.Context, webSocket *melody.Melody)

Types

type AvailableReportsPayload

type AvailableReportsPayload struct {
	Action  string            `json:"action"`
	Reports map[string]string `json:"reports"`
}

type ClientRequest

type ClientRequest struct {
	Action  string               `json:"action"`
	Payload ClientRequestPayload `json:"payload"`
}

type ClientRequestPayload

type ClientRequestPayload struct {
	Report ClientRequestReportPayload `json:"report"`
}

type ClientRequestReportPayload

type ClientRequestReportPayload struct {
	FullName string `json:"full_name"`
}

type ErrorPayload

type ErrorPayload struct {
	Action string `json:"action"`
	Error  string `json:"error"`
}

type ExecutionPayload

type ExecutionPayload struct {
	Action     string                         `json:"action"`
	ReportNode reportinterfaces.ReportNodeRun `json:"report_node"`
}

type ReportClientInfo

type ReportClientInfo struct {
	Report *string
}

type Server

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

func NewServer

func NewServer(ctx context.Context) (*Server, error)

func (*Server) HandleWorkspaceUpdate

func (s *Server) HandleWorkspaceUpdate(event reportevents.ReportEvent)

func (*Server) Shutdown

func (s *Server) Shutdown()

func (*Server) Start

func (s *Server) Start()

Starts the API server