system

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 16, 2023 License: MIT Imports: 13 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	/*EXT : extensiones de archivos */
	EXT = map[string]string{
		"JSON": ".json",
		"INI":  ".ini",
		"XML":  ".xml",
		"RUT":  ".rut",
		"SQL":  ".sql",
		"DB":   ".db",
		"CSV":  ".csv",
		"TXT":  ".txt",
		"DBX":  ".dbx",
	}
)

Functions

func CpDir 

func CpDir(PathOrig, PathDest string) error

CpDir : copia una carpeta entera a una carpeta destino

func CpFile 

func CpFile(PathOrig, PathDest string) error

CpFile : copia un archivo Origen a un directorio destino

func DirNew 

func DirNew(Path string) error

DirNew : Crea una carpeta vacia en el sistema

func FileExist 

func FileExist(Path string, inddir bool) bool

FileExist : Valida si el archivo del path existe antes de procesarlo. Valida tambien si existe un directorio con el inddir en true

func FileExt 

func FileExt(Path string, ext string) bool

FileExt : Valida las extenciones de archivos.

func FileNew 

func FileNew(p string) (*os.File, error)

FileNew : crea un archivo X

func FileRename 

func FileRename(PathOrigen, PathNuevo string) error

FileRename : Renombra a un archivo como tambien lo puede mover a otro directorio de manera nativa.

func GetCPU 

func GetCPU() int

GetCPU : envia la cantidad de CPU disponible en el procesador

func GetLocalIPV4 

func GetLocalIPV4() string

GetLocalIPV4 : te envia la ip local que contiene la maquina que estas ejecutando el programa

func IsLinux 

func IsLinux() bool

IsLinux : Valida si estas en un sistema operativo linux

func IsMac 

func IsMac() bool

IsMac : Valida si estas en un sistema operativo Imac

func IsSO 

func IsSO(so string) bool

IsSO : valida en que sistema operativo estas lista: android, darwin, dragonfly, linux, freebsd, openbsd, solaris, netbsd, plan9, windows

func IsWindows 

func IsWindows() bool

IsWindows : Valida si estas en un sistema operativo windows

func ListDir 

func ListDir(src string) ([]fs.DirEntry, error)

ListDir : lista la infomacion que contiene una carpeta

func MaxCPUtask 

func MaxCPUtask() int

MaxCPUtask : maxima multi hilos que puede obtener

func MaxCPUtaskLimit 

func MaxCPUtaskLimit(TASKCORE int) int

MaxCPUtaskLimit : maxima cantidad de core a usar con limitaciones TASKCORE es el limite

func MsjBlue 

func MsjBlue(format string, arg ...interface{}) string

MsjBlue : Enviar un string de color celeste funciona para consolas basadas en linux

func MsjGreen 

func MsjGreen(format string, arg ...interface{}) string

MsjGreen : Enviar un string de color verde para consolas basadas en linux

func MsjPc 

func MsjPc(c Pc, format string, arg ...interface{}) string

MsjPc : envia un string de color personalizado de las constantes disponible en la libreria

func MsjRed 

func MsjRed(format string, arg ...interface{}) string

MsjRed : Enviar un string de color rojo para consolas basadas en linux

func NumProcSet 

func NumProcSet(n int) int

NumProcSet : setea los numeros de proceso validos

func Open 

func Open(Path string) (*os.File, error)

Open : abre un archivo X

func PlecaAdd 

func PlecaAdd(src string) string

PlecaAdd : coloca la pleca de un directorio "/"

func PrintGreen 

func PrintGreen(format string, arg ...interface{})

PrintGreen : muestra un printf con color verde para consolas basadas en linux

func PrintPc 

func PrintPc(c Pc, format string, arg ...interface{})

PrintPc : muestra un printf con color personalizado para consolas basadas en linux

func PrintRed 

func PrintRed(format string, arg ...interface{})

PrintRed : muestra un printf con color rojo para consolas basadas en linux

func ReadFileStr 

func ReadFileStr(path string) (string, error)

ReadFileStr : lee un archivo de texto y lo pasa a string

func RmDir 

func RmDir(src string) error

RmDir : Elimina un directorio entero

func RmFile 

func RmFile(file string) error

RmFile : elimina un archivo exacto

func TrimFile 

func TrimFile(Path string) (string, error)

TrimFile : Renombra a una carpeta o archivo quitandole todos los espacio regresando el path del nuevo archivo.

