mgmtv1alpha1connect

package
v0.4.50 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 3, 2024 License: MIT Imports: 7 Imported by: 5

Documentation

Index

Constants

View Source 
const (
	// ApiKeyServiceGetAccountApiKeysProcedure is the fully-qualified name of the ApiKeyService's
	// GetAccountApiKeys RPC.
	ApiKeyServiceGetAccountApiKeysProcedure = "/mgmt.v1alpha1.ApiKeyService/GetAccountApiKeys"
	// ApiKeyServiceGetAccountApiKeyProcedure is the fully-qualified name of the ApiKeyService's
	// GetAccountApiKey RPC.
	ApiKeyServiceGetAccountApiKeyProcedure = "/mgmt.v1alpha1.ApiKeyService/GetAccountApiKey"
	// ApiKeyServiceCreateAccountApiKeyProcedure is the fully-qualified name of the ApiKeyService's
	// CreateAccountApiKey RPC.
	ApiKeyServiceCreateAccountApiKeyProcedure = "/mgmt.v1alpha1.ApiKeyService/CreateAccountApiKey"
	// ApiKeyServiceRegenerateAccountApiKeyProcedure is the fully-qualified name of the ApiKeyService's
	// RegenerateAccountApiKey RPC.
	ApiKeyServiceRegenerateAccountApiKeyProcedure = "/mgmt.v1alpha1.ApiKeyService/RegenerateAccountApiKey"
	// ApiKeyServiceDeleteAccountApiKeyProcedure is the fully-qualified name of the ApiKeyService's
	// DeleteAccountApiKey RPC.
	ApiKeyServiceDeleteAccountApiKeyProcedure = "/mgmt.v1alpha1.ApiKeyService/DeleteAccountApiKey"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// AuthServiceLoginCliProcedure is the fully-qualified name of the AuthService's LoginCli RPC.
	AuthServiceLoginCliProcedure = "/mgmt.v1alpha1.AuthService/LoginCli"
	// AuthServiceRefreshCliProcedure is the fully-qualified name of the AuthService's RefreshCli RPC.
	AuthServiceRefreshCliProcedure = "/mgmt.v1alpha1.AuthService/RefreshCli"
	// AuthServiceCheckTokenProcedure is the fully-qualified name of the AuthService's CheckToken RPC.
	AuthServiceCheckTokenProcedure = "/mgmt.v1alpha1.AuthService/CheckToken"
	// AuthServiceGetCliIssuerProcedure is the fully-qualified name of the AuthService's GetCliIssuer
	// RPC.
	AuthServiceGetCliIssuerProcedure = "/mgmt.v1alpha1.AuthService/GetCliIssuer"
	// AuthServiceGetAuthorizeUrlProcedure is the fully-qualified name of the AuthService's
	// GetAuthorizeUrl RPC.
	AuthServiceGetAuthorizeUrlProcedure = "/mgmt.v1alpha1.AuthService/GetAuthorizeUrl"
	// AuthServiceGetAuthStatusProcedure is the fully-qualified name of the AuthService's GetAuthStatus
	// RPC.
	AuthServiceGetAuthStatusProcedure = "/mgmt.v1alpha1.AuthService/GetAuthStatus"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// ConnectionServiceGetConnectionsProcedure is the fully-qualified name of the ConnectionService's
	// GetConnections RPC.
	ConnectionServiceGetConnectionsProcedure = "/mgmt.v1alpha1.ConnectionService/GetConnections"
	// ConnectionServiceGetConnectionProcedure is the fully-qualified name of the ConnectionService's
	// GetConnection RPC.
	ConnectionServiceGetConnectionProcedure = "/mgmt.v1alpha1.ConnectionService/GetConnection"
	// ConnectionServiceCreateConnectionProcedure is the fully-qualified name of the ConnectionService's
	// CreateConnection RPC.
	ConnectionServiceCreateConnectionProcedure = "/mgmt.v1alpha1.ConnectionService/CreateConnection"
	// ConnectionServiceUpdateConnectionProcedure is the fully-qualified name of the ConnectionService's
	// UpdateConnection RPC.
	ConnectionServiceUpdateConnectionProcedure = "/mgmt.v1alpha1.ConnectionService/UpdateConnection"
	// ConnectionServiceDeleteConnectionProcedure is the fully-qualified name of the ConnectionService's
	// DeleteConnection RPC.
	ConnectionServiceDeleteConnectionProcedure = "/mgmt.v1alpha1.ConnectionService/DeleteConnection"
	// ConnectionServiceIsConnectionNameAvailableProcedure is the fully-qualified name of the
	// ConnectionService's IsConnectionNameAvailable RPC.
	ConnectionServiceIsConnectionNameAvailableProcedure = "/mgmt.v1alpha1.ConnectionService/IsConnectionNameAvailable"
	// ConnectionServiceCheckConnectionConfigProcedure is the fully-qualified name of the
	// ConnectionService's CheckConnectionConfig RPC.
	ConnectionServiceCheckConnectionConfigProcedure = "/mgmt.v1alpha1.ConnectionService/CheckConnectionConfig"
	// ConnectionServiceCheckSqlQueryProcedure is the fully-qualified name of the ConnectionService's
	// CheckSqlQuery RPC.
	ConnectionServiceCheckSqlQueryProcedure = "/mgmt.v1alpha1.ConnectionService/CheckSqlQuery"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// ConnectionDataServiceGetConnectionDataStreamProcedure is the fully-qualified name of the
	// ConnectionDataService's GetConnectionDataStream RPC.
	ConnectionDataServiceGetConnectionDataStreamProcedure = "/mgmt.v1alpha1.ConnectionDataService/GetConnectionDataStream"
	// ConnectionDataServiceGetConnectionSchemaProcedure is the fully-qualified name of the
	// ConnectionDataService's GetConnectionSchema RPC.
	ConnectionDataServiceGetConnectionSchemaProcedure = "/mgmt.v1alpha1.ConnectionDataService/GetConnectionSchema"
	// ConnectionDataServiceGetConnectionSchemaMapProcedure is the fully-qualified name of the
	// ConnectionDataService's GetConnectionSchemaMap RPC.
	ConnectionDataServiceGetConnectionSchemaMapProcedure = "/mgmt.v1alpha1.ConnectionDataService/GetConnectionSchemaMap"
	// ConnectionDataServiceGetConnectionSchemaMapsProcedure is the fully-qualified name of the
	// ConnectionDataService's GetConnectionSchemaMaps RPC.
	ConnectionDataServiceGetConnectionSchemaMapsProcedure = "/mgmt.v1alpha1.ConnectionDataService/GetConnectionSchemaMaps"
	// ConnectionDataServiceGetConnectionTableConstraintsProcedure is the fully-qualified name of the
	// ConnectionDataService's GetConnectionTableConstraints RPC.
	ConnectionDataServiceGetConnectionTableConstraintsProcedure = "/mgmt.v1alpha1.ConnectionDataService/GetConnectionTableConstraints"
	// ConnectionDataServiceGetConnectionForeignConstraintsProcedure is the fully-qualified name of the
	// ConnectionDataService's GetConnectionForeignConstraints RPC.
	ConnectionDataServiceGetConnectionForeignConstraintsProcedure = "/mgmt.v1alpha1.ConnectionDataService/GetConnectionForeignConstraints"
	// ConnectionDataServiceGetConnectionPrimaryConstraintsProcedure is the fully-qualified name of the
	// ConnectionDataService's GetConnectionPrimaryConstraints RPC.
	ConnectionDataServiceGetConnectionPrimaryConstraintsProcedure = "/mgmt.v1alpha1.ConnectionDataService/GetConnectionPrimaryConstraints"
	// ConnectionDataServiceGetConnectionInitStatementsProcedure is the fully-qualified name of the
	// ConnectionDataService's GetConnectionInitStatements RPC.
	ConnectionDataServiceGetConnectionInitStatementsProcedure = "/mgmt.v1alpha1.ConnectionDataService/GetConnectionInitStatements"
	// ConnectionDataServiceGetConnectionUniqueConstraintsProcedure is the fully-qualified name of the
	// ConnectionDataService's GetConnectionUniqueConstraints RPC.
	ConnectionDataServiceGetConnectionUniqueConstraintsProcedure = "/mgmt.v1alpha1.ConnectionDataService/GetConnectionUniqueConstraints"
	// ConnectionDataServiceGetAiGeneratedDataProcedure is the fully-qualified name of the
	// ConnectionDataService's GetAiGeneratedData RPC.
	ConnectionDataServiceGetAiGeneratedDataProcedure = "/mgmt.v1alpha1.ConnectionDataService/GetAiGeneratedData"
	// ConnectionDataServiceGetTableRowCountProcedure is the fully-qualified name of the
	// ConnectionDataService's GetTableRowCount RPC.
	ConnectionDataServiceGetTableRowCountProcedure = "/mgmt.v1alpha1.ConnectionDataService/GetTableRowCount"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// JobServiceGetJobsProcedure is the fully-qualified name of the JobService's GetJobs RPC.
	JobServiceGetJobsProcedure = "/mgmt.v1alpha1.JobService/GetJobs"
	// JobServiceGetJobProcedure is the fully-qualified name of the JobService's GetJob RPC.
	JobServiceGetJobProcedure = "/mgmt.v1alpha1.JobService/GetJob"
	// JobServiceCreateJobProcedure is the fully-qualified name of the JobService's CreateJob RPC.
	JobServiceCreateJobProcedure = "/mgmt.v1alpha1.JobService/CreateJob"
	// JobServiceDeleteJobProcedure is the fully-qualified name of the JobService's DeleteJob RPC.
	JobServiceDeleteJobProcedure = "/mgmt.v1alpha1.JobService/DeleteJob"
	// JobServiceIsJobNameAvailableProcedure is the fully-qualified name of the JobService's
	// IsJobNameAvailable RPC.
	JobServiceIsJobNameAvailableProcedure = "/mgmt.v1alpha1.JobService/IsJobNameAvailable"
	// JobServiceUpdateJobScheduleProcedure is the fully-qualified name of the JobService's
	// UpdateJobSchedule RPC.
	JobServiceUpdateJobScheduleProcedure = "/mgmt.v1alpha1.JobService/UpdateJobSchedule"
	// JobServiceUpdateJobSourceConnectionProcedure is the fully-qualified name of the JobService's
	// UpdateJobSourceConnection RPC.
	JobServiceUpdateJobSourceConnectionProcedure = "/mgmt.v1alpha1.JobService/UpdateJobSourceConnection"
	// JobServiceSetJobSourceSqlConnectionSubsetsProcedure is the fully-qualified name of the
	// JobService's SetJobSourceSqlConnectionSubsets RPC.
	JobServiceSetJobSourceSqlConnectionSubsetsProcedure = "/mgmt.v1alpha1.JobService/SetJobSourceSqlConnectionSubsets"
	// JobServiceUpdateJobDestinationConnectionProcedure is the fully-qualified name of the JobService's
	// UpdateJobDestinationConnection RPC.
	JobServiceUpdateJobDestinationConnectionProcedure = "/mgmt.v1alpha1.JobService/UpdateJobDestinationConnection"
	// JobServiceDeleteJobDestinationConnectionProcedure is the fully-qualified name of the JobService's
	// DeleteJobDestinationConnection RPC.
	JobServiceDeleteJobDestinationConnectionProcedure = "/mgmt.v1alpha1.JobService/DeleteJobDestinationConnection"
	// JobServiceCreateJobDestinationConnectionsProcedure is the fully-qualified name of the
	// JobService's CreateJobDestinationConnections RPC.
	JobServiceCreateJobDestinationConnectionsProcedure = "/mgmt.v1alpha1.JobService/CreateJobDestinationConnections"
	// JobServicePauseJobProcedure is the fully-qualified name of the JobService's PauseJob RPC.
	JobServicePauseJobProcedure = "/mgmt.v1alpha1.JobService/PauseJob"
	// JobServiceGetJobRecentRunsProcedure is the fully-qualified name of the JobService's
	// GetJobRecentRuns RPC.
	JobServiceGetJobRecentRunsProcedure = "/mgmt.v1alpha1.JobService/GetJobRecentRuns"
	// JobServiceGetJobNextRunsProcedure is the fully-qualified name of the JobService's GetJobNextRuns
	// RPC.
	JobServiceGetJobNextRunsProcedure = "/mgmt.v1alpha1.JobService/GetJobNextRuns"
	// JobServiceGetJobStatusProcedure is the fully-qualified name of the JobService's GetJobStatus RPC.
	JobServiceGetJobStatusProcedure = "/mgmt.v1alpha1.JobService/GetJobStatus"
	// JobServiceGetJobStatusesProcedure is the fully-qualified name of the JobService's GetJobStatuses
	// RPC.
	JobServiceGetJobStatusesProcedure = "/mgmt.v1alpha1.JobService/GetJobStatuses"
	// JobServiceGetJobRunsProcedure is the fully-qualified name of the JobService's GetJobRuns RPC.
	JobServiceGetJobRunsProcedure = "/mgmt.v1alpha1.JobService/GetJobRuns"
	// JobServiceGetJobRunEventsProcedure is the fully-qualified name of the JobService's
	// GetJobRunEvents RPC.
	JobServiceGetJobRunEventsProcedure = "/mgmt.v1alpha1.JobService/GetJobRunEvents"
	// JobServiceGetJobRunProcedure is the fully-qualified name of the JobService's GetJobRun RPC.
	JobServiceGetJobRunProcedure = "/mgmt.v1alpha1.JobService/GetJobRun"
	// JobServiceDeleteJobRunProcedure is the fully-qualified name of the JobService's DeleteJobRun RPC.
	JobServiceDeleteJobRunProcedure = "/mgmt.v1alpha1.JobService/DeleteJobRun"
	// JobServiceCreateJobRunProcedure is the fully-qualified name of the JobService's CreateJobRun RPC.
	JobServiceCreateJobRunProcedure = "/mgmt.v1alpha1.JobService/CreateJobRun"
	// JobServiceCancelJobRunProcedure is the fully-qualified name of the JobService's CancelJobRun RPC.
	JobServiceCancelJobRunProcedure = "/mgmt.v1alpha1.JobService/CancelJobRun"
	// JobServiceTerminateJobRunProcedure is the fully-qualified name of the JobService's
	// TerminateJobRun RPC.
	JobServiceTerminateJobRunProcedure = "/mgmt.v1alpha1.JobService/TerminateJobRun"
	// JobServiceGetJobRunLogsStreamProcedure is the fully-qualified name of the JobService's
	// GetJobRunLogsStream RPC.
	JobServiceGetJobRunLogsStreamProcedure = "/mgmt.v1alpha1.JobService/GetJobRunLogsStream"
	// JobServiceSetJobWorkflowOptionsProcedure is the fully-qualified name of the JobService's
	// SetJobWorkflowOptions RPC.
	JobServiceSetJobWorkflowOptionsProcedure = "/mgmt.v1alpha1.JobService/SetJobWorkflowOptions"
	// JobServiceSetJobSyncOptionsProcedure is the fully-qualified name of the JobService's
	// SetJobSyncOptions RPC.
	JobServiceSetJobSyncOptionsProcedure = "/mgmt.v1alpha1.JobService/SetJobSyncOptions"
	// JobServiceValidateJobMappingsProcedure is the fully-qualified name of the JobService's
	// ValidateJobMappings RPC.
	JobServiceValidateJobMappingsProcedure = "/mgmt.v1alpha1.JobService/ValidateJobMappings"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// MetricsServiceGetDailyMetricCountProcedure is the fully-qualified name of the MetricsService's
	// GetDailyMetricCount RPC.
	MetricsServiceGetDailyMetricCountProcedure = "/mgmt.v1alpha1.MetricsService/GetDailyMetricCount"
	// MetricsServiceGetMetricCountProcedure is the fully-qualified name of the MetricsService's
	// GetMetricCount RPC.
	MetricsServiceGetMetricCountProcedure = "/mgmt.v1alpha1.MetricsService/GetMetricCount"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// TransformersServiceGetSystemTransformersProcedure is the fully-qualified name of the
	// TransformersService's GetSystemTransformers RPC.
	TransformersServiceGetSystemTransformersProcedure = "/mgmt.v1alpha1.TransformersService/GetSystemTransformers"
	// TransformersServiceGetSystemTransformerBySourceProcedure is the fully-qualified name of the
	// TransformersService's GetSystemTransformerBySource RPC.
	TransformersServiceGetSystemTransformerBySourceProcedure = "/mgmt.v1alpha1.TransformersService/GetSystemTransformerBySource"
	// TransformersServiceGetUserDefinedTransformersProcedure is the fully-qualified name of the
	// TransformersService's GetUserDefinedTransformers RPC.
	TransformersServiceGetUserDefinedTransformersProcedure = "/mgmt.v1alpha1.TransformersService/GetUserDefinedTransformers"
	// TransformersServiceGetUserDefinedTransformerByIdProcedure is the fully-qualified name of the
	// TransformersService's GetUserDefinedTransformerById RPC.
	TransformersServiceGetUserDefinedTransformerByIdProcedure = "/mgmt.v1alpha1.TransformersService/GetUserDefinedTransformerById"
	// TransformersServiceCreateUserDefinedTransformerProcedure is the fully-qualified name of the
	// TransformersService's CreateUserDefinedTransformer RPC.
	TransformersServiceCreateUserDefinedTransformerProcedure = "/mgmt.v1alpha1.TransformersService/CreateUserDefinedTransformer"
	// TransformersServiceDeleteUserDefinedTransformerProcedure is the fully-qualified name of the
	// TransformersService's DeleteUserDefinedTransformer RPC.
	TransformersServiceDeleteUserDefinedTransformerProcedure = "/mgmt.v1alpha1.TransformersService/DeleteUserDefinedTransformer"
	// TransformersServiceUpdateUserDefinedTransformerProcedure is the fully-qualified name of the
	// TransformersService's UpdateUserDefinedTransformer RPC.
	TransformersServiceUpdateUserDefinedTransformerProcedure = "/mgmt.v1alpha1.TransformersService/UpdateUserDefinedTransformer"
	// TransformersServiceIsTransformerNameAvailableProcedure is the fully-qualified name of the
	// TransformersService's IsTransformerNameAvailable RPC.
	TransformersServiceIsTransformerNameAvailableProcedure = "/mgmt.v1alpha1.TransformersService/IsTransformerNameAvailable"
	// TransformersServiceValidateUserJavascriptCodeProcedure is the fully-qualified name of the
	// TransformersService's ValidateUserJavascriptCode RPC.
	TransformersServiceValidateUserJavascriptCodeProcedure = "/mgmt.v1alpha1.TransformersService/ValidateUserJavascriptCode"
	// TransformersServiceValidateUserRegexCodeProcedure is the fully-qualified name of the
	// TransformersService's ValidateUserRegexCode RPC.
	TransformersServiceValidateUserRegexCodeProcedure = "/mgmt.v1alpha1.TransformersService/ValidateUserRegexCode"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// UserAccountServiceGetUserProcedure is the fully-qualified name of the UserAccountService's
	// GetUser RPC.
	UserAccountServiceGetUserProcedure = "/mgmt.v1alpha1.UserAccountService/GetUser"
	// UserAccountServiceSetUserProcedure is the fully-qualified name of the UserAccountService's
	// SetUser RPC.
	UserAccountServiceSetUserProcedure = "/mgmt.v1alpha1.UserAccountService/SetUser"
	// UserAccountServiceGetUserAccountsProcedure is the fully-qualified name of the
	// UserAccountService's GetUserAccounts RPC.
	UserAccountServiceGetUserAccountsProcedure = "/mgmt.v1alpha1.UserAccountService/GetUserAccounts"
	// UserAccountServiceSetPersonalAccountProcedure is the fully-qualified name of the
	// UserAccountService's SetPersonalAccount RPC.
	UserAccountServiceSetPersonalAccountProcedure = "/mgmt.v1alpha1.UserAccountService/SetPersonalAccount"
	// UserAccountServiceConvertPersonalToTeamAccountProcedure is the fully-qualified name of the
	// UserAccountService's ConvertPersonalToTeamAccount RPC.
	UserAccountServiceConvertPersonalToTeamAccountProcedure = "/mgmt.v1alpha1.UserAccountService/ConvertPersonalToTeamAccount"
	// UserAccountServiceCreateTeamAccountProcedure is the fully-qualified name of the
	// UserAccountService's CreateTeamAccount RPC.
	UserAccountServiceCreateTeamAccountProcedure = "/mgmt.v1alpha1.UserAccountService/CreateTeamAccount"
	// UserAccountServiceIsUserInAccountProcedure is the fully-qualified name of the
	// UserAccountService's IsUserInAccount RPC.
	UserAccountServiceIsUserInAccountProcedure = "/mgmt.v1alpha1.UserAccountService/IsUserInAccount"
	// UserAccountServiceGetAccountTemporalConfigProcedure is the fully-qualified name of the
	// UserAccountService's GetAccountTemporalConfig RPC.
	UserAccountServiceGetAccountTemporalConfigProcedure = "/mgmt.v1alpha1.UserAccountService/GetAccountTemporalConfig"
	// UserAccountServiceSetAccountTemporalConfigProcedure is the fully-qualified name of the
	// UserAccountService's SetAccountTemporalConfig RPC.
	UserAccountServiceSetAccountTemporalConfigProcedure = "/mgmt.v1alpha1.UserAccountService/SetAccountTemporalConfig"
	// UserAccountServiceGetTeamAccountMembersProcedure is the fully-qualified name of the
	// UserAccountService's GetTeamAccountMembers RPC.
	UserAccountServiceGetTeamAccountMembersProcedure = "/mgmt.v1alpha1.UserAccountService/GetTeamAccountMembers"
	// UserAccountServiceRemoveTeamAccountMemberProcedure is the fully-qualified name of the
	// UserAccountService's RemoveTeamAccountMember RPC.
	UserAccountServiceRemoveTeamAccountMemberProcedure = "/mgmt.v1alpha1.UserAccountService/RemoveTeamAccountMember"
	// UserAccountServiceInviteUserToTeamAccountProcedure is the fully-qualified name of the
	// UserAccountService's InviteUserToTeamAccount RPC.
	UserAccountServiceInviteUserToTeamAccountProcedure = "/mgmt.v1alpha1.UserAccountService/InviteUserToTeamAccount"
	// UserAccountServiceGetTeamAccountInvitesProcedure is the fully-qualified name of the
	// UserAccountService's GetTeamAccountInvites RPC.
	UserAccountServiceGetTeamAccountInvitesProcedure = "/mgmt.v1alpha1.UserAccountService/GetTeamAccountInvites"
	// UserAccountServiceRemoveTeamAccountInviteProcedure is the fully-qualified name of the
	// UserAccountService's RemoveTeamAccountInvite RPC.
	UserAccountServiceRemoveTeamAccountInviteProcedure = "/mgmt.v1alpha1.UserAccountService/RemoveTeamAccountInvite"
	// UserAccountServiceAcceptTeamAccountInviteProcedure is the fully-qualified name of the
	// UserAccountService's AcceptTeamAccountInvite RPC.
	UserAccountServiceAcceptTeamAccountInviteProcedure = "/mgmt.v1alpha1.UserAccountService/AcceptTeamAccountInvite"
	// UserAccountServiceGetSystemInformationProcedure is the fully-qualified name of the
	// UserAccountService's GetSystemInformation RPC.
	UserAccountServiceGetSystemInformationProcedure = "/mgmt.v1alpha1.UserAccountService/GetSystemInformation"
	// UserAccountServiceGetAccountOnboardingConfigProcedure is the fully-qualified name of the
	// UserAccountService's GetAccountOnboardingConfig RPC.
	UserAccountServiceGetAccountOnboardingConfigProcedure = "/mgmt.v1alpha1.UserAccountService/GetAccountOnboardingConfig"
	// UserAccountServiceSetAccountOnboardingConfigProcedure is the fully-qualified name of the
	// UserAccountService's SetAccountOnboardingConfig RPC.
	UserAccountServiceSetAccountOnboardingConfigProcedure = "/mgmt.v1alpha1.UserAccountService/SetAccountOnboardingConfig"
)

These constants are the fully-qualified names of the RPCs defined in this package. They're exposed at runtime as Spec.Procedure and as the final two segments of the HTTP route.

Note that these are different from the fully-qualified method names used by google.golang.org/protobuf/reflect/protoreflect. To convert from these constants to reflection-formatted method names, remove the leading slash and convert the remaining slash to a period.

View Source 
const (
	// ApiKeyServiceName is the fully-qualified name of the ApiKeyService service.
	ApiKeyServiceName = "mgmt.v1alpha1.ApiKeyService"
)
View Source 
const (
	// AuthServiceName is the fully-qualified name of the AuthService service.
	AuthServiceName = "mgmt.v1alpha1.AuthService"
)
View Source 
const (
	// ConnectionDataServiceName is the fully-qualified name of the ConnectionDataService service.
	ConnectionDataServiceName = "mgmt.v1alpha1.ConnectionDataService"
)
View Source 
const (
	// ConnectionServiceName is the fully-qualified name of the ConnectionService service.
	ConnectionServiceName = "mgmt.v1alpha1.ConnectionService"
)
View Source 
const (
	// JobServiceName is the fully-qualified name of the JobService service.
	JobServiceName = "mgmt.v1alpha1.JobService"
)
View Source 
const (
	// MetricsServiceName is the fully-qualified name of the MetricsService service.
	MetricsServiceName = "mgmt.v1alpha1.MetricsService"
)
View Source 
const (
	// TransformersServiceName is the fully-qualified name of the TransformersService service.
	TransformersServiceName = "mgmt.v1alpha1.TransformersService"
)
View Source 
const (
	// UserAccountServiceName is the fully-qualified name of the UserAccountService service.
	UserAccountServiceName = "mgmt.v1alpha1.UserAccountService"
)

Variables

This section is empty.

Functions

func NewApiKeyServiceHandler 

