@@ -905,6 +905,15 @@ func (*FakeQuerier) AcquireLock(_ context.Context, _ int64) error {
905
905
return xerrors .New ("AcquireLock must only be called within a transaction" )
906
906
}
907
907
908
+ func (q * FakeQuerier ) AcquireNotificationMessages (ctx context.Context , arg database.AcquireNotificationMessagesParams ) ([]database.AcquireNotificationMessagesRow , error ) {
909
+ err := validateDatabaseType (arg )
910
+ if err != nil {
911
+ return nil , err
912
+ }
913
+
914
+ panic ("not implemented" )
915
+ }
916
+
908
917
func (q * FakeQuerier ) AcquireProvisionerJob (_ context.Context , arg database.AcquireProvisionerJobParams ) (database.ProvisionerJob , error ) {
909
918
if err := validateDatabaseType (arg ); err != nil {
910
919
return database.ProvisionerJob {}, err
@@ -1167,6 +1176,24 @@ func (q *FakeQuerier) BatchUpdateWorkspaceLastUsedAt(_ context.Context, arg data
1167
1176
return nil
1168
1177
}
1169
1178
1179
+ func (q * FakeQuerier ) BulkMarkNotificationMessagesFailed (ctx context.Context , arg database.BulkMarkNotificationMessagesFailedParams ) (int64 , error ) {
1180
+ err := validateDatabaseType (arg )
1181
+ if err != nil {
1182
+ return 0 , err
1183
+ }
1184
+
1185
+ panic ("not implemented" )
1186
+ }
1187
+
1188
+ func (q * FakeQuerier ) BulkMarkNotificationMessagesSent (ctx context.Context , arg database.BulkMarkNotificationMessagesSentParams ) (int64 , error ) {
1189
+ err := validateDatabaseType (arg )
1190
+ if err != nil {
1191
+ return 0 , err
1192
+ }
1193
+
1194
+ panic ("not implemented" )
1195
+ }
1196
+
1170
1197
func (* FakeQuerier ) CleanTailnetCoordinators (_ context.Context ) error {
1171
1198
return ErrUnimplemented
1172
1199
}
@@ -1502,6 +1529,10 @@ func (q *FakeQuerier) DeleteOAuth2ProviderAppTokensByAppAndUserID(_ context.Cont
1502
1529
return nil
1503
1530
}
1504
1531
1532
+ func (q * FakeQuerier ) DeleteOldNotificationMessages (ctx context.Context ) error {
1533
+ panic ("not implemented" )
1534
+ }
1535
+
1505
1536
func (q * FakeQuerier ) DeleteOldProvisionerDaemons (_ context.Context ) error {
1506
1537
q .mutex .Lock ()
1507
1538
defer q .mutex .Unlock ()
@@ -1717,6 +1748,15 @@ func (q *FakeQuerier) DeleteWorkspaceAgentPortSharesByTemplate(_ context.Context
1717
1748
return nil
1718
1749
}
1719
1750
1751
+ func (q * FakeQuerier ) EnqueueNotificationMessage (ctx context.Context , arg database.EnqueueNotificationMessageParams ) (database.NotificationMessage , error ) {
1752
+ err := validateDatabaseType (arg )
1753
+ if err != nil {
1754
+ return database.NotificationMessage {}, err
1755
+ }
1756
+
1757
+ panic ("not implemented" )
1758
+ }
1759
+
1720
1760
func (q * FakeQuerier ) FavoriteWorkspace (_ context.Context , arg uuid.UUID ) error {
1721
1761
err := validateDatabaseType (arg )
1722
1762
if err != nil {
@@ -1736,6 +1776,15 @@ func (q *FakeQuerier) FavoriteWorkspace(_ context.Context, arg uuid.UUID) error
1736
1776
return nil
1737
1777
}
1738
1778
1779
+ func (q * FakeQuerier ) FetchNewMessageMetadata (ctx context.Context , arg database.FetchNewMessageMetadataParams ) (database.FetchNewMessageMetadataRow , error ) {
1780
+ err := validateDatabaseType (arg )
1781
+ if err != nil {
1782
+ return database.FetchNewMessageMetadataRow {}, err
1783
+ }
1784
+
1785
+ panic ("not implemented" )
1786
+ }
1787
+
1739
1788
func (q * FakeQuerier ) GetAPIKeyByID (_ context.Context , id string ) (database.APIKey , error ) {
1740
1789
q .mutex .RLock ()
1741
1790
defer q .mutex .RUnlock ()
@@ -6063,6 +6112,15 @@ func (q *FakeQuerier) InsertMissingGroups(_ context.Context, arg database.Insert
6063
6112
return newGroups , nil
6064
6113
}
6065
6114
6115
+ func (q * FakeQuerier ) InsertNotificationTemplate (ctx context.Context , arg database.InsertNotificationTemplateParams ) (database.NotificationTemplate , error ) {
6116
+ err := validateDatabaseType (arg )
6117
+ if err != nil {
6118
+ return database.NotificationTemplate {}, err
6119
+ }
6120
+
6121
+ panic ("not implemented" )
6122
+ }
6123
+
6066
6124
func (q * FakeQuerier ) InsertOAuth2ProviderApp (_ context.Context , arg database.InsertOAuth2ProviderAppParams ) (database.OAuth2ProviderApp , error ) {
6067
6125
err := validateDatabaseType (arg )
6068
6126
if err != nil {
0 commit comments