bot

Documentation

Index

• type Bot
  • func NewBot(log *logrus.Logger, projectID string, logName string, timezone string, ...) (*Bot, error)
  • func (b *Bot) Run(input string)
• type BotService
  • func NewBotService(cfg *config.Config, logger *logrus.Logger) (*BotService, error)
  • func (s *BotService) JSONEndpoints() map[string]map[string]server.JSONEndpoint
  • func (s *BotService) JSONMiddleware(j server.JSONEndpoint) server.JSONEndpoint
  • func (s *BotService) Middleware(h http.Handler) http.Handler
  • func (s *BotService) Prefix() string
• type GCPLogAdmin
  • func (g *GCPLogAdmin) GetLogAdminFilter(payload IncidentPayload) string
  • func (g *GCPLogAdmin) GetLogEntries(payload IncidentPayload) ([]IncidentLogEntry, error)
• type Incident
  • func (i *Incident) EndedAtTime() string
  • func (i *Incident) StartedAtTime() string
• type IncidentLogEntry
• type IncidentLogEntrySource
• type IncidentPayload
  • func (i *IncidentPayload) Populate(input string) error

Types

type Bot

type Bot struct {
	SlackWebhookURL string
	LogEntrySource  IncidentLogEntrySource
	Log             *logrus.Logger
}

func NewBot

func NewBot(log *logrus.Logger, projectID string, logName string, timezone string, webhookURL string) (*Bot, error)

func (*Bot) Run

func (b *Bot) Run(input string)

type BotService

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

func NewBotService

func NewBotService(cfg *config.Config, logger *logrus.Logger) (*BotService, error)

func (*BotService) JSONEndpoints

func (s *BotService) JSONEndpoints() map[string]map[string]server.JSONEndpoint

func (*BotService) JSONMiddleware

func (s *BotService) JSONMiddleware(j server.JSONEndpoint) server.JSONEndpoint

func (*BotService) Middleware

func (s *BotService) Middleware(h http.Handler) http.Handler

func (*BotService) Prefix

func (s *BotService) Prefix() string

type GCPLogAdmin

type GCPLogAdmin struct {
	ProjectID string
	LogName   string
	Timezone  string
}

func (*GCPLogAdmin) GetLogAdminFilter

func (g *GCPLogAdmin) GetLogAdminFilter(payload IncidentPayload) string

func (*GCPLogAdmin) GetLogEntries

func (g *GCPLogAdmin) GetLogEntries(payload IncidentPayload) ([]IncidentLogEntry, error)

type Incident

type Incident struct {
	IncidentID    string `json:"incident_id"`
	ResourceID    string `json:"resource_id"`
	ResourceName  string `json:"resource_name"`
	State         string `json:"state"`
	StartedAt     int64  `json:"started_at"`
	EndedAt       *int64 `json:"ended_at"`
	PolicyName    string `json:"policy_name"`
	ConditionName string `json:"condition_name"`
	URL           string `json:"url"`
	Summary       string `json:"summary"`
}

func (*Incident) EndedAtTime

func (i *Incident) EndedAtTime() string

func (*Incident) StartedAtTime

func (i *Incident) StartedAtTime() string

type IncidentLogEntry

type IncidentLogEntry struct {
	EventTime    time.Time
	Environment  string
	ResourceID   string
	ResourceName string
	Description  string
	Error        string
	Caller       string
	Service      string
}

type IncidentLogEntrySource

type IncidentLogEntrySource interface {
	GetLogAdminFilter(payload IncidentPayload) string
	GetLogEntries(payload IncidentPayload) ([]IncidentLogEntry, error)
}

type IncidentPayload

type IncidentPayload struct {
	Incident Incident
	Version  string
}

func (*IncidentPayload) Populate

func (i *IncidentPayload) Populate(input string) error