From 92b98b0e40c029e33e68d0db70f7a6c335bf60ab Mon Sep 17 00:00:00 2001 From: Dustin Wilson Date: Fri, 25 Aug 2023 12:26:28 -0400 Subject: [PATCH] update topic & dbconn struct fields --- databases.go | 19 ++++++++++++------- 1 file changed, 12 insertions(+), 7 deletions(-) diff --git a/databases.go b/databases.go index e0d963bc..867776a7 100644 --- a/databases.go +++ b/databases.go @@ -195,13 +195,15 @@ type DatabaseCA struct { // DatabaseConnection represents a database connection type DatabaseConnection struct { - URI string `json:"uri,omitempty"` - Database string `json:"database,omitempty"` - Host string `json:"host,omitempty"` - Port int `json:"port,omitempty"` - User string `json:"user,omitempty"` - Password string `json:"password,omitempty"` - SSL bool `json:"ssl,omitempty"` + Protocol string `json:"protocol"` + URI string `json:"uri,omitempty"` + Database string `json:"database,omitempty"` + Host string `json:"host,omitempty"` + Port int `json:"port,omitempty"` + User string `json:"user,omitempty"` + Password string `json:"password,omitempty"` + SSL bool `json:"ssl,omitempty"` + ApplicationPorts map[string]uint32 `json:"application_ports,omitempty"` } // DatabaseUser represents a user in the database @@ -209,6 +211,8 @@ type DatabaseUser struct { Name string `json:"name,omitempty"` Role string `json:"role,omitempty"` Password string `json:"password,omitempty"` + AccessCert string `json:"access_cert,omitempty"` + AccessKey string `json:"access_key,omitempty"` MySQLSettings *DatabaseMySQLUserSettings `json:"mysql_settings,omitempty"` KafkaSettings *DatabaseKafkaUserSettings `json:"settings,omitempty"` } @@ -296,6 +300,7 @@ type DatabaseTopic struct { Name string `json:"name"` PartitionCount *uint32 `json:"partition_count,omitempty"` ReplicationFactor *uint32 `json:"replication_factor,omitempty"` + State string `json:"state,omitempty"` Config *TopicConfig `json:"config,omitempty"` }