plugin

package module
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Apr 20, 2023 License: Apache-2.0 Imports: 16 Imported by: 0

README

Plugins License GoDoc Travis CI Go Report Card

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.

Read the docs to learn more about how to use them.

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 plugins.go file

package main

import (
	_ "github.com/micro/go-plugins/broker/rabbitmq/v2"
	_ "github.com/micro/go-plugins/registry/kubernetes/v2"
	_ "github.com/micro/go-plugins/transport/nats/v2"
)

Create your service and ensure you call service.Init

package main

import (
	"e.coding.net/nimrc/micro/micro"
)

func main() {
	service := micro.NewService(
		// Set service name
		micro.Name("my.service"),
	)

	// Parse CLI flags
	service.Init()
}

Build your service

go build -o service ./main.go ./plugins.go
Env

Use environment variables to set the

MICRO_BROKER=rabbitmq \
MICRO_REGISTRY=kubernetes \ 
MICRO_TRANSPORT=nats \ 
./service
Flags

Or use command line flags to enable them

./service --broker=rabbitmq --registry=kubernetes --transport=nats
Options

Import and set as options when creating a new service

import (
	"e.coding.net/nimrc/micro/micro"
	"github.com/micro/go-plugins/registry/kubernetes/v2"
)

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/v2"
	_ "github.com/micro/go-plugins/registry/kubernetes/v2"
	_ "github.com/micro/go-plugins/transport/nats/v2"
)

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

Documentation

Overview

Package plugin provides the ability to load plugins

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Build

func Build(path string, p *Plugin) error

Build generates a dso plugin using the go command `go build -buildmode=plugin`

func Generate

func Generate(path string, p *Plugin) error

Generate creates a go file at the specified path. You must use `go build -buildmode=plugin`to build it.

func Init

func Init(p *Plugin) error

Init sets up the plugin

Types

type Plugin

type Plugin struct {
	// Name of the plugin e.g rabbitmq
	Name string
	// Type of the plugin e.g broker
	Type string
	// Path specifies the import path
	Path string
	// NewFunc creates an instance of the plugin
	NewFunc interface{}
}

Plugin is a plugin loaded from a file

func Load

func Load(path string) (*Plugin, error)

Load loads a plugin created with `go build -buildmode=plugin`

Directories

Path Synopsis
agent
broker
gocloud
Package gocloud provides a pubsub broker for Go Cloud.
Package gocloud provides a pubsub broker for Go Cloud.
googlepubsub
Package googlepubsub provides a Google cloud pubsub broker
Package googlepubsub provides a Google cloud pubsub broker
grpc
Package grpc is a point to point grpc broker
Package grpc is a point to point grpc broker
grpc/proto
Package broker is a generated protocol buffer package.
Package broker is a generated protocol buffer package.
http
Package http provides a http based message broker
Package http provides a http based message broker
kafka
Package kafka provides a kafka broker using sarama cluster
Package kafka provides a kafka broker using sarama cluster
memory
Package memory provides a memory broker
Package memory provides a memory broker
mqtt
Package mqtt provides an mqtt broker
Package mqtt provides an mqtt broker
nats
Package memory provides a memory broker
Package memory provides a memory broker
nsq
Package nsq provides an NSQ broker
Package nsq provides an NSQ broker
proxy
Package proxy is a broker using the micro proxy
Package proxy is a broker using the micro proxy
rabbitmq
Package rabbitmq provides a RabbitMQ broker
Package rabbitmq provides a RabbitMQ broker
redis
Package redis provides a Redis broker
Package redis provides a Redis broker
segmentio
Package kafka provides a kafka broker using segmentio
Package kafka provides a kafka broker using segmentio
service
Package service provides the broker service client
Package service provides the broker service client
sqs
stan
Package stan provides a NATS Streaming broker
Package stan provides a NATS Streaming broker
client
http
Package http provides a http client
Package http provides a http client
http/test
Package test is a generated protocol buffer package.
Package test is a generated protocol buffer package.
mock
Package mock provides a mock client for testing
Package mock provides a mock client for testing
selector/label
Package label is a priority label based selector.
Package label is a priority label based selector.
selector/static
Package static is a selector which always returns the name specified with a port-number appended.
Package static is a selector which always returns the name specified with a port-number appended.
codec
bsonrpc
Package bsonrpc provides a bson-rpc codec
Package bsonrpc provides a bson-rpc codec
json-iterator
Package json iterator provides a json codec
Package json iterator provides a json 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
segmentio
Package json provides a json codec
Package json provides a json codec
config
source/configmap
Package configmap config is an interface for dynamic configuration.
Package configmap config is an interface for dynamic configuration.
source/grpc/proto
Package grpc is a generated protocol buffer package.
Package grpc is a generated protocol buffer package.
source/runtimevar
package runtimevar is the source for gocloud.dev/runtimevar
package runtimevar is the source for gocloud.dev/runtimevar
source/url
Package url loads changesets from a url
Package url loads changesets from a url
logger
zap
micro
allow
Package allow is a micro plugin for allowing service requests
Package allow is a micro plugin for allowing service requests
auth
Package auth provides auth management for micro
Package auth provides auth management for micro
auth/basic
Package basic provides basic auth using htpasswd
Package basic provides basic auth using htpasswd
auth/digest
Package digest provides digest auth using htdigest
Package digest provides digest auth using htdigest
auth/ldap
Package ldap provides ldap authentication
Package ldap provides ldap authentication
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_allow
Package ip_allow is a micro plugin for allowing ip addresses
Package ip_allow is a micro plugin for allowing ip addresses
metrics
Package metrics provides metrics for micro
Package metrics provides metrics for micro
metrics/prometheus
Package prometheus provides prometheus metrics via a http handler
Package prometheus provides prometheus metrics via a http handler
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
proxy
http
Package http provides a micro to http proxy
Package http provides a micro to http proxy
registry
cache
Package cache provides a registry cache
Package cache provides a registry cache
etcd
Package etcd provides an etcd v3 service registry
Package etcd provides an etcd v3 service registry
etcdv3
Package etcd provides an etcd v3 service registry
Package etcd provides an etcd v3 service registry
eureka
Package eureka provides a Eureka registry
Package eureka provides a Eureka registry
eureka/mock
This file was generated by counterfeiter
This file was generated by counterfeiter
gossip
Package gossip provides a gossip registry based on hashicorp/memberlist
Package gossip provides a gossip registry based on hashicorp/memberlist
kubernetes
Package kubernetes provides a kubernetes registry
Package kubernetes provides a kubernetes registry
mdns
Package mdns provides a multicast dns registry
Package mdns provides a multicast dns registry
memory
Package memory provides an in-memory registry
Package memory provides an in-memory registry
nats
Package nats provides a NATS registry using broadcast queries
Package nats provides a NATS registry using broadcast queries
proxy
Package proxy is a registry plugin for the micro proxy
Package proxy is a registry plugin for the micro proxy
service
Package service uses the registry service
Package service uses the registry service
zookeeper
Package zookeeper provides a zookeeper registry
Package zookeeper provides a zookeeper registry
server
http
Package http implements a go-micro.Server
Package http implements a go-micro.Server
store
consul
Package consul is a consul implementation of kv
Package consul is a consul implementation of kv
etcd
Package etcd implements a go-micro/v2/store with etcd
Package etcd implements a go-micro/v2/store with etcd
transport
grpc
Package grpc provides a grpc transport
Package grpc provides a grpc transport
http
Package http returns a http2 transport using net/http
Package http returns a http2 transport using net/http
memory
Package memory is an in-memory transport
Package memory is an in-memory transport
nats
Package nats provides a NATS transport
Package nats provides a NATS transport
quic
Package quic provides a QUIC based transport
Package quic provides a QUIC based transport
rabbitmq
Package rabbitmq provides a RabbitMQ transport
Package rabbitmq provides a RabbitMQ transport
tcp
Package tcp provides a TCP transport
Package tcp provides a TCP transport
utp
Package utp implements a utp transport
Package utp implements a utp transport
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