Skip to content

Commit

Permalink
Disable logging for now, until we switch to slog
Browse files Browse the repository at this point in the history
  • Loading branch information
dzbarsky committed Jul 10, 2023
1 parent cc2850e commit 5a01d49
Show file tree
Hide file tree
Showing 3 changed files with 7 additions and 8 deletions.
2 changes: 1 addition & 1 deletion server/server.go
Original file line number Diff line number Diff line change
Expand Up @@ -24,7 +24,7 @@ func New(methodRegistry map[string]http.HandlerFunc) *http.Server {

// The target endpoint is specified in the `X-Amz-Target` header.
target := r.Header.Get("X-Amz-Target")
log.Println(r.Method, r.URL.String(), target) //, r.Body)
//log.Println(r.Method, r.URL.String(), target) //, r.Body)

w.Header().Add("x-amzn-RequestId", uuid.Must(uuid.NewV4()).String())
method, ok := methodRegistry[target]
Expand Down
3 changes: 1 addition & 2 deletions services/dynamodb/dynamodb.go
Original file line number Diff line number Diff line change
@@ -1,7 +1,6 @@
package dynamodb

import (
"fmt"
"reflect"
"sync"

Expand Down Expand Up @@ -78,7 +77,7 @@ func (d *DynamoDB) CreateTable(input CreateTableInput) (*CreateTableOutput, *aws
}
d.tablesByName[input.TableName] = t

fmt.Println("CreateTable", input)
//fmt.Println("CreateTable", input)
return &CreateTableOutput{
TableDescription: t.toAPI(),
}, nil
Expand Down
10 changes: 5 additions & 5 deletions services/kinesis/kinesis.go
Original file line number Diff line number Diff line change
Expand Up @@ -188,7 +188,7 @@ func (k *Kinesis) PutRecord(input PutRecordInput) (*PutRecordOutput, *awserrors.
_, streamName = arn.ExtractId(input.StreamARN)
}

fmt.Println("PutRecord", streamName)
//fmt.Println("PutRecord", streamName)

var hashKey big.Int
if input.ExplicitHashKey != "" {
Expand Down Expand Up @@ -252,7 +252,7 @@ func (k *Kinesis) lockedGetShard(streamName, shardId string) (*Shard, *awserrors

// https://docs.aws.amazon.com/kinesis/latest/APIReference/API_GetRecords.html
func (k *Kinesis) GetRecords(input GetRecordsInput) (*GetRecordsOutput, *awserrors.Error) {
fmt.Println("GetRecords", input.ShardIterator)
//fmt.Println("GetRecords", input.ShardIterator)

streamName, shardId, start, err := decodeShardIterator(input.ShardIterator)
if err != nil {
Expand All @@ -278,7 +278,7 @@ func (k *Kinesis) GetRecords(input GetRecordsInput) (*GetRecordsOutput, *awserro
}

output.NextShardIterator = encodeShardIterator(streamName, shardId, currIndex)
fmt.Println("READ RECORDS", input.ShardIterator, output.NextShardIterator)
//fmt.Println("READ RECORDS", input.ShardIterator, output.NextShardIterator)
return output, nil
}

Expand All @@ -289,7 +289,7 @@ func (k *Kinesis) GetShardIterator(input GetShardIteratorInput) (*GetShardIterat
_, streamName = arn.ExtractId(input.StreamARN)
}

fmt.Println("GetShardIterator", streamName, input)
//fmt.Println("GetShardIterator", streamName, input)

output := &GetShardIteratorOutput{}
switch input.ShardIteratorType {
Expand Down Expand Up @@ -328,7 +328,7 @@ func (k *Kinesis) ListShards(input ListShardsInput) (*ListShardsOutput, *awserro
_, streamName = arn.ExtractId(input.StreamARN)
}

fmt.Println("ListShards", streamName)
//fmt.Println("ListShards", streamName)

k.mu.Lock()
defer k.mu.Unlock()
Expand Down

0 comments on commit 5a01d49

Please sign in to comment.