queue

Documentation

Overview

Package queue implements the data transmission queue.

Index

• type Queue
  • func NewQueue(_ context.Context, repo discovery.ServiceRepo) (Queue, error)

Types

type Queue

type Queue interface {
	run.Unit
	bus.Subscriber
	bus.Publisher
	run.Service
}

Queue builds a data transmission tunnel between subscribers and publishers.

func NewQueue

func NewQueue(_ context.Context, repo discovery.ServiceRepo) (Queue, error)

NewQueue return a new Queue which relies on the discovery service.