database

Documentation

Index

• type Service
  • func NewService(p newServiceParams) (*Service, error)
  • func (s *Service) Create(ctx context.Context, dbType database.Type, initializers []*database.Update) (uuid.UUID, *database.Database, error)
  • func (s *Service) CreateCredential(ctx context.Context, credentialName string, databaseID uuid.UUID) (clientId string, clientSecret string, err error)
  • func (s *Service) CreateTable(ctx context.Context, databaseID uuid.UUID, tableName string) error
  • func (s *Service) Delete(ctx context.Context, databaseID uuid.UUID) error
  • func (s *Service) DeleteCredential(ctx context.Context, credentialsName string, databaseID uuid.UUID) error
  • func (s *Service) DeleteTable(ctx context.Context, databaseID uuid.UUID, collectionName string) error
  • func (s *Service) Get(ctx context.Context, databaseID uuid.UUID) (*database.Database, error)
  • func (s *Service) GetByName(ctx context.Context, name string) (*database.Database, error)
  • func (s *Service) GetDatabaseEndpoint(ctx context.Context, databaseID uuid.UUID, clientID, clientSecret string) (string, string, error)
  • func (s *Service) List(ctx context.Context, pagination *model.Pagination) (iterator.Iterator[*database.Database], uint64, error)
  • func (s *Service) ListCredentials(ctx context.Context, databaseID uuid.UUID) ([]*database.Credential, error)
  • func (s *Service) ListTables(ctx context.Context, databaseID uuid.UUID) ([]*database.Table, error)
  • func (s *Service) Update(ctx context.Context, databaseID uuid.UUID, updates []*database.Update) (*database.Database, error)

Types

type Service

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

func NewService

func NewService(p newServiceParams) (*Service, error)

func (*Service) Create

func (s *Service) Create(ctx context.Context, dbType database.Type, initializers []*database.Update) (uuid.UUID, *database.Database, error)

func (*Service) CreateCredential

func (s *Service) CreateCredential(ctx context.Context, credentialName string, databaseID uuid.UUID) (clientId string, clientSecret string, err error)

func (*Service) CreateTable

func (s *Service) CreateTable(ctx context.Context, databaseID uuid.UUID, tableName string) error

func (*Service) Delete

func (s *Service) Delete(ctx context.Context, databaseID uuid.UUID) error

func (*Service) DeleteCredential

func (s *Service) DeleteCredential(ctx context.Context, credentialsName string, databaseID uuid.UUID) error

func (*Service) DeleteTable

func (s *Service) DeleteTable(ctx context.Context, databaseID uuid.UUID, collectionName string) error

func (*Service) Get

func (s *Service) Get(ctx context.Context, databaseID uuid.UUID) (*database.Database, error)

func (*Service) GetByName

func (s *Service) GetByName(ctx context.Context, name string) (*database.Database, error)

func (*Service) GetDatabaseEndpoint

func (s *Service) GetDatabaseEndpoint(ctx context.Context, databaseID uuid.UUID, clientID, clientSecret string) (string, string, error)

func (*Service) List

func (s *Service) List(ctx context.Context, pagination *model.Pagination) (iterator.Iterator[*database.Database], uint64, error)

func (*Service) ListCredentials

func (s *Service) ListCredentials(ctx context.Context, databaseID uuid.UUID) ([]*database.Credential, error)

func (*Service) ListTables

func (s *Service) ListTables(ctx context.Context, databaseID uuid.UUID) ([]*database.Table, error)

func (*Service) Update

func (s *Service) Update(ctx context.Context, databaseID uuid.UUID, updates []*database.Update) (*database.Database, error)