func NewApiKeyServiceHandler(svc ApiKeyServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewApiKeyServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewAuthServiceHandler 

func NewAuthServiceHandler(svc AuthServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewAuthServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewConnectionDataServiceHandler 

func NewConnectionDataServiceHandler(svc ConnectionDataServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewConnectionDataServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewConnectionServiceHandler 

func NewConnectionServiceHandler(svc ConnectionServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewConnectionServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewJobServiceHandler 

func NewJobServiceHandler(svc JobServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewJobServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewMetricsServiceHandler 

func NewMetricsServiceHandler(svc MetricsServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewMetricsServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewTransformersServiceHandler 

func NewTransformersServiceHandler(svc TransformersServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewTransformersServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

func NewUserAccountServiceHandler 

func NewUserAccountServiceHandler(svc UserAccountServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

NewUserAccountServiceHandler builds an HTTP handler from the service implementation. It returns the path on which to mount the handler and the handler itself.

By default, handlers support the Connect, gRPC, and gRPC-Web protocols with the binary Protobuf and JSON codecs. They also support gzip compression.

Types

type ApiKeyServiceClient 

type ApiKeyServiceClient interface {
	// Retrieves a list of Account API Keys
	GetAccountApiKeys(context.Context, *connect.Request[v1alpha1.GetAccountApiKeysRequest]) (*connect.Response[v1alpha1.GetAccountApiKeysResponse], error)
	// Retrieves a single API Key
	GetAccountApiKey(context.Context, *connect.Request[v1alpha1.GetAccountApiKeyRequest]) (*connect.Response[v1alpha1.GetAccountApiKeyResponse], error)
	// Creates a single API Key
	// This method will return the decrypted contents of the API key
	CreateAccountApiKey(context.Context, *connect.Request[v1alpha1.CreateAccountApiKeyRequest]) (*connect.Response[v1alpha1.CreateAccountApiKeyResponse], error)
	// Regenerates a single API Key with a new expiration time
	// This method will return the decrypted contents of the API key
	RegenerateAccountApiKey(context.Context, *connect.Request[v1alpha1.RegenerateAccountApiKeyRequest]) (*connect.Response[v1alpha1.RegenerateAccountApiKeyResponse], error)
	// Deletes an API Key from the system.
	DeleteAccountApiKey(context.Context, *connect.Request[v1alpha1.DeleteAccountApiKeyRequest]) (*connect.Response[v1alpha1.DeleteAccountApiKeyResponse], error)
}

ApiKeyServiceClient is a client for the mgmt.v1alpha1.ApiKeyService service.

func NewApiKeyServiceClient 

func NewApiKeyServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ApiKeyServiceClient

NewApiKeyServiceClient constructs a client for the mgmt.v1alpha1.ApiKeyService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type ApiKeyServiceHandler 

type ApiKeyServiceHandler interface {
	// Retrieves a list of Account API Keys
	GetAccountApiKeys(context.Context, *connect.Request[v1alpha1.GetAccountApiKeysRequest]) (*connect.Response[v1alpha1.GetAccountApiKeysResponse], error)
	// Retrieves a single API Key
	GetAccountApiKey(context.Context, *connect.Request[v1alpha1.GetAccountApiKeyRequest]) (*connect.Response[v1alpha1.GetAccountApiKeyResponse], error)
	// Creates a single API Key
	// This method will return the decrypted contents of the API key
	CreateAccountApiKey(context.Context, *connect.Request[v1alpha1.CreateAccountApiKeyRequest]) (*connect.Response[v1alpha1.CreateAccountApiKeyResponse], error)
	// Regenerates a single API Key with a new expiration time
	// This method will return the decrypted contents of the API key
	RegenerateAccountApiKey(context.Context, *connect.Request[v1alpha1.RegenerateAccountApiKeyRequest]) (*connect.Response[v1alpha1.RegenerateAccountApiKeyResponse], error)
	// Deletes an API Key from the system.
	DeleteAccountApiKey(context.Context, *connect.Request[v1alpha1.DeleteAccountApiKeyRequest]) (*connect.Response[v1alpha1.DeleteAccountApiKeyResponse], error)
}

ApiKeyServiceHandler is an implementation of the mgmt.v1alpha1.ApiKeyService service.

type AuthServiceClient 

type AuthServiceClient interface {
	// Used by the CLI to login to Neosync with OAuth.
	LoginCli(context.Context, *connect.Request[v1alpha1.LoginCliRequest]) (*connect.Response[v1alpha1.LoginCliResponse], error)
	// Used by the CLI to refresh an expired Neosync accesss token.
	// This should only be used if an access token was previously retrieved from the `LoginCli` or `RefreshCli` methods.
	RefreshCli(context.Context, *connect.Request[v1alpha1.RefreshCliRequest]) (*connect.Response[v1alpha1.RefreshCliResponse], error)
	// Empty endpoint to simply check if the provided access token is valid
	CheckToken(context.Context, *connect.Request[v1alpha1.CheckTokenRequest]) (*connect.Response[v1alpha1.CheckTokenResponse], error)
	// Used by the CLI to retrieve Auth Issuer information
	// @deprecated
	GetCliIssuer(context.Context, *connect.Request[v1alpha1.GetCliIssuerRequest]) (*connect.Response[v1alpha1.GetCliIssuerResponse], error)
	// Used by the CLI to retrieve an Authorize URL for use with OAuth login.
	GetAuthorizeUrl(context.Context, *connect.Request[v1alpha1.GetAuthorizeUrlRequest]) (*connect.Response[v1alpha1.GetAuthorizeUrlResponse], error)
	// Returns the auth status of the API server. Whether or not the backend has authentication enabled.
	// This is used by clients to make decisions on whether or not they should send access tokens to the API.
	GetAuthStatus(context.Context, *connect.Request[v1alpha1.GetAuthStatusRequest]) (*connect.Response[v1alpha1.GetAuthStatusResponse], error)
}

AuthServiceClient is a client for the mgmt.v1alpha1.AuthService service.

func NewAuthServiceClient 

func NewAuthServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) AuthServiceClient

NewAuthServiceClient constructs a client for the mgmt.v1alpha1.AuthService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type AuthServiceHandler 

type AuthServiceHandler interface {
	// Used by the CLI to login to Neosync with OAuth.
	LoginCli(context.Context, *connect.Request[v1alpha1.LoginCliRequest]) (*connect.Response[v1alpha1.LoginCliResponse], error)
	// Used by the CLI to refresh an expired Neosync accesss token.
	// This should only be used if an access token was previously retrieved from the `LoginCli` or `RefreshCli` methods.
	RefreshCli(context.Context, *connect.Request[v1alpha1.RefreshCliRequest]) (*connect.Response[v1alpha1.RefreshCliResponse], error)
	// Empty endpoint to simply check if the provided access token is valid
	CheckToken(context.Context, *connect.Request[v1alpha1.CheckTokenRequest]) (*connect.Response[v1alpha1.CheckTokenResponse], error)
	// Used by the CLI to retrieve Auth Issuer information
	// @deprecated
	GetCliIssuer(context.Context, *connect.Request[v1alpha1.GetCliIssuerRequest]) (*connect.Response[v1alpha1.GetCliIssuerResponse], error)
	// Used by the CLI to retrieve an Authorize URL for use with OAuth login.
	GetAuthorizeUrl(context.Context, *connect.Request[v1alpha1.GetAuthorizeUrlRequest]) (*connect.Response[v1alpha1.GetAuthorizeUrlResponse], error)
	// Returns the auth status of the API server. Whether or not the backend has authentication enabled.
	// This is used by clients to make decisions on whether or not they should send access tokens to the API.
	GetAuthStatus(context.Context, *connect.Request[v1alpha1.GetAuthStatusRequest]) (*connect.Response[v1alpha1.GetAuthStatusResponse], error)
}

AuthServiceHandler is an implementation of the mgmt.v1alpha1.AuthService service.

type ConnectionDataServiceClient 

type ConnectionDataServiceClient interface {
	// Streaming endpoint that will stream the data available from the Connection to the client.
	// Used primarily by the CLI sync command.
	GetConnectionDataStream(context.Context, *connect.Request[v1alpha1.GetConnectionDataStreamRequest]) (*connect.ServerStreamForClient[v1alpha1.GetConnectionDataStreamResponse], error)
	// Returns the schema for a specific connection. Used mostly for SQL-based connections
	GetConnectionSchema(context.Context, *connect.Request[v1alpha1.GetConnectionSchemaRequest]) (*connect.Response[v1alpha1.GetConnectionSchemaResponse], error)
	// Returns the schema in map format. The keys are the fully qualified table in the format <schema>.<table>
	GetConnectionSchemaMap(context.Context, *connect.Request[v1alpha1.GetConnectionSchemaMapRequest]) (*connect.Response[v1alpha1.GetConnectionSchemaMapResponse], error)
	// Returns the schema in map format for every request provided
	GetConnectionSchemaMaps(context.Context, *connect.Request[v1alpha1.GetConnectionSchemaMapsRequest]) (*connect.Response[v1alpha1.GetConnectionSchemaMapsResponse], error)
	// For a specific connection, returns the table constraints. Mostly useful for SQL-based Connections.
	GetConnectionTableConstraints(context.Context, *connect.Request[v1alpha1.GetConnectionTableConstraintsRequest]) (*connect.Response[v1alpha1.GetConnectionTableConstraintsResponse], error)
	// For a specific connection, returns the foreign key constraints. Mostly useful for SQL-based Connections.
	// Used primarily by the CLI sync command to determine stream order.
	GetConnectionForeignConstraints(context.Context, *connect.Request[v1alpha1.GetConnectionForeignConstraintsRequest]) (*connect.Response[v1alpha1.GetConnectionForeignConstraintsResponse], error)
	// For a specific connection, returns the primary key constraints. Mostly useful for SQL-based Connections.
	// Used primarily by the CLI sync command to determine stream order.
	GetConnectionPrimaryConstraints(context.Context, *connect.Request[v1alpha1.GetConnectionPrimaryConstraintsRequest]) (*connect.Response[v1alpha1.GetConnectionPrimaryConstraintsResponse], error)
	// For a specific connection, returns the init table statements. Mostly useful for SQL-based Connections.
	// Used primarily by the CLI sync command to create table schema init statement.
	GetConnectionInitStatements(context.Context, *connect.Request[v1alpha1.GetConnectionInitStatementsRequest]) (*connect.Response[v1alpha1.GetConnectionInitStatementsResponse], error)
	// For a specific connection, returns the unique constraints. Mostly useful for SQL-based connections.
	GetConnectionUniqueConstraints(context.Context, *connect.Request[v1alpha1.GetConnectionUniqueConstraintsRequest]) (*connect.Response[v1alpha1.GetConnectionUniqueConstraintsResponse], error)
	// Query an AI connection by providing the necessary values. Typically used for generating preview data
	GetAiGeneratedData(context.Context, *connect.Request[v1alpha1.GetAiGeneratedDataRequest]) (*connect.Response[v1alpha1.GetAiGeneratedDataResponse], error)
	// Query table with subset to get row count
	GetTableRowCount(context.Context, *connect.Request[v1alpha1.GetTableRowCountRequest]) (*connect.Response[v1alpha1.GetTableRowCountResponse], error)
}

ConnectionDataServiceClient is a client for the mgmt.v1alpha1.ConnectionDataService service.

func NewConnectionDataServiceClient 

func NewConnectionDataServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ConnectionDataServiceClient

NewConnectionDataServiceClient constructs a client for the mgmt.v1alpha1.ConnectionDataService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type ConnectionDataServiceHandler 

type ConnectionDataServiceHandler interface {
	// Streaming endpoint that will stream the data available from the Connection to the client.
	// Used primarily by the CLI sync command.
	GetConnectionDataStream(context.Context, *connect.Request[v1alpha1.GetConnectionDataStreamRequest], *connect.ServerStream[v1alpha1.GetConnectionDataStreamResponse]) error
	// Returns the schema for a specific connection. Used mostly for SQL-based connections
	GetConnectionSchema(context.Context, *connect.Request[v1alpha1.GetConnectionSchemaRequest]) (*connect.Response[v1alpha1.GetConnectionSchemaResponse], error)
	// Returns the schema in map format. The keys are the fully qualified table in the format <schema>.<table>
	GetConnectionSchemaMap(context.Context, *connect.Request[v1alpha1.GetConnectionSchemaMapRequest]) (*connect.Response[v1alpha1.GetConnectionSchemaMapResponse], error)
	// Returns the schema in map format for every request provided
	GetConnectionSchemaMaps(context.Context, *connect.Request[v1alpha1.GetConnectionSchemaMapsRequest]) (*connect.Response[v1alpha1.GetConnectionSchemaMapsResponse], error)
	// For a specific connection, returns the table constraints. Mostly useful for SQL-based Connections.
	GetConnectionTableConstraints(context.Context, *connect.Request[v1alpha1.GetConnectionTableConstraintsRequest]) (*connect.Response[v1alpha1.GetConnectionTableConstraintsResponse], error)
	// For a specific connection, returns the foreign key constraints. Mostly useful for SQL-based Connections.
	// Used primarily by the CLI sync command to determine stream order.
	GetConnectionForeignConstraints(context.Context, *connect.Request[v1alpha1.GetConnectionForeignConstraintsRequest]) (*connect.Response[v1alpha1.GetConnectionForeignConstraintsResponse], error)
	// For a specific connection, returns the primary key constraints. Mostly useful for SQL-based Connections.
	// Used primarily by the CLI sync command to determine stream order.
	GetConnectionPrimaryConstraints(context.Context, *connect.Request[v1alpha1.GetConnectionPrimaryConstraintsRequest]) (*connect.Response[v1alpha1.GetConnectionPrimaryConstraintsResponse], error)
	// For a specific connection, returns the init table statements. Mostly useful for SQL-based Connections.
	// Used primarily by the CLI sync command to create table schema init statement.
	GetConnectionInitStatements(context.Context, *connect.Request[v1alpha1.GetConnectionInitStatementsRequest]) (*connect.Response[v1alpha1.GetConnectionInitStatementsResponse], error)
	// For a specific connection, returns the unique constraints. Mostly useful for SQL-based connections.
	GetConnectionUniqueConstraints(context.Context, *connect.Request[v1alpha1.GetConnectionUniqueConstraintsRequest]) (*connect.Response[v1alpha1.GetConnectionUniqueConstraintsResponse], error)
	// Query an AI connection by providing the necessary values. Typically used for generating preview data
	GetAiGeneratedData(context.Context, *connect.Request[v1alpha1.GetAiGeneratedDataRequest]) (*connect.Response[v1alpha1.GetAiGeneratedDataResponse], error)
	// Query table with subset to get row count
	GetTableRowCount(context.Context, *connect.Request[v1alpha1.GetTableRowCountRequest]) (*connect.Response[v1alpha1.GetTableRowCountResponse], error)
}

ConnectionDataServiceHandler is an implementation of the mgmt.v1alpha1.ConnectionDataService service.

type ConnectionServiceClient 

type ConnectionServiceClient interface {
	// Returns a list of connections associated with the account
	GetConnections(context.Context, *connect.Request[v1alpha1.GetConnectionsRequest]) (*connect.Response[v1alpha1.GetConnectionsResponse], error)
	// Returns a single connection
	GetConnection(context.Context, *connect.Request[v1alpha1.GetConnectionRequest]) (*connect.Response[v1alpha1.GetConnectionResponse], error)
	// Creates a new connection
	CreateConnection(context.Context, *connect.Request[v1alpha1.CreateConnectionRequest]) (*connect.Response[v1alpha1.CreateConnectionResponse], error)
	// Updates an existing connection
	UpdateConnection(context.Context, *connect.Request[v1alpha1.UpdateConnectionRequest]) (*connect.Response[v1alpha1.UpdateConnectionResponse], error)
	// Removes a connection from the system.
	DeleteConnection(context.Context, *connect.Request[v1alpha1.DeleteConnectionRequest]) (*connect.Response[v1alpha1.DeleteConnectionResponse], error)
	// Connections have friendly names, this method checks if the requested name is available in the system based on the account
	IsConnectionNameAvailable(context.Context, *connect.Request[v1alpha1.IsConnectionNameAvailableRequest]) (*connect.Response[v1alpha1.IsConnectionNameAvailableResponse], error)
	// Checks if the connection config is connectable by the backend.
	// Used mostly to verify that a connection is valid prior to creating a Connection object.
	CheckConnectionConfig(context.Context, *connect.Request[v1alpha1.CheckConnectionConfigRequest]) (*connect.Response[v1alpha1.CheckConnectionConfigResponse], error)
	// Checks a constructed SQL query against a sql-based connection to see if it's valid based on that connection's data schema
	// This is useful when constructing subsets to see if the WHERE clause is correct
	CheckSqlQuery(context.Context, *connect.Request[v1alpha1.CheckSqlQueryRequest]) (*connect.Response[v1alpha1.CheckSqlQueryResponse], error)
}

ConnectionServiceClient is a client for the mgmt.v1alpha1.ConnectionService service.

func NewConnectionServiceClient 

func NewConnectionServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) ConnectionServiceClient

NewConnectionServiceClient constructs a client for the mgmt.v1alpha1.ConnectionService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type ConnectionServiceHandler 

type ConnectionServiceHandler interface {
	// Returns a list of connections associated with the account
	GetConnections(context.Context, *connect.Request[v1alpha1.GetConnectionsRequest]) (*connect.Response[v1alpha1.GetConnectionsResponse], error)
	// Returns a single connection
	GetConnection(context.Context, *connect.Request[v1alpha1.GetConnectionRequest]) (*connect.Response[v1alpha1.GetConnectionResponse], error)
	// Creates a new connection
	CreateConnection(context.Context, *connect.Request[v1alpha1.CreateConnectionRequest]) (*connect.Response[v1alpha1.CreateConnectionResponse], error)
	// Updates an existing connection
	UpdateConnection(context.Context, *connect.Request[v1alpha1.UpdateConnectionRequest]) (*connect.Response[v1alpha1.UpdateConnectionResponse], error)
	// Removes a connection from the system.
	DeleteConnection(context.Context, *connect.Request[v1alpha1.DeleteConnectionRequest]) (*connect.Response[v1alpha1.DeleteConnectionResponse], error)
	// Connections have friendly names, this method checks if the requested name is available in the system based on the account
	IsConnectionNameAvailable(context.Context, *connect.Request[v1alpha1.IsConnectionNameAvailableRequest]) (*connect.Response[v1alpha1.IsConnectionNameAvailableResponse], error)
	// Checks if the connection config is connectable by the backend.
	// Used mostly to verify that a connection is valid prior to creating a Connection object.
	CheckConnectionConfig(context.Context, *connect.Request[v1alpha1.CheckConnectionConfigRequest]) (*connect.Response[v1alpha1.CheckConnectionConfigResponse], error)
	// Checks a constructed SQL query against a sql-based connection to see if it's valid based on that connection's data schema
	// This is useful when constructing subsets to see if the WHERE clause is correct
	CheckSqlQuery(context.Context, *connect.Request[v1alpha1.CheckSqlQueryRequest]) (*connect.Response[v1alpha1.CheckSqlQueryResponse], error)
}

ConnectionServiceHandler is an implementation of the mgmt.v1alpha1.ConnectionService service.

type JobServiceClient 

type JobServiceClient interface {
	GetJobs(context.Context, *connect.Request[v1alpha1.GetJobsRequest]) (*connect.Response[v1alpha1.GetJobsResponse], error)
	GetJob(context.Context, *connect.Request[v1alpha1.GetJobRequest]) (*connect.Response[v1alpha1.GetJobResponse], error)
	CreateJob(context.Context, *connect.Request[v1alpha1.CreateJobRequest]) (*connect.Response[v1alpha1.CreateJobResponse], error)
	DeleteJob(context.Context, *connect.Request[v1alpha1.DeleteJobRequest]) (*connect.Response[v1alpha1.DeleteJobResponse], error)
	IsJobNameAvailable(context.Context, *connect.Request[v1alpha1.IsJobNameAvailableRequest]) (*connect.Response[v1alpha1.IsJobNameAvailableResponse], error)
	UpdateJobSchedule(context.Context, *connect.Request[v1alpha1.UpdateJobScheduleRequest]) (*connect.Response[v1alpha1.UpdateJobScheduleResponse], error)
	UpdateJobSourceConnection(context.Context, *connect.Request[v1alpha1.UpdateJobSourceConnectionRequest]) (*connect.Response[v1alpha1.UpdateJobSourceConnectionResponse], error)
	SetJobSourceSqlConnectionSubsets(context.Context, *connect.Request[v1alpha1.SetJobSourceSqlConnectionSubsetsRequest]) (*connect.Response[v1alpha1.SetJobSourceSqlConnectionSubsetsResponse], error)
	UpdateJobDestinationConnection(context.Context, *connect.Request[v1alpha1.UpdateJobDestinationConnectionRequest]) (*connect.Response[v1alpha1.UpdateJobDestinationConnectionResponse], error)
	DeleteJobDestinationConnection(context.Context, *connect.Request[v1alpha1.DeleteJobDestinationConnectionRequest]) (*connect.Response[v1alpha1.DeleteJobDestinationConnectionResponse], error)
	CreateJobDestinationConnections(context.Context, *connect.Request[v1alpha1.CreateJobDestinationConnectionsRequest]) (*connect.Response[v1alpha1.CreateJobDestinationConnectionsResponse], error)
	PauseJob(context.Context, *connect.Request[v1alpha1.PauseJobRequest]) (*connect.Response[v1alpha1.PauseJobResponse], error)
	// Returns a list of recently invoked job runs baseds on the Temporal cron scheduler. This will return a list of job runs that include archived runs
	GetJobRecentRuns(context.Context, *connect.Request[v1alpha1.GetJobRecentRunsRequest]) (*connect.Response[v1alpha1.GetJobRecentRunsResponse], error)
	// Returns a list of runs that are scheduled for execution based on the Temporal cron scheduler.
	GetJobNextRuns(context.Context, *connect.Request[v1alpha1.GetJobNextRunsRequest]) (*connect.Response[v1alpha1.GetJobNextRunsResponse], error)
	GetJobStatus(context.Context, *connect.Request[v1alpha1.GetJobStatusRequest]) (*connect.Response[v1alpha1.GetJobStatusResponse], error)
	GetJobStatuses(context.Context, *connect.Request[v1alpha1.GetJobStatusesRequest]) (*connect.Response[v1alpha1.GetJobStatusesResponse], error)
	// Returns a list of job runs by either account or job
	GetJobRuns(context.Context, *connect.Request[v1alpha1.GetJobRunsRequest]) (*connect.Response[v1alpha1.GetJobRunsResponse], error)
	GetJobRunEvents(context.Context, *connect.Request[v1alpha1.GetJobRunEventsRequest]) (*connect.Response[v1alpha1.GetJobRunEventsResponse], error)
	// Returns a specific job run, along with any of its pending activities
	GetJobRun(context.Context, *connect.Request[v1alpha1.GetJobRunRequest]) (*connect.Response[v1alpha1.GetJobRunResponse], error)
	DeleteJobRun(context.Context, *connect.Request[v1alpha1.DeleteJobRunRequest]) (*connect.Response[v1alpha1.DeleteJobRunResponse], error)
	CreateJobRun(context.Context, *connect.Request[v1alpha1.CreateJobRunRequest]) (*connect.Response[v1alpha1.CreateJobRunResponse], error)
	CancelJobRun(context.Context, *connect.Request[v1alpha1.CancelJobRunRequest]) (*connect.Response[v1alpha1.CancelJobRunResponse], error)
	TerminateJobRun(context.Context, *connect.Request[v1alpha1.TerminateJobRunRequest]) (*connect.Response[v1alpha1.TerminateJobRunResponse], error)
	// Returns a stream of logs from the worker nodes that pertain to a specific job run
	GetJobRunLogsStream(context.Context, *connect.Request[v1alpha1.GetJobRunLogsStreamRequest]) (*connect.ServerStreamForClient[v1alpha1.GetJobRunLogsStreamResponse], error)
	// Set any job workflow options. Must provide entire object as is it will fully override the previous configuration
	SetJobWorkflowOptions(context.Context, *connect.Request[v1alpha1.SetJobWorkflowOptionsRequest]) (*connect.Response[v1alpha1.SetJobWorkflowOptionsResponse], error)
	// Set the job sync options. Must provide entire object as it will fully override the previous configuration
	SetJobSyncOptions(context.Context, *connect.Request[v1alpha1.SetJobSyncOptionsRequest]) (*connect.Response[v1alpha1.SetJobSyncOptionsResponse], error)
	// validates that the jobmapping configured can run with table constraints
	ValidateJobMappings(context.Context, *connect.Request[v1alpha1.ValidateJobMappingsRequest]) (*connect.Response[v1alpha1.ValidateJobMappingsResponse], error)
}

JobServiceClient is a client for the mgmt.v1alpha1.JobService service.

func NewJobServiceClient 

func NewJobServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) JobServiceClient

NewJobServiceClient constructs a client for the mgmt.v1alpha1.JobService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type JobServiceHandler 

type JobServiceHandler interface {
	GetJobs(context.Context, *connect.Request[v1alpha1.GetJobsRequest]) (*connect.Response[v1alpha1.GetJobsResponse], error)
	GetJob(context.Context, *connect.Request[v1alpha1.GetJobRequest]) (*connect.Response[v1alpha1.GetJobResponse], error)
	CreateJob(context.Context, *connect.Request[v1alpha1.CreateJobRequest]) (*connect.Response[v1alpha1.CreateJobResponse], error)
	DeleteJob(context.Context, *connect.Request[v1alpha1.DeleteJobRequest]) (*connect.Response[v1alpha1.DeleteJobResponse], error)
	IsJobNameAvailable(context.Context, *connect.Request[v1alpha1.IsJobNameAvailableRequest]) (*connect.Response[v1alpha1.IsJobNameAvailableResponse], error)
	UpdateJobSchedule(context.Context, *connect.Request[v1alpha1.UpdateJobScheduleRequest]) (*connect.Response[v1alpha1.UpdateJobScheduleResponse], error)
	UpdateJobSourceConnection(context.Context, *connect.Request[v1alpha1.UpdateJobSourceConnectionRequest]) (*connect.Response[v1alpha1.UpdateJobSourceConnectionResponse], error)
	SetJobSourceSqlConnectionSubsets(context.Context, *connect.Request[v1alpha1.SetJobSourceSqlConnectionSubsetsRequest]) (*connect.Response[v1alpha1.SetJobSourceSqlConnectionSubsetsResponse], error)
	UpdateJobDestinationConnection(context.Context, *connect.Request[v1alpha1.UpdateJobDestinationConnectionRequest]) (*connect.Response[v1alpha1.UpdateJobDestinationConnectionResponse], error)
	DeleteJobDestinationConnection(context.Context, *connect.Request[v1alpha1.DeleteJobDestinationConnectionRequest]) (*connect.Response[v1alpha1.DeleteJobDestinationConnectionResponse], error)
	CreateJobDestinationConnections(context.Context, *connect.Request[v1alpha1.CreateJobDestinationConnectionsRequest]) (*connect.Response[v1alpha1.CreateJobDestinationConnectionsResponse], error)
	PauseJob(context.Context, *connect.Request[v1alpha1.PauseJobRequest]) (*connect.Response[v1alpha1.PauseJobResponse], error)
	// Returns a list of recently invoked job runs baseds on the Temporal cron scheduler. This will return a list of job runs that include archived runs
	GetJobRecentRuns(context.Context, *connect.Request[v1alpha1.GetJobRecentRunsRequest]) (*connect.Response[v1alpha1.GetJobRecentRunsResponse], error)
	// Returns a list of runs that are scheduled for execution based on the Temporal cron scheduler.
	GetJobNextRuns(context.Context, *connect.Request[v1alpha1.GetJobNextRunsRequest]) (*connect.Response[v1alpha1.GetJobNextRunsResponse], error)
	GetJobStatus(context.Context, *connect.Request[v1alpha1.GetJobStatusRequest]) (*connect.Response[v1alpha1.GetJobStatusResponse], error)
	GetJobStatuses(context.Context, *connect.Request[v1alpha1.GetJobStatusesRequest]) (*connect.Response[v1alpha1.GetJobStatusesResponse], error)
	// Returns a list of job runs by either account or job
	GetJobRuns(context.Context, *connect.Request[v1alpha1.GetJobRunsRequest]) (*connect.Response[v1alpha1.GetJobRunsResponse], error)
	GetJobRunEvents(context.Context, *connect.Request[v1alpha1.GetJobRunEventsRequest]) (*connect.Response[v1alpha1.GetJobRunEventsResponse], error)
	// Returns a specific job run, along with any of its pending activities
	GetJobRun(context.Context, *connect.Request[v1alpha1.GetJobRunRequest]) (*connect.Response[v1alpha1.GetJobRunResponse], error)
	DeleteJobRun(context.Context, *connect.Request[v1alpha1.DeleteJobRunRequest]) (*connect.Response[v1alpha1.DeleteJobRunResponse], error)
	CreateJobRun(context.Context, *connect.Request[v1alpha1.CreateJobRunRequest]) (*connect.Response[v1alpha1.CreateJobRunResponse], error)
	CancelJobRun(context.Context, *connect.Request[v1alpha1.CancelJobRunRequest]) (*connect.Response[v1alpha1.CancelJobRunResponse], error)
	TerminateJobRun(context.Context, *connect.Request[v1alpha1.TerminateJobRunRequest]) (*connect.Response[v1alpha1.TerminateJobRunResponse], error)
	// Returns a stream of logs from the worker nodes that pertain to a specific job run
	GetJobRunLogsStream(context.Context, *connect.Request[v1alpha1.GetJobRunLogsStreamRequest], *connect.ServerStream[v1alpha1.GetJobRunLogsStreamResponse]) error
	// Set any job workflow options. Must provide entire object as is it will fully override the previous configuration
	SetJobWorkflowOptions(context.Context, *connect.Request[v1alpha1.SetJobWorkflowOptionsRequest]) (*connect.Response[v1alpha1.SetJobWorkflowOptionsResponse], error)
	// Set the job sync options. Must provide entire object as it will fully override the previous configuration
	SetJobSyncOptions(context.Context, *connect.Request[v1alpha1.SetJobSyncOptionsRequest]) (*connect.Response[v1alpha1.SetJobSyncOptionsResponse], error)
	// validates that the jobmapping configured can run with table constraints
	ValidateJobMappings(context.Context, *connect.Request[v1alpha1.ValidateJobMappingsRequest]) (*connect.Response[v1alpha1.ValidateJobMappingsResponse], error)
}

JobServiceHandler is an implementation of the mgmt.v1alpha1.JobService service.

type MetricsServiceClient 

type MetricsServiceClient interface {
	// Retrieve a timed range of records
	GetDailyMetricCount(context.Context, *connect.Request[v1alpha1.GetDailyMetricCountRequest]) (*connect.Response[v1alpha1.GetDailyMetricCountResponse], error)
	// For the given metric and time range, returns the total count found
	GetMetricCount(context.Context, *connect.Request[v1alpha1.GetMetricCountRequest]) (*connect.Response[v1alpha1.GetMetricCountResponse], error)
}

MetricsServiceClient is a client for the mgmt.v1alpha1.MetricsService service.

func NewMetricsServiceClient 

func NewMetricsServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) MetricsServiceClient

NewMetricsServiceClient constructs a client for the mgmt.v1alpha1.MetricsService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type MetricsServiceHandler 

type MetricsServiceHandler interface {
	// Retrieve a timed range of records
	GetDailyMetricCount(context.Context, *connect.Request[v1alpha1.GetDailyMetricCountRequest]) (*connect.Response[v1alpha1.GetDailyMetricCountResponse], error)
	// For the given metric and time range, returns the total count found
	GetMetricCount(context.Context, *connect.Request[v1alpha1.GetMetricCountRequest]) (*connect.Response[v1alpha1.GetMetricCountResponse], error)
}

MetricsServiceHandler is an implementation of the mgmt.v1alpha1.MetricsService service.

type MockAuthServiceClient 

type MockAuthServiceClient struct {
	mock.Mock
}

MockAuthServiceClient is an autogenerated mock type for the AuthServiceClient type

func NewMockAuthServiceClient 

func NewMockAuthServiceClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockAuthServiceClient

NewMockAuthServiceClient creates a new instance of MockAuthServiceClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockAuthServiceClient) CheckToken 

func (_m *MockAuthServiceClient) CheckToken(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CheckTokenRequest]) (*connect.Response[mgmtv1alpha1.CheckTokenResponse], error)

CheckToken provides a mock function with given fields: _a0, _a1

func (*MockAuthServiceClient) EXPECT 

func (_m *MockAuthServiceClient) EXPECT() *MockAuthServiceClient_Expecter

func (*MockAuthServiceClient) GetAuthStatus 

func (_m *MockAuthServiceClient) GetAuthStatus(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetAuthStatusRequest]) (*connect.Response[mgmtv1alpha1.GetAuthStatusResponse], error)

GetAuthStatus provides a mock function with given fields: _a0, _a1

func (*MockAuthServiceClient) GetAuthorizeUrl 

func (_m *MockAuthServiceClient) GetAuthorizeUrl(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetAuthorizeUrlRequest]) (*connect.Response[mgmtv1alpha1.GetAuthorizeUrlResponse], error)

GetAuthorizeUrl provides a mock function with given fields: _a0, _a1

func (*MockAuthServiceClient) GetCliIssuer 

func (_m *MockAuthServiceClient) GetCliIssuer(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetCliIssuerRequest]) (*connect.Response[mgmtv1alpha1.GetCliIssuerResponse], error)

GetCliIssuer provides a mock function with given fields: _a0, _a1

func (*MockAuthServiceClient) LoginCli 

func (_m *MockAuthServiceClient) LoginCli(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.LoginCliRequest]) (*connect.Response[mgmtv1alpha1.LoginCliResponse], error)

LoginCli provides a mock function with given fields: _a0, _a1

func (*MockAuthServiceClient) RefreshCli 

func (_m *MockAuthServiceClient) RefreshCli(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.RefreshCliRequest]) (*connect.Response[mgmtv1alpha1.RefreshCliResponse], error)

RefreshCli provides a mock function with given fields: _a0, _a1

type MockAuthServiceClient_CheckToken_Call 

type MockAuthServiceClient_CheckToken_Call struct {
	*mock.Call
}

MockAuthServiceClient_CheckToken_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CheckToken'

func (*MockAuthServiceClient_CheckToken_Call) Return 

func (_c *MockAuthServiceClient_CheckToken_Call) Return(_a0 *connect.Response[mgmtv1alpha1.CheckTokenResponse], _a1 error) *MockAuthServiceClient_CheckToken_Call

func (*MockAuthServiceClient_CheckToken_Call) Run 

func (_c *MockAuthServiceClient_CheckToken_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CheckTokenRequest])) *MockAuthServiceClient_CheckToken_Call

func (*MockAuthServiceClient_CheckToken_Call) RunAndReturn 

func (_c *MockAuthServiceClient_CheckToken_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.CheckTokenRequest]) (*connect.Response[mgmtv1alpha1.CheckTokenResponse], error)) *MockAuthServiceClient_CheckToken_Call

type MockAuthServiceClient_Expecter 

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

func (*MockAuthServiceClient_Expecter) CheckToken 

func (_e *MockAuthServiceClient_Expecter) CheckToken(_a0 interface{}, _a1 interface{}) *MockAuthServiceClient_CheckToken_Call

CheckToken is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.CheckTokenRequest]

func (*MockAuthServiceClient_Expecter) GetAuthStatus 

func (_e *MockAuthServiceClient_Expecter) GetAuthStatus(_a0 interface{}, _a1 interface{}) *MockAuthServiceClient_GetAuthStatus_Call

GetAuthStatus is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetAuthStatusRequest]

func (*MockAuthServiceClient_Expecter) GetAuthorizeUrl 

func (_e *MockAuthServiceClient_Expecter) GetAuthorizeUrl(_a0 interface{}, _a1 interface{}) *MockAuthServiceClient_GetAuthorizeUrl_Call

GetAuthorizeUrl is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetAuthorizeUrlRequest]

func (*MockAuthServiceClient_Expecter) GetCliIssuer 

func (_e *MockAuthServiceClient_Expecter) GetCliIssuer(_a0 interface{}, _a1 interface{}) *MockAuthServiceClient_GetCliIssuer_Call

GetCliIssuer is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetCliIssuerRequest]

func (*MockAuthServiceClient_Expecter) LoginCli 

func (_e *MockAuthServiceClient_Expecter) LoginCli(_a0 interface{}, _a1 interface{}) *MockAuthServiceClient_LoginCli_Call

LoginCli is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.LoginCliRequest]

func (*MockAuthServiceClient_Expecter) RefreshCli 

func (_e *MockAuthServiceClient_Expecter) RefreshCli(_a0 interface{}, _a1 interface{}) *MockAuthServiceClient_RefreshCli_Call

RefreshCli is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.RefreshCliRequest]

type MockAuthServiceClient_GetAuthStatus_Call 

type MockAuthServiceClient_GetAuthStatus_Call struct {
	*mock.Call
}

MockAuthServiceClient_GetAuthStatus_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetAuthStatus'

func (*MockAuthServiceClient_GetAuthStatus_Call) Return 

func (_c *MockAuthServiceClient_GetAuthStatus_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetAuthStatusResponse], _a1 error) *MockAuthServiceClient_GetAuthStatus_Call

func (*MockAuthServiceClient_GetAuthStatus_Call) Run 

func (_c *MockAuthServiceClient_GetAuthStatus_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetAuthStatusRequest])) *MockAuthServiceClient_GetAuthStatus_Call

func (*MockAuthServiceClient_GetAuthStatus_Call) RunAndReturn 

func (_c *MockAuthServiceClient_GetAuthStatus_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetAuthStatusRequest]) (*connect.Response[mgmtv1alpha1.GetAuthStatusResponse], error)) *MockAuthServiceClient_GetAuthStatus_Call

type MockAuthServiceClient_GetAuthorizeUrl_Call 

type MockAuthServiceClient_GetAuthorizeUrl_Call struct {
	*mock.Call
}

MockAuthServiceClient_GetAuthorizeUrl_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetAuthorizeUrl'

func (*MockAuthServiceClient_GetAuthorizeUrl_Call) Return 

func (_c *MockAuthServiceClient_GetAuthorizeUrl_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetAuthorizeUrlResponse], _a1 error) *MockAuthServiceClient_GetAuthorizeUrl_Call

func (*MockAuthServiceClient_GetAuthorizeUrl_Call) Run 

func (_c *MockAuthServiceClient_GetAuthorizeUrl_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetAuthorizeUrlRequest])) *MockAuthServiceClient_GetAuthorizeUrl_Call

func (*MockAuthServiceClient_GetAuthorizeUrl_Call) RunAndReturn 

func (_c *MockAuthServiceClient_GetAuthorizeUrl_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetAuthorizeUrlRequest]) (*connect.Response[mgmtv1alpha1.GetAuthorizeUrlResponse], error)) *MockAuthServiceClient_GetAuthorizeUrl_Call

type MockAuthServiceClient_GetCliIssuer_Call 

type MockAuthServiceClient_GetCliIssuer_Call struct {
	*mock.Call
}

MockAuthServiceClient_GetCliIssuer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetCliIssuer'

func (*MockAuthServiceClient_GetCliIssuer_Call) Return 

func (_c *MockAuthServiceClient_GetCliIssuer_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetCliIssuerResponse], _a1 error) *MockAuthServiceClient_GetCliIssuer_Call

func (*MockAuthServiceClient_GetCliIssuer_Call) Run 

func (_c *MockAuthServiceClient_GetCliIssuer_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetCliIssuerRequest])) *MockAuthServiceClient_GetCliIssuer_Call

func (*MockAuthServiceClient_GetCliIssuer_Call) RunAndReturn 

func (_c *MockAuthServiceClient_GetCliIssuer_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetCliIssuerRequest]) (*connect.Response[mgmtv1alpha1.GetCliIssuerResponse], error)) *MockAuthServiceClient_GetCliIssuer_Call

type MockAuthServiceClient_LoginCli_Call 

type MockAuthServiceClient_LoginCli_Call struct {
	*mock.Call
}

MockAuthServiceClient_LoginCli_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'LoginCli'

func (*MockAuthServiceClient_LoginCli_Call) Return 

func (_c *MockAuthServiceClient_LoginCli_Call) Return(_a0 *connect.Response[mgmtv1alpha1.LoginCliResponse], _a1 error) *MockAuthServiceClient_LoginCli_Call

func (*MockAuthServiceClient_LoginCli_Call) Run 

func (_c *MockAuthServiceClient_LoginCli_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.LoginCliRequest])) *MockAuthServiceClient_LoginCli_Call

func (*MockAuthServiceClient_LoginCli_Call) RunAndReturn 

func (_c *MockAuthServiceClient_LoginCli_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.LoginCliRequest]) (*connect.Response[mgmtv1alpha1.LoginCliResponse], error)) *MockAuthServiceClient_LoginCli_Call

type MockAuthServiceClient_RefreshCli_Call 

type MockAuthServiceClient_RefreshCli_Call struct {
	*mock.Call
}

MockAuthServiceClient_RefreshCli_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RefreshCli'

func (*MockAuthServiceClient_RefreshCli_Call) Return 

func (_c *MockAuthServiceClient_RefreshCli_Call) Return(_a0 *connect.Response[mgmtv1alpha1.RefreshCliResponse], _a1 error) *MockAuthServiceClient_RefreshCli_Call

func (*MockAuthServiceClient_RefreshCli_Call) Run 

func (_c *MockAuthServiceClient_RefreshCli_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.RefreshCliRequest])) *MockAuthServiceClient_RefreshCli_Call

func (*MockAuthServiceClient_RefreshCli_Call) RunAndReturn 

func (_c *MockAuthServiceClient_RefreshCli_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.RefreshCliRequest]) (*connect.Response[mgmtv1alpha1.RefreshCliResponse], error)) *MockAuthServiceClient_RefreshCli_Call

type MockConnectionServiceClient 

type MockConnectionServiceClient struct {
	mock.Mock
}

MockConnectionServiceClient is an autogenerated mock type for the ConnectionServiceClient type

func NewMockConnectionServiceClient 

func NewMockConnectionServiceClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockConnectionServiceClient

NewMockConnectionServiceClient creates a new instance of MockConnectionServiceClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockConnectionServiceClient) CheckConnectionConfig 

func (_m *MockConnectionServiceClient) CheckConnectionConfig(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CheckConnectionConfigRequest]) (*connect.Response[mgmtv1alpha1.CheckConnectionConfigResponse], error)

CheckConnectionConfig provides a mock function with given fields: _a0, _a1

func (*MockConnectionServiceClient) CheckSqlQuery 

func (_m *MockConnectionServiceClient) CheckSqlQuery(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CheckSqlQueryRequest]) (*connect.Response[mgmtv1alpha1.CheckSqlQueryResponse], error)

CheckSqlQuery provides a mock function with given fields: _a0, _a1

func (*MockConnectionServiceClient) CreateConnection 

func (_m *MockConnectionServiceClient) CreateConnection(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CreateConnectionRequest]) (*connect.Response[mgmtv1alpha1.CreateConnectionResponse], error)

CreateConnection provides a mock function with given fields: _a0, _a1

func (*MockConnectionServiceClient) DeleteConnection 

func (_m *MockConnectionServiceClient) DeleteConnection(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.DeleteConnectionRequest]) (*connect.Response[mgmtv1alpha1.DeleteConnectionResponse], error)

DeleteConnection provides a mock function with given fields: _a0, _a1

func (*MockConnectionServiceClient) EXPECT 

func (_m *MockConnectionServiceClient) EXPECT() *MockConnectionServiceClient_Expecter

func (*MockConnectionServiceClient) GetConnection 

func (_m *MockConnectionServiceClient) GetConnection(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetConnectionRequest]) (*connect.Response[mgmtv1alpha1.GetConnectionResponse], error)

GetConnection provides a mock function with given fields: _a0, _a1

func (*MockConnectionServiceClient) GetConnections 

func (_m *MockConnectionServiceClient) GetConnections(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetConnectionsRequest]) (*connect.Response[mgmtv1alpha1.GetConnectionsResponse], error)

GetConnections provides a mock function with given fields: _a0, _a1

func (*MockConnectionServiceClient) IsConnectionNameAvailable 

func (_m *MockConnectionServiceClient) IsConnectionNameAvailable(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.IsConnectionNameAvailableRequest]) (*connect.Response[mgmtv1alpha1.IsConnectionNameAvailableResponse], error)

IsConnectionNameAvailable provides a mock function with given fields: _a0, _a1

func (*MockConnectionServiceClient) UpdateConnection 

func (_m *MockConnectionServiceClient) UpdateConnection(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.UpdateConnectionRequest]) (*connect.Response[mgmtv1alpha1.UpdateConnectionResponse], error)

UpdateConnection provides a mock function with given fields: _a0, _a1

type MockConnectionServiceClient_CheckConnectionConfig_Call 

type MockConnectionServiceClient_CheckConnectionConfig_Call struct {
	*mock.Call
}

MockConnectionServiceClient_CheckConnectionConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CheckConnectionConfig'

func (*MockConnectionServiceClient_CheckConnectionConfig_Call) Return 

func (_c *MockConnectionServiceClient_CheckConnectionConfig_Call) Return(_a0 *connect.Response[mgmtv1alpha1.CheckConnectionConfigResponse], _a1 error) *MockConnectionServiceClient_CheckConnectionConfig_Call

func (*MockConnectionServiceClient_CheckConnectionConfig_Call) Run 

func (_c *MockConnectionServiceClient_CheckConnectionConfig_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CheckConnectionConfigRequest])) *MockConnectionServiceClient_CheckConnectionConfig_Call

func (*MockConnectionServiceClient_CheckConnectionConfig_Call) RunAndReturn 

func (_c *MockConnectionServiceClient_CheckConnectionConfig_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.CheckConnectionConfigRequest]) (*connect.Response[mgmtv1alpha1.CheckConnectionConfigResponse], error)) *MockConnectionServiceClient_CheckConnectionConfig_Call

type MockConnectionServiceClient_CheckSqlQuery_Call 

type MockConnectionServiceClient_CheckSqlQuery_Call struct {
	*mock.Call
}

MockConnectionServiceClient_CheckSqlQuery_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CheckSqlQuery'

func (*MockConnectionServiceClient_CheckSqlQuery_Call) Return 

func (_c *MockConnectionServiceClient_CheckSqlQuery_Call) Return(_a0 *connect.Response[mgmtv1alpha1.CheckSqlQueryResponse], _a1 error) *MockConnectionServiceClient_CheckSqlQuery_Call

func (*MockConnectionServiceClient_CheckSqlQuery_Call) Run 

func (_c *MockConnectionServiceClient_CheckSqlQuery_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CheckSqlQueryRequest])) *MockConnectionServiceClient_CheckSqlQuery_Call

func (*MockConnectionServiceClient_CheckSqlQuery_Call) RunAndReturn 

func (_c *MockConnectionServiceClient_CheckSqlQuery_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.CheckSqlQueryRequest]) (*connect.Response[mgmtv1alpha1.CheckSqlQueryResponse], error)) *MockConnectionServiceClient_CheckSqlQuery_Call

type MockConnectionServiceClient_CreateConnection_Call 

type MockConnectionServiceClient_CreateConnection_Call struct {
	*mock.Call
}

MockConnectionServiceClient_CreateConnection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateConnection'

func (*MockConnectionServiceClient_CreateConnection_Call) Return 

func (_c *MockConnectionServiceClient_CreateConnection_Call) Return(_a0 *connect.Response[mgmtv1alpha1.CreateConnectionResponse], _a1 error) *MockConnectionServiceClient_CreateConnection_Call

func (*MockConnectionServiceClient_CreateConnection_Call) Run 

func (_c *MockConnectionServiceClient_CreateConnection_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CreateConnectionRequest])) *MockConnectionServiceClient_CreateConnection_Call

func (*MockConnectionServiceClient_CreateConnection_Call) RunAndReturn 

func (_c *MockConnectionServiceClient_CreateConnection_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.CreateConnectionRequest]) (*connect.Response[mgmtv1alpha1.CreateConnectionResponse], error)) *MockConnectionServiceClient_CreateConnection_Call

type MockConnectionServiceClient_DeleteConnection_Call 

type MockConnectionServiceClient_DeleteConnection_Call struct {
	*mock.Call
}

MockConnectionServiceClient_DeleteConnection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteConnection'

func (*MockConnectionServiceClient_DeleteConnection_Call) Return 

func (_c *MockConnectionServiceClient_DeleteConnection_Call) Return(_a0 *connect.Response[mgmtv1alpha1.DeleteConnectionResponse], _a1 error) *MockConnectionServiceClient_DeleteConnection_Call

func (*MockConnectionServiceClient_DeleteConnection_Call) Run 

func (_c *MockConnectionServiceClient_DeleteConnection_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.DeleteConnectionRequest])) *MockConnectionServiceClient_DeleteConnection_Call

func (*MockConnectionServiceClient_DeleteConnection_Call) RunAndReturn 

func (_c *MockConnectionServiceClient_DeleteConnection_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.DeleteConnectionRequest]) (*connect.Response[mgmtv1alpha1.DeleteConnectionResponse], error)) *MockConnectionServiceClient_DeleteConnection_Call

type MockConnectionServiceClient_Expecter 

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

func (*MockConnectionServiceClient_Expecter) CheckConnectionConfig 

func (_e *MockConnectionServiceClient_Expecter) CheckConnectionConfig(_a0 interface{}, _a1 interface{}) *MockConnectionServiceClient_CheckConnectionConfig_Call

CheckConnectionConfig is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.CheckConnectionConfigRequest]

func (*MockConnectionServiceClient_Expecter) CheckSqlQuery 

func (_e *MockConnectionServiceClient_Expecter) CheckSqlQuery(_a0 interface{}, _a1 interface{}) *MockConnectionServiceClient_CheckSqlQuery_Call

CheckSqlQuery is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.CheckSqlQueryRequest]

func (*MockConnectionServiceClient_Expecter) CreateConnection 

func (_e *MockConnectionServiceClient_Expecter) CreateConnection(_a0 interface{}, _a1 interface{}) *MockConnectionServiceClient_CreateConnection_Call

CreateConnection is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.CreateConnectionRequest]

func (*MockConnectionServiceClient_Expecter) DeleteConnection 

func (_e *MockConnectionServiceClient_Expecter) DeleteConnection(_a0 interface{}, _a1 interface{}) *MockConnectionServiceClient_DeleteConnection_Call

DeleteConnection is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.DeleteConnectionRequest]

func (*MockConnectionServiceClient_Expecter) GetConnection 

func (_e *MockConnectionServiceClient_Expecter) GetConnection(_a0 interface{}, _a1 interface{}) *MockConnectionServiceClient_GetConnection_Call

GetConnection is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetConnectionRequest]

func (*MockConnectionServiceClient_Expecter) GetConnections 

func (_e *MockConnectionServiceClient_Expecter) GetConnections(_a0 interface{}, _a1 interface{}) *MockConnectionServiceClient_GetConnections_Call

GetConnections is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetConnectionsRequest]

func (*MockConnectionServiceClient_Expecter) IsConnectionNameAvailable 

func (_e *MockConnectionServiceClient_Expecter) IsConnectionNameAvailable(_a0 interface{}, _a1 interface{}) *MockConnectionServiceClient_IsConnectionNameAvailable_Call

IsConnectionNameAvailable is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.IsConnectionNameAvailableRequest]

func (*MockConnectionServiceClient_Expecter) UpdateConnection 

func (_e *MockConnectionServiceClient_Expecter) UpdateConnection(_a0 interface{}, _a1 interface{}) *MockConnectionServiceClient_UpdateConnection_Call

UpdateConnection is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.UpdateConnectionRequest]

type MockConnectionServiceClient_GetConnection_Call 

type MockConnectionServiceClient_GetConnection_Call struct {
	*mock.Call
}

MockConnectionServiceClient_GetConnection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetConnection'

func (*MockConnectionServiceClient_GetConnection_Call) Return 

func (_c *MockConnectionServiceClient_GetConnection_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetConnectionResponse], _a1 error) *MockConnectionServiceClient_GetConnection_Call

func (*MockConnectionServiceClient_GetConnection_Call) Run 

func (_c *MockConnectionServiceClient_GetConnection_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetConnectionRequest])) *MockConnectionServiceClient_GetConnection_Call

func (*MockConnectionServiceClient_GetConnection_Call) RunAndReturn 

func (_c *MockConnectionServiceClient_GetConnection_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetConnectionRequest]) (*connect.Response[mgmtv1alpha1.GetConnectionResponse], error)) *MockConnectionServiceClient_GetConnection_Call

type MockConnectionServiceClient_GetConnections_Call 

type MockConnectionServiceClient_GetConnections_Call struct {
	*mock.Call
}

MockConnectionServiceClient_GetConnections_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetConnections'

func (*MockConnectionServiceClient_GetConnections_Call) Return 

func (_c *MockConnectionServiceClient_GetConnections_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetConnectionsResponse], _a1 error) *MockConnectionServiceClient_GetConnections_Call

func (*MockConnectionServiceClient_GetConnections_Call) Run 

func (_c *MockConnectionServiceClient_GetConnections_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetConnectionsRequest])) *MockConnectionServiceClient_GetConnections_Call

func (*MockConnectionServiceClient_GetConnections_Call) RunAndReturn 

func (_c *MockConnectionServiceClient_GetConnections_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetConnectionsRequest]) (*connect.Response[mgmtv1alpha1.GetConnectionsResponse], error)) *MockConnectionServiceClient_GetConnections_Call

type MockConnectionServiceClient_IsConnectionNameAvailable_Call 

type MockConnectionServiceClient_IsConnectionNameAvailable_Call struct {
	*mock.Call
}

MockConnectionServiceClient_IsConnectionNameAvailable_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsConnectionNameAvailable'

func (*MockConnectionServiceClient_IsConnectionNameAvailable_Call) Return 

func (_c *MockConnectionServiceClient_IsConnectionNameAvailable_Call) Return(_a0 *connect.Response[mgmtv1alpha1.IsConnectionNameAvailableResponse], _a1 error) *MockConnectionServiceClient_IsConnectionNameAvailable_Call

func (*MockConnectionServiceClient_IsConnectionNameAvailable_Call) Run 

func (_c *MockConnectionServiceClient_IsConnectionNameAvailable_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.IsConnectionNameAvailableRequest])) *MockConnectionServiceClient_IsConnectionNameAvailable_Call

func (*MockConnectionServiceClient_IsConnectionNameAvailable_Call) RunAndReturn 

func (_c *MockConnectionServiceClient_IsConnectionNameAvailable_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.IsConnectionNameAvailableRequest]) (*connect.Response[mgmtv1alpha1.IsConnectionNameAvailableResponse], error)) *MockConnectionServiceClient_IsConnectionNameAvailable_Call

type MockConnectionServiceClient_UpdateConnection_Call 

type MockConnectionServiceClient_UpdateConnection_Call struct {
	*mock.Call
}

MockConnectionServiceClient_UpdateConnection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateConnection'

func (*MockConnectionServiceClient_UpdateConnection_Call) Return 

func (_c *MockConnectionServiceClient_UpdateConnection_Call) Return(_a0 *connect.Response[mgmtv1alpha1.UpdateConnectionResponse], _a1 error) *MockConnectionServiceClient_UpdateConnection_Call

func (*MockConnectionServiceClient_UpdateConnection_Call) Run 

func (_c *MockConnectionServiceClient_UpdateConnection_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.UpdateConnectionRequest])) *MockConnectionServiceClient_UpdateConnection_Call

func (*MockConnectionServiceClient_UpdateConnection_Call) RunAndReturn 

func (_c *MockConnectionServiceClient_UpdateConnection_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.UpdateConnectionRequest]) (*connect.Response[mgmtv1alpha1.UpdateConnectionResponse], error)) *MockConnectionServiceClient_UpdateConnection_Call

type MockConnectionServiceHandler 

type MockConnectionServiceHandler struct {
	mock.Mock
}

MockConnectionServiceHandler is an autogenerated mock type for the ConnectionServiceHandler type

func NewMockConnectionServiceHandler 

func NewMockConnectionServiceHandler(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockConnectionServiceHandler

NewMockConnectionServiceHandler creates a new instance of MockConnectionServiceHandler. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockConnectionServiceHandler) CheckConnectionConfig 

func (_m *MockConnectionServiceHandler) CheckConnectionConfig(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CheckConnectionConfigRequest]) (*connect.Response[mgmtv1alpha1.CheckConnectionConfigResponse], error)

CheckConnectionConfig provides a mock function with given fields: _a0, _a1

func (*MockConnectionServiceHandler) CheckSqlQuery 

func (_m *MockConnectionServiceHandler) CheckSqlQuery(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CheckSqlQueryRequest]) (*connect.Response[mgmtv1alpha1.CheckSqlQueryResponse], error)

CheckSqlQuery provides a mock function with given fields: _a0, _a1

func (*MockConnectionServiceHandler) CreateConnection 

func (_m *MockConnectionServiceHandler) CreateConnection(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CreateConnectionRequest]) (*connect.Response[mgmtv1alpha1.CreateConnectionResponse], error)

CreateConnection provides a mock function with given fields: _a0, _a1

func (*MockConnectionServiceHandler) DeleteConnection 

func (_m *MockConnectionServiceHandler) DeleteConnection(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.DeleteConnectionRequest]) (*connect.Response[mgmtv1alpha1.DeleteConnectionResponse], error)

DeleteConnection provides a mock function with given fields: _a0, _a1

func (*MockConnectionServiceHandler) EXPECT 

func (_m *MockConnectionServiceHandler) EXPECT() *MockConnectionServiceHandler_Expecter

func (*MockConnectionServiceHandler) GetConnection 

func (_m *MockConnectionServiceHandler) GetConnection(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetConnectionRequest]) (*connect.Response[mgmtv1alpha1.GetConnectionResponse], error)

GetConnection provides a mock function with given fields: _a0, _a1

func (*MockConnectionServiceHandler) GetConnectionDataStream 

func (_m *MockConnectionServiceHandler) GetConnectionDataStream(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetConnectionDataStreamRequest], _a2 *connect.ServerStream[mgmtv1alpha1.GetConnectionDataStreamResponse]) error

GetConnectionDataStream provides a mock function with given fields: _a0, _a1, _a2

func (*MockConnectionServiceHandler) GetConnectionForeignConstraints 

func (_m *MockConnectionServiceHandler) GetConnectionForeignConstraints(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetConnectionForeignConstraintsRequest]) (*connect.Response[mgmtv1alpha1.GetConnectionForeignConstraintsResponse], error)

GetConnectionForeignConstraints provides a mock function with given fields: _a0, _a1

func (*MockConnectionServiceHandler) GetConnectionInitStatements 

func (_m *MockConnectionServiceHandler) GetConnectionInitStatements(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetConnectionInitStatementsRequest]) (*connect.Response[mgmtv1alpha1.GetConnectionInitStatementsResponse], error)

GetConnectionInitStatements provides a mock function with given fields: _a0, _a1

func (*MockConnectionServiceHandler) GetConnectionSchema 

func (_m *MockConnectionServiceHandler) GetConnectionSchema(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetConnectionSchemaRequest]) (*connect.Response[mgmtv1alpha1.GetConnectionSchemaResponse], error)

GetConnectionSchema provides a mock function with given fields: _a0, _a1

func (*MockConnectionServiceHandler) GetConnections 

func (_m *MockConnectionServiceHandler) GetConnections(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetConnectionsRequest]) (*connect.Response[mgmtv1alpha1.GetConnectionsResponse], error)

GetConnections provides a mock function with given fields: _a0, _a1

func (*MockConnectionServiceHandler) IsConnectionNameAvailable 

func (_m *MockConnectionServiceHandler) IsConnectionNameAvailable(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.IsConnectionNameAvailableRequest]) (*connect.Response[mgmtv1alpha1.IsConnectionNameAvailableResponse], error)

IsConnectionNameAvailable provides a mock function with given fields: _a0, _a1

func (*MockConnectionServiceHandler) UpdateConnection 

func (_m *MockConnectionServiceHandler) UpdateConnection(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.UpdateConnectionRequest]) (*connect.Response[mgmtv1alpha1.UpdateConnectionResponse], error)

UpdateConnection provides a mock function with given fields: _a0, _a1

type MockConnectionServiceHandler_CheckConnectionConfig_Call 

type MockConnectionServiceHandler_CheckConnectionConfig_Call struct {
	*mock.Call
}

MockConnectionServiceHandler_CheckConnectionConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CheckConnectionConfig'

func (*MockConnectionServiceHandler_CheckConnectionConfig_Call) Return 

func (_c *MockConnectionServiceHandler_CheckConnectionConfig_Call) Return(_a0 *connect.Response[mgmtv1alpha1.CheckConnectionConfigResponse], _a1 error) *MockConnectionServiceHandler_CheckConnectionConfig_Call

func (*MockConnectionServiceHandler_CheckConnectionConfig_Call) Run 

func (_c *MockConnectionServiceHandler_CheckConnectionConfig_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CheckConnectionConfigRequest])) *MockConnectionServiceHandler_CheckConnectionConfig_Call

func (*MockConnectionServiceHandler_CheckConnectionConfig_Call) RunAndReturn 

func (_c *MockConnectionServiceHandler_CheckConnectionConfig_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.CheckConnectionConfigRequest]) (*connect.Response[mgmtv1alpha1.CheckConnectionConfigResponse], error)) *MockConnectionServiceHandler_CheckConnectionConfig_Call

type MockConnectionServiceHandler_CheckSqlQuery_Call 

type MockConnectionServiceHandler_CheckSqlQuery_Call struct {
	*mock.Call
}

MockConnectionServiceHandler_CheckSqlQuery_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CheckSqlQuery'

func (*MockConnectionServiceHandler_CheckSqlQuery_Call) Return 

func (_c *MockConnectionServiceHandler_CheckSqlQuery_Call) Return(_a0 *connect.Response[mgmtv1alpha1.CheckSqlQueryResponse], _a1 error) *MockConnectionServiceHandler_CheckSqlQuery_Call

func (*MockConnectionServiceHandler_CheckSqlQuery_Call) Run 

func (_c *MockConnectionServiceHandler_CheckSqlQuery_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CheckSqlQueryRequest])) *MockConnectionServiceHandler_CheckSqlQuery_Call

func (*MockConnectionServiceHandler_CheckSqlQuery_Call) RunAndReturn 

func (_c *MockConnectionServiceHandler_CheckSqlQuery_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.CheckSqlQueryRequest]) (*connect.Response[mgmtv1alpha1.CheckSqlQueryResponse], error)) *MockConnectionServiceHandler_CheckSqlQuery_Call

type MockConnectionServiceHandler_CreateConnection_Call 

type MockConnectionServiceHandler_CreateConnection_Call struct {
	*mock.Call
}

MockConnectionServiceHandler_CreateConnection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateConnection'

func (*MockConnectionServiceHandler_CreateConnection_Call) Return 

func (_c *MockConnectionServiceHandler_CreateConnection_Call) Return(_a0 *connect.Response[mgmtv1alpha1.CreateConnectionResponse], _a1 error) *MockConnectionServiceHandler_CreateConnection_Call

func (*MockConnectionServiceHandler_CreateConnection_Call) Run 

func (_c *MockConnectionServiceHandler_CreateConnection_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CreateConnectionRequest])) *MockConnectionServiceHandler_CreateConnection_Call

func (*MockConnectionServiceHandler_CreateConnection_Call) RunAndReturn 

func (_c *MockConnectionServiceHandler_CreateConnection_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.CreateConnectionRequest]) (*connect.Response[mgmtv1alpha1.CreateConnectionResponse], error)) *MockConnectionServiceHandler_CreateConnection_Call

type MockConnectionServiceHandler_DeleteConnection_Call 

type MockConnectionServiceHandler_DeleteConnection_Call struct {
	*mock.Call
}

MockConnectionServiceHandler_DeleteConnection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteConnection'

func (*MockConnectionServiceHandler_DeleteConnection_Call) Return 

func (_c *MockConnectionServiceHandler_DeleteConnection_Call) Return(_a0 *connect.Response[mgmtv1alpha1.DeleteConnectionResponse], _a1 error) *MockConnectionServiceHandler_DeleteConnection_Call

func (*MockConnectionServiceHandler_DeleteConnection_Call) Run 

func (_c *MockConnectionServiceHandler_DeleteConnection_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.DeleteConnectionRequest])) *MockConnectionServiceHandler_DeleteConnection_Call

func (*MockConnectionServiceHandler_DeleteConnection_Call) RunAndReturn 

func (_c *MockConnectionServiceHandler_DeleteConnection_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.DeleteConnectionRequest]) (*connect.Response[mgmtv1alpha1.DeleteConnectionResponse], error)) *MockConnectionServiceHandler_DeleteConnection_Call

type MockConnectionServiceHandler_Expecter 

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

func (*MockConnectionServiceHandler_Expecter) CheckConnectionConfig 

func (_e *MockConnectionServiceHandler_Expecter) CheckConnectionConfig(_a0 interface{}, _a1 interface{}) *MockConnectionServiceHandler_CheckConnectionConfig_Call

CheckConnectionConfig is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.CheckConnectionConfigRequest]

func (*MockConnectionServiceHandler_Expecter) CheckSqlQuery 

func (_e *MockConnectionServiceHandler_Expecter) CheckSqlQuery(_a0 interface{}, _a1 interface{}) *MockConnectionServiceHandler_CheckSqlQuery_Call

CheckSqlQuery is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.CheckSqlQueryRequest]

func (*MockConnectionServiceHandler_Expecter) CreateConnection 

func (_e *MockConnectionServiceHandler_Expecter) CreateConnection(_a0 interface{}, _a1 interface{}) *MockConnectionServiceHandler_CreateConnection_Call

CreateConnection is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.CreateConnectionRequest]

func (*MockConnectionServiceHandler_Expecter) DeleteConnection 

func (_e *MockConnectionServiceHandler_Expecter) DeleteConnection(_a0 interface{}, _a1 interface{}) *MockConnectionServiceHandler_DeleteConnection_Call

DeleteConnection is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.DeleteConnectionRequest]

func (*MockConnectionServiceHandler_Expecter) GetConnection 

func (_e *MockConnectionServiceHandler_Expecter) GetConnection(_a0 interface{}, _a1 interface{}) *MockConnectionServiceHandler_GetConnection_Call

GetConnection is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetConnectionRequest]

func (*MockConnectionServiceHandler_Expecter) GetConnectionDataStream 

func (_e *MockConnectionServiceHandler_Expecter) GetConnectionDataStream(_a0 interface{}, _a1 interface{}, _a2 interface{}) *MockConnectionServiceHandler_GetConnectionDataStream_Call

GetConnectionDataStream is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetConnectionDataStreamRequest]
  • _a2 *connect.ServerStream[mgmtv1alpha1.GetConnectionDataStreamResponse]

func (*MockConnectionServiceHandler_Expecter) GetConnectionForeignConstraints 

func (_e *MockConnectionServiceHandler_Expecter) GetConnectionForeignConstraints(_a0 interface{}, _a1 interface{}) *MockConnectionServiceHandler_GetConnectionForeignConstraints_Call

GetConnectionForeignConstraints is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetConnectionForeignConstraintsRequest]

func (*MockConnectionServiceHandler_Expecter) GetConnectionInitStatements 

func (_e *MockConnectionServiceHandler_Expecter) GetConnectionInitStatements(_a0 interface{}, _a1 interface{}) *MockConnectionServiceHandler_GetConnectionInitStatements_Call

GetConnectionInitStatements is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetConnectionInitStatementsRequest]

func (*MockConnectionServiceHandler_Expecter) GetConnectionSchema 

func (_e *MockConnectionServiceHandler_Expecter) GetConnectionSchema(_a0 interface{}, _a1 interface{}) *MockConnectionServiceHandler_GetConnectionSchema_Call

GetConnectionSchema is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetConnectionSchemaRequest]

func (*MockConnectionServiceHandler_Expecter) GetConnections 

func (_e *MockConnectionServiceHandler_Expecter) GetConnections(_a0 interface{}, _a1 interface{}) *MockConnectionServiceHandler_GetConnections_Call

GetConnections is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetConnectionsRequest]

func (*MockConnectionServiceHandler_Expecter) IsConnectionNameAvailable 

func (_e *MockConnectionServiceHandler_Expecter) IsConnectionNameAvailable(_a0 interface{}, _a1 interface{}) *MockConnectionServiceHandler_IsConnectionNameAvailable_Call

IsConnectionNameAvailable is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.IsConnectionNameAvailableRequest]

func (*MockConnectionServiceHandler_Expecter) UpdateConnection 

func (_e *MockConnectionServiceHandler_Expecter) UpdateConnection(_a0 interface{}, _a1 interface{}) *MockConnectionServiceHandler_UpdateConnection_Call

UpdateConnection is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.UpdateConnectionRequest]

type MockConnectionServiceHandler_GetConnectionDataStream_Call 

type MockConnectionServiceHandler_GetConnectionDataStream_Call struct {
	*mock.Call
}

MockConnectionServiceHandler_GetConnectionDataStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetConnectionDataStream'

func (*MockConnectionServiceHandler_GetConnectionDataStream_Call) Return 

func (_c *MockConnectionServiceHandler_GetConnectionDataStream_Call) Return(_a0 error) *MockConnectionServiceHandler_GetConnectionDataStream_Call

func (*MockConnectionServiceHandler_GetConnectionDataStream_Call) Run 

func (_c *MockConnectionServiceHandler_GetConnectionDataStream_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetConnectionDataStreamRequest], _a2 *connect.ServerStream[mgmtv1alpha1.GetConnectionDataStreamResponse])) *MockConnectionServiceHandler_GetConnectionDataStream_Call

func (*MockConnectionServiceHandler_GetConnectionDataStream_Call) RunAndReturn 

func (_c *MockConnectionServiceHandler_GetConnectionDataStream_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetConnectionDataStreamRequest], *connect.ServerStream[mgmtv1alpha1.GetConnectionDataStreamResponse]) error) *MockConnectionServiceHandler_GetConnectionDataStream_Call

type MockConnectionServiceHandler_GetConnectionForeignConstraints_Call 

type MockConnectionServiceHandler_GetConnectionForeignConstraints_Call struct {
	*mock.Call
}

MockConnectionServiceHandler_GetConnectionForeignConstraints_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetConnectionForeignConstraints'

func (*MockConnectionServiceHandler_GetConnectionForeignConstraints_Call) Return 

func (_c *MockConnectionServiceHandler_GetConnectionForeignConstraints_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetConnectionForeignConstraintsResponse], _a1 error) *MockConnectionServiceHandler_GetConnectionForeignConstraints_Call

func (*MockConnectionServiceHandler_GetConnectionForeignConstraints_Call) Run 

func (_c *MockConnectionServiceHandler_GetConnectionForeignConstraints_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetConnectionForeignConstraintsRequest])) *MockConnectionServiceHandler_GetConnectionForeignConstraints_Call

func (*MockConnectionServiceHandler_GetConnectionForeignConstraints_Call) RunAndReturn 

func (_c *MockConnectionServiceHandler_GetConnectionForeignConstraints_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetConnectionForeignConstraintsRequest]) (*connect.Response[mgmtv1alpha1.GetConnectionForeignConstraintsResponse], error)) *MockConnectionServiceHandler_GetConnectionForeignConstraints_Call

type MockConnectionServiceHandler_GetConnectionInitStatements_Call 

type MockConnectionServiceHandler_GetConnectionInitStatements_Call struct {
	*mock.Call
}

MockConnectionServiceHandler_GetConnectionInitStatements_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetConnectionInitStatements'

func (*MockConnectionServiceHandler_GetConnectionInitStatements_Call) Return 

func (_c *MockConnectionServiceHandler_GetConnectionInitStatements_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetConnectionInitStatementsResponse], _a1 error) *MockConnectionServiceHandler_GetConnectionInitStatements_Call

func (*MockConnectionServiceHandler_GetConnectionInitStatements_Call) Run 

func (_c *MockConnectionServiceHandler_GetConnectionInitStatements_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetConnectionInitStatementsRequest])) *MockConnectionServiceHandler_GetConnectionInitStatements_Call

func (*MockConnectionServiceHandler_GetConnectionInitStatements_Call) RunAndReturn 

func (_c *MockConnectionServiceHandler_GetConnectionInitStatements_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetConnectionInitStatementsRequest]) (*connect.Response[mgmtv1alpha1.GetConnectionInitStatementsResponse], error)) *MockConnectionServiceHandler_GetConnectionInitStatements_Call

type MockConnectionServiceHandler_GetConnectionSchema_Call 

type MockConnectionServiceHandler_GetConnectionSchema_Call struct {
	*mock.Call
}

MockConnectionServiceHandler_GetConnectionSchema_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetConnectionSchema'

func (*MockConnectionServiceHandler_GetConnectionSchema_Call) Return 

func (_c *MockConnectionServiceHandler_GetConnectionSchema_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetConnectionSchemaResponse], _a1 error) *MockConnectionServiceHandler_GetConnectionSchema_Call

func (*MockConnectionServiceHandler_GetConnectionSchema_Call) Run 

func (_c *MockConnectionServiceHandler_GetConnectionSchema_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetConnectionSchemaRequest])) *MockConnectionServiceHandler_GetConnectionSchema_Call

func (*MockConnectionServiceHandler_GetConnectionSchema_Call) RunAndReturn 

func (_c *MockConnectionServiceHandler_GetConnectionSchema_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetConnectionSchemaRequest]) (*connect.Response[mgmtv1alpha1.GetConnectionSchemaResponse], error)) *MockConnectionServiceHandler_GetConnectionSchema_Call

type MockConnectionServiceHandler_GetConnection_Call 

type MockConnectionServiceHandler_GetConnection_Call struct {
	*mock.Call
}

MockConnectionServiceHandler_GetConnection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetConnection'

func (*MockConnectionServiceHandler_GetConnection_Call) Return 

func (_c *MockConnectionServiceHandler_GetConnection_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetConnectionResponse], _a1 error) *MockConnectionServiceHandler_GetConnection_Call

func (*MockConnectionServiceHandler_GetConnection_Call) Run 

func (_c *MockConnectionServiceHandler_GetConnection_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetConnectionRequest])) *MockConnectionServiceHandler_GetConnection_Call

func (*MockConnectionServiceHandler_GetConnection_Call) RunAndReturn 

func (_c *MockConnectionServiceHandler_GetConnection_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetConnectionRequest]) (*connect.Response[mgmtv1alpha1.GetConnectionResponse], error)) *MockConnectionServiceHandler_GetConnection_Call

type MockConnectionServiceHandler_GetConnections_Call 

type MockConnectionServiceHandler_GetConnections_Call struct {
	*mock.Call
}

MockConnectionServiceHandler_GetConnections_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetConnections'

func (*MockConnectionServiceHandler_GetConnections_Call) Return 

func (_c *MockConnectionServiceHandler_GetConnections_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetConnectionsResponse], _a1 error) *MockConnectionServiceHandler_GetConnections_Call

func (*MockConnectionServiceHandler_GetConnections_Call) Run 

func (_c *MockConnectionServiceHandler_GetConnections_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetConnectionsRequest])) *MockConnectionServiceHandler_GetConnections_Call

func (*MockConnectionServiceHandler_GetConnections_Call) RunAndReturn 

func (_c *MockConnectionServiceHandler_GetConnections_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetConnectionsRequest]) (*connect.Response[mgmtv1alpha1.GetConnectionsResponse], error)) *MockConnectionServiceHandler_GetConnections_Call

type MockConnectionServiceHandler_IsConnectionNameAvailable_Call 

type MockConnectionServiceHandler_IsConnectionNameAvailable_Call struct {
	*mock.Call
}

MockConnectionServiceHandler_IsConnectionNameAvailable_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsConnectionNameAvailable'

func (*MockConnectionServiceHandler_IsConnectionNameAvailable_Call) Return 

func (_c *MockConnectionServiceHandler_IsConnectionNameAvailable_Call) Return(_a0 *connect.Response[mgmtv1alpha1.IsConnectionNameAvailableResponse], _a1 error) *MockConnectionServiceHandler_IsConnectionNameAvailable_Call

func (*MockConnectionServiceHandler_IsConnectionNameAvailable_Call) Run 

func (_c *MockConnectionServiceHandler_IsConnectionNameAvailable_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.IsConnectionNameAvailableRequest])) *MockConnectionServiceHandler_IsConnectionNameAvailable_Call

func (*MockConnectionServiceHandler_IsConnectionNameAvailable_Call) RunAndReturn 

func (_c *MockConnectionServiceHandler_IsConnectionNameAvailable_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.IsConnectionNameAvailableRequest]) (*connect.Response[mgmtv1alpha1.IsConnectionNameAvailableResponse], error)) *MockConnectionServiceHandler_IsConnectionNameAvailable_Call

type MockConnectionServiceHandler_UpdateConnection_Call 

type MockConnectionServiceHandler_UpdateConnection_Call struct {
	*mock.Call
}

MockConnectionServiceHandler_UpdateConnection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateConnection'

func (*MockConnectionServiceHandler_UpdateConnection_Call) Return 

func (_c *MockConnectionServiceHandler_UpdateConnection_Call) Return(_a0 *connect.Response[mgmtv1alpha1.UpdateConnectionResponse], _a1 error) *MockConnectionServiceHandler_UpdateConnection_Call

func (*MockConnectionServiceHandler_UpdateConnection_Call) Run 

func (_c *MockConnectionServiceHandler_UpdateConnection_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.UpdateConnectionRequest])) *MockConnectionServiceHandler_UpdateConnection_Call

func (*MockConnectionServiceHandler_UpdateConnection_Call) RunAndReturn 

func (_c *MockConnectionServiceHandler_UpdateConnection_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.UpdateConnectionRequest]) (*connect.Response[mgmtv1alpha1.UpdateConnectionResponse], error)) *MockConnectionServiceHandler_UpdateConnection_Call

type MockJobServiceClient 

type MockJobServiceClient struct {
	mock.Mock
}

MockJobServiceClient is an autogenerated mock type for the JobServiceClient type

func NewMockJobServiceClient 

func NewMockJobServiceClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockJobServiceClient

NewMockJobServiceClient creates a new instance of MockJobServiceClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockJobServiceClient) CancelJobRun 

func (_m *MockJobServiceClient) CancelJobRun(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CancelJobRunRequest]) (*connect.Response[mgmtv1alpha1.CancelJobRunResponse], error)

CancelJobRun provides a mock function with given fields: _a0, _a1

func (*MockJobServiceClient) CreateJob 

func (_m *MockJobServiceClient) CreateJob(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CreateJobRequest]) (*connect.Response[mgmtv1alpha1.CreateJobResponse], error)

CreateJob provides a mock function with given fields: _a0, _a1

func (*MockJobServiceClient) CreateJobDestinationConnections 

func (_m *MockJobServiceClient) CreateJobDestinationConnections(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CreateJobDestinationConnectionsRequest]) (*connect.Response[mgmtv1alpha1.CreateJobDestinationConnectionsResponse], error)

CreateJobDestinationConnections provides a mock function with given fields: _a0, _a1

func (*MockJobServiceClient) CreateJobRun 

func (_m *MockJobServiceClient) CreateJobRun(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CreateJobRunRequest]) (*connect.Response[mgmtv1alpha1.CreateJobRunResponse], error)

CreateJobRun provides a mock function with given fields: _a0, _a1

func (*MockJobServiceClient) DeleteJob 

func (_m *MockJobServiceClient) DeleteJob(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.DeleteJobRequest]) (*connect.Response[mgmtv1alpha1.DeleteJobResponse], error)

DeleteJob provides a mock function with given fields: _a0, _a1

func (*MockJobServiceClient) DeleteJobDestinationConnection 

func (_m *MockJobServiceClient) DeleteJobDestinationConnection(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.DeleteJobDestinationConnectionRequest]) (*connect.Response[mgmtv1alpha1.DeleteJobDestinationConnectionResponse], error)

DeleteJobDestinationConnection provides a mock function with given fields: _a0, _a1

func (*MockJobServiceClient) DeleteJobRun 

func (_m *MockJobServiceClient) DeleteJobRun(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.DeleteJobRunRequest]) (*connect.Response[mgmtv1alpha1.DeleteJobRunResponse], error)

DeleteJobRun provides a mock function with given fields: _a0, _a1

func (*MockJobServiceClient) EXPECT 

func (_m *MockJobServiceClient) EXPECT() *MockJobServiceClient_Expecter

func (*MockJobServiceClient) GetJob 

func (_m *MockJobServiceClient) GetJob(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobRequest]) (*connect.Response[mgmtv1alpha1.GetJobResponse], error)

GetJob provides a mock function with given fields: _a0, _a1

func (*MockJobServiceClient) GetJobNextRuns 

func (_m *MockJobServiceClient) GetJobNextRuns(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobNextRunsRequest]) (*connect.Response[mgmtv1alpha1.GetJobNextRunsResponse], error)

GetJobNextRuns provides a mock function with given fields: _a0, _a1

func (*MockJobServiceClient) GetJobRecentRuns 

func (_m *MockJobServiceClient) GetJobRecentRuns(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobRecentRunsRequest]) (*connect.Response[mgmtv1alpha1.GetJobRecentRunsResponse], error)

GetJobRecentRuns provides a mock function with given fields: _a0, _a1

func (*MockJobServiceClient) GetJobRun 

func (_m *MockJobServiceClient) GetJobRun(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobRunRequest]) (*connect.Response[mgmtv1alpha1.GetJobRunResponse], error)

GetJobRun provides a mock function with given fields: _a0, _a1

func (*MockJobServiceClient) GetJobRunEvents 

