serviceweather

Documentation

Index

• Constants
• type API
  • func NewApi(store Store, errorResponder httperror.Responder) API
• type AggregationResult
  • func (r *AggregationResult) GetData() any
  • func (r *AggregationResult) GetTotal() int64
• type Counters
• type EntitiesListRequest
• type Entity
• type EntityAggregationResult
  • func (r *EntityAggregationResult) GetData() any
  • func (r *EntityAggregationResult) GetTotal() int64
• type Info
• type ListRequest
• type MongoQueryBuilder
  • func NewMongoQueryBuilder(client mongo.DbClient, authorProvider author.Provider) *MongoQueryBuilder
  • func (q *MongoQueryBuilder) CreateListAggregationPipeline(ctx context.Context, r ListRequest) ([]bson.M, error)
  • func (q *MongoQueryBuilder) CreateListDependenciesAggregationPipeline(id string, r EntitiesListRequest, now datetime.CpsTime) ([]bson.M, error)
• type PbhTypeCounter
• type Service
• type Store
  • func NewStore(dbClient mongo.DbClient, linkGenerator link.Generator, ...) Store

Constants

const (
	StateIconOk       = "wb_sunny"
	StateIconMinor    = "person"
	StateIconMajor    = "person"
	StateIconCritical = "wb_cloudy"
)

Types

type API

type API interface {
	List(c *gin.Context)
	EntityList(c *gin.Context)
}

func NewApi

func NewApi(store Store, errorResponder httperror.Responder) API

type AggregationResult

type AggregationResult struct {
	Data       []Service `bson:"data" json:"data"`
	TotalCount int64     `bson:"total_count" json:"total_count"`
}

func (*AggregationResult) GetData

func (r *AggregationResult) GetData() any

func (*AggregationResult) GetTotal

func (r *AggregationResult) GetTotal() int64

type Counters

type Counters struct {
	All    int64 `bson:"all" json:"all"`
	Alarms int64 `bson:"active" json:"active"`
	State  struct {
		Critical int64 `bson:"critical" json:"critical"`
		Major    int64 `bson:"major" json:"major"`
		Minor    int64 `bson:"minor" json:"minor"`
		Ok       int64 `bson:"ok" json:"ok"`
	} `bson:"state" json:"state"`
	Acknowledged         int64            `bson:"acked" json:"acked"`
	NotAcknowledged      int64            `bson:"unacked" json:"unacked"`
	AcknowledgedUnderPbh int64            `bson:"acked_under_pbh" json:"acked_under_pbh"`
	UnderPbehavior       int64            `bson:"under_pbh" json:"under_pbh"`
	Depends              int64            `bson:"depends" json:"depends"`
	PbhTypeCounters      []PbhTypeCounter `bson:"pbh_types" json:"pbh_types"`
}

type EntitiesListRequest

type EntitiesListRequest struct {
	pagination.Query
	WithInstructions   bool   `form:"with_instructions"`
	WithDeclareTickets bool   `form:"with_declare_tickets"`
	WithTagColors      bool   `form:"with_tag_colors"`
	Sort               string `form:"sort"`
	SortBy             string `form:"sort_by" json:"sort_by" binding:"oneoforempty=name state infos.* impact_state"`
	PbhOrigin          string `form:"pbh_origin" json:"pbh_origin"`
}

type Entity

