v1alpha1_connectionservice

Documentation

Index

• type Config
• type Service
  • func New(cfg *Config, db *nucleusdb.NucleusDb, ...) *Service
  • func (s *Service) CheckConnectionConfig(ctx context.Context, ...) (*connect.Response[mgmtv1alpha1.CheckConnectionConfigResponse], error)
  • func (s *Service) CheckConnectionConfigById(ctx context.Context, ...) (*connect.Response[mgmtv1alpha1.CheckConnectionConfigByIdResponse], error)
  • func (s *Service) CheckSqlQuery(ctx context.Context, req *connect.Request[mgmtv1alpha1.CheckSqlQueryRequest]) (*connect.Response[mgmtv1alpha1.CheckSqlQueryResponse], error)
  • func (s *Service) CreateConnection(ctx context.Context, ...) (*connect.Response[mgmtv1alpha1.CreateConnectionResponse], error)
  • func (s *Service) DeleteConnection(ctx context.Context, ...) (*connect.Response[mgmtv1alpha1.DeleteConnectionResponse], error)
  • func (s *Service) GetConnection(ctx context.Context, req *connect.Request[mgmtv1alpha1.GetConnectionRequest]) (*connect.Response[mgmtv1alpha1.GetConnectionResponse], error)
  • func (s *Service) GetConnections(ctx context.Context, req *connect.Request[mgmtv1alpha1.GetConnectionsRequest]) (*connect.Response[mgmtv1alpha1.GetConnectionsResponse], error)
  • func (s *Service) IsConnectionNameAvailable(ctx context.Context, ...) (*connect.Response[mgmtv1alpha1.IsConnectionNameAvailableResponse], error)
  • func (s *Service) UpdateConnection(ctx context.Context, ...) (*connect.Response[mgmtv1alpha1.UpdateConnectionResponse], error)

Types

type Config

type Config struct {
}

type Service

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

func New

func New(
	cfg *Config,
	db *nucleusdb.NucleusDb,
	useraccountService mgmtv1alpha1connect.UserAccountServiceClient,
	sqlConnector sqlconnect.SqlConnector,
	pgquerier pg_queries.Querier,
	mysqlquerier mysql_queries.Querier,
	mssqlquerier mssql_queries.Querier,
	mongoconnector mongoconnect.Interface,
	awsManager awsmanager.NeosyncAwsManagerClient,
) *Service

func (*Service) CheckConnectionConfig

func (s *Service) CheckConnectionConfig(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.CheckConnectionConfigRequest],
) (*connect.Response[mgmtv1alpha1.CheckConnectionConfigResponse], error)

func (*Service) CheckConnectionConfigById

func (s *Service) CheckConnectionConfigById(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.CheckConnectionConfigByIdRequest],
) (*connect.Response[mgmtv1alpha1.CheckConnectionConfigByIdResponse], error)

func (*Service) CheckSqlQuery

func (s *Service) CheckSqlQuery(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.CheckSqlQueryRequest],
) (*connect.Response[mgmtv1alpha1.CheckSqlQueryResponse], error)

func (*Service) CreateConnection

func (s *Service) CreateConnection(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.CreateConnectionRequest],
) (*connect.Response[mgmtv1alpha1.CreateConnectionResponse], error)

func (*Service) DeleteConnection

func (s *Service) DeleteConnection(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.DeleteConnectionRequest],
) (*connect.Response[mgmtv1alpha1.DeleteConnectionResponse], error)

func (*Service) GetConnection

func (s *Service) GetConnection(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.GetConnectionRequest],
) (*connect.Response[mgmtv1alpha1.GetConnectionResponse], error)

func (*Service) GetConnections

func (s *Service) GetConnections(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.GetConnectionsRequest],
) (*connect.Response[mgmtv1alpha1.GetConnectionsResponse], error)

func (*Service) IsConnectionNameAvailable

func (s *Service) IsConnectionNameAvailable(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.IsConnectionNameAvailableRequest],
) (*connect.Response[mgmtv1alpha1.IsConnectionNameAvailableResponse], error)

func (*Service) UpdateConnection

func (s *Service) UpdateConnection(
	ctx context.Context,
	req *connect.Request[mgmtv1alpha1.UpdateConnectionRequest],
) (*connect.Response[mgmtv1alpha1.UpdateConnectionResponse], error)