Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
This commit is contained in:
2021-04-26 01:10:37 +03:00
committed by GitHub
parent 1d0a53666a
commit f6c43cbf9e
9 changed files with 114 additions and 55 deletions

View File

@@ -3,15 +3,18 @@ package tcp
import (
"github.com/unistack-org/micro/v3/codec"
"github.com/unistack-org/micro/v3/metadata"
"github.com/unistack-org/micro/v3/server"
)
var _ server.Message = &tcpMessage{}
type tcpMessage struct {
topic string
payload interface{}
contentType string
header metadata.Metadata
body []byte
codec codec.Codec
header metadata.Metadata
topic string
contentType string
body []byte
}
func (r *tcpMessage) Topic() string {