micro

README

备份仓库

Documentation

Index

• func InitClient(cliName, version string, registry *EtcdRegistry, fn func(client.Client))
• func InitServer(name, version string, registry *EtcdRegistry, fn func(s server.Server))
• func LogClientWrap(c client.Client) client.Client
• func LogWrapper(fn server.HandlerFunc) server.HandlerFunc
• type Broker
• type EtcdRegistry
  • func (e *EtcdRegistry) Address() []string
• type KafkaBroker
  • func (k *KafkaBroker) Address() []string
• type MqttBroker
  • func (m *MqttBroker) Address() []string
• type NsqBroker
  • func (n *NsqBroker) Address() []string
• type RedisBroker
  • func (r *RedisBroker) Address() []string

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