keel

package module
v0.8.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 8, 2022 License: MIT Imports: 29 Imported by: 30

README

keel

Go Report Card godoc GitHub Super-Linter

Opinionated way to run services.

Stack

  • Zap
  • Viper
  • Open Telemetry
  • Nats
  • GoTSRPC

Examples

See the examples folder for usages

package main

import (
  "net/http"

  "github.com/foomo/keel"
)

func main() {
  svr := keel.NewServer(
    keel.WithHTTPZapService(true),
    keel.WithHTTPViperService(true),
    keel.WithHTTPPrometheusService(true),
  )

  l := svr.Logger()

  svs := newService()

  svr.AddService(
    keel.NewServiceHTTP(l, "demo", ":8080", svs),
  )

  svr.Run()
}

func newService() *http.ServeMux {
  s := http.NewServeMux()
  s.HandleFunc("/", func(w http.ResponseWriter, r *http.Request) {
    w.WriteHeader(http.StatusOK)
    _, _ = w.Write([]byte("OK"))
  })
  return s
}

How to Contribute

Make a pull request...

License

Distributed under MIT License, please see license file within the code for more details.

Documentation

Index

Constants

View Source 
const (
	DefaultServiceHTTPPrometheusName = "prometheus"
	DefaultServiceHTTPPrometheusAddr = ":9200"
	DefaultServiceHTTPPrometheusPath = "/metrics"
)
View Source 
const (
	DefaultServiceHTTPViperName = "viper"
	DefaultServiceHTTPViperAddr = "localhost:9300"
	DefaultServiceHTTPViperPath = "/config"
)
View Source 
const (
	DefaultServiceHTTPZapName = "zap"
	DefaultServiceHTTPZapAddr = "localhost:9100"
	DefaultServiceHTTPZapPath = "/log"
)

Variables

View Source 
var (
	// Version usage -ldflags "-X github.com/foomo/keel/server.Version=$VERSION"
	Version string
	// GitCommit usage -ldflags "-X github.com/foomo/keel/server.GitCommit=$GIT_COMMIT"
	GitCommit string
	// BuildTime usage -ldflags "-X 'github.com/foomo/keel/server.BuildTime=$(date -u '+%Y-%m-%d %H:%M:%S')'"
	BuildTime string
)

Functions

This section is empty.

Types

type Closer 

type Closer interface {
	Close()
}

Closer interface

type CloserFn added in v0.8.0 

type CloserFn func()

CloserFn interface

type CloserWithContext 

type CloserWithContext interface {
	Close(ctx context.Context)
}

CloserWithContext interface

type CloserWithContextFn added in v0.8.0 

type CloserWithContextFn func(ctx context.Context)

CloserWithContextFn interface

type ErrorCloser added in v0.2.10 

type ErrorCloser interface {
	Close() error
}

ErrorCloser interface

type ErrorCloserFn added in v0.8.0 

type ErrorCloserFn func() error

ErrorCloserFn interface

type ErrorCloserWithContext added in v0.2.10 

type ErrorCloserWithContext interface {
	Close(ctx context.Context) error
}

ErrorCloserWithContext interface

type ErrorCloserWithContextFn added in v0.8.0 

type ErrorCloserWithContextFn func(ctx context.Context) error

ErrorCloserWithContextFn interface

type ErrorShutdowner added in v0.2.10 

type ErrorShutdowner interface {
	Shutdown() error
}

ErrorShutdowner interface

type ErrorShutdownerWithContext added in v0.2.10 

type ErrorShutdownerWithContext interface {
	Shutdown(ctx context.Context) error
}

ErrorShutdownerWithContext interface

type ErrorUnsubscriber added in v0.2.10 

type ErrorUnsubscriber interface {
	Unsubscribe() error
}

ErrorUnsubscriber interface

type ErrorUnsubscriberWithContext added in v0.2.10 

type ErrorUnsubscriberWithContext interface {
	Unsubscribe(ctx context.Context) error
}

ErrorUnsubscriberWithContext interface

type Option 

type Option func(inst *Server)

Option func

func WithConfig 

func WithConfig(c *viper.Viper) Option

WithConfig option

func WithContext 

func WithContext(ctx context.Context) Option

WithContext option

func WithHTTPPrometheusService added in v0.2.0 

func WithHTTPPrometheusService(enabled bool) Option

WithHTTPPrometheusService option with default value

func WithHTTPViperService added in v0.2.0 

func WithHTTPViperService(enabled bool) Option

WithHTTPViperService option with default value

func WithHTTPZapService added in v0.2.0 

func WithHTTPZapService(enabled bool) Option

WithHTTPZapService option with default value

func WithLogFields 