func (_m *MockJobServiceClient) GetJobRunEvents(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobRunEventsRequest]) (*connect.Response[mgmtv1alpha1.GetJobRunEventsResponse], error)

GetJobRunEvents provides a mock function with given fields: _a0, _a1

func (*MockJobServiceClient) GetJobRunLogsStream 

func (_m *MockJobServiceClient) GetJobRunLogsStream(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobRunLogsStreamRequest]) (*connect.ServerStreamForClient[mgmtv1alpha1.GetJobRunLogsStreamResponse], error)

GetJobRunLogsStream provides a mock function with given fields: _a0, _a1

func (*MockJobServiceClient) GetJobRuns 

func (_m *MockJobServiceClient) GetJobRuns(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobRunsRequest]) (*connect.Response[mgmtv1alpha1.GetJobRunsResponse], error)

GetJobRuns provides a mock function with given fields: _a0, _a1

func (*MockJobServiceClient) GetJobStatus 

func (_m *MockJobServiceClient) GetJobStatus(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobStatusRequest]) (*connect.Response[mgmtv1alpha1.GetJobStatusResponse], error)

GetJobStatus provides a mock function with given fields: _a0, _a1

func (*MockJobServiceClient) GetJobStatuses 

func (_m *MockJobServiceClient) GetJobStatuses(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobStatusesRequest]) (*connect.Response[mgmtv1alpha1.GetJobStatusesResponse], error)

GetJobStatuses provides a mock function with given fields: _a0, _a1

func (*MockJobServiceClient) GetJobs 

func (_m *MockJobServiceClient) GetJobs(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobsRequest]) (*connect.Response[mgmtv1alpha1.GetJobsResponse], error)

GetJobs provides a mock function with given fields: _a0, _a1

func (*MockJobServiceClient) IsJobNameAvailable 

func (_m *MockJobServiceClient) IsJobNameAvailable(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.IsJobNameAvailableRequest]) (*connect.Response[mgmtv1alpha1.IsJobNameAvailableResponse], error)

IsJobNameAvailable provides a mock function with given fields: _a0, _a1

func (*MockJobServiceClient) PauseJob 

func (_m *MockJobServiceClient) PauseJob(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.PauseJobRequest]) (*connect.Response[mgmtv1alpha1.PauseJobResponse], error)

PauseJob provides a mock function with given fields: _a0, _a1

func (*MockJobServiceClient) SetJobSourceSqlConnectionSubsets 

func (_m *MockJobServiceClient) SetJobSourceSqlConnectionSubsets(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.SetJobSourceSqlConnectionSubsetsRequest]) (*connect.Response[mgmtv1alpha1.SetJobSourceSqlConnectionSubsetsResponse], error)

SetJobSourceSqlConnectionSubsets provides a mock function with given fields: _a0, _a1

func (*MockJobServiceClient) SetJobSyncOptions 

func (_m *MockJobServiceClient) SetJobSyncOptions(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.SetJobSyncOptionsRequest]) (*connect.Response[mgmtv1alpha1.SetJobSyncOptionsResponse], error)

SetJobSyncOptions provides a mock function with given fields: _a0, _a1

func (*MockJobServiceClient) SetJobWorkflowOptions 

func (_m *MockJobServiceClient) SetJobWorkflowOptions(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.SetJobWorkflowOptionsRequest]) (*connect.Response[mgmtv1alpha1.SetJobWorkflowOptionsResponse], error)

SetJobWorkflowOptions provides a mock function with given fields: _a0, _a1

func (*MockJobServiceClient) TerminateJobRun 

func (_m *MockJobServiceClient) TerminateJobRun(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.TerminateJobRunRequest]) (*connect.Response[mgmtv1alpha1.TerminateJobRunResponse], error)

TerminateJobRun provides a mock function with given fields: _a0, _a1

func (*MockJobServiceClient) UpdateJobDestinationConnection 

func (_m *MockJobServiceClient) UpdateJobDestinationConnection(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.UpdateJobDestinationConnectionRequest]) (*connect.Response[mgmtv1alpha1.UpdateJobDestinationConnectionResponse], error)

UpdateJobDestinationConnection provides a mock function with given fields: _a0, _a1

func (*MockJobServiceClient) UpdateJobSchedule 

func (_m *MockJobServiceClient) UpdateJobSchedule(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.UpdateJobScheduleRequest]) (*connect.Response[mgmtv1alpha1.UpdateJobScheduleResponse], error)

UpdateJobSchedule provides a mock function with given fields: _a0, _a1

func (*MockJobServiceClient) UpdateJobSourceConnection 

func (_m *MockJobServiceClient) UpdateJobSourceConnection(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.UpdateJobSourceConnectionRequest]) (*connect.Response[mgmtv1alpha1.UpdateJobSourceConnectionResponse], error)

UpdateJobSourceConnection provides a mock function with given fields: _a0, _a1

func (*MockJobServiceClient) ValidateJobMappings added in v0.4.24 

func (_m *MockJobServiceClient) ValidateJobMappings(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.ValidateJobMappingsRequest]) (*connect.Response[mgmtv1alpha1.ValidateJobMappingsResponse], error)

ValidateJobMappings provides a mock function with given fields: _a0, _a1

type MockJobServiceClient_CancelJobRun_Call 

type MockJobServiceClient_CancelJobRun_Call struct {
	*mock.Call
}

MockJobServiceClient_CancelJobRun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CancelJobRun'

func (*MockJobServiceClient_CancelJobRun_Call) Return 

func (_c *MockJobServiceClient_CancelJobRun_Call) Return(_a0 *connect.Response[mgmtv1alpha1.CancelJobRunResponse], _a1 error) *MockJobServiceClient_CancelJobRun_Call

func (*MockJobServiceClient_CancelJobRun_Call) Run 

func (_c *MockJobServiceClient_CancelJobRun_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CancelJobRunRequest])) *MockJobServiceClient_CancelJobRun_Call

func (*MockJobServiceClient_CancelJobRun_Call) RunAndReturn 

func (_c *MockJobServiceClient_CancelJobRun_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.CancelJobRunRequest]) (*connect.Response[mgmtv1alpha1.CancelJobRunResponse], error)) *MockJobServiceClient_CancelJobRun_Call

type MockJobServiceClient_CreateJobDestinationConnections_Call 

type MockJobServiceClient_CreateJobDestinationConnections_Call struct {
	*mock.Call
}

MockJobServiceClient_CreateJobDestinationConnections_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateJobDestinationConnections'

func (*MockJobServiceClient_CreateJobDestinationConnections_Call) Return 

func (_c *MockJobServiceClient_CreateJobDestinationConnections_Call) Return(_a0 *connect.Response[mgmtv1alpha1.CreateJobDestinationConnectionsResponse], _a1 error) *MockJobServiceClient_CreateJobDestinationConnections_Call

func (*MockJobServiceClient_CreateJobDestinationConnections_Call) Run 

func (_c *MockJobServiceClient_CreateJobDestinationConnections_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CreateJobDestinationConnectionsRequest])) *MockJobServiceClient_CreateJobDestinationConnections_Call

func (*MockJobServiceClient_CreateJobDestinationConnections_Call) RunAndReturn 

func (_c *MockJobServiceClient_CreateJobDestinationConnections_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.CreateJobDestinationConnectionsRequest]) (*connect.Response[mgmtv1alpha1.CreateJobDestinationConnectionsResponse], error)) *MockJobServiceClient_CreateJobDestinationConnections_Call

type MockJobServiceClient_CreateJobRun_Call 

type MockJobServiceClient_CreateJobRun_Call struct {
	*mock.Call
}

MockJobServiceClient_CreateJobRun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateJobRun'

func (*MockJobServiceClient_CreateJobRun_Call) Return 

func (_c *MockJobServiceClient_CreateJobRun_Call) Return(_a0 *connect.Response[mgmtv1alpha1.CreateJobRunResponse], _a1 error) *MockJobServiceClient_CreateJobRun_Call

func (*MockJobServiceClient_CreateJobRun_Call) Run 

func (_c *MockJobServiceClient_CreateJobRun_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CreateJobRunRequest])) *MockJobServiceClient_CreateJobRun_Call

func (*MockJobServiceClient_CreateJobRun_Call) RunAndReturn 

func (_c *MockJobServiceClient_CreateJobRun_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.CreateJobRunRequest]) (*connect.Response[mgmtv1alpha1.CreateJobRunResponse], error)) *MockJobServiceClient_CreateJobRun_Call

type MockJobServiceClient_CreateJob_Call 

type MockJobServiceClient_CreateJob_Call struct {
	*mock.Call
}

MockJobServiceClient_CreateJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateJob'

func (*MockJobServiceClient_CreateJob_Call) Return 

func (_c *MockJobServiceClient_CreateJob_Call) Return(_a0 *connect.Response[mgmtv1alpha1.CreateJobResponse], _a1 error) *MockJobServiceClient_CreateJob_Call

func (*MockJobServiceClient_CreateJob_Call) Run 

func (_c *MockJobServiceClient_CreateJob_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CreateJobRequest])) *MockJobServiceClient_CreateJob_Call

func (*MockJobServiceClient_CreateJob_Call) RunAndReturn 

func (_c *MockJobServiceClient_CreateJob_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.CreateJobRequest]) (*connect.Response[mgmtv1alpha1.CreateJobResponse], error)) *MockJobServiceClient_CreateJob_Call

type MockJobServiceClient_DeleteJobDestinationConnection_Call 

type MockJobServiceClient_DeleteJobDestinationConnection_Call struct {
	*mock.Call
}

MockJobServiceClient_DeleteJobDestinationConnection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteJobDestinationConnection'

func (*MockJobServiceClient_DeleteJobDestinationConnection_Call) Return 

func (_c *MockJobServiceClient_DeleteJobDestinationConnection_Call) Return(_a0 *connect.Response[mgmtv1alpha1.DeleteJobDestinationConnectionResponse], _a1 error) *MockJobServiceClient_DeleteJobDestinationConnection_Call

func (*MockJobServiceClient_DeleteJobDestinationConnection_Call) Run 

func (_c *MockJobServiceClient_DeleteJobDestinationConnection_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.DeleteJobDestinationConnectionRequest])) *MockJobServiceClient_DeleteJobDestinationConnection_Call

func (*MockJobServiceClient_DeleteJobDestinationConnection_Call) RunAndReturn 

func (_c *MockJobServiceClient_DeleteJobDestinationConnection_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.DeleteJobDestinationConnectionRequest]) (*connect.Response[mgmtv1alpha1.DeleteJobDestinationConnectionResponse], error)) *MockJobServiceClient_DeleteJobDestinationConnection_Call

type MockJobServiceClient_DeleteJobRun_Call 

type MockJobServiceClient_DeleteJobRun_Call struct {
	*mock.Call
}

MockJobServiceClient_DeleteJobRun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteJobRun'

func (*MockJobServiceClient_DeleteJobRun_Call) Return 

func (_c *MockJobServiceClient_DeleteJobRun_Call) Return(_a0 *connect.Response[mgmtv1alpha1.DeleteJobRunResponse], _a1 error) *MockJobServiceClient_DeleteJobRun_Call

func (*MockJobServiceClient_DeleteJobRun_Call) Run 

func (_c *MockJobServiceClient_DeleteJobRun_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.DeleteJobRunRequest])) *MockJobServiceClient_DeleteJobRun_Call

func (*MockJobServiceClient_DeleteJobRun_Call) RunAndReturn 

func (_c *MockJobServiceClient_DeleteJobRun_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.DeleteJobRunRequest]) (*connect.Response[mgmtv1alpha1.DeleteJobRunResponse], error)) *MockJobServiceClient_DeleteJobRun_Call

type MockJobServiceClient_DeleteJob_Call 

type MockJobServiceClient_DeleteJob_Call struct {
	*mock.Call
}

MockJobServiceClient_DeleteJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteJob'

func (*MockJobServiceClient_DeleteJob_Call) Return 

func (_c *MockJobServiceClient_DeleteJob_Call) Return(_a0 *connect.Response[mgmtv1alpha1.DeleteJobResponse], _a1 error) *MockJobServiceClient_DeleteJob_Call

func (*MockJobServiceClient_DeleteJob_Call) Run 

func (_c *MockJobServiceClient_DeleteJob_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.DeleteJobRequest])) *MockJobServiceClient_DeleteJob_Call

func (*MockJobServiceClient_DeleteJob_Call) RunAndReturn 

func (_c *MockJobServiceClient_DeleteJob_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.DeleteJobRequest]) (*connect.Response[mgmtv1alpha1.DeleteJobResponse], error)) *MockJobServiceClient_DeleteJob_Call

type MockJobServiceClient_Expecter 

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

func (*MockJobServiceClient_Expecter) CancelJobRun 

func (_e *MockJobServiceClient_Expecter) CancelJobRun(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_CancelJobRun_Call

CancelJobRun is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.CancelJobRunRequest]

func (*MockJobServiceClient_Expecter) CreateJob 

func (_e *MockJobServiceClient_Expecter) CreateJob(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_CreateJob_Call

CreateJob is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.CreateJobRequest]

func (*MockJobServiceClient_Expecter) CreateJobDestinationConnections 

func (_e *MockJobServiceClient_Expecter) CreateJobDestinationConnections(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_CreateJobDestinationConnections_Call

CreateJobDestinationConnections is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.CreateJobDestinationConnectionsRequest]

func (*MockJobServiceClient_Expecter) CreateJobRun 

func (_e *MockJobServiceClient_Expecter) CreateJobRun(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_CreateJobRun_Call

CreateJobRun is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.CreateJobRunRequest]

func (*MockJobServiceClient_Expecter) DeleteJob 

func (_e *MockJobServiceClient_Expecter) DeleteJob(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_DeleteJob_Call

DeleteJob is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.DeleteJobRequest]

func (*MockJobServiceClient_Expecter) DeleteJobDestinationConnection 

func (_e *MockJobServiceClient_Expecter) DeleteJobDestinationConnection(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_DeleteJobDestinationConnection_Call

DeleteJobDestinationConnection is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.DeleteJobDestinationConnectionRequest]

func (*MockJobServiceClient_Expecter) DeleteJobRun 

func (_e *MockJobServiceClient_Expecter) DeleteJobRun(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_DeleteJobRun_Call

DeleteJobRun is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.DeleteJobRunRequest]

func (*MockJobServiceClient_Expecter) GetJob 

func (_e *MockJobServiceClient_Expecter) GetJob(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_GetJob_Call

GetJob is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetJobRequest]

func (*MockJobServiceClient_Expecter) GetJobNextRuns 

func (_e *MockJobServiceClient_Expecter) GetJobNextRuns(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_GetJobNextRuns_Call

GetJobNextRuns is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetJobNextRunsRequest]

func (*MockJobServiceClient_Expecter) GetJobRecentRuns 

func (_e *MockJobServiceClient_Expecter) GetJobRecentRuns(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_GetJobRecentRuns_Call

GetJobRecentRuns is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetJobRecentRunsRequest]

func (*MockJobServiceClient_Expecter) GetJobRun 

func (_e *MockJobServiceClient_Expecter) GetJobRun(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_GetJobRun_Call

GetJobRun is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetJobRunRequest]

func (*MockJobServiceClient_Expecter) GetJobRunEvents 

func (_e *MockJobServiceClient_Expecter) GetJobRunEvents(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_GetJobRunEvents_Call

GetJobRunEvents is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetJobRunEventsRequest]

func (*MockJobServiceClient_Expecter) GetJobRunLogsStream 

func (_e *MockJobServiceClient_Expecter) GetJobRunLogsStream(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_GetJobRunLogsStream_Call

GetJobRunLogsStream is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetJobRunLogsStreamRequest]

func (*MockJobServiceClient_Expecter) GetJobRuns 

func (_e *MockJobServiceClient_Expecter) GetJobRuns(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_GetJobRuns_Call

GetJobRuns is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetJobRunsRequest]

func (*MockJobServiceClient_Expecter) GetJobStatus 

func (_e *MockJobServiceClient_Expecter) GetJobStatus(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_GetJobStatus_Call

GetJobStatus is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetJobStatusRequest]

func (*MockJobServiceClient_Expecter) GetJobStatuses 

func (_e *MockJobServiceClient_Expecter) GetJobStatuses(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_GetJobStatuses_Call

GetJobStatuses is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetJobStatusesRequest]

func (*MockJobServiceClient_Expecter) GetJobs 

func (_e *MockJobServiceClient_Expecter) GetJobs(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_GetJobs_Call

GetJobs is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetJobsRequest]

func (*MockJobServiceClient_Expecter) IsJobNameAvailable 

func (_e *MockJobServiceClient_Expecter) IsJobNameAvailable(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_IsJobNameAvailable_Call

IsJobNameAvailable is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.IsJobNameAvailableRequest]

func (*MockJobServiceClient_Expecter) PauseJob 

func (_e *MockJobServiceClient_Expecter) PauseJob(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_PauseJob_Call

PauseJob is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.PauseJobRequest]

func (*MockJobServiceClient_Expecter) SetJobSourceSqlConnectionSubsets 

func (_e *MockJobServiceClient_Expecter) SetJobSourceSqlConnectionSubsets(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_SetJobSourceSqlConnectionSubsets_Call

SetJobSourceSqlConnectionSubsets is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.SetJobSourceSqlConnectionSubsetsRequest]

func (*MockJobServiceClient_Expecter) SetJobSyncOptions 

func (_e *MockJobServiceClient_Expecter) SetJobSyncOptions(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_SetJobSyncOptions_Call

SetJobSyncOptions is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.SetJobSyncOptionsRequest]

func (*MockJobServiceClient_Expecter) SetJobWorkflowOptions 

func (_e *MockJobServiceClient_Expecter) SetJobWorkflowOptions(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_SetJobWorkflowOptions_Call

SetJobWorkflowOptions is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.SetJobWorkflowOptionsRequest]

func (*MockJobServiceClient_Expecter) TerminateJobRun 

func (_e *MockJobServiceClient_Expecter) TerminateJobRun(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_TerminateJobRun_Call

TerminateJobRun is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.TerminateJobRunRequest]

func (*MockJobServiceClient_Expecter) UpdateJobDestinationConnection 

func (_e *MockJobServiceClient_Expecter) UpdateJobDestinationConnection(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_UpdateJobDestinationConnection_Call

UpdateJobDestinationConnection is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.UpdateJobDestinationConnectionRequest]

func (*MockJobServiceClient_Expecter) UpdateJobSchedule 

func (_e *MockJobServiceClient_Expecter) UpdateJobSchedule(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_UpdateJobSchedule_Call

UpdateJobSchedule is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.UpdateJobScheduleRequest]

func (*MockJobServiceClient_Expecter) UpdateJobSourceConnection 

func (_e *MockJobServiceClient_Expecter) UpdateJobSourceConnection(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_UpdateJobSourceConnection_Call

UpdateJobSourceConnection is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.UpdateJobSourceConnectionRequest]

func (*MockJobServiceClient_Expecter) ValidateJobMappings added in v0.4.24 

func (_e *MockJobServiceClient_Expecter) ValidateJobMappings(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_ValidateJobMappings_Call

ValidateJobMappings is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.ValidateJobMappingsRequest]

type MockJobServiceClient_GetJobNextRuns_Call 

type MockJobServiceClient_GetJobNextRuns_Call struct {
	*mock.Call
}

MockJobServiceClient_GetJobNextRuns_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJobNextRuns'

func (*MockJobServiceClient_GetJobNextRuns_Call) Return 

func (_c *MockJobServiceClient_GetJobNextRuns_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetJobNextRunsResponse], _a1 error) *MockJobServiceClient_GetJobNextRuns_Call

func (*MockJobServiceClient_GetJobNextRuns_Call) Run 

func (_c *MockJobServiceClient_GetJobNextRuns_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobNextRunsRequest])) *MockJobServiceClient_GetJobNextRuns_Call

func (*MockJobServiceClient_GetJobNextRuns_Call) RunAndReturn 

func (_c *MockJobServiceClient_GetJobNextRuns_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetJobNextRunsRequest]) (*connect.Response[mgmtv1alpha1.GetJobNextRunsResponse], error)) *MockJobServiceClient_GetJobNextRuns_Call

type MockJobServiceClient_GetJobRecentRuns_Call 

type MockJobServiceClient_GetJobRecentRuns_Call struct {
	*mock.Call
}

MockJobServiceClient_GetJobRecentRuns_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJobRecentRuns'

func (*MockJobServiceClient_GetJobRecentRuns_Call) Return 

func (_c *MockJobServiceClient_GetJobRecentRuns_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetJobRecentRunsResponse], _a1 error) *MockJobServiceClient_GetJobRecentRuns_Call

func (*MockJobServiceClient_GetJobRecentRuns_Call) Run 

func (_c *MockJobServiceClient_GetJobRecentRuns_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobRecentRunsRequest])) *MockJobServiceClient_GetJobRecentRuns_Call

func (*MockJobServiceClient_GetJobRecentRuns_Call) RunAndReturn 

func (_c *MockJobServiceClient_GetJobRecentRuns_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetJobRecentRunsRequest]) (*connect.Response[mgmtv1alpha1.GetJobRecentRunsResponse], error)) *MockJobServiceClient_GetJobRecentRuns_Call

type MockJobServiceClient_GetJobRunEvents_Call 

type MockJobServiceClient_GetJobRunEvents_Call struct {
	*mock.Call
}

MockJobServiceClient_GetJobRunEvents_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJobRunEvents'

func (*MockJobServiceClient_GetJobRunEvents_Call) Return 

func (_c *MockJobServiceClient_GetJobRunEvents_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetJobRunEventsResponse], _a1 error) *MockJobServiceClient_GetJobRunEvents_Call

func (*MockJobServiceClient_GetJobRunEvents_Call) Run 

func (_c *MockJobServiceClient_GetJobRunEvents_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobRunEventsRequest])) *MockJobServiceClient_GetJobRunEvents_Call

func (*MockJobServiceClient_GetJobRunEvents_Call) RunAndReturn 

func (_c *MockJobServiceClient_GetJobRunEvents_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetJobRunEventsRequest]) (*connect.Response[mgmtv1alpha1.GetJobRunEventsResponse], error)) *MockJobServiceClient_GetJobRunEvents_Call

type MockJobServiceClient_GetJobRunLogsStream_Call 

type MockJobServiceClient_GetJobRunLogsStream_Call struct {
	*mock.Call
}

MockJobServiceClient_GetJobRunLogsStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJobRunLogsStream'

func (*MockJobServiceClient_GetJobRunLogsStream_Call) Return 

func (_c *MockJobServiceClient_GetJobRunLogsStream_Call) Return(_a0 *connect.ServerStreamForClient[mgmtv1alpha1.GetJobRunLogsStreamResponse], _a1 error) *MockJobServiceClient_GetJobRunLogsStream_Call

func (*MockJobServiceClient_GetJobRunLogsStream_Call) Run 

func (_c *MockJobServiceClient_GetJobRunLogsStream_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobRunLogsStreamRequest])) *MockJobServiceClient_GetJobRunLogsStream_Call

func (*MockJobServiceClient_GetJobRunLogsStream_Call) RunAndReturn 

func (_c *MockJobServiceClient_GetJobRunLogsStream_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetJobRunLogsStreamRequest]) (*connect.ServerStreamForClient[mgmtv1alpha1.GetJobRunLogsStreamResponse], error)) *MockJobServiceClient_GetJobRunLogsStream_Call

type MockJobServiceClient_GetJobRun_Call 

type MockJobServiceClient_GetJobRun_Call struct {
	*mock.Call
}

MockJobServiceClient_GetJobRun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJobRun'

func (*MockJobServiceClient_GetJobRun_Call) Return 

func (_c *MockJobServiceClient_GetJobRun_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetJobRunResponse], _a1 error) *MockJobServiceClient_GetJobRun_Call

func (*MockJobServiceClient_GetJobRun_Call) Run 

func (_c *MockJobServiceClient_GetJobRun_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobRunRequest])) *MockJobServiceClient_GetJobRun_Call

func (*MockJobServiceClient_GetJobRun_Call) RunAndReturn 

func (_c *MockJobServiceClient_GetJobRun_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetJobRunRequest]) (*connect.Response[mgmtv1alpha1.GetJobRunResponse], error)) *MockJobServiceClient_GetJobRun_Call

type MockJobServiceClient_GetJobRuns_Call 

type MockJobServiceClient_GetJobRuns_Call struct {
	*mock.Call
}

MockJobServiceClient_GetJobRuns_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJobRuns'

func (*MockJobServiceClient_GetJobRuns_Call) Return 

func (_c *MockJobServiceClient_GetJobRuns_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetJobRunsResponse], _a1 error) *MockJobServiceClient_GetJobRuns_Call

func (*MockJobServiceClient_GetJobRuns_Call) Run 

func (_c *MockJobServiceClient_GetJobRuns_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobRunsRequest])) *MockJobServiceClient_GetJobRuns_Call

func (*MockJobServiceClient_GetJobRuns_Call) RunAndReturn 

func (_c *MockJobServiceClient_GetJobRuns_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetJobRunsRequest]) (*connect.Response[mgmtv1alpha1.GetJobRunsResponse], error)) *MockJobServiceClient_GetJobRuns_Call

type MockJobServiceClient_GetJobStatus_Call 

type MockJobServiceClient_GetJobStatus_Call struct {
	*mock.Call
}

MockJobServiceClient_GetJobStatus_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJobStatus'

func (*MockJobServiceClient_GetJobStatus_Call) Return 

func (_c *MockJobServiceClient_GetJobStatus_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetJobStatusResponse], _a1 error) *MockJobServiceClient_GetJobStatus_Call

func (*MockJobServiceClient_GetJobStatus_Call) Run 

func (_c *MockJobServiceClient_GetJobStatus_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobStatusRequest])) *MockJobServiceClient_GetJobStatus_Call

func (*MockJobServiceClient_GetJobStatus_Call) RunAndReturn 

func (_c *MockJobServiceClient_GetJobStatus_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetJobStatusRequest]) (*connect.Response[mgmtv1alpha1.GetJobStatusResponse], error)) *MockJobServiceClient_GetJobStatus_Call

type MockJobServiceClient_GetJobStatuses_Call 

type MockJobServiceClient_GetJobStatuses_Call struct {
	*mock.Call
}

MockJobServiceClient_GetJobStatuses_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJobStatuses'

func (*MockJobServiceClient_GetJobStatuses_Call) Return 

func (_c *MockJobServiceClient_GetJobStatuses_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetJobStatusesResponse], _a1 error) *MockJobServiceClient_GetJobStatuses_Call

func (*MockJobServiceClient_GetJobStatuses_Call) Run 

func (_c *MockJobServiceClient_GetJobStatuses_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobStatusesRequest])) *MockJobServiceClient_GetJobStatuses_Call

func (*MockJobServiceClient_GetJobStatuses_Call) RunAndReturn 

func (_c *MockJobServiceClient_GetJobStatuses_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetJobStatusesRequest]) (*connect.Response[mgmtv1alpha1.GetJobStatusesResponse], error)) *MockJobServiceClient_GetJobStatuses_Call

type MockJobServiceClient_GetJob_Call 

type MockJobServiceClient_GetJob_Call struct {
	*mock.Call
}

MockJobServiceClient_GetJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJob'

func (*MockJobServiceClient_GetJob_Call) Return 

func (_c *MockJobServiceClient_GetJob_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetJobResponse], _a1 error) *MockJobServiceClient_GetJob_Call

func (*MockJobServiceClient_GetJob_Call) Run 

func (_c *MockJobServiceClient_GetJob_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobRequest])) *MockJobServiceClient_GetJob_Call

func (*MockJobServiceClient_GetJob_Call) RunAndReturn 

func (_c *MockJobServiceClient_GetJob_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetJobRequest]) (*connect.Response[mgmtv1alpha1.GetJobResponse], error)) *MockJobServiceClient_GetJob_Call

type MockJobServiceClient_GetJobs_Call 

type MockJobServiceClient_GetJobs_Call struct {
	*mock.Call
}

MockJobServiceClient_GetJobs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJobs'

func (*MockJobServiceClient_GetJobs_Call) Return 

func (_c *MockJobServiceClient_GetJobs_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetJobsResponse], _a1 error) *MockJobServiceClient_GetJobs_Call

func (*MockJobServiceClient_GetJobs_Call) Run 

func (_c *MockJobServiceClient_GetJobs_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobsRequest])) *MockJobServiceClient_GetJobs_Call

func (*MockJobServiceClient_GetJobs_Call) RunAndReturn 

func (_c *MockJobServiceClient_GetJobs_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetJobsRequest]) (*connect.Response[mgmtv1alpha1.GetJobsResponse], error)) *MockJobServiceClient_GetJobs_Call

type MockJobServiceClient_IsJobNameAvailable_Call 

type MockJobServiceClient_IsJobNameAvailable_Call struct {
	*mock.Call
}

MockJobServiceClient_IsJobNameAvailable_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsJobNameAvailable'

func (*MockJobServiceClient_IsJobNameAvailable_Call) Return 

func (_c *MockJobServiceClient_IsJobNameAvailable_Call) Return(_a0 *connect.Response[mgmtv1alpha1.IsJobNameAvailableResponse], _a1 error) *MockJobServiceClient_IsJobNameAvailable_Call

func (*MockJobServiceClient_IsJobNameAvailable_Call) Run 

func (_c *MockJobServiceClient_IsJobNameAvailable_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.IsJobNameAvailableRequest])) *MockJobServiceClient_IsJobNameAvailable_Call

func (*MockJobServiceClient_IsJobNameAvailable_Call) RunAndReturn 

func (_c *MockJobServiceClient_IsJobNameAvailable_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.IsJobNameAvailableRequest]) (*connect.Response[mgmtv1alpha1.IsJobNameAvailableResponse], error)) *MockJobServiceClient_IsJobNameAvailable_Call

type MockJobServiceClient_PauseJob_Call 

type MockJobServiceClient_PauseJob_Call struct {
	*mock.Call
}

MockJobServiceClient_PauseJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PauseJob'

func (*MockJobServiceClient_PauseJob_Call) Return 

func (_c *MockJobServiceClient_PauseJob_Call) Return(_a0 *connect.Response[mgmtv1alpha1.PauseJobResponse], _a1 error) *MockJobServiceClient_PauseJob_Call

func (*MockJobServiceClient_PauseJob_Call) Run 

func (_c *MockJobServiceClient_PauseJob_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.PauseJobRequest])) *MockJobServiceClient_PauseJob_Call

func (*MockJobServiceClient_PauseJob_Call) RunAndReturn 

func (_c *MockJobServiceClient_PauseJob_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.PauseJobRequest]) (*connect.Response[mgmtv1alpha1.PauseJobResponse], error)) *MockJobServiceClient_PauseJob_Call

type MockJobServiceClient_SetJobSourceSqlConnectionSubsets_Call 

type MockJobServiceClient_SetJobSourceSqlConnectionSubsets_Call struct {
	*mock.Call
}

MockJobServiceClient_SetJobSourceSqlConnectionSubsets_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetJobSourceSqlConnectionSubsets'

func (*MockJobServiceClient_SetJobSourceSqlConnectionSubsets_Call) Return 

func (_c *MockJobServiceClient_SetJobSourceSqlConnectionSubsets_Call) Return(_a0 *connect.Response[mgmtv1alpha1.SetJobSourceSqlConnectionSubsetsResponse], _a1 error) *MockJobServiceClient_SetJobSourceSqlConnectionSubsets_Call

func (*MockJobServiceClient_SetJobSourceSqlConnectionSubsets_Call) Run 

func (_c *MockJobServiceClient_SetJobSourceSqlConnectionSubsets_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.SetJobSourceSqlConnectionSubsetsRequest])) *MockJobServiceClient_SetJobSourceSqlConnectionSubsets_Call

func (*MockJobServiceClient_SetJobSourceSqlConnectionSubsets_Call) RunAndReturn 

func (_c *MockJobServiceClient_SetJobSourceSqlConnectionSubsets_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.SetJobSourceSqlConnectionSubsetsRequest]) (*connect.Response[mgmtv1alpha1.SetJobSourceSqlConnectionSubsetsResponse], error)) *MockJobServiceClient_SetJobSourceSqlConnectionSubsets_Call

type MockJobServiceClient_SetJobSyncOptions_Call 

type MockJobServiceClient_SetJobSyncOptions_Call struct {
	*mock.Call
}

MockJobServiceClient_SetJobSyncOptions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetJobSyncOptions'

func (*MockJobServiceClient_SetJobSyncOptions_Call) Return 

func (_c *MockJobServiceClient_SetJobSyncOptions_Call) Return(_a0 *connect.Response[mgmtv1alpha1.SetJobSyncOptionsResponse], _a1 error) *MockJobServiceClient_SetJobSyncOptions_Call

func (*MockJobServiceClient_SetJobSyncOptions_Call) Run 

func (_c *MockJobServiceClient_SetJobSyncOptions_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.SetJobSyncOptionsRequest])) *MockJobServiceClient_SetJobSyncOptions_Call

func (*MockJobServiceClient_SetJobSyncOptions_Call) RunAndReturn 

func (_c *MockJobServiceClient_SetJobSyncOptions_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.SetJobSyncOptionsRequest]) (*connect.Response[mgmtv1alpha1.SetJobSyncOptionsResponse], error)) *MockJobServiceClient_SetJobSyncOptions_Call

type MockJobServiceClient_SetJobWorkflowOptions_Call 

type MockJobServiceClient_SetJobWorkflowOptions_Call struct {
	*mock.Call
}

MockJobServiceClient_SetJobWorkflowOptions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetJobWorkflowOptions'

func (*MockJobServiceClient_SetJobWorkflowOptions_Call) Return 

func (_c *MockJobServiceClient_SetJobWorkflowOptions_Call) Return(_a0 *connect.Response[mgmtv1alpha1.SetJobWorkflowOptionsResponse], _a1 error) *MockJobServiceClient_SetJobWorkflowOptions_Call

func (*MockJobServiceClient_SetJobWorkflowOptions_Call) Run 

func (_c *MockJobServiceClient_SetJobWorkflowOptions_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.SetJobWorkflowOptionsRequest])) *MockJobServiceClient_SetJobWorkflowOptions_Call

func (*MockJobServiceClient_SetJobWorkflowOptions_Call) RunAndReturn 

func (_c *MockJobServiceClient_SetJobWorkflowOptions_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.SetJobWorkflowOptionsRequest]) (*connect.Response[mgmtv1alpha1.SetJobWorkflowOptionsResponse], error)) *MockJobServiceClient_SetJobWorkflowOptions_Call

type MockJobServiceClient_TerminateJobRun_Call 

type MockJobServiceClient_TerminateJobRun_Call struct {
	*mock.Call
}

MockJobServiceClient_TerminateJobRun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TerminateJobRun'

func (*MockJobServiceClient_TerminateJobRun_Call) Return 

func (_c *MockJobServiceClient_TerminateJobRun_Call) Return(_a0 *connect.Response[mgmtv1alpha1.TerminateJobRunResponse], _a1 error) *MockJobServiceClient_TerminateJobRun_Call

func (*MockJobServiceClient_TerminateJobRun_Call) Run 

func (_c *MockJobServiceClient_TerminateJobRun_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.TerminateJobRunRequest])) *MockJobServiceClient_TerminateJobRun_Call

func (*MockJobServiceClient_TerminateJobRun_Call) RunAndReturn 

func (_c *MockJobServiceClient_TerminateJobRun_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.TerminateJobRunRequest]) (*connect.Response[mgmtv1alpha1.TerminateJobRunResponse], error)) *MockJobServiceClient_TerminateJobRun_Call

type MockJobServiceClient_UpdateJobDestinationConnection_Call 

type MockJobServiceClient_UpdateJobDestinationConnection_Call struct {
	*mock.Call
}

MockJobServiceClient_UpdateJobDestinationConnection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateJobDestinationConnection'

func (*MockJobServiceClient_UpdateJobDestinationConnection_Call) Return 

func (_c *MockJobServiceClient_UpdateJobDestinationConnection_Call) Return(_a0 *connect.Response[mgmtv1alpha1.UpdateJobDestinationConnectionResponse], _a1 error) *MockJobServiceClient_UpdateJobDestinationConnection_Call

func (*MockJobServiceClient_UpdateJobDestinationConnection_Call) Run 

func (_c *MockJobServiceClient_UpdateJobDestinationConnection_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.UpdateJobDestinationConnectionRequest])) *MockJobServiceClient_UpdateJobDestinationConnection_Call

func (*MockJobServiceClient_UpdateJobDestinationConnection_Call) RunAndReturn 

func (_c *MockJobServiceClient_UpdateJobDestinationConnection_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.UpdateJobDestinationConnectionRequest]) (*connect.Response[mgmtv1alpha1.UpdateJobDestinationConnectionResponse], error)) *MockJobServiceClient_UpdateJobDestinationConnection_Call

type MockJobServiceClient_UpdateJobSchedule_Call 

type MockJobServiceClient_UpdateJobSchedule_Call struct {
	*mock.Call
}

MockJobServiceClient_UpdateJobSchedule_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateJobSchedule'

func (*MockJobServiceClient_UpdateJobSchedule_Call) Return 

func (_c *MockJobServiceClient_UpdateJobSchedule_Call) Return(_a0 *connect.Response[mgmtv1alpha1.UpdateJobScheduleResponse], _a1 error) *MockJobServiceClient_UpdateJobSchedule_Call

func (*MockJobServiceClient_UpdateJobSchedule_Call) Run 

func (_c *MockJobServiceClient_UpdateJobSchedule_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.UpdateJobScheduleRequest])) *MockJobServiceClient_UpdateJobSchedule_Call

func (*MockJobServiceClient_UpdateJobSchedule_Call) RunAndReturn 

func (_c *MockJobServiceClient_UpdateJobSchedule_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.UpdateJobScheduleRequest]) (*connect.Response[mgmtv1alpha1.UpdateJobScheduleResponse], error)) *MockJobServiceClient_UpdateJobSchedule_Call

type MockJobServiceClient_UpdateJobSourceConnection_Call 

type MockJobServiceClient_UpdateJobSourceConnection_Call struct {
	*mock.Call
}

MockJobServiceClient_UpdateJobSourceConnection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateJobSourceConnection'

func (*MockJobServiceClient_UpdateJobSourceConnection_Call) Return 

func (_c *MockJobServiceClient_UpdateJobSourceConnection_Call) Return(_a0 *connect.Response[mgmtv1alpha1.UpdateJobSourceConnectionResponse], _a1 error) *MockJobServiceClient_UpdateJobSourceConnection_Call

func (*MockJobServiceClient_UpdateJobSourceConnection_Call) Run 

func (_c *MockJobServiceClient_UpdateJobSourceConnection_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.UpdateJobSourceConnectionRequest])) *MockJobServiceClient_UpdateJobSourceConnection_Call

func (*MockJobServiceClient_UpdateJobSourceConnection_Call) RunAndReturn 

func (_c *MockJobServiceClient_UpdateJobSourceConnection_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.UpdateJobSourceConnectionRequest]) (*connect.Response[mgmtv1alpha1.UpdateJobSourceConnectionResponse], error)) *MockJobServiceClient_UpdateJobSourceConnection_Call

type MockJobServiceClient_ValidateJobMappings_Call added in v0.4.24 

type MockJobServiceClient_ValidateJobMappings_Call struct {
	*mock.Call
}

MockJobServiceClient_ValidateJobMappings_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ValidateJobMappings'

func (*MockJobServiceClient_ValidateJobMappings_Call) Return added in v0.4.24 

func (_c *MockJobServiceClient_ValidateJobMappings_Call) Return(_a0 *connect.Response[mgmtv1alpha1.ValidateJobMappingsResponse], _a1 error) *MockJobServiceClient_ValidateJobMappings_Call

func (*MockJobServiceClient_ValidateJobMappings_Call) Run added in v0.4.24 

func (_c *MockJobServiceClient_ValidateJobMappings_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.ValidateJobMappingsRequest])) *MockJobServiceClient_ValidateJobMappings_Call

func (*MockJobServiceClient_ValidateJobMappings_Call) RunAndReturn added in v0.4.24 

func (_c *MockJobServiceClient_ValidateJobMappings_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.ValidateJobMappingsRequest]) (*connect.Response[mgmtv1alpha1.ValidateJobMappingsResponse], error)) *MockJobServiceClient_ValidateJobMappings_Call

type MockJobServiceHandler 

type MockJobServiceHandler struct {
	mock.Mock
}

MockJobServiceHandler is an autogenerated mock type for the JobServiceHandler type

func NewMockJobServiceHandler 

func NewMockJobServiceHandler(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockJobServiceHandler

NewMockJobServiceHandler creates a new instance of MockJobServiceHandler. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockJobServiceHandler) CancelJobRun 

func (_m *MockJobServiceHandler) CancelJobRun(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CancelJobRunRequest]) (*connect.Response[mgmtv1alpha1.CancelJobRunResponse], error)

CancelJobRun provides a mock function with given fields: _a0, _a1

func (*MockJobServiceHandler) CreateJob 

func (_m *MockJobServiceHandler) CreateJob(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CreateJobRequest]) (*connect.Response[mgmtv1alpha1.CreateJobResponse], error)

CreateJob provides a mock function with given fields: _a0, _a1

func (*MockJobServiceHandler) CreateJobDestinationConnections 

func (_m *MockJobServiceHandler) CreateJobDestinationConnections(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CreateJobDestinationConnectionsRequest]) (*connect.Response[mgmtv1alpha1.CreateJobDestinationConnectionsResponse], error)

CreateJobDestinationConnections provides a mock function with given fields: _a0, _a1

func (*MockJobServiceHandler) CreateJobRun 

func (_m *MockJobServiceHandler) CreateJobRun(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CreateJobRunRequest]) (*connect.Response[mgmtv1alpha1.CreateJobRunResponse], error)

CreateJobRun provides a mock function with given fields: _a0, _a1

func (*MockJobServiceHandler) DeleteJob 

func (_m *MockJobServiceHandler) DeleteJob(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.DeleteJobRequest]) (*connect.Response[mgmtv1alpha1.DeleteJobResponse], error)

DeleteJob provides a mock function with given fields: _a0, _a1

func (*MockJobServiceHandler) DeleteJobDestinationConnection 

func (_m *MockJobServiceHandler) DeleteJobDestinationConnection(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.DeleteJobDestinationConnectionRequest]) (*connect.Response[mgmtv1alpha1.DeleteJobDestinationConnectionResponse], error)

DeleteJobDestinationConnection provides a mock function with given fields: _a0, _a1

func (*MockJobServiceHandler) DeleteJobRun 

func (_m *MockJobServiceHandler) DeleteJobRun(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.DeleteJobRunRequest]) (*connect.Response[mgmtv1alpha1.DeleteJobRunResponse], error)

DeleteJobRun provides a mock function with given fields: _a0, _a1

func (*MockJobServiceHandler) EXPECT 

func (_m *MockJobServiceHandler) EXPECT() *MockJobServiceHandler_Expecter

func (*MockJobServiceHandler) GetJob 

func (_m *MockJobServiceHandler) GetJob(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobRequest]) (*connect.Response[mgmtv1alpha1.GetJobResponse], error)

GetJob provides a mock function with given fields: _a0, _a1

func (*MockJobServiceHandler) GetJobNextRuns 

func (_m *MockJobServiceHandler) GetJobNextRuns(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobNextRunsRequest]) (*connect.Response[mgmtv1alpha1.GetJobNextRunsResponse], error)

GetJobNextRuns provides a mock function with given fields: _a0, _a1

func (*MockJobServiceHandler) GetJobRecentRuns 

func (_m *MockJobServiceHandler) GetJobRecentRuns(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobRecentRunsRequest]) (*connect.Response[mgmtv1alpha1.GetJobRecentRunsResponse], error)

GetJobRecentRuns provides a mock function with given fields: _a0, _a1

func (*MockJobServiceHandler) GetJobRun 

func (_m *MockJobServiceHandler) GetJobRun(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobRunRequest]) (*connect.Response[mgmtv1alpha1.GetJobRunResponse], error)

GetJobRun provides a mock function with given fields: _a0, _a1

func (*MockJobServiceHandler) GetJobRunEvents 

func (_m *MockJobServiceHandler) GetJobRunEvents(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobRunEventsRequest]) (*connect.Response[mgmtv1alpha1.GetJobRunEventsResponse], error)

GetJobRunEvents provides a mock function with given fields: _a0, _a1

func (*MockJobServiceHandler) GetJobRunLogsStream 

func (_m *MockJobServiceHandler) GetJobRunLogsStream(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobRunLogsStreamRequest], _a2 *connect.ServerStream[mgmtv1alpha1.GetJobRunLogsStreamResponse]) error

GetJobRunLogsStream provides a mock function with given fields: _a0, _a1, _a2

func (*MockJobServiceHandler) GetJobRuns 

func (_m *MockJobServiceHandler) GetJobRuns(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobRunsRequest]) (*connect.Response[mgmtv1alpha1.GetJobRunsResponse], error)

GetJobRuns provides a mock function with given fields: _a0, _a1

func (*MockJobServiceHandler) GetJobStatus 

func (_m *MockJobServiceHandler) GetJobStatus(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobStatusRequest]) (*connect.Response[mgmtv1alpha1.GetJobStatusResponse], error)

GetJobStatus provides a mock function with given fields: _a0, _a1

func (*MockJobServiceHandler) GetJobStatuses 

func (_m *MockJobServiceHandler) GetJobStatuses(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobStatusesRequest]) (*connect.Response[mgmtv1alpha1.GetJobStatusesResponse], error)

GetJobStatuses provides a mock function with given fields: _a0, _a1

func (*MockJobServiceHandler) GetJobs 

func (_m *MockJobServiceHandler) GetJobs(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobsRequest]) (*connect.Response[mgmtv1alpha1.GetJobsResponse], error)

GetJobs provides a mock function with given fields: _a0, _a1

func (*MockJobServiceHandler) IsJobNameAvailable 

func (_m *MockJobServiceHandler) IsJobNameAvailable(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.IsJobNameAvailableRequest]) (*connect.Response[mgmtv1alpha1.IsJobNameAvailableResponse], error)

IsJobNameAvailable provides a mock function with given fields: _a0, _a1

func (*MockJobServiceHandler) PauseJob 

func (_m *MockJobServiceHandler) PauseJob(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.PauseJobRequest]) (*connect.Response[mgmtv1alpha1.PauseJobResponse], error)

PauseJob provides a mock function with given fields: _a0, _a1

func (*MockJobServiceHandler) SetJobSourceSqlConnectionSubsets 

func (_m *MockJobServiceHandler) SetJobSourceSqlConnectionSubsets(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.SetJobSourceSqlConnectionSubsetsRequest]) (*connect.Response[mgmtv1alpha1.SetJobSourceSqlConnectionSubsetsResponse], error)

SetJobSourceSqlConnectionSubsets provides a mock function with given fields: _a0, _a1

func (*MockJobServiceHandler) SetJobSyncOptions 

func (_m *MockJobServiceHandler) SetJobSyncOptions(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.SetJobSyncOptionsRequest]) (*connect.Response[mgmtv1alpha1.SetJobSyncOptionsResponse], error)

SetJobSyncOptions provides a mock function with given fields: _a0, _a1

func (*MockJobServiceHandler) SetJobWorkflowOptions 

func (_m *MockJobServiceHandler) SetJobWorkflowOptions(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.SetJobWorkflowOptionsRequest]) (*connect.Response[mgmtv1alpha1.SetJobWorkflowOptionsResponse], error)

SetJobWorkflowOptions provides a mock function with given fields: _a0, _a1

func (*MockJobServiceHandler) TerminateJobRun 

func (_m *MockJobServiceHandler) TerminateJobRun(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.TerminateJobRunRequest]) (*connect.Response[mgmtv1alpha1.TerminateJobRunResponse], error)

TerminateJobRun provides a mock function with given fields: _a0, _a1

func (*MockJobServiceHandler) UpdateJobDestinationConnection 

func (_m *MockJobServiceHandler) UpdateJobDestinationConnection(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.UpdateJobDestinationConnectionRequest]) (*connect.Response[mgmtv1alpha1.UpdateJobDestinationConnectionResponse], error)

UpdateJobDestinationConnection provides a mock function with given fields: _a0, _a1

func (*MockJobServiceHandler) UpdateJobSchedule 

func (_m *MockJobServiceHandler) UpdateJobSchedule(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.UpdateJobScheduleRequest]) (*connect.Response[mgmtv1alpha1.UpdateJobScheduleResponse], error)

UpdateJobSchedule provides a mock function with given fields: _a0, _a1

func (*MockJobServiceHandler) UpdateJobSourceConnection 

func (_m *MockJobServiceHandler) UpdateJobSourceConnection(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.UpdateJobSourceConnectionRequest]) (*connect.Response[mgmtv1alpha1.UpdateJobSourceConnectionResponse], error)

UpdateJobSourceConnection provides a mock function with given fields: _a0, _a1

func (*MockJobServiceHandler) ValidateJobMappings added in v0.4.24 

func (_m *MockJobServiceHandler) ValidateJobMappings(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.ValidateJobMappingsRequest]) (*connect.Response[mgmtv1alpha1.ValidateJobMappingsResponse], error)

ValidateJobMappings provides a mock function with given fields: _a0, _a1

type MockJobServiceHandler_CancelJobRun_Call 

type MockJobServiceHandler_CancelJobRun_Call struct {
	*mock.Call
}

MockJobServiceHandler_CancelJobRun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CancelJobRun'

func (*MockJobServiceHandler_CancelJobRun_Call) Return 

func (_c *MockJobServiceHandler_CancelJobRun_Call) Return(_a0 *connect.Response[mgmtv1alpha1.CancelJobRunResponse], _a1 error) *MockJobServiceHandler_CancelJobRun_Call

func (*MockJobServiceHandler_CancelJobRun_Call) Run 

func (_c *MockJobServiceHandler_CancelJobRun_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CancelJobRunRequest])) *MockJobServiceHandler_CancelJobRun_Call

func (*MockJobServiceHandler_CancelJobRun_Call) RunAndReturn 

func (_c *MockJobServiceHandler_CancelJobRun_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.CancelJobRunRequest]) (*connect.Response[mgmtv1alpha1.CancelJobRunResponse], error)) *MockJobServiceHandler_CancelJobRun_Call

type MockJobServiceHandler_CreateJobDestinationConnections_Call 

type MockJobServiceHandler_CreateJobDestinationConnections_Call struct {
	*mock.Call
}

MockJobServiceHandler_CreateJobDestinationConnections_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateJobDestinationConnections'

func (*MockJobServiceHandler_CreateJobDestinationConnections_Call) Return 

func (_c *MockJobServiceHandler_CreateJobDestinationConnections_Call) Return(_a0 *connect.Response[mgmtv1alpha1.CreateJobDestinationConnectionsResponse], _a1 error) *MockJobServiceHandler_CreateJobDestinationConnections_Call

func (*MockJobServiceHandler_CreateJobDestinationConnections_Call) Run 

func (_c *MockJobServiceHandler_CreateJobDestinationConnections_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CreateJobDestinationConnectionsRequest])) *MockJobServiceHandler_CreateJobDestinationConnections_Call

func (*MockJobServiceHandler_CreateJobDestinationConnections_Call) RunAndReturn 

func (_c *MockJobServiceHandler_CreateJobDestinationConnections_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.CreateJobDestinationConnectionsRequest]) (*connect.Response[mgmtv1alpha1.CreateJobDestinationConnectionsResponse], error)) *MockJobServiceHandler_CreateJobDestinationConnections_Call

type MockJobServiceHandler_CreateJobRun_Call 

type MockJobServiceHandler_CreateJobRun_Call struct {
	*mock.Call
}

MockJobServiceHandler_CreateJobRun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateJobRun'

func (*MockJobServiceHandler_CreateJobRun_Call) Return 

func (_c *MockJobServiceHandler_CreateJobRun_Call) Return(_a0 *connect.Response[mgmtv1alpha1.CreateJobRunResponse], _a1 error) *MockJobServiceHandler_CreateJobRun_Call

func (*MockJobServiceHandler_CreateJobRun_Call) Run 

func (_c *MockJobServiceHandler_CreateJobRun_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CreateJobRunRequest])) *MockJobServiceHandler_CreateJobRun_Call

func (*MockJobServiceHandler_CreateJobRun_Call) RunAndReturn 

func (_c *MockJobServiceHandler_CreateJobRun_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.CreateJobRunRequest]) (*connect.Response[mgmtv1alpha1.CreateJobRunResponse], error)) *MockJobServiceHandler_CreateJobRun_Call

type MockJobServiceHandler_CreateJob_Call 

type MockJobServiceHandler_CreateJob_Call struct {
	*mock.Call
}

MockJobServiceHandler_CreateJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateJob'

func (*MockJobServiceHandler_CreateJob_Call) Return 

func (_c *MockJobServiceHandler_CreateJob_Call) Return(_a0 *connect.Response[mgmtv1alpha1.CreateJobResponse], _a1 error) *MockJobServiceHandler_CreateJob_Call

func (*MockJobServiceHandler_CreateJob_Call) Run 

func (_c *MockJobServiceHandler_CreateJob_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CreateJobRequest])) *MockJobServiceHandler_CreateJob_Call

func (*MockJobServiceHandler_CreateJob_Call) RunAndReturn 

func (_c *MockJobServiceHandler_CreateJob_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.CreateJobRequest]) (*connect.Response[mgmtv1alpha1.CreateJobResponse], error)) *MockJobServiceHandler_CreateJob_Call

type MockJobServiceHandler_DeleteJobDestinationConnection_Call 

type MockJobServiceHandler_DeleteJobDestinationConnection_Call struct {
	*mock.Call
}

MockJobServiceHandler_DeleteJobDestinationConnection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteJobDestinationConnection'

func (*MockJobServiceHandler_DeleteJobDestinationConnection_Call) Return 

func (_c *MockJobServiceHandler_DeleteJobDestinationConnection_Call) Return(_a0 *connect.Response[mgmtv1alpha1.DeleteJobDestinationConnectionResponse], _a1 error) *MockJobServiceHandler_DeleteJobDestinationConnection_Call

func (*MockJobServiceHandler_DeleteJobDestinationConnection_Call) Run 

func (_c *MockJobServiceHandler_DeleteJobDestinationConnection_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.DeleteJobDestinationConnectionRequest])) *MockJobServiceHandler_DeleteJobDestinationConnection_Call

func (*MockJobServiceHandler_DeleteJobDestinationConnection_Call) RunAndReturn 

func (_c *MockJobServiceHandler_DeleteJobDestinationConnection_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.DeleteJobDestinationConnectionRequest]) (*connect.Response[mgmtv1alpha1.DeleteJobDestinationConnectionResponse], error)) *MockJobServiceHandler_DeleteJobDestinationConnection_Call

type MockJobServiceHandler_DeleteJobRun_Call 

type MockJobServiceHandler_DeleteJobRun_Call struct {
	*mock.Call
}

MockJobServiceHandler_DeleteJobRun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteJobRun'

func (*MockJobServiceHandler_DeleteJobRun_Call) Return 

func (_c *MockJobServiceHandler_DeleteJobRun_Call) Return(_a0 *connect.Response[mgmtv1alpha1.DeleteJobRunResponse], _a1 error) *MockJobServiceHandler_DeleteJobRun_Call

func (*MockJobServiceHandler_DeleteJobRun_Call) Run 

func (_c *MockJobServiceHandler_DeleteJobRun_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.DeleteJobRunRequest])) *MockJobServiceHandler_DeleteJobRun_Call

func (*MockJobServiceHandler_DeleteJobRun_Call) RunAndReturn 

func (_c *MockJobServiceHandler_DeleteJobRun_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.DeleteJobRunRequest]) (*connect.Response[mgmtv1alpha1.DeleteJobRunResponse], error)) *MockJobServiceHandler_DeleteJobRun_Call

type MockJobServiceHandler_DeleteJob_Call 

type MockJobServiceHandler_DeleteJob_Call struct {
	*mock.Call
}

MockJobServiceHandler_DeleteJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteJob'

func (*MockJobServiceHandler_DeleteJob_Call) Return 

func (_c *MockJobServiceHandler_DeleteJob_Call) Return(_a0 *connect.Response[mgmtv1alpha1.DeleteJobResponse], _a1 error) *MockJobServiceHandler_DeleteJob_Call

func (*MockJobServiceHandler_DeleteJob_Call) Run 

func (_c *MockJobServiceHandler_DeleteJob_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.DeleteJobRequest])) *MockJobServiceHandler_DeleteJob_Call

func (*MockJobServiceHandler_DeleteJob_Call) RunAndReturn 

func (_c *MockJobServiceHandler_DeleteJob_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.DeleteJobRequest]) (*connect.Response[mgmtv1alpha1.DeleteJobResponse], error)) *MockJobServiceHandler_DeleteJob_Call

type MockJobServiceHandler_Expecter 

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

func (*MockJobServiceHandler_Expecter) CancelJobRun 

func (_e *MockJobServiceHandler_Expecter) CancelJobRun(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_CancelJobRun_Call

CancelJobRun is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.CancelJobRunRequest]

func (*MockJobServiceHandler_Expecter) CreateJob 

func (_e *MockJobServiceHandler_Expecter) CreateJob(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_CreateJob_Call

CreateJob is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.CreateJobRequest]

func (*MockJobServiceHandler_Expecter) CreateJobDestinationConnections 

func (_e *MockJobServiceHandler_Expecter) CreateJobDestinationConnections(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_CreateJobDestinationConnections_Call

CreateJobDestinationConnections is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.CreateJobDestinationConnectionsRequest]

func (*MockJobServiceHandler_Expecter) CreateJobRun 

func (_e *MockJobServiceHandler_Expecter) CreateJobRun(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_CreateJobRun_Call

CreateJobRun is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.CreateJobRunRequest]

func (*MockJobServiceHandler_Expecter) DeleteJob 

func (_e *MockJobServiceHandler_Expecter) DeleteJob(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_DeleteJob_Call

DeleteJob is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.DeleteJobRequest]

func (*MockJobServiceHandler_Expecter) DeleteJobDestinationConnection 

func (_e *MockJobServiceHandler_Expecter) DeleteJobDestinationConnection(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_DeleteJobDestinationConnection_Call

DeleteJobDestinationConnection is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.DeleteJobDestinationConnectionRequest]

func (*MockJobServiceHandler_Expecter) DeleteJobRun 

func (_e *MockJobServiceHandler_Expecter) DeleteJobRun(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_DeleteJobRun_Call

DeleteJobRun is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.DeleteJobRunRequest]

func (*MockJobServiceHandler_Expecter) GetJob 

func (_e *MockJobServiceHandler_Expecter) GetJob(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_GetJob_Call

GetJob is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetJobRequest]

func (*MockJobServiceHandler_Expecter) GetJobNextRuns 

func (_e *MockJobServiceHandler_Expecter) GetJobNextRuns(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_GetJobNextRuns_Call

GetJobNextRuns is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetJobNextRunsRequest]

func (*MockJobServiceHandler_Expecter) GetJobRecentRuns 

func (_e *MockJobServiceHandler_Expecter) GetJobRecentRuns(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_GetJobRecentRuns_Call

GetJobRecentRuns is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetJobRecentRunsRequest]

func (*MockJobServiceHandler_Expecter) GetJobRun 

func (_e *MockJobServiceHandler_Expecter) GetJobRun(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_GetJobRun_Call

GetJobRun is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetJobRunRequest]

func (*MockJobServiceHandler_Expecter) GetJobRunEvents 

func (_e *MockJobServiceHandler_Expecter) GetJobRunEvents(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_GetJobRunEvents_Call

GetJobRunEvents is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetJobRunEventsRequest]

func (*MockJobServiceHandler_Expecter) GetJobRunLogsStream 

func (_e *MockJobServiceHandler_Expecter) GetJobRunLogsStream(_a0 interface{}, _a1 interface{}, _a2 interface{}) *MockJobServiceHandler_GetJobRunLogsStream_Call

GetJobRunLogsStream is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetJobRunLogsStreamRequest]
  • _a2 *connect.ServerStream[mgmtv1alpha1.GetJobRunLogsStreamResponse]

func (*MockJobServiceHandler_Expecter) GetJobRuns 

func (_e *MockJobServiceHandler_Expecter) GetJobRuns(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_GetJobRuns_Call

GetJobRuns is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetJobRunsRequest]

func (*MockJobServiceHandler_Expecter) GetJobStatus 

func (_e *MockJobServiceHandler_Expecter) GetJobStatus(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_GetJobStatus_Call

GetJobStatus is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetJobStatusRequest]

func (*MockJobServiceHandler_Expecter) GetJobStatuses 

func (_e *MockJobServiceHandler_Expecter) GetJobStatuses(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_GetJobStatuses_Call

GetJobStatuses is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetJobStatusesRequest]

func (*MockJobServiceHandler_Expecter) GetJobs 

func (_e *MockJobServiceHandler_Expecter) GetJobs(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_GetJobs_Call

GetJobs is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetJobsRequest]

func (*MockJobServiceHandler_Expecter) IsJobNameAvailable 

func (_e *MockJobServiceHandler_Expecter) IsJobNameAvailable(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_IsJobNameAvailable_Call

IsJobNameAvailable is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.IsJobNameAvailableRequest]

func (*MockJobServiceHandler_Expecter) PauseJob 

func (_e *MockJobServiceHandler_Expecter) PauseJob(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_PauseJob_Call

PauseJob is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.PauseJobRequest]

func (*MockJobServiceHandler_Expecter) SetJobSourceSqlConnectionSubsets 

func (_e *MockJobServiceHandler_Expecter) SetJobSourceSqlConnectionSubsets(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_SetJobSourceSqlConnectionSubsets_Call

SetJobSourceSqlConnectionSubsets is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.SetJobSourceSqlConnectionSubsetsRequest]

func (*MockJobServiceHandler_Expecter) SetJobSyncOptions 

func (_e *MockJobServiceHandler_Expecter) SetJobSyncOptions(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_SetJobSyncOptions_Call

SetJobSyncOptions is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.SetJobSyncOptionsRequest]

func (*MockJobServiceHandler_Expecter) SetJobWorkflowOptions 

func (_e *MockJobServiceHandler_Expecter) SetJobWorkflowOptions(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_SetJobWorkflowOptions_Call

SetJobWorkflowOptions is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.SetJobWorkflowOptionsRequest]

func (*MockJobServiceHandler_Expecter) TerminateJobRun 

func (_e *MockJobServiceHandler_Expecter) TerminateJobRun(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_TerminateJobRun_Call

TerminateJobRun is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.TerminateJobRunRequest]

func (*MockJobServiceHandler_Expecter) UpdateJobDestinationConnection 

func (_e *MockJobServiceHandler_Expecter) UpdateJobDestinationConnection(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_UpdateJobDestinationConnection_Call

UpdateJobDestinationConnection is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.UpdateJobDestinationConnectionRequest]

func (*MockJobServiceHandler_Expecter) UpdateJobSchedule 

func (_e *MockJobServiceHandler_Expecter) UpdateJobSchedule(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_UpdateJobSchedule_Call

UpdateJobSchedule is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.UpdateJobScheduleRequest]

func (*MockJobServiceHandler_Expecter) UpdateJobSourceConnection 

func (_e *MockJobServiceHandler_Expecter) UpdateJobSourceConnection(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_UpdateJobSourceConnection_Call

UpdateJobSourceConnection is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.UpdateJobSourceConnectionRequest]

func (*MockJobServiceHandler_Expecter) ValidateJobMappings added in v0.4.24 

func (_e *MockJobServiceHandler_Expecter) ValidateJobMappings(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_ValidateJobMappings_Call

ValidateJobMappings is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.ValidateJobMappingsRequest]

type MockJobServiceHandler_GetJobNextRuns_Call 

type MockJobServiceHandler_GetJobNextRuns_Call struct {
	*mock.Call
}

MockJobServiceHandler_GetJobNextRuns_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJobNextRuns'

func (*MockJobServiceHandler_GetJobNextRuns_Call) Return 

func (_c *MockJobServiceHandler_GetJobNextRuns_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetJobNextRunsResponse], _a1 error) *MockJobServiceHandler_GetJobNextRuns_Call

func (*MockJobServiceHandler_GetJobNextRuns_Call) Run 

func (_c *MockJobServiceHandler_GetJobNextRuns_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobNextRunsRequest])) *MockJobServiceHandler_GetJobNextRuns_Call

func (*MockJobServiceHandler_GetJobNextRuns_Call) RunAndReturn 

func (_c *MockJobServiceHandler_GetJobNextRuns_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetJobNextRunsRequest]) (*connect.Response[mgmtv1alpha1.GetJobNextRunsResponse], error)) *MockJobServiceHandler_GetJobNextRuns_Call

type MockJobServiceHandler_GetJobRecentRuns_Call 

type MockJobServiceHandler_GetJobRecentRuns_Call struct {
	*mock.Call
}

MockJobServiceHandler_GetJobRecentRuns_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJobRecentRuns'

func (*MockJobServiceHandler_GetJobRecentRuns_Call) Return 

func (_c *MockJobServiceHandler_GetJobRecentRuns_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetJobRecentRunsResponse], _a1 error) *MockJobServiceHandler_GetJobRecentRuns_Call

func (*MockJobServiceHandler_GetJobRecentRuns_Call) Run 

func (_c *MockJobServiceHandler_GetJobRecentRuns_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobRecentRunsRequest])) *MockJobServiceHandler_GetJobRecentRuns_Call

func (*MockJobServiceHandler_GetJobRecentRuns_Call) RunAndReturn 

func (_c *MockJobServiceHandler_GetJobRecentRuns_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetJobRecentRunsRequest]) (*connect.Response[mgmtv1alpha1.GetJobRecentRunsResponse], error)) *MockJobServiceHandler_GetJobRecentRuns_Call

type MockJobServiceHandler_GetJobRunEvents_Call 

type MockJobServiceHandler_GetJobRunEvents_Call struct {
	*mock.Call
}

MockJobServiceHandler_GetJobRunEvents_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJobRunEvents'

func (*MockJobServiceHandler_GetJobRunEvents_Call) Return 

func (_c *MockJobServiceHandler_GetJobRunEvents_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetJobRunEventsResponse], _a1 error) *MockJobServiceHandler_GetJobRunEvents_Call

func (*MockJobServiceHandler_GetJobRunEvents_Call) Run 

func (_c *MockJobServiceHandler_GetJobRunEvents_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobRunEventsRequest])) *MockJobServiceHandler_GetJobRunEvents_Call

func (*MockJobServiceHandler_GetJobRunEvents_Call) RunAndReturn 

func (_c *MockJobServiceHandler_GetJobRunEvents_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetJobRunEventsRequest]) (*connect.Response[mgmtv1alpha1.GetJobRunEventsResponse], error)) *MockJobServiceHandler_GetJobRunEvents_Call

type MockJobServiceHandler_GetJobRunLogsStream_Call 

type MockJobServiceHandler_GetJobRunLogsStream_Call struct {
	*mock.Call
}

MockJobServiceHandler_GetJobRunLogsStream_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJobRunLogsStream'

func (*MockJobServiceHandler_GetJobRunLogsStream_Call) Return 

func (_c *MockJobServiceHandler_GetJobRunLogsStream_Call) Return(_a0 error) *MockJobServiceHandler_GetJobRunLogsStream_Call

func (*MockJobServiceHandler_GetJobRunLogsStream_Call) Run 

func (_c *MockJobServiceHandler_GetJobRunLogsStream_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobRunLogsStreamRequest], _a2 *connect.ServerStream[mgmtv1alpha1.GetJobRunLogsStreamResponse])) *MockJobServiceHandler_GetJobRunLogsStream_Call

func (*MockJobServiceHandler_GetJobRunLogsStream_Call) RunAndReturn 

func (_c *MockJobServiceHandler_GetJobRunLogsStream_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetJobRunLogsStreamRequest], *connect.ServerStream[mgmtv1alpha1.GetJobRunLogsStreamResponse]) error) *MockJobServiceHandler_GetJobRunLogsStream_Call

type MockJobServiceHandler_GetJobRun_Call 

type MockJobServiceHandler_GetJobRun_Call struct {
	*mock.Call
}

MockJobServiceHandler_GetJobRun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJobRun'

func (*MockJobServiceHandler_GetJobRun_Call) Return 

func (_c *MockJobServiceHandler_GetJobRun_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetJobRunResponse], _a1 error) *MockJobServiceHandler_GetJobRun_Call

func (*MockJobServiceHandler_GetJobRun_Call) Run 

func (_c *MockJobServiceHandler_GetJobRun_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobRunRequest])) *MockJobServiceHandler_GetJobRun_Call

func (*MockJobServiceHandler_GetJobRun_Call) RunAndReturn 

func (_c *MockJobServiceHandler_GetJobRun_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetJobRunRequest]) (*connect.Response[mgmtv1alpha1.GetJobRunResponse], error)) *MockJobServiceHandler_GetJobRun_Call

type MockJobServiceHandler_GetJobRuns_Call 

type MockJobServiceHandler_GetJobRuns_Call struct {
	*mock.Call
}

MockJobServiceHandler_GetJobRuns_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJobRuns'

func (*MockJobServiceHandler_GetJobRuns_Call) Return 

func (_c *MockJobServiceHandler_GetJobRuns_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetJobRunsResponse], _a1 error) *MockJobServiceHandler_GetJobRuns_Call

func (*MockJobServiceHandler_GetJobRuns_Call) Run 

func (_c *MockJobServiceHandler_GetJobRuns_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobRunsRequest])) *MockJobServiceHandler_GetJobRuns_Call

func (*MockJobServiceHandler_GetJobRuns_Call) RunAndReturn 

func (_c *MockJobServiceHandler_GetJobRuns_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetJobRunsRequest]) (*connect.Response[mgmtv1alpha1.GetJobRunsResponse], error)) *MockJobServiceHandler_GetJobRuns_Call

type MockJobServiceHandler_GetJobStatus_Call 

type MockJobServiceHandler_GetJobStatus_Call struct {
	*mock.Call
}

MockJobServiceHandler_GetJobStatus_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJobStatus'

func (*MockJobServiceHandler_GetJobStatus_Call) Return 

func (_c *MockJobServiceHandler_GetJobStatus_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetJobStatusResponse], _a1 error) *MockJobServiceHandler_GetJobStatus_Call

func (*MockJobServiceHandler_GetJobStatus_Call) Run 

func (_c *MockJobServiceHandler_GetJobStatus_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobStatusRequest])) *MockJobServiceHandler_GetJobStatus_Call

func (*MockJobServiceHandler_GetJobStatus_Call) RunAndReturn 

func (_c *MockJobServiceHandler_GetJobStatus_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetJobStatusRequest]) (*connect.Response[mgmtv1alpha1.GetJobStatusResponse], error)) *MockJobServiceHandler_GetJobStatus_Call

type MockJobServiceHandler_GetJobStatuses_Call 

type MockJobServiceHandler_GetJobStatuses_Call struct {
	*mock.Call
}

MockJobServiceHandler_GetJobStatuses_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJobStatuses'

func (*MockJobServiceHandler_GetJobStatuses_Call) Return 

func (_c *MockJobServiceHandler_GetJobStatuses_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetJobStatusesResponse], _a1 error) *MockJobServiceHandler_GetJobStatuses_Call

func (*MockJobServiceHandler_GetJobStatuses_Call) Run 

func (_c *MockJobServiceHandler_GetJobStatuses_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobStatusesRequest])) *MockJobServiceHandler_GetJobStatuses_Call

func (*MockJobServiceHandler_GetJobStatuses_Call) RunAndReturn 

func (_c *MockJobServiceHandler_GetJobStatuses_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetJobStatusesRequest]) (*connect.Response[mgmtv1alpha1.GetJobStatusesResponse], error)) *MockJobServiceHandler_GetJobStatuses_Call

