Skip to content

Welcome to Kolosys (Colossal Systems) 🚀

Building enterprise-grade Go libraries for high-performance applications

🎯 Our Mission

Kolosys creates production-ready Go libraries that solve complex challenges in concurrency, event processing, time-based operations, and Discord development. We focus on developer experience, performance, and reliability.

Core Principles

  • 🏗️ Context-Aware Design - Proper cancellation and timeout handling throughout
  • ⚡ Performance First - Zero-allocation hot paths and minimal overhead
  • 🛡️ Production Ready - Enterprise-grade reliability with comprehensive testing
  • 🎨 Developer Experience - Intuitive APIs that developers love to use
  • 🔧 Zero Dependencies - Core functionality without external dependencies

🏆 Featured Libraries

Ion - Concurrency & Scheduling Primitives

The backbone for concurrent Go applications with robust, context-aware primitives.

// Worker pool with graceful shutdown
pool := workerpool.New(4, 20, workerpool.WithName("api-workers"))
defer pool.Shutdown(ctx)

// Fair semaphore with configurable modes
sem := semaphore.NewWeighted(10, semaphore.WithFairness(semaphore.FIFO))

// Multi-tier rate limiting
limiter := ratelimit.NewMultiTier(
    ratelimit.NewTokenBucket(ratelimit.PerSecond(100), 20),
    ratelimit.NewLeakyBucket(ratelimit.PerMinute(1000), 100),
)

Key Features:

  • Worker Pools - Bounded pools with context-aware submission and metrics
  • Semaphores - Weighted fair semaphores with FIFO/LIFO/None fairness modes
  • Rate Limiters - Token bucket, leaky bucket, and multi-tier implementations
  • Pluggable Observability - Metrics, logging, and tracing hooks

Coming Soon: Circuit breakers, pipelines, task scheduling, and resource management


Nova - Event Processing & Messaging

Enterprise-grade event systems with predictable semantics and robust delivery guarantees.

// Event emitter with Ion-powered async processing
emitter := emitter.New(emitter.Config{
    WorkerPool: pool,
    AsyncMode:  true,
})

// Event bus with topic routing
bus := bus.New(bus.Config{
    DefaultDeliveryMode: bus.AtLeastOnce,
    DefaultPartitions:   4,
})

// Saga orchestration for complex workflows
saga := saga.New(saga.Config{Store: store})

Key Features:

  • Event Emitters - Sync/async emission with middleware support
  • Event Bus - Topic-based routing with delivery guarantees
  • Listeners - Lifecycle management with retry policies and circuit breakers
  • Sagas - Event-driven workflow orchestration with compensation
  • Memory Store - In-memory event storage with replay capabilities

Production Ready: At-least-once delivery, exactly-once semantics, and comprehensive observability


TimeCapsule - Time-Locked Value Storage

A lightweight library for storing values that are only retrievable after a specified time.

// Store a promotional code that unlocks in 24 hours
capsule := timecapsule.New()
capsule.Store(ctx, "holiday-promo", "SAVE50", time.Now().Add(24*time.Hour))

// Try to open (will fail if still locked)
value, err := capsule.Open[string](ctx, "holiday-promo")
if errors.Is(err, timecapsule.ErrStillLocked) {
    fmt.Println("Promo code not yet available")
}

Perfect For:

  • Delayed feature rollouts and configuration changes
  • Time-locked promotional codes and trials
  • Secure temporal value storage
  • Scheduled task coordination

Discord Libraries - Discord Bot Development

High-performance, type-safe Discord bot development for Go.

kolosys/discord - Core Library

client := discord.NewClient(token,
    discord.WithIntents(discord.IntentGuildMessages),
    discord.WithCache(cache.NewMemoryCache()),
)

// Type-safe event handlers
client.OnMessageCreate(func(ctx context.Context, event *discord.MessageCreateEvent) error {
    if event.Message.Content == "!ping" {
        return client.SendMessage(ctx, event.Message.ChannelID, "Pong!")
    }
    return nil
})

kolosys/discord-types - Type Definitions

Complete Discord API v10+ type definitions with helper utilities for permissions, snowflakes, and formatting.

Features:

  • Complete Discord API coverage including 2024 features (Polls, User Apps, etc.)
  • Zero-reflection event handling for maximum performance
  • Advanced rate limiting with global, per-route, and per-resource limits
  • Enterprise observability with OpenTelemetry integration
  • Plugin system for extensible functionality

🌐 Documentation & Resources

🏠 Central Hub

Visit kolosys.com for our comprehensive documentation platform featuring:

  • 📚 Unified Documentation - All libraries in one searchable platform
  • 🚀 Quick Start Guides - Get up and running in minutes
  • 📖 API References - Auto-generated from source code with examples
  • 💡 Tutorials & Examples - Real-world usage patterns and best practices
  • 📊 Performance Benchmarks - Detailed performance characteristics

