unistack-org/micro
4
0
Fork 3
Code Issues 19 Pull Requests 1 Actions Packages Projects Releases 259 Wiki Activity

Set database/table from init first

Browse Source
This commit is contained in:
Asim Aslam 2020-05-01 15:22:44 +01:00
parent 2a14feed93
commit 7a2dea6cc2
1 changed files with 20 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

24
store/service/service.go
View File

@ -59,7 +59,11 @@ func (s *serviceStore) Context() context.Context {
// Sync all the known records // Sync all the known records
func (s *serviceStore) List(opts ...store.ListOption) ([]string, error) { func (s *serviceStore) List(opts ...store.ListOption) ([]string, error) {
var options store.ListOptions options := store.ListOptions{
Database: s.Database,
Table: s.Table,
}
for _, o := range opts { for _, o := range opts {
o(&options) o(&options)
} }
@ -102,7 +106,11 @@ func (s *serviceStore) List(opts ...store.ListOption) ([]string, error) {
// Read a record with key // Read a record with key
func (s *serviceStore) Read(key string, opts ...store.ReadOption) ([]*store.Record, error) { func (s *serviceStore) Read(key string, opts ...store.ReadOption) ([]*store.Record, error) {
var options store.ReadOptions options := store.ReadOptions{
Database: s.Database,
Table: s.Table,
}
for _, o := range opts { for _, o := range opts {
o(&options) o(&options)
} }
@ -141,7 +149,11 @@ func (s *serviceStore) Read(key string, opts ...store.ReadOption) ([]*store.Reco
// Write a record // Write a record
func (s *serviceStore) Write(record *store.Record, opts ...store.WriteOption) error { func (s *serviceStore) Write(record *store.Record, opts ...store.WriteOption) error {
var options store.WriteOptions options := store.WriteOptions{
Database: s.Database,
Table: s.Table,
}
for _, o := range opts { for _, o := range opts {
o(&options) o(&options)
} }
@ -167,7 +179,11 @@ func (s *serviceStore) Write(record *store.Record, opts ...store.WriteOption) er
// Delete a record with key // Delete a record with key
func (s *serviceStore) Delete(key string, opts ...store.DeleteOption) error { func (s *serviceStore) Delete(key string, opts ...store.DeleteOption) error {
var options store.DeleteOptions options := store.DeleteOptions{
Database: s.Database,
Table: s.Table,
}
for _, o := range opts { for _, o := range opts {
o(&options) o(&options)
} }