sync_activity

package
v0.4.24 Latest Latest
Warning

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

 Go to latest Published: May 31, 2024 License: MIT Imports: 35 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Activity 

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

func New 

func New(
	connclient mgmtv1alpha1connect.ConnectionServiceClient,
	tunnelmanagermap *sync.Map,
	temporalclient client.Client,
	meter metric.Meter,
	benthosStreamManager BenthosStreamManagerClient,
) *Activity

func (*Activity) Sync 

func (a *Activity) Sync(ctx context.Context, req *SyncRequest, metadata *SyncMetadata) (*SyncResponse, error)

Temporal activity that runs benthos and syncs a source connection to one or more destination connections

type BenthosStreamAdapter 

type BenthosStreamAdapter struct {
	Stream *service.Stream
}

func NewBenthosStreamAdapter 

func NewBenthosStreamAdapter(stream *service.Stream) *BenthosStreamAdapter

func (*BenthosStreamAdapter) Run 

func (b *BenthosStreamAdapter) Run(ctx context.Context) error

func (*BenthosStreamAdapter) Stop 

func (b *BenthosStreamAdapter) Stop(ctx context.Context) error

func (*BenthosStreamAdapter) StopWithin 

func (b *BenthosStreamAdapter) StopWithin(d time.Duration) error

type BenthosStreamClient 

type BenthosStreamClient interface {
	Run(ctx context.Context) error
	Stop(ctx context.Context) error
	StopWithin(d time.Duration) error
}

type BenthosStreamManager 

type BenthosStreamManager struct{}

func NewBenthosStreamManager 

func NewBenthosStreamManager() *BenthosStreamManager

func (*BenthosStreamManager) NewBenthosStreamFromBuilder 

func (b *BenthosStreamManager) NewBenthosStreamFromBuilder(streambldr *service.StreamBuilder) (BenthosStreamClient, error)

type BenthosStreamManagerClient 

type BenthosStreamManagerClient interface {
	NewBenthosStreamFromBuilder(streambldr *service.StreamBuilder) (BenthosStreamClient, error)
}

type ConnectionTunnelManager 

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

This could be more efficient as connections are disparate, but the mutexes will block all other connections while a single connection comes online however the saving grace here is in prod this is scoped to a single Run, which is typically limited to its number of connections anyways

func NewConnectionTunnelManager 

func NewConnectionTunnelManager(sqlprovider sqlProvider) *ConnectionTunnelManager

func (*ConnectionTunnelManager) GetConnection 

func (c *ConnectionTunnelManager) GetConnection(
	session string,
	connection *mgmtv1alpha1.Connection,
	logger *slog.Logger,
) (neosync_benthos_sql.SqlDbtx, error)

func (*ConnectionTunnelManager) GetConnectionString 

func (c *ConnectionTunnelManager) GetConnectionString(
	session string,
	connection *mgmtv1alpha1.Connection,
	logger *slog.Logger,
) (string, error)

Purpose of this function is to return a connection string that can be used by a database client to connect to a tunneled instance of a database using a localhost port. Primarily used by Benthos since we don't have the ability to directly use a pg client

func (*ConnectionTunnelManager) Reaper 

func (c *ConnectionTunnelManager) Reaper()

func (*ConnectionTunnelManager) ReleaseSession 

func (c *ConnectionTunnelManager) ReleaseSession(session string) bool

returns true if it found a session to delete

func (*ConnectionTunnelManager) Shutdown 

func (c *ConnectionTunnelManager) Shutdown()

type MockBenthosStreamClient 

type MockBenthosStreamClient struct {
	mock.Mock
}

MockBenthosStreamClient is an autogenerated mock type for the BenthosStreamClient type

func NewMockBenthosStreamClient 

func NewMockBenthosStreamClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockBenthosStreamClient

NewMockBenthosStreamClient creates a new instance of MockBenthosStreamClient. 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 (*MockBenthosStreamClient) EXPECT 

func (_m *MockBenthosStreamClient) EXPECT() *MockBenthosStreamClient_Expecter

func (*MockBenthosStreamClient) Run 

func (_m *MockBenthosStreamClient) Run(ctx context.Context) error

Run provides a mock function with given fields: ctx

func (*MockBenthosStreamClient) Stop 

func (_m *MockBenthosStreamClient) Stop(ctx context.Context) error

Stop provides a mock function with given fields: ctx

func (*MockBenthosStreamClient) StopWithin 

func (_m *MockBenthosStreamClient) StopWithin(d time.Duration) error

StopWithin provides a mock function with given fields: d

type MockBenthosStreamClient_Expecter 

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

func (*MockBenthosStreamClient_Expecter) Run 

func (_e *MockBenthosStreamClient_Expecter) Run(ctx interface{}) *MockBenthosStreamClient_Run_Call

Run is a helper method to define mock.On call

  • ctx context.Context