func Write 

func Write(Path string, data []byte) error

Write : escrive los datos en un archivo X

Types

type ConfigWorker 

type ConfigWorker struct {
	Workers   FormatWorker `json:"workers"`
	ConfigDir StArchMa     `json:"files"`
	Pathlog   string       `json:"pathlog"`
	Debug     bool         `json:"debug"`
}

ConfigWorker : configuracion del worker maestro para integracion de demonio

type FormatWorker 

type FormatWorker []struct {
	Tp  string `json:"type"`
	Key string `json:"key"`
	Fr  string `json:"format"`
}

FormatWorker : contiene los formatos de los worker para poder obtenerlos de forma de un json

type Job 

type Job func(chan bool, chan error)

Job : alias para un proceso

type MasterWorker 

type MasterWorker struct {
	Jobs map[string]Job
	// contains filtered or unexported fields
}

MasterWorker : contiene varios worker y se administran de forma individual con maps

func NewMasterWorker 

func NewMasterWorker(Jobs map[string]Job, config string, indload bool) (MasterWorker, error)

NewMasterWorker : Crea un MasterWorker

func (*MasterWorker) Debug 

func (p *MasterWorker) Debug(key, format string, args ...interface{}) error

Debug : ingresa un texto en modo debug

func (*MasterWorker) Err 

func (p *MasterWorker) Err(key string) <-chan error

Err : envia el error en un canal de ejecucion

func (*MasterWorker) Error 

func (p *MasterWorker) Error(key, format string, args ...interface{}) error

Debug : ingresa un texto en modo error

func (*MasterWorker) Finally 

func (p *MasterWorker) Finally(key string)

Finally : Finalizacion del proceso donde el indicativo reset es para reintentar secuencia

func (*MasterWorker) FinallyDet 

func (p *MasterWorker) FinallyDet(key, msg string, indreload, inderr bool) error

FinallyDet : Finalizacion del proceso donde el indicativo reset es para reintentar secuencia ademas guarda en los logs si termino bien o tuvo un error ademas tiene la opcion de reconfigurar el proceso para la proxima ejecucion

func (*MasterWorker) LoadConfig 

func (p *MasterWorker) LoadConfig(PathJSON string) error

LoadConfig : carga el archivo de configuracion de los worker como archivo json

func (*MasterWorker) LoadWorkers 

func (p *MasterWorker) LoadWorkers() (map[string]*Worker, error)

LoadWorkers : carga todos los worker y lo envie en un map

func (*MasterWorker) Loadmaster 

func (p *MasterWorker) Loadmaster() error

Loadmaster : carga todas las configuraciones del master workers

func (*MasterWorker) Printf 

func (p *MasterWorker) Printf(err bool, key, format string, args ...interface{}) error

Printf : Ingresa un texto en los logs asignados.

func (*MasterWorker) ReloadConfig 

func (p *MasterWorker) ReloadConfig() error

ReloadConfig : recarga el archivo de configuracion por cualquier cambio de los workers

func (*MasterWorker) ReloadWork 

func (p *MasterWorker) ReloadWork(key string) error

ReloadWork : recarga un workers para recargar todos sus parametros

func (*MasterWorker) SendWork 

func (p *MasterWorker) SendWork(key string) (*Worker, error)

SendWork : Reconfigura un worker el tiempo de ejecucion

func (*MasterWorker) SetActivo 

func (p *MasterWorker) SetActivo(key string, act bool)

SetActivo : modifica para que se desactive la tarea

func (*MasterWorker) StartDet 

func (p *MasterWorker) StartDet(key, msg string)

StartGen : ejecuta una tarea en paralelo en forma general con un log de inicio de proceso

func (*MasterWorker) StartGen 

func (p *MasterWorker) StartGen(key string)

StartGen : ejecuta una tarea en paralelo en forma general

func (*MasterWorker) Tick 

func (p *MasterWorker) Tick(key string) <-chan time.Time

Tick : regresa el secuencial de tiempo

func (*MasterWorker) Valid 

func (p *MasterWorker) Valid(key string) <-chan bool

Valid : envia si el proceso termino

func (*MasterWorker) ValidWork 

func (p *MasterWorker) ValidWork(key string) bool

ValidWork : valida si existe un worker

type Pc 

type Pc string

Pc : es un tipo para las paletas de colores. 

