change type of event timestamp from string to time.Time (CrunchyData#965)

Author: abrightwell

apiserver/clusterservice/clusterimpl.go

@@ -402,7 +402,7 @@ func TestCluster(name, selector, ns, pgouser string, allFlag bool) msgs.ClusterT
 Namespace: ns,
 Username: pgouser,
 Topic: topics,
-Timestamp: events.GetTimestamp(),
+Timestamp: time.Now(),
 EventType: events.EventTestCluster,
 },
 Clustername: c.Name,

apiserver/loadservice/loadimpl.go

@@ -30,6 +30,7 @@ import (
 v1batch "k8s.io/api/batch/v1"
 "k8s.io/apimachinery/pkg/labels"
 "strings"
+"time"
 )
 
 type loadJobTemplateFields struct {
@@ -190,7 +191,7 @@ func Load(request *msgs.LoadRequest, ns, pgouser string) msgs.LoadResponse {
 Namespace: ns,
 Username: pgouser,
 Topic: topics,
-Timestamp: events.GetTimestamp(),
+Timestamp: time.Now(),
 EventType: events.EventLoad,
 },
 Clustername: c.Name,

apiserver/pgoroleservice/pgoroleimpl.go

@@ -27,6 +27,7 @@ import (
 "k8s.io/api/core/v1"
 "k8s.io/client-go/kubernetes"
 "strings"
+"time"
 )
 
 // CreatePgorole ...
@@ -60,7 +61,7 @@ func CreatePgorole(clientset *kubernetes.Clientset, createdBy string, request *m
 Namespace: apiserver.PgoNamespace,
 Username: createdBy,
 Topic: topics,
-Timestamp: events.GetTimestamp(),
+Timestamp: time.Now(),
 EventType: events.EventPGOCreateRole,
 },
 CreatedRolename: request.PgoroleName,
@@ -146,7 +147,7 @@ func DeletePgorole(clientset *kubernetes.Clientset, deletedBy string, request *m
 Namespace: apiserver.PgoNamespace,
 Username: deletedBy,
 Topic: topics,
-Timestamp: events.GetTimestamp(),
+Timestamp: time.Now(),
 EventType: events.EventPGODeleteRole,
 },
 DeletedRolename: v,
@@ -217,7 +218,7 @@ func UpdatePgorole(clientset *kubernetes.Clientset, updatedBy string, request *m
 Namespace: apiserver.PgoNamespace,
 Username: updatedBy,
 Topic: topics,
-Timestamp: events.GetTimestamp(),
+Timestamp: time.Now(),
 EventType: events.EventPGOUpdateRole,
 },
 UpdatedRolename: request.PgoroleName,

apiserver/pgouserservice/pgouserimpl.go

@@ -28,6 +28,7 @@ import (
 "k8s.io/api/core/v1"
 "k8s.io/client-go/kubernetes"
 "strings"
+"time"
 )
 
 const MAP_KEY_USERNAME = "username"
@@ -78,7 +79,7 @@ func CreatePgouser(clientset *kubernetes.Clientset, createdBy string, request *m
 Namespace: apiserver.PgoNamespace,
 Username: createdBy,
 Topic: topics,
-Timestamp: events.GetTimestamp(),
+Timestamp: time.Now(),
 EventType: events.EventPGOCreateUser,
 },
 CreatedUsername: request.PgouserName,
@@ -172,7 +173,7 @@ func DeletePgouser(clientset *kubernetes.Clientset, deletedBy string, request *m
 Namespace: apiserver.PgoNamespace,
 Username: deletedBy,
 Topic: topics,
-Timestamp: events.GetTimestamp(),
+Timestamp: time.Now(),
 EventType: events.EventPGODeleteUser,
 },
 DeletedUsername: v,

apiserver/policyservice/policyimpl.go

@@ -28,6 +28,7 @@ import (
 "k8s.io/api/apps/v1"
 meta_v1 "k8s.io/apimachinery/pkg/apis/meta/v1"
 "k8s.io/client-go/rest"
+"time"
 )
 
 // CreatePolicy ...
@@ -270,7 +271,7 @@ func ApplyPolicy(request *msgs.ApplyPolicyRequest, ns, pgouser string) msgs.Appl
 Namespace: ns,
 Username: pgouser,
 Topic: topics,
-Timestamp: events.GetTimestamp(),
+Timestamp: time.Now(),
 EventType: events.EventApplyPolicy,
 },
 Clustername: d.ObjectMeta.Labels[config.LABEL_PG_CLUSTER],

apiserver/reloadservice/reloadimpl.go

@@ -27,6 +27,7 @@ import (
 "k8s.io/client-go/kubernetes"
 "k8s.io/client-go/rest"
 "strings"
+"time"
 )
 
 // Reload ...
@@ -114,7 +115,7 @@ func Reload(request *msgs.ReloadRequest, ns, username string) msgs.ReloadRespons
 Namespace: ns,
 Username: username,
 Topic: topics,
