camunda_connect

Documentation

Overview

модуль для использования сервиса CAMUNDA

Index

• Variables
• func CloseConnection()
• func CloseJobWorker()
• func Connect()
• func Connect_err() error
• func FillSettings()
• func GetURL() string
• func LogInfo_Connected(err error)
• func Send_BPMN_File(BPMN_filename string)
• func StartCamunda(HandleJob func(client worker.JobClient, job entities.Job), ...)
• func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup, ...) error
• func WaitStop()
• func WorkComplete(client worker.JobClient, jobKey int64, variables map[string]interface{}) error
• func WorkFails(err error, client worker.JobClient, jobKey int64) error
• type SettingsINI

Variables

var Client zbc.Client

Client - клиент подключения к CAMUNDA_ID

var JobWorker worker.JobWorker

JobWorker - worker который выполняет подключение к приему сообщений от CAMUNDA

var NeedReconnect bool

NeedReconnect - флаг необходимости переподключения

Functions

func CloseConnection

func CloseConnection()

CloseConnection - отключается от сервера Camunda

func CloseJobWorker

func CloseJobWorker()

CloseConnection - отключается от сервера Camunda

func Connect

func Connect()

Connect_err - подключается к серверу Camunda, паника при ошибке

func Connect_err

func Connect_err() error

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

func FillSettings

func FillSettings()

FillSettings загружает переменные окружения в структуру из файла или из переменных окружения

func GetURL

func GetURL() string

GetURL - возврашает строку соединения к серверу Camunda

func LogInfo_Connected

func LogInfo_Connected(err error)

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

func Send_BPMN_File

func Send_BPMN_File(BPMN_filename string)

Send_BPMN_File - отправляем файл .bpmn в камунду

func StartCamunda

func StartCamunda(HandleJob func(client worker.JobClient, job entities.Job), CAMUNDA_JOBTYPE string, BPMN_filename string)

StartCamunda - необходимые процедуры для подключения к серверу Camunda

func Start_ctx

func Start_ctx(ctx *context.Context, WaitGroup *sync.WaitGroup, HandleJob func(client worker.JobClient, job entities.Job), CAMUNDA_JOBTYPE string, BPMN_filename string) error

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

func WaitStop

func WaitStop()

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

func WorkComplete

func WorkComplete(client worker.JobClient, jobKey int64, variables map[string]interface{}) error

WorkComplete - отправляет статус ОК на сервер Camunda

func WorkFails

func WorkFails(err error, client worker.JobClient, jobKey int64) error

WorkFails - отправляет статус ошибки на сервер Camunda

Types

type SettingsINI

type SettingsINI struct {
	CAMUNDA_HOST string
	CAMUNDA_PORT string
}

SettingsINI - структура для хранения всех нужных переменных окружения

var Settings SettingsINI

Settings хранит все нужные переменные окружения