db

Documentation

Index

• type AlertClient
  • func (ac *AlertClient) Save(ctx context.Context, msg *msg.AlertMsg) error
  • func (ac *AlertClient) Szenarios(ctx context.Context) ([]string, error)
• type Client
  • func New() (*Client, error)
  • func (c *Client) ThinOutIncidents(ctx context.Context) error
• type IncidentClient
  • func (ic *IncidentClient) Save(ctx context.Context, msg *msg.IncidentMsg) error
  • func (ic *IncidentClient) Szenarios(ctx context.Context) ([]string, error)
• type IncidentSummary
  • func (is IncidentSummary) Level() status.Level
• type IncidentSummaryQuery
  • func (isq *IncidentSummaryQuery) All(ctx context.Context) ([]*IncidentSummary, error)
  • func (isq IncidentSummaryQuery) CloseIncident(ctx context.Context, is *IncidentSummary, username string, ...) error
  • func (isq *IncidentSummaryQuery) First(ctx context.Context) (*IncidentSummary, error)
  • func (isq *IncidentSummaryQuery) Query() *IncidentSummaryQuery
  • func (isq *IncidentSummaryQuery) Where(s ...predicate.Incident) *IncidentSummaryQuery
• type MinMaxTime
  • func (mmt MinMaxTime) After(t MinMaxTime) bool
  • func (mmt MinMaxTime) Before(t MinMaxTime) bool
  • func (mmt MinMaxTime) IsZero() bool
  • func (mmt *MinMaxTime) Scan(value interface{}) error
  • func (mmt MinMaxTime) Since(t MinMaxTime) time.Duration
  • func (mmt MinMaxTime) String() string
  • func (mmt MinMaxTime) Time() time.Time
  • func (mmt MinMaxTime) Value() (driver.Value, error)

Types

type AlertClient

type AlertClient struct {
	*ent.AlertClient
	// contains filtered or unexported fields
}

AlertClient is a wrapper enhaning the ent client

func (*AlertClient) Save

func (ac *AlertClient) Save(ctx context.Context, msg *msg.AlertMsg) error

Save an alert msg to ent

func (*AlertClient) Szenarios

func (ac *AlertClient) Szenarios(ctx context.Context) ([]string, error)

Szenarios returns a list of szenario names

type Client

type Client struct {
	*ent.Client

	// IncidentSummary is the query for incident summaries
	IncidentSummary *IncidentSummaryQuery

	// Incident wraps and enhances the ent IncidentClient
	Incident *IncidentClient
	// Alert wraps and enhances the ent AlertClient
	Alert *AlertClient
	// contains filtered or unexported fields
}

Client gives access to the DB and wraps ent

func New

func New() (*Client, error)

New creates an ent access

func (*Client) ThinOutIncidents

func (c *Client) ThinOutIncidents(ctx context.Context) error

ThinOutIncidents removes multiple incident entries

type IncidentClient

type IncidentClient struct {
	*ent.IncidentClient
	// contains filtered or unexported fields
}

IncidentClient is a wrapper enhaning the ent client

func (*IncidentClient) Save

func (ic *IncidentClient) Save(ctx context.Context, msg *msg.IncidentMsg) error

Save save an incident msg to ent

func (*IncidentClient) Szenarios

func (ic *IncidentClient) Szenarios(ctx context.Context) ([]string, error)

Szenarios returns a list of szenario names

type IncidentSummary

type IncidentSummary struct {
	IncidentID uuid.UUID  `json:"incident_id"`
	Name       string     `json:"name"`
	Total      int        `json:"total"`
	IntLevel   int        `json:"level"`
	Start      MinMaxTime `json:"start"`
	End        MinMaxTime `json:"end"`
	LastUpdate MinMaxTime `json:"time"`
	Error      string     `json:"error"`
}

IncidentSummary is the summary of different incidents entries

func (IncidentSummary) Level

func (is IncidentSummary) Level() status.Level

Level convinience method that calls status Level

type IncidentSummaryQuery

type IncidentSummaryQuery struct {
	*ent.IncidentQuery
	// contains filtered or unexported fields
}

IncidentSummaryQuery allows quering incidents

func (*IncidentSummaryQuery) All

func (isq *IncidentSummaryQuery) All(ctx context.Context) ([]*IncidentSummary, error)

All returns all incudent summaries

func (IncidentSummaryQuery) CloseIncident

func (isq IncidentSummaryQuery) CloseIncident(ctx context.Context, is *IncidentSummary, username string, statusLevel status.Level, failure string) error

func (*IncidentSummaryQuery) First

func (isq *IncidentSummaryQuery) First(ctx context.Context) (*IncidentSummary, error)

First wrap ent first

func (*IncidentSummaryQuery) Query

func (isq *IncidentSummaryQuery) Query() *IncidentSummaryQuery

Query returns a list of incidents

func (*IncidentSummaryQuery) Where

func (isq *IncidentSummaryQuery) Where(s ...predicate.Incident) *IncidentSummaryQuery

Where wrap ent where

type MinMaxTime

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

MinMaxTime is a wrapper around time to support SQL max and min

func (MinMaxTime) After

func (mmt MinMaxTime) After(t MinMaxTime) bool

After is wraps time.Time.After

func (MinMaxTime) Before

func (mmt MinMaxTime) Before(t MinMaxTime) bool

Before is wraps time.Time.Before

func (MinMaxTime) IsZero

func (mmt MinMaxTime) IsZero() bool

IsZero is wraps time.Time.IsZero

func (*MinMaxTime) Scan

func (mmt *MinMaxTime) Scan(value interface{}) error

Scan scan value the time, implements sql.Scanner interface

func (MinMaxTime) Since

func (mmt MinMaxTime) Since(t MinMaxTime) time.Duration

Since returns the underlying time

func (MinMaxTime) String

func (mmt MinMaxTime) String() string

String formats the time

func (MinMaxTime) Time

func (mmt MinMaxTime) Time() time.Time

Time returns the underlying time

func (MinMaxTime) Value

func (mmt MinMaxTime) Value() (driver.Value, error)

Value return the time, implement driver.Valuer interface