hauxe

// FileSystem custom file system handler
type FileSystem struct {
	fs http.FileSystem
}

// Open opens file
func (fs FileSystem) Open(path string) (http.File, error) {
	f, err := fs.fs.Open(path)
	if err != nil {
		return nil, err

hauxe

package main

import (
	"sync"
	"time"
)

// Job define job interface
type Job interface {
	Execute()

hauxe

package utils

import (
	"os"
	"testing"

	"github.com/stretchr/testify/require"
)

func TestGetEnvT(t *testing.T) {

hauxe

package utils

import (
	"os"
	"strconv"
)

type Env[T any] struct {
	DefaultVal T
	FromString func(string) (T, error)

hauxe

package main

import (
	"flag"
	"log"
	"net/http"
	"strings"
)

func main() {

hauxe

package main

import (
	"flag"
	"log"
	"net/http"
	"strings"
)

// FileSystem custom file system handler

hauxe

// AND function combines all signal from channels into a single channel with And condition
func AND(channels ...<-chan interface{}) <-chan interface{} {
	switch len(channels) {
	case 0:
		return nil
	case 1:
		return channels[0]
	}
	andDone := make(chan interface{})
	collector := make(chan interface{}, len(channels))

hauxe

package main

import (
	"bytes"
	"fmt"
	"io"
	"log"
	"os"
	"sync"
)

hauxe

// OR function combines all signal from channels into a single channel with Or condition
func OR(channels ...<-chan interface{}) <-chan interface{} {
	switch len(channels) {
	case 0:
		return nil
	case 1:
		return channels[0]
	}
	orDone := make(chan interface{})
	go func() {

hauxe

package main

import (
	"log"
	"sync"
)

func main() {
	cond := sync.NewCond(&sync.Mutex{})
	var wg1 sync.WaitGroup