func WithLogFields(fields ...zap.Field) Option

WithLogFields option

func WithLogger 

func WithLogger(l *zap.Logger) Option

WithLogger option

func WithOTLPGRPCTracer added in v0.8.0 

func WithOTLPGRPCTracer(enabled bool) Option

WithOTLPGRPCTracer option with default value

func WithOTLPHTTPTracer added in v0.8.0 

func WithOTLPHTTPTracer(enabled bool) Option

WithOTLPHTTPTracer option with default value

func WithPrometheusMeter added in v0.8.0 

func WithPrometheusMeter(enabled bool) Option

WithPrometheusMeter option with default value

func WithShutdownSignals added in v0.6.4 

func WithShutdownSignals(shutdownSignals ...os.Signal) Option

WithShutdownSignals option

func WithShutdownTimeout 

func WithShutdownTimeout(shutdownTimeout time.Duration) Option

WithShutdownTimeout option

func WithStdOutMeter added in v0.8.0 

func WithStdOutMeter(enabled bool) Option

WithStdOutMeter option with default value

func WithStdOutTracer added in v0.8.0 

func WithStdOutTracer(enabled bool) Option

WithStdOutTracer option with default value

type Server 

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

Server struct

func NewServer 

func NewServer(opts ...Option) *Server

func (*Server) AddCloser 

func (s *Server) AddCloser(closer interface{})

AddCloser adds a closer to be called on shutdown

func (*Server) AddClosers 

func (s *Server) AddClosers(closers ...interface{})

AddClosers adds a closer to be called on shutdown

func (*Server) AddService 

func (s *Server) AddService(service Service)

AddService add a single service

func (*Server) AddServices 

func (s *Server) AddServices(services ...Service)

AddServices adds multiple service

func (*Server) Config 

func (s *Server) Config() *viper.Viper

Config returns server config

func (*Server) Context 

func (s *Server) Context() context.Context

Context returns server context

func (*Server) Logger 

func (s *Server) Logger() *zap.Logger

Logger returns server logger

func (*Server) Meter added in v0.8.0 

func (s *Server) Meter() metric.MeterMust

Meter returns the implementation meter

func (*Server) Run 

func (s *Server) Run()

Run runs the server

func (*Server) Tracer added in v0.8.0 

func (s *Server) Tracer() trace.Tracer

Tracer returns the implementation tracer

type Service 

type Service interface {
	Name() string
	Start(ctx context.Context) error
	Close(ctx context.Context) error
}

Service interface

type ServiceHTTP 

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

ServiceHTTP struct

func NewDefaultServiceHTTPPrometheus 

func NewDefaultServiceHTTPPrometheus() *ServiceHTTP

func NewDefaultServiceHTTPViper 

func NewDefaultServiceHTTPViper() *ServiceHTTP

func NewDefaultServiceHTTPZap 

func NewDefaultServiceHTTPZap() *ServiceHTTP

func NewServiceHTTP 

func NewServiceHTTP(l *zap.Logger, name, addr string, handler http.Handler, middlewares ...middleware.Middleware) *ServiceHTTP

func NewServiceHTTPPrometheus 

func NewServiceHTTPPrometheus(l *zap.Logger, name, addr, path string) *ServiceHTTP

func NewServiceHTTPViper 

func NewServiceHTTPViper(l *zap.Logger, c *viper.Viper, name, addr, path string) *ServiceHTTP

func NewServiceHTTPZap 

func NewServiceHTTPZap(l *zap.Logger, name, addr, path string) *ServiceHTTP

func (*ServiceHTTP) Close 

func (s *ServiceHTTP) Close(ctx context.Context) error

func (*ServiceHTTP) Name added in v0.3.3 

func (s *ServiceHTTP) Name() string

func (*ServiceHTTP) Start 

func (s *ServiceHTTP) Start(ctx context.Context) error

type Shutdowner 

type Shutdowner interface {
	Shutdown()
}

Shutdowner interface

type ShutdownerWithContext 

type ShutdownerWithContext interface {
	Shutdown(ctx context.Context)
}

ShutdownerWithContext interface

type Unsubscriber added in v0.2.0 

type Unsubscriber interface {
	Unsubscribe()
}

Unsubscriber interface

type UnsubscriberWithContext added in v0.2.0 

type UnsubscriberWithContext interface {
	Unsubscribe(ctx context.Context)
}

UnsubscriberWithContext interface

Source Files

View all Source files

Directories

Path Synopsis
example module
jetbench Module
integration
temporal
net
gotsrpc
http
http/cookie
http/middleware
http/roundtripware
stream
stream/jetstream
mongo
postgres
utils
net/http

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.