mirror of
https://github.com/fnproject/fn.git
synced 2022-10-28 21:29:17 +03:00
ea1f94253f
* Implements graceful shutdown of agent.DataAccess and underlying Datastore/Logstore/MessageQueue * adds tests for closing agent.DataAccess and Datastore
65 lines
2.0 KiB
Go
65 lines
2.0 KiB
Go
package hybrid
|
|
|
|
import (
|
|
"context"
|
|
"errors"
|
|
"io"
|
|
|
|
"github.com/fnproject/fn/api/agent"
|
|
"github.com/fnproject/fn/api/models"
|
|
"go.opencensus.io/trace"
|
|
)
|
|
|
|
// nopDataStore implements agent.DataAccess
|
|
type nopDataStore struct{}
|
|
|
|
func NewNopDataStore() (agent.DataAccess, error) {
|
|
return &nopDataStore{}, nil
|
|
}
|
|
|
|
func (cl *nopDataStore) GetAppID(ctx context.Context, appName string) (string, error) {
|
|
ctx, span := trace.StartSpan(ctx, "nop_datastore_get_app_id")
|
|
defer span.End()
|
|
return "", errors.New("should not call GetAppID on a NOP data store")
|
|
}
|
|
|
|
func (cl *nopDataStore) GetAppByID(ctx context.Context, appID string) (*models.App, error) {
|
|
ctx, span := trace.StartSpan(ctx, "nop_datastore_get_app_by_id")
|
|
defer span.End()
|
|
return nil, errors.New("should not call GetAppByID on a NOP data store")
|
|
}
|
|
|
|
func (cl *nopDataStore) Enqueue(ctx context.Context, c *models.Call) error {
|
|
ctx, span := trace.StartSpan(ctx, "nop_datastore_enqueue")
|
|
defer span.End()
|
|
return errors.New("Should not call Enqueue on a NOP data store")
|
|
}
|
|
|
|
func (cl *nopDataStore) Dequeue(ctx context.Context) (*models.Call, error) {
|
|
ctx, span := trace.StartSpan(ctx, "nop_datastore_dequeue")
|
|
defer span.End()
|
|
return nil, errors.New("Should not call Dequeue on a NOP data store")
|
|
}
|
|
|
|
func (cl *nopDataStore) Start(ctx context.Context, c *models.Call) error {
|
|
ctx, span := trace.StartSpan(ctx, "nop_datastore_start")
|
|
defer span.End()
|
|
return nil // It's ok to call this method, and it does no operations
|
|
}
|
|
|
|
func (cl *nopDataStore) Finish(ctx context.Context, c *models.Call, r io.Reader, async bool) error {
|
|
ctx, span := trace.StartSpan(ctx, "nop_datastore_end")
|
|
defer span.End()
|
|
return nil // It's ok to call this method, and it does no operations
|
|
}
|
|
|
|
func (cl *nopDataStore) GetRoute(ctx context.Context, appName, route string) (*models.Route, error) {
|
|
ctx, span := trace.StartSpan(ctx, "nop_datastore_get_route")
|
|
defer span.End()
|
|
return nil, errors.New("Should not call GetRoute on a NOP data store")
|
|
}
|
|
|
|
func (cl *nopDataStore) Close() error {
|
|
return nil
|
|
}
|