🔧 Developer Resources

  • Getting Started: Step-by-step guides for each library
  • Architecture Decisions: Documented design rationale and trade-offs
  • Migration Guides: Smooth transitions between versions
  • Performance Guides: Optimization tips and benchmarking results
  • Integration Examples: Popular framework integrations

📊 Performance & Quality

Benchmark Highlights

  • Ion WorkerPool: <200ns Submit hot path, 0 allocations in steady state
  • Ion Semaphore: <150ns Acquire/Release uncontended, <20% fairness overhead
  • Nova Emitter: >100K events/second throughput on standard hardware
  • TimeCapsule: <100ns Store/Open operations with minimal memory overhead

Quality Assurance

  • 🧪 >95% Test Coverage - Comprehensive unit, integration, and performance tests
  • 🔒 Zero Critical CVEs - Regular security audits and dependency updates
  • 📈 Performance Monitoring - Continuous benchmarking and regression detection
  • 🔍 Static Analysis - Advanced linting, formatting, and vulnerability scanning

🤝 Community & Contributing

Getting Involved

We welcome contributions from developers of all experience levels!

  1. 🌟 Start Small - Look for "good first issue" labels
  2. 📖 Read the Docs - Familiarize yourself with our libraries at kolosys.com
  3. 💬 Join Discussions - Use GitHub Discussions for questions and ideas
  4. 🛠️ Follow Guidelines - Each repository has detailed CONTRIBUTING.md files

Quick Contribution Setup

# Clone any project
git clone https://github.com/kolosys/<library-name>
cd <library-name>

# Install dependencies and run tests
go mod download
go test -v -race ./...

# Format and lint
go fmt ./...
golangci-lint run

# Run benchmarks
go test -bench=. -benchmem ./...

Community Guidelines

  • Be Respectful - We maintain a welcoming environment for all contributors
  • Ask Questions - No question is too basic; we're here to help
  • Share Ideas - Your feedback helps shape the future of our libraries
  • Follow Best Practices - We maintain high code quality standards

🚀 Ecosystem Overview

Library Dependencies

┌─────────────┐    ┌──────────────┐    ┌─────────────────┐
│ TimeCapsule │    │    Nova      │    │    Discord      │
│             │    │              │    │                 │
│  Time-locked│    │ Event System │    │  Bot Framework  │
│   Storage   │    │              │    │                 │
└─────────────┘    └──────┬───────┘    └─────────────────┘
                          │
                          ▼
                   ┌──────────────┐
                   │     Ion      │
                   │              │
                   │ Concurrency  │
                   │  Primitives  │
                   └──────────────┘
  • Ion serves as the foundational layer for concurrency and scheduling
  • Nova builds on Ion for high-performance event processing
  • TimeCapsule operates independently for time-based storage
  • Discord provides specialized bot development capabilities

Integration Examples

Microservice Architecture

// Use Ion for request processing
pool := workerpool.New(10, 100)
limiter := ratelimit.NewTokenBucket(ratelimit.PerSecond(1000), 100)

// Use Nova for event-driven communication
emitter := emitter.New(emitter.Config{WorkerPool: pool})
bus := bus.New(bus.Config{DefaultPartitions: 4})

// Use TimeCapsule for delayed operations
capsule := timecapsule.New()

🎯 Roadmap & Vision

2025 Goals

  • 🏆 Market Leadership - Become the go-to choice for Go concurrency primitives
  • 🌍 Ecosystem Growth - Expand integration examples with popular frameworks
  • ⚡ Performance Excellence - Maintain industry-leading benchmarks
  • 👥 Community Building - Foster active contributor base and feedback loops
  • 📚 Documentation Excellence - Best-in-class developer experience

Future Innovations

  • Distributed Primitives - Coordination for distributed systems
  • Cloud-Native Features - Kubernetes operators and service mesh integration
  • Advanced Observability - Enhanced metrics, tracing, and debugging tools
  • Language Interop - C/Python bindings for broader ecosystem adoption

🔗 Quick Links

Project Status

Library Version Status Documentation
Ion v0.1.1 ✅ Stable docs
Nova v0.1.0 🚧 Beta docs
TimeCapsule v1.0.0 ✅ Stable docs
Discord v0.1.0 🚧 Beta docs
Discord-Types v0.1.0 🚧 Beta docs

Building reliable software, one library at a time

🌟 Star our repos📖 Read the docs💬 Join discussions

Popular repositories Loading

  1. timecapsule timecapsule Public

    A lightweight library that lets developers store values that are only retrievable after a specified time. It acts like a “sealed envelope” or “time capsule” for objects, configs, or state.

    Go 1

  2. ion ion Public

    Robust, context-aware concurrency and scheduling primitives for Go applications

    Go

  3. .github .github Public

  4. discord discord Public

  5. .actions .actions Public

    Go

  6. discord-types discord-types Public

    Discord API types for Go that are kept up to date for use in Discord bot library creation.

    Go

Repositories

Showing 9 of 9 repositories

Top languages

Loading…

Most used topics

Loading…