mirror of
https://github.com/eosswedenorg/thalos
synced 2026-07-03 11:53:41 +02:00
Adding api/message/codec_manager.go to manager message codecs.
This commit is contained in:
parent
b5eb602e7d
commit
0d1b0f4310
1 changed files with 18 additions and 0 deletions
18
api/message/codec_manager.go
Normal file
18
api/message/codec_manager.go
Normal file
|
|
@ -0,0 +1,18 @@
|
||||||
|
package message
|
||||||
|
|
||||||
|
import "fmt"
|
||||||
|
|
||||||
|
var registry = map[string]Codec{}
|
||||||
|
|
||||||
|
func RegisterCodec(name string, codec Codec) {
|
||||||
|
registry[name] = codec
|
||||||
|
}
|
||||||
|
|
||||||
|
func GetCodec(name string) (Codec, error) {
|
||||||
|
var err error
|
||||||
|
codec, ok := registry[name]
|
||||||
|
if !ok {
|
||||||
|
err = fmt.Errorf("no codec registered with name '%s'", name)
|
||||||
|
}
|
||||||
|
return codec, err
|
||||||
|
}
|
||||||
Loading…
Add table
Add a link
Reference in a new issue