runsqlinittablestmts_activity

Documentation

Index

• type Activity
  • func New(jobclient mgmtv1alpha1connect.JobServiceClient, ...) *Activity
  • func (a *Activity) RunSqlInitTableStatements(ctx context.Context, req *RunSqlInitTableStatementsRequest) (*RunSqlInitTableStatementsResponse, error)
• type RunSqlInitTableStatementsRequest
• type RunSqlInitTableStatementsResponse

Types

type Activity

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

func New

func New(
	jobclient mgmtv1alpha1connect.JobServiceClient,
	connclient mgmtv1alpha1connect.ConnectionServiceClient,
	sqlmanager sql_manager.SqlManagerClient,
) *Activity

func (*Activity) RunSqlInitTableStatements

func (a *Activity) RunSqlInitTableStatements(
	ctx context.Context,
	req *RunSqlInitTableStatementsRequest,
) (*RunSqlInitTableStatementsResponse, error)

type RunSqlInitTableStatementsRequest

type RunSqlInitTableStatementsRequest struct {
	JobId      string
	WorkflowId string
}

type RunSqlInitTableStatementsResponse

type RunSqlInitTableStatementsResponse struct {
}