Merge pull request #14 from jonbretman/publish-time

Add PublishTime to Msg type

Author: arbarlow

google/google.go

@@ -148,9 +148,10 @@ func (g *GoogleCloud) subscribe(opts ps.HandlerOptions, h ps.MsgHandler, ready c
 
 				b.Reset()
 				msg := ps.Msg{
-					ID:       m.ID,
-					Metadata: m.Attributes,
-					Data:     m.Data,
+					ID:          m.ID,
+					Metadata:    m.Attributes,
+					Data:        m.Data,
+					PublishTime: &m.PublishTime,
 					Ack: func() {
 						m.Ack()
 					},

pubsub.go

@@ -4,6 +4,7 @@ package pubsub
 
 import (
 	"context"
+	"time"
 )
 
 var (
@@ -39,9 +40,10 @@ type Subscriber interface {
 
 // Msg is a lile representation of a pub sub message
 type Msg struct {
-	ID       string
-	Metadata map[string]string
-	Data     []byte
+	ID          string
+	Metadata    map[string]string
+	Data        []byte
+	PublishTime *time.Time
 
 	Ack  func()
 	Nack func()