lib/events: remove no-op WaitForDelivery method

lib/auth/auth_with_roles.go

@@ -3809,10 +3809,6 @@ func (a *ServerWithRoles) Close() error {
 	return a.authServer.Close()
 }
 
-func (a *ServerWithRoles) WaitForDelivery(context.Context) error {
-	return nil
-}
-
 // UpsertKubeService creates or updates a Server representing a teleport
 // kubernetes service.
 func (a *ServerWithRoles) UpsertKubeService(ctx context.Context, s types.Server) error {

lib/auth/clt.go

@@ -354,10 +354,6 @@ func (c *Client) Close() error {
 	return c.APIClient.Close()
 }
 
-func (c *Client) WaitForDelivery(context.Context) error {
-	return nil
-}
-
 // CreateCertAuthority not implemented: can only be called locally.
 func (c *Client) CreateCertAuthority(ca types.CertAuthority) error {
 	return trace.NotImplemented(notImplementedMessage)

lib/events/api.go

@@ -732,10 +732,6 @@ type IAuditLog interface {
 	// This function may never return more than 1 MiB of event data.
 	SearchSessionEvents(fromUTC, toUTC time.Time, limit int, order types.EventOrder, startKey string, cond *types.WhereExpr) ([]apievents.AuditEvent, string, error)
 
-	// WaitForDelivery waits for resources to be released and outstanding requests to
-	// complete after calling Close method
-	WaitForDelivery(context.Context) error
-
 	// StreamSessionEvents streams all events from a given session recording. An error is returned on the first
 	// channel if one is encountered. Otherwise the event channel is closed when the stream ends.
 	// The event channel is not closed on error to prevent race conditions in downstream select statements.

lib/events/auditlog.go

@@ -290,10 +290,6 @@ func NewAuditLog(cfg AuditLogConfig) (*AuditLog, error) {
 	return al, nil
 }
 
-func (l *AuditLog) WaitForDelivery(context.Context) error {
-	return nil
-}
-
 func getAuthServers(dataDir string) ([]string, error) {
 	// scan the log directory:
 	df, err := os.Open(dataDir)

lib/events/discard.go

@@ -35,10 +35,6 @@ func NewDiscardAuditLog() *DiscardAuditLog {
 	return &DiscardAuditLog{}
 }
 
-func (d *DiscardAuditLog) WaitForDelivery(context.Context) error {
-	return nil
-}
-
 func (d *DiscardAuditLog) Close() error {
 	return nil
 }

lib/events/dynamoevents/dynamoevents.go

@@ -894,12 +894,6 @@ func fromWhereExpr(cond *types.WhereExpr, params *condFilterParams) (string, err
 	return "", trace.BadParameter("failed to convert WhereExpr %q to DynamoDB filter expression", cond)
 }
 
-// WaitForDelivery waits for resources to be released and outstanding requests to
-// complete after calling Close method
-func (l *Log) WaitForDelivery(ctx context.Context) error {
-	return nil
-}
-
 func (l *Log) turnOnTimeToLive(ctx context.Context) error {
 	status, err := l.svc.DescribeTimeToLiveWithContext(ctx, &dynamodb.DescribeTimeToLiveInput{
 		TableName: aws.String(l.Tablename),

lib/events/filelog.go

@@ -395,10 +395,6 @@ func (l *FileLog) Close() error {
 	return err
 }
 
-func (l *FileLog) WaitForDelivery(context.Context) error {
-	return nil
-}
-
 func (l *FileLog) GetSessionChunk(namespace string, sid session.ID, offsetBytes, maxBytes int) ([]byte, error) {
 	return nil, trace.NotImplemented("not implemented")
 }

lib/events/firestoreevents/firestoreevents.go

@@ -565,12 +565,6 @@ type searchEventsFilter struct {
 	condition  utils.FieldsCondition
 }
 
-// WaitForDelivery waits for resources to be released and outstanding requests to
-// complete after calling Close method
-func (l *Log) WaitForDelivery(ctx context.Context) error {
-	return nil
-}
-
 func (l *Log) getIndexParent() string {
 	return "projects/" + l.ProjectID + "/databases/(default)/collectionGroups/" + l.CollectionName
 }

lib/events/multilog.go

@@ -51,12 +51,6 @@ type MultiLog struct {
 	*MultiEmitter
 }
 
-// WaitForDelivery waits for resources to be released and outstanding requests to
-// complete after calling Close method
-func (m *MultiLog) WaitForDelivery(ctx context.Context) error {
-	return nil
-}
-
 // Close releases connections and resources associated with logs if any
 func (m *MultiLog) Close() error {
 	var errors []error

lib/events/writer.go

@@ -94,12 +94,6 @@ func (w *WriterLog) SearchSessionEvents(fromUTC, toUTC time.Time, limit int, ord
 	return nil, "", trace.NotImplemented("not implemented")
 }
 
-// WaitForDelivery waits for resources to be released and outstanding requests to
-// complete after calling Close method
-func (w *WriterLog) WaitForDelivery(context.Context) error {
-	return nil
-}
-
 // StreamSessionEvents streams all events from a given session recording. An error is returned on the first
 // channel if one is encountered. Otherwise the event channel is closed when the stream ends.
 // The event channel is not closed on error to prevent race conditions in downstream select statements.