Documentation ¶
Index ¶
- type Config
- type DatabaseSchema
- type DateScanner
- type Service
- func (s *Service) GetAiGeneratedData(ctx context.Context, ...) (*connect.Response[mgmtv1alpha1.GetAiGeneratedDataResponse], error)
- func (s *Service) GetConnectionDataStream(ctx context.Context, ...) error
- func (s *Service) GetConnectionForeignConstraints(ctx context.Context, ...) (*connect.Response[mgmtv1alpha1.GetConnectionForeignConstraintsResponse], error)
- func (s *Service) GetConnectionInitStatements(ctx context.Context, ...) (*connect.Response[mgmtv1alpha1.GetConnectionInitStatementsResponse], error)
- func (s *Service) GetConnectionPrimaryConstraints(ctx context.Context, ...) (*connect.Response[mgmtv1alpha1.GetConnectionPrimaryConstraintsResponse], error)
- func (s *Service) GetConnectionSchema(ctx context.Context, ...) (*connect.Response[mgmtv1alpha1.GetConnectionSchemaResponse], error)
- func (s *Service) GetConnectionSchemaMap(ctx context.Context, ...) (*connect.Response[mgmtv1alpha1.GetConnectionSchemaMapResponse], error)
- func (s *Service) GetConnectionSchemaMaps(ctx context.Context, ...) (*connect.Response[mgmtv1alpha1.GetConnectionSchemaMapsResponse], error)
- func (s *Service) GetConnectionTableConstraints(ctx context.Context, ...) (*connect.Response[mgmtv1alpha1.GetConnectionTableConstraintsResponse], error)
- func (s *Service) GetConnectionUniqueConstraints(ctx context.Context, ...) (*connect.Response[mgmtv1alpha1.GetConnectionUniqueConstraintsResponse], error)
- func (s *Service) GetTableRowCount(ctx context.Context, ...) (*connect.Response[mgmtv1alpha1.GetTableRowCountResponse], error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type DatabaseSchema ¶
type DateScanner ¶
type DateScanner struct {
// contains filtered or unexported fields
}
func (*DateScanner) Scan ¶
func (ds *DateScanner) Scan(input any) error
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func New ¶
func New( cfg *Config, useraccountService mgmtv1alpha1connect.UserAccountServiceClient, connectionService mgmtv1alpha1connect.ConnectionServiceClient, jobService mgmtv1alpha1connect.JobServiceHandler, awsManager awsmanager.NeosyncAwsManagerClient, sqlConnector sqlconnect.SqlConnector, pgquerier pg_queries.Querier, mysqlquerier mysql_queries.Querier, mongoconnector mongoconnect.Interface, sqlmanager sql_manager.SqlManagerClient, gcpmanager neosync_gcp.ManagerInterface, ) *Service
func (*Service) GetAiGeneratedData ¶
func (s *Service) GetAiGeneratedData( ctx context.Context, req *connect.Request[mgmtv1alpha1.GetAiGeneratedDataRequest], ) (*connect.Response[mgmtv1alpha1.GetAiGeneratedDataResponse], error)
func (*Service) GetConnectionDataStream ¶
func (s *Service) GetConnectionDataStream( ctx context.Context, req *connect.Request[mgmtv1alpha1.GetConnectionDataStreamRequest], stream *connect.ServerStream[mgmtv1alpha1.GetConnectionDataStreamResponse], ) error
func (*Service) GetConnectionForeignConstraints ¶
func (s *Service) GetConnectionForeignConstraints( ctx context.Context, req *connect.Request[mgmtv1alpha1.GetConnectionForeignConstraintsRequest], ) (*connect.Response[mgmtv1alpha1.GetConnectionForeignConstraintsResponse], error)
func (*Service) GetConnectionInitStatements ¶
func (s *Service) GetConnectionInitStatements( ctx context.Context, req *connect.Request[mgmtv1alpha1.GetConnectionInitStatementsRequest], ) (*connect.Response[mgmtv1alpha1.GetConnectionInitStatementsResponse], error)
func (*Service) GetConnectionPrimaryConstraints ¶
func (s *Service) GetConnectionPrimaryConstraints( ctx context.Context, req *connect.Request[mgmtv1alpha1.GetConnectionPrimaryConstraintsRequest], ) (*connect.Response[mgmtv1alpha1.GetConnectionPrimaryConstraintsResponse], error)
func (*Service) GetConnectionSchema ¶
func (s *Service) GetConnectionSchema( ctx context.Context, req *connect.Request[mgmtv1alpha1.GetConnectionSchemaRequest], ) (*connect.Response[mgmtv1alpha1.GetConnectionSchemaResponse], error)
func (*Service) GetConnectionSchemaMap ¶ added in v0.4.47
func (s *Service) GetConnectionSchemaMap( ctx context.Context, req *connect.Request[mgmtv1alpha1.GetConnectionSchemaMapRequest], ) (*connect.Response[mgmtv1alpha1.GetConnectionSchemaMapResponse], error)
func (*Service) GetConnectionSchemaMaps ¶ added in v0.4.48
func (s *Service) GetConnectionSchemaMaps( ctx context.Context, req *connect.Request[mgmtv1alpha1.GetConnectionSchemaMapsRequest], ) (*connect.Response[mgmtv1alpha1.GetConnectionSchemaMapsResponse], error)
func (*Service) GetConnectionTableConstraints ¶ added in v0.4.24
func (s *Service) GetConnectionTableConstraints( ctx context.Context, req *connect.Request[mgmtv1alpha1.GetConnectionTableConstraintsRequest], ) (*connect.Response[mgmtv1alpha1.GetConnectionTableConstraintsResponse], error)
func (*Service) GetConnectionUniqueConstraints ¶
func (s *Service) GetConnectionUniqueConstraints( ctx context.Context, req *connect.Request[mgmtv1alpha1.GetConnectionUniqueConstraintsRequest], ) (*connect.Response[mgmtv1alpha1.GetConnectionUniqueConstraintsResponse], error)
func (*Service) GetTableRowCount ¶ added in v0.4.24
func (s *Service) GetTableRowCount( ctx context.Context, req *connect.Request[mgmtv1alpha1.GetTableRowCountRequest], ) (*connect.Response[mgmtv1alpha1.GetTableRowCountResponse], error)
Click to show internal directories.
Click to hide internal directories.