micro-go-plugins

module
v1.1.5 Latest Latest
Warning

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

Go to latest
Published: Oct 8, 2019 License: Apache-2.0

README

Plugins License GoDoc Travis CI Go Report Card

A repository for micro 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, Monitoring

Usage

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 @HeavyHorst

Directories

Path Synopsis
broker
gocloud
Package gocloud provides a pubsub broker for Go Cloud.
Package gocloud provides a pubsub broker for Go Cloud.
grpc/proto
Package broker is a generated protocol buffer package.
Package broker is a generated protocol buffer package.
client
http/test
Package test is a generated protocol buffer package.
Package test is a generated protocol buffer package.
codec
bsonrpc
Package bsonrpc provides a bson-rpc codec
Package bsonrpc provides a bson-rpc codec
jsonrpc2
Package jsonrpc2 provides a json-rpc 2.0 codec
Package jsonrpc2 provides a json-rpc 2.0 codec
msgpackrpc
Package msgpackrpc provides a msgpack-rpc codec
Package msgpackrpc provides a msgpack-rpc codec
micro
disable_rpc
Package disable_rpc disables the /rpc endpoint
Package disable_rpc disables the /rpc endpoint
gzip
Package gzip is a micro plugin for gzipping http response
Package gzip is a micro plugin for gzipping http response
index
Package index is a micro plugin for stripping a path index
Package index is a micro plugin for stripping a path index
ip_whitelist
Package ip_whitelist is a micro plugin for whitelisting ip addresses
Package ip_whitelist is a micro plugin for whitelisting ip addresses
router
Package router is a micro plugin for defining HTTP routes
Package router is a micro plugin for defining HTTP routes
stats_auth
stats_auth enables basic auth on the /stats endpoint
stats_auth enables basic auth on the /stats endpoint
trace/awsxray
Package awsxray is a micro plugin for whitelisting service requests
Package awsxray is a micro plugin for whitelisting service requests
trace/uuid
Package uuid is a micro plugin for adding a trace header
Package uuid is a micro plugin for adding a trace header
whitelist
Package whitelist is a micro plugin for whitelisting service requests
Package whitelist is a micro plugin for whitelisting service requests
registry
eureka/mock
This file was generated by counterfeiter
This file was generated by counterfeiter
selector
blacklist
Package blacklist is a selector which includes blacklisting of nodes when they fail
Package blacklist is a selector which includes blacklisting of nodes when they fail
transport
grpc/proto
Package go_micro_grpc_transport is a generated protocol buffer package.
Package go_micro_grpc_transport is a generated protocol buffer package.
wrapper
endpoint
Package endpoint provides a wrapper that executes other wrappers for specific methods
Package endpoint provides a wrapper that executes other wrappers for specific methods
select/roundrobin
Package roundrobin implements a roundrobin call strategy
Package roundrobin implements a roundrobin call strategy
select/shard
Package shard implements the sharding call strategy
Package shard implements the sharding call strategy
service
Package wrapper injects a go-micro.Service into the context
Package wrapper injects a go-micro.Service into the context
trace/awsxray
Package awsxray is a wrapper for AWS X-Ray distributed tracing
Package awsxray is a wrapper for AWS X-Ray distributed tracing
trace/datadog
Package datadog provides wrappers for Datadog ddtrace
Package datadog provides wrappers for Datadog ddtrace
trace/opencensus
Package opencensus provides wrappers for OpenCensus tracing.
Package opencensus provides wrappers for OpenCensus tracing.
trace/opentracing
Package opentracing provides wrappers for OpenTracing
Package opentracing provides wrappers for OpenTracing

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL