Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension


Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
2 changes: 1 addition & 1 deletion chanx/broadcaster.go
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ import (
"fmt"
"sync"

"go.atoms.co/lib/iox"
"go.atoms.co/iox"
"go.atoms.co/lib/syncx"
)

Expand Down
2 changes: 1 addition & 1 deletion chanx/chan.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import (
"sync"
"time"

"go.atoms.co/lib/iox"
"go.atoms.co/iox"
)

// NewFixed returns a new closed chan with the given elements.
Expand Down
4 changes: 2 additions & 2 deletions chanx/chan_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,9 +6,9 @@ import (
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"

"go.atoms.co/lib/testing/assertx"
"go.atoms.co/iox"
"go.atoms.co/lib/chanx"
"go.atoms.co/lib/iox"
"go.atoms.co/lib/testing/assertx"
)

func TestDrain(t *testing.T) {
Expand Down
3 changes: 2 additions & 1 deletion go.mod
Original file line number Diff line number Diff line change
@@ -1,6 +1,6 @@
module go.atoms.co/lib

go 1.24.9
go 1.24.11

require (
contrib.go.opencensus.io/exporter/prometheus v0.4.1
Expand All @@ -9,6 +9,7 @@ require (
github.com/google/uuid v1.6.0
github.com/prometheus/client_golang v1.18.0
github.com/stretchr/testify v1.11.1
go.atoms.co/iox v1.0.0
go.atoms.co/slicex v1.1.0
go.opencensus.io v0.24.0
go.opentelemetry.io/otel v1.32.0
Expand Down
2 changes: 2 additions & 0 deletions go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -226,6 +226,8 @@ github.com/stretchr/testify v1.11.1/go.mod h1:wZwfW3scLgRK+23gO65QZefKpKQRnfz6sD
github.com/yuin/goldmark v1.1.25/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
github.com/yuin/goldmark v1.1.27/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
github.com/yuin/goldmark v1.1.32/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=
go.atoms.co/iox v1.0.0 h1:tSCyphSPh17TnjhZn5OaGScJcO5aac2acOjO9M76skE=
go.atoms.co/iox v1.0.0/go.mod h1:2PpoGBhfToxA0U2UfXkDSskPMiUyQzKi9DZtANqolew=
go.atoms.co/slicex v1.1.0 h1:kxlUQRtwvt/iDiYAPGz+drM3CmVw1WI9AZLQ/nvkoCU=
go.atoms.co/slicex v1.1.0/go.mod h1:le4qkj6I+WTrEXXtTRyKF+or6wI5wOL9NW3Atk/zr5E=
go.opencensus.io v0.21.0/go.mod h1:mSImk1erAIZhrmZN+AvHh14ztQfjbGwt4TtuofqLduU=
Expand Down
76 changes: 0 additions & 76 deletions iox/closer.go

This file was deleted.

61 changes: 0 additions & 61 deletions iox/status.go

This file was deleted.

2 changes: 0 additions & 2 deletions metrics/metrics.go
Original file line number Diff line number Diff line change
Expand Up @@ -18,7 +18,6 @@ const (
Exponential Distribution = iota
Uniform
UserDefined
version = "1.0.1"
)

type UnitType string
Expand Down Expand Up @@ -177,7 +176,6 @@ func Init(appName string) error {
// set the default app value for all metrics.
initAppName(appName)


err := view.Register(ocgrpc.DefaultServerViews...)
if err != nil {
return err
Expand Down
4 changes: 2 additions & 2 deletions net/grpcx/stream.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,10 +6,10 @@ import (

"google.golang.org/grpc"

"go.atoms.co/lib/log"
"go.atoms.co/iox"
"go.atoms.co/lib/chanx"
"go.atoms.co/lib/contextx"
"go.atoms.co/lib/iox"
"go.atoms.co/lib/log"
)

const (
Expand Down
2 changes: 1 addition & 1 deletion signalx/signal.go
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ import (
"os/signal"
"syscall"

"go.atoms.co/lib/iox"
"go.atoms.co/iox"
)

// InterruptChan returns a channel that receives a signal when the process receives either syscall.SIGTERM or syscall.SIGINT
Expand Down
2 changes: 1 addition & 1 deletion syncx/lock.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ package syncx
import (
"sync/atomic"

"go.atoms.co/lib/iox"
"go.atoms.co/iox"
)

// Lock is a chan-based closeable semaphore with N concurrent locks granted. If N=1, it acts as a mutex.
Expand Down
Loading