Skip to content

Commit 147ab65

Browse files
committed
Fixed the name
1 parent ec752aa commit 147ab65

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

services/stream/stream.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -262,7 +262,7 @@ func (s *Store) SetEndpointInactiveByApplicationNamePwd(ctx context.Context, app
262262
}
263263

264264
func (s *Store) NewEndpoint(ctx context.Context, e EndpointDB) (EndpointDB, error) {
265-
builder := utils.PSQL().Insert("web_api.stream_endpoint").
265+
builder := utils.PSQL().Insert("web_api.stream_endpoints").
266266
Columns("application", "name", "pwd", "start_valid", "end_valid", "notes", "active", "blocked",
267267
"auto_remove").
268268
Values(e.Application, e.Name, e.Pwd, e.StartValid, e.EndValid, e.Notes, e.Active, e.Blocked, e.AutoRemove).
@@ -327,7 +327,7 @@ func (s *Store) EditEndpoint(ctx context.Context, e EndpointDB) error {
327327
}
328328

329329
func (s *Store) DeleteEndpoint(ctx context.Context, endpointID int) error {
330-
builder := utils.PSQL().Delete("web_api.stream_endpoint").
330+
builder := utils.PSQL().Delete("web_api.stream_endpoints").
331331
Where(sq.Eq{"endpoint_id": endpointID})
332332

333333
sql, args, err := builder.ToSql()

0 commit comments

Comments
 (0)