type MockJobServiceHandler_GetJob_Call 

type MockJobServiceHandler_GetJob_Call struct {
	*mock.Call
}

MockJobServiceHandler_GetJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJob'

func (*MockJobServiceHandler_GetJob_Call) Return 

func (_c *MockJobServiceHandler_GetJob_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetJobResponse], _a1 error) *MockJobServiceHandler_GetJob_Call

func (*MockJobServiceHandler_GetJob_Call) Run 

func (_c *MockJobServiceHandler_GetJob_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobRequest])) *MockJobServiceHandler_GetJob_Call

func (*MockJobServiceHandler_GetJob_Call) RunAndReturn 

func (_c *MockJobServiceHandler_GetJob_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetJobRequest]) (*connect.Response[mgmtv1alpha1.GetJobResponse], error)) *MockJobServiceHandler_GetJob_Call

type MockJobServiceHandler_GetJobs_Call 

type MockJobServiceHandler_GetJobs_Call struct {
	*mock.Call
}

MockJobServiceHandler_GetJobs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetJobs'

func (*MockJobServiceHandler_GetJobs_Call) Return 

func (_c *MockJobServiceHandler_GetJobs_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetJobsResponse], _a1 error) *MockJobServiceHandler_GetJobs_Call

func (*MockJobServiceHandler_GetJobs_Call) Run 

func (_c *MockJobServiceHandler_GetJobs_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetJobsRequest])) *MockJobServiceHandler_GetJobs_Call

func (*MockJobServiceHandler_GetJobs_Call) RunAndReturn 

func (_c *MockJobServiceHandler_GetJobs_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetJobsRequest]) (*connect.Response[mgmtv1alpha1.GetJobsResponse], error)) *MockJobServiceHandler_GetJobs_Call

type MockJobServiceHandler_IsJobNameAvailable_Call 

type MockJobServiceHandler_IsJobNameAvailable_Call struct {
	*mock.Call
}

MockJobServiceHandler_IsJobNameAvailable_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsJobNameAvailable'

func (*MockJobServiceHandler_IsJobNameAvailable_Call) Return 

func (_c *MockJobServiceHandler_IsJobNameAvailable_Call) Return(_a0 *connect.Response[mgmtv1alpha1.IsJobNameAvailableResponse], _a1 error) *MockJobServiceHandler_IsJobNameAvailable_Call

func (*MockJobServiceHandler_IsJobNameAvailable_Call) Run 

func (_c *MockJobServiceHandler_IsJobNameAvailable_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.IsJobNameAvailableRequest])) *MockJobServiceHandler_IsJobNameAvailable_Call

func (*MockJobServiceHandler_IsJobNameAvailable_Call) RunAndReturn 

func (_c *MockJobServiceHandler_IsJobNameAvailable_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.IsJobNameAvailableRequest]) (*connect.Response[mgmtv1alpha1.IsJobNameAvailableResponse], error)) *MockJobServiceHandler_IsJobNameAvailable_Call

type MockJobServiceHandler_PauseJob_Call 

type MockJobServiceHandler_PauseJob_Call struct {
	*mock.Call
}

MockJobServiceHandler_PauseJob_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'PauseJob'

func (*MockJobServiceHandler_PauseJob_Call) Return 

func (_c *MockJobServiceHandler_PauseJob_Call) Return(_a0 *connect.Response[mgmtv1alpha1.PauseJobResponse], _a1 error) *MockJobServiceHandler_PauseJob_Call

func (*MockJobServiceHandler_PauseJob_Call) Run 

func (_c *MockJobServiceHandler_PauseJob_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.PauseJobRequest])) *MockJobServiceHandler_PauseJob_Call

func (*MockJobServiceHandler_PauseJob_Call) RunAndReturn 

func (_c *MockJobServiceHandler_PauseJob_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.PauseJobRequest]) (*connect.Response[mgmtv1alpha1.PauseJobResponse], error)) *MockJobServiceHandler_PauseJob_Call

type MockJobServiceHandler_SetJobSourceSqlConnectionSubsets_Call 

type MockJobServiceHandler_SetJobSourceSqlConnectionSubsets_Call struct {
	*mock.Call
}

MockJobServiceHandler_SetJobSourceSqlConnectionSubsets_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetJobSourceSqlConnectionSubsets'

func (*MockJobServiceHandler_SetJobSourceSqlConnectionSubsets_Call) Return 

func (_c *MockJobServiceHandler_SetJobSourceSqlConnectionSubsets_Call) Return(_a0 *connect.Response[mgmtv1alpha1.SetJobSourceSqlConnectionSubsetsResponse], _a1 error) *MockJobServiceHandler_SetJobSourceSqlConnectionSubsets_Call

func (*MockJobServiceHandler_SetJobSourceSqlConnectionSubsets_Call) Run 

func (_c *MockJobServiceHandler_SetJobSourceSqlConnectionSubsets_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.SetJobSourceSqlConnectionSubsetsRequest])) *MockJobServiceHandler_SetJobSourceSqlConnectionSubsets_Call

func (*MockJobServiceHandler_SetJobSourceSqlConnectionSubsets_Call) RunAndReturn 

func (_c *MockJobServiceHandler_SetJobSourceSqlConnectionSubsets_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.SetJobSourceSqlConnectionSubsetsRequest]) (*connect.Response[mgmtv1alpha1.SetJobSourceSqlConnectionSubsetsResponse], error)) *MockJobServiceHandler_SetJobSourceSqlConnectionSubsets_Call

type MockJobServiceHandler_SetJobSyncOptions_Call 

type MockJobServiceHandler_SetJobSyncOptions_Call struct {
	*mock.Call
}

MockJobServiceHandler_SetJobSyncOptions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetJobSyncOptions'

func (*MockJobServiceHandler_SetJobSyncOptions_Call) Return 

func (_c *MockJobServiceHandler_SetJobSyncOptions_Call) Return(_a0 *connect.Response[mgmtv1alpha1.SetJobSyncOptionsResponse], _a1 error) *MockJobServiceHandler_SetJobSyncOptions_Call

func (*MockJobServiceHandler_SetJobSyncOptions_Call) Run 

func (_c *MockJobServiceHandler_SetJobSyncOptions_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.SetJobSyncOptionsRequest])) *MockJobServiceHandler_SetJobSyncOptions_Call

func (*MockJobServiceHandler_SetJobSyncOptions_Call) RunAndReturn 

func (_c *MockJobServiceHandler_SetJobSyncOptions_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.SetJobSyncOptionsRequest]) (*connect.Response[mgmtv1alpha1.SetJobSyncOptionsResponse], error)) *MockJobServiceHandler_SetJobSyncOptions_Call

type MockJobServiceHandler_SetJobWorkflowOptions_Call 

type MockJobServiceHandler_SetJobWorkflowOptions_Call struct {
	*mock.Call
}

MockJobServiceHandler_SetJobWorkflowOptions_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetJobWorkflowOptions'

func (*MockJobServiceHandler_SetJobWorkflowOptions_Call) Return 

func (_c *MockJobServiceHandler_SetJobWorkflowOptions_Call) Return(_a0 *connect.Response[mgmtv1alpha1.SetJobWorkflowOptionsResponse], _a1 error) *MockJobServiceHandler_SetJobWorkflowOptions_Call

func (*MockJobServiceHandler_SetJobWorkflowOptions_Call) Run 

func (_c *MockJobServiceHandler_SetJobWorkflowOptions_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.SetJobWorkflowOptionsRequest])) *MockJobServiceHandler_SetJobWorkflowOptions_Call

func (*MockJobServiceHandler_SetJobWorkflowOptions_Call) RunAndReturn 

func (_c *MockJobServiceHandler_SetJobWorkflowOptions_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.SetJobWorkflowOptionsRequest]) (*connect.Response[mgmtv1alpha1.SetJobWorkflowOptionsResponse], error)) *MockJobServiceHandler_SetJobWorkflowOptions_Call

type MockJobServiceHandler_TerminateJobRun_Call 

type MockJobServiceHandler_TerminateJobRun_Call struct {
	*mock.Call
}

MockJobServiceHandler_TerminateJobRun_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'TerminateJobRun'

func (*MockJobServiceHandler_TerminateJobRun_Call) Return 

func (_c *MockJobServiceHandler_TerminateJobRun_Call) Return(_a0 *connect.Response[mgmtv1alpha1.TerminateJobRunResponse], _a1 error) *MockJobServiceHandler_TerminateJobRun_Call

func (*MockJobServiceHandler_TerminateJobRun_Call) Run 

func (_c *MockJobServiceHandler_TerminateJobRun_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.TerminateJobRunRequest])) *MockJobServiceHandler_TerminateJobRun_Call

func (*MockJobServiceHandler_TerminateJobRun_Call) RunAndReturn 

func (_c *MockJobServiceHandler_TerminateJobRun_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.TerminateJobRunRequest]) (*connect.Response[mgmtv1alpha1.TerminateJobRunResponse], error)) *MockJobServiceHandler_TerminateJobRun_Call

type MockJobServiceHandler_UpdateJobDestinationConnection_Call 

type MockJobServiceHandler_UpdateJobDestinationConnection_Call struct {
	*mock.Call
}

MockJobServiceHandler_UpdateJobDestinationConnection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateJobDestinationConnection'

func (*MockJobServiceHandler_UpdateJobDestinationConnection_Call) Return 

func (_c *MockJobServiceHandler_UpdateJobDestinationConnection_Call) Return(_a0 *connect.Response[mgmtv1alpha1.UpdateJobDestinationConnectionResponse], _a1 error) *MockJobServiceHandler_UpdateJobDestinationConnection_Call

func (*MockJobServiceHandler_UpdateJobDestinationConnection_Call) Run 

func (_c *MockJobServiceHandler_UpdateJobDestinationConnection_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.UpdateJobDestinationConnectionRequest])) *MockJobServiceHandler_UpdateJobDestinationConnection_Call

func (*MockJobServiceHandler_UpdateJobDestinationConnection_Call) RunAndReturn 

func (_c *MockJobServiceHandler_UpdateJobDestinationConnection_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.UpdateJobDestinationConnectionRequest]) (*connect.Response[mgmtv1alpha1.UpdateJobDestinationConnectionResponse], error)) *MockJobServiceHandler_UpdateJobDestinationConnection_Call

type MockJobServiceHandler_UpdateJobSchedule_Call 

type MockJobServiceHandler_UpdateJobSchedule_Call struct {
	*mock.Call
}

MockJobServiceHandler_UpdateJobSchedule_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateJobSchedule'

func (*MockJobServiceHandler_UpdateJobSchedule_Call) Return 

func (_c *MockJobServiceHandler_UpdateJobSchedule_Call) Return(_a0 *connect.Response[mgmtv1alpha1.UpdateJobScheduleResponse], _a1 error) *MockJobServiceHandler_UpdateJobSchedule_Call

func (*MockJobServiceHandler_UpdateJobSchedule_Call) Run 

func (_c *MockJobServiceHandler_UpdateJobSchedule_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.UpdateJobScheduleRequest])) *MockJobServiceHandler_UpdateJobSchedule_Call

func (*MockJobServiceHandler_UpdateJobSchedule_Call) RunAndReturn 

func (_c *MockJobServiceHandler_UpdateJobSchedule_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.UpdateJobScheduleRequest]) (*connect.Response[mgmtv1alpha1.UpdateJobScheduleResponse], error)) *MockJobServiceHandler_UpdateJobSchedule_Call

type MockJobServiceHandler_UpdateJobSourceConnection_Call 

type MockJobServiceHandler_UpdateJobSourceConnection_Call struct {
	*mock.Call
}

MockJobServiceHandler_UpdateJobSourceConnection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateJobSourceConnection'

func (*MockJobServiceHandler_UpdateJobSourceConnection_Call) Return 

func (_c *MockJobServiceHandler_UpdateJobSourceConnection_Call) Return(_a0 *connect.Response[mgmtv1alpha1.UpdateJobSourceConnectionResponse], _a1 error) *MockJobServiceHandler_UpdateJobSourceConnection_Call

func (*MockJobServiceHandler_UpdateJobSourceConnection_Call) Run 

func (_c *MockJobServiceHandler_UpdateJobSourceConnection_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.UpdateJobSourceConnectionRequest])) *MockJobServiceHandler_UpdateJobSourceConnection_Call

func (*MockJobServiceHandler_UpdateJobSourceConnection_Call) RunAndReturn 

func (_c *MockJobServiceHandler_UpdateJobSourceConnection_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.UpdateJobSourceConnectionRequest]) (*connect.Response[mgmtv1alpha1.UpdateJobSourceConnectionResponse], error)) *MockJobServiceHandler_UpdateJobSourceConnection_Call

type MockJobServiceHandler_ValidateJobMappings_Call added in v0.4.24 

type MockJobServiceHandler_ValidateJobMappings_Call struct {
	*mock.Call
}

MockJobServiceHandler_ValidateJobMappings_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ValidateJobMappings'

func (*MockJobServiceHandler_ValidateJobMappings_Call) Return added in v0.4.24 

func (_c *MockJobServiceHandler_ValidateJobMappings_Call) Return(_a0 *connect.Response[mgmtv1alpha1.ValidateJobMappingsResponse], _a1 error) *MockJobServiceHandler_ValidateJobMappings_Call

func (*MockJobServiceHandler_ValidateJobMappings_Call) Run added in v0.4.24 

func (_c *MockJobServiceHandler_ValidateJobMappings_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.ValidateJobMappingsRequest])) *MockJobServiceHandler_ValidateJobMappings_Call

func (*MockJobServiceHandler_ValidateJobMappings_Call) RunAndReturn added in v0.4.24 

func (_c *MockJobServiceHandler_ValidateJobMappings_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.ValidateJobMappingsRequest]) (*connect.Response[mgmtv1alpha1.ValidateJobMappingsResponse], error)) *MockJobServiceHandler_ValidateJobMappings_Call

type MockTransformersServiceClient 

type MockTransformersServiceClient struct {
	mock.Mock
}

MockTransformersServiceClient is an autogenerated mock type for the TransformersServiceClient type

func NewMockTransformersServiceClient 

func NewMockTransformersServiceClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockTransformersServiceClient

NewMockTransformersServiceClient creates a new instance of MockTransformersServiceClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockTransformersServiceClient) CreateUserDefinedTransformer 

func (_m *MockTransformersServiceClient) CreateUserDefinedTransformer(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CreateUserDefinedTransformerRequest]) (*connect.Response[mgmtv1alpha1.CreateUserDefinedTransformerResponse], error)

CreateUserDefinedTransformer provides a mock function with given fields: _a0, _a1

func (*MockTransformersServiceClient) DeleteUserDefinedTransformer 

func (_m *MockTransformersServiceClient) DeleteUserDefinedTransformer(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.DeleteUserDefinedTransformerRequest]) (*connect.Response[mgmtv1alpha1.DeleteUserDefinedTransformerResponse], error)

DeleteUserDefinedTransformer provides a mock function with given fields: _a0, _a1

func (*MockTransformersServiceClient) EXPECT 

func (_m *MockTransformersServiceClient) EXPECT() *MockTransformersServiceClient_Expecter

func (*MockTransformersServiceClient) GetSystemTransformerBySource 

func (_m *MockTransformersServiceClient) GetSystemTransformerBySource(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetSystemTransformerBySourceRequest]) (*connect.Response[mgmtv1alpha1.GetSystemTransformerBySourceResponse], error)

GetSystemTransformerBySource provides a mock function with given fields: _a0, _a1

func (*MockTransformersServiceClient) GetSystemTransformers 

func (_m *MockTransformersServiceClient) GetSystemTransformers(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetSystemTransformersRequest]) (*connect.Response[mgmtv1alpha1.GetSystemTransformersResponse], error)

GetSystemTransformers provides a mock function with given fields: _a0, _a1

func (*MockTransformersServiceClient) GetUserDefinedTransformerById 

func (_m *MockTransformersServiceClient) GetUserDefinedTransformerById(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetUserDefinedTransformerByIdRequest]) (*connect.Response[mgmtv1alpha1.GetUserDefinedTransformerByIdResponse], error)

GetUserDefinedTransformerById provides a mock function with given fields: _a0, _a1

func (*MockTransformersServiceClient) GetUserDefinedTransformers 

func (_m *MockTransformersServiceClient) GetUserDefinedTransformers(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetUserDefinedTransformersRequest]) (*connect.Response[mgmtv1alpha1.GetUserDefinedTransformersResponse], error)

GetUserDefinedTransformers provides a mock function with given fields: _a0, _a1

func (*MockTransformersServiceClient) IsTransformerNameAvailable 

func (_m *MockTransformersServiceClient) IsTransformerNameAvailable(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.IsTransformerNameAvailableRequest]) (*connect.Response[mgmtv1alpha1.IsTransformerNameAvailableResponse], error)

IsTransformerNameAvailable provides a mock function with given fields: _a0, _a1

func (*MockTransformersServiceClient) UpdateUserDefinedTransformer 

func (_m *MockTransformersServiceClient) UpdateUserDefinedTransformer(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.UpdateUserDefinedTransformerRequest]) (*connect.Response[mgmtv1alpha1.UpdateUserDefinedTransformerResponse], error)

UpdateUserDefinedTransformer provides a mock function with given fields: _a0, _a1

func (*MockTransformersServiceClient) ValidateUserJavascriptCode 

func (_m *MockTransformersServiceClient) ValidateUserJavascriptCode(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.ValidateUserJavascriptCodeRequest]) (*connect.Response[mgmtv1alpha1.ValidateUserJavascriptCodeResponse], error)

ValidateUserJavascriptCode provides a mock function with given fields: _a0, _a1

func (*MockTransformersServiceClient) ValidateUserRegexCode 

func (_m *MockTransformersServiceClient) ValidateUserRegexCode(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.ValidateUserRegexCodeRequest]) (*connect.Response[mgmtv1alpha1.ValidateUserRegexCodeResponse], error)

ValidateUserRegexCode provides a mock function with given fields: _a0, _a1

type MockTransformersServiceClient_CreateUserDefinedTransformer_Call 

type MockTransformersServiceClient_CreateUserDefinedTransformer_Call struct {
	*mock.Call
}

MockTransformersServiceClient_CreateUserDefinedTransformer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateUserDefinedTransformer'

func (*MockTransformersServiceClient_CreateUserDefinedTransformer_Call) Return 

func (_c *MockTransformersServiceClient_CreateUserDefinedTransformer_Call) Return(_a0 *connect.Response[mgmtv1alpha1.CreateUserDefinedTransformerResponse], _a1 error) *MockTransformersServiceClient_CreateUserDefinedTransformer_Call

func (*MockTransformersServiceClient_CreateUserDefinedTransformer_Call) Run 

func (_c *MockTransformersServiceClient_CreateUserDefinedTransformer_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CreateUserDefinedTransformerRequest])) *MockTransformersServiceClient_CreateUserDefinedTransformer_Call

func (*MockTransformersServiceClient_CreateUserDefinedTransformer_Call) RunAndReturn 

func (_c *MockTransformersServiceClient_CreateUserDefinedTransformer_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.CreateUserDefinedTransformerRequest]) (*connect.Response[mgmtv1alpha1.CreateUserDefinedTransformerResponse], error)) *MockTransformersServiceClient_CreateUserDefinedTransformer_Call

type MockTransformersServiceClient_DeleteUserDefinedTransformer_Call 

type MockTransformersServiceClient_DeleteUserDefinedTransformer_Call struct {
	*mock.Call
}

MockTransformersServiceClient_DeleteUserDefinedTransformer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'DeleteUserDefinedTransformer'

func (*MockTransformersServiceClient_DeleteUserDefinedTransformer_Call) Return 

func (_c *MockTransformersServiceClient_DeleteUserDefinedTransformer_Call) Return(_a0 *connect.Response[mgmtv1alpha1.DeleteUserDefinedTransformerResponse], _a1 error) *MockTransformersServiceClient_DeleteUserDefinedTransformer_Call

func (*MockTransformersServiceClient_DeleteUserDefinedTransformer_Call) Run 

func (_c *MockTransformersServiceClient_DeleteUserDefinedTransformer_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.DeleteUserDefinedTransformerRequest])) *MockTransformersServiceClient_DeleteUserDefinedTransformer_Call

func (*MockTransformersServiceClient_DeleteUserDefinedTransformer_Call) RunAndReturn 

func (_c *MockTransformersServiceClient_DeleteUserDefinedTransformer_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.DeleteUserDefinedTransformerRequest]) (*connect.Response[mgmtv1alpha1.DeleteUserDefinedTransformerResponse], error)) *MockTransformersServiceClient_DeleteUserDefinedTransformer_Call

type MockTransformersServiceClient_Expecter 

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

func (*MockTransformersServiceClient_Expecter) CreateUserDefinedTransformer 

func (_e *MockTransformersServiceClient_Expecter) CreateUserDefinedTransformer(_a0 interface{}, _a1 interface{}) *MockTransformersServiceClient_CreateUserDefinedTransformer_Call

CreateUserDefinedTransformer is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.CreateUserDefinedTransformerRequest]

func (*MockTransformersServiceClient_Expecter) DeleteUserDefinedTransformer 

func (_e *MockTransformersServiceClient_Expecter) DeleteUserDefinedTransformer(_a0 interface{}, _a1 interface{}) *MockTransformersServiceClient_DeleteUserDefinedTransformer_Call

DeleteUserDefinedTransformer is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.DeleteUserDefinedTransformerRequest]

func (*MockTransformersServiceClient_Expecter) GetSystemTransformerBySource 

func (_e *MockTransformersServiceClient_Expecter) GetSystemTransformerBySource(_a0 interface{}, _a1 interface{}) *MockTransformersServiceClient_GetSystemTransformerBySource_Call

GetSystemTransformerBySource is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetSystemTransformerBySourceRequest]

func (*MockTransformersServiceClient_Expecter) GetSystemTransformers 

func (_e *MockTransformersServiceClient_Expecter) GetSystemTransformers(_a0 interface{}, _a1 interface{}) *MockTransformersServiceClient_GetSystemTransformers_Call

GetSystemTransformers is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetSystemTransformersRequest]

func (*MockTransformersServiceClient_Expecter) GetUserDefinedTransformerById 

func (_e *MockTransformersServiceClient_Expecter) GetUserDefinedTransformerById(_a0 interface{}, _a1 interface{}) *MockTransformersServiceClient_GetUserDefinedTransformerById_Call

GetUserDefinedTransformerById is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetUserDefinedTransformerByIdRequest]

func (*MockTransformersServiceClient_Expecter) GetUserDefinedTransformers 

func (_e *MockTransformersServiceClient_Expecter) GetUserDefinedTransformers(_a0 interface{}, _a1 interface{}) *MockTransformersServiceClient_GetUserDefinedTransformers_Call

GetUserDefinedTransformers is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetUserDefinedTransformersRequest]

func (*MockTransformersServiceClient_Expecter) IsTransformerNameAvailable 

func (_e *MockTransformersServiceClient_Expecter) IsTransformerNameAvailable(_a0 interface{}, _a1 interface{}) *MockTransformersServiceClient_IsTransformerNameAvailable_Call

IsTransformerNameAvailable is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.IsTransformerNameAvailableRequest]

func (*MockTransformersServiceClient_Expecter) UpdateUserDefinedTransformer 

func (_e *MockTransformersServiceClient_Expecter) UpdateUserDefinedTransformer(_a0 interface{}, _a1 interface{}) *MockTransformersServiceClient_UpdateUserDefinedTransformer_Call

UpdateUserDefinedTransformer is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.UpdateUserDefinedTransformerRequest]

func (*MockTransformersServiceClient_Expecter) ValidateUserJavascriptCode 

func (_e *MockTransformersServiceClient_Expecter) ValidateUserJavascriptCode(_a0 interface{}, _a1 interface{}) *MockTransformersServiceClient_ValidateUserJavascriptCode_Call

ValidateUserJavascriptCode is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.ValidateUserJavascriptCodeRequest]

func (*MockTransformersServiceClient_Expecter) ValidateUserRegexCode 

func (_e *MockTransformersServiceClient_Expecter) ValidateUserRegexCode(_a0 interface{}, _a1 interface{}) *MockTransformersServiceClient_ValidateUserRegexCode_Call

ValidateUserRegexCode is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.ValidateUserRegexCodeRequest]

type MockTransformersServiceClient_GetSystemTransformerBySource_Call 

type MockTransformersServiceClient_GetSystemTransformerBySource_Call struct {
	*mock.Call
}

MockTransformersServiceClient_GetSystemTransformerBySource_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSystemTransformerBySource'

func (*MockTransformersServiceClient_GetSystemTransformerBySource_Call) Return 

func (_c *MockTransformersServiceClient_GetSystemTransformerBySource_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetSystemTransformerBySourceResponse], _a1 error) *MockTransformersServiceClient_GetSystemTransformerBySource_Call

func (*MockTransformersServiceClient_GetSystemTransformerBySource_Call) Run 

func (_c *MockTransformersServiceClient_GetSystemTransformerBySource_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetSystemTransformerBySourceRequest])) *MockTransformersServiceClient_GetSystemTransformerBySource_Call

func (*MockTransformersServiceClient_GetSystemTransformerBySource_Call) RunAndReturn 

func (_c *MockTransformersServiceClient_GetSystemTransformerBySource_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetSystemTransformerBySourceRequest]) (*connect.Response[mgmtv1alpha1.GetSystemTransformerBySourceResponse], error)) *MockTransformersServiceClient_GetSystemTransformerBySource_Call

type MockTransformersServiceClient_GetSystemTransformers_Call 

type MockTransformersServiceClient_GetSystemTransformers_Call struct {
	*mock.Call
}

MockTransformersServiceClient_GetSystemTransformers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSystemTransformers'

func (*MockTransformersServiceClient_GetSystemTransformers_Call) Return 

func (_c *MockTransformersServiceClient_GetSystemTransformers_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetSystemTransformersResponse], _a1 error) *MockTransformersServiceClient_GetSystemTransformers_Call

func (*MockTransformersServiceClient_GetSystemTransformers_Call) Run 

func (_c *MockTransformersServiceClient_GetSystemTransformers_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetSystemTransformersRequest])) *MockTransformersServiceClient_GetSystemTransformers_Call

func (*MockTransformersServiceClient_GetSystemTransformers_Call) RunAndReturn 

func (_c *MockTransformersServiceClient_GetSystemTransformers_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetSystemTransformersRequest]) (*connect.Response[mgmtv1alpha1.GetSystemTransformersResponse], error)) *MockTransformersServiceClient_GetSystemTransformers_Call

type MockTransformersServiceClient_GetUserDefinedTransformerById_Call 

type MockTransformersServiceClient_GetUserDefinedTransformerById_Call struct {
	*mock.Call
}

MockTransformersServiceClient_GetUserDefinedTransformerById_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetUserDefinedTransformerById'

func (*MockTransformersServiceClient_GetUserDefinedTransformerById_Call) Return 

func (_c *MockTransformersServiceClient_GetUserDefinedTransformerById_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetUserDefinedTransformerByIdResponse], _a1 error) *MockTransformersServiceClient_GetUserDefinedTransformerById_Call

func (*MockTransformersServiceClient_GetUserDefinedTransformerById_Call) Run 

func (_c *MockTransformersServiceClient_GetUserDefinedTransformerById_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetUserDefinedTransformerByIdRequest])) *MockTransformersServiceClient_GetUserDefinedTransformerById_Call

func (*MockTransformersServiceClient_GetUserDefinedTransformerById_Call) RunAndReturn 

func (_c *MockTransformersServiceClient_GetUserDefinedTransformerById_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetUserDefinedTransformerByIdRequest]) (*connect.Response[mgmtv1alpha1.GetUserDefinedTransformerByIdResponse], error)) *MockTransformersServiceClient_GetUserDefinedTransformerById_Call

type MockTransformersServiceClient_GetUserDefinedTransformers_Call 

type MockTransformersServiceClient_GetUserDefinedTransformers_Call struct {
	*mock.Call
}

MockTransformersServiceClient_GetUserDefinedTransformers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetUserDefinedTransformers'

func (*MockTransformersServiceClient_GetUserDefinedTransformers_Call) Return 

func (_c *MockTransformersServiceClient_GetUserDefinedTransformers_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetUserDefinedTransformersResponse], _a1 error) *MockTransformersServiceClient_GetUserDefinedTransformers_Call

func (*MockTransformersServiceClient_GetUserDefinedTransformers_Call) Run 

func (_c *MockTransformersServiceClient_GetUserDefinedTransformers_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetUserDefinedTransformersRequest])) *MockTransformersServiceClient_GetUserDefinedTransformers_Call

func (*MockTransformersServiceClient_GetUserDefinedTransformers_Call) RunAndReturn 

func (_c *MockTransformersServiceClient_GetUserDefinedTransformers_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetUserDefinedTransformersRequest]) (*connect.Response[mgmtv1alpha1.GetUserDefinedTransformersResponse], error)) *MockTransformersServiceClient_GetUserDefinedTransformers_Call

type MockTransformersServiceClient_IsTransformerNameAvailable_Call 

type MockTransformersServiceClient_IsTransformerNameAvailable_Call struct {
	*mock.Call
}

MockTransformersServiceClient_IsTransformerNameAvailable_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsTransformerNameAvailable'

func (*MockTransformersServiceClient_IsTransformerNameAvailable_Call) Return 

func (_c *MockTransformersServiceClient_IsTransformerNameAvailable_Call) Return(_a0 *connect.Response[mgmtv1alpha1.IsTransformerNameAvailableResponse], _a1 error) *MockTransformersServiceClient_IsTransformerNameAvailable_Call

func (*MockTransformersServiceClient_IsTransformerNameAvailable_Call) Run 

func (_c *MockTransformersServiceClient_IsTransformerNameAvailable_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.IsTransformerNameAvailableRequest])) *MockTransformersServiceClient_IsTransformerNameAvailable_Call

func (*MockTransformersServiceClient_IsTransformerNameAvailable_Call) RunAndReturn 

func (_c *MockTransformersServiceClient_IsTransformerNameAvailable_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.IsTransformerNameAvailableRequest]) (*connect.Response[mgmtv1alpha1.IsTransformerNameAvailableResponse], error)) *MockTransformersServiceClient_IsTransformerNameAvailable_Call

type MockTransformersServiceClient_UpdateUserDefinedTransformer_Call 

type MockTransformersServiceClient_UpdateUserDefinedTransformer_Call struct {
	*mock.Call
}

MockTransformersServiceClient_UpdateUserDefinedTransformer_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'UpdateUserDefinedTransformer'

func (*MockTransformersServiceClient_UpdateUserDefinedTransformer_Call) Return 

func (_c *MockTransformersServiceClient_UpdateUserDefinedTransformer_Call) Return(_a0 *connect.Response[mgmtv1alpha1.UpdateUserDefinedTransformerResponse], _a1 error) *MockTransformersServiceClient_UpdateUserDefinedTransformer_Call

func (*MockTransformersServiceClient_UpdateUserDefinedTransformer_Call) Run 

func (_c *MockTransformersServiceClient_UpdateUserDefinedTransformer_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.UpdateUserDefinedTransformerRequest])) *MockTransformersServiceClient_UpdateUserDefinedTransformer_Call

func (*MockTransformersServiceClient_UpdateUserDefinedTransformer_Call) RunAndReturn 

func (_c *MockTransformersServiceClient_UpdateUserDefinedTransformer_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.UpdateUserDefinedTransformerRequest]) (*connect.Response[mgmtv1alpha1.UpdateUserDefinedTransformerResponse], error)) *MockTransformersServiceClient_UpdateUserDefinedTransformer_Call

type MockTransformersServiceClient_ValidateUserJavascriptCode_Call 

type MockTransformersServiceClient_ValidateUserJavascriptCode_Call struct {
	*mock.Call
}

MockTransformersServiceClient_ValidateUserJavascriptCode_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ValidateUserJavascriptCode'

func (*MockTransformersServiceClient_ValidateUserJavascriptCode_Call) Return 

func (_c *MockTransformersServiceClient_ValidateUserJavascriptCode_Call) Return(_a0 *connect.Response[mgmtv1alpha1.ValidateUserJavascriptCodeResponse], _a1 error) *MockTransformersServiceClient_ValidateUserJavascriptCode_Call

func (*MockTransformersServiceClient_ValidateUserJavascriptCode_Call) Run 

func (_c *MockTransformersServiceClient_ValidateUserJavascriptCode_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.ValidateUserJavascriptCodeRequest])) *MockTransformersServiceClient_ValidateUserJavascriptCode_Call

func (*MockTransformersServiceClient_ValidateUserJavascriptCode_Call) RunAndReturn 

func (_c *MockTransformersServiceClient_ValidateUserJavascriptCode_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.ValidateUserJavascriptCodeRequest]) (*connect.Response[mgmtv1alpha1.ValidateUserJavascriptCodeResponse], error)) *MockTransformersServiceClient_ValidateUserJavascriptCode_Call

type MockTransformersServiceClient_ValidateUserRegexCode_Call 

type MockTransformersServiceClient_ValidateUserRegexCode_Call struct {
	*mock.Call
}

MockTransformersServiceClient_ValidateUserRegexCode_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ValidateUserRegexCode'

func (*MockTransformersServiceClient_ValidateUserRegexCode_Call) Return 

func (_c *MockTransformersServiceClient_ValidateUserRegexCode_Call) Return(_a0 *connect.Response[mgmtv1alpha1.ValidateUserRegexCodeResponse], _a1 error) *MockTransformersServiceClient_ValidateUserRegexCode_Call

func (*MockTransformersServiceClient_ValidateUserRegexCode_Call) Run 

func (_c *MockTransformersServiceClient_ValidateUserRegexCode_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.ValidateUserRegexCodeRequest])) *MockTransformersServiceClient_ValidateUserRegexCode_Call

func (*MockTransformersServiceClient_ValidateUserRegexCode_Call) RunAndReturn 

func (_c *MockTransformersServiceClient_ValidateUserRegexCode_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.ValidateUserRegexCodeRequest]) (*connect.Response[mgmtv1alpha1.ValidateUserRegexCodeResponse], error)) *MockTransformersServiceClient_ValidateUserRegexCode_Call

type MockUserAccountServiceClient 

type MockUserAccountServiceClient struct {
	mock.Mock
}

MockUserAccountServiceClient is an autogenerated mock type for the UserAccountServiceClient type

func NewMockUserAccountServiceClient 

func NewMockUserAccountServiceClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockUserAccountServiceClient

NewMockUserAccountServiceClient creates a new instance of MockUserAccountServiceClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockUserAccountServiceClient) AcceptTeamAccountInvite 

func (_m *MockUserAccountServiceClient) AcceptTeamAccountInvite(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.AcceptTeamAccountInviteRequest]) (*connect.Response[mgmtv1alpha1.AcceptTeamAccountInviteResponse], error)

AcceptTeamAccountInvite provides a mock function with given fields: _a0, _a1

func (*MockUserAccountServiceClient) ConvertPersonalToTeamAccount 

func (_m *MockUserAccountServiceClient) ConvertPersonalToTeamAccount(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.ConvertPersonalToTeamAccountRequest]) (*connect.Response[mgmtv1alpha1.ConvertPersonalToTeamAccountResponse], error)

ConvertPersonalToTeamAccount provides a mock function with given fields: _a0, _a1

func (*MockUserAccountServiceClient) CreateTeamAccount 

func (_m *MockUserAccountServiceClient) CreateTeamAccount(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CreateTeamAccountRequest]) (*connect.Response[mgmtv1alpha1.CreateTeamAccountResponse], error)

CreateTeamAccount provides a mock function with given fields: _a0, _a1

func (*MockUserAccountServiceClient) EXPECT 

func (_m *MockUserAccountServiceClient) EXPECT() *MockUserAccountServiceClient_Expecter

func (*MockUserAccountServiceClient) GetAccountOnboardingConfig 

func (_m *MockUserAccountServiceClient) GetAccountOnboardingConfig(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetAccountOnboardingConfigRequest]) (*connect.Response[mgmtv1alpha1.GetAccountOnboardingConfigResponse], error)

GetAccountOnboardingConfig provides a mock function with given fields: _a0, _a1

func (*MockUserAccountServiceClient) GetAccountTemporalConfig 

func (_m *MockUserAccountServiceClient) GetAccountTemporalConfig(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetAccountTemporalConfigRequest]) (*connect.Response[mgmtv1alpha1.GetAccountTemporalConfigResponse], error)

GetAccountTemporalConfig provides a mock function with given fields: _a0, _a1

func (*MockUserAccountServiceClient) GetSystemInformation 

func (_m *MockUserAccountServiceClient) GetSystemInformation(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetSystemInformationRequest]) (*connect.Response[mgmtv1alpha1.GetSystemInformationResponse], error)

GetSystemInformation provides a mock function with given fields: _a0, _a1

func (*MockUserAccountServiceClient) GetTeamAccountInvites 

func (_m *MockUserAccountServiceClient) GetTeamAccountInvites(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetTeamAccountInvitesRequest]) (*connect.Response[mgmtv1alpha1.GetTeamAccountInvitesResponse], error)

GetTeamAccountInvites provides a mock function with given fields: _a0, _a1

func (*MockUserAccountServiceClient) GetTeamAccountMembers 

func (_m *MockUserAccountServiceClient) GetTeamAccountMembers(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetTeamAccountMembersRequest]) (*connect.Response[mgmtv1alpha1.GetTeamAccountMembersResponse], error)

GetTeamAccountMembers provides a mock function with given fields: _a0, _a1

func (*MockUserAccountServiceClient) GetUser 

func (_m *MockUserAccountServiceClient) GetUser(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetUserRequest]) (*connect.Response[mgmtv1alpha1.GetUserResponse], error)

GetUser provides a mock function with given fields: _a0, _a1

func (*MockUserAccountServiceClient) GetUserAccounts 

func (_m *MockUserAccountServiceClient) GetUserAccounts(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetUserAccountsRequest]) (*connect.Response[mgmtv1alpha1.GetUserAccountsResponse], error)

GetUserAccounts provides a mock function with given fields: _a0, _a1

func (*MockUserAccountServiceClient) InviteUserToTeamAccount 

func (_m *MockUserAccountServiceClient) InviteUserToTeamAccount(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.InviteUserToTeamAccountRequest]) (*connect.Response[mgmtv1alpha1.InviteUserToTeamAccountResponse], error)

InviteUserToTeamAccount provides a mock function with given fields: _a0, _a1

func (*MockUserAccountServiceClient) IsUserInAccount 

func (_m *MockUserAccountServiceClient) IsUserInAccount(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.IsUserInAccountRequest]) (*connect.Response[mgmtv1alpha1.IsUserInAccountResponse], error)

IsUserInAccount provides a mock function with given fields: _a0, _a1

func (*MockUserAccountServiceClient) RemoveTeamAccountInvite 

func (_m *MockUserAccountServiceClient) RemoveTeamAccountInvite(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.RemoveTeamAccountInviteRequest]) (*connect.Response[mgmtv1alpha1.RemoveTeamAccountInviteResponse], error)

RemoveTeamAccountInvite provides a mock function with given fields: _a0, _a1

func (*MockUserAccountServiceClient) RemoveTeamAccountMember 

func (_m *MockUserAccountServiceClient) RemoveTeamAccountMember(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.RemoveTeamAccountMemberRequest]) (*connect.Response[mgmtv1alpha1.RemoveTeamAccountMemberResponse], error)

RemoveTeamAccountMember provides a mock function with given fields: _a0, _a1

func (*MockUserAccountServiceClient) SetAccountOnboardingConfig 

func (_m *MockUserAccountServiceClient) SetAccountOnboardingConfig(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.SetAccountOnboardingConfigRequest]) (*connect.Response[mgmtv1alpha1.SetAccountOnboardingConfigResponse], error)

SetAccountOnboardingConfig provides a mock function with given fields: _a0, _a1

func (*MockUserAccountServiceClient) SetAccountTemporalConfig 

func (_m *MockUserAccountServiceClient) SetAccountTemporalConfig(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.SetAccountTemporalConfigRequest]) (*connect.Response[mgmtv1alpha1.SetAccountTemporalConfigResponse], error)

SetAccountTemporalConfig provides a mock function with given fields: _a0, _a1

func (*MockUserAccountServiceClient) SetPersonalAccount 

func (_m *MockUserAccountServiceClient) SetPersonalAccount(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.SetPersonalAccountRequest]) (*connect.Response[mgmtv1alpha1.SetPersonalAccountResponse], error)

SetPersonalAccount provides a mock function with given fields: _a0, _a1

func (*MockUserAccountServiceClient) SetUser 

func (_m *MockUserAccountServiceClient) SetUser(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.SetUserRequest]) (*connect.Response[mgmtv1alpha1.SetUserResponse], error)

SetUser provides a mock function with given fields: _a0, _a1

type MockUserAccountServiceClient_AcceptTeamAccountInvite_Call 

type MockUserAccountServiceClient_AcceptTeamAccountInvite_Call struct {
	*mock.Call
}

MockUserAccountServiceClient_AcceptTeamAccountInvite_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'AcceptTeamAccountInvite'

func (*MockUserAccountServiceClient_AcceptTeamAccountInvite_Call) Return 

func (_c *MockUserAccountServiceClient_AcceptTeamAccountInvite_Call) Return(_a0 *connect.Response[mgmtv1alpha1.AcceptTeamAccountInviteResponse], _a1 error) *MockUserAccountServiceClient_AcceptTeamAccountInvite_Call

func (*MockUserAccountServiceClient_AcceptTeamAccountInvite_Call) Run 

func (_c *MockUserAccountServiceClient_AcceptTeamAccountInvite_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.AcceptTeamAccountInviteRequest])) *MockUserAccountServiceClient_AcceptTeamAccountInvite_Call

func (*MockUserAccountServiceClient_AcceptTeamAccountInvite_Call) RunAndReturn 

func (_c *MockUserAccountServiceClient_AcceptTeamAccountInvite_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.AcceptTeamAccountInviteRequest]) (*connect.Response[mgmtv1alpha1.AcceptTeamAccountInviteResponse], error)) *MockUserAccountServiceClient_AcceptTeamAccountInvite_Call

type MockUserAccountServiceClient_ConvertPersonalToTeamAccount_Call 

type MockUserAccountServiceClient_ConvertPersonalToTeamAccount_Call struct {
	*mock.Call
}

MockUserAccountServiceClient_ConvertPersonalToTeamAccount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'ConvertPersonalToTeamAccount'

func (*MockUserAccountServiceClient_ConvertPersonalToTeamAccount_Call) Return 

func (_c *MockUserAccountServiceClient_ConvertPersonalToTeamAccount_Call) Return(_a0 *connect.Response[mgmtv1alpha1.ConvertPersonalToTeamAccountResponse], _a1 error) *MockUserAccountServiceClient_ConvertPersonalToTeamAccount_Call

func (*MockUserAccountServiceClient_ConvertPersonalToTeamAccount_Call) Run 

func (_c *MockUserAccountServiceClient_ConvertPersonalToTeamAccount_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.ConvertPersonalToTeamAccountRequest])) *MockUserAccountServiceClient_ConvertPersonalToTeamAccount_Call

func (*MockUserAccountServiceClient_ConvertPersonalToTeamAccount_Call) RunAndReturn 

func (_c *MockUserAccountServiceClient_ConvertPersonalToTeamAccount_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.ConvertPersonalToTeamAccountRequest]) (*connect.Response[mgmtv1alpha1.ConvertPersonalToTeamAccountResponse], error)) *MockUserAccountServiceClient_ConvertPersonalToTeamAccount_Call

type MockUserAccountServiceClient_CreateTeamAccount_Call 

type MockUserAccountServiceClient_CreateTeamAccount_Call struct {
	*mock.Call
}

MockUserAccountServiceClient_CreateTeamAccount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'CreateTeamAccount'

func (*MockUserAccountServiceClient_CreateTeamAccount_Call) Return 

func (_c *MockUserAccountServiceClient_CreateTeamAccount_Call) Return(_a0 *connect.Response[mgmtv1alpha1.CreateTeamAccountResponse], _a1 error) *MockUserAccountServiceClient_CreateTeamAccount_Call

func (*MockUserAccountServiceClient_CreateTeamAccount_Call) Run 

func (_c *MockUserAccountServiceClient_CreateTeamAccount_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.CreateTeamAccountRequest])) *MockUserAccountServiceClient_CreateTeamAccount_Call

func (*MockUserAccountServiceClient_CreateTeamAccount_Call) RunAndReturn 

func (_c *MockUserAccountServiceClient_CreateTeamAccount_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.CreateTeamAccountRequest]) (*connect.Response[mgmtv1alpha1.CreateTeamAccountResponse], error)) *MockUserAccountServiceClient_CreateTeamAccount_Call

type MockUserAccountServiceClient_Expecter 

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

func (*MockUserAccountServiceClient_Expecter) AcceptTeamAccountInvite 

func (_e *MockUserAccountServiceClient_Expecter) AcceptTeamAccountInvite(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_AcceptTeamAccountInvite_Call

AcceptTeamAccountInvite is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.AcceptTeamAccountInviteRequest]

func (*MockUserAccountServiceClient_Expecter) ConvertPersonalToTeamAccount 

func (_e *MockUserAccountServiceClient_Expecter) ConvertPersonalToTeamAccount(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_ConvertPersonalToTeamAccount_Call

ConvertPersonalToTeamAccount is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.ConvertPersonalToTeamAccountRequest]

func (*MockUserAccountServiceClient_Expecter) CreateTeamAccount 

func (_e *MockUserAccountServiceClient_Expecter) CreateTeamAccount(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_CreateTeamAccount_Call

CreateTeamAccount is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.CreateTeamAccountRequest]

func (*MockUserAccountServiceClient_Expecter) GetAccountOnboardingConfig 

func (_e *MockUserAccountServiceClient_Expecter) GetAccountOnboardingConfig(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_GetAccountOnboardingConfig_Call

GetAccountOnboardingConfig is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetAccountOnboardingConfigRequest]

func (*MockUserAccountServiceClient_Expecter) GetAccountTemporalConfig 

func (_e *MockUserAccountServiceClient_Expecter) GetAccountTemporalConfig(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_GetAccountTemporalConfig_Call

GetAccountTemporalConfig is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetAccountTemporalConfigRequest]

func (*MockUserAccountServiceClient_Expecter) GetSystemInformation 

func (_e *MockUserAccountServiceClient_Expecter) GetSystemInformation(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_GetSystemInformation_Call

GetSystemInformation is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetSystemInformationRequest]

func (*MockUserAccountServiceClient_Expecter) GetTeamAccountInvites 

func (_e *MockUserAccountServiceClient_Expecter) GetTeamAccountInvites(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_GetTeamAccountInvites_Call

GetTeamAccountInvites is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetTeamAccountInvitesRequest]

func (*MockUserAccountServiceClient_Expecter) GetTeamAccountMembers 

func (_e *MockUserAccountServiceClient_Expecter) GetTeamAccountMembers(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_GetTeamAccountMembers_Call

GetTeamAccountMembers is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetTeamAccountMembersRequest]

func (*MockUserAccountServiceClient_Expecter) GetUser 

func (_e *MockUserAccountServiceClient_Expecter) GetUser(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_GetUser_Call

GetUser is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetUserRequest]

func (*MockUserAccountServiceClient_Expecter) GetUserAccounts 

func (_e *MockUserAccountServiceClient_Expecter) GetUserAccounts(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_GetUserAccounts_Call

GetUserAccounts is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.GetUserAccountsRequest]

func (*MockUserAccountServiceClient_Expecter) InviteUserToTeamAccount 

func (_e *MockUserAccountServiceClient_Expecter) InviteUserToTeamAccount(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_InviteUserToTeamAccount_Call

InviteUserToTeamAccount is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.InviteUserToTeamAccountRequest]

func (*MockUserAccountServiceClient_Expecter) IsUserInAccount 

func (_e *MockUserAccountServiceClient_Expecter) IsUserInAccount(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_IsUserInAccount_Call

IsUserInAccount is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.IsUserInAccountRequest]

func (*MockUserAccountServiceClient_Expecter) RemoveTeamAccountInvite 

func (_e *MockUserAccountServiceClient_Expecter) RemoveTeamAccountInvite(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_RemoveTeamAccountInvite_Call

RemoveTeamAccountInvite is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.RemoveTeamAccountInviteRequest]

func (*MockUserAccountServiceClient_Expecter) RemoveTeamAccountMember 

func (_e *MockUserAccountServiceClient_Expecter) RemoveTeamAccountMember(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_RemoveTeamAccountMember_Call

RemoveTeamAccountMember is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.RemoveTeamAccountMemberRequest]

func (*MockUserAccountServiceClient_Expecter) SetAccountOnboardingConfig 

func (_e *MockUserAccountServiceClient_Expecter) SetAccountOnboardingConfig(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_SetAccountOnboardingConfig_Call

SetAccountOnboardingConfig is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.SetAccountOnboardingConfigRequest]

func (*MockUserAccountServiceClient_Expecter) SetAccountTemporalConfig 

func (_e *MockUserAccountServiceClient_Expecter) SetAccountTemporalConfig(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_SetAccountTemporalConfig_Call

SetAccountTemporalConfig is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.SetAccountTemporalConfigRequest]

func (*MockUserAccountServiceClient_Expecter) SetPersonalAccount 

func (_e *MockUserAccountServiceClient_Expecter) SetPersonalAccount(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_SetPersonalAccount_Call

SetPersonalAccount is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.SetPersonalAccountRequest]

func (*MockUserAccountServiceClient_Expecter) SetUser 

func (_e *MockUserAccountServiceClient_Expecter) SetUser(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_SetUser_Call

SetUser is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 *connect.Request[mgmtv1alpha1.SetUserRequest]

type MockUserAccountServiceClient_GetAccountOnboardingConfig_Call 

type MockUserAccountServiceClient_GetAccountOnboardingConfig_Call struct {
	*mock.Call
}

MockUserAccountServiceClient_GetAccountOnboardingConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetAccountOnboardingConfig'

func (*MockUserAccountServiceClient_GetAccountOnboardingConfig_Call) Return 

func (_c *MockUserAccountServiceClient_GetAccountOnboardingConfig_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetAccountOnboardingConfigResponse], _a1 error) *MockUserAccountServiceClient_GetAccountOnboardingConfig_Call

func (*MockUserAccountServiceClient_GetAccountOnboardingConfig_Call) Run 

func (_c *MockUserAccountServiceClient_GetAccountOnboardingConfig_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetAccountOnboardingConfigRequest])) *MockUserAccountServiceClient_GetAccountOnboardingConfig_Call

func (*MockUserAccountServiceClient_GetAccountOnboardingConfig_Call) RunAndReturn 

func (_c *MockUserAccountServiceClient_GetAccountOnboardingConfig_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetAccountOnboardingConfigRequest]) (*connect.Response[mgmtv1alpha1.GetAccountOnboardingConfigResponse], error)) *MockUserAccountServiceClient_GetAccountOnboardingConfig_Call

type MockUserAccountServiceClient_GetAccountTemporalConfig_Call 

type MockUserAccountServiceClient_GetAccountTemporalConfig_Call struct {
	*mock.Call
}

MockUserAccountServiceClient_GetAccountTemporalConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetAccountTemporalConfig'

func (*MockUserAccountServiceClient_GetAccountTemporalConfig_Call) Return 

func (_c *MockUserAccountServiceClient_GetAccountTemporalConfig_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetAccountTemporalConfigResponse], _a1 error) *MockUserAccountServiceClient_GetAccountTemporalConfig_Call

func (*MockUserAccountServiceClient_GetAccountTemporalConfig_Call) Run 

func (_c *MockUserAccountServiceClient_GetAccountTemporalConfig_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetAccountTemporalConfigRequest])) *MockUserAccountServiceClient_GetAccountTemporalConfig_Call

func (*MockUserAccountServiceClient_GetAccountTemporalConfig_Call) RunAndReturn 

func (_c *MockUserAccountServiceClient_GetAccountTemporalConfig_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetAccountTemporalConfigRequest]) (*connect.Response[mgmtv1alpha1.GetAccountTemporalConfigResponse], error)) *MockUserAccountServiceClient_GetAccountTemporalConfig_Call

type MockUserAccountServiceClient_GetSystemInformation_Call 

type MockUserAccountServiceClient_GetSystemInformation_Call struct {
	*mock.Call
}

MockUserAccountServiceClient_GetSystemInformation_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetSystemInformation'

func (*MockUserAccountServiceClient_GetSystemInformation_Call) Return 

func (_c *MockUserAccountServiceClient_GetSystemInformation_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetSystemInformationResponse], _a1 error) *MockUserAccountServiceClient_GetSystemInformation_Call

func (*MockUserAccountServiceClient_GetSystemInformation_Call) Run 

func (_c *MockUserAccountServiceClient_GetSystemInformation_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetSystemInformationRequest])) *MockUserAccountServiceClient_GetSystemInformation_Call

func (*MockUserAccountServiceClient_GetSystemInformation_Call) RunAndReturn 

func (_c *MockUserAccountServiceClient_GetSystemInformation_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetSystemInformationRequest]) (*connect.Response[mgmtv1alpha1.GetSystemInformationResponse], error)) *MockUserAccountServiceClient_GetSystemInformation_Call

type MockUserAccountServiceClient_GetTeamAccountInvites_Call 

type MockUserAccountServiceClient_GetTeamAccountInvites_Call struct {
	*mock.Call
}

MockUserAccountServiceClient_GetTeamAccountInvites_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTeamAccountInvites'

func (*MockUserAccountServiceClient_GetTeamAccountInvites_Call) Return 

func (_c *MockUserAccountServiceClient_GetTeamAccountInvites_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetTeamAccountInvitesResponse], _a1 error) *MockUserAccountServiceClient_GetTeamAccountInvites_Call

func (*MockUserAccountServiceClient_GetTeamAccountInvites_Call) Run 

func (_c *MockUserAccountServiceClient_GetTeamAccountInvites_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetTeamAccountInvitesRequest])) *MockUserAccountServiceClient_GetTeamAccountInvites_Call

func (*MockUserAccountServiceClient_GetTeamAccountInvites_Call) RunAndReturn 

func (_c *MockUserAccountServiceClient_GetTeamAccountInvites_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetTeamAccountInvitesRequest]) (*connect.Response[mgmtv1alpha1.GetTeamAccountInvitesResponse], error)) *MockUserAccountServiceClient_GetTeamAccountInvites_Call

type MockUserAccountServiceClient_GetTeamAccountMembers_Call 

type MockUserAccountServiceClient_GetTeamAccountMembers_Call struct {
	*mock.Call
}

MockUserAccountServiceClient_GetTeamAccountMembers_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetTeamAccountMembers'

func (*MockUserAccountServiceClient_GetTeamAccountMembers_Call) Return 

func (_c *MockUserAccountServiceClient_GetTeamAccountMembers_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetTeamAccountMembersResponse], _a1 error) *MockUserAccountServiceClient_GetTeamAccountMembers_Call

func (*MockUserAccountServiceClient_GetTeamAccountMembers_Call) Run 

func (_c *MockUserAccountServiceClient_GetTeamAccountMembers_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetTeamAccountMembersRequest])) *MockUserAccountServiceClient_GetTeamAccountMembers_Call

func (*MockUserAccountServiceClient_GetTeamAccountMembers_Call) RunAndReturn 

func (_c *MockUserAccountServiceClient_GetTeamAccountMembers_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetTeamAccountMembersRequest]) (*connect.Response[mgmtv1alpha1.GetTeamAccountMembersResponse], error)) *MockUserAccountServiceClient_GetTeamAccountMembers_Call

type MockUserAccountServiceClient_GetUserAccounts_Call 

type MockUserAccountServiceClient_GetUserAccounts_Call struct {
	*mock.Call
}

MockUserAccountServiceClient_GetUserAccounts_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetUserAccounts'

func (*MockUserAccountServiceClient_GetUserAccounts_Call) Return 

func (_c *MockUserAccountServiceClient_GetUserAccounts_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetUserAccountsResponse], _a1 error) *MockUserAccountServiceClient_GetUserAccounts_Call

func (*MockUserAccountServiceClient_GetUserAccounts_Call) Run 

func (_c *MockUserAccountServiceClient_GetUserAccounts_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetUserAccountsRequest])) *MockUserAccountServiceClient_GetUserAccounts_Call

func (*MockUserAccountServiceClient_GetUserAccounts_Call) RunAndReturn 

func (_c *MockUserAccountServiceClient_GetUserAccounts_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetUserAccountsRequest]) (*connect.Response[mgmtv1alpha1.GetUserAccountsResponse], error)) *MockUserAccountServiceClient_GetUserAccounts_Call

type MockUserAccountServiceClient_GetUser_Call 

type MockUserAccountServiceClient_GetUser_Call struct {
	*mock.Call
}

MockUserAccountServiceClient_GetUser_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'GetUser'

func (*MockUserAccountServiceClient_GetUser_Call) Return 

func (_c *MockUserAccountServiceClient_GetUser_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetUserResponse], _a1 error) *MockUserAccountServiceClient_GetUser_Call

func (*MockUserAccountServiceClient_GetUser_Call) Run 

func (_c *MockUserAccountServiceClient_GetUser_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetUserRequest])) *MockUserAccountServiceClient_GetUser_Call

func (*MockUserAccountServiceClient_GetUser_Call) RunAndReturn 

func (_c *MockUserAccountServiceClient_GetUser_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.GetUserRequest]) (*connect.Response[mgmtv1alpha1.GetUserResponse], error)) *MockUserAccountServiceClient_GetUser_Call

type MockUserAccountServiceClient_InviteUserToTeamAccount_Call 

type MockUserAccountServiceClient_InviteUserToTeamAccount_Call struct {
	*mock.Call
}

MockUserAccountServiceClient_InviteUserToTeamAccount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'InviteUserToTeamAccount'

func (*MockUserAccountServiceClient_InviteUserToTeamAccount_Call) Return 

func (_c *MockUserAccountServiceClient_InviteUserToTeamAccount_Call) Return(_a0 *connect.Response[mgmtv1alpha1.InviteUserToTeamAccountResponse], _a1 error) *MockUserAccountServiceClient_InviteUserToTeamAccount_Call

func (*MockUserAccountServiceClient_InviteUserToTeamAccount_Call) Run 

func (_c *MockUserAccountServiceClient_InviteUserToTeamAccount_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.InviteUserToTeamAccountRequest])) *MockUserAccountServiceClient_InviteUserToTeamAccount_Call

func (*MockUserAccountServiceClient_InviteUserToTeamAccount_Call) RunAndReturn 

func (_c *MockUserAccountServiceClient_InviteUserToTeamAccount_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.InviteUserToTeamAccountRequest]) (*connect.Response[mgmtv1alpha1.InviteUserToTeamAccountResponse], error)) *MockUserAccountServiceClient_InviteUserToTeamAccount_Call

type MockUserAccountServiceClient_IsUserInAccount_Call 

type MockUserAccountServiceClient_IsUserInAccount_Call struct {
	*mock.Call
}

MockUserAccountServiceClient_IsUserInAccount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'IsUserInAccount'

func (*MockUserAccountServiceClient_IsUserInAccount_Call) Return 

func (_c *MockUserAccountServiceClient_IsUserInAccount_Call) Return(_a0 *connect.Response[mgmtv1alpha1.IsUserInAccountResponse], _a1 error) *MockUserAccountServiceClient_IsUserInAccount_Call

func (*MockUserAccountServiceClient_IsUserInAccount_Call) Run 

func (_c *MockUserAccountServiceClient_IsUserInAccount_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.IsUserInAccountRequest])) *MockUserAccountServiceClient_IsUserInAccount_Call

func (*MockUserAccountServiceClient_IsUserInAccount_Call) RunAndReturn 

func (_c *MockUserAccountServiceClient_IsUserInAccount_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.IsUserInAccountRequest]) (*connect.Response[mgmtv1alpha1.IsUserInAccountResponse], error)) *MockUserAccountServiceClient_IsUserInAccount_Call

type MockUserAccountServiceClient_RemoveTeamAccountInvite_Call 

type MockUserAccountServiceClient_RemoveTeamAccountInvite_Call struct {
	*mock.Call
}

MockUserAccountServiceClient_RemoveTeamAccountInvite_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RemoveTeamAccountInvite'

func (*MockUserAccountServiceClient_RemoveTeamAccountInvite_Call) Return 

func (_c *MockUserAccountServiceClient_RemoveTeamAccountInvite_Call) Return(_a0 *connect.Response[mgmtv1alpha1.RemoveTeamAccountInviteResponse], _a1 error) *MockUserAccountServiceClient_RemoveTeamAccountInvite_Call

func (*MockUserAccountServiceClient_RemoveTeamAccountInvite_Call) Run 

func (_c *MockUserAccountServiceClient_RemoveTeamAccountInvite_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.RemoveTeamAccountInviteRequest])) *MockUserAccountServiceClient_RemoveTeamAccountInvite_Call

func (*MockUserAccountServiceClient_RemoveTeamAccountInvite_Call) RunAndReturn 

func (_c *MockUserAccountServiceClient_RemoveTeamAccountInvite_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.RemoveTeamAccountInviteRequest]) (*connect.Response[mgmtv1alpha1.RemoveTeamAccountInviteResponse], error)) *MockUserAccountServiceClient_RemoveTeamAccountInvite_Call

type MockUserAccountServiceClient_RemoveTeamAccountMember_Call 

type MockUserAccountServiceClient_RemoveTeamAccountMember_Call struct {
	*mock.Call
}

MockUserAccountServiceClient_RemoveTeamAccountMember_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'RemoveTeamAccountMember'

func (*MockUserAccountServiceClient_RemoveTeamAccountMember_Call) Return 

func (_c *MockUserAccountServiceClient_RemoveTeamAccountMember_Call) Return(_a0 *connect.Response[mgmtv1alpha1.RemoveTeamAccountMemberResponse], _a1 error) *MockUserAccountServiceClient_RemoveTeamAccountMember_Call

func (*MockUserAccountServiceClient_RemoveTeamAccountMember_Call) Run 

func (_c *MockUserAccountServiceClient_RemoveTeamAccountMember_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.RemoveTeamAccountMemberRequest])) *MockUserAccountServiceClient_RemoveTeamAccountMember_Call

func (*MockUserAccountServiceClient_RemoveTeamAccountMember_Call) RunAndReturn 

func (_c *MockUserAccountServiceClient_RemoveTeamAccountMember_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.RemoveTeamAccountMemberRequest]) (*connect.Response[mgmtv1alpha1.RemoveTeamAccountMemberResponse], error)) *MockUserAccountServiceClient_RemoveTeamAccountMember_Call

type MockUserAccountServiceClient_SetAccountOnboardingConfig_Call 

type MockUserAccountServiceClient_SetAccountOnboardingConfig_Call struct {
	*mock.Call
}

MockUserAccountServiceClient_SetAccountOnboardingConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetAccountOnboardingConfig'

func (*MockUserAccountServiceClient_SetAccountOnboardingConfig_Call) Return 

func (_c *MockUserAccountServiceClient_SetAccountOnboardingConfig_Call) Return(_a0 *connect.Response[mgmtv1alpha1.SetAccountOnboardingConfigResponse], _a1 error) *MockUserAccountServiceClient_SetAccountOnboardingConfig_Call

func (*MockUserAccountServiceClient_SetAccountOnboardingConfig_Call) Run 

func (_c *MockUserAccountServiceClient_SetAccountOnboardingConfig_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.SetAccountOnboardingConfigRequest])) *MockUserAccountServiceClient_SetAccountOnboardingConfig_Call

func (*MockUserAccountServiceClient_SetAccountOnboardingConfig_Call) RunAndReturn 

func (_c *MockUserAccountServiceClient_SetAccountOnboardingConfig_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.SetAccountOnboardingConfigRequest]) (*connect.Response[mgmtv1alpha1.SetAccountOnboardingConfigResponse], error)) *MockUserAccountServiceClient_SetAccountOnboardingConfig_Call

type MockUserAccountServiceClient_SetAccountTemporalConfig_Call 

type MockUserAccountServiceClient_SetAccountTemporalConfig_Call struct {
	*mock.Call
}

MockUserAccountServiceClient_SetAccountTemporalConfig_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetAccountTemporalConfig'

func (*MockUserAccountServiceClient_SetAccountTemporalConfig_Call) Return 

func (_c *MockUserAccountServiceClient_SetAccountTemporalConfig_Call) Return(_a0 *connect.Response[mgmtv1alpha1.SetAccountTemporalConfigResponse], _a1 error) *MockUserAccountServiceClient_SetAccountTemporalConfig_Call

func (*MockUserAccountServiceClient_SetAccountTemporalConfig_Call) Run 

func (_c *MockUserAccountServiceClient_SetAccountTemporalConfig_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.SetAccountTemporalConfigRequest])) *MockUserAccountServiceClient_SetAccountTemporalConfig_Call

func (*MockUserAccountServiceClient_SetAccountTemporalConfig_Call) RunAndReturn 

func (_c *MockUserAccountServiceClient_SetAccountTemporalConfig_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.SetAccountTemporalConfigRequest]) (*connect.Response[mgmtv1alpha1.SetAccountTemporalConfigResponse], error)) *MockUserAccountServiceClient_SetAccountTemporalConfig_Call

type MockUserAccountServiceClient_SetPersonalAccount_Call 

type MockUserAccountServiceClient_SetPersonalAccount_Call struct {
	*mock.Call
}

MockUserAccountServiceClient_SetPersonalAccount_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetPersonalAccount'

func (*MockUserAccountServiceClient_SetPersonalAccount_Call) Return 

func (_c *MockUserAccountServiceClient_SetPersonalAccount_Call) Return(_a0 *connect.Response[mgmtv1alpha1.SetPersonalAccountResponse], _a1 error) *MockUserAccountServiceClient_SetPersonalAccount_Call

func (*MockUserAccountServiceClient_SetPersonalAccount_Call) Run 

func (_c *MockUserAccountServiceClient_SetPersonalAccount_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.SetPersonalAccountRequest])) *MockUserAccountServiceClient_SetPersonalAccount_Call

func (*MockUserAccountServiceClient_SetPersonalAccount_Call) RunAndReturn 

func (_c *MockUserAccountServiceClient_SetPersonalAccount_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.SetPersonalAccountRequest]) (*connect.Response[mgmtv1alpha1.SetPersonalAccountResponse], error)) *MockUserAccountServiceClient_SetPersonalAccount_Call

type MockUserAccountServiceClient_SetUser_Call 

type MockUserAccountServiceClient_SetUser_Call struct {
	*mock.Call
}

MockUserAccountServiceClient_SetUser_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'SetUser'

func (*MockUserAccountServiceClient_SetUser_Call) Return 

func (_c *MockUserAccountServiceClient_SetUser_Call) Return(_a0 *connect.Response[mgmtv1alpha1.SetUserResponse], _a1 error) *MockUserAccountServiceClient_SetUser_Call

func (*MockUserAccountServiceClient_SetUser_Call) Run 

func (_c *MockUserAccountServiceClient_SetUser_Call) Run(run func(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.SetUserRequest])) *MockUserAccountServiceClient_SetUser_Call

func (*MockUserAccountServiceClient_SetUser_Call) RunAndReturn 

func (_c *MockUserAccountServiceClient_SetUser_Call) RunAndReturn(run func(context.Context, *connect.Request[mgmtv1alpha1.SetUserRequest]) (*connect.Response[mgmtv1alpha1.SetUserResponse], error)) *MockUserAccountServiceClient_SetUser_Call

type TransformersServiceClient 

type TransformersServiceClient interface {
	GetSystemTransformers(context.Context, *connect.Request[v1alpha1.GetSystemTransformersRequest]) (*connect.Response[v1alpha1.GetSystemTransformersResponse], error)
	GetSystemTransformerBySource(context.Context, *connect.Request[v1alpha1.GetSystemTransformerBySourceRequest]) (*connect.Response[v1alpha1.GetSystemTransformerBySourceResponse], error)
	GetUserDefinedTransformers(context.Context, *connect.Request[v1alpha1.GetUserDefinedTransformersRequest]) (*connect.Response[v1alpha1.GetUserDefinedTransformersResponse], error)
	GetUserDefinedTransformerById(context.Context, *connect.Request[v1alpha1.GetUserDefinedTransformerByIdRequest]) (*connect.Response[v1alpha1.GetUserDefinedTransformerByIdResponse], error)
	CreateUserDefinedTransformer(context.Context, *connect.Request[v1alpha1.CreateUserDefinedTransformerRequest]) (*connect.Response[v1alpha1.CreateUserDefinedTransformerResponse], error)
	DeleteUserDefinedTransformer(context.Context, *connect.Request[v1alpha1.DeleteUserDefinedTransformerRequest]) (*connect.Response[v1alpha1.DeleteUserDefinedTransformerResponse], error)
	UpdateUserDefinedTransformer(context.Context, *connect.Request[v1alpha1.UpdateUserDefinedTransformerRequest]) (*connect.Response[v1alpha1.UpdateUserDefinedTransformerResponse], error)
	IsTransformerNameAvailable(context.Context, *connect.Request[v1alpha1.IsTransformerNameAvailableRequest]) (*connect.Response[v1alpha1.IsTransformerNameAvailableResponse], error)
	ValidateUserJavascriptCode(context.Context, *connect.Request[v1alpha1.ValidateUserJavascriptCodeRequest]) (*connect.Response[v1alpha1.ValidateUserJavascriptCodeResponse], error)
	ValidateUserRegexCode(context.Context, *connect.Request[v1alpha1.ValidateUserRegexCodeRequest]) (*connect.Response[v1alpha1.ValidateUserRegexCodeResponse], error)
}

TransformersServiceClient is a client for the mgmt.v1alpha1.TransformersService service.

func NewTransformersServiceClient 

func NewTransformersServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) TransformersServiceClient

NewTransformersServiceClient constructs a client for the mgmt.v1alpha1.TransformersService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type TransformersServiceHandler 

type TransformersServiceHandler interface {
	GetSystemTransformers(context.Context, *connect.Request[v1alpha1.GetSystemTransformersRequest]) (*connect.Response[v1alpha1.GetSystemTransformersResponse], error)
	GetSystemTransformerBySource(context.Context, *connect.Request[v1alpha1.GetSystemTransformerBySourceRequest]) (*connect.Response[v1alpha1.GetSystemTransformerBySourceResponse], error)
	GetUserDefinedTransformers(context.Context, *connect.Request[v1alpha1.GetUserDefinedTransformersRequest]) (*connect.Response[v1alpha1.GetUserDefinedTransformersResponse], error)
	GetUserDefinedTransformerById(context.Context, *connect.Request[v1alpha1.GetUserDefinedTransformerByIdRequest]) (*connect.Response[v1alpha1.GetUserDefinedTransformerByIdResponse], error)
	CreateUserDefinedTransformer(context.Context, *connect.Request[v1alpha1.CreateUserDefinedTransformerRequest]) (*connect.Response[v1alpha1.CreateUserDefinedTransformerResponse], error)
	DeleteUserDefinedTransformer(context.Context, *connect.Request[v1alpha1.DeleteUserDefinedTransformerRequest]) (*connect.Response[v1alpha1.DeleteUserDefinedTransformerResponse], error)
	UpdateUserDefinedTransformer(context.Context, *connect.Request[v1alpha1.UpdateUserDefinedTransformerRequest]) (*connect.Response[v1alpha1.UpdateUserDefinedTransformerResponse], error)
	IsTransformerNameAvailable(context.Context, *connect.Request[v1alpha1.IsTransformerNameAvailableRequest]) (*connect.Response[v1alpha1.IsTransformerNameAvailableResponse], error)
	ValidateUserJavascriptCode(context.Context, *connect.Request[v1alpha1.ValidateUserJavascriptCodeRequest]) (*connect.Response[v1alpha1.ValidateUserJavascriptCodeResponse], error)
	ValidateUserRegexCode(context.Context, *connect.Request[v1alpha1.ValidateUserRegexCodeRequest]) (*connect.Response[v1alpha1.ValidateUserRegexCodeResponse], error)
}

TransformersServiceHandler is an implementation of the mgmt.v1alpha1.TransformersService service.

type UnimplementedApiKeyServiceHandler 

type UnimplementedApiKeyServiceHandler struct{}

UnimplementedApiKeyServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedApiKeyServiceHandler) CreateAccountApiKey 

func (UnimplementedApiKeyServiceHandler) CreateAccountApiKey(context.Context, *connect.Request[v1alpha1.CreateAccountApiKeyRequest]) (*connect.Response[v1alpha1.CreateAccountApiKeyResponse], error)

func (UnimplementedApiKeyServiceHandler) DeleteAccountApiKey 

func (UnimplementedApiKeyServiceHandler) DeleteAccountApiKey(context.Context, *connect.Request[v1alpha1.DeleteAccountApiKeyRequest]) (*connect.Response[v1alpha1.DeleteAccountApiKeyResponse], error)

func (UnimplementedApiKeyServiceHandler) GetAccountApiKey 

func (UnimplementedApiKeyServiceHandler) GetAccountApiKey(context.Context, *connect.Request[v1alpha1.GetAccountApiKeyRequest]) (*connect.Response[v1alpha1.GetAccountApiKeyResponse], error)

func (UnimplementedApiKeyServiceHandler) GetAccountApiKeys 

func (UnimplementedApiKeyServiceHandler) GetAccountApiKeys(context.Context, *connect.Request[v1alpha1.GetAccountApiKeysRequest]) (*connect.Response[v1alpha1.GetAccountApiKeysResponse], error)

func (UnimplementedApiKeyServiceHandler) RegenerateAccountApiKey 

func (UnimplementedApiKeyServiceHandler) RegenerateAccountApiKey(context.Context, *connect.Request[v1alpha1.RegenerateAccountApiKeyRequest]) (*connect.Response[v1alpha1.RegenerateAccountApiKeyResponse], error)

type UnimplementedAuthServiceHandler 

type UnimplementedAuthServiceHandler struct{}

UnimplementedAuthServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedAuthServiceHandler) CheckToken 

func (UnimplementedAuthServiceHandler) CheckToken(context.Context, *connect.Request[v1alpha1.CheckTokenRequest]) (*connect.Response[v1alpha1.CheckTokenResponse], error)

func (UnimplementedAuthServiceHandler) GetAuthStatus 

func (UnimplementedAuthServiceHandler) GetAuthStatus(context.Context, *connect.Request[v1alpha1.GetAuthStatusRequest]) (*connect.Response[v1alpha1.GetAuthStatusResponse], error)

func (UnimplementedAuthServiceHandler) GetAuthorizeUrl 

func (UnimplementedAuthServiceHandler) GetAuthorizeUrl(context.Context, *connect.Request[v1alpha1.GetAuthorizeUrlRequest]) (*connect.Response[v1alpha1.GetAuthorizeUrlResponse], error)

func (UnimplementedAuthServiceHandler) GetCliIssuer 

func (UnimplementedAuthServiceHandler) GetCliIssuer(context.Context, *connect.Request[v1alpha1.GetCliIssuerRequest]) (*connect.Response[v1alpha1.GetCliIssuerResponse], error)

func (UnimplementedAuthServiceHandler) LoginCli 

func (UnimplementedAuthServiceHandler) LoginCli(context.Context, *connect.Request[v1alpha1.LoginCliRequest]) (*connect.Response[v1alpha1.LoginCliResponse], error)

func (UnimplementedAuthServiceHandler) RefreshCli 

func (UnimplementedAuthServiceHandler) RefreshCli(context.Context, *connect.Request[v1alpha1.RefreshCliRequest]) (*connect.Response[v1alpha1.RefreshCliResponse], error)

type UnimplementedConnectionDataServiceHandler 

type UnimplementedConnectionDataServiceHandler struct{}

UnimplementedConnectionDataServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedConnectionDataServiceHandler) GetAiGeneratedData 

func (UnimplementedConnectionDataServiceHandler) GetAiGeneratedData(context.Context, *connect.Request[v1alpha1.GetAiGeneratedDataRequest]) (*connect.Response[v1alpha1.GetAiGeneratedDataResponse], error)

func (UnimplementedConnectionDataServiceHandler) GetConnectionDataStream 

func (UnimplementedConnectionDataServiceHandler) GetConnectionDataStream(context.Context, *connect.Request[v1alpha1.GetConnectionDataStreamRequest], *connect.ServerStream[v1alpha1.GetConnectionDataStreamResponse]) error

func (UnimplementedConnectionDataServiceHandler) GetConnectionForeignConstraints 

func (UnimplementedConnectionDataServiceHandler) GetConnectionForeignConstraints(context.Context, *connect.Request[v1alpha1.GetConnectionForeignConstraintsRequest]) (*connect.Response[v1alpha1.GetConnectionForeignConstraintsResponse], error)

func (UnimplementedConnectionDataServiceHandler) GetConnectionInitStatements 

func (UnimplementedConnectionDataServiceHandler) GetConnectionInitStatements(context.Context, *connect.Request[v1alpha1.GetConnectionInitStatementsRequest]) (*connect.Response[v1alpha1.GetConnectionInitStatementsResponse], error)

func (UnimplementedConnectionDataServiceHandler) GetConnectionPrimaryConstraints 

func (UnimplementedConnectionDataServiceHandler) GetConnectionPrimaryConstraints(context.Context, *connect.Request[v1alpha1.GetConnectionPrimaryConstraintsRequest]) (*connect.Response[v1alpha1.GetConnectionPrimaryConstraintsResponse], error)

func (UnimplementedConnectionDataServiceHandler) GetConnectionSchema 

func (UnimplementedConnectionDataServiceHandler) GetConnectionSchema(context.Context, *connect.Request[v1alpha1.GetConnectionSchemaRequest]) (*connect.Response[v1alpha1.GetConnectionSchemaResponse], error)

func (UnimplementedConnectionDataServiceHandler) GetConnectionSchemaMap added in v0.4.47 

func (UnimplementedConnectionDataServiceHandler) GetConnectionSchemaMap(context.Context, *connect.Request[v1alpha1.GetConnectionSchemaMapRequest]) (*connect.Response[v1alpha1.GetConnectionSchemaMapResponse], error)

func (UnimplementedConnectionDataServiceHandler) GetConnectionSchemaMaps added in v0.4.48 

func (UnimplementedConnectionDataServiceHandler) GetConnectionSchemaMaps(context.Context, *connect.Request[v1alpha1.GetConnectionSchemaMapsRequest]) (*connect.Response[v1alpha1.GetConnectionSchemaMapsResponse], error)

func (UnimplementedConnectionDataServiceHandler) GetConnectionTableConstraints added in v0.4.24 

func (UnimplementedConnectionDataServiceHandler) GetConnectionTableConstraints(context.Context, *connect.Request[v1alpha1.GetConnectionTableConstraintsRequest]) (*connect.Response[v1alpha1.GetConnectionTableConstraintsResponse], error)

func (UnimplementedConnectionDataServiceHandler) GetConnectionUniqueConstraints 

func (UnimplementedConnectionDataServiceHandler) GetConnectionUniqueConstraints(context.Context, *connect.Request[v1alpha1.GetConnectionUniqueConstraintsRequest]) (*connect.Response[v1alpha1.GetConnectionUniqueConstraintsResponse], error)

func (UnimplementedConnectionDataServiceHandler) GetTableRowCount added in v0.4.24 

func (UnimplementedConnectionDataServiceHandler) GetTableRowCount(context.Context, *connect.Request[v1alpha1.GetTableRowCountRequest]) (*connect.Response[v1alpha1.GetTableRowCountResponse], error)

type UnimplementedConnectionServiceHandler 

type UnimplementedConnectionServiceHandler struct{}

UnimplementedConnectionServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedConnectionServiceHandler) CheckConnectionConfig 

func (UnimplementedConnectionServiceHandler) CheckConnectionConfig(context.Context, *connect.Request[v1alpha1.CheckConnectionConfigRequest]) (*connect.Response[v1alpha1.CheckConnectionConfigResponse], error)

func (UnimplementedConnectionServiceHandler) CheckSqlQuery 

func (UnimplementedConnectionServiceHandler) CheckSqlQuery(context.Context, *connect.Request[v1alpha1.CheckSqlQueryRequest]) (*connect.Response[v1alpha1.CheckSqlQueryResponse], error)

func (UnimplementedConnectionServiceHandler) CreateConnection 

func (UnimplementedConnectionServiceHandler) CreateConnection(context.Context, *connect.Request[v1alpha1.CreateConnectionRequest]) (*connect.Response[v1alpha1.CreateConnectionResponse], error)

func (UnimplementedConnectionServiceHandler) DeleteConnection 

func (UnimplementedConnectionServiceHandler) DeleteConnection(context.Context, *connect.Request[v1alpha1.DeleteConnectionRequest]) (*connect.Response[v1alpha1.DeleteConnectionResponse], error)

func (UnimplementedConnectionServiceHandler) GetConnection 

func (UnimplementedConnectionServiceHandler) GetConnection(context.Context, *connect.Request[v1alpha1.GetConnectionRequest]) (*connect.Response[v1alpha1.GetConnectionResponse], error)

func (UnimplementedConnectionServiceHandler) GetConnections 

func (UnimplementedConnectionServiceHandler) GetConnections(context.Context, *connect.Request[v1alpha1.GetConnectionsRequest]) (*connect.Response[v1alpha1.GetConnectionsResponse], error)

func (UnimplementedConnectionServiceHandler) IsConnectionNameAvailable 

func (UnimplementedConnectionServiceHandler) IsConnectionNameAvailable(context.Context, *connect.Request[v1alpha1.IsConnectionNameAvailableRequest]) (*connect.Response[v1alpha1.IsConnectionNameAvailableResponse], error)

func (UnimplementedConnectionServiceHandler) UpdateConnection 

func (UnimplementedConnectionServiceHandler) UpdateConnection(context.Context, *connect.Request[v1alpha1.UpdateConnectionRequest]) (*connect.Response[v1alpha1.UpdateConnectionResponse], error)

type UnimplementedJobServiceHandler 

type UnimplementedJobServiceHandler struct{}

UnimplementedJobServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedJobServiceHandler) CancelJobRun 

func (UnimplementedJobServiceHandler) CancelJobRun(context.Context, *connect.Request[v1alpha1.CancelJobRunRequest]) (*connect.Response[v1alpha1.CancelJobRunResponse], error)

func (UnimplementedJobServiceHandler) CreateJob 

func (UnimplementedJobServiceHandler) CreateJob(context.Context, *connect.Request[v1alpha1.CreateJobRequest]) (*connect.Response[v1alpha1.CreateJobResponse], error)

func (UnimplementedJobServiceHandler) CreateJobDestinationConnections 

func (UnimplementedJobServiceHandler) CreateJobDestinationConnections(context.Context, *connect.Request[v1alpha1.CreateJobDestinationConnectionsRequest]) (*connect.Response[v1alpha1.CreateJobDestinationConnectionsResponse], error)

func (UnimplementedJobServiceHandler) CreateJobRun 

func (UnimplementedJobServiceHandler) CreateJobRun(context.Context, *connect.Request[v1alpha1.CreateJobRunRequest]) (*connect.Response[v1alpha1.CreateJobRunResponse], error)

func (UnimplementedJobServiceHandler) DeleteJob 

func (UnimplementedJobServiceHandler) DeleteJob(context.Context, *connect.Request[v1alpha1.DeleteJobRequest]) (*connect.Response[v1alpha1.DeleteJobResponse], error)

func (UnimplementedJobServiceHandler) DeleteJobDestinationConnection 

func (UnimplementedJobServiceHandler) DeleteJobDestinationConnection(context.Context, *connect.Request[v1alpha1.DeleteJobDestinationConnectionRequest]) (*connect.Response[v1alpha1.DeleteJobDestinationConnectionResponse], error)

func (UnimplementedJobServiceHandler) DeleteJobRun 

func (UnimplementedJobServiceHandler) DeleteJobRun(context.Context, *connect.Request[v1alpha1.DeleteJobRunRequest]) (*connect.Response[v1alpha1.DeleteJobRunResponse], error)

func (UnimplementedJobServiceHandler) GetJob 

func (UnimplementedJobServiceHandler) GetJob(context.Context, *connect.Request[v1alpha1.GetJobRequest]) (*connect.Response[v1alpha1.GetJobResponse], error)

func (UnimplementedJobServiceHandler) GetJobNextRuns 

func (UnimplementedJobServiceHandler) GetJobNextRuns(context.Context, *connect.Request[v1alpha1.GetJobNextRunsRequest]) (*connect.Response[v1alpha1.GetJobNextRunsResponse], error)

func (UnimplementedJobServiceHandler) GetJobRecentRuns 

func (UnimplementedJobServiceHandler) GetJobRecentRuns(context.Context, *connect.Request[v1alpha1.GetJobRecentRunsRequest]) (*connect.Response[v1alpha1.GetJobRecentRunsResponse], error)

func (UnimplementedJobServiceHandler) GetJobRun 

func (UnimplementedJobServiceHandler) GetJobRun(context.Context, *connect.Request[v1alpha1.GetJobRunRequest]) (*connect.Response[v1alpha1.GetJobRunResponse], error)

func (UnimplementedJobServiceHandler) GetJobRunEvents 

func (UnimplementedJobServiceHandler) GetJobRunEvents(context.Context, *connect.Request[v1alpha1.GetJobRunEventsRequest]) (*connect.Response[v1alpha1.GetJobRunEventsResponse], error)

func (UnimplementedJobServiceHandler) GetJobRunLogsStream 

func (UnimplementedJobServiceHandler) GetJobRunLogsStream(context.Context, *connect.Request[v1alpha1.GetJobRunLogsStreamRequest], *connect.ServerStream[v1alpha1.GetJobRunLogsStreamResponse]) error

func (UnimplementedJobServiceHandler) GetJobRuns 

func (UnimplementedJobServiceHandler) GetJobRuns(context.Context, *connect.Request[v1alpha1.GetJobRunsRequest]) (*connect.Response[v1alpha1.GetJobRunsResponse], error)

func (UnimplementedJobServiceHandler) GetJobStatus 

func (UnimplementedJobServiceHandler) GetJobStatus(context.Context, *connect.Request[v1alpha1.GetJobStatusRequest]) (*connect.Response[v1alpha1.GetJobStatusResponse], error)

func (UnimplementedJobServiceHandler) GetJobStatuses 

func (UnimplementedJobServiceHandler) GetJobStatuses(context.Context, *connect.Request[v1alpha1.GetJobStatusesRequest]) (*connect.Response[v1alpha1.GetJobStatusesResponse], error)

func (UnimplementedJobServiceHandler) GetJobs 

func (UnimplementedJobServiceHandler) GetJobs(context.Context, *connect.Request[v1alpha1.GetJobsRequest]) (*connect.Response[v1alpha1.GetJobsResponse], error)

func (UnimplementedJobServiceHandler) IsJobNameAvailable 

func (UnimplementedJobServiceHandler) IsJobNameAvailable(context.Context, *connect.Request[v1alpha1.IsJobNameAvailableRequest]) (*connect.Response[v1alpha1.IsJobNameAvailableResponse], error)

func (UnimplementedJobServiceHandler) PauseJob 

func (UnimplementedJobServiceHandler) PauseJob(context.Context, *connect.Request[v1alpha1.PauseJobRequest]) (*connect.Response[v1alpha1.PauseJobResponse], error)

func (UnimplementedJobServiceHandler) SetJobSourceSqlConnectionSubsets 

func (UnimplementedJobServiceHandler) SetJobSourceSqlConnectionSubsets(context.Context, *connect.Request[v1alpha1.SetJobSourceSqlConnectionSubsetsRequest]) (*connect.Response[v1alpha1.SetJobSourceSqlConnectionSubsetsResponse], error)

func (UnimplementedJobServiceHandler) SetJobSyncOptions 

func (UnimplementedJobServiceHandler) SetJobSyncOptions(context.Context, *connect.Request[v1alpha1.SetJobSyncOptionsRequest]) (*connect.Response[v1alpha1.SetJobSyncOptionsResponse], error)

func (UnimplementedJobServiceHandler) SetJobWorkflowOptions 

func (UnimplementedJobServiceHandler) SetJobWorkflowOptions(context.Context, *connect.Request[v1alpha1.SetJobWorkflowOptionsRequest]) (*connect.Response[v1alpha1.SetJobWorkflowOptionsResponse], error)

func (UnimplementedJobServiceHandler) TerminateJobRun 

func (UnimplementedJobServiceHandler) TerminateJobRun(context.Context, *connect.Request[v1alpha1.TerminateJobRunRequest]) (*connect.Response[v1alpha1.TerminateJobRunResponse], error)

func (UnimplementedJobServiceHandler) UpdateJobDestinationConnection 

func (UnimplementedJobServiceHandler) UpdateJobDestinationConnection(context.Context, *connect.Request[v1alpha1.UpdateJobDestinationConnectionRequest]) (*connect.Response[v1alpha1.UpdateJobDestinationConnectionResponse], error)

func (UnimplementedJobServiceHandler) UpdateJobSchedule 

func (UnimplementedJobServiceHandler) UpdateJobSchedule(context.Context, *connect.Request[v1alpha1.UpdateJobScheduleRequest]) (*connect.Response[v1alpha1.UpdateJobScheduleResponse], error)

func (UnimplementedJobServiceHandler) UpdateJobSourceConnection 

func (UnimplementedJobServiceHandler) UpdateJobSourceConnection(context.Context, *connect.Request[v1alpha1.UpdateJobSourceConnectionRequest]) (*connect.Response[v1alpha1.UpdateJobSourceConnectionResponse], error)

func (UnimplementedJobServiceHandler) ValidateJobMappings added in v0.4.24 

func (UnimplementedJobServiceHandler) ValidateJobMappings(context.Context, *connect.Request[v1alpha1.ValidateJobMappingsRequest]) (*connect.Response[v1alpha1.ValidateJobMappingsResponse], error)

type UnimplementedMetricsServiceHandler 

type UnimplementedMetricsServiceHandler struct{}

UnimplementedMetricsServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedMetricsServiceHandler) GetDailyMetricCount 

func (UnimplementedMetricsServiceHandler) GetDailyMetricCount(context.Context, *connect.Request[v1alpha1.GetDailyMetricCountRequest]) (*connect.Response[v1alpha1.GetDailyMetricCountResponse], error)

func (UnimplementedMetricsServiceHandler) GetMetricCount 

func (UnimplementedMetricsServiceHandler) GetMetricCount(context.Context, *connect.Request[v1alpha1.GetMetricCountRequest]) (*connect.Response[v1alpha1.GetMetricCountResponse], error)

type UnimplementedTransformersServiceHandler 

type UnimplementedTransformersServiceHandler struct{}

UnimplementedTransformersServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedTransformersServiceHandler) CreateUserDefinedTransformer 

func (UnimplementedTransformersServiceHandler) CreateUserDefinedTransformer(context.Context, *connect.Request[v1alpha1.CreateUserDefinedTransformerRequest]) (*connect.Response[v1alpha1.CreateUserDefinedTransformerResponse], error)

func (UnimplementedTransformersServiceHandler) DeleteUserDefinedTransformer 

func (UnimplementedTransformersServiceHandler) DeleteUserDefinedTransformer(context.Context, *connect.Request[v1alpha1.DeleteUserDefinedTransformerRequest]) (*connect.Response[v1alpha1.DeleteUserDefinedTransformerResponse], error)

func (UnimplementedTransformersServiceHandler) GetSystemTransformerBySource 

func (UnimplementedTransformersServiceHandler) GetSystemTransformerBySource(context.Context, *connect.Request[v1alpha1.GetSystemTransformerBySourceRequest]) (*connect.Response[v1alpha1.GetSystemTransformerBySourceResponse], error)

func (UnimplementedTransformersServiceHandler) GetSystemTransformers 

func (UnimplementedTransformersServiceHandler) GetSystemTransformers(context.Context, *connect.Request[v1alpha1.GetSystemTransformersRequest]) (*connect.Response[v1alpha1.GetSystemTransformersResponse], error)

func (UnimplementedTransformersServiceHandler) GetUserDefinedTransformerById 

func (UnimplementedTransformersServiceHandler) GetUserDefinedTransformerById(context.Context, *connect.Request[v1alpha1.GetUserDefinedTransformerByIdRequest]) (*connect.Response[v1alpha1.GetUserDefinedTransformerByIdResponse], error)

func (UnimplementedTransformersServiceHandler) GetUserDefinedTransformers 

func (UnimplementedTransformersServiceHandler) GetUserDefinedTransformers(context.Context, *connect.Request[v1alpha1.GetUserDefinedTransformersRequest]) (*connect.Response[v1alpha1.GetUserDefinedTransformersResponse], error)

func (UnimplementedTransformersServiceHandler) IsTransformerNameAvailable 

func (UnimplementedTransformersServiceHandler) IsTransformerNameAvailable(context.Context, *connect.Request[v1alpha1.IsTransformerNameAvailableRequest]) (*connect.Response[v1alpha1.IsTransformerNameAvailableResponse], error)

func (UnimplementedTransformersServiceHandler) UpdateUserDefinedTransformer 

func (UnimplementedTransformersServiceHandler) UpdateUserDefinedTransformer(context.Context, *connect.Request[v1alpha1.UpdateUserDefinedTransformerRequest]) (*connect.Response[v1alpha1.UpdateUserDefinedTransformerResponse], error)

func (UnimplementedTransformersServiceHandler) ValidateUserJavascriptCode 

func (UnimplementedTransformersServiceHandler) ValidateUserJavascriptCode(context.Context, *connect.Request[v1alpha1.ValidateUserJavascriptCodeRequest]) (*connect.Response[v1alpha1.ValidateUserJavascriptCodeResponse], error)

func (UnimplementedTransformersServiceHandler) ValidateUserRegexCode 

func (UnimplementedTransformersServiceHandler) ValidateUserRegexCode(context.Context, *connect.Request[v1alpha1.ValidateUserRegexCodeRequest]) (*connect.Response[v1alpha1.ValidateUserRegexCodeResponse], error)

type UnimplementedUserAccountServiceHandler 

type UnimplementedUserAccountServiceHandler struct{}

UnimplementedUserAccountServiceHandler returns CodeUnimplemented from all methods.

func (UnimplementedUserAccountServiceHandler) AcceptTeamAccountInvite 

func (UnimplementedUserAccountServiceHandler) AcceptTeamAccountInvite(context.Context, *connect.Request[v1alpha1.AcceptTeamAccountInviteRequest]) (*connect.Response[v1alpha1.AcceptTeamAccountInviteResponse], error)

func (UnimplementedUserAccountServiceHandler) ConvertPersonalToTeamAccount 

func (UnimplementedUserAccountServiceHandler) ConvertPersonalToTeamAccount(context.Context, *connect.Request[v1alpha1.ConvertPersonalToTeamAccountRequest]) (*connect.Response[v1alpha1.ConvertPersonalToTeamAccountResponse], error)

func (UnimplementedUserAccountServiceHandler) CreateTeamAccount 

func (UnimplementedUserAccountServiceHandler) CreateTeamAccount(context.Context, *connect.Request[v1alpha1.CreateTeamAccountRequest]) (*connect.Response[v1alpha1.CreateTeamAccountResponse], error)

func (UnimplementedUserAccountServiceHandler) GetAccountOnboardingConfig 

func (UnimplementedUserAccountServiceHandler) GetAccountOnboardingConfig(context.Context, *connect.Request[v1alpha1.GetAccountOnboardingConfigRequest]) (*connect.Response[v1alpha1.GetAccountOnboardingConfigResponse], error)

func (UnimplementedUserAccountServiceHandler) GetAccountTemporalConfig 

func (UnimplementedUserAccountServiceHandler) GetAccountTemporalConfig(context.Context, *connect.Request[v1alpha1.GetAccountTemporalConfigRequest]) (*connect.Response[v1alpha1.GetAccountTemporalConfigResponse], error)

func (UnimplementedUserAccountServiceHandler) GetSystemInformation 

func (UnimplementedUserAccountServiceHandler) GetSystemInformation(context.Context, *connect.Request[v1alpha1.GetSystemInformationRequest]) (*connect.Response[v1alpha1.GetSystemInformationResponse], error)

func (UnimplementedUserAccountServiceHandler) GetTeamAccountInvites 

func (UnimplementedUserAccountServiceHandler) GetTeamAccountInvites(context.Context, *connect.Request[v1alpha1.GetTeamAccountInvitesRequest]) (*connect.Response[v1alpha1.GetTeamAccountInvitesResponse], error)

func (UnimplementedUserAccountServiceHandler) GetTeamAccountMembers 

func (UnimplementedUserAccountServiceHandler) GetTeamAccountMembers(context.Context, *connect.Request[v1alpha1.GetTeamAccountMembersRequest]) (*connect.Response[v1alpha1.GetTeamAccountMembersResponse], error)

func (UnimplementedUserAccountServiceHandler) GetUser 

func (UnimplementedUserAccountServiceHandler) GetUser(context.Context, *connect.Request[v1alpha1.GetUserRequest]) (*connect.Response[v1alpha1.GetUserResponse], error)

func (UnimplementedUserAccountServiceHandler) GetUserAccounts 

func (UnimplementedUserAccountServiceHandler) GetUserAccounts(context.Context, *connect.Request[v1alpha1.GetUserAccountsRequest]) (*connect.Response[v1alpha1.GetUserAccountsResponse], error)

func (UnimplementedUserAccountServiceHandler) InviteUserToTeamAccount 

func (UnimplementedUserAccountServiceHandler) InviteUserToTeamAccount(context.Context, *connect.Request[v1alpha1.InviteUserToTeamAccountRequest]) (*connect.Response[v1alpha1.InviteUserToTeamAccountResponse], error)

func (UnimplementedUserAccountServiceHandler) IsUserInAccount 

func (UnimplementedUserAccountServiceHandler) IsUserInAccount(context.Context, *connect.Request[v1alpha1.IsUserInAccountRequest]) (*connect.Response[v1alpha1.IsUserInAccountResponse], error)

func (UnimplementedUserAccountServiceHandler) RemoveTeamAccountInvite 

func (UnimplementedUserAccountServiceHandler) RemoveTeamAccountInvite(context.Context, *connect.Request[v1alpha1.RemoveTeamAccountInviteRequest]) (*connect.Response[v1alpha1.RemoveTeamAccountInviteResponse], error)

func (UnimplementedUserAccountServiceHandler) RemoveTeamAccountMember 

func (UnimplementedUserAccountServiceHandler) RemoveTeamAccountMember(context.Context, *connect.Request[v1alpha1.RemoveTeamAccountMemberRequest]) (*connect.Response[v1alpha1.RemoveTeamAccountMemberResponse], error)

func (UnimplementedUserAccountServiceHandler) SetAccountOnboardingConfig 

func (UnimplementedUserAccountServiceHandler) SetAccountOnboardingConfig(context.Context, *connect.Request[v1alpha1.SetAccountOnboardingConfigRequest]) (*connect.Response[v1alpha1.SetAccountOnboardingConfigResponse], error)

func (UnimplementedUserAccountServiceHandler) SetAccountTemporalConfig 

func (UnimplementedUserAccountServiceHandler) SetAccountTemporalConfig(context.Context, *connect.Request[v1alpha1.SetAccountTemporalConfigRequest]) (*connect.Response[v1alpha1.SetAccountTemporalConfigResponse], error)

func (UnimplementedUserAccountServiceHandler) SetPersonalAccount 

func (UnimplementedUserAccountServiceHandler) SetPersonalAccount(context.Context, *connect.Request[v1alpha1.SetPersonalAccountRequest]) (*connect.Response[v1alpha1.SetPersonalAccountResponse], error)

func (UnimplementedUserAccountServiceHandler) SetUser 

func (UnimplementedUserAccountServiceHandler) SetUser(context.Context, *connect.Request[v1alpha1.SetUserRequest]) (*connect.Response[v1alpha1.SetUserResponse], error)

type UserAccountServiceClient 

type UserAccountServiceClient interface {
	GetUser(context.Context, *connect.Request[v1alpha1.GetUserRequest]) (*connect.Response[v1alpha1.GetUserResponse], error)
	SetUser(context.Context, *connect.Request[v1alpha1.SetUserRequest]) (*connect.Response[v1alpha1.SetUserResponse], error)
	GetUserAccounts(context.Context, *connect.Request[v1alpha1.GetUserAccountsRequest]) (*connect.Response[v1alpha1.GetUserAccountsResponse], error)
	SetPersonalAccount(context.Context, *connect.Request[v1alpha1.SetPersonalAccountRequest]) (*connect.Response[v1alpha1.SetPersonalAccountResponse], error)
	ConvertPersonalToTeamAccount(context.Context, *connect.Request[v1alpha1.ConvertPersonalToTeamAccountRequest]) (*connect.Response[v1alpha1.ConvertPersonalToTeamAccountResponse], error)
	CreateTeamAccount(context.Context, *connect.Request[v1alpha1.CreateTeamAccountRequest]) (*connect.Response[v1alpha1.CreateTeamAccountResponse], error)
	IsUserInAccount(context.Context, *connect.Request[v1alpha1.IsUserInAccountRequest]) (*connect.Response[v1alpha1.IsUserInAccountResponse], error)
	GetAccountTemporalConfig(context.Context, *connect.Request[v1alpha1.GetAccountTemporalConfigRequest]) (*connect.Response[v1alpha1.GetAccountTemporalConfigResponse], error)
	SetAccountTemporalConfig(context.Context, *connect.Request[v1alpha1.SetAccountTemporalConfigRequest]) (*connect.Response[v1alpha1.SetAccountTemporalConfigResponse], error)
	GetTeamAccountMembers(context.Context, *connect.Request[v1alpha1.GetTeamAccountMembersRequest]) (*connect.Response[v1alpha1.GetTeamAccountMembersResponse], error)
	RemoveTeamAccountMember(context.Context, *connect.Request[v1alpha1.RemoveTeamAccountMemberRequest]) (*connect.Response[v1alpha1.RemoveTeamAccountMemberResponse], error)
	InviteUserToTeamAccount(context.Context, *connect.Request[v1alpha1.InviteUserToTeamAccountRequest]) (*connect.Response[v1alpha1.InviteUserToTeamAccountResponse], error)
	GetTeamAccountInvites(context.Context, *connect.Request[v1alpha1.GetTeamAccountInvitesRequest]) (*connect.Response[v1alpha1.GetTeamAccountInvitesResponse], error)
	RemoveTeamAccountInvite(context.Context, *connect.Request[v1alpha1.RemoveTeamAccountInviteRequest]) (*connect.Response[v1alpha1.RemoveTeamAccountInviteResponse], error)
	AcceptTeamAccountInvite(context.Context, *connect.Request[v1alpha1.AcceptTeamAccountInviteRequest]) (*connect.Response[v1alpha1.AcceptTeamAccountInviteResponse], error)
	GetSystemInformation(context.Context, *connect.Request[v1alpha1.GetSystemInformationRequest]) (*connect.Response[v1alpha1.GetSystemInformationResponse], error)
	GetAccountOnboardingConfig(context.Context, *connect.Request[v1alpha1.GetAccountOnboardingConfigRequest]) (*connect.Response[v1alpha1.GetAccountOnboardingConfigResponse], error)
	SetAccountOnboardingConfig(context.Context, *connect.Request[v1alpha1.SetAccountOnboardingConfigRequest]) (*connect.Response[v1alpha1.SetAccountOnboardingConfigResponse], error)
}

UserAccountServiceClient is a client for the mgmt.v1alpha1.UserAccountService service.

func NewUserAccountServiceClient 

func NewUserAccountServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) UserAccountServiceClient

NewUserAccountServiceClient constructs a client for the mgmt.v1alpha1.UserAccountService service. By default, it uses the Connect protocol with the binary Protobuf Codec, asks for gzipped responses, and sends uncompressed requests. To use the gRPC or gRPC-Web protocols, supply the connect.WithGRPC() or connect.WithGRPCWeb() options.

The URL supplied here should be the base URL for the Connect or gRPC server (for example, http://api.acme.com or https://acme.com/grpc).

type UserAccountServiceHandler 

type UserAccountServiceHandler interface {
	GetUser(context.Context, *connect.Request[v1alpha1.GetUserRequest]) (*connect.Response[v1alpha1.GetUserResponse], error)
	SetUser(context.Context, *connect.Request[v1alpha1.SetUserRequest]) (*connect.Response[v1alpha1.SetUserResponse], error)
	GetUserAccounts(context.Context, *connect.Request[v1alpha1.GetUserAccountsRequest]) (*connect.Response[v1alpha1.GetUserAccountsResponse], error)
	SetPersonalAccount(context.Context, *connect.Request[v1alpha1.SetPersonalAccountRequest]) (*connect.Response[v1alpha1.SetPersonalAccountResponse], error)
	ConvertPersonalToTeamAccount(context.Context, *connect.Request[v1alpha1.ConvertPersonalToTeamAccountRequest]) (*connect.Response[v1alpha1.ConvertPersonalToTeamAccountResponse], error)
	CreateTeamAccount(context.Context, *connect.Request[v1alpha1.CreateTeamAccountRequest]) (*connect.Response[v1alpha1.CreateTeamAccountResponse], error)
	IsUserInAccount(context.Context, *connect.Request[v1alpha1.IsUserInAccountRequest]) (*connect.Response[v1alpha1.IsUserInAccountResponse], error)
	GetAccountTemporalConfig(context.Context, *connect.Request[v1alpha1.GetAccountTemporalConfigRequest]) (*connect.Response[v1alpha1.GetAccountTemporalConfigResponse], error)
	SetAccountTemporalConfig(context.Context, *connect.Request[v1alpha1.SetAccountTemporalConfigRequest]) (*connect.Response[v1alpha1.SetAccountTemporalConfigResponse], error)
	GetTeamAccountMembers(context.Context, *connect.Request[v1alpha1.GetTeamAccountMembersRequest]) (*connect.Response[v1alpha1.GetTeamAccountMembersResponse], error)
	RemoveTeamAccountMember(context.Context, *connect.Request[v1alpha1.RemoveTeamAccountMemberRequest]) (*connect.Response[v1alpha1.RemoveTeamAccountMemberResponse], error)
	InviteUserToTeamAccount(context.Context, *connect.Request[v1alpha1.InviteUserToTeamAccountRequest]) (*connect.Response[v1alpha1.InviteUserToTeamAccountResponse], error)
	GetTeamAccountInvites(context.Context, *connect.Request[v1alpha1.GetTeamAccountInvitesRequest]) (*connect.Response[v1alpha1.GetTeamAccountInvitesResponse], error)
	RemoveTeamAccountInvite(context.Context, *connect.Request[v1alpha1.RemoveTeamAccountInviteRequest]) (*connect.Response[v1alpha1.RemoveTeamAccountInviteResponse], error)
	AcceptTeamAccountInvite(context.Context, *connect.Request[v1alpha1.AcceptTeamAccountInviteRequest]) (*connect.Response[v1alpha1.AcceptTeamAccountInviteResponse], error)
	GetSystemInformation(context.Context, *connect.Request[v1alpha1.GetSystemInformationRequest]) (*connect.Response[v1alpha1.GetSystemInformationResponse], error)
	GetAccountOnboardingConfig(context.Context, *connect.Request[v1alpha1.GetAccountOnboardingConfigRequest]) (*connect.Response[v1alpha1.GetAccountOnboardingConfigResponse], error)
	SetAccountOnboardingConfig(context.Context, *connect.Request[v1alpha1.SetAccountOnboardingConfigRequest]) (*connect.Response[v1alpha1.SetAccountOnboardingConfigResponse], error)
}

UserAccountServiceHandler is an implementation of the mgmt.v1alpha1.UserAccountService service.

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.