const (

	/*Green : verde */
	Green Pc = "g"
	/*Red : rojo */
	Red Pc = "r"
	/*Blue : azul */
	Blue Pc = "b"
	/*Cyan : celeste */
	Cyan Pc = "c"
	/*White : blanco */
	White Pc = "w"
	/*Black : negro */
	Black Pc = "bl"
	/*Yellow : amarillo*/
	Yellow Pc = "y"
	/*Magenta : magenta */
	Magenta Pc = "m"
	/*HBlack : negro fuerte */
	HBlack Pc = "hbl"
	/*HRed : rojo fuerte */
	HRed Pc = "hr"
	/*HGreen : verde fuerte */
	HGreen Pc = "hg"
	/*HYellow : amarrillo fuerte */
	HYellow Pc = "hy"
	/*HBlue : azul fuerte */
	HBlue Pc = "hb"
	/*HMagenta : magenta fuerte*/
	HMagenta Pc = "hm"
	/*HCyan : celeste fuerte */
	HCyan Pc = "hc"
	/*HWhite : blanco fuerte */
	HWhite Pc = "hw"
	/*FORMFE : Formato de fecha para los archivo YYYYMMDD*/
	FORMFE = "%d%02d%02d"
)

type StArch 

type StArch struct {
	Path   string `json:"file"`
	IndDir bool   `json:"indir"`
}

StArch : estructura para registra los archivos y generarlos.

func (*StArch) Create 

func (p *StArch) Create() error

Create : crear el archivo o directorio vacio si existe no lo crea

type StArchMa 

type StArchMa []StArch

StArchMa : estructura maestra que crea directorios o archivos masivos.

func (*StArchMa) Create 

func (p *StArchMa) Create() error

Create : crear el archivo o directorio vacio si existe no lo crea

type StLog 

type StLog struct {
	//Directorio contenido
	Dir string
	//Nombre del log mas fecha
	Name string
	//Fecha
	Fe time.Time
	//Prefijo
	Prefix string
}

StLog : Estructura para crear log personalizados por medio de la fecha 

directorio/fecha.log

func NewStLog 

func NewStLog(dir, name, prefix string, fe time.Time) (StLog, error)

NewStLog : Crea una nueva intancia de StLog

func (*StLog) Init 

func (p *StLog) Init() error

Init : Inicializa el log para comenzarlo a usar

func (*StLog) Printf 

func (p *StLog) Printf(format string, args ...interface{}) error

Printf : Ingresa un texto en los logs asignado.

func (*StLog) ValidF 

func (p *StLog) ValidF()

ValidF : valida la fecha del log cargado

type Worker 

type Worker struct {
	// contains filtered or unexported fields
}

Worker : Orquestador de procesos paralelo

func NewWork 

func NewWork(format, tp string, job Job) (Worker, error)

NewWork : crea una tarea con formatos y tipo de de secuencia 1 - Ticker 2 - Time Formatos: 05 hr 54 min 12:16 time

func NewWorkTicker 

func NewWorkTicker(p *time.Ticker, job Job) Worker

NewWorkTicker : crea una tarea mediante un ticker para ponerlo en un servicio

func NewWorkTime 

func NewWorkTime(hr, min int, job Job) (Worker, error)

NewWorkTime : crea una tarea mediante una hora exacta para ponerlo en un servicio

func (*Worker) Err 

func (p *Worker) Err() <-chan error

Err : envia el error en un canal de ejecucion

func (*Worker) Finally 

func (p *Worker) Finally()

Finally : Finalizacion del proceso donde el indicativo reset es para reintentar secuencia

func (*Worker) GetStart 

func (p *Worker) GetStart() bool

GetStart : Envia si el proceso esta en ejecucion

func (*Worker) SetActivo 

func (p *Worker) SetActivo(act bool)

SetActivo : modifica para que se desactive la tarea

func (*Worker) Start 

func (p *Worker) Start()

Start : Ejecuta el proceso paralelo

func (*Worker) StartGen 

func (p *Worker) StartGen()

StartGen : ejecuta una tarea en paralelo en forma general

func (*Worker) StartTime 

func (p *Worker) StartTime()

StartTime : ejecuta un proceso paralelo mediante una hora especifica

func (*Worker) Tick 

func (p *Worker) Tick() <-chan time.Time

Tick : regresa el secuencial de tiempo

func (*Worker) Valid 

func (p *Worker) Valid() <-chan bool

Valid : envia si el proceso termino

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.