db_queries

package
v0.4.56 Latest Latest
Warning

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

 Go to latest Published: Aug 23, 2024 License: MIT Imports: 6 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type AreConnectionsInAccountParams 

type AreConnectionsInAccountParams struct {
	AccountId     pgtype.UUID
	ConnectionIds []pgtype.UUID
}

type CreateAccountApiKeyParams 

type CreateAccountApiKeyParams struct {
	KeyName     string
	KeyValue    string
	AccountID   pgtype.UUID
	ExpiresAt   pgtype.Timestamp
	CreatedByID pgtype.UUID
	UpdatedByID pgtype.UUID
	UserID      pgtype.UUID
}

type CreateAccountInviteParams 

type CreateAccountInviteParams struct {
	AccountID    pgtype.UUID
	SenderUserID pgtype.UUID
	Email        string
	ExpiresAt    pgtype.Timestamp
}

type CreateAccountUserAssociationParams 

type CreateAccountUserAssociationParams struct {
	AccountID pgtype.UUID
	UserID    pgtype.UUID
}

type CreateConnectionParams 

type CreateConnectionParams struct {
	Name             string
	AccountID        pgtype.UUID
	ConnectionConfig *pg_models.ConnectionConfig
	CreatedByID      pgtype.UUID
	UpdatedByID      pgtype.UUID
}

type CreateIdentityProviderAssociationParams 

type CreateIdentityProviderAssociationParams struct {
	UserID      pgtype.UUID
	ProviderSub string
}

type CreateJobConnectionDestinationParams 

type CreateJobConnectionDestinationParams struct {
	JobID        pgtype.UUID
	ConnectionID pgtype.UUID
	Options      *pg_models.JobDestinationOptions
}

type CreateJobConnectionDestinationsParams 

type CreateJobConnectionDestinationsParams struct {
	JobID        pgtype.UUID
	ConnectionID pgtype.UUID
	Options      *pg_models.JobDestinationOptions
}

type CreateJobParams 

type CreateJobParams struct {
	Name               string
	AccountID          pgtype.UUID
	Status             int16
	ConnectionOptions  *pg_models.JobSourceOptions
	Mappings           []*pg_models.JobMapping
	CronSchedule       pgtype.Text
	CreatedByID        pgtype.UUID
	UpdatedByID        pgtype.UUID
	WorkflowOptions    *pg_models.WorkflowOptions
	SyncOptions        *pg_models.ActivityOptions
	VirtualForeignKeys []*pg_models.VirtualForeignConstraint
}

type CreateUserDefinedTransformerParams 

type CreateUserDefinedTransformerParams struct {
	Name              string
	Description       string
	Source            int32
	AccountID         pgtype.UUID
	TransformerConfig *pg_models.TransformerConfigs
	CreatedByID       pgtype.UUID
	UpdatedByID       pgtype.UUID
}

type DBTX 

type DBTX interface {
	Exec(context.Context, string, ...interface{}) (pgconn.CommandTag, error)
	Query(context.Context, string, ...interface{}) (pgx.Rows, error)
	QueryRow(context.Context, string, ...interface{}) pgx.Row
	CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int64, error)
}

type GetAccountUserAssociationParams 

type GetAccountUserAssociationParams struct {
	AccountId pgtype.UUID
	UserId    pgtype.UUID
}

type GetConnectionByNameAndAccountParams 

type GetConnectionByNameAndAccountParams struct {
	AccountId      pgtype.UUID
	ConnectionName string
}

type GetJobByNameAndAccountParams 

type GetJobByNameAndAccountParams struct {
	AccountId pgtype.UUID
	JobName   string
}

type GetRunContextByKeyParams added in v0.4.54 

type GetRunContextByKeyParams struct {
	WorkflowId string
	ExternalId string
	AccountId  pgtype.UUID
}

type GetTemporalConfigByUserAccountParams 

type GetTemporalConfigByUserAccountParams struct {
	AccountId pgtype.UUID
	UserId    pgtype.UUID
}

type IsConnectionInAccountParams 

type IsConnectionInAccountParams struct {
	AccountId    pgtype.UUID
	ConnectionId pgtype.UUID
}

type IsConnectionNameAvailableParams 

type IsConnectionNameAvailableParams struct {
	AccountId      pgtype.UUID
	ConnectionName string
}

type IsJobNameAvailableParams 

type IsJobNameAvailableParams struct {
	AccountId pgtype.UUID
	JobName   string
}

type IsTransformerNameAvailableParams 

type IsTransformerNameAvailableParams struct {
	AccountId       pgtype.UUID
	TransformerName string
}

type IsUserInAccountApiKeyParams 

type IsUserInAccountApiKeyParams struct {
	AccountId pgtype.UUID
	UserId    pgtype.UUID
}

type IsUserInAccountParams 

type IsUserInAccountParams struct {
	AccountId pgtype.UUID
	UserId    pgtype.UUID
}

type MockDBTX 

type MockDBTX struct {
	mock.Mock
}

MockDBTX is an autogenerated mock type for the DBTX type

func NewMockDBTX 

func NewMockDBTX(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockDBTX

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

func (*MockDBTX) CopyFrom 

func (_m *MockDBTX) CopyFrom(ctx context.Context, tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource) (int64, error)

CopyFrom provides a mock function with given fields: ctx, tableName, columnNames, rowSrc

func (*MockDBTX) EXPECT 

func (_m *MockDBTX) EXPECT() *MockDBTX_Expecter

func (*MockDBTX) Exec 

func (_m *MockDBTX) Exec(_a0 context.Context, _a1 string, _a2 ...interface{}) (pgconn.CommandTag, error)

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

func (*MockDBTX) Query 

func (_m *MockDBTX) Query(_a0 context.Context, _a1 string, _a2 ...interface{}) (pgx.Rows, error)

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

func (*MockDBTX) QueryRow 

func (_m *MockDBTX) QueryRow(_a0 context.Context, _a1 string, _a2 ...interface{}) pgx.Row

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

type MockDBTX_CopyFrom_Call 

type MockDBTX_CopyFrom_Call struct {
	*mock.Call
}

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

func (*MockDBTX_CopyFrom_Call) Return 

func (_c *MockDBTX_CopyFrom_Call) Return(_a0 int64, _a1 error) *MockDBTX_CopyFrom_Call

func (*MockDBTX_CopyFrom_Call) Run 

func (_c *MockDBTX_CopyFrom_Call) Run(run func(ctx context.Context, tableName pgx.Identifier, columnNames []string, rowSrc pgx.CopyFromSource)) *MockDBTX_CopyFrom_Call

func (*MockDBTX_CopyFrom_Call) RunAndReturn 

func (_c *MockDBTX_CopyFrom_Call) RunAndReturn(run func(context.Context, pgx.Identifier, []string, pgx.CopyFromSource) (int64, error)) *MockDBTX_CopyFrom_Call

type MockDBTX_Exec_Call 

type MockDBTX_Exec_Call struct {
	*mock.Call
}

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

func (*MockDBTX_Exec_Call) Return 

func (_c *MockDBTX_Exec_Call) Return(_a0 pgconn.CommandTag, _a1 error) *MockDBTX_Exec_Call

func (*MockDBTX_Exec_Call) Run 

func (_c *MockDBTX_Exec_Call) Run(run func(_a0 context.Context, _a1 string, _a2 ...interface{})) *MockDBTX_Exec_Call

func (*MockDBTX_Exec_Call) RunAndReturn 

func (_c *MockDBTX_Exec_Call) RunAndReturn(run func(context.Context, string, ...interface{}) (pgconn.CommandTag, error)) *MockDBTX_Exec_Call

type MockDBTX_Expecter 

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

func (*MockDBTX_Expecter) CopyFrom 

func (_e *MockDBTX_Expecter) CopyFrom(ctx interface{}, tableName interface{}, columnNames interface{}, rowSrc interface{}) *MockDBTX_CopyFrom_Call

CopyFrom is a helper method to define mock.On call

  • ctx context.Context
  • tableName pgx.Identifier
  • columnNames []string
  • rowSrc pgx.CopyFromSource

func (*MockDBTX_Expecter) Exec 

func (_e *MockDBTX_Expecter) Exec(_a0 interface{}, _a1 interface{}, _a2 ...interface{}) *MockDBTX_Exec_Call

Exec is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 string
  • _a2 ...interface{}

func (*MockDBTX_Expecter) Query 

func (_e *MockDBTX_Expecter) Query(_a0 interface{}, _a1 interface{}, _a2 ...interface{}) *MockDBTX_Query_Call

Query is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 string
  • _a2 ...interface{}

func (*MockDBTX_Expecter) QueryRow 

func (_e *MockDBTX_Expecter) QueryRow(_a0 interface{}, _a1 interface{}, _a2 ...interface{}) *MockDBTX_QueryRow_Call

QueryRow is a helper method to define mock.On call

  • _a0 context.Context
  • _a1 string
  • _a2 ...interface{}

type MockDBTX_QueryRow_Call 

type MockDBTX_QueryRow_Call struct {
	*mock.Call
}

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

func (*MockDBTX_QueryRow_Call) Return 

func (_c *MockDBTX_QueryRow_Call) Return(_a0 pgx.Row) *MockDBTX_QueryRow_Call

func (*MockDBTX_QueryRow_Call) Run 

func (_c *MockDBTX_QueryRow_Call) Run(run func(_a0 context.Context, _a1 string, _a2 ...interface{})) *MockDBTX_QueryRow_Call

func (*MockDBTX_QueryRow_Call) RunAndReturn 

func (_c *MockDBTX_QueryRow_Call) RunAndReturn(run func(context.Context, string, ...interface{}) pgx.Row) *MockDBTX_QueryRow_Call

type MockDBTX_Query_Call 

type MockDBTX_Query_Call struct {
	*mock.Call
}

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

func (*MockDBTX_Query_Call) Return 

func (_c *MockDBTX_Query_Call) Return(_a0 pgx.Rows, _a1 error) *MockDBTX_Query_Call

func (*MockDBTX_Query_Call) Run 

func (_c *MockDBTX_Query_Call) Run(run func(_a0 context.Context, _a1 string, _a2 ...interface{})) *MockDBTX_Query_Call

func (*MockDBTX_Query_Call) RunAndReturn 

func (_c *MockDBTX_Query_Call) RunAndReturn(run func(context.Context, string, ...interface{}) (pgx.Rows, error)) *MockDBTX_Query_Call

type MockQuerier 

type MockQuerier struct {
	mock.Mock
}

MockQuerier is an autogenerated mock type for the Querier type

func NewMockQuerier 

func NewMockQuerier(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockQuerier

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

func (*MockQuerier) AreConnectionsInAccount 

func (_m *MockQuerier) AreConnectionsInAccount(ctx context.Context, db DBTX, arg AreConnectionsInAccountParams) (int64, error)

AreConnectionsInAccount provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) CreateAccountApiKey 

func (_m *MockQuerier) CreateAccountApiKey(ctx context.Context, db DBTX, arg CreateAccountApiKeyParams) (NeosyncApiAccountApiKey, error)

CreateAccountApiKey provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) CreateAccountInvite 

func (_m *MockQuerier) CreateAccountInvite(ctx context.Context, db DBTX, arg CreateAccountInviteParams) (NeosyncApiAccountInvite, error)

CreateAccountInvite provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) CreateAccountUserAssociation 

func (_m *MockQuerier) CreateAccountUserAssociation(ctx context.Context, db DBTX, arg CreateAccountUserAssociationParams) (NeosyncApiAccountUserAssociation, error)

CreateAccountUserAssociation provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) CreateConnection 

func (_m *MockQuerier) CreateConnection(ctx context.Context, db DBTX, arg CreateConnectionParams) (NeosyncApiConnection, error)

CreateConnection provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) CreateIdentityProviderAssociation 

func (_m *MockQuerier) CreateIdentityProviderAssociation(ctx context.Context, db DBTX, arg CreateIdentityProviderAssociationParams) (NeosyncApiUserIdentityProviderAssociation, error)

CreateIdentityProviderAssociation provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) CreateJob 

func (_m *MockQuerier) CreateJob(ctx context.Context, db DBTX, arg CreateJobParams) (NeosyncApiJob, error)

CreateJob provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) CreateJobConnectionDestination 

func (_m *MockQuerier) CreateJobConnectionDestination(ctx context.Context, db DBTX, arg CreateJobConnectionDestinationParams) (NeosyncApiJobDestinationConnectionAssociation, error)

CreateJobConnectionDestination provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) CreateJobConnectionDestinations 

func (_m *MockQuerier) CreateJobConnectionDestinations(ctx context.Context, db DBTX, arg []CreateJobConnectionDestinationsParams) (int64, error)

CreateJobConnectionDestinations provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) CreateMachineUser 

func (_m *MockQuerier) CreateMachineUser(ctx context.Context, db DBTX) (NeosyncApiUser, error)

CreateMachineUser provides a mock function with given fields: ctx, db

func (*MockQuerier) CreateNonMachineUser 

func (_m *MockQuerier) CreateNonMachineUser(ctx context.Context, db DBTX) (NeosyncApiUser, error)

CreateNonMachineUser provides a mock function with given fields: ctx, db

func (*MockQuerier) CreatePersonalAccount 

func (_m *MockQuerier) CreatePersonalAccount(ctx context.Context, db DBTX, accountSlug string) (NeosyncApiAccount, error)

CreatePersonalAccount provides a mock function with given fields: ctx, db, accountSlug

func (*MockQuerier) CreateTeamAccount 

func (_m *MockQuerier) CreateTeamAccount(ctx context.Context, db DBTX, accountSlug string) (NeosyncApiAccount, error)

CreateTeamAccount provides a mock function with given fields: ctx, db, accountSlug

func (*MockQuerier) CreateUserDefinedTransformer 

func (_m *MockQuerier) CreateUserDefinedTransformer(ctx context.Context, db DBTX, arg CreateUserDefinedTransformerParams) (NeosyncApiTransformer, error)

CreateUserDefinedTransformer provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) DeleteJob 

func (_m *MockQuerier) DeleteJob(ctx context.Context, db DBTX, id pgtype.UUID) error

DeleteJob provides a mock function with given fields: ctx, db, id

func (*MockQuerier) DeleteUserDefinedTransformerById 

func (_m *MockQuerier) DeleteUserDefinedTransformerById(ctx context.Context, db DBTX, id pgtype.UUID) error

DeleteUserDefinedTransformerById provides a mock function with given fields: ctx, db, id

func (*MockQuerier) EXPECT 

func (_m *MockQuerier) EXPECT() *MockQuerier_Expecter

func (*MockQuerier) GetAccount 

func (_m *MockQuerier) GetAccount(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiAccount, error)

GetAccount provides a mock function with given fields: ctx, db, id

func (*MockQuerier) GetAccountApiKeyById 

func (_m *MockQuerier) GetAccountApiKeyById(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiAccountApiKey, error)

GetAccountApiKeyById provides a mock function with given fields: ctx, db, id

func (*MockQuerier) GetAccountApiKeyByKeyValue 

func (_m *MockQuerier) GetAccountApiKeyByKeyValue(ctx context.Context, db DBTX, keyValue string) (NeosyncApiAccountApiKey, error)

GetAccountApiKeyByKeyValue provides a mock function with given fields: ctx, db, keyValue

func (*MockQuerier) GetAccountApiKeys 

func (_m *MockQuerier) GetAccountApiKeys(ctx context.Context, db DBTX, accountid pgtype.UUID) ([]NeosyncApiAccountApiKey, error)

GetAccountApiKeys provides a mock function with given fields: ctx, db, accountid

func (*MockQuerier) GetAccountInvite 

func (_m *MockQuerier) GetAccountInvite(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiAccountInvite, error)

GetAccountInvite provides a mock function with given fields: ctx, db, id

func (*MockQuerier) GetAccountInviteByToken 

func (_m *MockQuerier) GetAccountInviteByToken(ctx context.Context, db DBTX, token string) (NeosyncApiAccountInvite, error)

GetAccountInviteByToken provides a mock function with given fields: ctx, db, token

func (*MockQuerier) GetAccountOnboardingConfig 

func (_m *MockQuerier) GetAccountOnboardingConfig(ctx context.Context, db DBTX, id pgtype.UUID) (*pg_models.AccountOnboardingConfig, error)

GetAccountOnboardingConfig provides a mock function with given fields: ctx, db, id

func (*MockQuerier) GetAccountUserAssociation 

func (_m *MockQuerier) GetAccountUserAssociation(ctx context.Context, db DBTX, arg GetAccountUserAssociationParams) (NeosyncApiAccountUserAssociation, error)

GetAccountUserAssociation provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) GetAccountsByUser 

func (_m *MockQuerier) GetAccountsByUser(ctx context.Context, db DBTX, id pgtype.UUID) ([]NeosyncApiAccount, error)

GetAccountsByUser provides a mock function with given fields: ctx, db, id

func (*MockQuerier) GetActiveAccountInvites 

func (_m *MockQuerier) GetActiveAccountInvites(ctx context.Context, db DBTX, accountid pgtype.UUID) ([]NeosyncApiAccountInvite, error)

GetActiveAccountInvites provides a mock function with given fields: ctx, db, accountid

func (*MockQuerier) GetAnonymousUser 

func (_m *MockQuerier) GetAnonymousUser(ctx context.Context, db DBTX) (NeosyncApiUser, error)

GetAnonymousUser provides a mock function with given fields: ctx, db

func (*MockQuerier) GetConnectionById 

func (_m *MockQuerier) GetConnectionById(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiConnection, error)

GetConnectionById provides a mock function with given fields: ctx, db, id

func (*MockQuerier) GetConnectionByNameAndAccount 

func (_m *MockQuerier) GetConnectionByNameAndAccount(ctx context.Context, db DBTX, arg GetConnectionByNameAndAccountParams) (NeosyncApiConnection, error)

GetConnectionByNameAndAccount provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) GetConnectionsByAccount 

func (_m *MockQuerier) GetConnectionsByAccount(ctx context.Context, db DBTX, accountid pgtype.UUID) ([]NeosyncApiConnection, error)

GetConnectionsByAccount provides a mock function with given fields: ctx, db, accountid

func (*MockQuerier) GetConnectionsByIds 

func (_m *MockQuerier) GetConnectionsByIds(ctx context.Context, db DBTX, dollar_1 []pgtype.UUID) ([]NeosyncApiConnection, error)

GetConnectionsByIds provides a mock function with given fields: ctx, db, dollar_1

func (*MockQuerier) GetJobById 

func (_m *MockQuerier) GetJobById(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiJob, error)

GetJobById provides a mock function with given fields: ctx, db, id

func (*MockQuerier) GetJobByNameAndAccount 

func (_m *MockQuerier) GetJobByNameAndAccount(ctx context.Context, db DBTX, arg GetJobByNameAndAccountParams) (NeosyncApiJob, error)

GetJobByNameAndAccount provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) GetJobConnectionDestination 

func (_m *MockQuerier) GetJobConnectionDestination(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiJobDestinationConnectionAssociation, error)

GetJobConnectionDestination provides a mock function with given fields: ctx, db, id

func (*MockQuerier) GetJobConnectionDestinations 

func (_m *MockQuerier) GetJobConnectionDestinations(ctx context.Context, db DBTX, id pgtype.UUID) ([]NeosyncApiJobDestinationConnectionAssociation, error)

GetJobConnectionDestinations provides a mock function with given fields: ctx, db, id

func (*MockQuerier) GetJobConnectionDestinationsByJobIds 

func (_m *MockQuerier) GetJobConnectionDestinationsByJobIds(ctx context.Context, db DBTX, jobids []pgtype.UUID) ([]NeosyncApiJobDestinationConnectionAssociation, error)

GetJobConnectionDestinationsByJobIds provides a mock function with given fields: ctx, db, jobids

func (*MockQuerier) GetJobsByAccount 

func (_m *MockQuerier) GetJobsByAccount(ctx context.Context, db DBTX, accountid pgtype.UUID) ([]NeosyncApiJob, error)

GetJobsByAccount provides a mock function with given fields: ctx, db, accountid

func (*MockQuerier) GetPersonalAccountByUserId 

func (_m *MockQuerier) GetPersonalAccountByUserId(ctx context.Context, db DBTX, userid pgtype.UUID) (NeosyncApiAccount, error)

GetPersonalAccountByUserId provides a mock function with given fields: ctx, db, userid

func (*MockQuerier) GetRunContextByKey added in v0.4.54 

func (_m *MockQuerier) GetRunContextByKey(ctx context.Context, db DBTX, arg GetRunContextByKeyParams) (NeosyncApiRuncontext, error)

GetRunContextByKey provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) GetTeamAccountsByUserId 

func (_m *MockQuerier) GetTeamAccountsByUserId(ctx context.Context, db DBTX, userid pgtype.UUID) ([]NeosyncApiAccount, error)

GetTeamAccountsByUserId provides a mock function with given fields: ctx, db, userid

func (*MockQuerier) GetTemporalConfigByAccount 

func (_m *MockQuerier) GetTemporalConfigByAccount(ctx context.Context, db DBTX, id pgtype.UUID) (*pg_models.TemporalConfig, error)

GetTemporalConfigByAccount provides a mock function with given fields: ctx, db, id

func (*MockQuerier) GetTemporalConfigByUserAccount 

func (_m *MockQuerier) GetTemporalConfigByUserAccount(ctx context.Context, db DBTX, arg GetTemporalConfigByUserAccountParams) (*pg_models.TemporalConfig, error)

GetTemporalConfigByUserAccount provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) GetUser 

func (_m *MockQuerier) GetUser(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiUser, error)

GetUser provides a mock function with given fields: ctx, db, id

func (*MockQuerier) GetUserAssociationByProviderSub 

func (_m *MockQuerier) GetUserAssociationByProviderSub(ctx context.Context, db DBTX, providerSub string) (NeosyncApiUserIdentityProviderAssociation, error)

GetUserAssociationByProviderSub provides a mock function with given fields: ctx, db, providerSub

func (*MockQuerier) GetUserByProviderSub 

func (_m *MockQuerier) GetUserByProviderSub(ctx context.Context, db DBTX, providerSub string) (NeosyncApiUser, error)

GetUserByProviderSub provides a mock function with given fields: ctx, db, providerSub

func (*MockQuerier) GetUserDefinedTransformerById 

func (_m *MockQuerier) GetUserDefinedTransformerById(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiTransformer, error)

GetUserDefinedTransformerById provides a mock function with given fields: ctx, db, id

func (*MockQuerier) GetUserDefinedTransformersByAccount 

func (_m *MockQuerier) GetUserDefinedTransformersByAccount(ctx context.Context, db DBTX, accountid pgtype.UUID) ([]NeosyncApiTransformer, error)

GetUserDefinedTransformersByAccount provides a mock function with given fields: ctx, db, accountid

func (*MockQuerier) GetUserIdentitiesByTeamAccount 

func (_m *MockQuerier) GetUserIdentitiesByTeamAccount(ctx context.Context, db DBTX, accountid pgtype.UUID) ([]NeosyncApiUserIdentityProviderAssociation, error)

GetUserIdentitiesByTeamAccount provides a mock function with given fields: ctx, db, accountid

func (*MockQuerier) GetUserIdentityAssociationsByUserIds 

func (_m *MockQuerier) GetUserIdentityAssociationsByUserIds(ctx context.Context, db DBTX, dollar_1 []pgtype.UUID) ([]NeosyncApiUserIdentityProviderAssociation, error)

GetUserIdentityAssociationsByUserIds provides a mock function with given fields: ctx, db, dollar_1

func (*MockQuerier) GetUserIdentityByUserId 

func (_m *MockQuerier) GetUserIdentityByUserId(ctx context.Context, db DBTX, userID pgtype.UUID) (NeosyncApiUserIdentityProviderAssociation, error)

GetUserIdentityByUserId provides a mock function with given fields: ctx, db, userID

func (*MockQuerier) IsConnectionInAccount 

func (_m *MockQuerier) IsConnectionInAccount(ctx context.Context, db DBTX, arg IsConnectionInAccountParams) (int64, error)

IsConnectionInAccount provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) IsConnectionNameAvailable 

func (_m *MockQuerier) IsConnectionNameAvailable(ctx context.Context, db DBTX, arg IsConnectionNameAvailableParams) (int64, error)

IsConnectionNameAvailable provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) IsJobNameAvailable 

func (_m *MockQuerier) IsJobNameAvailable(ctx context.Context, db DBTX, arg IsJobNameAvailableParams) (int64, error)

IsJobNameAvailable provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) IsTransformerNameAvailable 

func (_m *MockQuerier) IsTransformerNameAvailable(ctx context.Context, db DBTX, arg IsTransformerNameAvailableParams) (int64, error)

IsTransformerNameAvailable provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) IsUserInAccount 

func (_m *MockQuerier) IsUserInAccount(ctx context.Context, db DBTX, arg IsUserInAccountParams) (int64, error)

IsUserInAccount provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) IsUserInAccountApiKey 

func (_m *MockQuerier) IsUserInAccountApiKey(ctx context.Context, db DBTX, arg IsUserInAccountApiKeyParams) (int64, error)

IsUserInAccountApiKey provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) RemoveAccountApiKey 

func (_m *MockQuerier) RemoveAccountApiKey(ctx context.Context, db DBTX, id pgtype.UUID) error

RemoveAccountApiKey provides a mock function with given fields: ctx, db, id

func (*MockQuerier) RemoveAccountInvite 

func (_m *MockQuerier) RemoveAccountInvite(ctx context.Context, db DBTX, id pgtype.UUID) error

RemoveAccountInvite provides a mock function with given fields: ctx, db, id

func (*MockQuerier) RemoveAccountUser 

func (_m *MockQuerier) RemoveAccountUser(ctx context.Context, db DBTX, arg RemoveAccountUserParams) error

RemoveAccountUser provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) RemoveConnectionById 

func (_m *MockQuerier) RemoveConnectionById(ctx context.Context, db DBTX, id pgtype.UUID) error

RemoveConnectionById provides a mock function with given fields: ctx, db, id

func (*MockQuerier) RemoveConnectionByNameAndAccount 

func (_m *MockQuerier) RemoveConnectionByNameAndAccount(ctx context.Context, db DBTX, arg RemoveConnectionByNameAndAccountParams) error

RemoveConnectionByNameAndAccount provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) RemoveJobById 

func (_m *MockQuerier) RemoveJobById(ctx context.Context, db DBTX, id pgtype.UUID) error

RemoveJobById provides a mock function with given fields: ctx, db, id

func (*MockQuerier) RemoveJobConnectionDestination 

func (_m *MockQuerier) RemoveJobConnectionDestination(ctx context.Context, db DBTX, id pgtype.UUID) error

RemoveJobConnectionDestination provides a mock function with given fields: ctx, db, id

func (*MockQuerier) RemoveJobConnectionDestinations 

func (_m *MockQuerier) RemoveJobConnectionDestinations(ctx context.Context, db DBTX, jobids []pgtype.UUID) error

RemoveJobConnectionDestinations provides a mock function with given fields: ctx, db, jobids

func (*MockQuerier) SetAnonymousUser 

func (_m *MockQuerier) SetAnonymousUser(ctx context.Context, db DBTX) (NeosyncApiUser, error)

SetAnonymousUser provides a mock function with given fields: ctx, db

func (*MockQuerier) SetJobSyncOptions 

func (_m *MockQuerier) SetJobSyncOptions(ctx context.Context, db DBTX, arg SetJobSyncOptionsParams) (NeosyncApiJob, error)

SetJobSyncOptions provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) SetJobWorkflowOptions 

func (_m *MockQuerier) SetJobWorkflowOptions(ctx context.Context, db DBTX, arg SetJobWorkflowOptionsParams) (NeosyncApiJob, error)

SetJobWorkflowOptions provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) SetRunContext added in v0.4.54 

func (_m *MockQuerier) SetRunContext(ctx context.Context, db DBTX, arg SetRunContextParams) error

SetRunContext provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) UpdateAccountApiKeyValue 

func (_m *MockQuerier) UpdateAccountApiKeyValue(ctx context.Context, db DBTX, arg UpdateAccountApiKeyValueParams) (NeosyncApiAccountApiKey, error)

UpdateAccountApiKeyValue provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) UpdateAccountInviteToAccepted 

func (_m *MockQuerier) UpdateAccountInviteToAccepted(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiAccountInvite, error)

UpdateAccountInviteToAccepted provides a mock function with given fields: ctx, db, id

func (*MockQuerier) UpdateAccountOnboardingConfig 

func (_m *MockQuerier) UpdateAccountOnboardingConfig(ctx context.Context, db DBTX, arg UpdateAccountOnboardingConfigParams) (NeosyncApiAccount, error)

UpdateAccountOnboardingConfig provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) UpdateActiveAccountInvitesToExpired 

func (_m *MockQuerier) UpdateActiveAccountInvitesToExpired(ctx context.Context, db DBTX, arg UpdateActiveAccountInvitesToExpiredParams) (NeosyncApiAccountInvite, error)

UpdateActiveAccountInvitesToExpired provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) UpdateConnection 

func (_m *MockQuerier) UpdateConnection(ctx context.Context, db DBTX, arg UpdateConnectionParams) (NeosyncApiConnection, error)

UpdateConnection provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) UpdateJobConnectionDestination 

func (_m *MockQuerier) UpdateJobConnectionDestination(ctx context.Context, db DBTX, arg UpdateJobConnectionDestinationParams) (NeosyncApiJobDestinationConnectionAssociation, error)

UpdateJobConnectionDestination provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) UpdateJobMappings 

func (_m *MockQuerier) UpdateJobMappings(ctx context.Context, db DBTX, arg UpdateJobMappingsParams) (NeosyncApiJob, error)

UpdateJobMappings provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) UpdateJobSchedule 

func (_m *MockQuerier) UpdateJobSchedule(ctx context.Context, db DBTX, arg UpdateJobScheduleParams) (NeosyncApiJob, error)

UpdateJobSchedule provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) UpdateJobSource 

func (_m *MockQuerier) UpdateJobSource(ctx context.Context, db DBTX, arg UpdateJobSourceParams) (NeosyncApiJob, error)

UpdateJobSource provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) UpdateJobVirtualForeignKeys added in v0.4.39 

func (_m *MockQuerier) UpdateJobVirtualForeignKeys(ctx context.Context, db DBTX, arg UpdateJobVirtualForeignKeysParams) (NeosyncApiJob, error)

UpdateJobVirtualForeignKeys provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) UpdateTemporalConfigByAccount 

func (_m *MockQuerier) UpdateTemporalConfigByAccount(ctx context.Context, db DBTX, arg UpdateTemporalConfigByAccountParams) (NeosyncApiAccount, error)

UpdateTemporalConfigByAccount provides a mock function with given fields: ctx, db, arg

func (*MockQuerier) UpdateUserDefinedTransformer 

func (_m *MockQuerier) UpdateUserDefinedTransformer(ctx context.Context, db DBTX, arg UpdateUserDefinedTransformerParams) (NeosyncApiTransformer, error)

UpdateUserDefinedTransformer provides a mock function with given fields: ctx, db, arg

type MockQuerier_AreConnectionsInAccount_Call 

type MockQuerier_AreConnectionsInAccount_Call struct {
	*mock.Call
}

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

func (*MockQuerier_AreConnectionsInAccount_Call) Return 

func (_c *MockQuerier_AreConnectionsInAccount_Call) Return(_a0 int64, _a1 error) *MockQuerier_AreConnectionsInAccount_Call

func (*MockQuerier_AreConnectionsInAccount_Call) Run 

func (_c *MockQuerier_AreConnectionsInAccount_Call) Run(run func(ctx context.Context, db DBTX, arg AreConnectionsInAccountParams)) *MockQuerier_AreConnectionsInAccount_Call

func (*MockQuerier_AreConnectionsInAccount_Call) RunAndReturn 

func (_c *MockQuerier_AreConnectionsInAccount_Call) RunAndReturn(run func(context.Context, DBTX, AreConnectionsInAccountParams) (int64, error)) *MockQuerier_AreConnectionsInAccount_Call

type MockQuerier_CreateAccountApiKey_Call 

type MockQuerier_CreateAccountApiKey_Call struct {
	*mock.Call
}

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

func (*MockQuerier_CreateAccountApiKey_Call) Return 

func (_c *MockQuerier_CreateAccountApiKey_Call) Return(_a0 NeosyncApiAccountApiKey, _a1 error) *MockQuerier_CreateAccountApiKey_Call

func (*MockQuerier_CreateAccountApiKey_Call) Run 

func (_c *MockQuerier_CreateAccountApiKey_Call) Run(run func(ctx context.Context, db DBTX, arg CreateAccountApiKeyParams)) *MockQuerier_CreateAccountApiKey_Call

func (*MockQuerier_CreateAccountApiKey_Call) RunAndReturn 

func (_c *MockQuerier_CreateAccountApiKey_Call) RunAndReturn(run func(context.Context, DBTX, CreateAccountApiKeyParams) (NeosyncApiAccountApiKey, error)) *MockQuerier_CreateAccountApiKey_Call

type MockQuerier_CreateAccountInvite_Call 

type MockQuerier_CreateAccountInvite_Call struct {
	*mock.Call
}

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

func (*MockQuerier_CreateAccountInvite_Call) Return 

func (_c *MockQuerier_CreateAccountInvite_Call) Return(_a0 NeosyncApiAccountInvite, _a1 error) *MockQuerier_CreateAccountInvite_Call

func (*MockQuerier_CreateAccountInvite_Call) Run 

func (_c *MockQuerier_CreateAccountInvite_Call) Run(run func(ctx context.Context, db DBTX, arg CreateAccountInviteParams)) *MockQuerier_CreateAccountInvite_Call

func (*MockQuerier_CreateAccountInvite_Call) RunAndReturn 

func (_c *MockQuerier_CreateAccountInvite_Call) RunAndReturn(run func(context.Context, DBTX, CreateAccountInviteParams) (NeosyncApiAccountInvite, error)) *MockQuerier_CreateAccountInvite_Call

type MockQuerier_CreateAccountUserAssociation_Call 

type MockQuerier_CreateAccountUserAssociation_Call struct {
	*mock.Call
}

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

func (*MockQuerier_CreateAccountUserAssociation_Call) Return 

func (_c *MockQuerier_CreateAccountUserAssociation_Call) Return(_a0 NeosyncApiAccountUserAssociation, _a1 error) *MockQuerier_CreateAccountUserAssociation_Call

func (*MockQuerier_CreateAccountUserAssociation_Call) Run 

func (_c *MockQuerier_CreateAccountUserAssociation_Call) Run(run func(ctx context.Context, db DBTX, arg CreateAccountUserAssociationParams)) *MockQuerier_CreateAccountUserAssociation_Call

func (*MockQuerier_CreateAccountUserAssociation_Call) RunAndReturn 

func (_c *MockQuerier_CreateAccountUserAssociation_Call) RunAndReturn(run func(context.Context, DBTX, CreateAccountUserAssociationParams) (NeosyncApiAccountUserAssociation, error)) *MockQuerier_CreateAccountUserAssociation_Call

type MockQuerier_CreateConnection_Call 

type MockQuerier_CreateConnection_Call struct {
	*mock.Call
}

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

func (*MockQuerier_CreateConnection_Call) Return 

func (_c *MockQuerier_CreateConnection_Call) Return(_a0 NeosyncApiConnection, _a1 error) *MockQuerier_CreateConnection_Call

func (*MockQuerier_CreateConnection_Call) Run 

func (_c *MockQuerier_CreateConnection_Call) Run(run func(ctx context.Context, db DBTX, arg CreateConnectionParams)) *MockQuerier_CreateConnection_Call

func (*MockQuerier_CreateConnection_Call) RunAndReturn 

func (_c *MockQuerier_CreateConnection_Call) RunAndReturn(run func(context.Context, DBTX, CreateConnectionParams) (NeosyncApiConnection, error)) *MockQuerier_CreateConnection_Call

type MockQuerier_CreateIdentityProviderAssociation_Call 

type MockQuerier_CreateIdentityProviderAssociation_Call struct {
	*mock.Call
}

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

func (*MockQuerier_CreateIdentityProviderAssociation_Call) Return 

func (_c *MockQuerier_CreateIdentityProviderAssociation_Call) Return(_a0 NeosyncApiUserIdentityProviderAssociation, _a1 error) *MockQuerier_CreateIdentityProviderAssociation_Call

func (*MockQuerier_CreateIdentityProviderAssociation_Call) Run 

func (_c *MockQuerier_CreateIdentityProviderAssociation_Call) Run(run func(ctx context.Context, db DBTX, arg CreateIdentityProviderAssociationParams)) *MockQuerier_CreateIdentityProviderAssociation_Call

func (*MockQuerier_CreateIdentityProviderAssociation_Call) RunAndReturn 

func (_c *MockQuerier_CreateIdentityProviderAssociation_Call) RunAndReturn(run func(context.Context, DBTX, CreateIdentityProviderAssociationParams) (NeosyncApiUserIdentityProviderAssociation, error)) *MockQuerier_CreateIdentityProviderAssociation_Call

type MockQuerier_CreateJobConnectionDestination_Call 

type MockQuerier_CreateJobConnectionDestination_Call struct {
	*mock.Call
}

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

func (*MockQuerier_CreateJobConnectionDestination_Call) Return 

func (_c *MockQuerier_CreateJobConnectionDestination_Call) Return(_a0 NeosyncApiJobDestinationConnectionAssociation, _a1 error) *MockQuerier_CreateJobConnectionDestination_Call

func (*MockQuerier_CreateJobConnectionDestination_Call) Run 

func (_c *MockQuerier_CreateJobConnectionDestination_Call) Run(run func(ctx context.Context, db DBTX, arg CreateJobConnectionDestinationParams)) *MockQuerier_CreateJobConnectionDestination_Call

func (*MockQuerier_CreateJobConnectionDestination_Call) RunAndReturn 

func (_c *MockQuerier_CreateJobConnectionDestination_Call) RunAndReturn(run func(context.Context, DBTX, CreateJobConnectionDestinationParams) (NeosyncApiJobDestinationConnectionAssociation, error)) *MockQuerier_CreateJobConnectionDestination_Call

type MockQuerier_CreateJobConnectionDestinations_Call 

type MockQuerier_CreateJobConnectionDestinations_Call struct {
	*mock.Call
}

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

func (*MockQuerier_CreateJobConnectionDestinations_Call) Return 

func (_c *MockQuerier_CreateJobConnectionDestinations_Call) Return(_a0 int64, _a1 error) *MockQuerier_CreateJobConnectionDestinations_Call

func (*MockQuerier_CreateJobConnectionDestinations_Call) Run 

func (_c *MockQuerier_CreateJobConnectionDestinations_Call) Run(run func(ctx context.Context, db DBTX, arg []CreateJobConnectionDestinationsParams)) *MockQuerier_CreateJobConnectionDestinations_Call

func (*MockQuerier_CreateJobConnectionDestinations_Call) RunAndReturn 

func (_c *MockQuerier_CreateJobConnectionDestinations_Call) RunAndReturn(run func(context.Context, DBTX, []CreateJobConnectionDestinationsParams) (int64, error)) *MockQuerier_CreateJobConnectionDestinations_Call

type MockQuerier_CreateJob_Call 

type MockQuerier_CreateJob_Call struct {
	*mock.Call
}

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

func (*MockQuerier_CreateJob_Call) Return 

func (_c *MockQuerier_CreateJob_Call) Return(_a0 NeosyncApiJob, _a1 error) *MockQuerier_CreateJob_Call

func (*MockQuerier_CreateJob_Call) Run 

func (_c *MockQuerier_CreateJob_Call) Run(run func(ctx context.Context, db DBTX, arg CreateJobParams)) *MockQuerier_CreateJob_Call

func (*MockQuerier_CreateJob_Call) RunAndReturn 

func (_c *MockQuerier_CreateJob_Call) RunAndReturn(run func(context.Context, DBTX, CreateJobParams) (NeosyncApiJob, error)) *MockQuerier_CreateJob_Call

type MockQuerier_CreateMachineUser_Call 

type MockQuerier_CreateMachineUser_Call struct {
	*mock.Call
}

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

func (*MockQuerier_CreateMachineUser_Call) Return 

func (_c *MockQuerier_CreateMachineUser_Call) Return(_a0 NeosyncApiUser, _a1 error) *MockQuerier_CreateMachineUser_Call

func (*MockQuerier_CreateMachineUser_Call) Run 

func (_c *MockQuerier_CreateMachineUser_Call) Run(run func(ctx context.Context, db DBTX)) *MockQuerier_CreateMachineUser_Call

func (*MockQuerier_CreateMachineUser_Call) RunAndReturn 

func (_c *MockQuerier_CreateMachineUser_Call) RunAndReturn(run func(context.Context, DBTX) (NeosyncApiUser, error)) *MockQuerier_CreateMachineUser_Call

type MockQuerier_CreateNonMachineUser_Call 

type MockQuerier_CreateNonMachineUser_Call struct {
	*mock.Call
}

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

func (*MockQuerier_CreateNonMachineUser_Call) Return 

func (_c *MockQuerier_CreateNonMachineUser_Call) Return(_a0 NeosyncApiUser, _a1 error) *MockQuerier_CreateNonMachineUser_Call

func (*MockQuerier_CreateNonMachineUser_Call) Run 

func (_c *MockQuerier_CreateNonMachineUser_Call) Run(run func(ctx context.Context, db DBTX)) *MockQuerier_CreateNonMachineUser_Call

func (*MockQuerier_CreateNonMachineUser_Call) RunAndReturn 

func (_c *MockQuerier_CreateNonMachineUser_Call) RunAndReturn(run func(context.Context, DBTX) (NeosyncApiUser, error)) *MockQuerier_CreateNonMachineUser_Call

type MockQuerier_CreatePersonalAccount_Call 

type MockQuerier_CreatePersonalAccount_Call struct {
	*mock.Call
}

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

func (*MockQuerier_CreatePersonalAccount_Call) Return 

func (_c *MockQuerier_CreatePersonalAccount_Call) Return(_a0 NeosyncApiAccount, _a1 error) *MockQuerier_CreatePersonalAccount_Call

func (*MockQuerier_CreatePersonalAccount_Call) Run 

func (_c *MockQuerier_CreatePersonalAccount_Call) Run(run func(ctx context.Context, db DBTX, accountSlug string)) *MockQuerier_CreatePersonalAccount_Call

func (*MockQuerier_CreatePersonalAccount_Call) RunAndReturn 

func (_c *MockQuerier_CreatePersonalAccount_Call) RunAndReturn(run func(context.Context, DBTX, string) (NeosyncApiAccount, error)) *MockQuerier_CreatePersonalAccount_Call

type MockQuerier_CreateTeamAccount_Call 

type MockQuerier_CreateTeamAccount_Call struct {
	*mock.Call
}

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

func (*MockQuerier_CreateTeamAccount_Call) Return 

func (_c *MockQuerier_CreateTeamAccount_Call) Return(_a0 NeosyncApiAccount, _a1 error) *MockQuerier_CreateTeamAccount_Call

func (*MockQuerier_CreateTeamAccount_Call) Run 

func (_c *MockQuerier_CreateTeamAccount_Call) Run(run func(ctx context.Context, db DBTX, accountSlug string)) *MockQuerier_CreateTeamAccount_Call

func (*MockQuerier_CreateTeamAccount_Call) RunAndReturn 

func (_c *MockQuerier_CreateTeamAccount_Call) RunAndReturn(run func(context.Context, DBTX, string) (NeosyncApiAccount, error)) *MockQuerier_CreateTeamAccount_Call

type MockQuerier_CreateUserDefinedTransformer_Call 

type MockQuerier_CreateUserDefinedTransformer_Call struct {
	*mock.Call
}

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

func (*MockQuerier_CreateUserDefinedTransformer_Call) Return 

func (_c *MockQuerier_CreateUserDefinedTransformer_Call) Return(_a0 NeosyncApiTransformer, _a1 error) *MockQuerier_CreateUserDefinedTransformer_Call

func (*MockQuerier_CreateUserDefinedTransformer_Call) Run 

func (_c *MockQuerier_CreateUserDefinedTransformer_Call) Run(run func(ctx context.Context, db DBTX, arg CreateUserDefinedTransformerParams)) *MockQuerier_CreateUserDefinedTransformer_Call

func (*MockQuerier_CreateUserDefinedTransformer_Call) RunAndReturn 

func (_c *MockQuerier_CreateUserDefinedTransformer_Call) RunAndReturn(run func(context.Context, DBTX, CreateUserDefinedTransformerParams) (NeosyncApiTransformer, error)) *MockQuerier_CreateUserDefinedTransformer_Call

type MockQuerier_DeleteJob_Call 

type MockQuerier_DeleteJob_Call struct {
	*mock.Call
}

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

func (*MockQuerier_DeleteJob_Call) Return 

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

func (*MockQuerier_DeleteJob_Call) Run 

func (_c *MockQuerier_DeleteJob_Call) Run(run func(ctx context.Context, db DBTX, id pgtype.UUID)) *MockQuerier_DeleteJob_Call

func (*MockQuerier_DeleteJob_Call) RunAndReturn 

func (_c *MockQuerier_DeleteJob_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) error) *MockQuerier_DeleteJob_Call

type MockQuerier_DeleteUserDefinedTransformerById_Call 

type MockQuerier_DeleteUserDefinedTransformerById_Call struct {
	*mock.Call
}

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

func (*MockQuerier_DeleteUserDefinedTransformerById_Call) Return 

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

func (*MockQuerier_DeleteUserDefinedTransformerById_Call) Run 

func (_c *MockQuerier_DeleteUserDefinedTransformerById_Call) Run(run func(ctx context.Context, db DBTX, id pgtype.UUID)) *MockQuerier_DeleteUserDefinedTransformerById_Call

func (*MockQuerier_DeleteUserDefinedTransformerById_Call) RunAndReturn 

func (_c *MockQuerier_DeleteUserDefinedTransformerById_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) error) *MockQuerier_DeleteUserDefinedTransformerById_Call

type MockQuerier_Expecter 

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

func (*MockQuerier_Expecter) AreConnectionsInAccount 

func (_e *MockQuerier_Expecter) AreConnectionsInAccount(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_AreConnectionsInAccount_Call

AreConnectionsInAccount is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg AreConnectionsInAccountParams

func (*MockQuerier_Expecter) CreateAccountApiKey 

func (_e *MockQuerier_Expecter) CreateAccountApiKey(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_CreateAccountApiKey_Call

CreateAccountApiKey is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg CreateAccountApiKeyParams

func (*MockQuerier_Expecter) CreateAccountInvite 

func (_e *MockQuerier_Expecter) CreateAccountInvite(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_CreateAccountInvite_Call

CreateAccountInvite is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg CreateAccountInviteParams

func (*MockQuerier_Expecter) CreateAccountUserAssociation 

func (_e *MockQuerier_Expecter) CreateAccountUserAssociation(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_CreateAccountUserAssociation_Call

CreateAccountUserAssociation is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg CreateAccountUserAssociationParams

func (*MockQuerier_Expecter) CreateConnection 

func (_e *MockQuerier_Expecter) CreateConnection(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_CreateConnection_Call

CreateConnection is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg CreateConnectionParams

func (*MockQuerier_Expecter) CreateIdentityProviderAssociation 

func (_e *MockQuerier_Expecter) CreateIdentityProviderAssociation(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_CreateIdentityProviderAssociation_Call

CreateIdentityProviderAssociation is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg CreateIdentityProviderAssociationParams

func (*MockQuerier_Expecter) CreateJob 

func (_e *MockQuerier_Expecter) CreateJob(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_CreateJob_Call

CreateJob is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg CreateJobParams

func (*MockQuerier_Expecter) CreateJobConnectionDestination 

func (_e *MockQuerier_Expecter) CreateJobConnectionDestination(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_CreateJobConnectionDestination_Call

CreateJobConnectionDestination is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg CreateJobConnectionDestinationParams

func (*MockQuerier_Expecter) CreateJobConnectionDestinations 

func (_e *MockQuerier_Expecter) CreateJobConnectionDestinations(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_CreateJobConnectionDestinations_Call

CreateJobConnectionDestinations is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg []CreateJobConnectionDestinationsParams

func (*MockQuerier_Expecter) CreateMachineUser 

func (_e *MockQuerier_Expecter) CreateMachineUser(ctx interface{}, db interface{}) *MockQuerier_CreateMachineUser_Call

CreateMachineUser is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX

func (*MockQuerier_Expecter) CreateNonMachineUser 

func (_e *MockQuerier_Expecter) CreateNonMachineUser(ctx interface{}, db interface{}) *MockQuerier_CreateNonMachineUser_Call

CreateNonMachineUser is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX

func (*MockQuerier_Expecter) CreatePersonalAccount 

func (_e *MockQuerier_Expecter) CreatePersonalAccount(ctx interface{}, db interface{}, accountSlug interface{}) *MockQuerier_CreatePersonalAccount_Call

CreatePersonalAccount is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • accountSlug string

func (*MockQuerier_Expecter) CreateTeamAccount 

func (_e *MockQuerier_Expecter) CreateTeamAccount(ctx interface{}, db interface{}, accountSlug interface{}) *MockQuerier_CreateTeamAccount_Call

CreateTeamAccount is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • accountSlug string

func (*MockQuerier_Expecter) CreateUserDefinedTransformer 

func (_e *MockQuerier_Expecter) CreateUserDefinedTransformer(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_CreateUserDefinedTransformer_Call

CreateUserDefinedTransformer is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg CreateUserDefinedTransformerParams

func (*MockQuerier_Expecter) DeleteJob 

func (_e *MockQuerier_Expecter) DeleteJob(ctx interface{}, db interface{}, id interface{}) *MockQuerier_DeleteJob_Call

DeleteJob is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • id pgtype.UUID

func (*MockQuerier_Expecter) DeleteUserDefinedTransformerById 

func (_e *MockQuerier_Expecter) DeleteUserDefinedTransformerById(ctx interface{}, db interface{}, id interface{}) *MockQuerier_DeleteUserDefinedTransformerById_Call

DeleteUserDefinedTransformerById is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • id pgtype.UUID

func (*MockQuerier_Expecter) GetAccount 

func (_e *MockQuerier_Expecter) GetAccount(ctx interface{}, db interface{}, id interface{}) *MockQuerier_GetAccount_Call

GetAccount is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • id pgtype.UUID

func (*MockQuerier_Expecter) GetAccountApiKeyById 

func (_e *MockQuerier_Expecter) GetAccountApiKeyById(ctx interface{}, db interface{}, id interface{}) *MockQuerier_GetAccountApiKeyById_Call

GetAccountApiKeyById is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • id pgtype.UUID

func (*MockQuerier_Expecter) GetAccountApiKeyByKeyValue 

func (_e *MockQuerier_Expecter) GetAccountApiKeyByKeyValue(ctx interface{}, db interface{}, keyValue interface{}) *MockQuerier_GetAccountApiKeyByKeyValue_Call

GetAccountApiKeyByKeyValue is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • keyValue string

func (*MockQuerier_Expecter) GetAccountApiKeys 

func (_e *MockQuerier_Expecter) GetAccountApiKeys(ctx interface{}, db interface{}, accountid interface{}) *MockQuerier_GetAccountApiKeys_Call

GetAccountApiKeys is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • accountid pgtype.UUID

func (*MockQuerier_Expecter) GetAccountInvite 

func (_e *MockQuerier_Expecter) GetAccountInvite(ctx interface{}, db interface{}, id interface{}) *MockQuerier_GetAccountInvite_Call

GetAccountInvite is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • id pgtype.UUID

func (*MockQuerier_Expecter) GetAccountInviteByToken 

func (_e *MockQuerier_Expecter) GetAccountInviteByToken(ctx interface{}, db interface{}, token interface{}) *MockQuerier_GetAccountInviteByToken_Call

GetAccountInviteByToken is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • token string

func (*MockQuerier_Expecter) GetAccountOnboardingConfig 

func (_e *MockQuerier_Expecter) GetAccountOnboardingConfig(ctx interface{}, db interface{}, id interface{}) *MockQuerier_GetAccountOnboardingConfig_Call

GetAccountOnboardingConfig is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • id pgtype.UUID

func (*MockQuerier_Expecter) GetAccountUserAssociation 

func (_e *MockQuerier_Expecter) GetAccountUserAssociation(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_GetAccountUserAssociation_Call

GetAccountUserAssociation is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg GetAccountUserAssociationParams

func (*MockQuerier_Expecter) GetAccountsByUser 

func (_e *MockQuerier_Expecter) GetAccountsByUser(ctx interface{}, db interface{}, id interface{}) *MockQuerier_GetAccountsByUser_Call

GetAccountsByUser is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • id pgtype.UUID

func (*MockQuerier_Expecter) GetActiveAccountInvites 

func (_e *MockQuerier_Expecter) GetActiveAccountInvites(ctx interface{}, db interface{}, accountid interface{}) *MockQuerier_GetActiveAccountInvites_Call

GetActiveAccountInvites is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • accountid pgtype.UUID

func (*MockQuerier_Expecter) GetAnonymousUser 

func (_e *MockQuerier_Expecter) GetAnonymousUser(ctx interface{}, db interface{}) *MockQuerier_GetAnonymousUser_Call

GetAnonymousUser is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX

func (*MockQuerier_Expecter) GetConnectionById 

func (_e *MockQuerier_Expecter) GetConnectionById(ctx interface{}, db interface{}, id interface{}) *MockQuerier_GetConnectionById_Call

GetConnectionById is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • id pgtype.UUID

func (*MockQuerier_Expecter) GetConnectionByNameAndAccount 

func (_e *MockQuerier_Expecter) GetConnectionByNameAndAccount(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_GetConnectionByNameAndAccount_Call

GetConnectionByNameAndAccount is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg GetConnectionByNameAndAccountParams

func (*MockQuerier_Expecter) GetConnectionsByAccount 

func (_e *MockQuerier_Expecter) GetConnectionsByAccount(ctx interface{}, db interface{}, accountid interface{}) *MockQuerier_GetConnectionsByAccount_Call

GetConnectionsByAccount is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • accountid pgtype.UUID

func (*MockQuerier_Expecter) GetConnectionsByIds 

func (_e *MockQuerier_Expecter) GetConnectionsByIds(ctx interface{}, db interface{}, dollar_1 interface{}) *MockQuerier_GetConnectionsByIds_Call

GetConnectionsByIds is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • dollar_1 []pgtype.UUID

func (*MockQuerier_Expecter) GetJobById 

func (_e *MockQuerier_Expecter) GetJobById(ctx interface{}, db interface{}, id interface{}) *MockQuerier_GetJobById_Call

GetJobById is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • id pgtype.UUID

func (*MockQuerier_Expecter) GetJobByNameAndAccount 

func (_e *MockQuerier_Expecter) GetJobByNameAndAccount(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_GetJobByNameAndAccount_Call

GetJobByNameAndAccount is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg GetJobByNameAndAccountParams

func (*MockQuerier_Expecter) GetJobConnectionDestination 

func (_e *MockQuerier_Expecter) GetJobConnectionDestination(ctx interface{}, db interface{}, id interface{}) *MockQuerier_GetJobConnectionDestination_Call

GetJobConnectionDestination is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • id pgtype.UUID

func (*MockQuerier_Expecter) GetJobConnectionDestinations 

func (_e *MockQuerier_Expecter) GetJobConnectionDestinations(ctx interface{}, db interface{}, id interface{}) *MockQuerier_GetJobConnectionDestinations_Call

GetJobConnectionDestinations is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • id pgtype.UUID

func (*MockQuerier_Expecter) GetJobConnectionDestinationsByJobIds 

func (_e *MockQuerier_Expecter) GetJobConnectionDestinationsByJobIds(ctx interface{}, db interface{}, jobids interface{}) *MockQuerier_GetJobConnectionDestinationsByJobIds_Call

GetJobConnectionDestinationsByJobIds is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • jobids []pgtype.UUID

func (*MockQuerier_Expecter) GetJobsByAccount 

func (_e *MockQuerier_Expecter) GetJobsByAccount(ctx interface{}, db interface{}, accountid interface{}) *MockQuerier_GetJobsByAccount_Call

GetJobsByAccount is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • accountid pgtype.UUID

func (*MockQuerier_Expecter) GetPersonalAccountByUserId 

func (_e *MockQuerier_Expecter) GetPersonalAccountByUserId(ctx interface{}, db interface{}, userid interface{}) *MockQuerier_GetPersonalAccountByUserId_Call

GetPersonalAccountByUserId is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • userid pgtype.UUID

func (*MockQuerier_Expecter) GetRunContextByKey added in v0.4.54 

func (_e *MockQuerier_Expecter) GetRunContextByKey(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_GetRunContextByKey_Call

GetRunContextByKey is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg GetRunContextByKeyParams

func (*MockQuerier_Expecter) GetTeamAccountsByUserId 

func (_e *MockQuerier_Expecter) GetTeamAccountsByUserId(ctx interface{}, db interface{}, userid interface{}) *MockQuerier_GetTeamAccountsByUserId_Call

GetTeamAccountsByUserId is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • userid pgtype.UUID

func (*MockQuerier_Expecter) GetTemporalConfigByAccount 

func (_e *MockQuerier_Expecter) GetTemporalConfigByAccount(ctx interface{}, db interface{}, id interface{}) *MockQuerier_GetTemporalConfigByAccount_Call

GetTemporalConfigByAccount is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • id pgtype.UUID

func (*MockQuerier_Expecter) GetTemporalConfigByUserAccount 

func (_e *MockQuerier_Expecter) GetTemporalConfigByUserAccount(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_GetTemporalConfigByUserAccount_Call

GetTemporalConfigByUserAccount is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg GetTemporalConfigByUserAccountParams

func (*MockQuerier_Expecter) GetUser 

func (_e *MockQuerier_Expecter) GetUser(ctx interface{}, db interface{}, id interface{}) *MockQuerier_GetUser_Call

GetUser is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • id pgtype.UUID

func (*MockQuerier_Expecter) GetUserAssociationByProviderSub 

func (_e *MockQuerier_Expecter) GetUserAssociationByProviderSub(ctx interface{}, db interface{}, providerSub interface{}) *MockQuerier_GetUserAssociationByProviderSub_Call

GetUserAssociationByProviderSub is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • providerSub string

func (*MockQuerier_Expecter) GetUserByProviderSub 

func (_e *MockQuerier_Expecter) GetUserByProviderSub(ctx interface{}, db interface{}, providerSub interface{}) *MockQuerier_GetUserByProviderSub_Call

GetUserByProviderSub is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • providerSub string

func (*MockQuerier_Expecter) GetUserDefinedTransformerById 

func (_e *MockQuerier_Expecter) GetUserDefinedTransformerById(ctx interface{}, db interface{}, id interface{}) *MockQuerier_GetUserDefinedTransformerById_Call

GetUserDefinedTransformerById is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • id pgtype.UUID

func (*MockQuerier_Expecter) GetUserDefinedTransformersByAccount 

func (_e *MockQuerier_Expecter) GetUserDefinedTransformersByAccount(ctx interface{}, db interface{}, accountid interface{}) *MockQuerier_GetUserDefinedTransformersByAccount_Call

GetUserDefinedTransformersByAccount is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • accountid pgtype.UUID

func (*MockQuerier_Expecter) GetUserIdentitiesByTeamAccount 

func (_e *MockQuerier_Expecter) GetUserIdentitiesByTeamAccount(ctx interface{}, db interface{}, accountid interface{}) *MockQuerier_GetUserIdentitiesByTeamAccount_Call

GetUserIdentitiesByTeamAccount is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • accountid pgtype.UUID

func (*MockQuerier_Expecter) GetUserIdentityAssociationsByUserIds 

func (_e *MockQuerier_Expecter) GetUserIdentityAssociationsByUserIds(ctx interface{}, db interface{}, dollar_1 interface{}) *MockQuerier_GetUserIdentityAssociationsByUserIds_Call

GetUserIdentityAssociationsByUserIds is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • dollar_1 []pgtype.UUID

func (*MockQuerier_Expecter) GetUserIdentityByUserId 

func (_e *MockQuerier_Expecter) GetUserIdentityByUserId(ctx interface{}, db interface{}, userID interface{}) *MockQuerier_GetUserIdentityByUserId_Call

GetUserIdentityByUserId is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • userID pgtype.UUID

func (*MockQuerier_Expecter) IsConnectionInAccount 

func (_e *MockQuerier_Expecter) IsConnectionInAccount(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_IsConnectionInAccount_Call

IsConnectionInAccount is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg IsConnectionInAccountParams

func (*MockQuerier_Expecter) IsConnectionNameAvailable 

func (_e *MockQuerier_Expecter) IsConnectionNameAvailable(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_IsConnectionNameAvailable_Call

IsConnectionNameAvailable is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg IsConnectionNameAvailableParams

func (*MockQuerier_Expecter) IsJobNameAvailable 

func (_e *MockQuerier_Expecter) IsJobNameAvailable(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_IsJobNameAvailable_Call

IsJobNameAvailable is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg IsJobNameAvailableParams

func (*MockQuerier_Expecter) IsTransformerNameAvailable 

func (_e *MockQuerier_Expecter) IsTransformerNameAvailable(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_IsTransformerNameAvailable_Call

IsTransformerNameAvailable is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg IsTransformerNameAvailableParams

func (*MockQuerier_Expecter) IsUserInAccount 

func (_e *MockQuerier_Expecter) IsUserInAccount(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_IsUserInAccount_Call

IsUserInAccount is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg IsUserInAccountParams

func (*MockQuerier_Expecter) IsUserInAccountApiKey 

func (_e *MockQuerier_Expecter) IsUserInAccountApiKey(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_IsUserInAccountApiKey_Call

IsUserInAccountApiKey is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg IsUserInAccountApiKeyParams

func (*MockQuerier_Expecter) RemoveAccountApiKey 

func (_e *MockQuerier_Expecter) RemoveAccountApiKey(ctx interface{}, db interface{}, id interface{}) *MockQuerier_RemoveAccountApiKey_Call

RemoveAccountApiKey is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • id pgtype.UUID

func (*MockQuerier_Expecter) RemoveAccountInvite 

func (_e *MockQuerier_Expecter) RemoveAccountInvite(ctx interface{}, db interface{}, id interface{}) *MockQuerier_RemoveAccountInvite_Call

RemoveAccountInvite is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • id pgtype.UUID

func (*MockQuerier_Expecter) RemoveAccountUser 

func (_e *MockQuerier_Expecter) RemoveAccountUser(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_RemoveAccountUser_Call

RemoveAccountUser is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg RemoveAccountUserParams

func (*MockQuerier_Expecter) RemoveConnectionById 

func (_e *MockQuerier_Expecter) RemoveConnectionById(ctx interface{}, db interface{}, id interface{}) *MockQuerier_RemoveConnectionById_Call

RemoveConnectionById is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • id pgtype.UUID

func (*MockQuerier_Expecter) RemoveConnectionByNameAndAccount 

func (_e *MockQuerier_Expecter) RemoveConnectionByNameAndAccount(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_RemoveConnectionByNameAndAccount_Call

RemoveConnectionByNameAndAccount is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg RemoveConnectionByNameAndAccountParams

func (*MockQuerier_Expecter) RemoveJobById 

func (_e *MockQuerier_Expecter) RemoveJobById(ctx interface{}, db interface{}, id interface{}) *MockQuerier_RemoveJobById_Call

RemoveJobById is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • id pgtype.UUID

func (*MockQuerier_Expecter) RemoveJobConnectionDestination 

func (_e *MockQuerier_Expecter) RemoveJobConnectionDestination(ctx interface{}, db interface{}, id interface{}) *MockQuerier_RemoveJobConnectionDestination_Call

RemoveJobConnectionDestination is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • id pgtype.UUID

func (*MockQuerier_Expecter) RemoveJobConnectionDestinations 

func (_e *MockQuerier_Expecter) RemoveJobConnectionDestinations(ctx interface{}, db interface{}, jobids interface{}) *MockQuerier_RemoveJobConnectionDestinations_Call

RemoveJobConnectionDestinations is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • jobids []pgtype.UUID

func (*MockQuerier_Expecter) SetAnonymousUser 

func (_e *MockQuerier_Expecter) SetAnonymousUser(ctx interface{}, db interface{}) *MockQuerier_SetAnonymousUser_Call

SetAnonymousUser is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX

func (*MockQuerier_Expecter) SetJobSyncOptions 

func (_e *MockQuerier_Expecter) SetJobSyncOptions(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_SetJobSyncOptions_Call

SetJobSyncOptions is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg SetJobSyncOptionsParams

func (*MockQuerier_Expecter) SetJobWorkflowOptions 

func (_e *MockQuerier_Expecter) SetJobWorkflowOptions(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_SetJobWorkflowOptions_Call

SetJobWorkflowOptions is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg SetJobWorkflowOptionsParams

func (*MockQuerier_Expecter) SetRunContext added in v0.4.54 

func (_e *MockQuerier_Expecter) SetRunContext(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_SetRunContext_Call

SetRunContext is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg SetRunContextParams

func (*MockQuerier_Expecter) UpdateAccountApiKeyValue 

func (_e *MockQuerier_Expecter) UpdateAccountApiKeyValue(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_UpdateAccountApiKeyValue_Call

UpdateAccountApiKeyValue is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg UpdateAccountApiKeyValueParams

func (*MockQuerier_Expecter) UpdateAccountInviteToAccepted 

func (_e *MockQuerier_Expecter) UpdateAccountInviteToAccepted(ctx interface{}, db interface{}, id interface{}) *MockQuerier_UpdateAccountInviteToAccepted_Call

UpdateAccountInviteToAccepted is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • id pgtype.UUID

func (*MockQuerier_Expecter) UpdateAccountOnboardingConfig 

func (_e *MockQuerier_Expecter) UpdateAccountOnboardingConfig(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_UpdateAccountOnboardingConfig_Call

UpdateAccountOnboardingConfig is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg UpdateAccountOnboardingConfigParams

func (*MockQuerier_Expecter) UpdateActiveAccountInvitesToExpired 

func (_e *MockQuerier_Expecter) UpdateActiveAccountInvitesToExpired(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_UpdateActiveAccountInvitesToExpired_Call

UpdateActiveAccountInvitesToExpired is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg UpdateActiveAccountInvitesToExpiredParams

func (*MockQuerier_Expecter) UpdateConnection 

func (_e *MockQuerier_Expecter) UpdateConnection(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_UpdateConnection_Call

UpdateConnection is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg UpdateConnectionParams

func (*MockQuerier_Expecter) UpdateJobConnectionDestination 

func (_e *MockQuerier_Expecter) UpdateJobConnectionDestination(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_UpdateJobConnectionDestination_Call

UpdateJobConnectionDestination is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg UpdateJobConnectionDestinationParams

func (*MockQuerier_Expecter) UpdateJobMappings 

func (_e *MockQuerier_Expecter) UpdateJobMappings(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_UpdateJobMappings_Call

UpdateJobMappings is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg UpdateJobMappingsParams

func (*MockQuerier_Expecter) UpdateJobSchedule 

func (_e *MockQuerier_Expecter) UpdateJobSchedule(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_UpdateJobSchedule_Call

UpdateJobSchedule is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg UpdateJobScheduleParams

func (*MockQuerier_Expecter) UpdateJobSource 

func (_e *MockQuerier_Expecter) UpdateJobSource(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_UpdateJobSource_Call

UpdateJobSource is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg UpdateJobSourceParams

func (*MockQuerier_Expecter) UpdateJobVirtualForeignKeys added in v0.4.39 

func (_e *MockQuerier_Expecter) UpdateJobVirtualForeignKeys(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_UpdateJobVirtualForeignKeys_Call

UpdateJobVirtualForeignKeys is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg UpdateJobVirtualForeignKeysParams

func (*MockQuerier_Expecter) UpdateTemporalConfigByAccount 

func (_e *MockQuerier_Expecter) UpdateTemporalConfigByAccount(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_UpdateTemporalConfigByAccount_Call

UpdateTemporalConfigByAccount is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg UpdateTemporalConfigByAccountParams

func (*MockQuerier_Expecter) UpdateUserDefinedTransformer 

func (_e *MockQuerier_Expecter) UpdateUserDefinedTransformer(ctx interface{}, db interface{}, arg interface{}) *MockQuerier_UpdateUserDefinedTransformer_Call

UpdateUserDefinedTransformer is a helper method to define mock.On call

  • ctx context.Context
  • db DBTX
  • arg UpdateUserDefinedTransformerParams

type MockQuerier_GetAccountApiKeyById_Call 

type MockQuerier_GetAccountApiKeyById_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetAccountApiKeyById_Call) Return 

func (_c *MockQuerier_GetAccountApiKeyById_Call) Return(_a0 NeosyncApiAccountApiKey, _a1 error) *MockQuerier_GetAccountApiKeyById_Call

func (*MockQuerier_GetAccountApiKeyById_Call) Run 

func (_c *MockQuerier_GetAccountApiKeyById_Call) Run(run func(ctx context.Context, db DBTX, id pgtype.UUID)) *MockQuerier_GetAccountApiKeyById_Call

func (*MockQuerier_GetAccountApiKeyById_Call) RunAndReturn 

func (_c *MockQuerier_GetAccountApiKeyById_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) (NeosyncApiAccountApiKey, error)) *MockQuerier_GetAccountApiKeyById_Call

type MockQuerier_GetAccountApiKeyByKeyValue_Call 

type MockQuerier_GetAccountApiKeyByKeyValue_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetAccountApiKeyByKeyValue_Call) Return 

func (_c *MockQuerier_GetAccountApiKeyByKeyValue_Call) Return(_a0 NeosyncApiAccountApiKey, _a1 error) *MockQuerier_GetAccountApiKeyByKeyValue_Call

func (*MockQuerier_GetAccountApiKeyByKeyValue_Call) Run 

func (_c *MockQuerier_GetAccountApiKeyByKeyValue_Call) Run(run func(ctx context.Context, db DBTX, keyValue string)) *MockQuerier_GetAccountApiKeyByKeyValue_Call

func (*MockQuerier_GetAccountApiKeyByKeyValue_Call) RunAndReturn 

func (_c *MockQuerier_GetAccountApiKeyByKeyValue_Call) RunAndReturn(run func(context.Context, DBTX, string) (NeosyncApiAccountApiKey, error)) *MockQuerier_GetAccountApiKeyByKeyValue_Call

type MockQuerier_GetAccountApiKeys_Call 

type MockQuerier_GetAccountApiKeys_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetAccountApiKeys_Call) Return 

func (_c *MockQuerier_GetAccountApiKeys_Call) Return(_a0 []NeosyncApiAccountApiKey, _a1 error) *MockQuerier_GetAccountApiKeys_Call

func (*MockQuerier_GetAccountApiKeys_Call) Run 

func (_c *MockQuerier_GetAccountApiKeys_Call) Run(run func(ctx context.Context, db DBTX, accountid pgtype.UUID)) *MockQuerier_GetAccountApiKeys_Call

func (*MockQuerier_GetAccountApiKeys_Call) RunAndReturn 

func (_c *MockQuerier_GetAccountApiKeys_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) ([]NeosyncApiAccountApiKey, error)) *MockQuerier_GetAccountApiKeys_Call

type MockQuerier_GetAccountInviteByToken_Call 

type MockQuerier_GetAccountInviteByToken_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetAccountInviteByToken_Call) Return 

func (_c *MockQuerier_GetAccountInviteByToken_Call) Return(_a0 NeosyncApiAccountInvite, _a1 error) *MockQuerier_GetAccountInviteByToken_Call

func (*MockQuerier_GetAccountInviteByToken_Call) Run 

func (_c *MockQuerier_GetAccountInviteByToken_Call) Run(run func(ctx context.Context, db DBTX, token string)) *MockQuerier_GetAccountInviteByToken_Call

func (*MockQuerier_GetAccountInviteByToken_Call) RunAndReturn 

func (_c *MockQuerier_GetAccountInviteByToken_Call) RunAndReturn(run func(context.Context, DBTX, string) (NeosyncApiAccountInvite, error)) *MockQuerier_GetAccountInviteByToken_Call

type MockQuerier_GetAccountInvite_Call 

type MockQuerier_GetAccountInvite_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetAccountInvite_Call) Return 

func (_c *MockQuerier_GetAccountInvite_Call) Return(_a0 NeosyncApiAccountInvite, _a1 error) *MockQuerier_GetAccountInvite_Call

func (*MockQuerier_GetAccountInvite_Call) Run 

func (_c *MockQuerier_GetAccountInvite_Call) Run(run func(ctx context.Context, db DBTX, id pgtype.UUID)) *MockQuerier_GetAccountInvite_Call

func (*MockQuerier_GetAccountInvite_Call) RunAndReturn 

func (_c *MockQuerier_GetAccountInvite_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) (NeosyncApiAccountInvite, error)) *MockQuerier_GetAccountInvite_Call

type MockQuerier_GetAccountOnboardingConfig_Call 

type MockQuerier_GetAccountOnboardingConfig_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetAccountOnboardingConfig_Call) Return 

func (_c *MockQuerier_GetAccountOnboardingConfig_Call) Return(_a0 *pg_models.AccountOnboardingConfig, _a1 error) *MockQuerier_GetAccountOnboardingConfig_Call

func (*MockQuerier_GetAccountOnboardingConfig_Call) Run 

func (_c *MockQuerier_GetAccountOnboardingConfig_Call) Run(run func(ctx context.Context, db DBTX, id pgtype.UUID)) *MockQuerier_GetAccountOnboardingConfig_Call

func (*MockQuerier_GetAccountOnboardingConfig_Call) RunAndReturn 

func (_c *MockQuerier_GetAccountOnboardingConfig_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) (*pg_models.AccountOnboardingConfig, error)) *MockQuerier_GetAccountOnboardingConfig_Call

type MockQuerier_GetAccountUserAssociation_Call 

type MockQuerier_GetAccountUserAssociation_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetAccountUserAssociation_Call) Return 

func (_c *MockQuerier_GetAccountUserAssociation_Call) Return(_a0 NeosyncApiAccountUserAssociation, _a1 error) *MockQuerier_GetAccountUserAssociation_Call

func (*MockQuerier_GetAccountUserAssociation_Call) Run 

func (_c *MockQuerier_GetAccountUserAssociation_Call) Run(run func(ctx context.Context, db DBTX, arg GetAccountUserAssociationParams)) *MockQuerier_GetAccountUserAssociation_Call

func (*MockQuerier_GetAccountUserAssociation_Call) RunAndReturn 

func (_c *MockQuerier_GetAccountUserAssociation_Call) RunAndReturn(run func(context.Context, DBTX, GetAccountUserAssociationParams) (NeosyncApiAccountUserAssociation, error)) *MockQuerier_GetAccountUserAssociation_Call

type MockQuerier_GetAccount_Call 

type MockQuerier_GetAccount_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetAccount_Call) Return 

func (_c *MockQuerier_GetAccount_Call) Return(_a0 NeosyncApiAccount, _a1 error) *MockQuerier_GetAccount_Call

func (*MockQuerier_GetAccount_Call) Run 

func (_c *MockQuerier_GetAccount_Call) Run(run func(ctx context.Context, db DBTX, id pgtype.UUID)) *MockQuerier_GetAccount_Call

func (*MockQuerier_GetAccount_Call) RunAndReturn 

func (_c *MockQuerier_GetAccount_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) (NeosyncApiAccount, error)) *MockQuerier_GetAccount_Call

type MockQuerier_GetAccountsByUser_Call 

type MockQuerier_GetAccountsByUser_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetAccountsByUser_Call) Return 

func (_c *MockQuerier_GetAccountsByUser_Call) Return(_a0 []NeosyncApiAccount, _a1 error) *MockQuerier_GetAccountsByUser_Call

func (*MockQuerier_GetAccountsByUser_Call) Run 

func (_c *MockQuerier_GetAccountsByUser_Call) Run(run func(ctx context.Context, db DBTX, id pgtype.UUID)) *MockQuerier_GetAccountsByUser_Call

func (*MockQuerier_GetAccountsByUser_Call) RunAndReturn 

func (_c *MockQuerier_GetAccountsByUser_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) ([]NeosyncApiAccount, error)) *MockQuerier_GetAccountsByUser_Call

type MockQuerier_GetActiveAccountInvites_Call 

type MockQuerier_GetActiveAccountInvites_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetActiveAccountInvites_Call) Return 

func (_c *MockQuerier_GetActiveAccountInvites_Call) Return(_a0 []NeosyncApiAccountInvite, _a1 error) *MockQuerier_GetActiveAccountInvites_Call

func (*MockQuerier_GetActiveAccountInvites_Call) Run 

func (_c *MockQuerier_GetActiveAccountInvites_Call) Run(run func(ctx context.Context, db DBTX, accountid pgtype.UUID)) *MockQuerier_GetActiveAccountInvites_Call

func (*MockQuerier_GetActiveAccountInvites_Call) RunAndReturn 

func (_c *MockQuerier_GetActiveAccountInvites_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) ([]NeosyncApiAccountInvite, error)) *MockQuerier_GetActiveAccountInvites_Call

type MockQuerier_GetAnonymousUser_Call 

type MockQuerier_GetAnonymousUser_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetAnonymousUser_Call) Return 

func (_c *MockQuerier_GetAnonymousUser_Call) Return(_a0 NeosyncApiUser, _a1 error) *MockQuerier_GetAnonymousUser_Call

func (*MockQuerier_GetAnonymousUser_Call) Run 

func (_c *MockQuerier_GetAnonymousUser_Call) Run(run func(ctx context.Context, db DBTX)) *MockQuerier_GetAnonymousUser_Call

func (*MockQuerier_GetAnonymousUser_Call) RunAndReturn 

func (_c *MockQuerier_GetAnonymousUser_Call) RunAndReturn(run func(context.Context, DBTX) (NeosyncApiUser, error)) *MockQuerier_GetAnonymousUser_Call

type MockQuerier_GetConnectionById_Call 

type MockQuerier_GetConnectionById_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetConnectionById_Call) Return 

func (_c *MockQuerier_GetConnectionById_Call) Return(_a0 NeosyncApiConnection, _a1 error) *MockQuerier_GetConnectionById_Call

func (*MockQuerier_GetConnectionById_Call) Run 

func (_c *MockQuerier_GetConnectionById_Call) Run(run func(ctx context.Context, db DBTX, id pgtype.UUID)) *MockQuerier_GetConnectionById_Call

func (*MockQuerier_GetConnectionById_Call) RunAndReturn 

func (_c *MockQuerier_GetConnectionById_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) (NeosyncApiConnection, error)) *MockQuerier_GetConnectionById_Call

type MockQuerier_GetConnectionByNameAndAccount_Call 

type MockQuerier_GetConnectionByNameAndAccount_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetConnectionByNameAndAccount_Call) Return 

func (_c *MockQuerier_GetConnectionByNameAndAccount_Call) Return(_a0 NeosyncApiConnection, _a1 error) *MockQuerier_GetConnectionByNameAndAccount_Call

func (*MockQuerier_GetConnectionByNameAndAccount_Call) Run 

func (_c *MockQuerier_GetConnectionByNameAndAccount_Call) Run(run func(ctx context.Context, db DBTX, arg GetConnectionByNameAndAccountParams)) *MockQuerier_GetConnectionByNameAndAccount_Call

func (*MockQuerier_GetConnectionByNameAndAccount_Call) RunAndReturn 

func (_c *MockQuerier_GetConnectionByNameAndAccount_Call) RunAndReturn(run func(context.Context, DBTX, GetConnectionByNameAndAccountParams) (NeosyncApiConnection, error)) *MockQuerier_GetConnectionByNameAndAccount_Call

type MockQuerier_GetConnectionsByAccount_Call 

type MockQuerier_GetConnectionsByAccount_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetConnectionsByAccount_Call) Return 

func (_c *MockQuerier_GetConnectionsByAccount_Call) Return(_a0 []NeosyncApiConnection, _a1 error) *MockQuerier_GetConnectionsByAccount_Call

func (*MockQuerier_GetConnectionsByAccount_Call) Run 

func (_c *MockQuerier_GetConnectionsByAccount_Call) Run(run func(ctx context.Context, db DBTX, accountid pgtype.UUID)) *MockQuerier_GetConnectionsByAccount_Call

func (*MockQuerier_GetConnectionsByAccount_Call) RunAndReturn 

func (_c *MockQuerier_GetConnectionsByAccount_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) ([]NeosyncApiConnection, error)) *MockQuerier_GetConnectionsByAccount_Call

type MockQuerier_GetConnectionsByIds_Call 

type MockQuerier_GetConnectionsByIds_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetConnectionsByIds_Call) Return 

func (_c *MockQuerier_GetConnectionsByIds_Call) Return(_a0 []NeosyncApiConnection, _a1 error) *MockQuerier_GetConnectionsByIds_Call

func (*MockQuerier_GetConnectionsByIds_Call) Run 

func (_c *MockQuerier_GetConnectionsByIds_Call) Run(run func(ctx context.Context, db DBTX, dollar_1 []pgtype.UUID)) *MockQuerier_GetConnectionsByIds_Call

func (*MockQuerier_GetConnectionsByIds_Call) RunAndReturn 

func (_c *MockQuerier_GetConnectionsByIds_Call) RunAndReturn(run func(context.Context, DBTX, []pgtype.UUID) ([]NeosyncApiConnection, error)) *MockQuerier_GetConnectionsByIds_Call

type MockQuerier_GetJobById_Call 

type MockQuerier_GetJobById_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetJobById_Call) Return 

func (_c *MockQuerier_GetJobById_Call) Return(_a0 NeosyncApiJob, _a1 error) *MockQuerier_GetJobById_Call

func (*MockQuerier_GetJobById_Call) Run 

func (_c *MockQuerier_GetJobById_Call) Run(run func(ctx context.Context, db DBTX, id pgtype.UUID)) *MockQuerier_GetJobById_Call

func (*MockQuerier_GetJobById_Call) RunAndReturn 

func (_c *MockQuerier_GetJobById_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) (NeosyncApiJob, error)) *MockQuerier_GetJobById_Call

type MockQuerier_GetJobByNameAndAccount_Call 

type MockQuerier_GetJobByNameAndAccount_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetJobByNameAndAccount_Call) Return 

func (_c *MockQuerier_GetJobByNameAndAccount_Call) Return(_a0 NeosyncApiJob, _a1 error) *MockQuerier_GetJobByNameAndAccount_Call

func (*MockQuerier_GetJobByNameAndAccount_Call) Run 

func (_c *MockQuerier_GetJobByNameAndAccount_Call) Run(run func(ctx context.Context, db DBTX, arg GetJobByNameAndAccountParams)) *MockQuerier_GetJobByNameAndAccount_Call

func (*MockQuerier_GetJobByNameAndAccount_Call) RunAndReturn 

func (_c *MockQuerier_GetJobByNameAndAccount_Call) RunAndReturn(run func(context.Context, DBTX, GetJobByNameAndAccountParams) (NeosyncApiJob, error)) *MockQuerier_GetJobByNameAndAccount_Call

type MockQuerier_GetJobConnectionDestination_Call 

type MockQuerier_GetJobConnectionDestination_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetJobConnectionDestination_Call) Return 

func (_c *MockQuerier_GetJobConnectionDestination_Call) Return(_a0 NeosyncApiJobDestinationConnectionAssociation, _a1 error) *MockQuerier_GetJobConnectionDestination_Call

func (*MockQuerier_GetJobConnectionDestination_Call) Run 

func (_c *MockQuerier_GetJobConnectionDestination_Call) Run(run func(ctx context.Context, db DBTX, id pgtype.UUID)) *MockQuerier_GetJobConnectionDestination_Call

func (*MockQuerier_GetJobConnectionDestination_Call) RunAndReturn 

func (_c *MockQuerier_GetJobConnectionDestination_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) (NeosyncApiJobDestinationConnectionAssociation, error)) *MockQuerier_GetJobConnectionDestination_Call

type MockQuerier_GetJobConnectionDestinationsByJobIds_Call 

type MockQuerier_GetJobConnectionDestinationsByJobIds_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetJobConnectionDestinationsByJobIds_Call) Return 

func (_c *MockQuerier_GetJobConnectionDestinationsByJobIds_Call) Return(_a0 []NeosyncApiJobDestinationConnectionAssociation, _a1 error) *MockQuerier_GetJobConnectionDestinationsByJobIds_Call

func (*MockQuerier_GetJobConnectionDestinationsByJobIds_Call) Run 

func (_c *MockQuerier_GetJobConnectionDestinationsByJobIds_Call) Run(run func(ctx context.Context, db DBTX, jobids []pgtype.UUID)) *MockQuerier_GetJobConnectionDestinationsByJobIds_Call

func (*MockQuerier_GetJobConnectionDestinationsByJobIds_Call) RunAndReturn 

func (_c *MockQuerier_GetJobConnectionDestinationsByJobIds_Call) RunAndReturn(run func(context.Context, DBTX, []pgtype.UUID) ([]NeosyncApiJobDestinationConnectionAssociation, error)) *MockQuerier_GetJobConnectionDestinationsByJobIds_Call

type MockQuerier_GetJobConnectionDestinations_Call 

type MockQuerier_GetJobConnectionDestinations_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetJobConnectionDestinations_Call) Return 

func (_c *MockQuerier_GetJobConnectionDestinations_Call) Return(_a0 []NeosyncApiJobDestinationConnectionAssociation, _a1 error) *MockQuerier_GetJobConnectionDestinations_Call

func (*MockQuerier_GetJobConnectionDestinations_Call) Run 

func (_c *MockQuerier_GetJobConnectionDestinations_Call) Run(run func(ctx context.Context, db DBTX, id pgtype.UUID)) *MockQuerier_GetJobConnectionDestinations_Call

func (*MockQuerier_GetJobConnectionDestinations_Call) RunAndReturn 

func (_c *MockQuerier_GetJobConnectionDestinations_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) ([]NeosyncApiJobDestinationConnectionAssociation, error)) *MockQuerier_GetJobConnectionDestinations_Call

type MockQuerier_GetJobsByAccount_Call 

type MockQuerier_GetJobsByAccount_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetJobsByAccount_Call) Return 

func (_c *MockQuerier_GetJobsByAccount_Call) Return(_a0 []NeosyncApiJob, _a1 error) *MockQuerier_GetJobsByAccount_Call

func (*MockQuerier_GetJobsByAccount_Call) Run 

func (_c *MockQuerier_GetJobsByAccount_Call) Run(run func(ctx context.Context, db DBTX, accountid pgtype.UUID)) *MockQuerier_GetJobsByAccount_Call

func (*MockQuerier_GetJobsByAccount_Call) RunAndReturn 

func (_c *MockQuerier_GetJobsByAccount_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) ([]NeosyncApiJob, error)) *MockQuerier_GetJobsByAccount_Call

type MockQuerier_GetPersonalAccountByUserId_Call 

type MockQuerier_GetPersonalAccountByUserId_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetPersonalAccountByUserId_Call) Return 

func (_c *MockQuerier_GetPersonalAccountByUserId_Call) Return(_a0 NeosyncApiAccount, _a1 error) *MockQuerier_GetPersonalAccountByUserId_Call

func (*MockQuerier_GetPersonalAccountByUserId_Call) Run 

func (_c *MockQuerier_GetPersonalAccountByUserId_Call) Run(run func(ctx context.Context, db DBTX, userid pgtype.UUID)) *MockQuerier_GetPersonalAccountByUserId_Call

func (*MockQuerier_GetPersonalAccountByUserId_Call) RunAndReturn 

func (_c *MockQuerier_GetPersonalAccountByUserId_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) (NeosyncApiAccount, error)) *MockQuerier_GetPersonalAccountByUserId_Call

type MockQuerier_GetRunContextByKey_Call added in v0.4.54 

type MockQuerier_GetRunContextByKey_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetRunContextByKey_Call) Return added in v0.4.54 

func (_c *MockQuerier_GetRunContextByKey_Call) Return(_a0 NeosyncApiRuncontext, _a1 error) *MockQuerier_GetRunContextByKey_Call

func (*MockQuerier_GetRunContextByKey_Call) Run added in v0.4.54 

func (_c *MockQuerier_GetRunContextByKey_Call) Run(run func(ctx context.Context, db DBTX, arg GetRunContextByKeyParams)) *MockQuerier_GetRunContextByKey_Call

func (*MockQuerier_GetRunContextByKey_Call) RunAndReturn added in v0.4.54 

func (_c *MockQuerier_GetRunContextByKey_Call) RunAndReturn(run func(context.Context, DBTX, GetRunContextByKeyParams) (NeosyncApiRuncontext, error)) *MockQuerier_GetRunContextByKey_Call

type MockQuerier_GetTeamAccountsByUserId_Call 

type MockQuerier_GetTeamAccountsByUserId_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetTeamAccountsByUserId_Call) Return 

func (_c *MockQuerier_GetTeamAccountsByUserId_Call) Return(_a0 []NeosyncApiAccount, _a1 error) *MockQuerier_GetTeamAccountsByUserId_Call

func (*MockQuerier_GetTeamAccountsByUserId_Call) Run 

func (_c *MockQuerier_GetTeamAccountsByUserId_Call) Run(run func(ctx context.Context, db DBTX, userid pgtype.UUID)) *MockQuerier_GetTeamAccountsByUserId_Call

func (*MockQuerier_GetTeamAccountsByUserId_Call) RunAndReturn 

func (_c *MockQuerier_GetTeamAccountsByUserId_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) ([]NeosyncApiAccount, error)) *MockQuerier_GetTeamAccountsByUserId_Call

type MockQuerier_GetTemporalConfigByAccount_Call 

type MockQuerier_GetTemporalConfigByAccount_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetTemporalConfigByAccount_Call) Return 

func (_c *MockQuerier_GetTemporalConfigByAccount_Call) Return(_a0 *pg_models.TemporalConfig, _a1 error) *MockQuerier_GetTemporalConfigByAccount_Call

func (*MockQuerier_GetTemporalConfigByAccount_Call) Run 

func (_c *MockQuerier_GetTemporalConfigByAccount_Call) Run(run func(ctx context.Context, db DBTX, id pgtype.UUID)) *MockQuerier_GetTemporalConfigByAccount_Call

func (*MockQuerier_GetTemporalConfigByAccount_Call) RunAndReturn 

func (_c *MockQuerier_GetTemporalConfigByAccount_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) (*pg_models.TemporalConfig, error)) *MockQuerier_GetTemporalConfigByAccount_Call

type MockQuerier_GetTemporalConfigByUserAccount_Call 

type MockQuerier_GetTemporalConfigByUserAccount_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetTemporalConfigByUserAccount_Call) Return 

func (_c *MockQuerier_GetTemporalConfigByUserAccount_Call) Return(_a0 *pg_models.TemporalConfig, _a1 error) *MockQuerier_GetTemporalConfigByUserAccount_Call

func (*MockQuerier_GetTemporalConfigByUserAccount_Call) Run 

func (_c *MockQuerier_GetTemporalConfigByUserAccount_Call) Run(run func(ctx context.Context, db DBTX, arg GetTemporalConfigByUserAccountParams)) *MockQuerier_GetTemporalConfigByUserAccount_Call

func (*MockQuerier_GetTemporalConfigByUserAccount_Call) RunAndReturn 

func (_c *MockQuerier_GetTemporalConfigByUserAccount_Call) RunAndReturn(run func(context.Context, DBTX, GetTemporalConfigByUserAccountParams) (*pg_models.TemporalConfig, error)) *MockQuerier_GetTemporalConfigByUserAccount_Call

type MockQuerier_GetUserAssociationByProviderSub_Call 

type MockQuerier_GetUserAssociationByProviderSub_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetUserAssociationByProviderSub_Call) Return 

func (_c *MockQuerier_GetUserAssociationByProviderSub_Call) Return(_a0 NeosyncApiUserIdentityProviderAssociation, _a1 error) *MockQuerier_GetUserAssociationByProviderSub_Call

func (*MockQuerier_GetUserAssociationByProviderSub_Call) Run 

func (_c *MockQuerier_GetUserAssociationByProviderSub_Call) Run(run func(ctx context.Context, db DBTX, providerSub string)) *MockQuerier_GetUserAssociationByProviderSub_Call

func (*MockQuerier_GetUserAssociationByProviderSub_Call) RunAndReturn 

func (_c *MockQuerier_GetUserAssociationByProviderSub_Call) RunAndReturn(run func(context.Context, DBTX, string) (NeosyncApiUserIdentityProviderAssociation, error)) *MockQuerier_GetUserAssociationByProviderSub_Call

type MockQuerier_GetUserByProviderSub_Call 

type MockQuerier_GetUserByProviderSub_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetUserByProviderSub_Call) Return 

func (_c *MockQuerier_GetUserByProviderSub_Call) Return(_a0 NeosyncApiUser, _a1 error) *MockQuerier_GetUserByProviderSub_Call

func (*MockQuerier_GetUserByProviderSub_Call) Run 

func (_c *MockQuerier_GetUserByProviderSub_Call) Run(run func(ctx context.Context, db DBTX, providerSub string)) *MockQuerier_GetUserByProviderSub_Call

func (*MockQuerier_GetUserByProviderSub_Call) RunAndReturn 

func (_c *MockQuerier_GetUserByProviderSub_Call) RunAndReturn(run func(context.Context, DBTX, string) (NeosyncApiUser, error)) *MockQuerier_GetUserByProviderSub_Call

type MockQuerier_GetUserDefinedTransformerById_Call 

type MockQuerier_GetUserDefinedTransformerById_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetUserDefinedTransformerById_Call) Return 

func (_c *MockQuerier_GetUserDefinedTransformerById_Call) Return(_a0 NeosyncApiTransformer, _a1 error) *MockQuerier_GetUserDefinedTransformerById_Call

func (*MockQuerier_GetUserDefinedTransformerById_Call) Run 

func (_c *MockQuerier_GetUserDefinedTransformerById_Call) Run(run func(ctx context.Context, db DBTX, id pgtype.UUID)) *MockQuerier_GetUserDefinedTransformerById_Call

func (*MockQuerier_GetUserDefinedTransformerById_Call) RunAndReturn 

func (_c *MockQuerier_GetUserDefinedTransformerById_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) (NeosyncApiTransformer, error)) *MockQuerier_GetUserDefinedTransformerById_Call

type MockQuerier_GetUserDefinedTransformersByAccount_Call 

type MockQuerier_GetUserDefinedTransformersByAccount_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetUserDefinedTransformersByAccount_Call) Return 

func (_c *MockQuerier_GetUserDefinedTransformersByAccount_Call) Return(_a0 []NeosyncApiTransformer, _a1 error) *MockQuerier_GetUserDefinedTransformersByAccount_Call

func (*MockQuerier_GetUserDefinedTransformersByAccount_Call) Run 

func (_c *MockQuerier_GetUserDefinedTransformersByAccount_Call) Run(run func(ctx context.Context, db DBTX, accountid pgtype.UUID)) *MockQuerier_GetUserDefinedTransformersByAccount_Call

func (*MockQuerier_GetUserDefinedTransformersByAccount_Call) RunAndReturn 

func (_c *MockQuerier_GetUserDefinedTransformersByAccount_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) ([]NeosyncApiTransformer, error)) *MockQuerier_GetUserDefinedTransformersByAccount_Call

type MockQuerier_GetUserIdentitiesByTeamAccount_Call 

type MockQuerier_GetUserIdentitiesByTeamAccount_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetUserIdentitiesByTeamAccount_Call) Return 

func (_c *MockQuerier_GetUserIdentitiesByTeamAccount_Call) Return(_a0 []NeosyncApiUserIdentityProviderAssociation, _a1 error) *MockQuerier_GetUserIdentitiesByTeamAccount_Call

func (*MockQuerier_GetUserIdentitiesByTeamAccount_Call) Run 

func (_c *MockQuerier_GetUserIdentitiesByTeamAccount_Call) Run(run func(ctx context.Context, db DBTX, accountid pgtype.UUID)) *MockQuerier_GetUserIdentitiesByTeamAccount_Call

func (*MockQuerier_GetUserIdentitiesByTeamAccount_Call) RunAndReturn 

func (_c *MockQuerier_GetUserIdentitiesByTeamAccount_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) ([]NeosyncApiUserIdentityProviderAssociation, error)) *MockQuerier_GetUserIdentitiesByTeamAccount_Call

type MockQuerier_GetUserIdentityAssociationsByUserIds_Call 

type MockQuerier_GetUserIdentityAssociationsByUserIds_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetUserIdentityAssociationsByUserIds_Call) Return 

func (_c *MockQuerier_GetUserIdentityAssociationsByUserIds_Call) Return(_a0 []NeosyncApiUserIdentityProviderAssociation, _a1 error) *MockQuerier_GetUserIdentityAssociationsByUserIds_Call

func (*MockQuerier_GetUserIdentityAssociationsByUserIds_Call) Run 

func (_c *MockQuerier_GetUserIdentityAssociationsByUserIds_Call) Run(run func(ctx context.Context, db DBTX, dollar_1 []pgtype.UUID)) *MockQuerier_GetUserIdentityAssociationsByUserIds_Call

func (*MockQuerier_GetUserIdentityAssociationsByUserIds_Call) RunAndReturn 

func (_c *MockQuerier_GetUserIdentityAssociationsByUserIds_Call) RunAndReturn(run func(context.Context, DBTX, []pgtype.UUID) ([]NeosyncApiUserIdentityProviderAssociation, error)) *MockQuerier_GetUserIdentityAssociationsByUserIds_Call

type MockQuerier_GetUserIdentityByUserId_Call 

type MockQuerier_GetUserIdentityByUserId_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetUserIdentityByUserId_Call) Return 

func (_c *MockQuerier_GetUserIdentityByUserId_Call) Return(_a0 NeosyncApiUserIdentityProviderAssociation, _a1 error) *MockQuerier_GetUserIdentityByUserId_Call

func (*MockQuerier_GetUserIdentityByUserId_Call) Run 

func (_c *MockQuerier_GetUserIdentityByUserId_Call) Run(run func(ctx context.Context, db DBTX, userID pgtype.UUID)) *MockQuerier_GetUserIdentityByUserId_Call

func (*MockQuerier_GetUserIdentityByUserId_Call) RunAndReturn 

func (_c *MockQuerier_GetUserIdentityByUserId_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) (NeosyncApiUserIdentityProviderAssociation, error)) *MockQuerier_GetUserIdentityByUserId_Call

type MockQuerier_GetUser_Call 

type MockQuerier_GetUser_Call struct {
	*mock.Call
}

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

func (*MockQuerier_GetUser_Call) Return 

func (_c *MockQuerier_GetUser_Call) Return(_a0 NeosyncApiUser, _a1 error) *MockQuerier_GetUser_Call

func (*MockQuerier_GetUser_Call) Run 

func (_c *MockQuerier_GetUser_Call) Run(run func(ctx context.Context, db DBTX, id pgtype.UUID)) *MockQuerier_GetUser_Call

func (*MockQuerier_GetUser_Call) RunAndReturn 

func (_c *MockQuerier_GetUser_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) (NeosyncApiUser, error)) *MockQuerier_GetUser_Call

type MockQuerier_IsConnectionInAccount_Call 

type MockQuerier_IsConnectionInAccount_Call struct {
	*mock.Call
}

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

func (*MockQuerier_IsConnectionInAccount_Call) Return 

func (_c *MockQuerier_IsConnectionInAccount_Call) Return(_a0 int64, _a1 error) *MockQuerier_IsConnectionInAccount_Call

func (*MockQuerier_IsConnectionInAccount_Call) Run 

func (_c *MockQuerier_IsConnectionInAccount_Call) Run(run func(ctx context.Context, db DBTX, arg IsConnectionInAccountParams)) *MockQuerier_IsConnectionInAccount_Call

func (*MockQuerier_IsConnectionInAccount_Call) RunAndReturn 

func (_c *MockQuerier_IsConnectionInAccount_Call) RunAndReturn(run func(context.Context, DBTX, IsConnectionInAccountParams) (int64, error)) *MockQuerier_IsConnectionInAccount_Call

type MockQuerier_IsConnectionNameAvailable_Call 

type MockQuerier_IsConnectionNameAvailable_Call struct {
	*mock.Call
}

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

func (*MockQuerier_IsConnectionNameAvailable_Call) Return 

