Skip to content

Commit

Permalink
clean up review comments
Browse files Browse the repository at this point in the history
  • Loading branch information
fogfish committed Mar 11, 2024
1 parent 88fea73 commit 1946825
Show file tree
Hide file tree
Showing 2 changed files with 2 additions and 17 deletions.
7 changes: 2 additions & 5 deletions README.md
Original file line number Diff line number Diff line change
Expand Up @@ -70,6 +70,8 @@ api | examples
**AWS Redis** | ![help needed](https://img.shields.io/badge/help%20needed-035392?style=platic)
**MQTT API** | ![help needed](https://img.shields.io/badge/help%20needed-035392?style=platic)

Please let us know via [GitHub issues](https://github.com/fogfish/swarm/issue) your needs about queuing technologies.


## Inspiration

Expand Down Expand Up @@ -420,11 +422,6 @@ stack.NewSink(
)
```

### Supported queuing system and event brokers


Please let us know via [GitHub issues](https://github.com/fogfish/swarm/issue) your needs about queuing technologies.


## How To Contribute

Expand Down
12 changes: 0 additions & 12 deletions bag.go
Original file line number Diff line number Diff line change
Expand Up @@ -32,26 +32,16 @@ func NewContext(ctx context.Context, cat, digest string) *Context {
}
}

// type Digest struct {
// // Unique brief summary of the message
// Brief string

// // Error on the message processing
// Error error
// }

// Msg is a generic envelop type for incoming messages.
// It contains both decoded object and its digest used to acknowledge message.
type Msg[T any] struct {
Ctx *Context
Object T
// Digest Digest
}

// Fail message with error
func (msg Msg[T]) Fail(err error) Msg[T] {
msg.Ctx.Error = err
//msg.Digest.Error = err
return msg
}

Expand All @@ -60,6 +50,4 @@ func (msg Msg[T]) Fail(err error) Msg[T] {
type Bag struct {
Ctx *Context
Object []byte
// Digest Digest
// Category string
}

0 comments on commit 1946825

Please sign in to comment.