public_git
/
postgres-operator
mirror of https://github.com/zalando/postgres-operator.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

rename to StringToPointer

This commit is contained in:
Felix Kunde 2022-03-17 19:10:44 +01:00
parent 8f3699e435
commit 458e18bd22
2 changed files with 9 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

16
pkg/cluster/streams_test.go
View File

@ -64,15 +64,15 @@ var (
Tables: map[string]acidv1.StreamTable{ Tables: map[string]acidv1.StreamTable{
"data.bar": acidv1.StreamTable{ "data.bar": acidv1.StreamTable{
EventType: "stream-type-a", EventType: "stream-type-a",
IdColumn: k8sutil.StringPointer("b_id"), IdColumn: k8sutil.StringToPointer("b_id"),
PayloadColumn: k8sutil.StringPointer("b_payload"), PayloadColumn: k8sutil.StringToPointer("b_payload"),
}, },
"data.foobar": acidv1.StreamTable{ "data.foobar": acidv1.StreamTable{
EventType: "stream-type-b", EventType: "stream-type-b",
}, },
}, },
Filter: map[string]*string{ Filter: map[string]*string{
"data.bar": k8sutil.StringPointer("[?(@.source.txId > 500 && @.source.lsn > 123456)]"), "data.bar": k8sutil.StringToPointer("[?(@.source.txId > 500 && @.source.lsn > 123456)]"),
}, },
BatchSize: k8sutil.UInt32ToPointer(uint32(100)), BatchSize: k8sutil.UInt32ToPointer(uint32(100)),
}, },
@ -105,7 +105,7 @@ var (
EventStreams: []zalandov1.EventStream{ EventStreams: []zalandov1.EventStream{
zalandov1.EventStream{ zalandov1.EventStream{
EventStreamFlow: zalandov1.EventStreamFlow{ EventStreamFlow: zalandov1.EventStreamFlow{
PayloadColumn: k8sutil.StringPointer("b_payload"), PayloadColumn: k8sutil.StringToPointer("b_payload"),
Type: constants.EventStreamFlowPgGenericType, Type: constants.EventStreamFlowPgGenericType,
}, },
EventStreamSink: zalandov1.EventStreamSink{ EventStreamSink: zalandov1.EventStreamSink{
@ -114,7 +114,7 @@ var (
Type: constants.EventStreamSinkNakadiType, Type: constants.EventStreamSinkNakadiType,
}, },
EventStreamSource: zalandov1.EventStreamSource{ EventStreamSource: zalandov1.EventStreamSource{
Filter: k8sutil.StringPointer("[?(@.source.txId > 500 && @.source.lsn > 123456)]"), Filter: k8sutil.StringToPointer("[?(@.source.txId > 500 && @.source.lsn > 123456)]"),
Connection: zalandov1.Connection{ Connection: zalandov1.Connection{
DBAuth: zalandov1.DBAuth{ DBAuth: zalandov1.DBAuth{
Name: fmt.Sprintf("fes-user.%s.credentials.postgresql.acid.zalan.do", clusterName), Name: fmt.Sprintf("fes-user.%s.credentials.postgresql.acid.zalan.do", clusterName),
@ -128,7 +128,7 @@ var (
}, },
Schema: "data", Schema: "data",
EventStreamTable: zalandov1.EventStreamTable{ EventStreamTable: zalandov1.EventStreamTable{
IDColumn: k8sutil.StringPointer("b_id"), IDColumn: k8sutil.StringToPointer("b_id"),
Name: "bar", Name: "bar",
}, },
Type: constants.EventStreamSourcePGType, Type: constants.EventStreamSourcePGType,
@ -338,8 +338,8 @@ func TestUpdateFabricEventStream(t *testing.T) {
Tables: map[string]acidv1.StreamTable{ Tables: map[string]acidv1.StreamTable{
"data.bar": acidv1.StreamTable{ "data.bar": acidv1.StreamTable{
EventType: "stream-type-c", EventType: "stream-type-c",
IdColumn: k8sutil.StringPointer("b_id"), IdColumn: k8sutil.StringToPointer("b_id"),
PayloadColumn: k8sutil.StringPointer("b_payload"), PayloadColumn: k8sutil.StringToPointer("b_payload"),
}, },
}, },
BatchSize: k8sutil.UInt32ToPointer(uint32(250)), BatchSize: k8sutil.UInt32ToPointer(uint32(250)),

2
pkg/util/k8sutil/k8sutil.go
View File

@ -41,7 +41,7 @@ func UInt32ToPointer(value uint32) *uint32 {
return &value return &value
} }
func StringPointer(str string) *string { func StringToPointer(str string) *string {
return &str return &str
} }