Skip to content

Commit

Permalink
minor updates after review
Browse files Browse the repository at this point in the history
  • Loading branch information
fogfish committed Sep 29, 2024
1 parent 85c9617 commit 6ea82db
Show file tree
Hide file tree
Showing 2 changed files with 8 additions and 22 deletions.
22 changes: 0 additions & 22 deletions broker/events3/events3.go
Original file line number Diff line number Diff line change
Expand Up @@ -38,28 +38,6 @@ func NewReader(opts ...Option) (*kernel.Dequeuer, error) {
return kernel.NewDequeuer(bridge, c.config), nil
}

// New creates broker for AWS S3 (serverless events)
// func New(queue string, opts ...swarm.Option) (swarm.Broker, error) {
// config := swarm.NewConfig()
// for _, opt := range opts {
// opt(&config)
// }
//
// starter := lambda.Start
//
// type Mock interface{ Start(interface{}) }
// if config.Service != nil {
// service, ok := config.Service.(Mock)
// if ok {
// starter = service.Start
// }
// }
//
// sls := bridge{f: starter, c: config}
//
// return kernel.New(nil, sls, config), nil
// }

//------------------------------------------------------------------------------

type bridge struct{ *kernel.Bridge }
Expand Down
8 changes: 8 additions & 0 deletions broker/events3/events3_test.go
Original file line number Diff line number Diff line change
@@ -1,3 +1,11 @@
//
// Copyright (C) 2021 - 2024 Dmitry Kolesnikov
//
// This file may be modified and distributed under the terms
// of the Apache License Version 2.0. See the LICENSE file for details.
// https://github.com/fogfish/swarm
//

package events3

import (
Expand Down

0 comments on commit 6ea82db

Please sign in to comment.