mq

Documentation

Index

• type AmqpUpstream
  • func (au *AmqpUpstream) Submit(topic string, v interface{})
• type Connector
• type Downstream
• type Service
  • func Start(ctx context.Context, c Connector, s ...Downstream) (svs Service, err error)
• type Upstream

Types

type AmqpUpstream

type AmqpUpstream struct {
	// contains filtered or unexported fields
}

func (*AmqpUpstream) Submit

func (au *AmqpUpstream) Submit(topic string, v interface{})

type Connector

type Connector struct {
	Conn string
}

type Downstream

type Downstream interface {
	Subscribe(topic string, v interface{}, upstream Upstream)
	Topic() string
}

type Service

type Service interface {
	Run() error
	UpstreamHandler() Upstream
}

func Start

func Start(ctx context.Context, c Connector, s ...Downstream) (svs Service, err error)

type Upstream

type Upstream interface {
	Submit(topic string, v interface{}) // 提交
}