go/starter
1
0
Fork 0
mirror of https://github.com/ManyakRus/starter.git synced 2025-11-25 23:02:22 +02:00
Code Issues Releases Activity

сделал ping_go() var err error

Browse Source
This commit is contained in:
Nikitin Aleksandr
2025-04-01 16:02:24 +03:00
parent 1a763d61c2
commit efd7b3809b
9 changed files with 18 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
camunda_connect/camunda_connect.go
View File

@@ -323,6 +323,7 @@ func Send_BPMN_File(BPMN_filename string) {
// ping_go - делает пинг каждые 60 секунд, и реконнект
func ping_go(HandleJob func(client worker.JobClient, job entities.Job), CAMUNDA_JOBTYPE string) {
var err error
ticker := time.NewTicker(60 * time.Second)
@@ -336,7 +337,7 @@ loop:
log.Warn("Context app is canceled. camunda_connect.ping")
break loop
case <-ticker.C:
err := port_checker.CheckPort_err(Settings.CAMUNDA_HOST, Settings.CAMUNDA_PORT)
err = port_checker.CheckPort_err(Settings.CAMUNDA_HOST, Settings.CAMUNDA_PORT)
// log.Debug("ticker, ping err: ", err) //удалить
if err != nil {
NeedReconnect = true

3
camunda_connect2/camunda_connect2.go
View File

@@ -279,6 +279,7 @@ func Send_BPMN_File(BPMN_filename string) {
// ping_go - делает пинг каждые 60 секунд, и реконнект
func ping_go(HandleJob func(client worker.JobClient, job entities.Job), CAMUNDA_JOBTYPE string) {
var err error
ticker := time.NewTicker(60 * time.Second)
@@ -292,7 +293,7 @@ loop:
log.Warn("Context app is canceled. camunda_connect.ping")
break loop
case <-ticker.C:
err := port_checker.CheckPort_err(Settings.CAMUNDA_HOST, Settings.CAMUNDA_PORT)
err = port_checker.CheckPort_err(Settings.CAMUNDA_HOST, Settings.CAMUNDA_PORT)
// log.Debug("ticker, ping err: ", err) //удалить
if err != nil {
NeedReconnect = true

3
minio_connect/minio_connect.go
View File

@@ -268,6 +268,7 @@ func FillSettings() {
// ping_go - делает пинг каждые 60 секунд, и реконнект
func ping_go() {
var err error
ticker := time.NewTicker(60 * time.Second)
@@ -281,7 +282,7 @@ loop:
log.Warn("Context app is canceled. minio_connect.ping")
break loop
case <-ticker.C:
err := port_checker.CheckPort_err(Settings.MINIO_HOST, Settings.MINIO_PORT)
err = port_checker.CheckPort_err(Settings.MINIO_HOST, Settings.MINIO_PORT)
//log.Debug("ticker, ping err: ", err) //удалить
if err != nil {
NeedReconnect = true

3
postgres_connect/postgres_connect.go
View File

@@ -299,6 +299,7 @@ func FillSettings() {
// ping_go - делает пинг каждые 60 секунд, и реконнект
func ping_go() {
var err error
ticker := time.NewTicker(60 * time.Second)
@@ -312,7 +313,7 @@ loop:
log.Warn("Context app is canceled. postgres_connect.ping")
break loop
case <-ticker.C:
err := port_checker.CheckPort_err(Settings.DB_HOST, Settings.DB_PORT)
err = port_checker.CheckPort_err(Settings.DB_HOST, Settings.DB_PORT)
//log.Debug("ticker, ping err: ", err) //удалить
if err != nil {
NeedReconnect = true

3
postgres_gorm/postgres_gorm.go
View File

@@ -437,6 +437,7 @@ func GetConnection_WithApplicationName(ApplicationName string) *gorm.DB {
// ping_go - делает пинг каждые 60 секунд, и реконнект
func ping_go() {
var err error
ticker := time.NewTicker(60 * time.Second)
defer ticker.Stop()
@@ -451,7 +452,7 @@ loop:
log.Warn("Context app is canceled. postgres_gorm.ping")
break loop
case <-ticker.C:
err := port_checker.CheckPort_err(Settings.DB_HOST, Settings.DB_PORT)
err = port_checker.CheckPort_err(Settings.DB_HOST, Settings.DB_PORT)
//log.Debug("ticker, ping err: ", err) //удалить
if err != nil {
NeedReconnect = true

3
postgres_gorm2/postgres_gorm2.go
View File

@@ -439,6 +439,7 @@ func GetConnection_WithApplicationName(ApplicationName string) *gorm.DB {
// ping_go - делает пинг каждые 60 секунд, и реконнект
func ping_go() {
var err error
ticker := time.NewTicker(60 * time.Second)
defer ticker.Stop()
@@ -453,7 +454,7 @@ loop:
log.Warn("Context app is canceled. postgres_gorm.ping")
break loop
case <-ticker.C:
err := port_checker.CheckPort_err(Settings.DB_HOST, Settings.DB_PORT)
err = port_checker.CheckPort_err(Settings.DB_HOST, Settings.DB_PORT)
//log.Debug("ticker, ping err: ", err) //удалить
if err != nil {
NeedReconnect = true

3
postgres_pgx/postgres_pgx.go
View File

@@ -343,6 +343,7 @@ func FillSettings() {
// ping_go - делает пинг каждые 60 секунд, и реконнект
func ping_go() {
var err error
ticker := time.NewTicker(60 * time.Second)
@@ -356,7 +357,7 @@ loop:
log.Warn("Context app is canceled. postgres_pgx.ping")
break loop
case <-ticker.C:
err := port_checker.CheckPort_err(Settings.DB_HOST, Settings.DB_PORT)
err = port_checker.CheckPort_err(Settings.DB_HOST, Settings.DB_PORT)
//log.Debug("ticker, ping err: ", err) //удалить
if err != nil {
NeedReconnect = true

3
postgres_stek/postgres_stek.go
View File

@@ -343,6 +343,7 @@ func GetConnection(Connection connections.Connection) *gorm.DB {
// ping_go - делает пинг каждые 60 секунд, и реконнект
func ping_go() {
var err error
ticker := time.NewTicker(60 * time.Second)
@@ -362,7 +363,7 @@ loop:
log.Warn("Context app is canceled. postgres_stek.ping")
break loop
case <-ticker.C:
err := port_checker.CheckPort_err(Connection.Server, Connection.Port)
err = port_checker.CheckPort_err(Connection.Server, Connection.Port)
//log.Debug("ticker, ping err: ", err) //удалить
if err != nil {
NeedReconnect = true

3
tinkoff_connect/tinkoff_connect.go
View File

@@ -190,6 +190,7 @@ func CloseConnection_err() error {
// ping_go - делает пинг каждые 60 секунд, и реконнект
func ping_go() {
var err error
ticker := time.NewTicker(60 * time.Second)
defer ticker.Stop()
@@ -204,7 +205,7 @@ loop:
log.Warn("Context app is canceled. grpc_client.ping")
break loop
case <-ticker.C:
err := port_checker.CheckPort_err(Settings.Host, Settings.Port)
err = port_checker.CheckPort_err(Settings.Host, Settings.Port)
//log.Debug("ticker, ping err: ", err) //удалить
if err != nil {
NeedReconnect = true