messaging

package
v0.0.0-...-03a60d5 Latest Latest
Warning

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

Go to latest
Published: Sep 9, 2021 License: AGPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CreateRoadSegmentSurfaceUpdatedReceiver

func CreateRoadSegmentSurfaceUpdatedReceiver(db database.Datastore) messaging.TopicMessageHandler

CreateRoadSegmentSurfaceUpdatedReceiver is a closure that take a datastore and handles incoming events

func CreateUpdateRoadSegmentSurfaceCommandHandler

func CreateUpdateRoadSegmentSurfaceCommandHandler(db database.Datastore, msg MessagingContext) messaging.CommandHandler

CreateUpdateRoadSegmentSurfaceCommandHandler returns a handler for commands

Types

type MessagingContext

type MessagingContext interface {
	PublishOnTopic(message messaging.TopicMessage) error
	NoteToSelf(message messaging.CommandMessage) error
}

MessagingContext is an interface that allows mocking of messaging.Context parameters

Directories

Path Synopsis

Jump to

Keyboard shortcuts

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