func (_c *MockQuerier_IsConnectionNameAvailable_Call) Return(_a0 int64, _a1 error) *MockQuerier_IsConnectionNameAvailable_Call

func (*MockQuerier_IsConnectionNameAvailable_Call) Run 

func (_c *MockQuerier_IsConnectionNameAvailable_Call) Run(run func(ctx context.Context, db DBTX, arg IsConnectionNameAvailableParams)) *MockQuerier_IsConnectionNameAvailable_Call

func (*MockQuerier_IsConnectionNameAvailable_Call) RunAndReturn 

func (_c *MockQuerier_IsConnectionNameAvailable_Call) RunAndReturn(run func(context.Context, DBTX, IsConnectionNameAvailableParams) (int64, error)) *MockQuerier_IsConnectionNameAvailable_Call

type MockQuerier_IsJobNameAvailable_Call 

type MockQuerier_IsJobNameAvailable_Call struct {
	*mock.Call
}

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

func (*MockQuerier_IsJobNameAvailable_Call) Return 

func (_c *MockQuerier_IsJobNameAvailable_Call) Return(_a0 int64, _a1 error) *MockQuerier_IsJobNameAvailable_Call

func (*MockQuerier_IsJobNameAvailable_Call) Run 

func (_c *MockQuerier_IsJobNameAvailable_Call) Run(run func(ctx context.Context, db DBTX, arg IsJobNameAvailableParams)) *MockQuerier_IsJobNameAvailable_Call

func (*MockQuerier_IsJobNameAvailable_Call) RunAndReturn 

func (_c *MockQuerier_IsJobNameAvailable_Call) RunAndReturn(run func(context.Context, DBTX, IsJobNameAvailableParams) (int64, error)) *MockQuerier_IsJobNameAvailable_Call

type MockQuerier_IsTransformerNameAvailable_Call 

type MockQuerier_IsTransformerNameAvailable_Call struct {
	*mock.Call
}

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

func (*MockQuerier_IsTransformerNameAvailable_Call) Return 

func (_c *MockQuerier_IsTransformerNameAvailable_Call) Return(_a0 int64, _a1 error) *MockQuerier_IsTransformerNameAvailable_Call

func (*MockQuerier_IsTransformerNameAvailable_Call) Run 

func (_c *MockQuerier_IsTransformerNameAvailable_Call) Run(run func(ctx context.Context, db DBTX, arg IsTransformerNameAvailableParams)) *MockQuerier_IsTransformerNameAvailable_Call

func (*MockQuerier_IsTransformerNameAvailable_Call) RunAndReturn 

func (_c *MockQuerier_IsTransformerNameAvailable_Call) RunAndReturn(run func(context.Context, DBTX, IsTransformerNameAvailableParams) (int64, error)) *MockQuerier_IsTransformerNameAvailable_Call

type MockQuerier_IsUserInAccountApiKey_Call 

type MockQuerier_IsUserInAccountApiKey_Call struct {
	*mock.Call
}

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

func (*MockQuerier_IsUserInAccountApiKey_Call) Return 

func (_c *MockQuerier_IsUserInAccountApiKey_Call) Return(_a0 int64, _a1 error) *MockQuerier_IsUserInAccountApiKey_Call

func (*MockQuerier_IsUserInAccountApiKey_Call) Run 

func (_c *MockQuerier_IsUserInAccountApiKey_Call) Run(run func(ctx context.Context, db DBTX, arg IsUserInAccountApiKeyParams)) *MockQuerier_IsUserInAccountApiKey_Call

func (*MockQuerier_IsUserInAccountApiKey_Call) RunAndReturn 

func (_c *MockQuerier_IsUserInAccountApiKey_Call) RunAndReturn(run func(context.Context, DBTX, IsUserInAccountApiKeyParams) (int64, error)) *MockQuerier_IsUserInAccountApiKey_Call

type MockQuerier_IsUserInAccount_Call 

type MockQuerier_IsUserInAccount_Call struct {
	*mock.Call
}

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

func (*MockQuerier_IsUserInAccount_Call) Return 

func (_c *MockQuerier_IsUserInAccount_Call) Return(_a0 int64, _a1 error) *MockQuerier_IsUserInAccount_Call

func (*MockQuerier_IsUserInAccount_Call) Run 

func (_c *MockQuerier_IsUserInAccount_Call) Run(run func(ctx context.Context, db DBTX, arg IsUserInAccountParams)) *MockQuerier_IsUserInAccount_Call

func (*MockQuerier_IsUserInAccount_Call) RunAndReturn 

func (_c *MockQuerier_IsUserInAccount_Call) RunAndReturn(run func(context.Context, DBTX, IsUserInAccountParams) (int64, error)) *MockQuerier_IsUserInAccount_Call

type MockQuerier_RemoveAccountApiKey_Call 

type MockQuerier_RemoveAccountApiKey_Call struct {
	*mock.Call
}

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

func (*MockQuerier_RemoveAccountApiKey_Call) Return 

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

func (*MockQuerier_RemoveAccountApiKey_Call) Run 

func (_c *MockQuerier_RemoveAccountApiKey_Call) Run(run func(ctx context.Context, db DBTX, id pgtype.UUID)) *MockQuerier_RemoveAccountApiKey_Call

func (*MockQuerier_RemoveAccountApiKey_Call) RunAndReturn 

func (_c *MockQuerier_RemoveAccountApiKey_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) error) *MockQuerier_RemoveAccountApiKey_Call

type MockQuerier_RemoveAccountInvite_Call 

type MockQuerier_RemoveAccountInvite_Call struct {
	*mock.Call
}

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

func (*MockQuerier_RemoveAccountInvite_Call) Return 

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

func (*MockQuerier_RemoveAccountInvite_Call) Run 

func (_c *MockQuerier_RemoveAccountInvite_Call) Run(run func(ctx context.Context, db DBTX, id pgtype.UUID)) *MockQuerier_RemoveAccountInvite_Call

func (*MockQuerier_RemoveAccountInvite_Call) RunAndReturn 

func (_c *MockQuerier_RemoveAccountInvite_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) error) *MockQuerier_RemoveAccountInvite_Call

type MockQuerier_RemoveAccountUser_Call 

type MockQuerier_RemoveAccountUser_Call struct {
	*mock.Call
}

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

func (*MockQuerier_RemoveAccountUser_Call) Return 

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

func (*MockQuerier_RemoveAccountUser_Call) Run 

func (_c *MockQuerier_RemoveAccountUser_Call) Run(run func(ctx context.Context, db DBTX, arg RemoveAccountUserParams)) *MockQuerier_RemoveAccountUser_Call

func (*MockQuerier_RemoveAccountUser_Call) RunAndReturn 

func (_c *MockQuerier_RemoveAccountUser_Call) RunAndReturn(run func(context.Context, DBTX, RemoveAccountUserParams) error) *MockQuerier_RemoveAccountUser_Call

type MockQuerier_RemoveConnectionById_Call 

type MockQuerier_RemoveConnectionById_Call struct {
	*mock.Call
}

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

func (*MockQuerier_RemoveConnectionById_Call) Return 

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

func (*MockQuerier_RemoveConnectionById_Call) Run 

func (_c *MockQuerier_RemoveConnectionById_Call) Run(run func(ctx context.Context, db DBTX, id pgtype.UUID)) *MockQuerier_RemoveConnectionById_Call

func (*MockQuerier_RemoveConnectionById_Call) RunAndReturn 

func (_c *MockQuerier_RemoveConnectionById_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) error) *MockQuerier_RemoveConnectionById_Call

type MockQuerier_RemoveConnectionByNameAndAccount_Call 

type MockQuerier_RemoveConnectionByNameAndAccount_Call struct {
	*mock.Call
}

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

func (*MockQuerier_RemoveConnectionByNameAndAccount_Call) Return 

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

func (*MockQuerier_RemoveConnectionByNameAndAccount_Call) Run 

func (_c *MockQuerier_RemoveConnectionByNameAndAccount_Call) Run(run func(ctx context.Context, db DBTX, arg RemoveConnectionByNameAndAccountParams)) *MockQuerier_RemoveConnectionByNameAndAccount_Call

func (*MockQuerier_RemoveConnectionByNameAndAccount_Call) RunAndReturn 

func (_c *MockQuerier_RemoveConnectionByNameAndAccount_Call) RunAndReturn(run func(context.Context, DBTX, RemoveConnectionByNameAndAccountParams) error) *MockQuerier_RemoveConnectionByNameAndAccount_Call

type MockQuerier_RemoveJobById_Call 

type MockQuerier_RemoveJobById_Call struct {
	*mock.Call
}

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

func (*MockQuerier_RemoveJobById_Call) Return 

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

func (*MockQuerier_RemoveJobById_Call) Run 

func (_c *MockQuerier_RemoveJobById_Call) Run(run func(ctx context.Context, db DBTX, id pgtype.UUID)) *MockQuerier_RemoveJobById_Call

func (*MockQuerier_RemoveJobById_Call) RunAndReturn 

func (_c *MockQuerier_RemoveJobById_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) error) *MockQuerier_RemoveJobById_Call

type MockQuerier_RemoveJobConnectionDestination_Call 

type MockQuerier_RemoveJobConnectionDestination_Call struct {
	*mock.Call
}

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

func (*MockQuerier_RemoveJobConnectionDestination_Call) Return 

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

func (*MockQuerier_RemoveJobConnectionDestination_Call) Run 

func (_c *MockQuerier_RemoveJobConnectionDestination_Call) Run(run func(ctx context.Context, db DBTX, id pgtype.UUID)) *MockQuerier_RemoveJobConnectionDestination_Call

func (*MockQuerier_RemoveJobConnectionDestination_Call) RunAndReturn 

func (_c *MockQuerier_RemoveJobConnectionDestination_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) error) *MockQuerier_RemoveJobConnectionDestination_Call

type MockQuerier_RemoveJobConnectionDestinations_Call 

type MockQuerier_RemoveJobConnectionDestinations_Call struct {
	*mock.Call
}

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

func (*MockQuerier_RemoveJobConnectionDestinations_Call) Return 

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

func (*MockQuerier_RemoveJobConnectionDestinations_Call) Run 

func (_c *MockQuerier_RemoveJobConnectionDestinations_Call) Run(run func(ctx context.Context, db DBTX, jobids []pgtype.UUID)) *MockQuerier_RemoveJobConnectionDestinations_Call

func (*MockQuerier_RemoveJobConnectionDestinations_Call) RunAndReturn 

func (_c *MockQuerier_RemoveJobConnectionDestinations_Call) RunAndReturn(run func(context.Context, DBTX, []pgtype.UUID) error) *MockQuerier_RemoveJobConnectionDestinations_Call

type MockQuerier_SetAnonymousUser_Call 

type MockQuerier_SetAnonymousUser_Call struct {
	*mock.Call
}

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

func (*MockQuerier_SetAnonymousUser_Call) Return 

func (_c *MockQuerier_SetAnonymousUser_Call) Return(_a0 NeosyncApiUser, _a1 error) *MockQuerier_SetAnonymousUser_Call

func (*MockQuerier_SetAnonymousUser_Call) Run 

func (_c *MockQuerier_SetAnonymousUser_Call) Run(run func(ctx context.Context, db DBTX)) *MockQuerier_SetAnonymousUser_Call

func (*MockQuerier_SetAnonymousUser_Call) RunAndReturn 

func (_c *MockQuerier_SetAnonymousUser_Call) RunAndReturn(run func(context.Context, DBTX) (NeosyncApiUser, error)) *MockQuerier_SetAnonymousUser_Call

type MockQuerier_SetJobSyncOptions_Call 

type MockQuerier_SetJobSyncOptions_Call struct {
	*mock.Call
}

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

func (*MockQuerier_SetJobSyncOptions_Call) Return 

func (_c *MockQuerier_SetJobSyncOptions_Call) Return(_a0 NeosyncApiJob, _a1 error) *MockQuerier_SetJobSyncOptions_Call

func (*MockQuerier_SetJobSyncOptions_Call) Run 

func (_c *MockQuerier_SetJobSyncOptions_Call) Run(run func(ctx context.Context, db DBTX, arg SetJobSyncOptionsParams)) *MockQuerier_SetJobSyncOptions_Call

func (*MockQuerier_SetJobSyncOptions_Call) RunAndReturn 

func (_c *MockQuerier_SetJobSyncOptions_Call) RunAndReturn(run func(context.Context, DBTX, SetJobSyncOptionsParams) (NeosyncApiJob, error)) *MockQuerier_SetJobSyncOptions_Call

type MockQuerier_SetJobWorkflowOptions_Call 

type MockQuerier_SetJobWorkflowOptions_Call struct {
	*mock.Call
}

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

func (*MockQuerier_SetJobWorkflowOptions_Call) Return 

func (_c *MockQuerier_SetJobWorkflowOptions_Call) Return(_a0 NeosyncApiJob, _a1 error) *MockQuerier_SetJobWorkflowOptions_Call

func (*MockQuerier_SetJobWorkflowOptions_Call) Run 

func (_c *MockQuerier_SetJobWorkflowOptions_Call) Run(run func(ctx context.Context, db DBTX, arg SetJobWorkflowOptionsParams)) *MockQuerier_SetJobWorkflowOptions_Call

func (*MockQuerier_SetJobWorkflowOptions_Call) RunAndReturn 

func (_c *MockQuerier_SetJobWorkflowOptions_Call) RunAndReturn(run func(context.Context, DBTX, SetJobWorkflowOptionsParams) (NeosyncApiJob, error)) *MockQuerier_SetJobWorkflowOptions_Call

type MockQuerier_SetRunContext_Call added in v0.4.54 

type MockQuerier_SetRunContext_Call struct {
	*mock.Call
}

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

func (*MockQuerier_SetRunContext_Call) Return added in v0.4.54 

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

func (*MockQuerier_SetRunContext_Call) Run added in v0.4.54 

func (_c *MockQuerier_SetRunContext_Call) Run(run func(ctx context.Context, db DBTX, arg SetRunContextParams)) *MockQuerier_SetRunContext_Call

func (*MockQuerier_SetRunContext_Call) RunAndReturn added in v0.4.54 

func (_c *MockQuerier_SetRunContext_Call) RunAndReturn(run func(context.Context, DBTX, SetRunContextParams) error) *MockQuerier_SetRunContext_Call

type MockQuerier_UpdateAccountApiKeyValue_Call 

type MockQuerier_UpdateAccountApiKeyValue_Call struct {
	*mock.Call
}

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

func (*MockQuerier_UpdateAccountApiKeyValue_Call) Return 

func (_c *MockQuerier_UpdateAccountApiKeyValue_Call) Return(_a0 NeosyncApiAccountApiKey, _a1 error) *MockQuerier_UpdateAccountApiKeyValue_Call

func (*MockQuerier_UpdateAccountApiKeyValue_Call) Run 

func (_c *MockQuerier_UpdateAccountApiKeyValue_Call) Run(run func(ctx context.Context, db DBTX, arg UpdateAccountApiKeyValueParams)) *MockQuerier_UpdateAccountApiKeyValue_Call

func (*MockQuerier_UpdateAccountApiKeyValue_Call) RunAndReturn 

func (_c *MockQuerier_UpdateAccountApiKeyValue_Call) RunAndReturn(run func(context.Context, DBTX, UpdateAccountApiKeyValueParams) (NeosyncApiAccountApiKey, error)) *MockQuerier_UpdateAccountApiKeyValue_Call

type MockQuerier_UpdateAccountInviteToAccepted_Call 

type MockQuerier_UpdateAccountInviteToAccepted_Call struct {
	*mock.Call
}

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

func (*MockQuerier_UpdateAccountInviteToAccepted_Call) Return 

func (_c *MockQuerier_UpdateAccountInviteToAccepted_Call) Return(_a0 NeosyncApiAccountInvite, _a1 error) *MockQuerier_UpdateAccountInviteToAccepted_Call

func (*MockQuerier_UpdateAccountInviteToAccepted_Call) Run 

func (_c *MockQuerier_UpdateAccountInviteToAccepted_Call) Run(run func(ctx context.Context, db DBTX, id pgtype.UUID)) *MockQuerier_UpdateAccountInviteToAccepted_Call

func (*MockQuerier_UpdateAccountInviteToAccepted_Call) RunAndReturn 

func (_c *MockQuerier_UpdateAccountInviteToAccepted_Call) RunAndReturn(run func(context.Context, DBTX, pgtype.UUID) (NeosyncApiAccountInvite, error)) *MockQuerier_UpdateAccountInviteToAccepted_Call

type MockQuerier_UpdateAccountOnboardingConfig_Call 

type MockQuerier_UpdateAccountOnboardingConfig_Call struct {
	*mock.Call
}

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

func (*MockQuerier_UpdateAccountOnboardingConfig_Call) Return 

func (_c *MockQuerier_UpdateAccountOnboardingConfig_Call) Return(_a0 NeosyncApiAccount, _a1 error) *MockQuerier_UpdateAccountOnboardingConfig_Call

func (*MockQuerier_UpdateAccountOnboardingConfig_Call) Run 

func (_c *MockQuerier_UpdateAccountOnboardingConfig_Call) Run(run func(ctx context.Context, db DBTX, arg UpdateAccountOnboardingConfigParams)) *MockQuerier_UpdateAccountOnboardingConfig_Call

func (*MockQuerier_UpdateAccountOnboardingConfig_Call) RunAndReturn 

func (_c *MockQuerier_UpdateAccountOnboardingConfig_Call) RunAndReturn(run func(context.Context, DBTX, UpdateAccountOnboardingConfigParams) (NeosyncApiAccount, error)) *MockQuerier_UpdateAccountOnboardingConfig_Call

type MockQuerier_UpdateActiveAccountInvitesToExpired_Call 

type MockQuerier_UpdateActiveAccountInvitesToExpired_Call struct {
	*mock.Call
}

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

func (*MockQuerier_UpdateActiveAccountInvitesToExpired_Call) Return 

func (_c *MockQuerier_UpdateActiveAccountInvitesToExpired_Call) Return(_a0 NeosyncApiAccountInvite, _a1 error) *MockQuerier_UpdateActiveAccountInvitesToExpired_Call

func (*MockQuerier_UpdateActiveAccountInvitesToExpired_Call) Run 

func (_c *MockQuerier_UpdateActiveAccountInvitesToExpired_Call) Run(run func(ctx context.Context, db DBTX, arg UpdateActiveAccountInvitesToExpiredParams)) *MockQuerier_UpdateActiveAccountInvitesToExpired_Call

func (*MockQuerier_UpdateActiveAccountInvitesToExpired_Call) RunAndReturn 

func (_c *MockQuerier_UpdateActiveAccountInvitesToExpired_Call) RunAndReturn(run func(context.Context, DBTX, UpdateActiveAccountInvitesToExpiredParams) (NeosyncApiAccountInvite, error)) *MockQuerier_UpdateActiveAccountInvitesToExpired_Call

type MockQuerier_UpdateConnection_Call 

type MockQuerier_UpdateConnection_Call struct {
	*mock.Call
}

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

func (*MockQuerier_UpdateConnection_Call) Return 

func (_c *MockQuerier_UpdateConnection_Call) Return(_a0 NeosyncApiConnection, _a1 error) *MockQuerier_UpdateConnection_Call

func (*MockQuerier_UpdateConnection_Call) Run 

func (_c *MockQuerier_UpdateConnection_Call) Run(run func(ctx context.Context, db DBTX, arg UpdateConnectionParams)) *MockQuerier_UpdateConnection_Call

func (*MockQuerier_UpdateConnection_Call) RunAndReturn 

func (_c *MockQuerier_UpdateConnection_Call) RunAndReturn(run func(context.Context, DBTX, UpdateConnectionParams) (NeosyncApiConnection, error)) *MockQuerier_UpdateConnection_Call

type MockQuerier_UpdateJobConnectionDestination_Call 

type MockQuerier_UpdateJobConnectionDestination_Call struct {
	*mock.Call
}

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

func (*MockQuerier_UpdateJobConnectionDestination_Call) Return 

func (_c *MockQuerier_UpdateJobConnectionDestination_Call) Return(_a0 NeosyncApiJobDestinationConnectionAssociation, _a1 error) *MockQuerier_UpdateJobConnectionDestination_Call

func (*MockQuerier_UpdateJobConnectionDestination_Call) Run 

func (_c *MockQuerier_UpdateJobConnectionDestination_Call) Run(run func(ctx context.Context, db DBTX, arg UpdateJobConnectionDestinationParams)) *MockQuerier_UpdateJobConnectionDestination_Call

func (*MockQuerier_UpdateJobConnectionDestination_Call) RunAndReturn 

func (_c *MockQuerier_UpdateJobConnectionDestination_Call) RunAndReturn(run func(context.Context, DBTX, UpdateJobConnectionDestinationParams) (NeosyncApiJobDestinationConnectionAssociation, error)) *MockQuerier_UpdateJobConnectionDestination_Call

type MockQuerier_UpdateJobMappings_Call 

type MockQuerier_UpdateJobMappings_Call struct {
	*mock.Call
}

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

func (*MockQuerier_UpdateJobMappings_Call) Return 

func (_c *MockQuerier_UpdateJobMappings_Call) Return(_a0 NeosyncApiJob, _a1 error) *MockQuerier_UpdateJobMappings_Call

func (*MockQuerier_UpdateJobMappings_Call) Run 

func (_c *MockQuerier_UpdateJobMappings_Call) Run(run func(ctx context.Context, db DBTX, arg UpdateJobMappingsParams)) *MockQuerier_UpdateJobMappings_Call

func (*MockQuerier_UpdateJobMappings_Call) RunAndReturn 

func (_c *MockQuerier_UpdateJobMappings_Call) RunAndReturn(run func(context.Context, DBTX, UpdateJobMappingsParams) (NeosyncApiJob, error)) *MockQuerier_UpdateJobMappings_Call

type MockQuerier_UpdateJobSchedule_Call 

type MockQuerier_UpdateJobSchedule_Call struct {
	*mock.Call
}

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

func (*MockQuerier_UpdateJobSchedule_Call) Return 

func (_c *MockQuerier_UpdateJobSchedule_Call) Return(_a0 NeosyncApiJob, _a1 error) *MockQuerier_UpdateJobSchedule_Call

func (*MockQuerier_UpdateJobSchedule_Call) Run 

func (_c *MockQuerier_UpdateJobSchedule_Call) Run(run func(ctx context.Context, db DBTX, arg UpdateJobScheduleParams)) *MockQuerier_UpdateJobSchedule_Call

func (*MockQuerier_UpdateJobSchedule_Call) RunAndReturn 

func (_c *MockQuerier_UpdateJobSchedule_Call) RunAndReturn(run func(context.Context, DBTX, UpdateJobScheduleParams) (NeosyncApiJob, error)) *MockQuerier_UpdateJobSchedule_Call

type MockQuerier_UpdateJobSource_Call 

type MockQuerier_UpdateJobSource_Call struct {
	*mock.Call
}

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

func (*MockQuerier_UpdateJobSource_Call) Return 

func (_c *MockQuerier_UpdateJobSource_Call) Return(_a0 NeosyncApiJob, _a1 error) *MockQuerier_UpdateJobSource_Call

func (*MockQuerier_UpdateJobSource_Call) Run 

func (_c *MockQuerier_UpdateJobSource_Call) Run(run func(ctx context.Context, db DBTX, arg UpdateJobSourceParams)) *MockQuerier_UpdateJobSource_Call

func (*MockQuerier_UpdateJobSource_Call) RunAndReturn 

func (_c *MockQuerier_UpdateJobSource_Call) RunAndReturn(run func(context.Context, DBTX, UpdateJobSourceParams) (NeosyncApiJob, error)) *MockQuerier_UpdateJobSource_Call

type MockQuerier_UpdateJobVirtualForeignKeys_Call added in v0.4.39 

type MockQuerier_UpdateJobVirtualForeignKeys_Call struct {
	*mock.Call
}

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

func (*MockQuerier_UpdateJobVirtualForeignKeys_Call) Return added in v0.4.39 

func (_c *MockQuerier_UpdateJobVirtualForeignKeys_Call) Return(_a0 NeosyncApiJob, _a1 error) *MockQuerier_UpdateJobVirtualForeignKeys_Call

func (*MockQuerier_UpdateJobVirtualForeignKeys_Call) Run added in v0.4.39 

func (_c *MockQuerier_UpdateJobVirtualForeignKeys_Call) Run(run func(ctx context.Context, db DBTX, arg UpdateJobVirtualForeignKeysParams)) *MockQuerier_UpdateJobVirtualForeignKeys_Call

func (*MockQuerier_UpdateJobVirtualForeignKeys_Call) RunAndReturn added in v0.4.39 

func (_c *MockQuerier_UpdateJobVirtualForeignKeys_Call) RunAndReturn(run func(context.Context, DBTX, UpdateJobVirtualForeignKeysParams) (NeosyncApiJob, error)) *MockQuerier_UpdateJobVirtualForeignKeys_Call

type MockQuerier_UpdateTemporalConfigByAccount_Call 

type MockQuerier_UpdateTemporalConfigByAccount_Call struct {
	*mock.Call
}

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

func (*MockQuerier_UpdateTemporalConfigByAccount_Call) Return 

func (_c *MockQuerier_UpdateTemporalConfigByAccount_Call) Return(_a0 NeosyncApiAccount, _a1 error) *MockQuerier_UpdateTemporalConfigByAccount_Call

func (*MockQuerier_UpdateTemporalConfigByAccount_Call) Run 

func (_c *MockQuerier_UpdateTemporalConfigByAccount_Call) Run(run func(ctx context.Context, db DBTX, arg UpdateTemporalConfigByAccountParams)) *MockQuerier_UpdateTemporalConfigByAccount_Call

func (*MockQuerier_UpdateTemporalConfigByAccount_Call) RunAndReturn 

func (_c *MockQuerier_UpdateTemporalConfigByAccount_Call) RunAndReturn(run func(context.Context, DBTX, UpdateTemporalConfigByAccountParams) (NeosyncApiAccount, error)) *MockQuerier_UpdateTemporalConfigByAccount_Call

type MockQuerier_UpdateUserDefinedTransformer_Call 

type MockQuerier_UpdateUserDefinedTransformer_Call struct {
	*mock.Call
}

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

func (*MockQuerier_UpdateUserDefinedTransformer_Call) Return 

func (_c *MockQuerier_UpdateUserDefinedTransformer_Call) Return(_a0 NeosyncApiTransformer, _a1 error) *MockQuerier_UpdateUserDefinedTransformer_Call

func (*MockQuerier_UpdateUserDefinedTransformer_Call) Run 

func (_c *MockQuerier_UpdateUserDefinedTransformer_Call) Run(run func(ctx context.Context, db DBTX, arg UpdateUserDefinedTransformerParams)) *MockQuerier_UpdateUserDefinedTransformer_Call

func (*MockQuerier_UpdateUserDefinedTransformer_Call) RunAndReturn 

func (_c *MockQuerier_UpdateUserDefinedTransformer_Call) RunAndReturn(run func(context.Context, DBTX, UpdateUserDefinedTransformerParams) (NeosyncApiTransformer, error)) *MockQuerier_UpdateUserDefinedTransformer_Call

type NeosyncApiAccount 

type NeosyncApiAccount struct {
	ID               pgtype.UUID
	CreatedAt        pgtype.Timestamp
	UpdatedAt        pgtype.Timestamp
	AccountType      int16
	AccountSlug      string
	TemporalConfig   *pg_models.TemporalConfig
	OnboardingConfig *pg_models.AccountOnboardingConfig
}

type NeosyncApiAccountApiKey 

type NeosyncApiAccountApiKey struct {
	ID          pgtype.UUID
	AccountID   pgtype.UUID
	KeyValue    string
	CreatedByID pgtype.UUID
	UpdatedByID pgtype.UUID
	CreatedAt   pgtype.Timestamp
	UpdatedAt   pgtype.Timestamp
	ExpiresAt   pgtype.Timestamp
	KeyName     string
	UserID      pgtype.UUID
}

type NeosyncApiAccountInvite 

type NeosyncApiAccountInvite struct {
	ID           pgtype.UUID
	AccountID    pgtype.UUID
	SenderUserID pgtype.UUID
	Email        string
	Token        string
	Accepted     pgtype.Bool
	CreatedAt    pgtype.Timestamp
	UpdatedAt    pgtype.Timestamp
	ExpiresAt    pgtype.Timestamp
}

type NeosyncApiAccountUserAssociation 

type NeosyncApiAccountUserAssociation struct {
	ID        pgtype.UUID
	AccountID pgtype.UUID
	UserID    pgtype.UUID
	CreatedAt pgtype.Timestamp
	UpdatedAt pgtype.Timestamp
}

type NeosyncApiConnection 

type NeosyncApiConnection struct {
	ID               pgtype.UUID
	CreatedAt        pgtype.Timestamp
	UpdatedAt        pgtype.Timestamp
	Name             string
	AccountID        pgtype.UUID
	ConnectionConfig *pg_models.ConnectionConfig
	CreatedByID      pgtype.UUID
	UpdatedByID      pgtype.UUID
}

type NeosyncApiJob 

type NeosyncApiJob struct {
	ID                 pgtype.UUID
	CreatedAt          pgtype.Timestamp
	UpdatedAt          pgtype.Timestamp
	Name               string
	AccountID          pgtype.UUID
	Status             int16
	ConnectionOptions  *pg_models.JobSourceOptions
	Mappings           []*pg_models.JobMapping
	CronSchedule       pgtype.Text
	CreatedByID        pgtype.UUID
	UpdatedByID        pgtype.UUID
	WorkflowOptions    *pg_models.WorkflowOptions
	SyncOptions        *pg_models.ActivityOptions
	VirtualForeignKeys []*pg_models.VirtualForeignConstraint
}

type NeosyncApiJobDestinationConnectionAssociation 

type NeosyncApiJobDestinationConnectionAssociation struct {
	ID           pgtype.UUID
	CreatedAt    pgtype.Timestamp
	UpdatedAt    pgtype.Timestamp
	JobID        pgtype.UUID
	ConnectionID pgtype.UUID
	Options      *pg_models.JobDestinationOptions
}

type NeosyncApiRuncontext added in v0.4.54 

type NeosyncApiRuncontext struct {
	WorkflowID  string
	ExternalID  string
	AccountID   pgtype.UUID
	Value       []byte
	CreatedAt   pgtype.Timestamp
	UpdatedAt   pgtype.Timestamp
	CreatedByID pgtype.UUID
	UpdatedByID pgtype.UUID
}

type NeosyncApiTransformer 

type NeosyncApiTransformer struct {
	ID                pgtype.UUID
	CreatedAt         pgtype.Timestamp
	UpdatedAt         pgtype.Timestamp
	Name              string
	Description       string
	AccountID         pgtype.UUID
	TransformerConfig *pg_models.TransformerConfigs
	CreatedByID       pgtype.UUID
	UpdatedByID       pgtype.UUID
	Source            int32
}

type NeosyncApiUser 

type NeosyncApiUser struct {
	ID        pgtype.UUID
	CreatedAt pgtype.Timestamp
	UpdatedAt pgtype.Timestamp
	UserType  int16
}

type NeosyncApiUserIdentityProviderAssociation 

type NeosyncApiUserIdentityProviderAssociation struct {
	ID          pgtype.UUID
	UserID      pgtype.UUID
	ProviderSub string
	CreatedAt   pgtype.Timestamp
	UpdatedAt   pgtype.Timestamp
}

type Querier 

type Querier interface {
	AreConnectionsInAccount(ctx context.Context, db DBTX, arg AreConnectionsInAccountParams) (int64, error)
	CreateAccountApiKey(ctx context.Context, db DBTX, arg CreateAccountApiKeyParams) (NeosyncApiAccountApiKey, error)
	CreateAccountInvite(ctx context.Context, db DBTX, arg CreateAccountInviteParams) (NeosyncApiAccountInvite, error)
	CreateAccountUserAssociation(ctx context.Context, db DBTX, arg CreateAccountUserAssociationParams) (NeosyncApiAccountUserAssociation, error)
	CreateConnection(ctx context.Context, db DBTX, arg CreateConnectionParams) (NeosyncApiConnection, error)
	CreateIdentityProviderAssociation(ctx context.Context, db DBTX, arg CreateIdentityProviderAssociationParams) (NeosyncApiUserIdentityProviderAssociation, error)
	CreateJob(ctx context.Context, db DBTX, arg CreateJobParams) (NeosyncApiJob, error)
	CreateJobConnectionDestination(ctx context.Context, db DBTX, arg CreateJobConnectionDestinationParams) (NeosyncApiJobDestinationConnectionAssociation, error)
	CreateJobConnectionDestinations(ctx context.Context, db DBTX, arg []CreateJobConnectionDestinationsParams) (int64, error)
	CreateMachineUser(ctx context.Context, db DBTX) (NeosyncApiUser, error)
	CreateNonMachineUser(ctx context.Context, db DBTX) (NeosyncApiUser, error)
	CreatePersonalAccount(ctx context.Context, db DBTX, accountSlug string) (NeosyncApiAccount, error)
	CreateTeamAccount(ctx context.Context, db DBTX, accountSlug string) (NeosyncApiAccount, error)
	CreateUserDefinedTransformer(ctx context.Context, db DBTX, arg CreateUserDefinedTransformerParams) (NeosyncApiTransformer, error)
	DeleteJob(ctx context.Context, db DBTX, id pgtype.UUID) error
	DeleteUserDefinedTransformerById(ctx context.Context, db DBTX, id pgtype.UUID) error
	GetAccount(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiAccount, error)
	GetAccountApiKeyById(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiAccountApiKey, error)
	GetAccountApiKeyByKeyValue(ctx context.Context, db DBTX, keyValue string) (NeosyncApiAccountApiKey, error)
	GetAccountApiKeys(ctx context.Context, db DBTX, accountid pgtype.UUID) ([]NeosyncApiAccountApiKey, error)
	GetAccountInvite(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiAccountInvite, error)
	GetAccountInviteByToken(ctx context.Context, db DBTX, token string) (NeosyncApiAccountInvite, error)
	GetAccountOnboardingConfig(ctx context.Context, db DBTX, id pgtype.UUID) (*pg_models.AccountOnboardingConfig, error)
	GetAccountUserAssociation(ctx context.Context, db DBTX, arg GetAccountUserAssociationParams) (NeosyncApiAccountUserAssociation, error)
	GetAccountsByUser(ctx context.Context, db DBTX, id pgtype.UUID) ([]NeosyncApiAccount, error)
	GetActiveAccountInvites(ctx context.Context, db DBTX, accountid pgtype.UUID) ([]NeosyncApiAccountInvite, error)
	GetAnonymousUser(ctx context.Context, db DBTX) (NeosyncApiUser, error)
	GetConnectionById(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiConnection, error)
	GetConnectionByNameAndAccount(ctx context.Context, db DBTX, arg GetConnectionByNameAndAccountParams) (NeosyncApiConnection, error)
	GetConnectionsByAccount(ctx context.Context, db DBTX, accountid pgtype.UUID) ([]NeosyncApiConnection, error)
	GetConnectionsByIds(ctx context.Context, db DBTX, dollar_1 []pgtype.UUID) ([]NeosyncApiConnection, error)
	GetJobById(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiJob, error)
	GetJobByNameAndAccount(ctx context.Context, db DBTX, arg GetJobByNameAndAccountParams) (NeosyncApiJob, error)
	GetJobConnectionDestination(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiJobDestinationConnectionAssociation, error)
	GetJobConnectionDestinations(ctx context.Context, db DBTX, id pgtype.UUID) ([]NeosyncApiJobDestinationConnectionAssociation, error)
	GetJobConnectionDestinationsByJobIds(ctx context.Context, db DBTX, jobids []pgtype.UUID) ([]NeosyncApiJobDestinationConnectionAssociation, error)
	GetJobsByAccount(ctx context.Context, db DBTX, accountid pgtype.UUID) ([]NeosyncApiJob, error)
	GetPersonalAccountByUserId(ctx context.Context, db DBTX, userid pgtype.UUID) (NeosyncApiAccount, error)
	GetRunContextByKey(ctx context.Context, db DBTX, arg GetRunContextByKeyParams) (NeosyncApiRuncontext, error)
	GetTeamAccountsByUserId(ctx context.Context, db DBTX, userid pgtype.UUID) ([]NeosyncApiAccount, error)
	GetTemporalConfigByAccount(ctx context.Context, db DBTX, id pgtype.UUID) (*pg_models.TemporalConfig, error)
	GetTemporalConfigByUserAccount(ctx context.Context, db DBTX, arg GetTemporalConfigByUserAccountParams) (*pg_models.TemporalConfig, error)
	GetUser(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiUser, error)
	GetUserAssociationByProviderSub(ctx context.Context, db DBTX, providerSub string) (NeosyncApiUserIdentityProviderAssociation, error)
	GetUserByProviderSub(ctx context.Context, db DBTX, providerSub string) (NeosyncApiUser, error)
	GetUserDefinedTransformerById(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiTransformer, error)
	GetUserDefinedTransformersByAccount(ctx context.Context, db DBTX, accountid pgtype.UUID) ([]NeosyncApiTransformer, error)
	GetUserIdentitiesByTeamAccount(ctx context.Context, db DBTX, accountid pgtype.UUID) ([]NeosyncApiUserIdentityProviderAssociation, error)
	GetUserIdentityAssociationsByUserIds(ctx context.Context, db DBTX, dollar_1 []pgtype.UUID) ([]NeosyncApiUserIdentityProviderAssociation, error)
	GetUserIdentityByUserId(ctx context.Context, db DBTX, userID pgtype.UUID) (NeosyncApiUserIdentityProviderAssociation, error)
	IsConnectionInAccount(ctx context.Context, db DBTX, arg IsConnectionInAccountParams) (int64, error)
	IsConnectionNameAvailable(ctx context.Context, db DBTX, arg IsConnectionNameAvailableParams) (int64, error)
	IsJobNameAvailable(ctx context.Context, db DBTX, arg IsJobNameAvailableParams) (int64, error)
	IsTransformerNameAvailable(ctx context.Context, db DBTX, arg IsTransformerNameAvailableParams) (int64, error)
	IsUserInAccount(ctx context.Context, db DBTX, arg IsUserInAccountParams) (int64, error)
	IsUserInAccountApiKey(ctx context.Context, db DBTX, arg IsUserInAccountApiKeyParams) (int64, error)
	RemoveAccountApiKey(ctx context.Context, db DBTX, id pgtype.UUID) error
	RemoveAccountInvite(ctx context.Context, db DBTX, id pgtype.UUID) error
	RemoveAccountUser(ctx context.Context, db DBTX, arg RemoveAccountUserParams) error
	RemoveConnectionById(ctx context.Context, db DBTX, id pgtype.UUID) error
	RemoveConnectionByNameAndAccount(ctx context.Context, db DBTX, arg RemoveConnectionByNameAndAccountParams) error
	RemoveJobById(ctx context.Context, db DBTX, id pgtype.UUID) error
	RemoveJobConnectionDestination(ctx context.Context, db DBTX, id pgtype.UUID) error
	RemoveJobConnectionDestinations(ctx context.Context, db DBTX, jobids []pgtype.UUID) error
	SetAnonymousUser(ctx context.Context, db DBTX) (NeosyncApiUser, error)
	SetJobSyncOptions(ctx context.Context, db DBTX, arg SetJobSyncOptionsParams) (NeosyncApiJob, error)
	SetJobWorkflowOptions(ctx context.Context, db DBTX, arg SetJobWorkflowOptionsParams) (NeosyncApiJob, error)
	SetRunContext(ctx context.Context, db DBTX, arg SetRunContextParams) error
	UpdateAccountApiKeyValue(ctx context.Context, db DBTX, arg UpdateAccountApiKeyValueParams) (NeosyncApiAccountApiKey, error)
	UpdateAccountInviteToAccepted(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiAccountInvite, error)
	UpdateAccountOnboardingConfig(ctx context.Context, db DBTX, arg UpdateAccountOnboardingConfigParams) (NeosyncApiAccount, error)
	UpdateActiveAccountInvitesToExpired(ctx context.Context, db DBTX, arg UpdateActiveAccountInvitesToExpiredParams) (NeosyncApiAccountInvite, error)
	UpdateConnection(ctx context.Context, db DBTX, arg UpdateConnectionParams) (NeosyncApiConnection, error)
	UpdateJobConnectionDestination(ctx context.Context, db DBTX, arg UpdateJobConnectionDestinationParams) (NeosyncApiJobDestinationConnectionAssociation, error)
	UpdateJobMappings(ctx context.Context, db DBTX, arg UpdateJobMappingsParams) (NeosyncApiJob, error)
	UpdateJobSchedule(ctx context.Context, db DBTX, arg UpdateJobScheduleParams) (NeosyncApiJob, error)
	UpdateJobSource(ctx context.Context, db DBTX, arg UpdateJobSourceParams) (NeosyncApiJob, error)
	UpdateJobVirtualForeignKeys(ctx context.Context, db DBTX, arg UpdateJobVirtualForeignKeysParams) (NeosyncApiJob, error)
	UpdateTemporalConfigByAccount(ctx context.Context, db DBTX, arg UpdateTemporalConfigByAccountParams) (NeosyncApiAccount, error)
	UpdateUserDefinedTransformer(ctx context.Context, db DBTX, arg UpdateUserDefinedTransformerParams) (NeosyncApiTransformer, error)
}

