plugin

package module
v0.0.0-...-62a0e51 Latest Latest
Warning

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

Go to latest
Published: Apr 7, 2022 License: Apache-2.0 Imports: 15 Imported by: 0

README

Plugins License GoDoc

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.

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

Create your service and ensure you call service.Init

package main

import (
	"go-micro.dev"
)

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 (
	"go-micro.dev"
	"github.com/go-micro/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/go-micro/plugins/broker/rabbitmq"
	_ "github.com/go-micro/plugins/registry/kubernetes"
	_ "github.com/go-micro/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

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
auth
jwt Module
broker
kafka Module
memory Module
mqtt Module
nats Module
rabbitmq Module
redis Module
client
grpc Module
http Module
mucp Module
config
encoder/toml Module
encoder/yaml Module
source/etcd Module
events
redis Module
registry
consul Module
etcd Module
eureka Module
gossip Module
kubernetes Module
multi Module
nacos Module
nats Module
proxy Module
zookeeper Module
selector
static Module
server
http Module
store
file Module
transport
tcp Module
utp Module
v2
broker/grpc Module
broker/http Module
broker/kafka Module
broker/memory Module
broker/mqtt Module
broker/nats Module
broker/proxy Module
broker/redis Module
broker/snssqs Module
broker/sqs Module
broker/stan Module
broker/stomp Module
client/http Module
client/mock Module
codec/bsonrpc Module
logger/apex Module
logger/logrus Module
logger/zap Module
micro/auth Module
micro/cors Module
micro/gzip Module
micro/header Module
micro/index Module
micro/metrics Module
micro/router Module
proxy/http Module
registry/etcd Module
registry/mdns Module
registry/nats Module
server/http Module
store/consul Module
store/etcd Module
store/mysql Module
store/redis Module
transport/tcp Module
transport/utp Module
v3
auth/jwt Module
broker/grpc Module
broker/http Module
broker/kafka Module
broker/memory Module
broker/mqtt Module
broker/nats Module
broker/nsq Module
broker/proxy Module
broker/redis Module
broker/snssqs Module
broker/sqs Module
broker/stan Module
broker/stomp Module
client/grpc Module
client/http Module
client/mock Module
client/mucp Module
codec/bsonrpc Module
logger/apex Module
logger/logrus Module
logger/zap Module
proxy/http Module
registry/etcd Module
registry/mdns Module
registry/nats Module
selector/dns Module
server/grpc Module
server/http Module
server/mucp Module
store/consul Module
store/file Module
store/memory Module
store/mysql Module
store/redis Module
sync/consul Module
sync/etcd Module
sync/memory Module
transport/tcp Module
transport/utp Module
v4
auth/jwt Module
broker/grpc Module
broker/http Module
broker/kafka Module
broker/memory Module
broker/mqtt Module
broker/nats Module
broker/nsq Module
broker/proxy Module
broker/redis Module
broker/snssqs Module
broker/sqs Module
broker/stan Module
broker/stomp Module
cache/redis Module
client/grpc Module
client/http Module
client/mock Module
client/mucp Module
codec/bsonrpc Module
events/nats Module
events/natsjs Module
events/redis Module
logger/apex Module
logger/logrus Module
logger/zap Module
proxy/http Module
registry/etcd Module
registry/mdns Module
registry/nats Module
selector/dns Module
server/grpc Module
server/http Module
server/mucp Module
store/consul Module
store/file Module
store/memory Module
store/mysql Module
store/nats-js Module
store/redis Module
sync/consul Module
sync/etcd Module
sync/memory Module
transport/tcp Module
transport/utp Module
wrapper
select/shard Module

Jump to

Keyboard shortcuts

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