Skip to content
Merged
Show file tree
Hide file tree
Changes from 2 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 .github/workflows/lint.yml
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ on:
pull_request:
workflow_dispatch:
env:
GOLANGCI_LINT_VERSION: v2.1.6
GOLANGCI_LINT_VERSION: v2.4.0
GO_VERSION: '1.25'
jobs:
golangci:
Expand Down
8 changes: 8 additions & 0 deletions .golangci.yml
Original file line number Diff line number Diff line change
Expand Up @@ -45,6 +45,10 @@ linters:
- iface
- gosmopolitan
- funcorder

# introduced v2.4.0
- noinlineerr
- wsl_v5
settings:
errcheck:
check-type-assertions: false
Expand Down Expand Up @@ -117,6 +121,10 @@ linters:
- name: if-return
- name: increment-decrement
- name: var-naming
arguments:
- [] # AllowList
- [] # DenyList
- - skip-package-name-checks: true
- name: var-declaration
- name: package-comments
- name: range
Expand Down
1 change: 1 addition & 0 deletions internal/pool/pool_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -41,6 +41,7 @@ type (
}
testWaitChPool struct {
xsync.Pool[chan *testItem]

testHookGetWaitCh func()
}
)
Expand Down
1 change: 1 addition & 0 deletions internal/query/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -128,6 +128,7 @@ func (c *Client) FetchScriptResults(ctx context.Context,

type executeScriptSettings struct {
executeSettings

ttl time.Duration
operationParams *Ydb_Operations.OperationParams
}
Expand Down
1 change: 1 addition & 0 deletions internal/query/options/retry.go
Original file line number Diff line number Diff line change
Expand Up @@ -33,6 +33,7 @@ type (

doTxSettings struct {
doSettings

txSettings tx.Settings
}

Expand Down
1 change: 1 addition & 0 deletions internal/query/result_set.go
Original file line number Diff line number Diff line change
Expand Up @@ -40,6 +40,7 @@ type (
}
resultSetWithClose struct {
*resultSet

close func(ctx context.Context) error
}
)
Expand Down
1 change: 1 addition & 0 deletions internal/topic/configs.go
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,7 @@ import (

type Config struct {
config.Common

Trace *trace.Topic
MaxGrpcMessageSize int
}
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,7 @@ import (
// syncMessageSender extends mockMessageSender with synchronization capabilities
type syncMessageSender struct {
*mockMessageSender

messageReceived empty.Chan
}

Expand Down
1 change: 1 addition & 0 deletions internal/topic/topicmock/grpc_topic_mock.go
Original file line number Diff line number Diff line change
Expand Up @@ -89,6 +89,7 @@ func newGrpcMock(listener net.Listener, topicServiceImpl Ydb_Topic_V1.TopicServi

type mockDiscoveryService struct {
Ydb_Discovery_V1.UnimplementedDiscoveryServiceServer

host string
port uint32
}
Expand Down
2 changes: 1 addition & 1 deletion internal/topic/topicreaderinternal/reader.go
Original file line number Diff line number Diff line change
Expand Up @@ -248,10 +248,10 @@ func (r *Reader) CommitRanges(ctx context.Context, ranges []topicreadercommon.Pu

type ReaderConfig struct {
config.Common
topicStreamReaderConfig

RetrySettings topic.RetrySettings
DefaultBatchConfig ReadMessageBatchOptions
topicStreamReaderConfig
}

type PublicReaderOption func(cfg *ReaderConfig)
Expand Down
Original file line number Diff line number Diff line change
Expand Up @@ -18,6 +18,7 @@ func newMockTransactionWrapper(sessionID, transactinID string) *mockTransaction

type mockTransaction struct {
tx.Identifier

materializedID tx.Identifier
materialized bool
sessionID string
Expand Down
1 change: 1 addition & 0 deletions internal/xerrors/stacktrace.go
Original file line number Diff line number Diff line change
Expand Up @@ -62,6 +62,7 @@ func (e *stackError) Unwrap() error {

type stackTransportError struct {
stackError

status *grpcStatus.Status
}

Expand Down
2 changes: 2 additions & 0 deletions internal/xresolver/xresolver.go
Original file line number Diff line number Diff line change
Expand Up @@ -12,12 +12,14 @@ import (

type dnsBuilder struct {
resolver.Builder

scheme string
trace *trace.Driver
}

type clientConn struct {
resolver.ClientConn

target resolver.Target
trace *trace.Driver
}
Expand Down
2 changes: 2 additions & 0 deletions operation/client.go
Original file line number Diff line number Diff line change
Expand Up @@ -26,6 +26,7 @@ type (
// Experimental: https://github.com/ydb-platform/ydb-go-sdk/blob/master/VERSIONING.md#experimental
listOperationsWithNextToken[PT metadata.Constraint[T], T metadata.TypesConstraint] struct {
listOperations[PT, T]

NextToken string
}
// Experimental: https://github.com/ydb-platform/ydb-go-sdk/blob/master/VERSIONING.md#experimental
Expand All @@ -41,6 +42,7 @@ type (
// Experimental: https://github.com/ydb-platform/ydb-go-sdk/blob/master/VERSIONING.md#experimental
typedOperation[PT metadata.Constraint[T], T metadata.TypesConstraint] struct {
operation

Metadata *T
}
)
Expand Down
1 change: 1 addition & 0 deletions pkg/xtest/grpclogger.go
Original file line number Diff line number Diff line change
Expand Up @@ -68,6 +68,7 @@ func (l GrpcLogger) StreamClientInterceptor(

type grpcLoggerStream struct {
grpc.ClientStream

streamID int64
t testing.TB
}
Expand Down
3 changes: 2 additions & 1 deletion pkg/xtest/logger.go
Original file line number Diff line number Diff line change
Expand Up @@ -12,8 +12,9 @@ func MakeSyncedTest(t *testing.T) *SyncedTest {
}

type SyncedTest struct {
m sync.Mutex
*testing.T

m sync.Mutex
}

func (s *SyncedTest) Cleanup(f func()) {
Expand Down
1 change: 1 addition & 0 deletions scheme/scheme.go
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,7 @@ type EntryType uint

type Directory struct {
Entry

Children []Entry
}

Expand Down
1 change: 1 addition & 0 deletions topic/topicsugar/iterators.go
Original file line number Diff line number Diff line change
Expand Up @@ -136,6 +136,7 @@ func IteratorFunc[T any](

type TypedTopicMessage[T any] struct {
*topicreader.Message

Data T
}

Expand Down
Loading