pubsub

README

go-pubsub

Go package to provide a common interface for abstract publish and subscribe operations.

Documentation

Documentation is incomplete at this time.

Tools

$> make cli
go build -mod vendor -ldflags="-s -w" -o bin/publish cmd/publish/main.go
go build -mod vendor -ldflags="-s -w" -o bin/subscribe cmd/subscribe/main.go

Examples

$> ./bin/publish \
	-publisher-uri 'awssqs-creds://?region={REGION}&credentials={CREDENTIALS}&queue-url=https://sqs.{REGION}.amazonaws.com/{ACCOUNT}/{QUEUE}' \
	'hello world'

$> ./bin/subscribe \
	-subscriber-uri 'awssqs-creds://?region={REGION}&credentials={CREDENTIALS}&queue-url=https://sqs.{REGION}.amazonaws.com/{ACCOUNT}/{QUEUE}'
2024/09/04 10:59:57 INFO Listening for messages
hello world

See also

• https://gocloud.dev/howto/pubsub/
• https://github.com/google/go-cloud/issues/1368
• https://github.com/go-redis/redis/v8

Documentation

Overview

Package pubsub provides a common interface for abstract publish and subscribe operations. Ideally this package would/could be replaced by the GoCloud pubsub package but it does not support Redis... https://gocloud.dev/howto/pubsub/ https://github.com/google/go-cloud/issues/1368

Index

• Constants
• func RedisConfigFromURL(u *url.URL) (string, string, error)

Constants

const REDIS_DEFAULT_HOST string = "localhost"

const REDIS_DEFAULT_PORT int = 6379

Functions

func RedisConfigFromURL

func RedisConfigFromURL(u *url.URL) (string, string, error)