func (*MockBenthosStreamClient_Expecter) Stop 

func (_e *MockBenthosStreamClient_Expecter) Stop(ctx interface{}) *MockBenthosStreamClient_Stop_Call

Stop is a helper method to define mock.On call

  • ctx context.Context

func (*MockBenthosStreamClient_Expecter) StopWithin 

func (_e *MockBenthosStreamClient_Expecter) StopWithin(d interface{}) *MockBenthosStreamClient_StopWithin_Call

StopWithin is a helper method to define mock.On call

  • d time.Duration

type MockBenthosStreamClient_Run_Call 

type MockBenthosStreamClient_Run_Call struct {
	*mock.Call
}

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

func (*MockBenthosStreamClient_Run_Call) Return 

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

func (*MockBenthosStreamClient_Run_Call) Run 

func (_c *MockBenthosStreamClient_Run_Call) Run(run func(ctx context.Context)) *MockBenthosStreamClient_Run_Call

func (*MockBenthosStreamClient_Run_Call) RunAndReturn 

func (_c *MockBenthosStreamClient_Run_Call) RunAndReturn(run func(context.Context) error) *MockBenthosStreamClient_Run_Call

type MockBenthosStreamClient_StopWithin_Call 

type MockBenthosStreamClient_StopWithin_Call struct {
	*mock.Call
}

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

func (*MockBenthosStreamClient_StopWithin_Call) Return 

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

func (*MockBenthosStreamClient_StopWithin_Call) Run 

func (_c *MockBenthosStreamClient_StopWithin_Call) Run(run func(d time.Duration)) *MockBenthosStreamClient_StopWithin_Call

func (*MockBenthosStreamClient_StopWithin_Call) RunAndReturn 

func (_c *MockBenthosStreamClient_StopWithin_Call) RunAndReturn(run func(time.Duration) error) *MockBenthosStreamClient_StopWithin_Call

type MockBenthosStreamClient_Stop_Call 

type MockBenthosStreamClient_Stop_Call struct {
	*mock.Call
}

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

func (*MockBenthosStreamClient_Stop_Call) Return 

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

func (*MockBenthosStreamClient_Stop_Call) Run 

func (_c *MockBenthosStreamClient_Stop_Call) Run(run func(ctx context.Context)) *MockBenthosStreamClient_Stop_Call

func (*MockBenthosStreamClient_Stop_Call) RunAndReturn 

func (_c *MockBenthosStreamClient_Stop_Call) RunAndReturn(run func(context.Context) error) *MockBenthosStreamClient_Stop_Call

type MockBenthosStreamManagerClient 

type MockBenthosStreamManagerClient struct {
	mock.Mock
}

MockBenthosStreamManagerClient is an autogenerated mock type for the BenthosStreamManagerClient type

func NewMockBenthosStreamManagerClient 

func NewMockBenthosStreamManagerClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockBenthosStreamManagerClient

NewMockBenthosStreamManagerClient creates a new instance of MockBenthosStreamManagerClient. 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 (*MockBenthosStreamManagerClient) EXPECT 

func (_m *MockBenthosStreamManagerClient) EXPECT() *MockBenthosStreamManagerClient_Expecter

func (*MockBenthosStreamManagerClient) NewBenthosStreamFromBuilder 

func (_m *MockBenthosStreamManagerClient) NewBenthosStreamFromBuilder(streambldr *service.StreamBuilder) (BenthosStreamClient, error)

NewBenthosStreamFromBuilder provides a mock function with given fields: streambldr

type MockBenthosStreamManagerClient_Expecter 

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

func (*MockBenthosStreamManagerClient_Expecter) NewBenthosStreamFromBuilder 

func (_e *MockBenthosStreamManagerClient_Expecter) NewBenthosStreamFromBuilder(streambldr interface{}) *MockBenthosStreamManagerClient_NewBenthosStreamFromBuilder_Call

NewBenthosStreamFromBuilder is a helper method to define mock.On call

  • streambldr *service.StreamBuilder

type MockBenthosStreamManagerClient_NewBenthosStreamFromBuilder_Call 

type MockBenthosStreamManagerClient_NewBenthosStreamFromBuilder_Call struct {
	*mock.Call
}

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

func (*MockBenthosStreamManagerClient_NewBenthosStreamFromBuilder_Call) Return 

func (_c *MockBenthosStreamManagerClient_NewBenthosStreamFromBuilder_Call) Return(_a0 BenthosStreamClient, _a1 error) *MockBenthosStreamManagerClient_NewBenthosStreamFromBuilder_Call

func (*MockBenthosStreamManagerClient_NewBenthosStreamFromBuilder_Call) Run 

func (_c *MockBenthosStreamManagerClient_NewBenthosStreamFromBuilder_Call) Run(run func(streambldr *service.StreamBuilder)) *MockBenthosStreamManagerClient_NewBenthosStreamFromBuilder_Call

