Skip to content

Commit

Permalink
#197 Added PreprocessRecord() (#204)
Browse files Browse the repository at this point in the history
* #197 Update dependencies

* #197 Prepare for versioned release
  • Loading branch information
docktermj authored Oct 1, 2024
1 parent 31c3363 commit 524d1ac
Show file tree
Hide file tree
Showing 11 changed files with 197 additions and 110 deletions.
6 changes: 6 additions & 0 deletions CHANGELOG.md
Original file line number Diff line number Diff line change
Expand Up @@ -9,6 +9,12 @@ and this project adheres to [Semantic Versioning].

-

## [0.8.3] - 2024-10-01

### Added in 0.8.3

- Method `PreprocessRecord()`

## [0.8.2] - 2024-09-11

### Changed in 0.8.2
Expand Down
6 changes: 3 additions & 3 deletions go.mod
Original file line number Diff line number Diff line change
Expand Up @@ -10,8 +10,8 @@ require (
github.com/senzing-garage/go-logging v1.5.1
github.com/senzing-garage/go-messaging v1.5.2
github.com/senzing-garage/go-observing v0.3.3
github.com/senzing-garage/sz-sdk-go v0.14.1
github.com/senzing-garage/sz-sdk-proto v0.7.7
github.com/senzing-garage/sz-sdk-go v0.14.2
github.com/senzing-garage/sz-sdk-proto v0.7.8
github.com/stretchr/testify v1.9.0
google.golang.org/grpc v1.67.1
)
Expand All @@ -24,7 +24,7 @@ require (
golang.org/x/net v0.29.0 // indirect
golang.org/x/sys v0.25.0 // indirect
golang.org/x/text v0.18.0 // indirect
google.golang.org/genproto/googleapis/rpc v0.0.0-20240903143218-8af14fe29dc1 // indirect
google.golang.org/genproto/googleapis/rpc v0.0.0-20240930140551-af27646dc61f // indirect
google.golang.org/protobuf v1.34.2 // indirect
gopkg.in/yaml.v3 v3.0.1 // indirect
)
12 changes: 6 additions & 6 deletions go.sum
Original file line number Diff line number Diff line change
Expand Up @@ -21,10 +21,10 @@ github.com/senzing-garage/go-messaging v1.5.2 h1:lU9W2HV3zKQsDU9Vs7lwe/C/LbHVCMn
github.com/senzing-garage/go-messaging v1.5.2/go.mod h1:iEWGVuDGWjolIkwLqnn9oJS7ifF3aoZjTtI44tf1gWQ=
github.com/senzing-garage/go-observing v0.3.3 h1:AhQYgOG012sDZtWXYcXVAaS5qEoDjlWmPYJDVCUZ/g0=
github.com/senzing-garage/go-observing v0.3.3/go.mod h1:qFUi5Dwb6vmd7izTZGjGbWKUGRHzWzsgbsX3oNSD198=
github.com/senzing-garage/sz-sdk-go v0.14.1 h1:bJOOHROg/SMEZ8KhCypVMr7scMzCuSpDpcMR9e4gzsA=
github.com/senzing-garage/sz-sdk-go v0.14.1/go.mod h1:9Kvr/NpNoU1DSKpVXmZ+91/WFMKvXmjuubFhAiS69Ts=
github.com/senzing-garage/sz-sdk-proto v0.7.7 h1:yD2gL8OBo8h9UfSCORXB3ilCckW+9zdPC87jURIU0IQ=
github.com/senzing-garage/sz-sdk-proto v0.7.7/go.mod h1:CGtcd5FweXuIpOfbTlRPYCkk5Z0AmX6dGuVkMkRwNQ8=
github.com/senzing-garage/sz-sdk-go v0.14.2 h1:1LksQW0+epSY0DhlxThxrnfeDwgyLPvyqG9NehZmz04=
github.com/senzing-garage/sz-sdk-go v0.14.2/go.mod h1:rj9HH6qo+kW5PsFSRnEIUQqDZBE34gZjQGsDvAxw6dI=
github.com/senzing-garage/sz-sdk-proto v0.7.8 h1:kh1Xas66cPj41rOwdfGZ54agyiQJCxh82QXH+mT+qEk=
github.com/senzing-garage/sz-sdk-proto v0.7.8/go.mod h1:zvm6iJkUSGyXCVSjDE3KzL815uRcoEXocgGsPc0lWAQ=
github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=
github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=
golang.org/x/exp v0.0.0-20240909161429-701f63a606c0 h1:e66Fs6Z+fZTbFBAxKfP3PALWBtpfqks2bwGcexMxgtk=
Expand All @@ -35,8 +35,8 @@ golang.org/x/sys v0.25.0 h1:r+8e+loiHxRqhXVl6ML1nO3l1+oFoWbnlu2Ehimmi34=
golang.org/x/sys v0.25.0/go.mod h1:/VUhepiaJMQUp4+oa/7Zr1D23ma6VTLIYjOOTFZPUcA=
golang.org/x/text v0.18.0 h1:XvMDiNzPAl0jr17s6W9lcaIhGUfUORdGCNsuLmPG224=
golang.org/x/text v0.18.0/go.mod h1:BuEKDfySbSR4drPmRPG/7iBdf8hvFMuRexcpahXilzY=
google.golang.org/genproto/googleapis/rpc v0.0.0-20240903143218-8af14fe29dc1 h1:pPJltXNxVzT4pK9yD8vR9X75DaWYYmLGMsEvBfFQZzQ=
google.golang.org/genproto/googleapis/rpc v0.0.0-20240903143218-8af14fe29dc1/go.mod h1:UqMtugtsSgubUsoxbuAoiCXvqvErP7Gf0so0mK9tHxU=
google.golang.org/genproto/googleapis/rpc v0.0.0-20240930140551-af27646dc61f h1:cUMEy+8oS78BWIH9OWazBkzbr090Od9tWBNtZHkOhf0=
google.golang.org/genproto/googleapis/rpc v0.0.0-20240930140551-af27646dc61f/go.mod h1:UqMtugtsSgubUsoxbuAoiCXvqvErP7Gf0so0mK9tHxU=
google.golang.org/grpc v1.67.1 h1:zWnc1Vrcno+lHZCOofnIMvycFcc0QRGIzm9dhnDX68E=
google.golang.org/grpc v1.67.1/go.mod h1:1gLDyUQU7CTLJI90u3nXZ9ekeghjeM7pTDZlqFNg2AA=
google.golang.org/protobuf v1.34.2 h1:6xV6lTsCfpGD21XK49h7MhtcApnLqkfYgPcdHftf6hg=
Expand Down
30 changes: 15 additions & 15 deletions szconfig/szconfig.go
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ const (
// ----------------------------------------------------------------------------

/*
The AddDataSource method adds a new data source to an existing in-memory configuration.
Method AddDataSource adds a new data source to an existing in-memory configuration.
Input
- ctx: A context to control lifecycle.
Expand Down Expand Up @@ -71,7 +71,7 @@ func (client *Szconfig) AddDataSource(ctx context.Context, configHandle uintptr,
}

/*
The CloseConfig method terminates an in-memory configuration and cleans up system resources.
Method CloseConfig terminates an in-memory configuration and cleans up system resources.
After calling CloseConfig, the configuration handle can no longer be used and is invalid.
Input
Expand All @@ -97,8 +97,8 @@ func (client *Szconfig) CloseConfig(ctx context.Context, configHandle uintptr) e
}

/*
The CreateConfig method creates an in-memory configuration using the default template.
The default template is the Senzing configuration JSON document file, `g2config.json`, located in the PIPELINE.RESOURCEPATH path.
Method CreateConfig creates an in-memory configuration using the default template.
The default template is the Senzing configuration JSON document file, g2config.json, located in the PIPELINE.RESOURCEPATH path.
The returned configHandle is used by the [Szconfig.AddDataSource], [Szconfig.DeleteDataSource],
[Szconfig.ExportConfig], and [Szconfig.GetDataSources] methods.
The configHandle is terminated by the [Szconfig.CloseConfig] method.
Expand Down Expand Up @@ -128,7 +128,7 @@ func (client *Szconfig) CreateConfig(ctx context.Context) (uintptr, error) {
}

/*
The DeleteDataSource method removes a data source from an in-memory configuration.
Method DeleteDataSource removes a data source from an in-memory configuration.
Input
- ctx: A context to control lifecycle.
Expand Down Expand Up @@ -156,7 +156,7 @@ func (client *Szconfig) DeleteDataSource(ctx context.Context, configHandle uintp
}

/*
The Destroy method is a Null function for sz-sdk-go-grpc.
Method Destroy is a Null function for sz-sdk-go-grpc.
Input
- ctx: A context to control lifecycle.
Expand All @@ -178,7 +178,7 @@ func (client *Szconfig) Destroy(ctx context.Context) error {
}

/*
The ExportConfig method creates a Senzing configuration JSON document representation of an in-memory configuration.
Method ExportConfig creates a Senzing configuration JSON document representation of an in-memory configuration.
Input
- ctx: A context to control lifecycle.
Expand Down Expand Up @@ -207,7 +207,7 @@ func (client *Szconfig) ExportConfig(ctx context.Context, configHandle uintptr)
}

/*
The GetDataSources method returns a JSON document containing data sources defined in an in-memory configuration.
Method GetDataSources returns a JSON document containing data sources defined in an in-memory configuration.
Input
- ctx: A context to control lifecycle.
Expand Down Expand Up @@ -236,7 +236,7 @@ func (client *Szconfig) GetDataSources(ctx context.Context, configHandle uintptr
}

/*
The ImportConfig method creates a new in-memory configuration from a JSON document.
Method ImportConfig creates a new in-memory configuration from a JSON document.
The returned configHandle is used by the [Szconfig.AddDataSource], [Szconfig.DeleteDataSource],
[Szconfig.ExportConfig], and [Szconfig.GetDataSources] methods.
The configHandle is terminated by the [Szconfig.CloseConfig] method.
Expand Down Expand Up @@ -271,7 +271,7 @@ func (client *Szconfig) ImportConfig(ctx context.Context, configDefinition strin
// ----------------------------------------------------------------------------

/*
The GetObserverOrigin method returns the "origin" value of past Observer messages.
Method GetObserverOrigin returns the "origin" value of past Observer messages.
Input
- ctx: A context to control lifecycle.
Expand All @@ -285,7 +285,7 @@ func (client *Szconfig) GetObserverOrigin(ctx context.Context) string {
}

/*
The Initialize method is a Null function for sz-sdk-go-grpc.
Method Initialize is a Null function for sz-sdk-go-grpc.
Input
- ctx: A context to control lifecycle.
Expand Down Expand Up @@ -314,7 +314,7 @@ func (client *Szconfig) Initialize(ctx context.Context, instanceName string, set
}

/*
The RegisterObserver method adds the observer to the list of observers notified.
Method RegisterObserver adds the observer to the list of observers notified.
Input
- ctx: A context to control lifecycle.
Expand Down Expand Up @@ -343,7 +343,7 @@ func (client *Szconfig) RegisterObserver(ctx context.Context, observer observer.
}

/*
The SetLogLevel method sets the level of logging.
Method SetLogLevel sets the level of logging.
Input
- ctx: A context to control lifecycle.
Expand Down Expand Up @@ -373,7 +373,7 @@ func (client *Szconfig) SetLogLevel(ctx context.Context, logLevelName string) er
}

/*
The SetObserverOrigin method sets the "origin" value in future Observer messages.
Method SetObserverOrigin sets the "origin" value in future Observer messages.
Input
- ctx: A context to control lifecycle.
Expand All @@ -385,7 +385,7 @@ func (client *Szconfig) SetObserverOrigin(ctx context.Context, origin string) {
}

/*
The UnregisterObserver method removes the observer to the list of observers notified.
Method UnregisterObserver removes the observer to the list of observers notified.
Input
- ctx: A context to control lifecycle.
Expand Down
26 changes: 13 additions & 13 deletions szconfigmanager/szconfigmanager.go
Original file line number Diff line number Diff line change
Expand Up @@ -38,7 +38,7 @@ const (
// ----------------------------------------------------------------------------

/*
The AddConfig method adds a Senzing configuration JSON document to the Senzing datastore.
Method AddConfig adds a Senzing configuration JSON document to the Senzing datastore.
Input
- ctx: A context to control lifecycle.
Expand Down Expand Up @@ -69,7 +69,7 @@ func (client *Szconfigmanager) AddConfig(ctx context.Context, configDefinition s
}

/*
The Destroy method is a Null function for sz-sdk-go-grpc.
Method Destroy is a Null function for sz-sdk-go-grpc.
Input
- ctx: A context to control lifecycle.
Expand All @@ -91,7 +91,7 @@ func (client *Szconfigmanager) Destroy(ctx context.Context) error {
}

/*
The GetConfig method retrieves a specific Senzing configuration JSON document from the Senzing datastore.
Method GetConfig retrieves a specific Senzing configuration JSON document from the Senzing datastore.
Input
- ctx: A context to control lifecycle.
Expand Down Expand Up @@ -119,7 +119,7 @@ func (client *Szconfigmanager) GetConfig(ctx context.Context, configID int64) (s
}

/*
The GetConfigs method retrieves a list of Senzing configuration JSON documents from the Senzing datastore.
Method GetConfigs retrieves a list of Senzing configuration JSON documents from the Senzing datastore.
Input
- ctx: A context to control lifecycle.
Expand All @@ -146,7 +146,7 @@ func (client *Szconfigmanager) GetConfigs(ctx context.Context) (string, error) {
}

/*
The GetDefaultConfigID method retrieves the default Senzing configuration JSON document identifier from the Senzing datastore.
Method GetDefaultConfigID retrieves the default Senzing configuration JSON document identifier from the Senzing datastore.
Note: this may not be the currently active in-memory configuration.
See [Szconfigmanager.SetDefaultConfigID] and [Szconfigmanager.ReplaceDefaultConfigID] for more details.
Expand Down Expand Up @@ -176,7 +176,7 @@ func (client *Szconfigmanager) GetDefaultConfigID(ctx context.Context) (int64, e

/*
Similar to the [Szconfigmanager.SetDefaultConfigID] method,
the ReplaceDefaultConfigID method sets which Senzing configuration JSON document is used when initializing or reinitializing the system.
method ReplaceDefaultConfigID sets which Senzing configuration JSON document is used when initializing or reinitializing the system.
The difference is that ReplaceDefaultConfigID only succeeds when the old Senzing configuration JSON document identifier
is the existing default when the new identifier is applied.
In other words, if currentDefaultConfigID is no longer the "old" identifier, the operation will fail.
Expand Down Expand Up @@ -209,7 +209,7 @@ func (client *Szconfigmanager) ReplaceDefaultConfigID(ctx context.Context, curre
}

/*
The SetDefaultConfigID method sets which Senzing configuration JSON document identifier
Method SetDefaultConfigID sets which Senzing configuration JSON document identifier
is used when initializing or reinitializing the system.
Note that calling the SetDefaultConfigID method does not affect the currently
running in-memory configuration.
Expand Down Expand Up @@ -244,7 +244,7 @@ func (client *Szconfigmanager) SetDefaultConfigID(ctx context.Context, configID
// ----------------------------------------------------------------------------

/*
The GetObserverOrigin method returns the "origin" value of past Observer messages.
Method GetObserverOrigin returns the "origin" value of past Observer messages.
Input
- ctx: A context to control lifecycle.
Expand All @@ -258,7 +258,7 @@ func (client *Szconfigmanager) GetObserverOrigin(ctx context.Context) string {
}

/*
The Initialize method is a Null function for sz-sdk-go-grpc.
Method Initialize is a Null function for sz-sdk-go-grpc.
Input
- ctx: A context to control lifecycle.
Expand Down Expand Up @@ -287,7 +287,7 @@ func (client *Szconfigmanager) Initialize(ctx context.Context, instanceName stri
}

/*
The RegisterObserver method adds the observer to the list of observers notified.
Method RegisterObserver adds the observer to the list of observers notified.
Input
- ctx: A context to control lifecycle.
Expand Down Expand Up @@ -316,7 +316,7 @@ func (client *Szconfigmanager) RegisterObserver(ctx context.Context, observer ob
}

/*
The SetLogLevel method sets the level of logging.
Method SetLogLevel sets the level of logging.
Input
- ctx: A context to control lifecycle.
Expand Down Expand Up @@ -346,7 +346,7 @@ func (client *Szconfigmanager) SetLogLevel(ctx context.Context, logLevelName str
}

/*
The SetObserverOrigin method sets the "origin" value in future Observer messages.
Method SetObserverOrigin sets the "origin" value in future Observer messages.
Input
- ctx: A context to control lifecycle.
Expand All @@ -358,7 +358,7 @@ func (client *Szconfigmanager) SetObserverOrigin(ctx context.Context, origin str
}

/*
The UnregisterObserver method removes the observer to the list of observers notified.
Method UnregisterObserver removes the observer to the list of observers notified.
Input
- ctx: A context to control lifecycle.
Expand Down
Loading

0 comments on commit 524d1ac

Please sign in to comment.