api

Documentation

Index

• Constants
• type Api
  • func NewApi(cache *cache.Cache, db *db.DB, collector *collector.Collector, ...) *Api
  • func (api *Api) Application(w http.ResponseWriter, r *http.Request, u *db.User)
  • func (api *Api) Auth(h func(http.ResponseWriter, *http.Request, *db.User)) http.HandlerFunc
  • func (api *Api) AuthInit(anonymousRole string, adminPassword string) error
  • func (api *Api) Categories(w http.ResponseWriter, r *http.Request, u *db.User)
  • func (api *Api) CustomApplications(w http.ResponseWriter, r *http.Request, u *db.User)
  • func (api *Api) GetUser(r *http.Request) *db.User
  • func (api *Api) Incident(w http.ResponseWriter, r *http.Request, u *db.User)
  • func (api *Api) Inspection(w http.ResponseWriter, r *http.Request, u *db.User)
  • func (api *Api) Inspections(w http.ResponseWriter, r *http.Request, u *db.User)
  • func (api *Api) Instrumentation(w http.ResponseWriter, r *http.Request, u *db.User)
  • func (api *Api) Integration(w http.ResponseWriter, r *http.Request, u *db.User)
  • func (api *Api) Integrations(w http.ResponseWriter, r *http.Request, u *db.User)
  • func (api *Api) IsAllowed(u *db.User, action rbac.Action) bool
  • func (api *Api) LoadWorld(ctx context.Context, project *db.Project, from, to timeseries.Time) (*model.World, *cache.Status, error)
  • func (api *Api) LoadWorldByRequest(r *http.Request) (*model.World, *db.Project, *cache.Status, error)
  • func (api *Api) Login(w http.ResponseWriter, r *http.Request)
  • func (api *Api) Logout(w http.ResponseWriter, r *http.Request)
  • func (api *Api) Logs(w http.ResponseWriter, r *http.Request, u *db.User)
  • func (api *Api) Node(w http.ResponseWriter, r *http.Request, u *db.User)
  • func (api *Api) Overview(w http.ResponseWriter, r *http.Request, u *db.User)
  • func (api *Api) Profiling(w http.ResponseWriter, r *http.Request, u *db.User)
  • func (api *Api) Project(w http.ResponseWriter, r *http.Request, u *db.User)
  • func (api *Api) Prom(w http.ResponseWriter, r *http.Request, u *db.User)
  • func (api *Api) RCA(w http.ResponseWriter, r *http.Request, u *db.User)
  • func (api *Api) Roles(w http.ResponseWriter, r *http.Request, u *db.User)
  • func (api *Api) SSO(w http.ResponseWriter, r *http.Request, u *db.User)
  • func (api *Api) SetSessionCookie(w http.ResponseWriter, userId int, ttl time.Duration) error
  • func (api *Api) Status(w http.ResponseWriter, r *http.Request, u *db.User)
  • func (api *Api) Tracing(w http.ResponseWriter, r *http.Request, u *db.User)
  • func (api *Api) User(w http.ResponseWriter, r *http.Request, u *db.User)
  • func (api *Api) Users(w http.ResponseWriter, r *http.Request, u *db.User)
  • func (api *Api) WithContext(p *db.Project, cacheStatus *cache.Status, w *model.World, data any) DataWithContext
• type Application
• type Context
• type DataWithContext
• type KubeStateMetrics
• type Node
• type NodeAgent
• type Prometheus
• type Search
• type Session
• type Status

Constants

const (
	AuthSecretSettingName = "auth_secret"
	HashFunc              = crypto.SHA256
	SessionCookieName     = "coroot_session"
	SessionCookieTTL      = 7 * 24 * time.Hour
)

Types

type Api

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

func NewApi

func NewApi(cache *cache.Cache, db *db.DB, collector *collector.Collector, pricing *pricing.Manager, roles rbac.RoleManager,
	globalClickHouse *db.IntegrationClickhouse, globalPrometheus *db.IntegrationsPrometheus) *Api

func (*Api) Application

func (api *Api) Application(w http.ResponseWriter, r *http.Request, u *db.User)

func (*Api) Auth

func (api *Api) Auth(h func(http.ResponseWriter, *http.Request, *db.User)) http.HandlerFunc

func (*Api) AuthInit

func (api *Api) AuthInit(anonymousRole string, adminPassword string) error

func (*Api) Categories

func (api *Api) Categories(w http.ResponseWriter, r *http.Request, u *db.User)

func (*Api) CustomApplications

func (api *Api) CustomApplications(w http.ResponseWriter, r *http.Request, u *db.User)

func (*Api) GetUser