func (*MockBenthosStreamManagerClient_NewBenthosStreamFromBuilder_Call) RunAndReturn 

func (_c *MockBenthosStreamManagerClient_NewBenthosStreamFromBuilder_Call) RunAndReturn(run func(*service.StreamBuilder) (BenthosStreamClient, error)) *MockBenthosStreamManagerClient_NewBenthosStreamFromBuilder_Call

type MocksqlProvider 

type MocksqlProvider struct {
	mock.Mock
}

MocksqlProvider is an autogenerated mock type for the sqlProvider type

func NewMocksqlProvider 

func NewMocksqlProvider(t interface {
	mock.TestingT
	Cleanup(func())
}) *MocksqlProvider

NewMocksqlProvider creates a new instance of MocksqlProvider. 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 (*MocksqlProvider) DbOpen 

func (_m *MocksqlProvider) DbOpen(driver string, dsn string, maxConnectionLimits *int32) (neosync_benthos_sql.SqlDbtx, error)

DbOpen provides a mock function with given fields: driver, dsn, maxConnectionLimits

func (*MocksqlProvider) EXPECT 

func (_m *MocksqlProvider) EXPECT() *MocksqlProvider_Expecter

func (*MocksqlProvider) GetConnectionDetails 

func (_m *MocksqlProvider) GetConnectionDetails(cc *mgmtv1alpha1.ConnectionConfig, connTimeout *uint32, logger *slog.Logger) (*sqlconnect.ConnectionDetails, error)

GetConnectionDetails provides a mock function with given fields: cc, connTimeout, logger

type MocksqlProvider_DbOpen_Call 

type MocksqlProvider_DbOpen_Call struct {
	*mock.Call
}

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

func (*MocksqlProvider_DbOpen_Call) Return 

func (_c *MocksqlProvider_DbOpen_Call) Return(_a0 neosync_benthos_sql.SqlDbtx, _a1 error) *MocksqlProvider_DbOpen_Call

func (*MocksqlProvider_DbOpen_Call) Run 

func (_c *MocksqlProvider_DbOpen_Call) Run(run func(driver string, dsn string, maxConnectionLimits *int32)) *MocksqlProvider_DbOpen_Call

func (*MocksqlProvider_DbOpen_Call) RunAndReturn 

func (_c *MocksqlProvider_DbOpen_Call) RunAndReturn(run func(string, string, *int32) (neosync_benthos_sql.SqlDbtx, error)) *MocksqlProvider_DbOpen_Call

type MocksqlProvider_Expecter 

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

func (*MocksqlProvider_Expecter) DbOpen 

func (_e *MocksqlProvider_Expecter) DbOpen(driver interface{}, dsn interface{}, maxConnectionLimits interface{}) *MocksqlProvider_DbOpen_Call

DbOpen is a helper method to define mock.On call

  • driver string
  • dsn string
  • maxConnectionLimits *int32

func (*MocksqlProvider_Expecter) GetConnectionDetails 

func (_e *MocksqlProvider_Expecter) GetConnectionDetails(cc interface{}, connTimeout interface{}, logger interface{}) *MocksqlProvider_GetConnectionDetails_Call

GetConnectionDetails is a helper method to define mock.On call

  • cc *mgmtv1alpha1.ConnectionConfig
  • connTimeout *uint32
  • logger *slog.Logger

type MocksqlProvider_GetConnectionDetails_Call 

type MocksqlProvider_GetConnectionDetails_Call struct {
	*mock.Call
}

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

func (*MocksqlProvider_GetConnectionDetails_Call) Return 

func (_c *MocksqlProvider_GetConnectionDetails_Call) Return(_a0 *sqlconnect.ConnectionDetails, _a1 error) *MocksqlProvider_GetConnectionDetails_Call

func (*MocksqlProvider_GetConnectionDetails_Call) Run 

func (_c *MocksqlProvider_GetConnectionDetails_Call) Run(run func(cc *mgmtv1alpha1.ConnectionConfig, connTimeout *uint32, logger *slog.Logger)) *MocksqlProvider_GetConnectionDetails_Call

func (*MocksqlProvider_GetConnectionDetails_Call) RunAndReturn 

func (_c *MocksqlProvider_GetConnectionDetails_Call) RunAndReturn(run func(*mgmtv1alpha1.ConnectionConfig, *uint32, *slog.Logger) (*sqlconnect.ConnectionDetails, error)) *MocksqlProvider_GetConnectionDetails_Call

type SyncMetadata 

type SyncMetadata struct {
	Schema string
	Table  string
}

type SyncRequest 

type SyncRequest struct {
	BenthosConfig string
	BenthosDsns   []*shared.BenthosDsn
}

type SyncResponse 

type SyncResponse struct{}

Source Files

View all Source files

Jump to

Keyboard shortcuts

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