queue

Documentation

Overview

Package queue implements the data transmission queue.

Index

• type BatchPublisher
• type Client
• type Queue
  • func Local() Queue
• type Server

Types

type BatchPublisher

type BatchPublisher interface {
	bus.Publisher
	io.Closer
}

BatchPublisher is the interface for publishing data in batch.

type Client

type Client interface {
	run.Unit
	bus.Publisher
	bus.Broadcaster
	NewBatchPublisher(timeout time.Duration) BatchPublisher
	Register(schema.EventHandler)
}

Client is the interface for publishing data to the queue.

type Queue

type Queue interface {
	Client
	Server
	run.Service
}

Queue builds a data transmission tunnel between subscribers and publishers.

func Local

func Local() Queue

Local return a new local Queue.

type Server

type Server interface {
	run.Unit
	bus.Subscriber
	GetPort() *uint32
}

Server is the interface for receiving data from the queue.