common

Documentation

Index

• func GetStringKeys(arr map[string]interface{}) []string
• func LoadTemplate(name, tmpl string) (*template.Template, error)
• func LoadYaml(config string, obj interface{}) (bool, error)
• func RemoveEmptyStrings(items []string) []string
• type HttpProcessor
• type Observability
  • func NewObservability(logs *sre.Logs, metrics *sre.Metrics) *Observability
  • func (o *Observability) Debug(obj interface{}, args ...interface{})
  • func (o *Observability) Error(obj interface{}, args ...interface{})
  • func (o *Observability) Info(obj interface{}, args ...interface{})
  • func (o *Observability) Logs() *sre.Logs
  • func (o *Observability) Metrics() *sre.Metrics
  • func (o *Observability) Warn(obj interface{}, args ...interface{})
• type Processor
• type Processors
  • func NewProcessors() *Processors
  • func (ps *Processors) Add(p Processor)
  • func (ps *Processors) Find(typ string) Processor
  • func (ps *Processors) FindHttpProcessor(typ string) HttpProcessor
• type Server
• type Servers
  • func NewServers() Servers
  • func (ss *Servers) Add(s Server)
  • func (ss *Servers) Start(wg *sync.WaitGroup)

Functions

func GetStringKeys

func GetStringKeys(arr map[string]interface{}) []string

func LoadTemplate

func LoadTemplate(name, tmpl string) (*template.Template, error)

func LoadYaml

func LoadYaml(config string, obj interface{}) (bool, error)

func RemoveEmptyStrings

func RemoveEmptyStrings(items []string) []string

Types

type HttpProcessor

type HttpProcessor interface {
	Processor
	HandleHttpRequest(w http.ResponseWriter, r *http.Request) error
}

type Observability

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

func NewObservability

func NewObservability(logs *sre.Logs, metrics *sre.Metrics) *Observability

func (*Observability) Debug

func (o *Observability) Debug(obj interface{}, args ...interface{})

func (*Observability) Error

func (o *Observability) Error(obj interface{}, args ...interface{})

func (*Observability) Info

func (o *Observability) Info(obj interface{}, args ...interface{})

func (*Observability) Logs

func (o *Observability) Logs() *sre.Logs

func (*Observability) Metrics

func (o *Observability) Metrics() *sre.Metrics

func (*Observability) Warn

func (o *Observability) Warn(obj interface{}, args ...interface{})

type Processor

type Processor interface {
	Type() string
}

type Processors

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

func NewProcessors

func NewProcessors() *Processors

func (*Processors) Add

func (ps *Processors) Add(p Processor)

func (*Processors) Find

func (ps *Processors) Find(typ string) Processor

func (*Processors) FindHttpProcessor

func (ps *Processors) FindHttpProcessor(typ string) HttpProcessor

type Server

type Server interface {
	Start(wg *sync.WaitGroup)
}

type Servers

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

func NewServers

func NewServers() Servers

func (*Servers) Add

func (ss *Servers) Add(s Server)

func (*Servers) Start

func (ss *Servers) Start(wg *sync.WaitGroup)