database

Documentation

Index

• Variables
• type Config
• type Service
  • 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) CreateUser(ctx context.Context, username string, encryptedPassword string, email *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) FetchAPITokenByID(ctx context.Context, id 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) FetchInvocations(ctx context.Context, pageNumber uint32, pageSize uint32) ([]model.Invocation, error)
  • func (s *Service) FetchUser(ctx context.Context, username string) (*model.User, 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

Variables

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

Types

type Config

type Config struct {
	ConnectionString string
}

type Service

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

func New

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

func (*Service) AutoMigrate

func (s *Service) AutoMigrate() error

func (*Service) CreateAPIToken

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

func (*Service) CreateFunction

func (s *Service) CreateFunction(
	ctx context.Context,
	name string,
	image string,
	skipLogging bool,
	environment map[string]string,
	secrets map[string]string,
) (*string, error)

func (*Service) CreateInvocation

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

func (*Service) CreateUser

func (s *Service) CreateUser(ctx context.Context, username string, encryptedPassword string, email *string, name *string) (*string, error)

func (*Service) DeleteAPIToken

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

func (*Service) FetchAPIToken

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

func (*Service) FetchAPITokenByID

func (s *Service) FetchAPITokenByID(ctx context.Context, id string) (*model.APIToken, error)

func (*Service) FetchAPITokens

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

func (*Service) FetchFunction

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

func (*Service) FetchFunctionInvocations

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

func (*Service) FetchFunctions

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

func (*Service) FetchInvocation

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

func (*Service) FetchInvocations

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

func (*Service) FetchUser

func (s *Service) FetchUser(ctx context.Context, username string) (*model.User, error)

func (*Service) UpdateInvocationFailed

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

func (*Service) UpdateInvocationStarted

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

func (*Service) UpdateInvocationSucceeded

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