func (api *Api) GetUser(r *http.Request) *db.User

func (*Api) Incident

func (api *Api) Incident(w http.ResponseWriter, r *http.Request, u *db.User)

func (*Api) Inspection

func (api *Api) Inspection(w http.ResponseWriter, r *http.Request, u *db.User)

func (*Api) Inspections

func (api *Api) Inspections(w http.ResponseWriter, r *http.Request, u *db.User)

func (*Api) Instrumentation

func (api *Api) Instrumentation(w http.ResponseWriter, r *http.Request, u *db.User)

func (*Api) Integration

func (api *Api) Integration(w http.ResponseWriter, r *http.Request, u *db.User)

func (*Api) Integrations

func (api *Api) Integrations(w http.ResponseWriter, r *http.Request, u *db.User)

func (*Api) IsAllowed

func (api *Api) IsAllowed(u *db.User, action rbac.Action) bool

func (*Api) LoadWorld

func (api *Api) LoadWorld(ctx context.Context, project *db.Project, from, to timeseries.Time) (*model.World, *cache.Status, error)

func (*Api) LoadWorldByRequest

func (api *Api) LoadWorldByRequest(r *http.Request) (*model.World, *db.Project, *cache.Status, error)

func (*Api) Login

func (api *Api) Login(w http.ResponseWriter, r *http.Request)

func (*Api) Logout

func (api *Api) Logout(w http.ResponseWriter, r *http.Request)

func (*Api) Logs

func (api *Api) Logs(w http.ResponseWriter, r *http.Request, u *db.User)

func (*Api) Node

func (api *Api) Node(w http.ResponseWriter, r *http.Request, u *db.User)

func (*Api) Overview

func (api *Api) Overview(w http.ResponseWriter, r *http.Request, u *db.User)

func (*Api) Profiling

func (api *Api) Profiling(w http.ResponseWriter, r *http.Request, u *db.User)

func (*Api) Project

func (api *Api) Project(w http.ResponseWriter, r *http.Request, u *db.User)

func (*Api) Prom

func (api *Api) Prom(w http.ResponseWriter, r *http.Request, u *db.User)

func (*Api) RCA

func (api *Api) RCA(w http.ResponseWriter, r *http.Request, u *db.User)

func (*Api) Roles

func (api *Api) Roles(w http.ResponseWriter, r *http.Request, u *db.User)

func (*Api) SSO

func (api *Api) SSO(w http.ResponseWriter, r *http.Request, u *db.User)

func (*Api) SetSessionCookie

func (api *Api) SetSessionCookie(w http.ResponseWriter, userId int, ttl time.Duration) error

func (*Api) Status

func (api *Api) Status(w http.ResponseWriter, r *http.Request, u *db.User)

func (*Api) Tracing

func (api *Api) Tracing(w http.ResponseWriter, r *http.Request, u *db.User)

func (*Api) User

func (api *Api) User(w http.ResponseWriter, r *http.Request, u *db.User)

func (*Api) Users

func (api *Api) Users(w http.ResponseWriter, r *http.Request, u *db.User)

func (*Api) WithContext

func (api *Api) WithContext(p *db.Project, cacheStatus *cache.Status, w *model.World, data any) DataWithContext

type Application

type Application struct {
	Id     model.ApplicationId `json:"id"`
	Status model.Status        `json:"status"`
}

type Context

type Context struct {
	Status Status `json:"status"`
	Search Search `json:"search"`
}

type DataWithContext

type DataWithContext struct {
	Context Context `json:"context"`
	Data    any     `json:"data"`
}

type KubeStateMetrics

type KubeStateMetrics struct {
	Status       model.Status `json:"status"`
	Applications int          `json:"applications"`
}

type Node

type Node struct {
	Name   string       `json:"name"`
	Status model.Status `json:"status"`
}

type NodeAgent

type NodeAgent struct {
	Status model.Status `json:"status"`
	Nodes  int          `json:"nodes"`
}

type Prometheus

type Prometheus struct {
	Status  model.Status `json:"status"`
	Message string       `json:"message"`
	Error   string       `json:"error"`
	Action  string       `json:"action"`
}

type Search

type Search struct {
	Applications []Application `json:"applications"`
	Nodes        []Node        `json:"nodes"`
}

type Session

type Session struct {
	Id int `json:"id"`
}

type Status

type Status struct {
	Status           model.Status      `json:"status"`
	Error            string            `json:"error"`
	Prometheus       Prometheus        `json:"prometheus"`
	NodeAgent        NodeAgent         `json:"node_agent"`
	KubeStateMetrics *KubeStateMetrics `json:"kube_state_metrics"`
}