sql

Documentation

Index

• Constants
• type SQLStore
  • func New(ctx context.Context, u *url.URL) (*SQLStore, error)
  • func (ds *SQLStore) Close() error
  • func (ds *SQLStore) GetAppByID(ctx context.Context, appID string) (*models.App, error)
  • func (ds *SQLStore) GetAppID(ctx context.Context, appName string) (string, error)
  • func (ds *SQLStore) GetApps(ctx context.Context, filter *models.AppFilter) (*models.AppList, error)
  • func (ds *SQLStore) GetCall(ctx context.Context, fnID, callID string) (*models.Call, error)
  • func (ds *SQLStore) GetCall1(ctx context.Context, appID, callID string) (*models.Call, error)
  • func (ds *SQLStore) GetCalls(ctx context.Context, filter *models.CallFilter) (*models.CallList, error)
  • func (ds *SQLStore) GetCalls1(ctx context.Context, filter *models.CallFilter) ([]*models.Call, error)
  • func (ds *SQLStore) GetFnByID(ctx context.Context, fnID string) (*models.Fn, error)
  • func (ds *SQLStore) GetFns(ctx context.Context, filter *models.FnFilter) (*models.FnList, error)
  • func (ds *SQLStore) GetLog(ctx context.Context, fnID, callID string) (io.Reader, error)
  • func (ds *SQLStore) GetTrigger(ctx context.Context, appId, fnId, triggerName string) (*models.Trigger, error)
  • func (ds *SQLStore) GetTriggerByID(ctx context.Context, triggerID string) (*models.Trigger, error)
  • func (ds *SQLStore) GetTriggerBySource(ctx context.Context, appId string, triggerType, source string) (*models.Trigger, error)
  • func (ds *SQLStore) GetTriggers(ctx context.Context, filter *models.TriggerFilter) (*models.TriggerList, error)
  • func (ds *SQLStore) InsertApp(ctx context.Context, newApp *models.App) (*models.App, error)
  • func (ds *SQLStore) InsertCall(ctx context.Context, call *models.Call) error
  • func (ds *SQLStore) InsertFn(ctx context.Context, newFn *models.Fn) (*models.Fn, error)
  • func (ds *SQLStore) InsertLog(ctx context.Context, call *models.Call, logR io.Reader) error
  • func (ds *SQLStore) InsertTrigger(ctx context.Context, newTrigger *models.Trigger) (*models.Trigger, error)
  • func (ds *SQLStore) RemoveApp(ctx context.Context, appID string) error
  • func (ds *SQLStore) RemoveFn(ctx context.Context, fnID string) error
  • func (ds *SQLStore) RemoveTrigger(ctx context.Context, triggerId string) error
  • func (ds *SQLStore) Tx(f func(*sqlx.Tx) error) error
  • func (ds *SQLStore) UpdateApp(ctx context.Context, newapp *models.App) (*models.App, error)
  • func (ds *SQLStore) UpdateFn(ctx context.Context, fn *models.Fn) (*models.Fn, error)
  • func (ds *SQLStore) UpdateTrigger(ctx context.Context, trigger *models.Trigger) (*models.Trigger, error)

Constants

const (
	EnvDBPingMaxRetries = "FN_DS_DB_PING_MAX_RETRIES"
)

Types

type SQLStore

type SQLStore struct {
	// contains filtered or unexported fields
}

func New

func New(ctx context.Context, u *url.URL) (*SQLStore, error)

New will open the db specified by url, create any tables necessary and return a models.Datastore safe for concurrent usage.

func (*SQLStore) Close

func (ds *SQLStore) Close() error

Close closes the database, releasing any open resources.

func (*SQLStore) GetAppByID

func (ds *SQLStore) GetAppByID(ctx context.Context, appID string) (*models.App, error)

func (*SQLStore) GetAppID

func (ds *SQLStore) GetAppID(ctx context.Context, appName string) (string, error)

func (*SQLStore) GetApps

func (ds *SQLStore) GetApps(ctx context.Context, filter *models.AppFilter) (*models.AppList, error)

GetApps retrieves an array of apps according to a specific filter.

func (*SQLStore) GetCall

func (ds *SQLStore) GetCall(ctx context.Context, fnID, callID string) (*models.Call, error)

func (*SQLStore) GetCall1

func (ds *SQLStore) GetCall1(ctx context.Context, appID, callID string) (*models.Call, error)

func (*SQLStore) GetCalls

func (ds *SQLStore) GetCalls(ctx context.Context, filter *models.CallFilter) (*models.CallList, error)

func (*SQLStore) GetCalls1

func (ds *SQLStore) GetCalls1(ctx context.Context, filter *models.CallFilter) ([]*models.Call, error)

func (*SQLStore) GetFnByID

func (ds *SQLStore) GetFnByID(ctx context.Context, fnID string) (*models.Fn, error)

func (*SQLStore) GetFns

func (ds *SQLStore) GetFns(ctx context.Context, filter *models.FnFilter) (*models.FnList, error)

func (*SQLStore) GetLog

func (ds *SQLStore) GetLog(ctx context.Context, fnID, callID string) (io.Reader, error)

func (*SQLStore) GetTrigger

func (ds *SQLStore) GetTrigger(ctx context.Context, appId, fnId, triggerName string) (*models.Trigger, error)

func (*SQLStore) GetTriggerByID

func (ds *SQLStore) GetTriggerByID(ctx context.Context, triggerID string) (*models.Trigger, error)

func (*SQLStore) GetTriggerBySource

func (ds *SQLStore) GetTriggerBySource(ctx context.Context, appId string, triggerType, source string) (*models.Trigger, error)

func (*SQLStore) GetTriggers

func (ds *SQLStore) GetTriggers(ctx context.Context, filter *models.TriggerFilter) (*models.TriggerList, error)

func (*SQLStore) InsertApp

func (ds *SQLStore) InsertApp(ctx context.Context, newApp *models.App) (*models.App, error)

func (*SQLStore) InsertCall

func (ds *SQLStore) InsertCall(ctx context.Context, call *models.Call) error

func (*SQLStore) InsertFn

func (ds *SQLStore) InsertFn(ctx context.Context, newFn *models.Fn) (*models.Fn, error)

func (*SQLStore) InsertLog

func (ds *SQLStore) InsertLog(ctx context.Context, call *models.Call, logR io.Reader) error

func (*SQLStore) InsertTrigger

func (ds *SQLStore) InsertTrigger(ctx context.Context, newTrigger *models.Trigger) (*models.Trigger, error)

func (*SQLStore) RemoveApp

func (ds *SQLStore) RemoveApp(ctx context.Context, appID string) error

func (*SQLStore) RemoveFn

func (ds *SQLStore) RemoveFn(ctx context.Context, fnID string) error

func (*SQLStore) RemoveTrigger

func (ds *SQLStore) RemoveTrigger(ctx context.Context, triggerId string) error

func (*SQLStore) Tx

func (ds *SQLStore) Tx(f func(*sqlx.Tx) error) error

func (*SQLStore) UpdateApp

func (ds *SQLStore) UpdateApp(ctx context.Context, newapp *models.App) (*models.App, error)

func (*SQLStore) UpdateFn

func (ds *SQLStore) UpdateFn(ctx context.Context, fn *models.Fn) (*models.Fn, error)

func (*SQLStore) UpdateTrigger

func (ds *SQLStore) UpdateTrigger(ctx context.Context, trigger *models.Trigger) (*models.Trigger, error)