type Queries 

type Queries struct {
}

func New 

func New() *Queries

func (*Queries) AreConnectionsInAccount 

func (q *Queries) AreConnectionsInAccount(ctx context.Context, db DBTX, arg AreConnectionsInAccountParams) (int64, error)

func (*Queries) CreateAccountApiKey 

func (q *Queries) CreateAccountApiKey(ctx context.Context, db DBTX, arg CreateAccountApiKeyParams) (NeosyncApiAccountApiKey, error)

func (*Queries) CreateAccountInvite 

func (q *Queries) CreateAccountInvite(ctx context.Context, db DBTX, arg CreateAccountInviteParams) (NeosyncApiAccountInvite, error)

func (*Queries) CreateAccountUserAssociation 

func (q *Queries) CreateAccountUserAssociation(ctx context.Context, db DBTX, arg CreateAccountUserAssociationParams) (NeosyncApiAccountUserAssociation, error)

func (*Queries) CreateConnection 

func (q *Queries) CreateConnection(ctx context.Context, db DBTX, arg CreateConnectionParams) (NeosyncApiConnection, error)

func (*Queries) CreateIdentityProviderAssociation 

func (q *Queries) CreateIdentityProviderAssociation(ctx context.Context, db DBTX, arg CreateIdentityProviderAssociationParams) (NeosyncApiUserIdentityProviderAssociation, error)

func (*Queries) CreateJob 

func (q *Queries) CreateJob(ctx context.Context, db DBTX, arg CreateJobParams) (NeosyncApiJob, error)

func (*Queries) CreateJobConnectionDestination 

func (q *Queries) CreateJobConnectionDestination(ctx context.Context, db DBTX, arg CreateJobConnectionDestinationParams) (NeosyncApiJobDestinationConnectionAssociation, error)

func (*Queries) CreateJobConnectionDestinations 

func (q *Queries) CreateJobConnectionDestinations(ctx context.Context, db DBTX, arg []CreateJobConnectionDestinationsParams) (int64, error)

func (*Queries) CreateMachineUser 

func (q *Queries) CreateMachineUser(ctx context.Context, db DBTX) (NeosyncApiUser, error)

func (*Queries) CreateNonMachineUser 

func (q *Queries) CreateNonMachineUser(ctx context.Context, db DBTX) (NeosyncApiUser, error)

func (*Queries) CreatePersonalAccount 

func (q *Queries) CreatePersonalAccount(ctx context.Context, db DBTX, accountSlug string) (NeosyncApiAccount, error)

func (*Queries) CreateTeamAccount 

func (q *Queries) CreateTeamAccount(ctx context.Context, db DBTX, accountSlug string) (NeosyncApiAccount, error)

func (*Queries) CreateUserDefinedTransformer 

func (q *Queries) CreateUserDefinedTransformer(ctx context.Context, db DBTX, arg CreateUserDefinedTransformerParams) (NeosyncApiTransformer, error)

func (*Queries) DeleteJob 

func (q *Queries) DeleteJob(ctx context.Context, db DBTX, id pgtype.UUID) error

func (*Queries) DeleteUserDefinedTransformerById 

func (q *Queries) DeleteUserDefinedTransformerById(ctx context.Context, db DBTX, id pgtype.UUID) error

func (*Queries) GetAccount 

func (q *Queries) GetAccount(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiAccount, error)

func (*Queries) GetAccountApiKeyById 

func (q *Queries) GetAccountApiKeyById(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiAccountApiKey, error)

func (*Queries) GetAccountApiKeyByKeyValue 

func (q *Queries) GetAccountApiKeyByKeyValue(ctx context.Context, db DBTX, keyValue string) (NeosyncApiAccountApiKey, error)

func (*Queries) GetAccountApiKeys 

func (q *Queries) GetAccountApiKeys(ctx context.Context, db DBTX, accountid pgtype.UUID) ([]NeosyncApiAccountApiKey, error)

func (*Queries) GetAccountInvite 

func (q *Queries) GetAccountInvite(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiAccountInvite, error)

func (*Queries) GetAccountInviteByToken 

func (q *Queries) GetAccountInviteByToken(ctx context.Context, db DBTX, token string) (NeosyncApiAccountInvite, error)

func (*Queries) GetAccountOnboardingConfig 

func (q *Queries) GetAccountOnboardingConfig(ctx context.Context, db DBTX, id pgtype.UUID) (*pg_models.AccountOnboardingConfig, error)

func (*Queries) GetAccountUserAssociation 

func (q *Queries) GetAccountUserAssociation(ctx context.Context, db DBTX, arg GetAccountUserAssociationParams) (NeosyncApiAccountUserAssociation, error)

func (*Queries) GetAccountsByUser 

func (q *Queries) GetAccountsByUser(ctx context.Context, db DBTX, id pgtype.UUID) ([]NeosyncApiAccount, error)

func (*Queries) GetActiveAccountInvites 

func (q *Queries) GetActiveAccountInvites(ctx context.Context, db DBTX, accountid pgtype.UUID) ([]NeosyncApiAccountInvite, error)

func (*Queries) GetAnonymousUser 

func (q *Queries) GetAnonymousUser(ctx context.Context, db DBTX) (NeosyncApiUser, error)

func (*Queries) GetConnectionById 

func (q *Queries) GetConnectionById(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiConnection, error)

func (*Queries) GetConnectionByNameAndAccount 

func (q *Queries) GetConnectionByNameAndAccount(ctx context.Context, db DBTX, arg GetConnectionByNameAndAccountParams) (NeosyncApiConnection, error)

func (*Queries) GetConnectionsByAccount 

func (q *Queries) GetConnectionsByAccount(ctx context.Context, db DBTX, accountid pgtype.UUID) ([]NeosyncApiConnection, error)

func (*Queries) GetConnectionsByIds 

func (q *Queries) GetConnectionsByIds(ctx context.Context, db DBTX, dollar_1 []pgtype.UUID) ([]NeosyncApiConnection, error)

func (*Queries) GetJobById 

func (q *Queries) GetJobById(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiJob, error)

func (*Queries) GetJobByNameAndAccount 

func (q *Queries) GetJobByNameAndAccount(ctx context.Context, db DBTX, arg GetJobByNameAndAccountParams) (NeosyncApiJob, error)

func (*Queries) GetJobConnectionDestination 

func (q *Queries) GetJobConnectionDestination(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiJobDestinationConnectionAssociation, error)

func (*Queries) GetJobConnectionDestinations 

func (q *Queries) GetJobConnectionDestinations(ctx context.Context, db DBTX, id pgtype.UUID) ([]NeosyncApiJobDestinationConnectionAssociation, error)

func (*Queries) GetJobConnectionDestinationsByJobIds 

func (q *Queries) GetJobConnectionDestinationsByJobIds(ctx context.Context, db DBTX, jobids []pgtype.UUID) ([]NeosyncApiJobDestinationConnectionAssociation, error)

func (*Queries) GetJobsByAccount 

func (q *Queries) GetJobsByAccount(ctx context.Context, db DBTX, accountid pgtype.UUID) ([]NeosyncApiJob, error)

func (*Queries) GetPersonalAccountByUserId 

func (q *Queries) GetPersonalAccountByUserId(ctx context.Context, db DBTX, userid pgtype.UUID) (NeosyncApiAccount, error)

func (*Queries) GetRunContextByKey added in v0.4.54 

func (q *Queries) GetRunContextByKey(ctx context.Context, db DBTX, arg GetRunContextByKeyParams) (NeosyncApiRuncontext, error)

func (*Queries) GetTeamAccountsByUserId 

func (q *Queries) GetTeamAccountsByUserId(ctx context.Context, db DBTX, userid pgtype.UUID) ([]NeosyncApiAccount, error)

func (*Queries) GetTemporalConfigByAccount 

func (q *Queries) GetTemporalConfigByAccount(ctx context.Context, db DBTX, id pgtype.UUID) (*pg_models.TemporalConfig, error)

func (*Queries) GetTemporalConfigByUserAccount 

func (q *Queries) GetTemporalConfigByUserAccount(ctx context.Context, db DBTX, arg GetTemporalConfigByUserAccountParams) (*pg_models.TemporalConfig, error)

func (*Queries) GetUser 

func (q *Queries) GetUser(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiUser, error)

func (*Queries) GetUserAssociationByProviderSub 

func (q *Queries) GetUserAssociationByProviderSub(ctx context.Context, db DBTX, providerSub string) (NeosyncApiUserIdentityProviderAssociation, error)

func (*Queries) GetUserByProviderSub 

func (q *Queries) GetUserByProviderSub(ctx context.Context, db DBTX, providerSub string) (NeosyncApiUser, error)

func (*Queries) GetUserDefinedTransformerById 

func (q *Queries) GetUserDefinedTransformerById(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiTransformer, error)

func (*Queries) GetUserDefinedTransformersByAccount 

func (q *Queries) GetUserDefinedTransformersByAccount(ctx context.Context, db DBTX, accountid pgtype.UUID) ([]NeosyncApiTransformer, error)

func (*Queries) GetUserIdentitiesByTeamAccount 

func (q *Queries) GetUserIdentitiesByTeamAccount(ctx context.Context, db DBTX, accountid pgtype.UUID) ([]NeosyncApiUserIdentityProviderAssociation, error)

func (*Queries) GetUserIdentityAssociationsByUserIds 

func (q *Queries) GetUserIdentityAssociationsByUserIds(ctx context.Context, db DBTX, dollar_1 []pgtype.UUID) ([]NeosyncApiUserIdentityProviderAssociation, error)

func (*Queries) GetUserIdentityByUserId 

func (q *Queries) GetUserIdentityByUserId(ctx context.Context, db DBTX, userID pgtype.UUID) (NeosyncApiUserIdentityProviderAssociation, error)

func (*Queries) IsConnectionInAccount 

func (q *Queries) IsConnectionInAccount(ctx context.Context, db DBTX, arg IsConnectionInAccountParams) (int64, error)

func (*Queries) IsConnectionNameAvailable 

func (q *Queries) IsConnectionNameAvailable(ctx context.Context, db DBTX, arg IsConnectionNameAvailableParams) (int64, error)

func (*Queries) IsJobNameAvailable 

func (q *Queries) IsJobNameAvailable(ctx context.Context, db DBTX, arg IsJobNameAvailableParams) (int64, error)

func (*Queries) IsTransformerNameAvailable 

func (q *Queries) IsTransformerNameAvailable(ctx context.Context, db DBTX, arg IsTransformerNameAvailableParams) (int64, error)

func (*Queries) IsUserInAccount 

func (q *Queries) IsUserInAccount(ctx context.Context, db DBTX, arg IsUserInAccountParams) (int64, error)

func (*Queries) IsUserInAccountApiKey 

func (q *Queries) IsUserInAccountApiKey(ctx context.Context, db DBTX, arg IsUserInAccountApiKeyParams) (int64, error)

func (*Queries) RemoveAccountApiKey 

func (q *Queries) RemoveAccountApiKey(ctx context.Context, db DBTX, id pgtype.UUID) error

func (*Queries) RemoveAccountInvite 

func (q *Queries) RemoveAccountInvite(ctx context.Context, db DBTX, id pgtype.UUID) error

func (*Queries) RemoveAccountUser 

func (q *Queries) RemoveAccountUser(ctx context.Context, db DBTX, arg RemoveAccountUserParams) error

func (*Queries) RemoveConnectionById 

func (q *Queries) RemoveConnectionById(ctx context.Context, db DBTX, id pgtype.UUID) error

func (*Queries) RemoveConnectionByNameAndAccount 

func (q *Queries) RemoveConnectionByNameAndAccount(ctx context.Context, db DBTX, arg RemoveConnectionByNameAndAccountParams) error

func (*Queries) RemoveJobById 

func (q *Queries) RemoveJobById(ctx context.Context, db DBTX, id pgtype.UUID) error

func (*Queries) RemoveJobConnectionDestination 

func (q *Queries) RemoveJobConnectionDestination(ctx context.Context, db DBTX, id pgtype.UUID) error

func (*Queries) RemoveJobConnectionDestinations 

func (q *Queries) RemoveJobConnectionDestinations(ctx context.Context, db DBTX, jobids []pgtype.UUID) error

func (*Queries) SetAnonymousUser 

func (q *Queries) SetAnonymousUser(ctx context.Context, db DBTX) (NeosyncApiUser, error)

func (*Queries) SetJobSyncOptions 

func (q *Queries) SetJobSyncOptions(ctx context.Context, db DBTX, arg SetJobSyncOptionsParams) (NeosyncApiJob, error)

func (*Queries) SetJobWorkflowOptions 

func (q *Queries) SetJobWorkflowOptions(ctx context.Context, db DBTX, arg SetJobWorkflowOptionsParams) (NeosyncApiJob, error)

func (*Queries) SetRunContext added in v0.4.54 

func (q *Queries) SetRunContext(ctx context.Context, db DBTX, arg SetRunContextParams) error

func (*Queries) UpdateAccountApiKeyValue 

func (q *Queries) UpdateAccountApiKeyValue(ctx context.Context, db DBTX, arg UpdateAccountApiKeyValueParams) (NeosyncApiAccountApiKey, error)

func (*Queries) UpdateAccountInviteToAccepted 

func (q *Queries) UpdateAccountInviteToAccepted(ctx context.Context, db DBTX, id pgtype.UUID) (NeosyncApiAccountInvite, error)

func (*Queries) UpdateAccountOnboardingConfig 

func (q *Queries) UpdateAccountOnboardingConfig(ctx context.Context, db DBTX, arg UpdateAccountOnboardingConfigParams) (NeosyncApiAccount, error)

func (*Queries) UpdateActiveAccountInvitesToExpired 

func (q *Queries) UpdateActiveAccountInvitesToExpired(ctx context.Context, db DBTX, arg UpdateActiveAccountInvitesToExpiredParams) (NeosyncApiAccountInvite, error)

func (*Queries) UpdateConnection 

func (q *Queries) UpdateConnection(ctx context.Context, db DBTX, arg UpdateConnectionParams) (NeosyncApiConnection, error)

func (*Queries) UpdateJobConnectionDestination 

func (q *Queries) UpdateJobConnectionDestination(ctx context.Context, db DBTX, arg UpdateJobConnectionDestinationParams) (NeosyncApiJobDestinationConnectionAssociation, error)

func (*Queries) UpdateJobMappings 

func (q *Queries) UpdateJobMappings(ctx context.Context, db DBTX, arg UpdateJobMappingsParams) (NeosyncApiJob, error)

func (*Queries) UpdateJobSchedule 

func (q *Queries) UpdateJobSchedule(ctx context.Context, db DBTX, arg UpdateJobScheduleParams) (NeosyncApiJob, error)

func (*Queries) UpdateJobSource 

func (q *Queries) UpdateJobSource(ctx context.Context, db DBTX, arg UpdateJobSourceParams) (NeosyncApiJob, error)

func (*Queries) UpdateJobVirtualForeignKeys added in v0.4.39 

func (q *Queries) UpdateJobVirtualForeignKeys(ctx context.Context, db DBTX, arg UpdateJobVirtualForeignKeysParams) (NeosyncApiJob, error)

func (*Queries) UpdateTemporalConfigByAccount 

func (q *Queries) UpdateTemporalConfigByAccount(ctx context.Context, db DBTX, arg UpdateTemporalConfigByAccountParams) (NeosyncApiAccount, error)

func (*Queries) UpdateUserDefinedTransformer 

func (q *Queries) UpdateUserDefinedTransformer(ctx context.Context, db DBTX, arg UpdateUserDefinedTransformerParams) (NeosyncApiTransformer, error)

type RemoveAccountUserParams 

type RemoveAccountUserParams struct {
	AccountId pgtype.UUID
	UserId    pgtype.UUID
}

type RemoveConnectionByNameAndAccountParams 

type RemoveConnectionByNameAndAccountParams struct {
	Name      string
	AccountID pgtype.UUID
}

type SetJobSyncOptionsParams 

type SetJobSyncOptionsParams struct {
	SyncOptions *pg_models.ActivityOptions
	UpdatedByID pgtype.UUID
	ID          pgtype.UUID
}

type SetJobWorkflowOptionsParams 

type SetJobWorkflowOptionsParams struct {
	WorkflowOptions *pg_models.WorkflowOptions
	UpdatedByID     pgtype.UUID
	ID              pgtype.UUID
}

type SetRunContextParams added in v0.4.54 

type SetRunContextParams struct {
	WorkflowID  string
	ExternalID  string
	Value       []byte
	CreatedByID pgtype.UUID
	UpdatedByID pgtype.UUID
	AccountID   pgtype.UUID
}

type UpdateAccountApiKeyValueParams 

type UpdateAccountApiKeyValueParams struct {
	KeyValue    string
	ExpiresAt   pgtype.Timestamp
	UpdatedByID pgtype.UUID
	ID          pgtype.UUID
}

type UpdateAccountOnboardingConfigParams 

type UpdateAccountOnboardingConfigParams struct {
	OnboardingConfig *pg_models.AccountOnboardingConfig
	AccountId        pgtype.UUID
}

type UpdateActiveAccountInvitesToExpiredParams 

type UpdateActiveAccountInvitesToExpiredParams struct {
	AccountId pgtype.UUID
	Email     string
}

type UpdateConnectionParams 

type UpdateConnectionParams struct {
	Name             string
	ConnectionConfig *pg_models.ConnectionConfig
	UpdatedByID      pgtype.UUID
	ID               pgtype.UUID
}

type UpdateJobConnectionDestinationParams 

type UpdateJobConnectionDestinationParams struct {
	Options      *pg_models.JobDestinationOptions
	ConnectionID pgtype.UUID
	ID           pgtype.UUID
}

type UpdateJobMappingsParams 

type UpdateJobMappingsParams struct {
	Mappings    []*pg_models.JobMapping
	UpdatedByID pgtype.UUID
	ID          pgtype.UUID
}

type UpdateJobScheduleParams 

type UpdateJobScheduleParams struct {
	CronSchedule pgtype.Text
	UpdatedByID  pgtype.UUID
	ID           pgtype.UUID
}

type UpdateJobSourceParams 

type UpdateJobSourceParams struct {
	ConnectionOptions *pg_models.JobSourceOptions
	UpdatedByID       pgtype.UUID
	ID                pgtype.UUID
}

type UpdateJobVirtualForeignKeysParams added in v0.4.39 

type UpdateJobVirtualForeignKeysParams struct {
	VirtualForeignKeys []*pg_models.VirtualForeignConstraint
	UpdatedByID        pgtype.UUID
	ID                 pgtype.UUID
}

type UpdateTemporalConfigByAccountParams 

type UpdateTemporalConfigByAccountParams struct {
	TemporalConfig *pg_models.TemporalConfig
	AccountId      pgtype.UUID
}

type UpdateUserDefinedTransformerParams 

type UpdateUserDefinedTransformerParams struct {
	Name              string
	Description       string
	TransformerConfig *pg_models.TransformerConfigs
	UpdatedByID       pgtype.UUID
	ID                pgtype.UUID
}

Source Files

View all Source files

Directories

Path Synopsis
dbschemas
mysql
postgresql

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.