Skip to content

Commit a7b39df

Browse files
committed
separate table + use channels
1 parent 2976c00 commit a7b39df

14 files changed

+513
-177
lines changed

coderd/database/dbauthz/dbauthz.go

+10-2
Original file line numberDiff line numberDiff line change
@@ -767,6 +767,10 @@ func (q *querier) DeleteTailnetClient(ctx context.Context, arg database.DeleteTa
767767
return q.db.DeleteTailnetClient(ctx, arg)
768768
}
769769

770+
func (q *querier) DeleteTailnetClientSubscription(ctx context.Context, arg database.DeleteTailnetClientSubscriptionParams) (database.DeleteTailnetClientSubscriptionRow, error) {
771+
panic("not implemented")
772+
}
773+
770774
func (q *querier) GetAPIKeyByID(ctx context.Context, id string) (database.APIKey, error) {
771775
return fetch(q.log, q.auth, q.db.GetAPIKeyByID)(ctx, id)
772776
}
@@ -809,9 +813,9 @@ func (q *querier) GetAllTailnetAgents(ctx context.Context) ([]database.TailnetAg
809813
return q.db.GetAllTailnetAgents(ctx)
810814
}
811815

812-
func (q *querier) GetAllTailnetClients(ctx context.Context) ([]database.TailnetClient, error) {
816+
func (q *querier) GetAllTailnetClients(ctx context.Context) ([]database.GetAllTailnetClientsRow, error) {
813817
if err := q.authorizeContext(ctx, rbac.ActionRead, rbac.ResourceTailnetCoordinator); err != nil {
814-
return []database.TailnetClient{}, err
818+
return []database.GetAllTailnetClientsRow{}, err
815819
}
816820
return q.db.GetAllTailnetClients(ctx)
817821
}
@@ -2778,6 +2782,10 @@ func (q *querier) UpsertTailnetClient(ctx context.Context, arg database.UpsertTa
27782782
return q.db.UpsertTailnetClient(ctx, arg)
27792783
}
27802784

2785+
func (q *querier) UpsertTailnetClientSubscription(ctx context.Context, arg database.UpsertTailnetClientSubscriptionParams) error {
2786+
panic("not implemented")
2787+
}
2788+
27812789
func (q *querier) UpsertTailnetCoordinator(ctx context.Context, id uuid.UUID) (database.TailnetCoordinator, error) {
27822790
if err := q.authorizeContext(ctx, rbac.ActionUpdate, rbac.ResourceTailnetCoordinator); err != nil {
27832791
return database.TailnetCoordinator{}, err

coderd/database/dbfake/dbfake.go

+14-1
Original file line numberDiff line numberDiff line change
@@ -909,6 +909,15 @@ func (*FakeQuerier) DeleteTailnetClient(context.Context, database.DeleteTailnetC
909909
return database.DeleteTailnetClientRow{}, ErrUnimplemented
910910
}
911911

912+
func (q *FakeQuerier) DeleteTailnetClientSubscription(ctx context.Context, arg database.DeleteTailnetClientSubscriptionParams) (database.DeleteTailnetClientSubscriptionRow, error) {
913+
err := validateDatabaseType(arg)
914+
if err != nil {
915+
return database.DeleteTailnetClientSubscriptionRow{}, err
916+
}
917+
918+
panic("not implemented")
919+
}
920+
912921
func (q *FakeQuerier) GetAPIKeyByID(_ context.Context, id string) (database.APIKey, error) {
913922
q.mutex.RLock()
914923
defer q.mutex.RUnlock()
@@ -1024,7 +1033,7 @@ func (*FakeQuerier) GetAllTailnetAgents(_ context.Context) ([]database.TailnetAg
10241033
return nil, ErrUnimplemented
10251034
}
10261035

1027-
func (*FakeQuerier) GetAllTailnetClients(_ context.Context) ([]database.TailnetClient, error) {
1036+
func (*FakeQuerier) GetAllTailnetClients(_ context.Context) ([]database.GetAllTailnetClientsRow, error) {
10281037
return nil, ErrUnimplemented
10291038
}
10301039

@@ -6032,6 +6041,10 @@ func (*FakeQuerier) UpsertTailnetClient(context.Context, database.UpsertTailnetC
60326041
return database.TailnetClient{}, ErrUnimplemented
60336042
}
60346043

6044+
func (q *FakeQuerier) UpsertTailnetClientSubscription(ctx context.Context, arg database.UpsertTailnetClientSubscriptionParams) error {
6045+
return ErrUnimplemented
6046+
}
6047+
60356048
func (*FakeQuerier) UpsertTailnetCoordinator(context.Context, uuid.UUID) (database.TailnetCoordinator, error) {
60366049
return database.TailnetCoordinator{}, ErrUnimplemented
60376050
}

coderd/database/dbmetrics/dbmetrics.go

+15-1
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

coderd/database/dbmock/dbmock.go

+31-2
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

coderd/database/dump.sql

+71-7
Some generated files are not rendered by default. Learn more about customizing how changed files appear on GitHub.

coderd/database/migrations/000152_pg_coordinator_single_tailnet.up.sql

-42
This file was deleted.

0 commit comments

Comments
 (0)