repo

Documentation

Index

• type Error
  • func (e Error) Error() string
• type EventSourceRepository
  • func NewEventSourceRepository(db database.Database) *EventSourceRepository
  • func (e *EventSourceRepository) GetAllEventSources(ctx context.Context) ([]domain.EventSource, error)
  • func (e *EventSourceRepository) GetEventSource(ctx context.Context, id string) (*domain.EventSource, error)
  • func (e *EventSourceRepository) InsertEventSource(ctx context.Context, eventSource domain.EventSource) error
• type FunctionRepository
  • func NewFunctionRepository(db database.Database) *FunctionRepository
  • func (f FunctionRepository) GetAllLatestFunctions(ctx context.Context) ([]domain.Function, error)
  • func (f FunctionRepository) GetEnvironmentForFunction(ctx context.Context, function domain.Function) (*aws.Environment, error)
  • func (f FunctionRepository) GetLatestFunctionByName(ctx context.Context, name string) (*domain.Function, error)
  • func (f FunctionRepository) GetLatestVersionForFunctionName(ctx context.Context, name string) (int, error)
  • func (f FunctionRepository) GetLayersForFunction(ctx context.Context, function domain.Function) ([]domain.LambdaLayer, error)
  • func (f FunctionRepository) GetVersionsForFunctionName(ctx context.Context, name string) ([]domain.Function, error)
  • func (f FunctionRepository) InsertFunction(ctx context.Context, function *domain.Function) (*domain.Function, error)
  • func (f FunctionRepository) UpsertFunctionEnvironment(ctx context.Context, function *domain.Function, environment *aws.Environment) error
• type LayerRepository
  • func NewLayerRepository(db database.Database) *LayerRepository
  • func (l LayerRepository) GetLatestLayerVersionByName(ctx context.Context, name string) (int, error)
  • func (l LayerRepository) GetLayerByName(ctx context.Context, name string) ([]domain.LambdaLayer, error)
  • func (l LayerRepository) GetLayerByNameAndVersion(ctx context.Context, name string, version int) (domain.LambdaLayer, error)
  • func (l *LayerRepository) InsertLayer(ctx context.Context, layer domain.LambdaLayer, dbRuntimes *map[aws.Runtime]int) (*domain.LambdaLayer, error)
• type RowError
  • func (e RowError) Error() string
• type RuntimeRepository
  • func NewRuntimeRepository(db database.Database) *RuntimeRepository
  • func (r RuntimeRepository) RuntimeExistsByName(ctx context.Context, runtime types.Runtime) (bool, error)
  • func (r RuntimeRepository) RuntimeIDsByNames(ctx context.Context, runtimes []types.Runtime) (map[types.Runtime]int, error)

Types

type Error

type Error struct {
	Msg  string
	Base error
}

func (Error) Error

func (e Error) Error() string

type EventSourceRepository

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

func NewEventSourceRepository

func NewEventSourceRepository(db database.Database) *EventSourceRepository

func (*EventSourceRepository) GetAllEventSources

func (e *EventSourceRepository) GetAllEventSources(ctx context.Context) ([]domain.EventSource, error)

func (*EventSourceRepository) GetEventSource

func (e *EventSourceRepository) GetEventSource(ctx context.Context, id string) (*domain.EventSource, error)

func (*EventSourceRepository) InsertEventSource

func (e *EventSourceRepository) InsertEventSource(ctx context.Context, eventSource domain.EventSource) error

type FunctionRepository

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

func NewFunctionRepository

func NewFunctionRepository(db database.Database) *FunctionRepository

func (FunctionRepository) GetAllLatestFunctions

func (f FunctionRepository) GetAllLatestFunctions(ctx context.Context) ([]domain.Function, error)

func (FunctionRepository) GetEnvironmentForFunction

func (f FunctionRepository) GetEnvironmentForFunction(ctx context.Context, function domain.Function) (*aws.Environment, error)

func (FunctionRepository) GetLatestFunctionByName

func (f FunctionRepository) GetLatestFunctionByName(ctx context.Context, name string) (*domain.Function, error)

func (FunctionRepository) GetLatestVersionForFunctionName

func (f FunctionRepository) GetLatestVersionForFunctionName(ctx context.Context, name string) (int, error)

func (FunctionRepository) GetLayersForFunction

func (f FunctionRepository) GetLayersForFunction(ctx context.Context, function domain.Function) ([]domain.LambdaLayer, error)

func (FunctionRepository) GetVersionsForFunctionName

func (f FunctionRepository) GetVersionsForFunctionName(ctx context.Context, name string) ([]domain.Function, error)

func (FunctionRepository) InsertFunction

func (f FunctionRepository) InsertFunction(ctx context.Context, function *domain.Function) (*domain.Function, error)

func (FunctionRepository) UpsertFunctionEnvironment

func (f FunctionRepository) UpsertFunctionEnvironment(ctx context.Context, function *domain.Function, environment *aws.Environment) error

type LayerRepository

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

func NewLayerRepository

func NewLayerRepository(db database.Database) *LayerRepository

func (LayerRepository) GetLatestLayerVersionByName

func (l LayerRepository) GetLatestLayerVersionByName(ctx context.Context, name string) (int, error)

func (LayerRepository) GetLayerByName

func (l LayerRepository) GetLayerByName(ctx context.Context, name string) ([]domain.LambdaLayer, error)

func (LayerRepository) GetLayerByNameAndVersion

func (l LayerRepository) GetLayerByNameAndVersion(ctx context.Context, name string, version int) (domain.LambdaLayer, error)

func (*LayerRepository) InsertLayer

func (l *LayerRepository) InsertLayer(ctx context.Context, layer domain.LambdaLayer, dbRuntimes *map[aws.Runtime]int) (*domain.LambdaLayer, error)

type RowError

type RowError struct {
	Op   string
	Row  int
	Base error
}

func (RowError) Error

func (e RowError) Error() string

type RuntimeRepository

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

func NewRuntimeRepository

func NewRuntimeRepository(db database.Database) *RuntimeRepository

func (RuntimeRepository) RuntimeExistsByName

func (r RuntimeRepository) RuntimeExistsByName(ctx context.Context, runtime types.Runtime) (bool, error)

func (RuntimeRepository) RuntimeIDsByNames

func (r RuntimeRepository) RuntimeIDsByNames(ctx context.Context, runtimes []types.Runtime) (map[types.Runtime]int, error)