-Timestamp: events.GetTimestamp(),
+Timestamp: time.Now(),
 EventType: events.EventReloadCluster,
 },
 Clustername: cluster.Spec.Name,

apiserver/userservice/userimpl.go

@@ -186,7 +186,7 @@ func UpdateUser(request *msgs.UpdateUserRequest, pgouser string) msgs.UpdateUser
 EventHeader: events.EventHeader{
 Namespace: request.Namespace,
 Username: pgouser,
-Timestamp: events.GetTimestamp(),
+Timestamp: time.Now(),
 Topic: topics,
 EventType: events.EventChangePasswordUser,
 },
@@ -711,7 +711,7 @@ func CreateUser(request *msgs.CreateUserRequest, pgouser string) msgs.CreateUser
 Namespace: request.Namespace,
 Username: pgouser,
 Topic: topics,
-Timestamp: events.GetTimestamp(),
+Timestamp: time.Now(),
 EventType: events.EventCreateUser,
 },
 Clustername: c.Name,
@@ -853,7 +853,7 @@ func DeleteUser(request *msgs.DeleteUserRequest, pgouser string) msgs.DeleteUser
 Namespace: request.Namespace,
 Username: pgouser,
 Topic: topics,
-Timestamp: events.GetTimestamp(),
+Timestamp: time.Now(),
 EventType: events.EventDeleteUser,
 },
 Clustername: clusterName,

controller/jobcontroller.go

@@ -302,7 +302,7 @@ func (c *JobController) onUpdate(oldObj, newObj interface{}) {
 Namespace: job.ObjectMeta.Namespace,
 Username: job.ObjectMeta.Labels[config.LABEL_PGOUSER],
 Topic: topics,
-Timestamp: events.GetTimestamp(),
+Timestamp: time.Now(),
 EventType: events.EventBenchmarkCompleted,
 },
 Clustername: labels[config.LABEL_PG_CLUSTER],
@@ -476,7 +476,7 @@ func publishBackupComplete(clusterName, clusterIdentifier, username, backuptype,
 Namespace: namespace,
 Username: username,
 Topic: topics,
-Timestamp: events.GetTimestamp(),
+Timestamp: time.Now(),
 EventType: events.EventCreateBackupCompleted,
 },
 Clustername: clusterName,
@@ -500,7 +500,7 @@ func publishRestoreComplete(clusterName, identifier, username, namespace string)
 Namespace: namespace,
 Username: username,
 Topic: topics,
-Timestamp: events.GetTimestamp(),
+Timestamp: time.Now(),
 EventType: events.EventRestoreClusterCompleted,
 },
 Clustername: clusterName,

controller/podcontroller.go

@@ -18,6 +18,7 @@ limitations under the License.
 import (
 "context"
 "sync"
+"time"
 
 crv1 "github.com/crunchydata/postgres-operator/apis/cr/v1"
 "github.com/crunchydata/postgres-operator/config"
@@ -328,7 +329,7 @@ func publishClusterComplete(clusterName, namespace string, cluster *crv1.Pgclust
 Namespace: namespace,
 Username: cluster.Spec.UserLabels[config.LABEL_PGOUSER],
 Topic: topics,
-Timestamp: events.GetTimestamp(),
+Timestamp: time.Now(),
 EventType: events.EventCreateClusterCompleted,
 },
 Clustername: clusterName,
@@ -392,7 +393,7 @@ func publishPrimaryNotReady(clusterName, identifier, username, namespace string)
 Namespace: namespace,
 Username: username,
 Topic: topics,
-Timestamp: events.GetTimestamp(),
+Timestamp: time.Now(),
 EventType: events.EventPrimaryNotReady,
 },
 Clustername: clusterName,

controller/policycontroller.go

@@ -18,6 +18,7 @@ limitations under the License.
 import (
 "context"
 "sync"
+"time"
 
 "github.com/crunchydata/postgres-operator/config"
 "github.com/crunchydata/postgres-operator/kubeapi"
@@ -104,7 +105,7 @@ func (c *PgpolicyController) onAdd(obj interface{}) {
 Namespace: policy.ObjectMeta.Namespace,
 Username: policy.ObjectMeta.Labels[config.LABEL_PGOUSER],
 Topic: topics,
-Timestamp: events.GetTimestamp(),
+Timestamp: time.Now(),
 EventType: events.EventCreatePolicy,
 },
 Policyname: policy.ObjectMeta.Name,
@@ -137,7 +138,7 @@ func (c *PgpolicyController) onDelete(obj interface{}) {
 Namespace: policy.ObjectMeta.Namespace,
 Username: policy.ObjectMeta.Labels[config.LABEL_PGOUSER],
 Topic: topics,
-Timestamp: events.GetTimestamp(),
+Timestamp: time.Now(),
 EventType: events.EventDeletePolicy,
 },
 Policyname: policy.ObjectMeta.Name,