pubsubinterfaces

package
v0.6.0 Latest Latest
Warning

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

Go to latest
Published: Mar 19, 2020 License: MIT Imports: 1 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Message

type Message interface {
	GetData() []byte
}

PubsubMessage is the equivalent of a *pubsub.Message

type Pubsubber

type Pubsubber interface {
	Publish(topic string, data []byte) error
	Subscribe(topic string) (Subscription, error)
}

Pubsubber is ther interface needed for a client to a *pubsub.Pubsub

type Subscription

type Subscription interface {
	Next(context.Context) (Message, error)
	Cancel()
}

PubsubSubscription is the equivalent of a *pubsub.Subscription

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL