micro

package
Version: v1.0.20 Latest Latest
Warning

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

Go to latest
Published: Apr 28, 2021 License: Apache-2.0 Imports: 8 Imported by: 0

README

备份仓库

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func InitClient

func InitClient(cliName, version string, registry *EtcdRegistry, fn func(client.Client))

func InitServer

func InitServer(name, version string, registry *EtcdRegistry, fn func(s server.Server))

func LogClientWrap

func LogClientWrap(c client.Client) client.Client

func LogWrapper

func LogWrapper(fn server.HandlerFunc) server.HandlerFunc

Types

type Broker

type Broker interface {
	Address() []string
}

type EtcdRegistry

type EtcdRegistry struct {
	Addrs []string
}

func (*EtcdRegistry) Address

func (e *EtcdRegistry) Address() []string

type KafkaBroker

type KafkaBroker struct {
	Addrs []string
}

func (*KafkaBroker) Address

func (k *KafkaBroker) Address() []string

type MqttBroker

type MqttBroker struct {
	Addrs []string
}

func (*MqttBroker) Address

func (m *MqttBroker) Address() []string

type NsqBroker

type NsqBroker struct {
	Addrs []string
}

#==============Broker==============

func (*NsqBroker) Address

func (n *NsqBroker) Address() []string

type RedisBroker

type RedisBroker struct {
	Addrs []string
}

func (*RedisBroker) Address

func (r *RedisBroker) Address() []string

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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