![](/style/images/good.png)
![](/style/images/bad.png)
GitHub - micro/go-plugins: Community maintained plugins
source link: https://github.com/micro/go-plugins
Go to the source link to view the article. You can view the picture content, updated content and better typesetting reading experience. If the link is broken, please click the button below to view the snapshot at that time.
README.md
Plugins
![Go Report Card](https://camo.githubusercontent.com/719d4df05a146a09ac077674d7bf4d0f9a1bf309/68747470733a2f2f676f7265706f7274636172642e636f6d2f62616467652f6d6963726f2f676f2d706c7567696e73)
Go plugins is a place for community maintained plugins.
Overview
Micro tooling is built on a powerful pluggable architecture. Plugins can be swapped out with zero code changes. This repository contains plugins for all micro related tools. Read on for further info.
Check out the Micro on NATS blog post to learn more about plugins.
Follow us on Twitter or join the Slack community.
Getting Started
Contents
Contents of this repository:
Directory Description Broker PubSub messaging; NATS, NSQ, RabbitMQ, Kafka Client RPC Clients; gRPC, HTTP Codec Message Encoding; BSON, Mercury Micro Micro Toolkit Plugins Registry Service Discovery; Etcd, Gossip, NATS Selector Load balancing; Label, Cache, Static Server RPC Servers; gRPC, HTTP Transport Bidirectional Streaming; NATS, RabbitMQ Wrapper Middleware; Circuit Breakers, Rate Limiting, Tracing, MonitoringUsage
Plugins can be added to go-micro in the following ways. By doing so they'll be available to set via command line args or environment variables.
Import the plugins in a Go program then call service.Init to parse the command line and environment variables.
import ( "github.com/micro/go-micro" _ "github.com/micro/go-plugins/broker/rabbitmq" _ "github.com/micro/go-plugins/registry/kubernetes" _ "github.com/micro/go-plugins/transport/nats" ) func main() { service := micro.NewService( // Set service name micro.Name("my.service"), ) // Parse CLI flags service.Init() }
Flags
Specify the plugins as flags
go run service.go --broker=rabbitmq --registry=kubernetes --transport=nats
Env
Use env vars to specify the plugins
MICRO_BROKER=rabbitmq \
MICRO_REGISTRY=kubernetes \
MICRO_TRANSPORT=nats \
go run service.go
Options
Import and set as options when creating a new service
import ( "github.com/micro/go-micro" "github.com/micro/go-plugins/registry/kubernetes" ) func main() { registry := kubernetes.NewRegistry() //a default to using env vars for master API service := micro.NewService( // Set service name micro.Name("my.service"), // Set service registry micro.Registry(registry), ) }
Build
An anti-pattern is modifying the main.go
file to include plugins. Best practice recommendation is to include
plugins in a separate file and rebuild with it included. This allows for automation of building plugins and
clean separation of concerns.
Create file plugins.go
package main import ( _ "github.com/micro/go-plugins/broker/rabbitmq" _ "github.com/micro/go-plugins/registry/kubernetes" _ "github.com/micro/go-plugins/transport/nats" )
Build with plugins.go
go build -o service main.go plugins.go
Run with plugins
MICRO_BROKER=rabbitmq \ MICRO_REGISTRY=kubernetes \ MICRO_TRANSPORT=nats \ service
Contributions
A few contributions by others
Feature Description Author Registry/Kubernetes Service discovery via the Kubernetes API @nickjackson Registry/Zookeeper Service discovery using Zookeeper @HeavyHorstRecommend
About Joyk
Aggregate valuable and interesting links.
Joyk means Joy of geeK