type Entity struct {
	ID      string `json:"_id" bson:"_id"`
	AlarmID string `json:"alarm_id" bson:"alarm_id"`

	AssignedInstructions         *[]alarm.AssignedInstruction `bson:"-" json:"assigned_instructions,omitempty"`
	InstructionExecutionIcon     int                          `bson:"-" json:"instruction_execution_icon,omitempty"`
	RunningManualInstructions    []string                     `bson:"-" json:"running_manual_instructions,omitempty"`
	RunningAutoInstructions      []string                     `bson:"-" json:"running_auto_instructions,omitempty"`
	FailedManualInstructions     []string                     `bson:"-" json:"failed_manual_instructions,omitempty"`
	FailedAutoInstructions       []string                     `bson:"-" json:"failed_auto_instructions,omitempty"`
	SuccessfulManualInstructions []string                     `bson:"-" json:"successful_manual_instructions,omitempty"`
	SuccessfulAutoInstructions   []string                     `bson:"-" json:"successful_auto_instructions,omitempty"`

	Name             string                     `json:"name" bson:"name"`
	Infos            map[string]Info            `json:"infos" bson:"infos"`
	Type             string                     `json:"source_type" bson:"type"`
	Category         *entity.Category           `json:"category" bson:"category"`
	Connector        string                     `json:"connector" bson:"connector"`
	ConnectorName    string                     `json:"connector_name" bson:"connector_name"`
	Component        string                     `json:"component" bson:"component"`
	Resource         string                     `json:"resource" bson:"resource"`
	LastComment      *entitycomment.Comment     `json:"last_comment" bson:"last_comment"`
	State            common.AlarmStep           `json:"state" bson:"state"`
	Status           common.AlarmStep           `json:"status" bson:"status"`
	Snooze           *common.AlarmStep          `json:"snooze" bson:"snooze"`
	Ack              *common.AlarmStep          `json:"ack" bson:"ack"`
	Ticket           *common.AlarmStep          `json:"ticket" bson:"ticket"`
	Tickets          []common.AlarmStep         `json:"tickets" bson:"tickets"`
	AlarmLastComment *common.AlarmStep          `json:"alarm_last_comment" bson:"alarm_last_comment"`
	Tags             []string                   `json:"tags" bson:"tags"`
	TagColors        []alarm.TagColor           `json:"tag_colors" bson:"tag_colors"`
	LastUpdateDate   *datetime.CpsTime          `json:"last_update_date" bson:"last_update_date" swaggertype:"integer"`
	CreationDate     *datetime.CpsTime          `json:"alarm_creation_date" bson:"creation_date" swaggertype:"integer"`
	DisplayName      string                     `json:"alarm_display_name" bson:"display_name"`
	Icon             string                     `json:"icon" bson:"icon"`
	Pbehaviors       []alarm.Pbehavior          `json:"pbehaviors" bson:"pbehaviors"`
	PbehaviorInfo    *entity.PbehaviorInfo      `json:"pbehavior_info" bson:"pbehavior_info"`
	PbhOriginIcon    string                     `json:"pbh_origin_icon" bson:"pbh_origin_icon,omitempty"`
	IsGrey           bool                       `json:"is_grey" bson:"is_grey"`
	ImpactLevel      int                        `json:"impact_level" bson:"impact_level"`
	ImpactState      int                        `json:"impact_state" bson:"impact_state"`
	IdleSince        *datetime.CpsTime          `json:"idle_since,omitempty" bson:"idle_since,omitempty" swaggertype:"integer"`
	Stats            statistics.EventStatistics `json:"stats" bson:"stats"`

	Links link.LinksByCategory `json:"links" bson:"-"`

	DependsCount int `bson:"depends_count" json:"depends_count"`

	ImportSource string            `bson:"import_source,omitempty" json:"import_source,omitempty"`
	Imported     *datetime.CpsTime `bson:"imported,omitempty" json:"imported,omitempty" swaggertype:"integer"`

	AssignedDeclareTicketRules []alarm.AssignedDeclareTicketRule `bson:"-" json:"assigned_declare_ticket_rules,omitempty"`
}

type EntityAggregationResult

type EntityAggregationResult struct {
	Data       []Entity `bson:"data" json:"data"`
	TotalCount int64    `bson:"total_count" json:"total_count"`
}

func (*EntityAggregationResult) GetData

func (r *EntityAggregationResult) GetData() any

func (*EntityAggregationResult) GetTotal

func (r *EntityAggregationResult) GetTotal() int64

type Info

type Info struct {
	Description string `bson:"description,omitempty" json:"description"`
	Value       any    `bson:"value" json:"value"`
}

type ListRequest

