From a12247cf4c2299dd6dbed7f1cd9ea73c8dcd98c0 Mon Sep 17 00:00:00 2001 From: Caleb Doxsey Date: Tue, 27 Jul 2021 16:59:40 -0600 Subject: [PATCH] remove azure --- README.md | 2 +- providers/azure/queue.go | 43 ---------------------------------------- 2 files changed, 1 insertion(+), 44 deletions(-) delete mode 100644 providers/azure/queue.go diff --git a/README.md b/README.md index d45800f..de07be5 100644 --- a/README.md +++ b/README.md @@ -3,4 +3,4 @@ ## Providers - [ ] [Google Cloud Pub/Sub](https://cloud.google.com/pubsub) -- [ ] [Azure Storage Queues](https://docs.microsoft.com/en-us/azure/storage/queues/reference) \ No newline at end of file +- [ ] In Memory \ No newline at end of file diff --git a/providers/azure/queue.go b/providers/azure/queue.go deleted file mode 100644 index 0c1134e..0000000 --- a/providers/azure/queue.go +++ /dev/null @@ -1,43 +0,0 @@ -package azure - -import ( - "context" - - "github.com/badgerodon/pubsub" -) - -type queue struct { -} - -// New creates a new pub/sub queue backed by Azure Storage Queues. -func New() pubsub.Queue { - return new(queue) -} - -func (q *queue) Close() error { - panic("implement me") -} - -func (q *queue) Topic(ctx context.Context, name string) (pubsub.Topic, error) { - return newTopic(q, name), nil -} - -type topic struct { - q *queue - name string -} - -func newTopic(q *queue, name string) pubsub.Topic { - return &topic{ - q: q, - name: name, - } -} - -func (t *topic) Publish(ctx context.Context, msg pubsub.Message) error { - panic("implement me") -} - -func (t *topic) Subscribe(ctx context.Context, name string, options ...pubsub.SubscribeOption) (pubsub.Subscription, error) { - panic("implement me") -}