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 .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 examples/topic/topicreader/topicreader_handler.go
Original file line number Diff line number Diff line change
Expand Up @@ -28,6 +28,7 @@ func StartReader(ctx context.Context, db *ydb.Driver) (*topiclistener.TopicListe

type TopicEventsHandler struct {
topiclistener.BaseHandler

listener *topiclistener.TopicListener

m sync.Mutex
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