Skip to content

Commit

Permalink
fix more lint errors
Browse files Browse the repository at this point in the history
  • Loading branch information
rapthead committed Aug 16, 2024
1 parent 7168991 commit 5a27ad7
Show file tree
Hide file tree
Showing 3 changed files with 6 additions and 6 deletions.
2 changes: 1 addition & 1 deletion formats/internal/kv/json/jsonkv.go
Original file line number Diff line number Diff line change
Expand Up @@ -130,7 +130,7 @@ type options struct {

func applyOptions(optFns ...Option) *options {
opts := &options{
filter: func(k []byte) (allowed bool) { return true },
filter: func([]byte) (allowed bool) { return true },
}

for _, o := range optFns {
Expand Down
2 changes: 1 addition & 1 deletion loader/e2e_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -58,7 +58,7 @@ func TestE2E(t *testing.T) {
})

framer := http2.NewFramer(serverConn, serverConn)
framer.ReadMetaHeaders = hpack.NewDecoder(4096, func(f hpack.HeaderField) {})
framer.ReadMetaHeaders = hpack.NewDecoder(4096, func(hpack.HeaderField) {})
framer.SetMaxReadFrameSize(256)
respChan := make(chan uint32, 128)

Expand Down
8 changes: 4 additions & 4 deletions loader/reciever/processor_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -70,9 +70,9 @@ func TestProcessor(t *testing.T) {
b := framer.W.Bytes()

tpPing.ProcessFunc = func(
header frameheader.FrameHeader,
payload []byte,
incomplete bool,
frameheader.FrameHeader,
[]byte,
bool,
) error {
return nil
}
Expand Down Expand Up @@ -205,7 +205,7 @@ func TestHeadersFrameProcessor(t *testing.T) {
const streamID uint32 = 21123

stream := &StreamMock{
OnHeaderFunc: func(k, v string) {},
OnHeaderFunc: func(string, string) {},
}
fp := newHeadersFrameProcessor(&StreamStoreMock{
GetFunc: func(s uint32) types.Stream {
Expand Down

0 comments on commit 5a27ad7

Please sign in to comment.