nats_liveness

package

v1.0.64 Latest Latest Go to latest Published: Oct 22, 2024 License: MIT Imports: 14 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/ManyakRus/starter

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
func CheckSettingsNATS() error
func CloseConnection()
func CloseConnection_err() error
func Connect()
func Connect_err() error
func FillSettings(SERVICE_NAME string)
func LogInfo_Connected(err error)
func SendMessage()
func SendMessages_go()
func Start(ServiceName string)
func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup, ServiceName string) error
func WaitStop()
type Message
type SettingsINI

Constants ¶

This section is empty.

Variables ¶

View Source

var ServiceStartAt time.Time

View Source

var Ticker *time.Ticker

Functions ¶

func CheckSettingsNATS ¶ added in v1.0.58

func CheckSettingsNATS() error

CheckSettingsNATS - проверяет наличие переменных окружения

func CloseConnection ¶

func CloseConnection()

CloseConnection - закрывает соединение с сервером Nats-sync_exchange

func CloseConnection_err ¶

func CloseConnection_err() error

CloseConnection - закрывает соединение с сервером Nats-sync_exchange, и возвращает ошибку

func Connect ¶

func Connect()

Connect - подключается к серверу Nats-sync_exchange

func Connect_err ¶

func Connect_err() error

Connect_err - подключается к серверу Nats-sync_exchange и возвращает ошибку

func FillSettings ¶

func FillSettings(SERVICE_NAME string)

func LogInfo_Connected ¶ added in v1.0.58

func LogInfo_Connected(err error)

LogInfo_Connected - выводит сообщение в Лог, или паника при ошибке

func SendMessage ¶

func SendMessage()

SendMessage - отправляет 1 сообщение в Nats-sync_exchange

func SendMessages_go ¶

func SendMessages_go()

SendMessages_go - Отправляет сообщения каждые 5 секунд

func Start_ctx ¶ added in v1.0.58

func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup, ServiceName string) error

Start_ctx - необходимые процедуры для подключения к серверу NATS Свой контекст и WaitGroup нужны для остановки работы сервиса Graceful shutdown Для тех кто пользуется этим репозиторием для старта и останова сервиса можно просто Start()

func WaitStop ¶

func WaitStop()

WaitStop - ожидает отмену глобального контекста

Types ¶

type Message ¶

type Message struct {
	ServiceName   string `json:"service_name"`   // Имя сервиса
	ServiceTime   string `json:"service_time"`   // Фактическое время сервиса
	ServiceUptime string `json:"service_uptime"` // Аптайм сервиса
	ServiceNum    string `json:"service_num"`    // Уникальный номер сервиса
	KernelVers    string `json:"kernel_version"` // Фактическая версия ядра
	KernelType    string `json:"kernel_type"`    // Фактическая версия ядра
}

type SettingsINI ¶

type SettingsINI struct {
	NATS_LIVENESS_TOPIC string
	SERVICE_NAME        string
	SERVICE_NUMBER      string
	STAGE               string
	SERVICE_NAME_FULL   string
}

var Settings SettingsINI

Source Files ¶

View all Source files

nats_liveness.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL