mgmtv1alpha1connect

package

Go to main page

Versions in this module

v0

v0.5.3

Jan 13, 2025

v0.5.2

Jan 10, 2025

v0.5.1

Jan 6, 2025

v0.5.0

Jan 3, 2025

v0.4.99

Dec 12, 2024

v0.4.98

Dec 10, 2024

v0.4.97

Dec 10, 2024

v0.4.96

Dec 5, 2024

v0.4.95

Dec 5, 2024

v0.4.94

Dec 4, 2024

v0.4.93

Nov 26, 2024

v0.4.92

Nov 21, 2024

v0.4.91

Nov 21, 2024

v0.4.90

Nov 20, 2024

v0.4.89

Nov 19, 2024

v0.4.87

Nov 13, 2024

v0.4.86

Nov 8, 2024

v0.4.85

Nov 6, 2024

v0.4.84

Nov 1, 2024

v0.4.83

Oct 25, 2024

v0.4.82

Oct 24, 2024

v0.4.81

Oct 24, 2024

v0.4.80

Oct 22, 2024

v0.4.79

Oct 16, 2024

v0.4.78

Oct 11, 2024

Changes in this version

+ const AnonymizationServiceAnonymizeManyProcedure

+ const AnonymizationServiceAnonymizeSingleProcedure

+ const AnonymizationServiceName

+ func NewAnonymizationServiceHandler(svc AnonymizationServiceHandler, opts ...connect.HandlerOption) (string, http.Handler)

+ type AnonymizationServiceClient interface

+ AnonymizeMany func(context.Context, *connect.Request[v1alpha1.AnonymizeManyRequest]) (*connect.Response[v1alpha1.AnonymizeManyResponse], error)

+ AnonymizeSingle func(context.Context, *connect.Request[v1alpha1.AnonymizeSingleRequest]) (*connect.Response[v1alpha1.AnonymizeSingleResponse], error)

+ func NewAnonymizationServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) AnonymizationServiceClient

+ type AnonymizationServiceHandler interface

+ AnonymizeMany func(context.Context, *connect.Request[v1alpha1.AnonymizeManyRequest]) (*connect.Response[v1alpha1.AnonymizeManyResponse], error)

+ AnonymizeSingle func(context.Context, *connect.Request[v1alpha1.AnonymizeSingleRequest]) (*connect.Response[v1alpha1.AnonymizeSingleResponse], error)

+ type UnimplementedAnonymizationServiceHandler struct

+ func (UnimplementedAnonymizationServiceHandler) AnonymizeMany(context.Context, *connect.Request[v1alpha1.AnonymizeManyRequest]) (*connect.Response[v1alpha1.AnonymizeManyResponse], error)

+ func (UnimplementedAnonymizationServiceHandler) AnonymizeSingle(context.Context, *connect.Request[v1alpha1.AnonymizeSingleRequest]) (*connect.Response[v1alpha1.AnonymizeSingleResponse], error)

v0.4.77

Oct 9, 2024

v0.4.76

Oct 8, 2024

v0.4.75

Oct 7, 2024

v0.4.74

Oct 3, 2024

v0.4.73

Oct 2, 2024

v0.4.72

Oct 1, 2024

v0.4.71

Sep 26, 2024

Changes in this version

+ const UserAccountServiceGetBillingAccountsProcedure

+ const UserAccountServiceSetBillingMeterEventProcedure

type MockUserAccountServiceClient

+ func (_m *MockUserAccountServiceClient) GetBillingAccounts(_a0 context.Context, ...) (*connect.Response[mgmtv1alpha1.GetBillingAccountsResponse], error)

+ func (_m *MockUserAccountServiceClient) SetBillingMeterEvent(_a0 context.Context, ...) (*connect.Response[mgmtv1alpha1.SetBillingMeterEventResponse], error)

type MockUserAccountServiceClient_Expecter

+ func (_e *MockUserAccountServiceClient_Expecter) GetBillingAccounts(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_GetBillingAccounts_Call

+ func (_e *MockUserAccountServiceClient_Expecter) SetBillingMeterEvent(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_SetBillingMeterEvent_Call

+ type MockUserAccountServiceClient_GetBillingAccounts_Call struct

+ func (_c *MockUserAccountServiceClient_GetBillingAccounts_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetBillingAccountsResponse], _a1 error) *MockUserAccountServiceClient_GetBillingAccounts_Call

+ func (_c *MockUserAccountServiceClient_GetBillingAccounts_Call) Run(run func(_a0 context.Context, ...)) *MockUserAccountServiceClient_GetBillingAccounts_Call

+ func (_c *MockUserAccountServiceClient_GetBillingAccounts_Call) RunAndReturn(...) *MockUserAccountServiceClient_GetBillingAccounts_Call

+ type MockUserAccountServiceClient_SetBillingMeterEvent_Call struct

+ func (_c *MockUserAccountServiceClient_SetBillingMeterEvent_Call) Return(_a0 *connect.Response[mgmtv1alpha1.SetBillingMeterEventResponse], _a1 error) *MockUserAccountServiceClient_SetBillingMeterEvent_Call

+ func (_c *MockUserAccountServiceClient_SetBillingMeterEvent_Call) Run(run func(_a0 context.Context, ...)) *MockUserAccountServiceClient_SetBillingMeterEvent_Call

+ func (_c *MockUserAccountServiceClient_SetBillingMeterEvent_Call) RunAndReturn(...) *MockUserAccountServiceClient_SetBillingMeterEvent_Call

type UnimplementedUserAccountServiceHandler

+ func (UnimplementedUserAccountServiceHandler) GetBillingAccounts(context.Context, *connect.Request[v1alpha1.GetBillingAccountsRequest]) (*connect.Response[v1alpha1.GetBillingAccountsResponse], error)

+ func (UnimplementedUserAccountServiceHandler) SetBillingMeterEvent(context.Context, *connect.Request[v1alpha1.SetBillingMeterEventRequest]) (*connect.Response[v1alpha1.SetBillingMeterEventResponse], error)

type UserAccountServiceClient

+ GetBillingAccounts func(context.Context, *connect.Request[v1alpha1.GetBillingAccountsRequest]) (*connect.Response[v1alpha1.GetBillingAccountsResponse], error)

+ SetBillingMeterEvent func(context.Context, *connect.Request[v1alpha1.SetBillingMeterEventRequest]) (*connect.Response[v1alpha1.SetBillingMeterEventResponse], error)

type UserAccountServiceHandler

+ GetBillingAccounts func(context.Context, *connect.Request[v1alpha1.GetBillingAccountsRequest]) (*connect.Response[v1alpha1.GetBillingAccountsResponse], error)

+ SetBillingMeterEvent func(context.Context, *connect.Request[v1alpha1.SetBillingMeterEventRequest]) (*connect.Response[v1alpha1.SetBillingMeterEventResponse], error)

v0.4.70

Sep 25, 2024

Changes in this version

+ const UserAccountServiceGetAccountBillingCheckoutSessionProcedure

+ const UserAccountServiceGetAccountBillingPortalSessionProcedure

type MockUserAccountServiceClient

+ func (_m *MockUserAccountServiceClient) GetAccountBillingCheckoutSession(_a0 context.Context, ...) (*connect.Response[mgmtv1alpha1.GetAccountBillingCheckoutSessionResponse], ...)

+ func (_m *MockUserAccountServiceClient) GetAccountBillingPortalSession(_a0 context.Context, ...) (*connect.Response[mgmtv1alpha1.GetAccountBillingPortalSessionResponse], error)

type MockUserAccountServiceClient_Expecter

+ func (_e *MockUserAccountServiceClient_Expecter) GetAccountBillingCheckoutSession(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_GetAccountBillingCheckoutSession_Call

+ func (_e *MockUserAccountServiceClient_Expecter) GetAccountBillingPortalSession(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_GetAccountBillingPortalSession_Call

+ type MockUserAccountServiceClient_GetAccountBillingCheckoutSession_Call struct

+ func (_c *MockUserAccountServiceClient_GetAccountBillingCheckoutSession_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetAccountBillingCheckoutSessionResponse], ...) *MockUserAccountServiceClient_GetAccountBillingCheckoutSession_Call

+ func (_c *MockUserAccountServiceClient_GetAccountBillingCheckoutSession_Call) Run(run func(_a0 context.Context, ...)) *MockUserAccountServiceClient_GetAccountBillingCheckoutSession_Call

+ func (_c *MockUserAccountServiceClient_GetAccountBillingCheckoutSession_Call) RunAndReturn(...) *MockUserAccountServiceClient_GetAccountBillingCheckoutSession_Call

+ type MockUserAccountServiceClient_GetAccountBillingPortalSession_Call struct

+ func (_c *MockUserAccountServiceClient_GetAccountBillingPortalSession_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetAccountBillingPortalSessionResponse], ...) *MockUserAccountServiceClient_GetAccountBillingPortalSession_Call

+ func (_c *MockUserAccountServiceClient_GetAccountBillingPortalSession_Call) Run(run func(_a0 context.Context, ...)) *MockUserAccountServiceClient_GetAccountBillingPortalSession_Call

+ func (_c *MockUserAccountServiceClient_GetAccountBillingPortalSession_Call) RunAndReturn(...) *MockUserAccountServiceClient_GetAccountBillingPortalSession_Call

type UnimplementedUserAccountServiceHandler

+ func (UnimplementedUserAccountServiceHandler) GetAccountBillingCheckoutSession(context.Context, ...) (*connect.Response[v1alpha1.GetAccountBillingCheckoutSessionResponse], error)

+ func (UnimplementedUserAccountServiceHandler) GetAccountBillingPortalSession(context.Context, ...) (*connect.Response[v1alpha1.GetAccountBillingPortalSessionResponse], error)

type UserAccountServiceClient

+ GetAccountBillingCheckoutSession func(context.Context, ...) (*connect.Response[v1alpha1.GetAccountBillingCheckoutSessionResponse], error)

+ GetAccountBillingPortalSession func(context.Context, ...) (*connect.Response[v1alpha1.GetAccountBillingPortalSessionResponse], error)

type UserAccountServiceHandler

+ GetAccountBillingCheckoutSession func(context.Context, ...) (*connect.Response[v1alpha1.GetAccountBillingCheckoutSessionResponse], error)

+ GetAccountBillingPortalSession func(context.Context, ...) (*connect.Response[v1alpha1.GetAccountBillingPortalSessionResponse], error)

v0.4.69

Sep 19, 2024

v0.4.68

Sep 17, 2024

v0.4.67

Sep 16, 2024

v0.4.66

Sep 12, 2024

v0.4.65

Sep 11, 2024

Changes in this version

+ const UserAccountServiceGetAccountStatusProcedure

+ const UserAccountServiceIsAccountStatusValidProcedure

type MockUserAccountServiceClient

+ func (_m *MockUserAccountServiceClient) GetAccountStatus(_a0 context.Context, ...) (*connect.Response[mgmtv1alpha1.GetAccountStatusResponse], error)

+ func (_m *MockUserAccountServiceClient) IsAccountStatusValid(_a0 context.Context, ...) (*connect.Response[mgmtv1alpha1.IsAccountStatusValidResponse], error)

type MockUserAccountServiceClient_Expecter

+ func (_e *MockUserAccountServiceClient_Expecter) GetAccountStatus(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_GetAccountStatus_Call

+ func (_e *MockUserAccountServiceClient_Expecter) IsAccountStatusValid(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_IsAccountStatusValid_Call

+ type MockUserAccountServiceClient_GetAccountStatus_Call struct

+ func (_c *MockUserAccountServiceClient_GetAccountStatus_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetAccountStatusResponse], _a1 error) *MockUserAccountServiceClient_GetAccountStatus_Call

+ func (_c *MockUserAccountServiceClient_GetAccountStatus_Call) Run(run func(_a0 context.Context, ...)) *MockUserAccountServiceClient_GetAccountStatus_Call

+ func (_c *MockUserAccountServiceClient_GetAccountStatus_Call) RunAndReturn(...) *MockUserAccountServiceClient_GetAccountStatus_Call

+ type MockUserAccountServiceClient_IsAccountStatusValid_Call struct

+ func (_c *MockUserAccountServiceClient_IsAccountStatusValid_Call) Return(_a0 *connect.Response[mgmtv1alpha1.IsAccountStatusValidResponse], _a1 error) *MockUserAccountServiceClient_IsAccountStatusValid_Call

+ func (_c *MockUserAccountServiceClient_IsAccountStatusValid_Call) Run(run func(_a0 context.Context, ...)) *MockUserAccountServiceClient_IsAccountStatusValid_Call

+ func (_c *MockUserAccountServiceClient_IsAccountStatusValid_Call) RunAndReturn(...) *MockUserAccountServiceClient_IsAccountStatusValid_Call

type UnimplementedUserAccountServiceHandler

+ func (UnimplementedUserAccountServiceHandler) GetAccountStatus(context.Context, *connect.Request[v1alpha1.GetAccountStatusRequest]) (*connect.Response[v1alpha1.GetAccountStatusResponse], error)

+ func (UnimplementedUserAccountServiceHandler) IsAccountStatusValid(context.Context, *connect.Request[v1alpha1.IsAccountStatusValidRequest]) (*connect.Response[v1alpha1.IsAccountStatusValidResponse], error)

type UserAccountServiceClient

+ GetAccountStatus func(context.Context, *connect.Request[v1alpha1.GetAccountStatusRequest]) (*connect.Response[v1alpha1.GetAccountStatusResponse], error)

+ IsAccountStatusValid func(context.Context, *connect.Request[v1alpha1.IsAccountStatusValidRequest]) (*connect.Response[v1alpha1.IsAccountStatusValidResponse], error)

type UserAccountServiceHandler

+ GetAccountStatus func(context.Context, *connect.Request[v1alpha1.GetAccountStatusRequest]) (*connect.Response[v1alpha1.GetAccountStatusResponse], error)

+ IsAccountStatusValid func(context.Context, *connect.Request[v1alpha1.IsAccountStatusValidRequest]) (*connect.Response[v1alpha1.IsAccountStatusValidResponse], error)

v0.4.64

Sep 6, 2024

v0.4.63

Sep 6, 2024

v0.4.62

Sep 5, 2024

Changes in this version

+ const ConnectionServiceCheckConnectionConfigByIdProcedure

type ConnectionServiceClient

+ CheckConnectionConfigById func(context.Context, *connect.Request[v1alpha1.CheckConnectionConfigByIdRequest]) (*connect.Response[v1alpha1.CheckConnectionConfigByIdResponse], error)

type ConnectionServiceHandler

+ CheckConnectionConfigById func(context.Context, *connect.Request[v1alpha1.CheckConnectionConfigByIdRequest]) (*connect.Response[v1alpha1.CheckConnectionConfigByIdResponse], error)

type MockConnectionServiceClient

+ func (_m *MockConnectionServiceClient) CheckConnectionConfigById(_a0 context.Context, ...) (*connect.Response[mgmtv1alpha1.CheckConnectionConfigByIdResponse], error)

+ type MockConnectionServiceClient_CheckConnectionConfigById_Call struct

+ func (_c *MockConnectionServiceClient_CheckConnectionConfigById_Call) Return(_a0 *connect.Response[mgmtv1alpha1.CheckConnectionConfigByIdResponse], ...) *MockConnectionServiceClient_CheckConnectionConfigById_Call

+ func (_c *MockConnectionServiceClient_CheckConnectionConfigById_Call) Run(run func(_a0 context.Context, ...)) *MockConnectionServiceClient_CheckConnectionConfigById_Call

+ func (_c *MockConnectionServiceClient_CheckConnectionConfigById_Call) RunAndReturn(...) *MockConnectionServiceClient_CheckConnectionConfigById_Call

type MockConnectionServiceClient_Expecter

+ func (_e *MockConnectionServiceClient_Expecter) CheckConnectionConfigById(_a0 interface{}, _a1 interface{}) *MockConnectionServiceClient_CheckConnectionConfigById_Call

type UnimplementedConnectionServiceHandler

+ func (UnimplementedConnectionServiceHandler) CheckConnectionConfigById(context.Context, *connect.Request[v1alpha1.CheckConnectionConfigByIdRequest]) (*connect.Response[v1alpha1.CheckConnectionConfigByIdResponse], error)

v0.4.61

Sep 4, 2024

v0.4.60

Sep 4, 2024

v0.4.59

Sep 4, 2024

v0.4.58

Aug 29, 2024

v0.4.57

Aug 28, 2024

v0.4.56

Aug 23, 2024

v0.4.55

Aug 23, 2024

v0.4.54

Aug 22, 2024

Changes in this version

+ const JobServiceGetRunContextProcedure

+ const JobServiceSetRunContextProcedure

+ const JobServiceSetRunContextsProcedure

type JobServiceClient

+ GetRunContext func(context.Context, *connect.Request[v1alpha1.GetRunContextRequest]) (*connect.Response[v1alpha1.GetRunContextResponse], error)

+ SetRunContext func(context.Context, *connect.Request[v1alpha1.SetRunContextRequest]) (*connect.Response[v1alpha1.SetRunContextResponse], error)

+ SetRunContexts func(context.Context) ...

type JobServiceHandler

+ GetRunContext func(context.Context, *connect.Request[v1alpha1.GetRunContextRequest]) (*connect.Response[v1alpha1.GetRunContextResponse], error)

+ SetRunContext func(context.Context, *connect.Request[v1alpha1.SetRunContextRequest]) (*connect.Response[v1alpha1.SetRunContextResponse], error)

+ SetRunContexts func(context.Context, *connect.ClientStream[v1alpha1.SetRunContextsRequest]) (*connect.Response[v1alpha1.SetRunContextsResponse], error)

type MockJobServiceClient

+ func (_m *MockJobServiceClient) GetRunContext(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetRunContextRequest]) (*connect.Response[mgmtv1alpha1.GetRunContextResponse], error)

+ func (_m *MockJobServiceClient) SetRunContext(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.SetRunContextRequest]) (*connect.Response[mgmtv1alpha1.SetRunContextResponse], error)

+ func (_m *MockJobServiceClient) SetRunContexts(_a0 context.Context) ...

type MockJobServiceClient_Expecter

+ func (_e *MockJobServiceClient_Expecter) GetRunContext(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_GetRunContext_Call

+ func (_e *MockJobServiceClient_Expecter) SetRunContext(_a0 interface{}, _a1 interface{}) *MockJobServiceClient_SetRunContext_Call

+ func (_e *MockJobServiceClient_Expecter) SetRunContexts(_a0 interface{}) *MockJobServiceClient_SetRunContexts_Call

+ type MockJobServiceClient_GetRunContext_Call struct

+ func (_c *MockJobServiceClient_GetRunContext_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetRunContextResponse], _a1 error) *MockJobServiceClient_GetRunContext_Call

+ func (_c *MockJobServiceClient_GetRunContext_Call) Run(...) *MockJobServiceClient_GetRunContext_Call

+ func (_c *MockJobServiceClient_GetRunContext_Call) RunAndReturn(...) *MockJobServiceClient_GetRunContext_Call

+ type MockJobServiceClient_SetRunContext_Call struct

+ func (_c *MockJobServiceClient_SetRunContext_Call) Return(_a0 *connect.Response[mgmtv1alpha1.SetRunContextResponse], _a1 error) *MockJobServiceClient_SetRunContext_Call

+ func (_c *MockJobServiceClient_SetRunContext_Call) Run(...) *MockJobServiceClient_SetRunContext_Call

+ func (_c *MockJobServiceClient_SetRunContext_Call) RunAndReturn(...) *MockJobServiceClient_SetRunContext_Call

+ type MockJobServiceClient_SetRunContexts_Call struct

+ func (_c *MockJobServiceClient_SetRunContexts_Call) Return(...) *MockJobServiceClient_SetRunContexts_Call

+ func (_c *MockJobServiceClient_SetRunContexts_Call) Run(run func(_a0 context.Context)) *MockJobServiceClient_SetRunContexts_Call

+ func (_c *MockJobServiceClient_SetRunContexts_Call) RunAndReturn(run func(context.Context) ...) *MockJobServiceClient_SetRunContexts_Call

type MockJobServiceHandler

+ func (_m *MockJobServiceHandler) GetRunContext(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetRunContextRequest]) (*connect.Response[mgmtv1alpha1.GetRunContextResponse], error)

+ func (_m *MockJobServiceHandler) SetRunContext(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.SetRunContextRequest]) (*connect.Response[mgmtv1alpha1.SetRunContextResponse], error)

+ func (_m *MockJobServiceHandler) SetRunContexts(_a0 context.Context, ...) (*connect.Response[mgmtv1alpha1.SetRunContextsResponse], error)

type MockJobServiceHandler_Expecter

+ func (_e *MockJobServiceHandler_Expecter) GetRunContext(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_GetRunContext_Call

+ func (_e *MockJobServiceHandler_Expecter) SetRunContext(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_SetRunContext_Call

+ func (_e *MockJobServiceHandler_Expecter) SetRunContexts(_a0 interface{}, _a1 interface{}) *MockJobServiceHandler_SetRunContexts_Call

+ type MockJobServiceHandler_GetRunContext_Call struct

+ func (_c *MockJobServiceHandler_GetRunContext_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetRunContextResponse], _a1 error) *MockJobServiceHandler_GetRunContext_Call

+ func (_c *MockJobServiceHandler_GetRunContext_Call) Run(...) *MockJobServiceHandler_GetRunContext_Call

+ func (_c *MockJobServiceHandler_GetRunContext_Call) RunAndReturn(...) *MockJobServiceHandler_GetRunContext_Call

+ type MockJobServiceHandler_SetRunContext_Call struct

+ func (_c *MockJobServiceHandler_SetRunContext_Call) Return(_a0 *connect.Response[mgmtv1alpha1.SetRunContextResponse], _a1 error) *MockJobServiceHandler_SetRunContext_Call

+ func (_c *MockJobServiceHandler_SetRunContext_Call) Run(...) *MockJobServiceHandler_SetRunContext_Call

+ func (_c *MockJobServiceHandler_SetRunContext_Call) RunAndReturn(...) *MockJobServiceHandler_SetRunContext_Call

+ type MockJobServiceHandler_SetRunContexts_Call struct

+ func (_c *MockJobServiceHandler_SetRunContexts_Call) Return(_a0 *connect.Response[mgmtv1alpha1.SetRunContextsResponse], _a1 error) *MockJobServiceHandler_SetRunContexts_Call

+ func (_c *MockJobServiceHandler_SetRunContexts_Call) Run(run func(_a0 context.Context, ...)) *MockJobServiceHandler_SetRunContexts_Call

+ func (_c *MockJobServiceHandler_SetRunContexts_Call) RunAndReturn(...) *MockJobServiceHandler_SetRunContexts_Call

type UnimplementedJobServiceHandler

+ func (UnimplementedJobServiceHandler) GetRunContext(context.Context, *connect.Request[v1alpha1.GetRunContextRequest]) (*connect.Response[v1alpha1.GetRunContextResponse], error)

+ func (UnimplementedJobServiceHandler) SetRunContext(context.Context, *connect.Request[v1alpha1.SetRunContextRequest]) (*connect.Response[v1alpha1.SetRunContextResponse], error)

+ func (UnimplementedJobServiceHandler) SetRunContexts(context.Context, *connect.ClientStream[v1alpha1.SetRunContextsRequest]) (*connect.Response[v1alpha1.SetRunContextsResponse], error)

v0.4.53

Aug 21, 2024

v0.4.52

Aug 15, 2024

v0.4.51

Aug 12, 2024

v0.4.50

Aug 3, 2024

v0.4.49

Aug 1, 2024

v0.4.48

Jul 31, 2024

Changes in this version

+ const ConnectionDataServiceGetConnectionSchemaMapsProcedure

type ConnectionDataServiceClient

+ GetConnectionSchemaMaps func(context.Context, *connect.Request[v1alpha1.GetConnectionSchemaMapsRequest]) (*connect.Response[v1alpha1.GetConnectionSchemaMapsResponse], error)

type ConnectionDataServiceHandler

+ GetConnectionSchemaMaps func(context.Context, *connect.Request[v1alpha1.GetConnectionSchemaMapsRequest]) (*connect.Response[v1alpha1.GetConnectionSchemaMapsResponse], error)

type UnimplementedConnectionDataServiceHandler

+ func (UnimplementedConnectionDataServiceHandler) GetConnectionSchemaMaps(context.Context, *connect.Request[v1alpha1.GetConnectionSchemaMapsRequest]) (*connect.Response[v1alpha1.GetConnectionSchemaMapsResponse], error)

v0.4.47

Jul 23, 2024

Changes in this version

+ const ConnectionDataServiceGetConnectionSchemaMapProcedure

type ConnectionDataServiceClient

+ GetConnectionSchemaMap func(context.Context, *connect.Request[v1alpha1.GetConnectionSchemaMapRequest]) (*connect.Response[v1alpha1.GetConnectionSchemaMapResponse], error)

type ConnectionDataServiceHandler

+ GetConnectionSchemaMap func(context.Context, *connect.Request[v1alpha1.GetConnectionSchemaMapRequest]) (*connect.Response[v1alpha1.GetConnectionSchemaMapResponse], error)

type UnimplementedConnectionDataServiceHandler

+ func (UnimplementedConnectionDataServiceHandler) GetConnectionSchemaMap(context.Context, *connect.Request[v1alpha1.GetConnectionSchemaMapRequest]) (*connect.Response[v1alpha1.GetConnectionSchemaMapResponse], error)

v0.4.46

Jul 16, 2024

v0.4.45

Jul 16, 2024

v0.4.44

Jul 11, 2024

v0.4.43

Jul 4, 2024

v0.4.42

Jul 4, 2024

v0.4.41

Jul 2, 2024

v0.4.40

Jul 1, 2024

v0.4.39

Jun 25, 2024

v0.4.38

Jun 20, 2024

v0.4.37

Jun 18, 2024

v0.4.36

Jun 18, 2024

v0.4.35

Jun 14, 2024

v0.4.34

Jun 14, 2024

v0.4.33

Jun 14, 2024

v0.4.32

Jun 13, 2024

v0.4.31

Jun 13, 2024

v0.4.30

Jun 13, 2024

v0.4.29

Jun 13, 2024

v0.4.28

Jun 13, 2024

v0.4.27

Jun 13, 2024

v0.4.26

Jun 12, 2024

v0.4.25

Jun 1, 2024

v0.4.24

May 31, 2024

Changes in this version

+ const ConnectionDataServiceGetConnectionTableConstraintsProcedure

+ const ConnectionDataServiceGetTableRowCountProcedure

+ const JobServiceValidateJobMappingsProcedure

type ConnectionDataServiceClient

+ GetConnectionTableConstraints func(context.Context, ...) (*connect.Response[v1alpha1.GetConnectionTableConstraintsResponse], error)

+ GetTableRowCount func(context.Context, *connect.Request[v1alpha1.GetTableRowCountRequest]) (*connect.Response[v1alpha1.GetTableRowCountResponse], error)

type ConnectionDataServiceHandler

+ GetConnectionTableConstraints func(context.Context, ...) (*connect.Response[v1alpha1.GetConnectionTableConstraintsResponse], error)

+ GetTableRowCount func(context.Context, *connect.Request[v1alpha1.GetTableRowCountRequest]) (*connect.Response[v1alpha1.GetTableRowCountResponse], error)

type JobServiceClient

+ ValidateJobMappings func(context.Context, *connect.Request[v1alpha1.ValidateJobMappingsRequest]) (*connect.Response[v1alpha1.ValidateJobMappingsResponse], error)

type JobServiceHandler

+ ValidateJobMappings func(context.Context, *connect.Request[v1alpha1.ValidateJobMappingsRequest]) (*connect.Response[v1alpha1.ValidateJobMappingsResponse], error)

type MockJobServiceClient

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

type MockJobServiceClient_Expecter

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

+ type MockJobServiceClient_ValidateJobMappings_Call struct

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

+ func (_c *MockJobServiceClient_ValidateJobMappings_Call) Run(run func(_a0 context.Context, ...)) *MockJobServiceClient_ValidateJobMappings_Call

+ func (_c *MockJobServiceClient_ValidateJobMappings_Call) RunAndReturn(...) *MockJobServiceClient_ValidateJobMappings_Call

type MockJobServiceHandler

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

type MockJobServiceHandler_Expecter

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

+ type MockJobServiceHandler_ValidateJobMappings_Call struct

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

+ func (_c *MockJobServiceHandler_ValidateJobMappings_Call) Run(run func(_a0 context.Context, ...)) *MockJobServiceHandler_ValidateJobMappings_Call

+ func (_c *MockJobServiceHandler_ValidateJobMappings_Call) RunAndReturn(...) *MockJobServiceHandler_ValidateJobMappings_Call

type UnimplementedConnectionDataServiceHandler

+ func (UnimplementedConnectionDataServiceHandler) GetConnectionTableConstraints(context.Context, ...) (*connect.Response[v1alpha1.GetConnectionTableConstraintsResponse], error)

+ func (UnimplementedConnectionDataServiceHandler) GetTableRowCount(context.Context, *connect.Request[v1alpha1.GetTableRowCountRequest]) (*connect.Response[v1alpha1.GetTableRowCountResponse], error)

type UnimplementedJobServiceHandler

+ func (UnimplementedJobServiceHandler) ValidateJobMappings(context.Context, *connect.Request[v1alpha1.ValidateJobMappingsRequest]) (*connect.Response[v1alpha1.ValidateJobMappingsResponse], error)

v0.4.23

May 28, 2024

v0.4.22

May 22, 2024

v0.4.21

May 21, 2024

v0.4.20

May 20, 2024

Changes in this version

+ const ApiKeyServiceCreateAccountApiKeyProcedure

+ const ApiKeyServiceDeleteAccountApiKeyProcedure

+ const ApiKeyServiceGetAccountApiKeyProcedure

+ const ApiKeyServiceGetAccountApiKeysProcedure

+ const ApiKeyServiceName

+ const ApiKeyServiceRegenerateAccountApiKeyProcedure

+ const AuthServiceCheckTokenProcedure

+ const AuthServiceGetAuthStatusProcedure

+ const AuthServiceGetAuthorizeUrlProcedure

+ const AuthServiceGetCliIssuerProcedure

+ const AuthServiceLoginCliProcedure

+ const AuthServiceName

+ const AuthServiceRefreshCliProcedure

+ const ConnectionDataServiceGetAiGeneratedDataProcedure

+ const ConnectionDataServiceGetConnectionDataStreamProcedure

+ const ConnectionDataServiceGetConnectionForeignConstraintsProcedure

+ const ConnectionDataServiceGetConnectionInitStatementsProcedure

+ const ConnectionDataServiceGetConnectionPrimaryConstraintsProcedure

+ const ConnectionDataServiceGetConnectionSchemaProcedure

+ const ConnectionDataServiceGetConnectionUniqueConstraintsProcedure

+ const ConnectionDataServiceName

+ const ConnectionServiceCheckConnectionConfigProcedure

+ const ConnectionServiceCheckSqlQueryProcedure

+ const ConnectionServiceCreateConnectionProcedure

+ const ConnectionServiceDeleteConnectionProcedure

+ const ConnectionServiceGetConnectionProcedure

+ const ConnectionServiceGetConnectionsProcedure

+ const ConnectionServiceIsConnectionNameAvailableProcedure

+ const ConnectionServiceName

+ const ConnectionServiceUpdateConnectionProcedure

+ const JobServiceCancelJobRunProcedure

+ const JobServiceCreateJobDestinationConnectionsProcedure

+ const JobServiceCreateJobProcedure

+ const JobServiceCreateJobRunProcedure

+ const JobServiceDeleteJobDestinationConnectionProcedure

+ const JobServiceDeleteJobProcedure

+ const JobServiceDeleteJobRunProcedure

+ const JobServiceGetJobNextRunsProcedure

+ const JobServiceGetJobProcedure

+ const JobServiceGetJobRecentRunsProcedure

+ const JobServiceGetJobRunEventsProcedure

+ const JobServiceGetJobRunLogsStreamProcedure

+ const JobServiceGetJobRunProcedure

+ const JobServiceGetJobRunsProcedure

+ const JobServiceGetJobStatusProcedure

+ const JobServiceGetJobStatusesProcedure

+ const JobServiceGetJobsProcedure

+ const JobServiceIsJobNameAvailableProcedure

+ const JobServiceName

+ const JobServicePauseJobProcedure

+ const JobServiceSetJobSourceSqlConnectionSubsetsProcedure

+ const JobServiceSetJobSyncOptionsProcedure

+ const JobServiceSetJobWorkflowOptionsProcedure

+ const JobServiceTerminateJobRunProcedure

+ const JobServiceUpdateJobDestinationConnectionProcedure

+ const JobServiceUpdateJobScheduleProcedure

+ const JobServiceUpdateJobSourceConnectionProcedure

+ const MetricsServiceGetDailyMetricCountProcedure

+ const MetricsServiceGetMetricCountProcedure

+ const MetricsServiceName

+ const TransformersServiceCreateUserDefinedTransformerProcedure

+ const TransformersServiceDeleteUserDefinedTransformerProcedure

+ const TransformersServiceGetSystemTransformerBySourceProcedure

+ const TransformersServiceGetSystemTransformersProcedure

+ const TransformersServiceGetUserDefinedTransformerByIdProcedure

+ const TransformersServiceGetUserDefinedTransformersProcedure

+ const TransformersServiceIsTransformerNameAvailableProcedure

+ const TransformersServiceName

+ const TransformersServiceUpdateUserDefinedTransformerProcedure

+ const TransformersServiceValidateUserJavascriptCodeProcedure

+ const TransformersServiceValidateUserRegexCodeProcedure

+ const UserAccountServiceAcceptTeamAccountInviteProcedure

+ const UserAccountServiceConvertPersonalToTeamAccountProcedure

+ const UserAccountServiceCreateTeamAccountProcedure

+ const UserAccountServiceGetAccountOnboardingConfigProcedure

+ const UserAccountServiceGetAccountTemporalConfigProcedure

+ const UserAccountServiceGetSystemInformationProcedure

+ const UserAccountServiceGetTeamAccountInvitesProcedure

+ const UserAccountServiceGetTeamAccountMembersProcedure

+ const UserAccountServiceGetUserAccountsProcedure

+ const UserAccountServiceGetUserProcedure

+ const UserAccountServiceInviteUserToTeamAccountProcedure

+ const UserAccountServiceIsUserInAccountProcedure

+ const UserAccountServiceName

+ const UserAccountServiceRemoveTeamAccountInviteProcedure

+ const UserAccountServiceRemoveTeamAccountMemberProcedure

+ const UserAccountServiceSetAccountOnboardingConfigProcedure

+ const UserAccountServiceSetAccountTemporalConfigProcedure

+ const UserAccountServiceSetPersonalAccountProcedure

+ const UserAccountServiceSetUserProcedure

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

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

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

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

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

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

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

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

+ type ApiKeyServiceClient interface

+ CreateAccountApiKey func(context.Context, *connect.Request[v1alpha1.CreateAccountApiKeyRequest]) (*connect.Response[v1alpha1.CreateAccountApiKeyResponse], error)

+ DeleteAccountApiKey func(context.Context, *connect.Request[v1alpha1.DeleteAccountApiKeyRequest]) (*connect.Response[v1alpha1.DeleteAccountApiKeyResponse], error)

+ GetAccountApiKey func(context.Context, *connect.Request[v1alpha1.GetAccountApiKeyRequest]) (*connect.Response[v1alpha1.GetAccountApiKeyResponse], error)

+ GetAccountApiKeys func(context.Context, *connect.Request[v1alpha1.GetAccountApiKeysRequest]) (*connect.Response[v1alpha1.GetAccountApiKeysResponse], error)

+ RegenerateAccountApiKey func(context.Context, *connect.Request[v1alpha1.RegenerateAccountApiKeyRequest]) (*connect.Response[v1alpha1.RegenerateAccountApiKeyResponse], error)

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

+ type ApiKeyServiceHandler interface

+ CreateAccountApiKey func(context.Context, *connect.Request[v1alpha1.CreateAccountApiKeyRequest]) (*connect.Response[v1alpha1.CreateAccountApiKeyResponse], error)

+ DeleteAccountApiKey func(context.Context, *connect.Request[v1alpha1.DeleteAccountApiKeyRequest]) (*connect.Response[v1alpha1.DeleteAccountApiKeyResponse], error)

+ GetAccountApiKey func(context.Context, *connect.Request[v1alpha1.GetAccountApiKeyRequest]) (*connect.Response[v1alpha1.GetAccountApiKeyResponse], error)

+ GetAccountApiKeys func(context.Context, *connect.Request[v1alpha1.GetAccountApiKeysRequest]) (*connect.Response[v1alpha1.GetAccountApiKeysResponse], error)

+ RegenerateAccountApiKey func(context.Context, *connect.Request[v1alpha1.RegenerateAccountApiKeyRequest]) (*connect.Response[v1alpha1.RegenerateAccountApiKeyResponse], error)

+ type AuthServiceClient interface

+ CheckToken func(context.Context, *connect.Request[v1alpha1.CheckTokenRequest]) (*connect.Response[v1alpha1.CheckTokenResponse], error)

+ GetAuthStatus func(context.Context, *connect.Request[v1alpha1.GetAuthStatusRequest]) (*connect.Response[v1alpha1.GetAuthStatusResponse], error)

+ GetAuthorizeUrl func(context.Context, *connect.Request[v1alpha1.GetAuthorizeUrlRequest]) (*connect.Response[v1alpha1.GetAuthorizeUrlResponse], error)

+ GetCliIssuer func(context.Context, *connect.Request[v1alpha1.GetCliIssuerRequest]) (*connect.Response[v1alpha1.GetCliIssuerResponse], error)

+ LoginCli func(context.Context, *connect.Request[v1alpha1.LoginCliRequest]) (*connect.Response[v1alpha1.LoginCliResponse], error)

+ RefreshCli func(context.Context, *connect.Request[v1alpha1.RefreshCliRequest]) (*connect.Response[v1alpha1.RefreshCliResponse], error)

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

+ type AuthServiceHandler interface

+ CheckToken func(context.Context, *connect.Request[v1alpha1.CheckTokenRequest]) (*connect.Response[v1alpha1.CheckTokenResponse], error)

+ GetAuthStatus func(context.Context, *connect.Request[v1alpha1.GetAuthStatusRequest]) (*connect.Response[v1alpha1.GetAuthStatusResponse], error)

+ GetAuthorizeUrl func(context.Context, *connect.Request[v1alpha1.GetAuthorizeUrlRequest]) (*connect.Response[v1alpha1.GetAuthorizeUrlResponse], error)

+ GetCliIssuer func(context.Context, *connect.Request[v1alpha1.GetCliIssuerRequest]) (*connect.Response[v1alpha1.GetCliIssuerResponse], error)

+ LoginCli func(context.Context, *connect.Request[v1alpha1.LoginCliRequest]) (*connect.Response[v1alpha1.LoginCliResponse], error)

+ RefreshCli func(context.Context, *connect.Request[v1alpha1.RefreshCliRequest]) (*connect.Response[v1alpha1.RefreshCliResponse], error)

+ type ConnectionDataServiceClient interface

+ GetAiGeneratedData func(context.Context, *connect.Request[v1alpha1.GetAiGeneratedDataRequest]) (*connect.Response[v1alpha1.GetAiGeneratedDataResponse], error)

+ GetConnectionDataStream func(context.Context, *connect.Request[v1alpha1.GetConnectionDataStreamRequest]) (*connect.ServerStreamForClient[v1alpha1.GetConnectionDataStreamResponse], ...)

+ GetConnectionForeignConstraints func(context.Context, ...) (*connect.Response[v1alpha1.GetConnectionForeignConstraintsResponse], error)

+ GetConnectionInitStatements func(context.Context, *connect.Request[v1alpha1.GetConnectionInitStatementsRequest]) (*connect.Response[v1alpha1.GetConnectionInitStatementsResponse], error)

+ GetConnectionPrimaryConstraints func(context.Context, ...) (*connect.Response[v1alpha1.GetConnectionPrimaryConstraintsResponse], error)

+ GetConnectionSchema func(context.Context, *connect.Request[v1alpha1.GetConnectionSchemaRequest]) (*connect.Response[v1alpha1.GetConnectionSchemaResponse], error)

+ GetConnectionUniqueConstraints func(context.Context, ...) (*connect.Response[v1alpha1.GetConnectionUniqueConstraintsResponse], error)

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

+ type ConnectionDataServiceHandler interface

+ GetAiGeneratedData func(context.Context, *connect.Request[v1alpha1.GetAiGeneratedDataRequest]) (*connect.Response[v1alpha1.GetAiGeneratedDataResponse], error)

+ GetConnectionDataStream func(context.Context, *connect.Request[v1alpha1.GetConnectionDataStreamRequest], ...) error

+ GetConnectionForeignConstraints func(context.Context, ...) (*connect.Response[v1alpha1.GetConnectionForeignConstraintsResponse], error)

+ GetConnectionInitStatements func(context.Context, *connect.Request[v1alpha1.GetConnectionInitStatementsRequest]) (*connect.Response[v1alpha1.GetConnectionInitStatementsResponse], error)

+ GetConnectionPrimaryConstraints func(context.Context, ...) (*connect.Response[v1alpha1.GetConnectionPrimaryConstraintsResponse], error)

+ GetConnectionSchema func(context.Context, *connect.Request[v1alpha1.GetConnectionSchemaRequest]) (*connect.Response[v1alpha1.GetConnectionSchemaResponse], error)

+ GetConnectionUniqueConstraints func(context.Context, ...) (*connect.Response[v1alpha1.GetConnectionUniqueConstraintsResponse], error)

+ type ConnectionServiceClient interface

+ CheckConnectionConfig func(context.Context, *connect.Request[v1alpha1.CheckConnectionConfigRequest]) (*connect.Response[v1alpha1.CheckConnectionConfigResponse], error)

+ CheckSqlQuery func(context.Context, *connect.Request[v1alpha1.CheckSqlQueryRequest]) (*connect.Response[v1alpha1.CheckSqlQueryResponse], error)

+ CreateConnection func(context.Context, *connect.Request[v1alpha1.CreateConnectionRequest]) (*connect.Response[v1alpha1.CreateConnectionResponse], error)

+ DeleteConnection func(context.Context, *connect.Request[v1alpha1.DeleteConnectionRequest]) (*connect.Response[v1alpha1.DeleteConnectionResponse], error)

+ GetConnection func(context.Context, *connect.Request[v1alpha1.GetConnectionRequest]) (*connect.Response[v1alpha1.GetConnectionResponse], error)

+ GetConnections func(context.Context, *connect.Request[v1alpha1.GetConnectionsRequest]) (*connect.Response[v1alpha1.GetConnectionsResponse], error)

+ IsConnectionNameAvailable func(context.Context, *connect.Request[v1alpha1.IsConnectionNameAvailableRequest]) (*connect.Response[v1alpha1.IsConnectionNameAvailableResponse], error)

+ UpdateConnection func(context.Context, *connect.Request[v1alpha1.UpdateConnectionRequest]) (*connect.Response[v1alpha1.UpdateConnectionResponse], error)

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

+ type ConnectionServiceHandler interface

+ CheckConnectionConfig func(context.Context, *connect.Request[v1alpha1.CheckConnectionConfigRequest]) (*connect.Response[v1alpha1.CheckConnectionConfigResponse], error)

+ CheckSqlQuery func(context.Context, *connect.Request[v1alpha1.CheckSqlQueryRequest]) (*connect.Response[v1alpha1.CheckSqlQueryResponse], error)

+ CreateConnection func(context.Context, *connect.Request[v1alpha1.CreateConnectionRequest]) (*connect.Response[v1alpha1.CreateConnectionResponse], error)

+ DeleteConnection func(context.Context, *connect.Request[v1alpha1.DeleteConnectionRequest]) (*connect.Response[v1alpha1.DeleteConnectionResponse], error)

+ GetConnection func(context.Context, *connect.Request[v1alpha1.GetConnectionRequest]) (*connect.Response[v1alpha1.GetConnectionResponse], error)

+ GetConnections func(context.Context, *connect.Request[v1alpha1.GetConnectionsRequest]) (*connect.Response[v1alpha1.GetConnectionsResponse], error)

+ IsConnectionNameAvailable func(context.Context, *connect.Request[v1alpha1.IsConnectionNameAvailableRequest]) (*connect.Response[v1alpha1.IsConnectionNameAvailableResponse], error)

+ UpdateConnection func(context.Context, *connect.Request[v1alpha1.UpdateConnectionRequest]) (*connect.Response[v1alpha1.UpdateConnectionResponse], error)

+ type JobServiceClient interface

+ CancelJobRun func(context.Context, *connect.Request[v1alpha1.CancelJobRunRequest]) (*connect.Response[v1alpha1.CancelJobRunResponse], error)

+ CreateJob func(context.Context, *connect.Request[v1alpha1.CreateJobRequest]) (*connect.Response[v1alpha1.CreateJobResponse], error)

+ CreateJobDestinationConnections func(context.Context, ...) (*connect.Response[v1alpha1.CreateJobDestinationConnectionsResponse], error)

+ CreateJobRun func(context.Context, *connect.Request[v1alpha1.CreateJobRunRequest]) (*connect.Response[v1alpha1.CreateJobRunResponse], error)

+ DeleteJob func(context.Context, *connect.Request[v1alpha1.DeleteJobRequest]) (*connect.Response[v1alpha1.DeleteJobResponse], error)

+ DeleteJobDestinationConnection func(context.Context, ...) (*connect.Response[v1alpha1.DeleteJobDestinationConnectionResponse], error)

+ DeleteJobRun func(context.Context, *connect.Request[v1alpha1.DeleteJobRunRequest]) (*connect.Response[v1alpha1.DeleteJobRunResponse], error)

+ GetJob func(context.Context, *connect.Request[v1alpha1.GetJobRequest]) (*connect.Response[v1alpha1.GetJobResponse], error)

+ GetJobNextRuns func(context.Context, *connect.Request[v1alpha1.GetJobNextRunsRequest]) (*connect.Response[v1alpha1.GetJobNextRunsResponse], error)

+ GetJobRecentRuns func(context.Context, *connect.Request[v1alpha1.GetJobRecentRunsRequest]) (*connect.Response[v1alpha1.GetJobRecentRunsResponse], error)

+ GetJobRun func(context.Context, *connect.Request[v1alpha1.GetJobRunRequest]) (*connect.Response[v1alpha1.GetJobRunResponse], error)

+ GetJobRunEvents func(context.Context, *connect.Request[v1alpha1.GetJobRunEventsRequest]) (*connect.Response[v1alpha1.GetJobRunEventsResponse], error)

+ GetJobRunLogsStream func(context.Context, *connect.Request[v1alpha1.GetJobRunLogsStreamRequest]) (*connect.ServerStreamForClient[v1alpha1.GetJobRunLogsStreamResponse], error)

+ GetJobRuns func(context.Context, *connect.Request[v1alpha1.GetJobRunsRequest]) (*connect.Response[v1alpha1.GetJobRunsResponse], error)

+ GetJobStatus func(context.Context, *connect.Request[v1alpha1.GetJobStatusRequest]) (*connect.Response[v1alpha1.GetJobStatusResponse], error)

+ GetJobStatuses func(context.Context, *connect.Request[v1alpha1.GetJobStatusesRequest]) (*connect.Response[v1alpha1.GetJobStatusesResponse], error)

+ GetJobs func(context.Context, *connect.Request[v1alpha1.GetJobsRequest]) (*connect.Response[v1alpha1.GetJobsResponse], error)

+ IsJobNameAvailable func(context.Context, *connect.Request[v1alpha1.IsJobNameAvailableRequest]) (*connect.Response[v1alpha1.IsJobNameAvailableResponse], error)

+ PauseJob func(context.Context, *connect.Request[v1alpha1.PauseJobRequest]) (*connect.Response[v1alpha1.PauseJobResponse], error)

+ SetJobSourceSqlConnectionSubsets func(context.Context, ...) (*connect.Response[v1alpha1.SetJobSourceSqlConnectionSubsetsResponse], error)

+ SetJobSyncOptions func(context.Context, *connect.Request[v1alpha1.SetJobSyncOptionsRequest]) (*connect.Response[v1alpha1.SetJobSyncOptionsResponse], error)

+ SetJobWorkflowOptions func(context.Context, *connect.Request[v1alpha1.SetJobWorkflowOptionsRequest]) (*connect.Response[v1alpha1.SetJobWorkflowOptionsResponse], error)

+ TerminateJobRun func(context.Context, *connect.Request[v1alpha1.TerminateJobRunRequest]) (*connect.Response[v1alpha1.TerminateJobRunResponse], error)

+ UpdateJobDestinationConnection func(context.Context, ...) (*connect.Response[v1alpha1.UpdateJobDestinationConnectionResponse], error)

+ UpdateJobSchedule func(context.Context, *connect.Request[v1alpha1.UpdateJobScheduleRequest]) (*connect.Response[v1alpha1.UpdateJobScheduleResponse], error)

+ UpdateJobSourceConnection func(context.Context, *connect.Request[v1alpha1.UpdateJobSourceConnectionRequest]) (*connect.Response[v1alpha1.UpdateJobSourceConnectionResponse], error)

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

+ type JobServiceHandler interface

+ CancelJobRun func(context.Context, *connect.Request[v1alpha1.CancelJobRunRequest]) (*connect.Response[v1alpha1.CancelJobRunResponse], error)

+ CreateJob func(context.Context, *connect.Request[v1alpha1.CreateJobRequest]) (*connect.Response[v1alpha1.CreateJobResponse], error)

+ CreateJobDestinationConnections func(context.Context, ...) (*connect.Response[v1alpha1.CreateJobDestinationConnectionsResponse], error)

+ CreateJobRun func(context.Context, *connect.Request[v1alpha1.CreateJobRunRequest]) (*connect.Response[v1alpha1.CreateJobRunResponse], error)

+ DeleteJob func(context.Context, *connect.Request[v1alpha1.DeleteJobRequest]) (*connect.Response[v1alpha1.DeleteJobResponse], error)

+ DeleteJobDestinationConnection func(context.Context, ...) (*connect.Response[v1alpha1.DeleteJobDestinationConnectionResponse], error)

+ DeleteJobRun func(context.Context, *connect.Request[v1alpha1.DeleteJobRunRequest]) (*connect.Response[v1alpha1.DeleteJobRunResponse], error)

+ GetJob func(context.Context, *connect.Request[v1alpha1.GetJobRequest]) (*connect.Response[v1alpha1.GetJobResponse], error)

+ GetJobNextRuns func(context.Context, *connect.Request[v1alpha1.GetJobNextRunsRequest]) (*connect.Response[v1alpha1.GetJobNextRunsResponse], error)

+ GetJobRecentRuns func(context.Context, *connect.Request[v1alpha1.GetJobRecentRunsRequest]) (*connect.Response[v1alpha1.GetJobRecentRunsResponse], error)

+ GetJobRun func(context.Context, *connect.Request[v1alpha1.GetJobRunRequest]) (*connect.Response[v1alpha1.GetJobRunResponse], error)

+ GetJobRunEvents func(context.Context, *connect.Request[v1alpha1.GetJobRunEventsRequest]) (*connect.Response[v1alpha1.GetJobRunEventsResponse], error)

+ GetJobRunLogsStream func(context.Context, *connect.Request[v1alpha1.GetJobRunLogsStreamRequest], ...) error

+ GetJobRuns func(context.Context, *connect.Request[v1alpha1.GetJobRunsRequest]) (*connect.Response[v1alpha1.GetJobRunsResponse], error)

+ GetJobStatus func(context.Context, *connect.Request[v1alpha1.GetJobStatusRequest]) (*connect.Response[v1alpha1.GetJobStatusResponse], error)

+ GetJobStatuses func(context.Context, *connect.Request[v1alpha1.GetJobStatusesRequest]) (*connect.Response[v1alpha1.GetJobStatusesResponse], error)

+ GetJobs func(context.Context, *connect.Request[v1alpha1.GetJobsRequest]) (*connect.Response[v1alpha1.GetJobsResponse], error)

+ IsJobNameAvailable func(context.Context, *connect.Request[v1alpha1.IsJobNameAvailableRequest]) (*connect.Response[v1alpha1.IsJobNameAvailableResponse], error)

+ PauseJob func(context.Context, *connect.Request[v1alpha1.PauseJobRequest]) (*connect.Response[v1alpha1.PauseJobResponse], error)

+ SetJobSourceSqlConnectionSubsets func(context.Context, ...) (*connect.Response[v1alpha1.SetJobSourceSqlConnectionSubsetsResponse], error)

+ SetJobSyncOptions func(context.Context, *connect.Request[v1alpha1.SetJobSyncOptionsRequest]) (*connect.Response[v1alpha1.SetJobSyncOptionsResponse], error)

+ SetJobWorkflowOptions func(context.Context, *connect.Request[v1alpha1.SetJobWorkflowOptionsRequest]) (*connect.Response[v1alpha1.SetJobWorkflowOptionsResponse], error)

+ TerminateJobRun func(context.Context, *connect.Request[v1alpha1.TerminateJobRunRequest]) (*connect.Response[v1alpha1.TerminateJobRunResponse], error)

+ UpdateJobDestinationConnection func(context.Context, ...) (*connect.Response[v1alpha1.UpdateJobDestinationConnectionResponse], error)

+ UpdateJobSchedule func(context.Context, *connect.Request[v1alpha1.UpdateJobScheduleRequest]) (*connect.Response[v1alpha1.UpdateJobScheduleResponse], error)

+ UpdateJobSourceConnection func(context.Context, *connect.Request[v1alpha1.UpdateJobSourceConnectionRequest]) (*connect.Response[v1alpha1.UpdateJobSourceConnectionResponse], error)

+ type MetricsServiceClient interface

+ GetDailyMetricCount func(context.Context, *connect.Request[v1alpha1.GetDailyMetricCountRequest]) (*connect.Response[v1alpha1.GetDailyMetricCountResponse], error)

+ GetMetricCount func(context.Context, *connect.Request[v1alpha1.GetMetricCountRequest]) (*connect.Response[v1alpha1.GetMetricCountResponse], error)

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

+ type MetricsServiceHandler interface

+ GetDailyMetricCount func(context.Context, *connect.Request[v1alpha1.GetDailyMetricCountRequest]) (*connect.Response[v1alpha1.GetDailyMetricCountResponse], error)

+ GetMetricCount func(context.Context, *connect.Request[v1alpha1.GetMetricCountRequest]) (*connect.Response[v1alpha1.GetMetricCountResponse], error)

+ type MockAuthServiceClient struct

+ func NewMockAuthServiceClient(t interface{ ... }) *MockAuthServiceClient

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

+ func (_m *MockAuthServiceClient) EXPECT() *MockAuthServiceClient_Expecter

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

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

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

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

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

+ type MockAuthServiceClient_CheckToken_Call struct

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

+ func (_c *MockAuthServiceClient_CheckToken_Call) Run(...) *MockAuthServiceClient_CheckToken_Call

+ func (_c *MockAuthServiceClient_CheckToken_Call) RunAndReturn(...) *MockAuthServiceClient_CheckToken_Call

+ type MockAuthServiceClient_Expecter struct

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

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

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

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

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

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

+ type MockAuthServiceClient_GetAuthStatus_Call struct

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

+ func (_c *MockAuthServiceClient_GetAuthStatus_Call) Run(...) *MockAuthServiceClient_GetAuthStatus_Call

+ func (_c *MockAuthServiceClient_GetAuthStatus_Call) RunAndReturn(...) *MockAuthServiceClient_GetAuthStatus_Call

+ type MockAuthServiceClient_GetAuthorizeUrl_Call struct

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

+ func (_c *MockAuthServiceClient_GetAuthorizeUrl_Call) Run(...) *MockAuthServiceClient_GetAuthorizeUrl_Call

+ func (_c *MockAuthServiceClient_GetAuthorizeUrl_Call) RunAndReturn(...) *MockAuthServiceClient_GetAuthorizeUrl_Call

+ type MockAuthServiceClient_GetCliIssuer_Call struct

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

+ func (_c *MockAuthServiceClient_GetCliIssuer_Call) Run(...) *MockAuthServiceClient_GetCliIssuer_Call

+ func (_c *MockAuthServiceClient_GetCliIssuer_Call) RunAndReturn(...) *MockAuthServiceClient_GetCliIssuer_Call

+ type MockAuthServiceClient_LoginCli_Call struct

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

+ func (_c *MockAuthServiceClient_LoginCli_Call) Run(...) *MockAuthServiceClient_LoginCli_Call

+ func (_c *MockAuthServiceClient_LoginCli_Call) RunAndReturn(...) *MockAuthServiceClient_LoginCli_Call

+ type MockAuthServiceClient_RefreshCli_Call struct

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

+ func (_c *MockAuthServiceClient_RefreshCli_Call) Run(...) *MockAuthServiceClient_RefreshCli_Call

+ func (_c *MockAuthServiceClient_RefreshCli_Call) RunAndReturn(...) *MockAuthServiceClient_RefreshCli_Call

+ type MockConnectionServiceClient struct

+ func NewMockConnectionServiceClient(t interface{ ... }) *MockConnectionServiceClient

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

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

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

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

+ func (_m *MockConnectionServiceClient) EXPECT() *MockConnectionServiceClient_Expecter

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

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

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

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

+ type MockConnectionServiceClient_CheckConnectionConfig_Call struct

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

+ func (_c *MockConnectionServiceClient_CheckConnectionConfig_Call) Run(run func(_a0 context.Context, ...)) *MockConnectionServiceClient_CheckConnectionConfig_Call

+ func (_c *MockConnectionServiceClient_CheckConnectionConfig_Call) RunAndReturn(...) *MockConnectionServiceClient_CheckConnectionConfig_Call

+ type MockConnectionServiceClient_CheckSqlQuery_Call struct

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

+ func (_c *MockConnectionServiceClient_CheckSqlQuery_Call) Run(...) *MockConnectionServiceClient_CheckSqlQuery_Call

+ func (_c *MockConnectionServiceClient_CheckSqlQuery_Call) RunAndReturn(...) *MockConnectionServiceClient_CheckSqlQuery_Call

+ type MockConnectionServiceClient_CreateConnection_Call struct

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

+ func (_c *MockConnectionServiceClient_CreateConnection_Call) Run(run func(_a0 context.Context, ...)) *MockConnectionServiceClient_CreateConnection_Call

+ func (_c *MockConnectionServiceClient_CreateConnection_Call) RunAndReturn(...) *MockConnectionServiceClient_CreateConnection_Call

+ type MockConnectionServiceClient_DeleteConnection_Call struct

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

+ func (_c *MockConnectionServiceClient_DeleteConnection_Call) Run(run func(_a0 context.Context, ...)) *MockConnectionServiceClient_DeleteConnection_Call

+ func (_c *MockConnectionServiceClient_DeleteConnection_Call) RunAndReturn(...) *MockConnectionServiceClient_DeleteConnection_Call

+ type MockConnectionServiceClient_Expecter struct

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

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

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

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

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

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

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

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

+ type MockConnectionServiceClient_GetConnection_Call struct

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

+ func (_c *MockConnectionServiceClient_GetConnection_Call) Run(...) *MockConnectionServiceClient_GetConnection_Call

+ func (_c *MockConnectionServiceClient_GetConnection_Call) RunAndReturn(...) *MockConnectionServiceClient_GetConnection_Call

+ type MockConnectionServiceClient_GetConnections_Call struct

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

+ func (_c *MockConnectionServiceClient_GetConnections_Call) Run(...) *MockConnectionServiceClient_GetConnections_Call

+ func (_c *MockConnectionServiceClient_GetConnections_Call) RunAndReturn(...) *MockConnectionServiceClient_GetConnections_Call

+ type MockConnectionServiceClient_IsConnectionNameAvailable_Call struct

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

+ func (_c *MockConnectionServiceClient_IsConnectionNameAvailable_Call) Run(run func(_a0 context.Context, ...)) *MockConnectionServiceClient_IsConnectionNameAvailable_Call

+ func (_c *MockConnectionServiceClient_IsConnectionNameAvailable_Call) RunAndReturn(...) *MockConnectionServiceClient_IsConnectionNameAvailable_Call

+ type MockConnectionServiceClient_UpdateConnection_Call struct

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

+ func (_c *MockConnectionServiceClient_UpdateConnection_Call) Run(run func(_a0 context.Context, ...)) *MockConnectionServiceClient_UpdateConnection_Call

+ func (_c *MockConnectionServiceClient_UpdateConnection_Call) RunAndReturn(...) *MockConnectionServiceClient_UpdateConnection_Call

+ type MockConnectionServiceHandler struct

+ func NewMockConnectionServiceHandler(t interface{ ... }) *MockConnectionServiceHandler

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

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

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

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

+ func (_m *MockConnectionServiceHandler) EXPECT() *MockConnectionServiceHandler_Expecter

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

+ func (_m *MockConnectionServiceHandler) GetConnectionDataStream(_a0 context.Context, ...) error

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

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

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

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

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

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

+ type MockConnectionServiceHandler_CheckConnectionConfig_Call struct

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

+ func (_c *MockConnectionServiceHandler_CheckConnectionConfig_Call) Run(run func(_a0 context.Context, ...)) *MockConnectionServiceHandler_CheckConnectionConfig_Call

+ func (_c *MockConnectionServiceHandler_CheckConnectionConfig_Call) RunAndReturn(...) *MockConnectionServiceHandler_CheckConnectionConfig_Call

+ type MockConnectionServiceHandler_CheckSqlQuery_Call struct

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

+ func (_c *MockConnectionServiceHandler_CheckSqlQuery_Call) Run(...) *MockConnectionServiceHandler_CheckSqlQuery_Call

+ func (_c *MockConnectionServiceHandler_CheckSqlQuery_Call) RunAndReturn(...) *MockConnectionServiceHandler_CheckSqlQuery_Call

+ type MockConnectionServiceHandler_CreateConnection_Call struct

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

+ func (_c *MockConnectionServiceHandler_CreateConnection_Call) Run(run func(_a0 context.Context, ...)) *MockConnectionServiceHandler_CreateConnection_Call

+ func (_c *MockConnectionServiceHandler_CreateConnection_Call) RunAndReturn(...) *MockConnectionServiceHandler_CreateConnection_Call

+ type MockConnectionServiceHandler_DeleteConnection_Call struct

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

+ func (_c *MockConnectionServiceHandler_DeleteConnection_Call) Run(run func(_a0 context.Context, ...)) *MockConnectionServiceHandler_DeleteConnection_Call

+ func (_c *MockConnectionServiceHandler_DeleteConnection_Call) RunAndReturn(...) *MockConnectionServiceHandler_DeleteConnection_Call

+ type MockConnectionServiceHandler_Expecter struct

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

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

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

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

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

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

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

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

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

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

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

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

+ type MockConnectionServiceHandler_GetConnectionDataStream_Call struct

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

+ func (_c *MockConnectionServiceHandler_GetConnectionDataStream_Call) Run(run func(_a0 context.Context, ...)) *MockConnectionServiceHandler_GetConnectionDataStream_Call

+ func (_c *MockConnectionServiceHandler_GetConnectionDataStream_Call) RunAndReturn(...) *MockConnectionServiceHandler_GetConnectionDataStream_Call

+ type MockConnectionServiceHandler_GetConnectionForeignConstraints_Call struct

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

+ func (_c *MockConnectionServiceHandler_GetConnectionForeignConstraints_Call) Run(run func(_a0 context.Context, ...)) *MockConnectionServiceHandler_GetConnectionForeignConstraints_Call

+ func (_c *MockConnectionServiceHandler_GetConnectionForeignConstraints_Call) RunAndReturn(...) *MockConnectionServiceHandler_GetConnectionForeignConstraints_Call

+ type MockConnectionServiceHandler_GetConnectionInitStatements_Call struct

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

+ func (_c *MockConnectionServiceHandler_GetConnectionInitStatements_Call) Run(run func(_a0 context.Context, ...)) *MockConnectionServiceHandler_GetConnectionInitStatements_Call

+ func (_c *MockConnectionServiceHandler_GetConnectionInitStatements_Call) RunAndReturn(...) *MockConnectionServiceHandler_GetConnectionInitStatements_Call

+ type MockConnectionServiceHandler_GetConnectionSchema_Call struct

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

+ func (_c *MockConnectionServiceHandler_GetConnectionSchema_Call) Run(run func(_a0 context.Context, ...)) *MockConnectionServiceHandler_GetConnectionSchema_Call

+ func (_c *MockConnectionServiceHandler_GetConnectionSchema_Call) RunAndReturn(...) *MockConnectionServiceHandler_GetConnectionSchema_Call

+ type MockConnectionServiceHandler_GetConnection_Call struct

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

+ func (_c *MockConnectionServiceHandler_GetConnection_Call) Run(...) *MockConnectionServiceHandler_GetConnection_Call

+ func (_c *MockConnectionServiceHandler_GetConnection_Call) RunAndReturn(...) *MockConnectionServiceHandler_GetConnection_Call

+ type MockConnectionServiceHandler_GetConnections_Call struct

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

+ func (_c *MockConnectionServiceHandler_GetConnections_Call) Run(...) *MockConnectionServiceHandler_GetConnections_Call

+ func (_c *MockConnectionServiceHandler_GetConnections_Call) RunAndReturn(...) *MockConnectionServiceHandler_GetConnections_Call

+ type MockConnectionServiceHandler_IsConnectionNameAvailable_Call struct

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

+ func (_c *MockConnectionServiceHandler_IsConnectionNameAvailable_Call) Run(run func(_a0 context.Context, ...)) *MockConnectionServiceHandler_IsConnectionNameAvailable_Call

+ func (_c *MockConnectionServiceHandler_IsConnectionNameAvailable_Call) RunAndReturn(...) *MockConnectionServiceHandler_IsConnectionNameAvailable_Call

+ type MockConnectionServiceHandler_UpdateConnection_Call struct

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

+ func (_c *MockConnectionServiceHandler_UpdateConnection_Call) Run(run func(_a0 context.Context, ...)) *MockConnectionServiceHandler_UpdateConnection_Call

+ func (_c *MockConnectionServiceHandler_UpdateConnection_Call) RunAndReturn(...) *MockConnectionServiceHandler_UpdateConnection_Call

+ type MockJobServiceClient struct

+ func NewMockJobServiceClient(t interface{ ... }) *MockJobServiceClient

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

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

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

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

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

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

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

+ func (_m *MockJobServiceClient) EXPECT() *MockJobServiceClient_Expecter

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

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

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

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

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

+ func (_m *MockJobServiceClient) GetJobRunLogsStream(_a0 context.Context, ...) (*connect.ServerStreamForClient[mgmtv1alpha1.GetJobRunLogsStreamResponse], ...)

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

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

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

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

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

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

+ func (_m *MockJobServiceClient) SetJobSourceSqlConnectionSubsets(_a0 context.Context, ...) (*connect.Response[mgmtv1alpha1.SetJobSourceSqlConnectionSubsetsResponse], ...)

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

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

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

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

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

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

+ type MockJobServiceClient_CancelJobRun_Call struct

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

+ func (_c *MockJobServiceClient_CancelJobRun_Call) Run(...) *MockJobServiceClient_CancelJobRun_Call

+ func (_c *MockJobServiceClient_CancelJobRun_Call) RunAndReturn(...) *MockJobServiceClient_CancelJobRun_Call

+ type MockJobServiceClient_CreateJobDestinationConnections_Call struct

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

+ func (_c *MockJobServiceClient_CreateJobDestinationConnections_Call) Run(run func(_a0 context.Context, ...)) *MockJobServiceClient_CreateJobDestinationConnections_Call

+ func (_c *MockJobServiceClient_CreateJobDestinationConnections_Call) RunAndReturn(...) *MockJobServiceClient_CreateJobDestinationConnections_Call

+ type MockJobServiceClient_CreateJobRun_Call struct

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

+ func (_c *MockJobServiceClient_CreateJobRun_Call) Run(...) *MockJobServiceClient_CreateJobRun_Call

+ func (_c *MockJobServiceClient_CreateJobRun_Call) RunAndReturn(...) *MockJobServiceClient_CreateJobRun_Call

+ type MockJobServiceClient_CreateJob_Call struct

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

+ func (_c *MockJobServiceClient_CreateJob_Call) Run(...) *MockJobServiceClient_CreateJob_Call

+ func (_c *MockJobServiceClient_CreateJob_Call) RunAndReturn(...) *MockJobServiceClient_CreateJob_Call

+ type MockJobServiceClient_DeleteJobDestinationConnection_Call struct

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

+ func (_c *MockJobServiceClient_DeleteJobDestinationConnection_Call) Run(run func(_a0 context.Context, ...)) *MockJobServiceClient_DeleteJobDestinationConnection_Call

+ func (_c *MockJobServiceClient_DeleteJobDestinationConnection_Call) RunAndReturn(...) *MockJobServiceClient_DeleteJobDestinationConnection_Call

+ type MockJobServiceClient_DeleteJobRun_Call struct

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

+ func (_c *MockJobServiceClient_DeleteJobRun_Call) Run(...) *MockJobServiceClient_DeleteJobRun_Call

+ func (_c *MockJobServiceClient_DeleteJobRun_Call) RunAndReturn(...) *MockJobServiceClient_DeleteJobRun_Call

+ type MockJobServiceClient_DeleteJob_Call struct

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

+ func (_c *MockJobServiceClient_DeleteJob_Call) Run(...) *MockJobServiceClient_DeleteJob_Call

+ func (_c *MockJobServiceClient_DeleteJob_Call) RunAndReturn(...) *MockJobServiceClient_DeleteJob_Call

+ type MockJobServiceClient_Expecter struct

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type MockJobServiceClient_GetJobNextRuns_Call struct

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

+ func (_c *MockJobServiceClient_GetJobNextRuns_Call) Run(...) *MockJobServiceClient_GetJobNextRuns_Call

+ func (_c *MockJobServiceClient_GetJobNextRuns_Call) RunAndReturn(...) *MockJobServiceClient_GetJobNextRuns_Call

+ type MockJobServiceClient_GetJobRecentRuns_Call struct

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

+ func (_c *MockJobServiceClient_GetJobRecentRuns_Call) Run(run func(_a0 context.Context, ...)) *MockJobServiceClient_GetJobRecentRuns_Call

+ func (_c *MockJobServiceClient_GetJobRecentRuns_Call) RunAndReturn(...) *MockJobServiceClient_GetJobRecentRuns_Call

+ type MockJobServiceClient_GetJobRunEvents_Call struct

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

+ func (_c *MockJobServiceClient_GetJobRunEvents_Call) Run(...) *MockJobServiceClient_GetJobRunEvents_Call

+ func (_c *MockJobServiceClient_GetJobRunEvents_Call) RunAndReturn(...) *MockJobServiceClient_GetJobRunEvents_Call

+ type MockJobServiceClient_GetJobRunLogsStream_Call struct

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

+ func (_c *MockJobServiceClient_GetJobRunLogsStream_Call) Run(run func(_a0 context.Context, ...)) *MockJobServiceClient_GetJobRunLogsStream_Call

+ func (_c *MockJobServiceClient_GetJobRunLogsStream_Call) RunAndReturn(...) *MockJobServiceClient_GetJobRunLogsStream_Call

+ type MockJobServiceClient_GetJobRun_Call struct

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

+ func (_c *MockJobServiceClient_GetJobRun_Call) Run(...) *MockJobServiceClient_GetJobRun_Call

+ func (_c *MockJobServiceClient_GetJobRun_Call) RunAndReturn(...) *MockJobServiceClient_GetJobRun_Call

+ type MockJobServiceClient_GetJobRuns_Call struct

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

+ func (_c *MockJobServiceClient_GetJobRuns_Call) Run(...) *MockJobServiceClient_GetJobRuns_Call

+ func (_c *MockJobServiceClient_GetJobRuns_Call) RunAndReturn(...) *MockJobServiceClient_GetJobRuns_Call

+ type MockJobServiceClient_GetJobStatus_Call struct

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

+ func (_c *MockJobServiceClient_GetJobStatus_Call) Run(...) *MockJobServiceClient_GetJobStatus_Call

+ func (_c *MockJobServiceClient_GetJobStatus_Call) RunAndReturn(...) *MockJobServiceClient_GetJobStatus_Call

+ type MockJobServiceClient_GetJobStatuses_Call struct

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

+ func (_c *MockJobServiceClient_GetJobStatuses_Call) Run(...) *MockJobServiceClient_GetJobStatuses_Call

+ func (_c *MockJobServiceClient_GetJobStatuses_Call) RunAndReturn(...) *MockJobServiceClient_GetJobStatuses_Call

+ type MockJobServiceClient_GetJob_Call struct

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

+ func (_c *MockJobServiceClient_GetJob_Call) Run(...) *MockJobServiceClient_GetJob_Call

+ func (_c *MockJobServiceClient_GetJob_Call) RunAndReturn(...) *MockJobServiceClient_GetJob_Call

+ type MockJobServiceClient_GetJobs_Call struct

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

+ func (_c *MockJobServiceClient_GetJobs_Call) Run(...) *MockJobServiceClient_GetJobs_Call

+ func (_c *MockJobServiceClient_GetJobs_Call) RunAndReturn(...) *MockJobServiceClient_GetJobs_Call

+ type MockJobServiceClient_IsJobNameAvailable_Call struct

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

+ func (_c *MockJobServiceClient_IsJobNameAvailable_Call) Run(run func(_a0 context.Context, ...)) *MockJobServiceClient_IsJobNameAvailable_Call

+ func (_c *MockJobServiceClient_IsJobNameAvailable_Call) RunAndReturn(...) *MockJobServiceClient_IsJobNameAvailable_Call

+ type MockJobServiceClient_PauseJob_Call struct

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

+ func (_c *MockJobServiceClient_PauseJob_Call) Run(...) *MockJobServiceClient_PauseJob_Call

+ func (_c *MockJobServiceClient_PauseJob_Call) RunAndReturn(...) *MockJobServiceClient_PauseJob_Call

+ type MockJobServiceClient_SetJobSourceSqlConnectionSubsets_Call struct

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

+ func (_c *MockJobServiceClient_SetJobSourceSqlConnectionSubsets_Call) Run(run func(_a0 context.Context, ...)) *MockJobServiceClient_SetJobSourceSqlConnectionSubsets_Call

+ func (_c *MockJobServiceClient_SetJobSourceSqlConnectionSubsets_Call) RunAndReturn(...) *MockJobServiceClient_SetJobSourceSqlConnectionSubsets_Call

+ type MockJobServiceClient_SetJobSyncOptions_Call struct

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

+ func (_c *MockJobServiceClient_SetJobSyncOptions_Call) Run(run func(_a0 context.Context, ...)) *MockJobServiceClient_SetJobSyncOptions_Call

+ func (_c *MockJobServiceClient_SetJobSyncOptions_Call) RunAndReturn(...) *MockJobServiceClient_SetJobSyncOptions_Call

+ type MockJobServiceClient_SetJobWorkflowOptions_Call struct

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

+ func (_c *MockJobServiceClient_SetJobWorkflowOptions_Call) Run(run func(_a0 context.Context, ...)) *MockJobServiceClient_SetJobWorkflowOptions_Call

+ func (_c *MockJobServiceClient_SetJobWorkflowOptions_Call) RunAndReturn(...) *MockJobServiceClient_SetJobWorkflowOptions_Call

+ type MockJobServiceClient_TerminateJobRun_Call struct

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

+ func (_c *MockJobServiceClient_TerminateJobRun_Call) Run(...) *MockJobServiceClient_TerminateJobRun_Call

+ func (_c *MockJobServiceClient_TerminateJobRun_Call) RunAndReturn(...) *MockJobServiceClient_TerminateJobRun_Call

+ type MockJobServiceClient_UpdateJobDestinationConnection_Call struct

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

+ func (_c *MockJobServiceClient_UpdateJobDestinationConnection_Call) Run(run func(_a0 context.Context, ...)) *MockJobServiceClient_UpdateJobDestinationConnection_Call

+ func (_c *MockJobServiceClient_UpdateJobDestinationConnection_Call) RunAndReturn(...) *MockJobServiceClient_UpdateJobDestinationConnection_Call

+ type MockJobServiceClient_UpdateJobSchedule_Call struct

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

+ func (_c *MockJobServiceClient_UpdateJobSchedule_Call) Run(run func(_a0 context.Context, ...)) *MockJobServiceClient_UpdateJobSchedule_Call

+ func (_c *MockJobServiceClient_UpdateJobSchedule_Call) RunAndReturn(...) *MockJobServiceClient_UpdateJobSchedule_Call

+ type MockJobServiceClient_UpdateJobSourceConnection_Call struct

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

+ func (_c *MockJobServiceClient_UpdateJobSourceConnection_Call) Run(run func(_a0 context.Context, ...)) *MockJobServiceClient_UpdateJobSourceConnection_Call

+ func (_c *MockJobServiceClient_UpdateJobSourceConnection_Call) RunAndReturn(...) *MockJobServiceClient_UpdateJobSourceConnection_Call

+ type MockJobServiceHandler struct

+ func NewMockJobServiceHandler(t interface{ ... }) *MockJobServiceHandler

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

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

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

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

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

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

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

+ func (_m *MockJobServiceHandler) EXPECT() *MockJobServiceHandler_Expecter

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

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

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

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

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

+ func (_m *MockJobServiceHandler) GetJobRunLogsStream(_a0 context.Context, ...) error

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

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

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

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

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

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

+ func (_m *MockJobServiceHandler) SetJobSourceSqlConnectionSubsets(_a0 context.Context, ...) (*connect.Response[mgmtv1alpha1.SetJobSourceSqlConnectionSubsetsResponse], ...)

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

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

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

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

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

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

+ type MockJobServiceHandler_CancelJobRun_Call struct

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

+ func (_c *MockJobServiceHandler_CancelJobRun_Call) Run(...) *MockJobServiceHandler_CancelJobRun_Call

+ func (_c *MockJobServiceHandler_CancelJobRun_Call) RunAndReturn(...) *MockJobServiceHandler_CancelJobRun_Call

+ type MockJobServiceHandler_CreateJobDestinationConnections_Call struct

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

+ func (_c *MockJobServiceHandler_CreateJobDestinationConnections_Call) Run(run func(_a0 context.Context, ...)) *MockJobServiceHandler_CreateJobDestinationConnections_Call

+ func (_c *MockJobServiceHandler_CreateJobDestinationConnections_Call) RunAndReturn(...) *MockJobServiceHandler_CreateJobDestinationConnections_Call

+ type MockJobServiceHandler_CreateJobRun_Call struct

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

+ func (_c *MockJobServiceHandler_CreateJobRun_Call) Run(...) *MockJobServiceHandler_CreateJobRun_Call

+ func (_c *MockJobServiceHandler_CreateJobRun_Call) RunAndReturn(...) *MockJobServiceHandler_CreateJobRun_Call

+ type MockJobServiceHandler_CreateJob_Call struct

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

+ func (_c *MockJobServiceHandler_CreateJob_Call) Run(...) *MockJobServiceHandler_CreateJob_Call

+ func (_c *MockJobServiceHandler_CreateJob_Call) RunAndReturn(...) *MockJobServiceHandler_CreateJob_Call

+ type MockJobServiceHandler_DeleteJobDestinationConnection_Call struct

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

+ func (_c *MockJobServiceHandler_DeleteJobDestinationConnection_Call) Run(run func(_a0 context.Context, ...)) *MockJobServiceHandler_DeleteJobDestinationConnection_Call

+ func (_c *MockJobServiceHandler_DeleteJobDestinationConnection_Call) RunAndReturn(...) *MockJobServiceHandler_DeleteJobDestinationConnection_Call

+ type MockJobServiceHandler_DeleteJobRun_Call struct

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

+ func (_c *MockJobServiceHandler_DeleteJobRun_Call) Run(...) *MockJobServiceHandler_DeleteJobRun_Call

+ func (_c *MockJobServiceHandler_DeleteJobRun_Call) RunAndReturn(...) *MockJobServiceHandler_DeleteJobRun_Call

+ type MockJobServiceHandler_DeleteJob_Call struct

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

+ func (_c *MockJobServiceHandler_DeleteJob_Call) Run(...) *MockJobServiceHandler_DeleteJob_Call

+ func (_c *MockJobServiceHandler_DeleteJob_Call) RunAndReturn(...) *MockJobServiceHandler_DeleteJob_Call

+ type MockJobServiceHandler_Expecter struct

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

+ type MockJobServiceHandler_GetJobNextRuns_Call struct

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

+ func (_c *MockJobServiceHandler_GetJobNextRuns_Call) Run(...) *MockJobServiceHandler_GetJobNextRuns_Call

+ func (_c *MockJobServiceHandler_GetJobNextRuns_Call) RunAndReturn(...) *MockJobServiceHandler_GetJobNextRuns_Call

+ type MockJobServiceHandler_GetJobRecentRuns_Call struct

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

+ func (_c *MockJobServiceHandler_GetJobRecentRuns_Call) Run(run func(_a0 context.Context, ...)) *MockJobServiceHandler_GetJobRecentRuns_Call

+ func (_c *MockJobServiceHandler_GetJobRecentRuns_Call) RunAndReturn(...) *MockJobServiceHandler_GetJobRecentRuns_Call

+ type MockJobServiceHandler_GetJobRunEvents_Call struct

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

+ func (_c *MockJobServiceHandler_GetJobRunEvents_Call) Run(...) *MockJobServiceHandler_GetJobRunEvents_Call

+ func (_c *MockJobServiceHandler_GetJobRunEvents_Call) RunAndReturn(...) *MockJobServiceHandler_GetJobRunEvents_Call

+ type MockJobServiceHandler_GetJobRunLogsStream_Call struct

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

+ func (_c *MockJobServiceHandler_GetJobRunLogsStream_Call) Run(run func(_a0 context.Context, ...)) *MockJobServiceHandler_GetJobRunLogsStream_Call

+ func (_c *MockJobServiceHandler_GetJobRunLogsStream_Call) RunAndReturn(...) *MockJobServiceHandler_GetJobRunLogsStream_Call

+ type MockJobServiceHandler_GetJobRun_Call struct

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

+ func (_c *MockJobServiceHandler_GetJobRun_Call) Run(...) *MockJobServiceHandler_GetJobRun_Call

+ func (_c *MockJobServiceHandler_GetJobRun_Call) RunAndReturn(...) *MockJobServiceHandler_GetJobRun_Call

+ type MockJobServiceHandler_GetJobRuns_Call struct

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

+ func (_c *MockJobServiceHandler_GetJobRuns_Call) Run(...) *MockJobServiceHandler_GetJobRuns_Call

+ func (_c *MockJobServiceHandler_GetJobRuns_Call) RunAndReturn(...) *MockJobServiceHandler_GetJobRuns_Call

+ type MockJobServiceHandler_GetJobStatus_Call struct

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

+ func (_c *MockJobServiceHandler_GetJobStatus_Call) Run(...) *MockJobServiceHandler_GetJobStatus_Call

+ func (_c *MockJobServiceHandler_GetJobStatus_Call) RunAndReturn(...) *MockJobServiceHandler_GetJobStatus_Call

+ type MockJobServiceHandler_GetJobStatuses_Call struct

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

+ func (_c *MockJobServiceHandler_GetJobStatuses_Call) Run(...) *MockJobServiceHandler_GetJobStatuses_Call

+ func (_c *MockJobServiceHandler_GetJobStatuses_Call) RunAndReturn(...) *MockJobServiceHandler_GetJobStatuses_Call

+ type MockJobServiceHandler_GetJob_Call struct

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

+ func (_c *MockJobServiceHandler_GetJob_Call) Run(...) *MockJobServiceHandler_GetJob_Call

+ func (_c *MockJobServiceHandler_GetJob_Call) RunAndReturn(...) *MockJobServiceHandler_GetJob_Call

+ type MockJobServiceHandler_GetJobs_Call struct

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

+ func (_c *MockJobServiceHandler_GetJobs_Call) Run(...) *MockJobServiceHandler_GetJobs_Call

+ func (_c *MockJobServiceHandler_GetJobs_Call) RunAndReturn(...) *MockJobServiceHandler_GetJobs_Call

+ type MockJobServiceHandler_IsJobNameAvailable_Call struct

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

+ func (_c *MockJobServiceHandler_IsJobNameAvailable_Call) Run(run func(_a0 context.Context, ...)) *MockJobServiceHandler_IsJobNameAvailable_Call

+ func (_c *MockJobServiceHandler_IsJobNameAvailable_Call) RunAndReturn(...) *MockJobServiceHandler_IsJobNameAvailable_Call

+ type MockJobServiceHandler_PauseJob_Call struct

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

+ func (_c *MockJobServiceHandler_PauseJob_Call) Run(...) *MockJobServiceHandler_PauseJob_Call

+ func (_c *MockJobServiceHandler_PauseJob_Call) RunAndReturn(...) *MockJobServiceHandler_PauseJob_Call

+ type MockJobServiceHandler_SetJobSourceSqlConnectionSubsets_Call struct

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

+ func (_c *MockJobServiceHandler_SetJobSourceSqlConnectionSubsets_Call) Run(run func(_a0 context.Context, ...)) *MockJobServiceHandler_SetJobSourceSqlConnectionSubsets_Call

+ func (_c *MockJobServiceHandler_SetJobSourceSqlConnectionSubsets_Call) RunAndReturn(...) *MockJobServiceHandler_SetJobSourceSqlConnectionSubsets_Call

+ type MockJobServiceHandler_SetJobSyncOptions_Call struct

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

+ func (_c *MockJobServiceHandler_SetJobSyncOptions_Call) Run(run func(_a0 context.Context, ...)) *MockJobServiceHandler_SetJobSyncOptions_Call

+ func (_c *MockJobServiceHandler_SetJobSyncOptions_Call) RunAndReturn(...) *MockJobServiceHandler_SetJobSyncOptions_Call

+ type MockJobServiceHandler_SetJobWorkflowOptions_Call struct

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

+ func (_c *MockJobServiceHandler_SetJobWorkflowOptions_Call) Run(run func(_a0 context.Context, ...)) *MockJobServiceHandler_SetJobWorkflowOptions_Call

+ func (_c *MockJobServiceHandler_SetJobWorkflowOptions_Call) RunAndReturn(...) *MockJobServiceHandler_SetJobWorkflowOptions_Call

+ type MockJobServiceHandler_TerminateJobRun_Call struct

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

+ func (_c *MockJobServiceHandler_TerminateJobRun_Call) Run(...) *MockJobServiceHandler_TerminateJobRun_Call

+ func (_c *MockJobServiceHandler_TerminateJobRun_Call) RunAndReturn(...) *MockJobServiceHandler_TerminateJobRun_Call

+ type MockJobServiceHandler_UpdateJobDestinationConnection_Call struct

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

+ func (_c *MockJobServiceHandler_UpdateJobDestinationConnection_Call) Run(run func(_a0 context.Context, ...)) *MockJobServiceHandler_UpdateJobDestinationConnection_Call

+ func (_c *MockJobServiceHandler_UpdateJobDestinationConnection_Call) RunAndReturn(...) *MockJobServiceHandler_UpdateJobDestinationConnection_Call

+ type MockJobServiceHandler_UpdateJobSchedule_Call struct

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

+ func (_c *MockJobServiceHandler_UpdateJobSchedule_Call) Run(run func(_a0 context.Context, ...)) *MockJobServiceHandler_UpdateJobSchedule_Call

+ func (_c *MockJobServiceHandler_UpdateJobSchedule_Call) RunAndReturn(...) *MockJobServiceHandler_UpdateJobSchedule_Call

+ type MockJobServiceHandler_UpdateJobSourceConnection_Call struct

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

+ func (_c *MockJobServiceHandler_UpdateJobSourceConnection_Call) Run(run func(_a0 context.Context, ...)) *MockJobServiceHandler_UpdateJobSourceConnection_Call

+ func (_c *MockJobServiceHandler_UpdateJobSourceConnection_Call) RunAndReturn(...) *MockJobServiceHandler_UpdateJobSourceConnection_Call

+ type MockTransformersServiceClient struct

+ func NewMockTransformersServiceClient(t interface{ ... }) *MockTransformersServiceClient

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

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

+ func (_m *MockTransformersServiceClient) EXPECT() *MockTransformersServiceClient_Expecter

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

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

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

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

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

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

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

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

+ type MockTransformersServiceClient_CreateUserDefinedTransformer_Call struct

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

+ func (_c *MockTransformersServiceClient_CreateUserDefinedTransformer_Call) Run(run func(_a0 context.Context, ...)) *MockTransformersServiceClient_CreateUserDefinedTransformer_Call

+ func (_c *MockTransformersServiceClient_CreateUserDefinedTransformer_Call) RunAndReturn(...) *MockTransformersServiceClient_CreateUserDefinedTransformer_Call

+ type MockTransformersServiceClient_DeleteUserDefinedTransformer_Call struct

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

+ func (_c *MockTransformersServiceClient_DeleteUserDefinedTransformer_Call) Run(run func(_a0 context.Context, ...)) *MockTransformersServiceClient_DeleteUserDefinedTransformer_Call

+ func (_c *MockTransformersServiceClient_DeleteUserDefinedTransformer_Call) RunAndReturn(...) *MockTransformersServiceClient_DeleteUserDefinedTransformer_Call

+ type MockTransformersServiceClient_Expecter struct

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

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

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

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

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

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

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

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

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

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

+ type MockTransformersServiceClient_GetSystemTransformerBySource_Call struct

+ func (_c *MockTransformersServiceClient_GetSystemTransformerBySource_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetSystemTransformerBySourceResponse], ...) *MockTransformersServiceClient_GetSystemTransformerBySource_Call

+ func (_c *MockTransformersServiceClient_GetSystemTransformerBySource_Call) Run(run func(_a0 context.Context, ...)) *MockTransformersServiceClient_GetSystemTransformerBySource_Call

+ func (_c *MockTransformersServiceClient_GetSystemTransformerBySource_Call) RunAndReturn(...) *MockTransformersServiceClient_GetSystemTransformerBySource_Call

+ type MockTransformersServiceClient_GetSystemTransformers_Call struct

+ func (_c *MockTransformersServiceClient_GetSystemTransformers_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetSystemTransformersResponse], _a1 error) *MockTransformersServiceClient_GetSystemTransformers_Call

+ func (_c *MockTransformersServiceClient_GetSystemTransformers_Call) Run(run func(_a0 context.Context, ...)) *MockTransformersServiceClient_GetSystemTransformers_Call

+ func (_c *MockTransformersServiceClient_GetSystemTransformers_Call) RunAndReturn(...) *MockTransformersServiceClient_GetSystemTransformers_Call

+ type MockTransformersServiceClient_GetUserDefinedTransformerById_Call struct

+ func (_c *MockTransformersServiceClient_GetUserDefinedTransformerById_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetUserDefinedTransformerByIdResponse], ...) *MockTransformersServiceClient_GetUserDefinedTransformerById_Call

+ func (_c *MockTransformersServiceClient_GetUserDefinedTransformerById_Call) Run(run func(_a0 context.Context, ...)) *MockTransformersServiceClient_GetUserDefinedTransformerById_Call

+ func (_c *MockTransformersServiceClient_GetUserDefinedTransformerById_Call) RunAndReturn(...) *MockTransformersServiceClient_GetUserDefinedTransformerById_Call

+ type MockTransformersServiceClient_GetUserDefinedTransformers_Call struct

+ func (_c *MockTransformersServiceClient_GetUserDefinedTransformers_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetUserDefinedTransformersResponse], ...) *MockTransformersServiceClient_GetUserDefinedTransformers_Call

+ func (_c *MockTransformersServiceClient_GetUserDefinedTransformers_Call) Run(run func(_a0 context.Context, ...)) *MockTransformersServiceClient_GetUserDefinedTransformers_Call

+ func (_c *MockTransformersServiceClient_GetUserDefinedTransformers_Call) RunAndReturn(...) *MockTransformersServiceClient_GetUserDefinedTransformers_Call

+ type MockTransformersServiceClient_IsTransformerNameAvailable_Call struct

+ func (_c *MockTransformersServiceClient_IsTransformerNameAvailable_Call) Return(_a0 *connect.Response[mgmtv1alpha1.IsTransformerNameAvailableResponse], ...) *MockTransformersServiceClient_IsTransformerNameAvailable_Call

+ func (_c *MockTransformersServiceClient_IsTransformerNameAvailable_Call) Run(run func(_a0 context.Context, ...)) *MockTransformersServiceClient_IsTransformerNameAvailable_Call

+ func (_c *MockTransformersServiceClient_IsTransformerNameAvailable_Call) RunAndReturn(...) *MockTransformersServiceClient_IsTransformerNameAvailable_Call

+ type MockTransformersServiceClient_UpdateUserDefinedTransformer_Call struct

+ func (_c *MockTransformersServiceClient_UpdateUserDefinedTransformer_Call) Return(_a0 *connect.Response[mgmtv1alpha1.UpdateUserDefinedTransformerResponse], ...) *MockTransformersServiceClient_UpdateUserDefinedTransformer_Call

+ func (_c *MockTransformersServiceClient_UpdateUserDefinedTransformer_Call) Run(run func(_a0 context.Context, ...)) *MockTransformersServiceClient_UpdateUserDefinedTransformer_Call

+ func (_c *MockTransformersServiceClient_UpdateUserDefinedTransformer_Call) RunAndReturn(...) *MockTransformersServiceClient_UpdateUserDefinedTransformer_Call

+ type MockTransformersServiceClient_ValidateUserJavascriptCode_Call struct

+ func (_c *MockTransformersServiceClient_ValidateUserJavascriptCode_Call) Return(_a0 *connect.Response[mgmtv1alpha1.ValidateUserJavascriptCodeResponse], ...) *MockTransformersServiceClient_ValidateUserJavascriptCode_Call

+ func (_c *MockTransformersServiceClient_ValidateUserJavascriptCode_Call) Run(run func(_a0 context.Context, ...)) *MockTransformersServiceClient_ValidateUserJavascriptCode_Call

+ func (_c *MockTransformersServiceClient_ValidateUserJavascriptCode_Call) RunAndReturn(...) *MockTransformersServiceClient_ValidateUserJavascriptCode_Call

+ type MockTransformersServiceClient_ValidateUserRegexCode_Call struct

+ func (_c *MockTransformersServiceClient_ValidateUserRegexCode_Call) Return(_a0 *connect.Response[mgmtv1alpha1.ValidateUserRegexCodeResponse], _a1 error) *MockTransformersServiceClient_ValidateUserRegexCode_Call

+ func (_c *MockTransformersServiceClient_ValidateUserRegexCode_Call) Run(run func(_a0 context.Context, ...)) *MockTransformersServiceClient_ValidateUserRegexCode_Call

+ func (_c *MockTransformersServiceClient_ValidateUserRegexCode_Call) RunAndReturn(...) *MockTransformersServiceClient_ValidateUserRegexCode_Call

+ type MockUserAccountServiceClient struct

+ func NewMockUserAccountServiceClient(t interface{ ... }) *MockUserAccountServiceClient

+ func (_m *MockUserAccountServiceClient) AcceptTeamAccountInvite(_a0 context.Context, ...) (*connect.Response[mgmtv1alpha1.AcceptTeamAccountInviteResponse], error)

+ func (_m *MockUserAccountServiceClient) ConvertPersonalToTeamAccount(_a0 context.Context, ...) (*connect.Response[mgmtv1alpha1.ConvertPersonalToTeamAccountResponse], error)

+ func (_m *MockUserAccountServiceClient) CreateTeamAccount(_a0 context.Context, ...) (*connect.Response[mgmtv1alpha1.CreateTeamAccountResponse], error)

+ func (_m *MockUserAccountServiceClient) EXPECT() *MockUserAccountServiceClient_Expecter

+ func (_m *MockUserAccountServiceClient) GetAccountOnboardingConfig(_a0 context.Context, ...) (*connect.Response[mgmtv1alpha1.GetAccountOnboardingConfigResponse], error)

+ func (_m *MockUserAccountServiceClient) GetAccountTemporalConfig(_a0 context.Context, ...) (*connect.Response[mgmtv1alpha1.GetAccountTemporalConfigResponse], error)

+ func (_m *MockUserAccountServiceClient) GetSystemInformation(_a0 context.Context, ...) (*connect.Response[mgmtv1alpha1.GetSystemInformationResponse], error)

+ func (_m *MockUserAccountServiceClient) GetTeamAccountInvites(_a0 context.Context, ...) (*connect.Response[mgmtv1alpha1.GetTeamAccountInvitesResponse], error)

+ func (_m *MockUserAccountServiceClient) GetTeamAccountMembers(_a0 context.Context, ...) (*connect.Response[mgmtv1alpha1.GetTeamAccountMembersResponse], error)

+ func (_m *MockUserAccountServiceClient) GetUser(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetUserRequest]) (*connect.Response[mgmtv1alpha1.GetUserResponse], error)

+ func (_m *MockUserAccountServiceClient) GetUserAccounts(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.GetUserAccountsRequest]) (*connect.Response[mgmtv1alpha1.GetUserAccountsResponse], error)

+ func (_m *MockUserAccountServiceClient) InviteUserToTeamAccount(_a0 context.Context, ...) (*connect.Response[mgmtv1alpha1.InviteUserToTeamAccountResponse], error)

+ func (_m *MockUserAccountServiceClient) IsUserInAccount(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.IsUserInAccountRequest]) (*connect.Response[mgmtv1alpha1.IsUserInAccountResponse], error)

+ func (_m *MockUserAccountServiceClient) RemoveTeamAccountInvite(_a0 context.Context, ...) (*connect.Response[mgmtv1alpha1.RemoveTeamAccountInviteResponse], error)

+ func (_m *MockUserAccountServiceClient) RemoveTeamAccountMember(_a0 context.Context, ...) (*connect.Response[mgmtv1alpha1.RemoveTeamAccountMemberResponse], error)

+ func (_m *MockUserAccountServiceClient) SetAccountOnboardingConfig(_a0 context.Context, ...) (*connect.Response[mgmtv1alpha1.SetAccountOnboardingConfigResponse], error)

+ func (_m *MockUserAccountServiceClient) SetAccountTemporalConfig(_a0 context.Context, ...) (*connect.Response[mgmtv1alpha1.SetAccountTemporalConfigResponse], error)

+ func (_m *MockUserAccountServiceClient) SetPersonalAccount(_a0 context.Context, ...) (*connect.Response[mgmtv1alpha1.SetPersonalAccountResponse], error)

+ func (_m *MockUserAccountServiceClient) SetUser(_a0 context.Context, _a1 *connect.Request[mgmtv1alpha1.SetUserRequest]) (*connect.Response[mgmtv1alpha1.SetUserResponse], error)

+ type MockUserAccountServiceClient_AcceptTeamAccountInvite_Call struct

+ func (_c *MockUserAccountServiceClient_AcceptTeamAccountInvite_Call) Return(_a0 *connect.Response[mgmtv1alpha1.AcceptTeamAccountInviteResponse], _a1 error) *MockUserAccountServiceClient_AcceptTeamAccountInvite_Call

+ func (_c *MockUserAccountServiceClient_AcceptTeamAccountInvite_Call) Run(run func(_a0 context.Context, ...)) *MockUserAccountServiceClient_AcceptTeamAccountInvite_Call

+ func (_c *MockUserAccountServiceClient_AcceptTeamAccountInvite_Call) RunAndReturn(...) *MockUserAccountServiceClient_AcceptTeamAccountInvite_Call

+ type MockUserAccountServiceClient_ConvertPersonalToTeamAccount_Call struct

+ func (_c *MockUserAccountServiceClient_ConvertPersonalToTeamAccount_Call) Return(_a0 *connect.Response[mgmtv1alpha1.ConvertPersonalToTeamAccountResponse], ...) *MockUserAccountServiceClient_ConvertPersonalToTeamAccount_Call

+ func (_c *MockUserAccountServiceClient_ConvertPersonalToTeamAccount_Call) Run(run func(_a0 context.Context, ...)) *MockUserAccountServiceClient_ConvertPersonalToTeamAccount_Call

+ func (_c *MockUserAccountServiceClient_ConvertPersonalToTeamAccount_Call) RunAndReturn(...) *MockUserAccountServiceClient_ConvertPersonalToTeamAccount_Call

+ type MockUserAccountServiceClient_CreateTeamAccount_Call struct

+ func (_c *MockUserAccountServiceClient_CreateTeamAccount_Call) Return(_a0 *connect.Response[mgmtv1alpha1.CreateTeamAccountResponse], _a1 error) *MockUserAccountServiceClient_CreateTeamAccount_Call

+ func (_c *MockUserAccountServiceClient_CreateTeamAccount_Call) Run(run func(_a0 context.Context, ...)) *MockUserAccountServiceClient_CreateTeamAccount_Call

+ func (_c *MockUserAccountServiceClient_CreateTeamAccount_Call) RunAndReturn(...) *MockUserAccountServiceClient_CreateTeamAccount_Call

+ type MockUserAccountServiceClient_Expecter struct

+ func (_e *MockUserAccountServiceClient_Expecter) AcceptTeamAccountInvite(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_AcceptTeamAccountInvite_Call

+ func (_e *MockUserAccountServiceClient_Expecter) ConvertPersonalToTeamAccount(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_ConvertPersonalToTeamAccount_Call

+ func (_e *MockUserAccountServiceClient_Expecter) CreateTeamAccount(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_CreateTeamAccount_Call

+ func (_e *MockUserAccountServiceClient_Expecter) GetAccountOnboardingConfig(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_GetAccountOnboardingConfig_Call

+ func (_e *MockUserAccountServiceClient_Expecter) GetAccountTemporalConfig(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_GetAccountTemporalConfig_Call

+ func (_e *MockUserAccountServiceClient_Expecter) GetSystemInformation(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_GetSystemInformation_Call

+ func (_e *MockUserAccountServiceClient_Expecter) GetTeamAccountInvites(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_GetTeamAccountInvites_Call

+ func (_e *MockUserAccountServiceClient_Expecter) GetTeamAccountMembers(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_GetTeamAccountMembers_Call

+ func (_e *MockUserAccountServiceClient_Expecter) GetUser(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_GetUser_Call

+ func (_e *MockUserAccountServiceClient_Expecter) GetUserAccounts(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_GetUserAccounts_Call

+ func (_e *MockUserAccountServiceClient_Expecter) InviteUserToTeamAccount(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_InviteUserToTeamAccount_Call

+ func (_e *MockUserAccountServiceClient_Expecter) IsUserInAccount(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_IsUserInAccount_Call

+ func (_e *MockUserAccountServiceClient_Expecter) RemoveTeamAccountInvite(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_RemoveTeamAccountInvite_Call

+ func (_e *MockUserAccountServiceClient_Expecter) RemoveTeamAccountMember(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_RemoveTeamAccountMember_Call

+ func (_e *MockUserAccountServiceClient_Expecter) SetAccountOnboardingConfig(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_SetAccountOnboardingConfig_Call

+ func (_e *MockUserAccountServiceClient_Expecter) SetAccountTemporalConfig(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_SetAccountTemporalConfig_Call

+ func (_e *MockUserAccountServiceClient_Expecter) SetPersonalAccount(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_SetPersonalAccount_Call

+ func (_e *MockUserAccountServiceClient_Expecter) SetUser(_a0 interface{}, _a1 interface{}) *MockUserAccountServiceClient_SetUser_Call

+ type MockUserAccountServiceClient_GetAccountOnboardingConfig_Call struct

+ func (_c *MockUserAccountServiceClient_GetAccountOnboardingConfig_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetAccountOnboardingConfigResponse], ...) *MockUserAccountServiceClient_GetAccountOnboardingConfig_Call

+ func (_c *MockUserAccountServiceClient_GetAccountOnboardingConfig_Call) Run(run func(_a0 context.Context, ...)) *MockUserAccountServiceClient_GetAccountOnboardingConfig_Call

+ func (_c *MockUserAccountServiceClient_GetAccountOnboardingConfig_Call) RunAndReturn(...) *MockUserAccountServiceClient_GetAccountOnboardingConfig_Call

+ type MockUserAccountServiceClient_GetAccountTemporalConfig_Call struct

+ func (_c *MockUserAccountServiceClient_GetAccountTemporalConfig_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetAccountTemporalConfigResponse], ...) *MockUserAccountServiceClient_GetAccountTemporalConfig_Call

+ func (_c *MockUserAccountServiceClient_GetAccountTemporalConfig_Call) Run(run func(_a0 context.Context, ...)) *MockUserAccountServiceClient_GetAccountTemporalConfig_Call

+ func (_c *MockUserAccountServiceClient_GetAccountTemporalConfig_Call) RunAndReturn(...) *MockUserAccountServiceClient_GetAccountTemporalConfig_Call

+ type MockUserAccountServiceClient_GetSystemInformation_Call struct

+ func (_c *MockUserAccountServiceClient_GetSystemInformation_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetSystemInformationResponse], _a1 error) *MockUserAccountServiceClient_GetSystemInformation_Call

+ func (_c *MockUserAccountServiceClient_GetSystemInformation_Call) Run(run func(_a0 context.Context, ...)) *MockUserAccountServiceClient_GetSystemInformation_Call

+ func (_c *MockUserAccountServiceClient_GetSystemInformation_Call) RunAndReturn(...) *MockUserAccountServiceClient_GetSystemInformation_Call

+ type MockUserAccountServiceClient_GetTeamAccountInvites_Call struct

+ func (_c *MockUserAccountServiceClient_GetTeamAccountInvites_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetTeamAccountInvitesResponse], _a1 error) *MockUserAccountServiceClient_GetTeamAccountInvites_Call

+ func (_c *MockUserAccountServiceClient_GetTeamAccountInvites_Call) Run(run func(_a0 context.Context, ...)) *MockUserAccountServiceClient_GetTeamAccountInvites_Call

+ func (_c *MockUserAccountServiceClient_GetTeamAccountInvites_Call) RunAndReturn(...) *MockUserAccountServiceClient_GetTeamAccountInvites_Call

+ type MockUserAccountServiceClient_GetTeamAccountMembers_Call struct

+ func (_c *MockUserAccountServiceClient_GetTeamAccountMembers_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetTeamAccountMembersResponse], _a1 error) *MockUserAccountServiceClient_GetTeamAccountMembers_Call

+ func (_c *MockUserAccountServiceClient_GetTeamAccountMembers_Call) Run(run func(_a0 context.Context, ...)) *MockUserAccountServiceClient_GetTeamAccountMembers_Call

+ func (_c *MockUserAccountServiceClient_GetTeamAccountMembers_Call) RunAndReturn(...) *MockUserAccountServiceClient_GetTeamAccountMembers_Call

+ type MockUserAccountServiceClient_GetUserAccounts_Call struct

+ func (_c *MockUserAccountServiceClient_GetUserAccounts_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetUserAccountsResponse], _a1 error) *MockUserAccountServiceClient_GetUserAccounts_Call

+ func (_c *MockUserAccountServiceClient_GetUserAccounts_Call) Run(...) *MockUserAccountServiceClient_GetUserAccounts_Call

+ func (_c *MockUserAccountServiceClient_GetUserAccounts_Call) RunAndReturn(...) *MockUserAccountServiceClient_GetUserAccounts_Call

+ type MockUserAccountServiceClient_GetUser_Call struct

+ func (_c *MockUserAccountServiceClient_GetUser_Call) Return(_a0 *connect.Response[mgmtv1alpha1.GetUserResponse], _a1 error) *MockUserAccountServiceClient_GetUser_Call

+ func (_c *MockUserAccountServiceClient_GetUser_Call) Run(...) *MockUserAccountServiceClient_GetUser_Call

+ func (_c *MockUserAccountServiceClient_GetUser_Call) RunAndReturn(...) *MockUserAccountServiceClient_GetUser_Call

+ type MockUserAccountServiceClient_InviteUserToTeamAccount_Call struct

+ func (_c *MockUserAccountServiceClient_InviteUserToTeamAccount_Call) Return(_a0 *connect.Response[mgmtv1alpha1.InviteUserToTeamAccountResponse], _a1 error) *MockUserAccountServiceClient_InviteUserToTeamAccount_Call

+ func (_c *MockUserAccountServiceClient_InviteUserToTeamAccount_Call) Run(run func(_a0 context.Context, ...)) *MockUserAccountServiceClient_InviteUserToTeamAccount_Call

+ func (_c *MockUserAccountServiceClient_InviteUserToTeamAccount_Call) RunAndReturn(...) *MockUserAccountServiceClient_InviteUserToTeamAccount_Call

+ type MockUserAccountServiceClient_IsUserInAccount_Call struct

+ func (_c *MockUserAccountServiceClient_IsUserInAccount_Call) Return(_a0 *connect.Response[mgmtv1alpha1.IsUserInAccountResponse], _a1 error) *MockUserAccountServiceClient_IsUserInAccount_Call

+ func (_c *MockUserAccountServiceClient_IsUserInAccount_Call) Run(...) *MockUserAccountServiceClient_IsUserInAccount_Call

+ func (_c *MockUserAccountServiceClient_IsUserInAccount_Call) RunAndReturn(...) *MockUserAccountServiceClient_IsUserInAccount_Call

+ type MockUserAccountServiceClient_RemoveTeamAccountInvite_Call struct

+ func (_c *MockUserAccountServiceClient_RemoveTeamAccountInvite_Call) Return(_a0 *connect.Response[mgmtv1alpha1.RemoveTeamAccountInviteResponse], _a1 error) *MockUserAccountServiceClient_RemoveTeamAccountInvite_Call

+ func (_c *MockUserAccountServiceClient_RemoveTeamAccountInvite_Call) Run(run func(_a0 context.Context, ...)) *MockUserAccountServiceClient_RemoveTeamAccountInvite_Call

+ func (_c *MockUserAccountServiceClient_RemoveTeamAccountInvite_Call) RunAndReturn(...) *MockUserAccountServiceClient_RemoveTeamAccountInvite_Call

+ type MockUserAccountServiceClient_RemoveTeamAccountMember_Call struct

+ func (_c *MockUserAccountServiceClient_RemoveTeamAccountMember_Call) Return(_a0 *connect.Response[mgmtv1alpha1.RemoveTeamAccountMemberResponse], _a1 error) *MockUserAccountServiceClient_RemoveTeamAccountMember_Call

+ func (_c *MockUserAccountServiceClient_RemoveTeamAccountMember_Call) Run(run func(_a0 context.Context, ...)) *MockUserAccountServiceClient_RemoveTeamAccountMember_Call

+ func (_c *MockUserAccountServiceClient_RemoveTeamAccountMember_Call) RunAndReturn(...) *MockUserAccountServiceClient_RemoveTeamAccountMember_Call

+ type MockUserAccountServiceClient_SetAccountOnboardingConfig_Call struct

+ func (_c *MockUserAccountServiceClient_SetAccountOnboardingConfig_Call) Return(_a0 *connect.Response[mgmtv1alpha1.SetAccountOnboardingConfigResponse], ...) *MockUserAccountServiceClient_SetAccountOnboardingConfig_Call

+ func (_c *MockUserAccountServiceClient_SetAccountOnboardingConfig_Call) Run(run func(_a0 context.Context, ...)) *MockUserAccountServiceClient_SetAccountOnboardingConfig_Call

+ func (_c *MockUserAccountServiceClient_SetAccountOnboardingConfig_Call) RunAndReturn(...) *MockUserAccountServiceClient_SetAccountOnboardingConfig_Call

+ type MockUserAccountServiceClient_SetAccountTemporalConfig_Call struct

+ func (_c *MockUserAccountServiceClient_SetAccountTemporalConfig_Call) Return(_a0 *connect.Response[mgmtv1alpha1.SetAccountTemporalConfigResponse], ...) *MockUserAccountServiceClient_SetAccountTemporalConfig_Call

+ func (_c *MockUserAccountServiceClient_SetAccountTemporalConfig_Call) Run(run func(_a0 context.Context, ...)) *MockUserAccountServiceClient_SetAccountTemporalConfig_Call

+ func (_c *MockUserAccountServiceClient_SetAccountTemporalConfig_Call) RunAndReturn(...) *MockUserAccountServiceClient_SetAccountTemporalConfig_Call

+ type MockUserAccountServiceClient_SetPersonalAccount_Call struct

+ func (_c *MockUserAccountServiceClient_SetPersonalAccount_Call) Return(_a0 *connect.Response[mgmtv1alpha1.SetPersonalAccountResponse], _a1 error) *MockUserAccountServiceClient_SetPersonalAccount_Call

+ func (_c *MockUserAccountServiceClient_SetPersonalAccount_Call) Run(run func(_a0 context.Context, ...)) *MockUserAccountServiceClient_SetPersonalAccount_Call

+ func (_c *MockUserAccountServiceClient_SetPersonalAccount_Call) RunAndReturn(...) *MockUserAccountServiceClient_SetPersonalAccount_Call

+ type MockUserAccountServiceClient_SetUser_Call struct

+ func (_c *MockUserAccountServiceClient_SetUser_Call) Return(_a0 *connect.Response[mgmtv1alpha1.SetUserResponse], _a1 error) *MockUserAccountServiceClient_SetUser_Call

+ func (_c *MockUserAccountServiceClient_SetUser_Call) Run(...) *MockUserAccountServiceClient_SetUser_Call

+ func (_c *MockUserAccountServiceClient_SetUser_Call) RunAndReturn(...) *MockUserAccountServiceClient_SetUser_Call

+ type TransformersServiceClient interface

+ CreateUserDefinedTransformer func(context.Context, ...) (*connect.Response[v1alpha1.CreateUserDefinedTransformerResponse], error)

+ DeleteUserDefinedTransformer func(context.Context, ...) (*connect.Response[v1alpha1.DeleteUserDefinedTransformerResponse], error)

+ GetSystemTransformerBySource func(context.Context, ...) (*connect.Response[v1alpha1.GetSystemTransformerBySourceResponse], error)

+ GetSystemTransformers func(context.Context, *connect.Request[v1alpha1.GetSystemTransformersRequest]) (*connect.Response[v1alpha1.GetSystemTransformersResponse], error)

+ GetUserDefinedTransformerById func(context.Context, ...) (*connect.Response[v1alpha1.GetUserDefinedTransformerByIdResponse], error)

+ GetUserDefinedTransformers func(context.Context, *connect.Request[v1alpha1.GetUserDefinedTransformersRequest]) (*connect.Response[v1alpha1.GetUserDefinedTransformersResponse], error)

+ IsTransformerNameAvailable func(context.Context, *connect.Request[v1alpha1.IsTransformerNameAvailableRequest]) (*connect.Response[v1alpha1.IsTransformerNameAvailableResponse], error)

+ UpdateUserDefinedTransformer func(context.Context, ...) (*connect.Response[v1alpha1.UpdateUserDefinedTransformerResponse], error)

+ ValidateUserJavascriptCode func(context.Context, *connect.Request[v1alpha1.ValidateUserJavascriptCodeRequest]) (*connect.Response[v1alpha1.ValidateUserJavascriptCodeResponse], error)

+ ValidateUserRegexCode func(context.Context, *connect.Request[v1alpha1.ValidateUserRegexCodeRequest]) (*connect.Response[v1alpha1.ValidateUserRegexCodeResponse], error)

+ func NewTransformersServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) TransformersServiceClient

+ type TransformersServiceHandler interface

+ CreateUserDefinedTransformer func(context.Context, ...) (*connect.Response[v1alpha1.CreateUserDefinedTransformerResponse], error)

+ DeleteUserDefinedTransformer func(context.Context, ...) (*connect.Response[v1alpha1.DeleteUserDefinedTransformerResponse], error)

+ GetSystemTransformerBySource func(context.Context, ...) (*connect.Response[v1alpha1.GetSystemTransformerBySourceResponse], error)

+ GetSystemTransformers func(context.Context, *connect.Request[v1alpha1.GetSystemTransformersRequest]) (*connect.Response[v1alpha1.GetSystemTransformersResponse], error)

+ GetUserDefinedTransformerById func(context.Context, ...) (*connect.Response[v1alpha1.GetUserDefinedTransformerByIdResponse], error)

+ GetUserDefinedTransformers func(context.Context, *connect.Request[v1alpha1.GetUserDefinedTransformersRequest]) (*connect.Response[v1alpha1.GetUserDefinedTransformersResponse], error)

+ IsTransformerNameAvailable func(context.Context, *connect.Request[v1alpha1.IsTransformerNameAvailableRequest]) (*connect.Response[v1alpha1.IsTransformerNameAvailableResponse], error)

+ UpdateUserDefinedTransformer func(context.Context, ...) (*connect.Response[v1alpha1.UpdateUserDefinedTransformerResponse], error)

+ ValidateUserJavascriptCode func(context.Context, *connect.Request[v1alpha1.ValidateUserJavascriptCodeRequest]) (*connect.Response[v1alpha1.ValidateUserJavascriptCodeResponse], error)

+ ValidateUserRegexCode func(context.Context, *connect.Request[v1alpha1.ValidateUserRegexCodeRequest]) (*connect.Response[v1alpha1.ValidateUserRegexCodeResponse], error)

+ type UnimplementedApiKeyServiceHandler struct

+ func (UnimplementedApiKeyServiceHandler) CreateAccountApiKey(context.Context, *connect.Request[v1alpha1.CreateAccountApiKeyRequest]) (*connect.Response[v1alpha1.CreateAccountApiKeyResponse], error)

+ func (UnimplementedApiKeyServiceHandler) DeleteAccountApiKey(context.Context, *connect.Request[v1alpha1.DeleteAccountApiKeyRequest]) (*connect.Response[v1alpha1.DeleteAccountApiKeyResponse], error)

+ func (UnimplementedApiKeyServiceHandler) GetAccountApiKey(context.Context, *connect.Request[v1alpha1.GetAccountApiKeyRequest]) (*connect.Response[v1alpha1.GetAccountApiKeyResponse], error)

+ func (UnimplementedApiKeyServiceHandler) GetAccountApiKeys(context.Context, *connect.Request[v1alpha1.GetAccountApiKeysRequest]) (*connect.Response[v1alpha1.GetAccountApiKeysResponse], error)

+ func (UnimplementedApiKeyServiceHandler) RegenerateAccountApiKey(context.Context, *connect.Request[v1alpha1.RegenerateAccountApiKeyRequest]) (*connect.Response[v1alpha1.RegenerateAccountApiKeyResponse], error)

+ type UnimplementedAuthServiceHandler struct

+ func (UnimplementedAuthServiceHandler) CheckToken(context.Context, *connect.Request[v1alpha1.CheckTokenRequest]) (*connect.Response[v1alpha1.CheckTokenResponse], error)

+ func (UnimplementedAuthServiceHandler) GetAuthStatus(context.Context, *connect.Request[v1alpha1.GetAuthStatusRequest]) (*connect.Response[v1alpha1.GetAuthStatusResponse], error)

+ func (UnimplementedAuthServiceHandler) GetAuthorizeUrl(context.Context, *connect.Request[v1alpha1.GetAuthorizeUrlRequest]) (*connect.Response[v1alpha1.GetAuthorizeUrlResponse], error)

+ func (UnimplementedAuthServiceHandler) GetCliIssuer(context.Context, *connect.Request[v1alpha1.GetCliIssuerRequest]) (*connect.Response[v1alpha1.GetCliIssuerResponse], error)

+ func (UnimplementedAuthServiceHandler) LoginCli(context.Context, *connect.Request[v1alpha1.LoginCliRequest]) (*connect.Response[v1alpha1.LoginCliResponse], error)

+ func (UnimplementedAuthServiceHandler) RefreshCli(context.Context, *connect.Request[v1alpha1.RefreshCliRequest]) (*connect.Response[v1alpha1.RefreshCliResponse], error)

+ type UnimplementedConnectionDataServiceHandler struct

+ func (UnimplementedConnectionDataServiceHandler) GetAiGeneratedData(context.Context, *connect.Request[v1alpha1.GetAiGeneratedDataRequest]) (*connect.Response[v1alpha1.GetAiGeneratedDataResponse], error)

+ func (UnimplementedConnectionDataServiceHandler) GetConnectionDataStream(context.Context, *connect.Request[v1alpha1.GetConnectionDataStreamRequest], ...) error

+ func (UnimplementedConnectionDataServiceHandler) GetConnectionForeignConstraints(context.Context, ...) (*connect.Response[v1alpha1.GetConnectionForeignConstraintsResponse], error)

+ func (UnimplementedConnectionDataServiceHandler) GetConnectionInitStatements(context.Context, *connect.Request[v1alpha1.GetConnectionInitStatementsRequest]) (*connect.Response[v1alpha1.GetConnectionInitStatementsResponse], error)

+ func (UnimplementedConnectionDataServiceHandler) GetConnectionPrimaryConstraints(context.Context, ...) (*connect.Response[v1alpha1.GetConnectionPrimaryConstraintsResponse], error)

+ func (UnimplementedConnectionDataServiceHandler) GetConnectionSchema(context.Context, *connect.Request[v1alpha1.GetConnectionSchemaRequest]) (*connect.Response[v1alpha1.GetConnectionSchemaResponse], error)

+ func (UnimplementedConnectionDataServiceHandler) GetConnectionUniqueConstraints(context.Context, ...) (*connect.Response[v1alpha1.GetConnectionUniqueConstraintsResponse], error)

+ type UnimplementedConnectionServiceHandler struct

+ func (UnimplementedConnectionServiceHandler) CheckConnectionConfig(context.Context, *connect.Request[v1alpha1.CheckConnectionConfigRequest]) (*connect.Response[v1alpha1.CheckConnectionConfigResponse], error)

+ func (UnimplementedConnectionServiceHandler) CheckSqlQuery(context.Context, *connect.Request[v1alpha1.CheckSqlQueryRequest]) (*connect.Response[v1alpha1.CheckSqlQueryResponse], error)

+ func (UnimplementedConnectionServiceHandler) CreateConnection(context.Context, *connect.Request[v1alpha1.CreateConnectionRequest]) (*connect.Response[v1alpha1.CreateConnectionResponse], error)

+ func (UnimplementedConnectionServiceHandler) DeleteConnection(context.Context, *connect.Request[v1alpha1.DeleteConnectionRequest]) (*connect.Response[v1alpha1.DeleteConnectionResponse], error)

+ func (UnimplementedConnectionServiceHandler) GetConnection(context.Context, *connect.Request[v1alpha1.GetConnectionRequest]) (*connect.Response[v1alpha1.GetConnectionResponse], error)

+ func (UnimplementedConnectionServiceHandler) GetConnections(context.Context, *connect.Request[v1alpha1.GetConnectionsRequest]) (*connect.Response[v1alpha1.GetConnectionsResponse], error)

+ func (UnimplementedConnectionServiceHandler) IsConnectionNameAvailable(context.Context, *connect.Request[v1alpha1.IsConnectionNameAvailableRequest]) (*connect.Response[v1alpha1.IsConnectionNameAvailableResponse], error)

+ func (UnimplementedConnectionServiceHandler) UpdateConnection(context.Context, *connect.Request[v1alpha1.UpdateConnectionRequest]) (*connect.Response[v1alpha1.UpdateConnectionResponse], error)

+ type UnimplementedJobServiceHandler struct

+ func (UnimplementedJobServiceHandler) CancelJobRun(context.Context, *connect.Request[v1alpha1.CancelJobRunRequest]) (*connect.Response[v1alpha1.CancelJobRunResponse], error)

+ func (UnimplementedJobServiceHandler) CreateJob(context.Context, *connect.Request[v1alpha1.CreateJobRequest]) (*connect.Response[v1alpha1.CreateJobResponse], error)

+ func (UnimplementedJobServiceHandler) CreateJobDestinationConnections(context.Context, ...) (*connect.Response[v1alpha1.CreateJobDestinationConnectionsResponse], error)

+ func (UnimplementedJobServiceHandler) CreateJobRun(context.Context, *connect.Request[v1alpha1.CreateJobRunRequest]) (*connect.Response[v1alpha1.CreateJobRunResponse], error)

+ func (UnimplementedJobServiceHandler) DeleteJob(context.Context, *connect.Request[v1alpha1.DeleteJobRequest]) (*connect.Response[v1alpha1.DeleteJobResponse], error)

+ func (UnimplementedJobServiceHandler) DeleteJobDestinationConnection(context.Context, ...) (*connect.Response[v1alpha1.DeleteJobDestinationConnectionResponse], error)

+ func (UnimplementedJobServiceHandler) DeleteJobRun(context.Context, *connect.Request[v1alpha1.DeleteJobRunRequest]) (*connect.Response[v1alpha1.DeleteJobRunResponse], error)

+ func (UnimplementedJobServiceHandler) GetJob(context.Context, *connect.Request[v1alpha1.GetJobRequest]) (*connect.Response[v1alpha1.GetJobResponse], error)

+ func (UnimplementedJobServiceHandler) GetJobNextRuns(context.Context, *connect.Request[v1alpha1.GetJobNextRunsRequest]) (*connect.Response[v1alpha1.GetJobNextRunsResponse], error)

+ func (UnimplementedJobServiceHandler) GetJobRecentRuns(context.Context, *connect.Request[v1alpha1.GetJobRecentRunsRequest]) (*connect.Response[v1alpha1.GetJobRecentRunsResponse], error)

+ func (UnimplementedJobServiceHandler) GetJobRun(context.Context, *connect.Request[v1alpha1.GetJobRunRequest]) (*connect.Response[v1alpha1.GetJobRunResponse], error)

+ func (UnimplementedJobServiceHandler) GetJobRunEvents(context.Context, *connect.Request[v1alpha1.GetJobRunEventsRequest]) (*connect.Response[v1alpha1.GetJobRunEventsResponse], error)

+ func (UnimplementedJobServiceHandler) GetJobRunLogsStream(context.Context, *connect.Request[v1alpha1.GetJobRunLogsStreamRequest], ...) error

+ func (UnimplementedJobServiceHandler) GetJobRuns(context.Context, *connect.Request[v1alpha1.GetJobRunsRequest]) (*connect.Response[v1alpha1.GetJobRunsResponse], error)

+ func (UnimplementedJobServiceHandler) GetJobStatus(context.Context, *connect.Request[v1alpha1.GetJobStatusRequest]) (*connect.Response[v1alpha1.GetJobStatusResponse], error)

+ func (UnimplementedJobServiceHandler) GetJobStatuses(context.Context, *connect.Request[v1alpha1.GetJobStatusesRequest]) (*connect.Response[v1alpha1.GetJobStatusesResponse], error)

+ func (UnimplementedJobServiceHandler) GetJobs(context.Context, *connect.Request[v1alpha1.GetJobsRequest]) (*connect.Response[v1alpha1.GetJobsResponse], error)

+ func (UnimplementedJobServiceHandler) IsJobNameAvailable(context.Context, *connect.Request[v1alpha1.IsJobNameAvailableRequest]) (*connect.Response[v1alpha1.IsJobNameAvailableResponse], error)

+ func (UnimplementedJobServiceHandler) PauseJob(context.Context, *connect.Request[v1alpha1.PauseJobRequest]) (*connect.Response[v1alpha1.PauseJobResponse], error)

+ func (UnimplementedJobServiceHandler) SetJobSourceSqlConnectionSubsets(context.Context, ...) (*connect.Response[v1alpha1.SetJobSourceSqlConnectionSubsetsResponse], error)

+ func (UnimplementedJobServiceHandler) SetJobSyncOptions(context.Context, *connect.Request[v1alpha1.SetJobSyncOptionsRequest]) (*connect.Response[v1alpha1.SetJobSyncOptionsResponse], error)

+ func (UnimplementedJobServiceHandler) SetJobWorkflowOptions(context.Context, *connect.Request[v1alpha1.SetJobWorkflowOptionsRequest]) (*connect.Response[v1alpha1.SetJobWorkflowOptionsResponse], error)

+ func (UnimplementedJobServiceHandler) TerminateJobRun(context.Context, *connect.Request[v1alpha1.TerminateJobRunRequest]) (*connect.Response[v1alpha1.TerminateJobRunResponse], error)

+ func (UnimplementedJobServiceHandler) UpdateJobDestinationConnection(context.Context, ...) (*connect.Response[v1alpha1.UpdateJobDestinationConnectionResponse], error)

+ func (UnimplementedJobServiceHandler) UpdateJobSchedule(context.Context, *connect.Request[v1alpha1.UpdateJobScheduleRequest]) (*connect.Response[v1alpha1.UpdateJobScheduleResponse], error)

+ func (UnimplementedJobServiceHandler) UpdateJobSourceConnection(context.Context, *connect.Request[v1alpha1.UpdateJobSourceConnectionRequest]) (*connect.Response[v1alpha1.UpdateJobSourceConnectionResponse], error)

+ type UnimplementedMetricsServiceHandler struct

+ func (UnimplementedMetricsServiceHandler) GetDailyMetricCount(context.Context, *connect.Request[v1alpha1.GetDailyMetricCountRequest]) (*connect.Response[v1alpha1.GetDailyMetricCountResponse], error)

+ func (UnimplementedMetricsServiceHandler) GetMetricCount(context.Context, *connect.Request[v1alpha1.GetMetricCountRequest]) (*connect.Response[v1alpha1.GetMetricCountResponse], error)

+ type UnimplementedTransformersServiceHandler struct

+ func (UnimplementedTransformersServiceHandler) CreateUserDefinedTransformer(context.Context, ...) (*connect.Response[v1alpha1.CreateUserDefinedTransformerResponse], error)

+ func (UnimplementedTransformersServiceHandler) DeleteUserDefinedTransformer(context.Context, ...) (*connect.Response[v1alpha1.DeleteUserDefinedTransformerResponse], error)

+ func (UnimplementedTransformersServiceHandler) GetSystemTransformerBySource(context.Context, ...) (*connect.Response[v1alpha1.GetSystemTransformerBySourceResponse], error)

+ func (UnimplementedTransformersServiceHandler) GetSystemTransformers(context.Context, *connect.Request[v1alpha1.GetSystemTransformersRequest]) (*connect.Response[v1alpha1.GetSystemTransformersResponse], error)

+ func (UnimplementedTransformersServiceHandler) GetUserDefinedTransformerById(context.Context, ...) (*connect.Response[v1alpha1.GetUserDefinedTransformerByIdResponse], error)

+ func (UnimplementedTransformersServiceHandler) GetUserDefinedTransformers(context.Context, *connect.Request[v1alpha1.GetUserDefinedTransformersRequest]) (*connect.Response[v1alpha1.GetUserDefinedTransformersResponse], error)

+ func (UnimplementedTransformersServiceHandler) IsTransformerNameAvailable(context.Context, *connect.Request[v1alpha1.IsTransformerNameAvailableRequest]) (*connect.Response[v1alpha1.IsTransformerNameAvailableResponse], error)

+ func (UnimplementedTransformersServiceHandler) UpdateUserDefinedTransformer(context.Context, ...) (*connect.Response[v1alpha1.UpdateUserDefinedTransformerResponse], error)

+ func (UnimplementedTransformersServiceHandler) ValidateUserJavascriptCode(context.Context, *connect.Request[v1alpha1.ValidateUserJavascriptCodeRequest]) (*connect.Response[v1alpha1.ValidateUserJavascriptCodeResponse], error)

+ func (UnimplementedTransformersServiceHandler) ValidateUserRegexCode(context.Context, *connect.Request[v1alpha1.ValidateUserRegexCodeRequest]) (*connect.Response[v1alpha1.ValidateUserRegexCodeResponse], error)

+ type UnimplementedUserAccountServiceHandler struct

+ func (UnimplementedUserAccountServiceHandler) AcceptTeamAccountInvite(context.Context, *connect.Request[v1alpha1.AcceptTeamAccountInviteRequest]) (*connect.Response[v1alpha1.AcceptTeamAccountInviteResponse], error)

+ func (UnimplementedUserAccountServiceHandler) ConvertPersonalToTeamAccount(context.Context, ...) (*connect.Response[v1alpha1.ConvertPersonalToTeamAccountResponse], error)

+ func (UnimplementedUserAccountServiceHandler) CreateTeamAccount(context.Context, *connect.Request[v1alpha1.CreateTeamAccountRequest]) (*connect.Response[v1alpha1.CreateTeamAccountResponse], error)

+ func (UnimplementedUserAccountServiceHandler) GetAccountOnboardingConfig(context.Context, *connect.Request[v1alpha1.GetAccountOnboardingConfigRequest]) (*connect.Response[v1alpha1.GetAccountOnboardingConfigResponse], error)

+ func (UnimplementedUserAccountServiceHandler) GetAccountTemporalConfig(context.Context, *connect.Request[v1alpha1.GetAccountTemporalConfigRequest]) (*connect.Response[v1alpha1.GetAccountTemporalConfigResponse], error)

+ func (UnimplementedUserAccountServiceHandler) GetSystemInformation(context.Context, *connect.Request[v1alpha1.GetSystemInformationRequest]) (*connect.Response[v1alpha1.GetSystemInformationResponse], error)

+ func (UnimplementedUserAccountServiceHandler) GetTeamAccountInvites(context.Context, *connect.Request[v1alpha1.GetTeamAccountInvitesRequest]) (*connect.Response[v1alpha1.GetTeamAccountInvitesResponse], error)

+ func (UnimplementedUserAccountServiceHandler) GetTeamAccountMembers(context.Context, *connect.Request[v1alpha1.GetTeamAccountMembersRequest]) (*connect.Response[v1alpha1.GetTeamAccountMembersResponse], error)

+ func (UnimplementedUserAccountServiceHandler) GetUser(context.Context, *connect.Request[v1alpha1.GetUserRequest]) (*connect.Response[v1alpha1.GetUserResponse], error)

+ func (UnimplementedUserAccountServiceHandler) GetUserAccounts(context.Context, *connect.Request[v1alpha1.GetUserAccountsRequest]) (*connect.Response[v1alpha1.GetUserAccountsResponse], error)

+ func (UnimplementedUserAccountServiceHandler) InviteUserToTeamAccount(context.Context, *connect.Request[v1alpha1.InviteUserToTeamAccountRequest]) (*connect.Response[v1alpha1.InviteUserToTeamAccountResponse], error)

+ func (UnimplementedUserAccountServiceHandler) IsUserInAccount(context.Context, *connect.Request[v1alpha1.IsUserInAccountRequest]) (*connect.Response[v1alpha1.IsUserInAccountResponse], error)

+ func (UnimplementedUserAccountServiceHandler) RemoveTeamAccountInvite(context.Context, *connect.Request[v1alpha1.RemoveTeamAccountInviteRequest]) (*connect.Response[v1alpha1.RemoveTeamAccountInviteResponse], error)

+ func (UnimplementedUserAccountServiceHandler) RemoveTeamAccountMember(context.Context, *connect.Request[v1alpha1.RemoveTeamAccountMemberRequest]) (*connect.Response[v1alpha1.RemoveTeamAccountMemberResponse], error)

+ func (UnimplementedUserAccountServiceHandler) SetAccountOnboardingConfig(context.Context, *connect.Request[v1alpha1.SetAccountOnboardingConfigRequest]) (*connect.Response[v1alpha1.SetAccountOnboardingConfigResponse], error)

+ func (UnimplementedUserAccountServiceHandler) SetAccountTemporalConfig(context.Context, *connect.Request[v1alpha1.SetAccountTemporalConfigRequest]) (*connect.Response[v1alpha1.SetAccountTemporalConfigResponse], error)

+ func (UnimplementedUserAccountServiceHandler) SetPersonalAccount(context.Context, *connect.Request[v1alpha1.SetPersonalAccountRequest]) (*connect.Response[v1alpha1.SetPersonalAccountResponse], error)

+ func (UnimplementedUserAccountServiceHandler) SetUser(context.Context, *connect.Request[v1alpha1.SetUserRequest]) (*connect.Response[v1alpha1.SetUserResponse], error)

+ type UserAccountServiceClient interface

+ AcceptTeamAccountInvite func(context.Context, *connect.Request[v1alpha1.AcceptTeamAccountInviteRequest]) (*connect.Response[v1alpha1.AcceptTeamAccountInviteResponse], error)

+ ConvertPersonalToTeamAccount func(context.Context, ...) (*connect.Response[v1alpha1.ConvertPersonalToTeamAccountResponse], error)

+ CreateTeamAccount func(context.Context, *connect.Request[v1alpha1.CreateTeamAccountRequest]) (*connect.Response[v1alpha1.CreateTeamAccountResponse], error)

+ GetAccountOnboardingConfig func(context.Context, *connect.Request[v1alpha1.GetAccountOnboardingConfigRequest]) (*connect.Response[v1alpha1.GetAccountOnboardingConfigResponse], error)

+ GetAccountTemporalConfig func(context.Context, *connect.Request[v1alpha1.GetAccountTemporalConfigRequest]) (*connect.Response[v1alpha1.GetAccountTemporalConfigResponse], error)

+ GetSystemInformation func(context.Context, *connect.Request[v1alpha1.GetSystemInformationRequest]) (*connect.Response[v1alpha1.GetSystemInformationResponse], error)

+ GetTeamAccountInvites func(context.Context, *connect.Request[v1alpha1.GetTeamAccountInvitesRequest]) (*connect.Response[v1alpha1.GetTeamAccountInvitesResponse], error)

+ GetTeamAccountMembers func(context.Context, *connect.Request[v1alpha1.GetTeamAccountMembersRequest]) (*connect.Response[v1alpha1.GetTeamAccountMembersResponse], error)

+ GetUser func(context.Context, *connect.Request[v1alpha1.GetUserRequest]) (*connect.Response[v1alpha1.GetUserResponse], error)

+ GetUserAccounts func(context.Context, *connect.Request[v1alpha1.GetUserAccountsRequest]) (*connect.Response[v1alpha1.GetUserAccountsResponse], error)

+ InviteUserToTeamAccount func(context.Context, *connect.Request[v1alpha1.InviteUserToTeamAccountRequest]) (*connect.Response[v1alpha1.InviteUserToTeamAccountResponse], error)

+ IsUserInAccount func(context.Context, *connect.Request[v1alpha1.IsUserInAccountRequest]) (*connect.Response[v1alpha1.IsUserInAccountResponse], error)

+ RemoveTeamAccountInvite func(context.Context, *connect.Request[v1alpha1.RemoveTeamAccountInviteRequest]) (*connect.Response[v1alpha1.RemoveTeamAccountInviteResponse], error)

+ RemoveTeamAccountMember func(context.Context, *connect.Request[v1alpha1.RemoveTeamAccountMemberRequest]) (*connect.Response[v1alpha1.RemoveTeamAccountMemberResponse], error)

+ SetAccountOnboardingConfig func(context.Context, *connect.Request[v1alpha1.SetAccountOnboardingConfigRequest]) (*connect.Response[v1alpha1.SetAccountOnboardingConfigResponse], error)

+ SetAccountTemporalConfig func(context.Context, *connect.Request[v1alpha1.SetAccountTemporalConfigRequest]) (*connect.Response[v1alpha1.SetAccountTemporalConfigResponse], error)

+ SetPersonalAccount func(context.Context, *connect.Request[v1alpha1.SetPersonalAccountRequest]) (*connect.Response[v1alpha1.SetPersonalAccountResponse], error)

+ SetUser func(context.Context, *connect.Request[v1alpha1.SetUserRequest]) (*connect.Response[v1alpha1.SetUserResponse], error)

+ func NewUserAccountServiceClient(httpClient connect.HTTPClient, baseURL string, opts ...connect.ClientOption) UserAccountServiceClient

+ type UserAccountServiceHandler interface

+ AcceptTeamAccountInvite func(context.Context, *connect.Request[v1alpha1.AcceptTeamAccountInviteRequest]) (*connect.Response[v1alpha1.AcceptTeamAccountInviteResponse], error)

+ ConvertPersonalToTeamAccount func(context.Context, ...) (*connect.Response[v1alpha1.ConvertPersonalToTeamAccountResponse], error)

+ CreateTeamAccount func(context.Context, *connect.Request[v1alpha1.CreateTeamAccountRequest]) (*connect.Response[v1alpha1.CreateTeamAccountResponse], error)

+ GetAccountOnboardingConfig func(context.Context, *connect.Request[v1alpha1.GetAccountOnboardingConfigRequest]) (*connect.Response[v1alpha1.GetAccountOnboardingConfigResponse], error)

+ GetAccountTemporalConfig func(context.Context, *connect.Request[v1alpha1.GetAccountTemporalConfigRequest]) (*connect.Response[v1alpha1.GetAccountTemporalConfigResponse], error)

+ GetSystemInformation func(context.Context, *connect.Request[v1alpha1.GetSystemInformationRequest]) (*connect.Response[v1alpha1.GetSystemInformationResponse], error)

+ GetTeamAccountInvites func(context.Context, *connect.Request[v1alpha1.GetTeamAccountInvitesRequest]) (*connect.Response[v1alpha1.GetTeamAccountInvitesResponse], error)

+ GetTeamAccountMembers func(context.Context, *connect.Request[v1alpha1.GetTeamAccountMembersRequest]) (*connect.Response[v1alpha1.GetTeamAccountMembersResponse], error)

+ GetUser func(context.Context, *connect.Request[v1alpha1.GetUserRequest]) (*connect.Response[v1alpha1.GetUserResponse], error)

+ GetUserAccounts func(context.Context, *connect.Request[v1alpha1.GetUserAccountsRequest]) (*connect.Response[v1alpha1.GetUserAccountsResponse], error)

+ InviteUserToTeamAccount func(context.Context, *connect.Request[v1alpha1.InviteUserToTeamAccountRequest]) (*connect.Response[v1alpha1.InviteUserToTeamAccountResponse], error)

+ IsUserInAccount func(context.Context, *connect.Request[v1alpha1.IsUserInAccountRequest]) (*connect.Response[v1alpha1.IsUserInAccountResponse], error)

+ RemoveTeamAccountInvite func(context.Context, *connect.Request[v1alpha1.RemoveTeamAccountInviteRequest]) (*connect.Response[v1alpha1.RemoveTeamAccountInviteResponse], error)

+ RemoveTeamAccountMember func(context.Context, *connect.Request[v1alpha1.RemoveTeamAccountMemberRequest]) (*connect.Response[v1alpha1.RemoveTeamAccountMemberResponse], error)

+ SetAccountOnboardingConfig func(context.Context, *connect.Request[v1alpha1.SetAccountOnboardingConfigRequest]) (*connect.Response[v1alpha1.SetAccountOnboardingConfigResponse], error)

+ SetAccountTemporalConfig func(context.Context, *connect.Request[v1alpha1.SetAccountTemporalConfigRequest]) (*connect.Response[v1alpha1.SetAccountTemporalConfigResponse], error)

+ SetPersonalAccount func(context.Context, *connect.Request[v1alpha1.SetPersonalAccountRequest]) (*connect.Response[v1alpha1.SetPersonalAccountResponse], error)

+ SetUser func(context.Context, *connect.Request[v1alpha1.SetUserRequest]) (*connect.Response[v1alpha1.SetUserResponse], error)

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL