queue

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: Oct 7, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Package queue implements the data transmission queue.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type BatchPublisher added in v0.5.0 

type BatchPublisher interface {
	bus.Publisher
	io.Closer
}

BatchPublisher is the interface for publishing data in batch.

type Client added in v0.5.0 

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 added in v0.5.0 

func Local() Queue

Local return a new local Queue.

type Server added in v0.5.0 

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

Server is the interface for receiving data from the queue.

Source Files

View all Source files

Directories

Path Synopsis
Package pub implements the queue client.
 Package pub implements the queue client.
Package sub implements the queue server.
 Package sub implements the queue server.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.