type ListRequest struct {
	pagination.Query
	Filters       []string `form:"filters[]" json:"filters"`
	Category      string   `form:"category" json:"category"`
	HideGrey      bool     `form:"hide_grey" json:"hide_grey"`
	WithTagColors bool     `form:"with_tag_colors"`
	Sort          string   `form:"sort" json:"sort" binding:"oneoforempty=asc desc"`
	SortBy        string   `form:"sort_by" json:"sort_by" binding:"oneoforempty=name state infos.* impact_state"`

	EntityPattern         string `form:"entity_pattern" json:"entity_pattern"`
	WeatherServicePattern string `form:"weather_service_pattern" json:"weather_service_pattern"`
}

type MongoQueryBuilder

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

func NewMongoQueryBuilder

func NewMongoQueryBuilder(client mongo.DbClient, authorProvider author.Provider) *MongoQueryBuilder

func (*MongoQueryBuilder) CreateListAggregationPipeline

func (q *MongoQueryBuilder) CreateListAggregationPipeline(ctx context.Context, r ListRequest) ([]bson.M, error)

func (*MongoQueryBuilder) CreateListDependenciesAggregationPipeline

func (q *MongoQueryBuilder) CreateListDependenciesAggregationPipeline(id string, r EntitiesListRequest, now datetime.CpsTime) ([]bson.M, error)

type PbhTypeCounter

type PbhTypeCounter struct {
	Count int64                  `json:"count" bson:"count"`
	Type  pbehaviortype.Response `json:"type" bson:"type"`
}

type Service

type Service struct {
	ID               string                 `json:"_id" bson:"_id"`
	Name             string                 `json:"name" bson:"name"`
	Infos            map[string]Info        `json:"infos" bson:"infos"`
	Connector        string                 `json:"connector" bson:"connector"`
	ConnectorName    string                 `json:"connector_name" bson:"connector_name"`
	Component        string                 `json:"component" bson:"component"`
	Resource         string                 `json:"resource" bson:"resource"`
	LastComment      *entitycomment.Comment `json:"last_comment" bson:"last_comment"`
	HasOpenAlarm     bool                   `json:"is_action_required" bson:"has_open_alarm"`
	State            common.AlarmStep       `json:"state" bson:"state"`
	Status           common.AlarmStep       `json:"status" bson:"status"`
	Snooze           *common.AlarmStep      `json:"snooze" bson:"snooze"`
	Ack              *common.AlarmStep      `json:"ack" bson:"ack"`
	AlarmLastComment *common.AlarmStep      `json:"alarm_last_comment" bson:"alarm_last_comment"`
	Tags             []string               `json:"tags" bson:"tags"`
	TagColors        []alarm.TagColor       `json:"tag_colors" bson:"tag_colors"`
	Icon             string                 `json:"icon" bson:"icon"`
	SecondaryIcon    string                 `json:"secondary_icon" bson:"secondary_icon"`
	Output           string                 `json:"output" bson:"output"`
	LastUpdateDate   *datetime.CpsTime      `json:"last_update_date" bson:"last_update_date" swaggertype:"integer"`
	Counters         Counters               `json:"counters" bson:"counters"`
	PbehaviorInfo    *entity.PbehaviorInfo  `json:"pbehavior_info" bson:"pbehavior_info"`
	Pbehaviors       []alarm.Pbehavior      `json:"pbehaviors" bson:"pbehaviors"`
	ImpactLevel      int                    `json:"impact_level" bson:"impact_level"`
	ImpactState      int                    `json:"impact_state" bson:"impact_state"`
	Category         *entity.Category       `json:"category" bson:"category"`
	IsGrey           bool                   `json:"is_grey" bson:"is_grey"`
	IdleSince        *datetime.CpsTime      `json:"idle_since,omitempty" bson:"idle_since,omitempty" swaggertype:"integer"`
}

type Store

type Store interface {
	Find(context.Context, ListRequest) (*AggregationResult, error)
	FindEntities(ctx context.Context, id string, query EntitiesListRequest, userID string) (*EntityAggregationResult, error)
}

func NewStore

func NewStore(
	dbClient mongo.DbClient,
	linkGenerator link.Generator,
	alarmStore alarmapi.Store,
	timezoneConfigProvider config.TimezoneConfigProvider,
	authorProvider author.Provider,
	logger zerolog.Logger,
) Store