luciano/kinesis-consumer
1
0
Fork 0
Code Issues Pull requests Projects Releases Packages Wiki Activity Actions

#12 rename package

Browse source
This commit is contained in:
Alex Senger 2024-04-10 17:19:07 +02:00
parent c169ad4789
commit 7e0806126c
No known key found for this signature in database
GPG key ID: 0B4A96F8AF6934CF
7 changed files with 16 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
consumer_test.go
View file

@ -10,7 +10,7 @@ import (
"github.com/aws/aws-sdk-go-v2/service/kinesis"
"github.com/aws/aws-sdk-go-v2/service/kinesis/types"
store "github.com/harlow/kinesis-consumer/store/memory"
store "github.com/alexgridx/kinesis-consumer/store/memory"
)
var records = []types.Record{

5
examples/consumer-dynamodb/main.go
View file

@ -21,8 +21,9 @@ import (
ddbtypes "github.com/aws/aws-sdk-go-v2/service/dynamodb/types"
"github.com/aws/aws-sdk-go-v2/service/kinesis"
"github.com/aws/aws-sdk-go-v2/service/kinesis/types"
consumer "github.com/harlow/kinesis-consumer"
storage "github.com/harlow/kinesis-consumer/store/ddb"
consumer "github.com/alexgridx/kinesis-consumer"
storage "github.com/alexgridx/kinesis-consumer/store/ddb"
)
// kick off a server for exposing scan metrics

5
examples/consumer-mysql/main.go
View file

@ -13,8 +13,9 @@ import (
"github.com/aws/aws-sdk-go-v2/config"
"github.com/aws/aws-sdk-go-v2/credentials"
"github.com/aws/aws-sdk-go-v2/service/kinesis"
consumer "github.com/harlow/kinesis-consumer"
store "github.com/harlow/kinesis-consumer/store/mysql"
consumer "github.com/alexgridx/kinesis-consumer"
store "github.com/alexgridx/kinesis-consumer/store/mysql"
)
func main() {

5
examples/consumer-postgres/main.go
View file

@ -13,8 +13,9 @@ import (
"github.com/aws/aws-sdk-go-v2/config"
"github.com/aws/aws-sdk-go-v2/credentials"
"github.com/aws/aws-sdk-go-v2/service/kinesis"
consumer "github.com/harlow/kinesis-consumer"
store "github.com/harlow/kinesis-consumer/store/postgres"
consumer "github.com/alexgridx/kinesis-consumer"
store "github.com/alexgridx/kinesis-consumer/store/postgres"
)
func main() {

5
examples/consumer-redis/main.go
View file

@ -12,8 +12,9 @@ import (
"github.com/aws/aws-sdk-go-v2/config"
"github.com/aws/aws-sdk-go-v2/credentials"
"github.com/aws/aws-sdk-go-v2/service/kinesis"
consumer "github.com/harlow/kinesis-consumer"
store "github.com/harlow/kinesis-consumer/store/redis"
consumer "github.com/alexgridx/kinesis-consumer"
store "github.com/alexgridx/kinesis-consumer/store/redis"
)
// A myLogger provides a minimalistic logger satisfying the Logger interface.

3
examples/consumer/main.go
View file

@ -13,7 +13,8 @@ import (
"github.com/aws/aws-sdk-go-v2/config"
"github.com/aws/aws-sdk-go-v2/credentials"
"github.com/aws/aws-sdk-go-v2/service/kinesis"
consumer "github.com/harlow/kinesis-consumer"
consumer "github.com/alexgridx/kinesis-consumer"
)
// A myLogger provides a minimalistic logger satisfying the Logger interface.

2
go.mod
View file

@ -1,4 +1,4 @@
module github.com/harlow/kinesis-consumer
module github.com/alexgridx/kinesis-consumer
go 1.22