| FazBrowse GitHub Viewer | Trending | | Home |
| Tools: [Download Repo ZIP] [Original HTTPS Page] |
This package is not in the latest version of its module.
Go to latest Published: Mar 23, 2022 License: MITThe Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Modules with tagged versions give importers more predictable builds.
When a project reaches major version v1 it is considered stable.
Package core is a service container that elegantly bootstrap and coordinate twelve-factor apps in Go.
Checkout the README.md for an overview of this package.
Example (Minimal) ¶
package main
import (
"context"
"fmt"
"io/ioutil"
"net/http"
"time"
"github.com/DoNewsCode/core"
"github.com/gorilla/mux"
)
func main() {
// Spin up a real server
c := core.Default(core.WithInline("log.level", "none"))
c.AddModule(core.HttpFunc(func(router *mux.Router) {
router.HandleFunc("/", func(writer http.ResponseWriter, request *http.Request) {
writer.Write([]byte("hello world"))
})
}))
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
go c.Serve(ctx)
// Giver server sometime to be ready.
time.Sleep(time.Second)
// Let's try if the server works.
resp, err := http.Get("http://localhost:8080/")
if err != nil {
return
}
defer resp.Body.Close()
bytes, _ := ioutil.ReadAll(resp.Body)
cancel()
fmt.Println(string(bytes))
}
Output: hello world
const ( // OnHTTPServerStart is an event triggered when the http server is ready to serve // traffic. At this point the module is already wired up. This event is useful to // register service to service discovery. OnHTTPServerStart event = "onHTTPServerStart" // OnHTTPServerShutdown is an event triggered when the http server is shutting down. // traffic. At this point The traffic can no longer reach the server, but the // database and other infrastructures are not closed yet. This event is useful // to unregister service to service discovery. OnHTTPServerShutdown event = "onHTTPServerShutdown" // OnGRPCServerStart is an event triggered when the grpc server is ready to serve // traffic. At this point the module is already wired up. This event is useful to // register service to service discovery. OnGRPCServerStart event = "onGRPCServerStart" // OnGRPCServerShutdown is an event triggered when the http server is shutting down. // traffic. At this point The traffic can no longer reach the server, but the // database and other infrastructures are not closed yet. This event is useful // to unregister service to service discovery. OnGRPCServerShutdown event = "onGRPCServerShutdown" )
This section is empty.
func NewServeModule(in serveIn) serveModule
func ProvideAppName(conf contract.ConfigUnmarshaler) contract.AppName
ProvideAppName is the default AppNameProvider for package Core.
func ProvideConfig(configStack []config.ProviderSet, configWatcher contract.ConfigWatcher) contract.ConfigUnmarshaler
ProvideConfig is the default ConfigProvider for package Core.
func ProvideDi(conf contract.ConfigUnmarshaler) *dig.Container
ProvideDi is the default DiProvider for package Core.
func ProvideEnv(conf contract.ConfigUnmarshaler) contract.Env
ProvideEnv is the default EnvProvider for package Core.
func ProvideEventDispatcher(conf contract.ConfigUnmarshaler) contract.Dispatcher
ProvideEventDispatcher is the default EventDispatcherProvider for package Core.
func ProvideLogger(conf contract.ConfigUnmarshaler, appName contract.AppName, env contract.Env) log.Logger
ProvideLogger is the default LoggerProvider for package Core.
func WithYamlFile(path string) (CoreOption, CoreOption)
WithYamlFile is a two-in-one coreOption. It uses the configuration file as the source of configuration, and watches the change of that file for hot reloading.
type AppNameProvider func(conf contract.ConfigUnmarshaler) contract.AppName
AppNameProvider provides the contract.AppName to the core.
type C struct {
AppName contract.AppName
Env contract.Env
contract.ConfigAccessor
logging.LevelLogger
*container.Container
contract.Dispatcher
// contains filtered or unexported fields
}
C stands for the core of the application. It contains service definitions and dependencies. C means to be used in the boostrap phase of the application. Do not pass C into services and use it as a service locator.
Example (Stack) ¶
package main
import (
"context"
"flag"
"net/http"
"strings"
"github.com/DoNewsCode/core"
"github.com/gorilla/mux"
"github.com/knadh/koanf/parsers/json"
"github.com/knadh/koanf/providers/basicflag"
"github.com/knadh/koanf/providers/env"
"github.com/knadh/koanf/providers/file"
)
func main() {
fs := flag.NewFlagSet("example", flag.ContinueOnError)
fs.String("log.level", "error", "the log level")
// Spin up a real server
c := core.New(
core.WithConfigStack(basicflag.Provider(fs, "."), nil),
core.WithConfigStack(env.Provider("APP_", ".", func(s string) string {
return strings.ToLower(strings.Replace(s, "APP_", "", 1))
}), nil),
core.WithConfigStack(file.Provider("./config/testdata/mock.json"), json.Parser()),
)
c.AddModule(core.HttpFunc(func(router *mux.Router) {
router.HandleFunc("/", func(writer http.ResponseWriter, request *http.Request) {
writer.Write([]byte("hello world"))
})
}))
c.Serve(context.Background())
}
Output:
func Default(opts ...CoreOption) *C
Default creates a core.C under its default state. Core dependencies are already provided, and the config module and serve module are bundled.
func (c *C) AddModule(module interface{})
AddModule adds a module to the core.
A Module is a group of functionality. It must provide some runnable stuff: http handlers, grpc handlers, cron jobs, one-time command, etc.
Optionally if the module embeds di.In, its fields will be injected by DI container. The semantics of injection follows the same rule of dig.Invoke. Note that the module added in this way will not retain any original field values, i.e. the module will only contain fields populated by DI container.
Example (Inject) ¶
package main
import (
"os"
"github.com/DoNewsCode/core"
"github.com/DoNewsCode/core/di"
"github.com/go-kit/log"
)
func main() {
type Foo struct {
di.In
Logger log.Logger
}
var f Foo
c := core.New()
c.Provide(di.Deps{func() log.Logger {
return log.NewLogfmtLogger(os.Stdout)
}})
// If the module embeds di.In (directly or indirectly via pointer), then DI will
// populate its fields.
c.AddModule(&f)
f.Logger.Log("msg", "hello")
}
Output: msg=hello
package main
import (
"fmt"
"github.com/DoNewsCode/core"
)
func main() {
type Foo struct{}
c := core.New()
c.AddModule(Foo{})
fmt.Printf("%T\n", c.Modules()...)
}
Output: core_test.Foo
func (c *C) AddModuleFunc(constructor interface{})
AddModuleFunc add the module after Invoking its constructor. Clean up functions and errors are handled automatically.
Example ¶
package main
import (
"fmt"
"github.com/DoNewsCode/core"
)
func main() {
type Foo struct{}
c := core.New()
c.AddModuleFunc(func() (Foo, func(), error) {
return Foo{}, func() {}, nil
})
fmt.Printf("%T %T\n", c.Modules()...)
}
Output: core.cleanup core_test.Foo
ApplyRootCommand iterates through every CommandProvider registered in the container, and introduce the root *cobra.Command to everyone.
func (c *C) Invoke(function interface{})
Invoke runs the given function after instantiating its dependencies. Any arguments that the function has are treated as its dependencies. The dependencies are instantiated in an unspecified order along with any dependencies that they might have. The function may return an error to indicate failure. The error will be returned to the caller as-is.
It internally calls uber's dig library. Consult dig's documentation for details. (https://pkg.go.dev/go.uber.org/dig)
Provide adds dependencies provider to the core. Note the dependency provider must be a function in the form of:
func(foo Foo) Bar
where foo is the upstream dependency and Bar is the provided type. The order for providers doesn't matter. They are only executed lazily when the Invoke is called.
This method internally calls uber's dig library. Consult dig's documentation for details. (https://pkg.go.dev/go.uber.org/dig)
The difference is, core.Provide has been made to accommodate the convention from google/wire (https://github.com/google/wire). All "func()" returned by constructor are treated as clean up functions. It also examines if the dependency implements the modular interface. If so, this dependency will be added the module collection.
Example ¶
package main
import (
"fmt"
"github.com/DoNewsCode/core"
"github.com/DoNewsCode/core/di"
)
func main() {
type Foo struct {
Value string
}
type Bar struct {
foo Foo
}
c := core.New()
c.Provide(di.Deps{
func() (foo Foo, cleanup func(), err error) {
return Foo{
Value: "test",
}, func() {}, nil
},
func(foo Foo) Bar {
return Bar{foo: foo}
},
})
c.Invoke(func(bar Bar) {
fmt.Println(bar.foo.Value)
})
}
Output: test
func (c *C) ProvideEssentials()
ProvideEssentials adds the default core dependencies to the core.
type CloserProvider interface {
ProvideCloser()
}
CloserProvider provides a shutdown function that will be called when service exits.
CommandProvider provides cobra.Command.
type ConfParser interface {
Unmarshal([]byte) (map[string]interface{}, error)
Marshal(map[string]interface{}) ([]byte, error)
}
ConfParser models a parser for configuration. For example, yaml.Parser.
ConfProvider models a configuration provider. For example, file.Provider.
type ConfigProvider func(configStack []config.ProviderSet, configWatcher contract.ConfigWatcher) contract.ConfigUnmarshaler
ConfigProvider provides contract.ConfigAccessor to the core.
type CoreOption func(*coreValues)
CoreOption is the option to modify core attribute.
func SetAppNameProvider(provider AppNameProvider) CoreOption
SetAppNameProvider is a CoreOption to replaces the default AppNameProvider.
func SetConfigProvider(provider ConfigProvider) CoreOption
SetConfigProvider is a CoreOption to replaces the default ConfigProvider.
func SetDiProvider(provider DiProvider) CoreOption
SetDiProvider is a CoreOption to replaces the default DiContainer.
func SetEnvProvider(provider EnvProvider) CoreOption
SetEnvProvider is a CoreOption to replaces the default EnvProvider.
func SetEventDispatcherProvider(provider EventDispatcherProvider) CoreOption
SetEventDispatcherProvider is a CoreOption to replaces the default EventDispatcherProvider.
func SetLoggerProvider(provider LoggerProvider) CoreOption
SetLoggerProvider is a CoreOption to replaces the default LoggerProvider.
func WithConfigStack(provider ConfProvider, parser ConfParser) CoreOption
WithConfigStack is a CoreOption that defines a configuration layer. See package config for details.
func WithConfigWatcher(watcher contract.ConfigWatcher) CoreOption
WithConfigWatcher is a CoreOption that adds a config watcher to the core (for hot reloading configs).
func WithInline(key string, entry interface{}) CoreOption
WithInline is a CoreOption that creates a inline config in the configuration stack.
CronProvider provides cron jobs.
DeprecatedCronProvider provides cron jobs. Deprecated: CronProvider is deprecated. Use CronProvider instead
type DiProvider func(conf contract.ConfigUnmarshaler) *dig.Container
DiProvider provides the *dig.Container to the core.
type EnvProvider func(conf contract.ConfigUnmarshaler) contract.Env
EnvProvider provides the contract.Env to the core.
type EventDispatcherProvider func(conf contract.ConfigUnmarshaler) contract.Dispatcher
EventDispatcherProvider provides contract.Dispatcher to the core.
GRPCProvider provides gRPC services.
HTTPProvider provides http services.
HttpFunc converts a function to a module provides http.
ProvideHTTP implements container.HTTPProvider
type LoggerProvider func(conf contract.ConfigUnmarshaler, appName contract.AppName, env contract.Env) log.Logger
LoggerProvider provides the log.Logger to the core.
OnGRPCServerShutdownPayload is the payload of OnGRPCServerShutdown
OnGRPCServerStartPayload is the payload of OnGRPCServerStart
OnHTTPServerShutdownPayload is the payload of OnHTTPServerShutdown
OnHTTPServerStartPayload is the payload of OnHTTPServerStart
RunProvider provides a runnable actor. Use it to register any server-like actions. For example, kafka consumer can be started here.
| Path | Synopsis |
|---|---|
|
Package clihttp adds opentracing support to http client.
|
Package clihttp adds opentracing support to http client. |
|
codec
|
|
|
json
Package json provides the json codec.
|
Package json provides the json codec. |
|
yaml
Package yaml provides the yaml codec.
|
Package yaml provides the yaml codec. |
|
Package config provides supports to a fully customizable layered configuration stack.
|
Package config provides supports to a fully customizable layered configuration stack. |
|
remote/etcd
Package etcd allows the core package to bootstrap its configuration from an etcd server.
|
Package etcd allows the core package to bootstrap its configuration from an etcd server. |
|
Package container includes the Container type, witch contains a collection of modules.
|
Package container includes the Container type, witch contains a collection of modules. |
|
Package contract defines a set of common interfaces for all packages in this repository.
|
Package contract defines a set of common interfaces for all packages in this repository. |
|
Package cron is a partial rewrite based on the github.com/robfig/cron/v3 package.
|
Package cron is a partial rewrite based on the github.com/robfig/cron/v3 package. |
|
Package ctxmeta provides a helper type for request-scoped metadata.
|
Package ctxmeta provides a helper type for request-scoped metadata. |
|
Package dag offers a simple, pure in-memory job scheduler based on Directed Acyclic graph.
|
Package dag offers a simple, pure in-memory job scheduler based on Directed Acyclic graph. |
|
Package cronopts contains the options for cron.
|
Package cronopts contains the options for cron. |
|
Package di is a thin wrapper around dig.
|
Package di is a thin wrapper around dig. |
|
Package events provides a simple and effective implementation of event system.
|
Package events provides a simple and effective implementation of event system. |
|
internal
|
|
|
Package key provides a way to distribute labels to component.
|
Package key provides a way to distribute labels to component. |
|
Package leader provides a simple leader election implementation.
|
Package leader provides a simple leader election implementation. |
|
leaderetcd
Package leaderetcd provides a etcd driver for package leader
|
Package leaderetcd provides a etcd driver for package leader |
|
leaderredis
Package leaderredis provides a redis driver for package leader
|
Package leaderredis provides a redis driver for package leader |
|
Package logging provides a kitlog compatible logger.
|
Package logging provides a kitlog compatible logger. |
|
Package observability provides a tracer and a set of perdefined metrics to measure critical system stats.
|
Package observability provides a tracer and a set of perdefined metrics to measure critical system stats. |
|
Package otes provides es client with opentracing.
|
Package otes provides es client with opentracing. |
|
Package otetcd provides etcd client with opentracing.
|
Package otetcd provides etcd client with opentracing. |
|
Package otgorm provides gorm with opentracing.
|
Package otgorm provides gorm with opentracing. |
|
mocks
Package mock_metrics is a generated GoMock package.
|
Package mock_metrics is a generated GoMock package. |
|
Package otkafka contains the opentracing integrated a kafka transport for package Core.
|
Package otkafka contains the opentracing integrated a kafka transport for package Core. |
|
mocks
Package mock_metrics is a generated GoMock package.
|
Package mock_metrics is a generated GoMock package. |
|
Package otmongo provides mongo client with opentracing.
|
Package otmongo provides mongo client with opentracing. |
|
Package otredis provides redis client with opentracing.
|
Package otredis provides redis client with opentracing. |
|
mocks
Package mock_metrics is a generated GoMock package.
|
Package mock_metrics is a generated GoMock package. |
|
Package ots3 provides a s3 uploader with opentracing capabilities.
|
Package ots3 provides a s3 uploader with opentracing capabilities. |
|
Package srvhttp groups helpers for server side http use cases.
|
Package srvhttp groups helpers for server side http use cases. |
|
Package text provides utilities to generate textual output.
|
Package text provides utilities to generate textual output. |
|
Package unierr presents an unification error model between gRPC transport and HTTP transport, and between server and client.
|
Package unierr presents an unification error model between gRPC transport and HTTP transport, and between server and client. |
| Back | FazBrowse Home | New Git URL |