database

package

v1.1.1 Latest Latest Go to latest Published: Dec 31, 2022 License: AGPL-3.0-or-later Imports: 10 Imported by: 0

Details

This section is empty.

View Source

var ErrInvalidPagination = errors.New("invalid page request")

This section is empty.

type Config struct {
	ConnectionString string
}

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

func New(cfg Config) (*Service, error)

func (s *Service) AutoMigrate() error

func (s *Service) CreateAPIToken(ctx context.Context, clientName string, token string) (*string, error)

func (s *Service) CreateFunction(ctx context.Context, name string, image string, skipLogging bool) (*string, error)

func (s *Service) CreateInvocation(ctx context.Context, fn model.Function, clientName string, input *string) (*string, error)

func (s *Service) DeleteAPIToken(ctx context.Context, id string) error

func (s *Service) FetchAPIToken(ctx context.Context, tokenString string) (*model.APIToken, error)

func (s *Service) FetchAPITokens(ctx context.Context, pageNumber uint32, pageSize uint32) ([]model.APIToken, error)

func (s *Service) FetchFunction(ctx context.Context, name string) (*model.Function, error)

func (s *Service) FetchFunctionInvocations(ctx context.Context, functionID string, pageNumber uint32, pageSize uint32) ([]model.Invocation, error)

func (s *Service) FetchFunctions(ctx context.Context, pageNumber uint32, pageSize uint32) ([]model.Function, error)

func (s *Service) FetchInvocation(ctx context.Context, id string) (*model.Invocation, error)

func (s *Service) UpdateInvocationFailed(ctx context.Context, id string, endedAt time.Time, errorMessage *string) error

func (s *Service) UpdateInvocationStarted(ctx context.Context, id string, startedAt time.Time) error

func (s *Service) UpdateInvocationSucceeded(ctx context.Context, id string, endedAt time.Time, output *string) error

Path	Synopsis
dbiface