Welcome to Pletter 👋

A standard way to wrap a proto message

Pletter was born with a single mission: To standardize wrapping protocol buffer messages. This is normally needed when you use protobuf as your messaging protocol.

The Problem

Imagine that you have an event driven architecture. In this system you chose to use protocol buffers to ensure message contract and to transit information. Let's assume we use Kafka as our message broker. In this Kafka we have one topic called accounts, this means all account messages will go to the accounts topic.

On the consumer side, we will receive multiple messages in the same topic. If an application wants to read this messages it needs to identify the message type/name to either enrich, fan out or handle it. To solve that we have a few options:

1. If you use something like AMQP instead of a message broker you can set the name of the message in the header and deal with it in the consumer side
2. If you use Kafka/Kinesis or any message broker that streams messages, you will need to envelop the message.

Option 2 is the option that Pletter tries to solve in Go.

An interesting article about streams architecture can be found here

Install

go get github.com/vimeda/pletter

Use

Pletter is simple to use, we provide you a few functions to deal with the message.

When producing messages:

// Create your proto messageac:= pb.Example{
ID: "1231231312",
}
// call the PackAndMarshal function to wrap your message and already proto.Marshal itraw, err:=any.PackAndMarshal(&ac)
iferr!=nil {
fmt.Errorf("an error ocurred while packing and marshalling the message: %s", err)
}
// send the slice of byte to your message broker

When consuming messages:

// declare your expected typevarexpectedExample pb.Example// call the Unpack function that will unwrap your message from the enveloperr=any.Unpack(raw, &expectedExample)
iferr!=nil {
fmt.Errorf("an error ocurred while unpacking the message: %s", err)
}

You can also filter out messages when consuming them:

// call the Unpack function that will unwrap your message from the envelopname, err:=any.GetMessageName(raw)
iferr!=nil {
fmt.Errorf("an error ocurred while getting the message name: %s", err)
}
switchname {
case"pb.Example":
// declare your expected typevarexpectedExample pb.Example// call the Unpack function that will unwrap your message from the enveloperr=any.Unpack(raw, &expectedExample)
iferr!=nil {
fmt.Errorf("an error ocurred while unpacking the message: %s", err)
}
// do somthingdefault;
// ignore the other messages
}

Run tests

go test ./...

Author

👤 Italo Vietro

• Github: @italolelis

👤 Felipe Umpierre

• Github: @felipeumpierre

🤝 Contributing

Contributions, issues and feature requests are welcome!
Feel free to check issues page.