datastream_accessor

Documentation

Index

• type DatastreamAccessor
• type DatastreamAccessorImpl
  • func (da *DatastreamAccessorImpl) ConnectionProfileExists(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, ...) (bool, error)
  • func (da *DatastreamAccessorImpl) CreateConnectionProfile(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, ...) (*datastreampb.ConnectionProfile, error)
  • func (da *DatastreamAccessorImpl) DeleteConnectionProfile(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, ...) error
  • func (da *DatastreamAccessorImpl) FetchTargetBucketAndPath(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, ...) (string, string, error)
  • func (da *DatastreamAccessorImpl) GetConnProfilesRegion(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, ...) ([]string, error)
• type DatastreamAccessorMock
  • func (dam *DatastreamAccessorMock) ConnectionProfileExists(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, ...) (bool, error)
  • func (dam *DatastreamAccessorMock) CreateConnectionProfile(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, ...) (*datastreampb.ConnectionProfile, error)
  • func (dam *DatastreamAccessorMock) DeleteConnectionProfile(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, ...) error
  • func (dam *DatastreamAccessorMock) FetchTargetBucketAndPath(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, ...) (string, string, error)
  • func (dam *DatastreamAccessorMock) GetConnProfilesRegion(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, ...) ([]string, error)

Types

type DatastreamAccessor

type DatastreamAccessor interface {
	FetchTargetBucketAndPath(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, projectID string, datastreamDestinationConnCfg streaming.DstConnCfg) (string, string, error)
	DeleteConnectionProfile(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, id string, projectId string, region string) error
	GetConnProfilesRegion(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, projectId string, region string) ([]string, error)
	CreateConnectionProfile(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, req *datastreampb.CreateConnectionProfileRequest) (*datastreampb.ConnectionProfile, error)
	ConnectionProfileExists(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, projectId string, profileName string, profileLocation string, connectionProfiles map[string][]string) (bool, error)
}

The DatastreamAccessor provides methods that internally use the datstreamclient. Methods should only contain generic logic here that can be used by multiple workflows.

type DatastreamAccessorImpl

type DatastreamAccessorImpl struct{}

func (*DatastreamAccessorImpl) ConnectionProfileExists

func (da *DatastreamAccessorImpl) ConnectionProfileExists(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, projectId string, profileName string, profileLocation string, connectionProfiles map[string][]string) (bool, error)

returns true if connection profile exists in a provided region else false

func (*DatastreamAccessorImpl) CreateConnectionProfile

func (da *DatastreamAccessorImpl) CreateConnectionProfile(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, req *datastreampb.CreateConnectionProfileRequest) (*datastreampb.ConnectionProfile, error)

Creates new connection Profile

func (*DatastreamAccessorImpl) DeleteConnectionProfile

func (da *DatastreamAccessorImpl) DeleteConnectionProfile(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, id string, projectId string, region string) error

Deletes a connection Profile

func (*DatastreamAccessorImpl) FetchTargetBucketAndPath

func (da *DatastreamAccessorImpl) FetchTargetBucketAndPath(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, projectID string, datastreamDestinationConnCfg streaming.DstConnCfg) (string, string, error)

FetchTargetBucketAndPath fetches the bucket and path name from a Datastream destination config.

func (*DatastreamAccessorImpl) GetConnProfilesRegion

func (da *DatastreamAccessorImpl) GetConnProfilesRegion(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, projectId string, region string) ([]string, error)

Gets all connection profiles in a region

type DatastreamAccessorMock

type DatastreamAccessorMock struct {
	FetchTargetBucketAndPathMock func(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, projectID string, datastreamDestinationConnCfg streaming.DstConnCfg) (string, string, error)
	DeleteConnectionProfileMock  func(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, id string, projectId string, region string) error
	GetConnProfilesRegionMock    func(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, projectId string, region string) ([]string, error)
	CreateConnectionProfileMock  func(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, req *datastreampb.CreateConnectionProfileRequest) (*datastreampb.ConnectionProfile, error)
	ConnectionProfileExistsMock  func(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, projectId string, profileName string, profileLocation string, connectionProfiles map[string][]string) (bool, error)
}

func (*DatastreamAccessorMock) ConnectionProfileExists

func (dam *DatastreamAccessorMock) ConnectionProfileExists(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, projectId string, profileName string, profileLocation string, connectionProfiles map[string][]string) (bool, error)

func (*DatastreamAccessorMock) CreateConnectionProfile

func (dam *DatastreamAccessorMock) CreateConnectionProfile(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, req *datastreampb.CreateConnectionProfileRequest) (*datastreampb.ConnectionProfile, error)

func (*DatastreamAccessorMock) DeleteConnectionProfile

func (dam *DatastreamAccessorMock) DeleteConnectionProfile(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, id string, projectId string, region string) error

func (*DatastreamAccessorMock) FetchTargetBucketAndPath

func (dam *DatastreamAccessorMock) FetchTargetBucketAndPath(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, projectID string, datastreamDestinationConnCfg streaming.DstConnCfg) (string, string, error)

func (*DatastreamAccessorMock) GetConnProfilesRegion

func (dam *DatastreamAccessorMock) GetConnProfilesRegion(ctx context.Context, datastreamClient datastreamclient.DatastreamClient, projectId string, region string) ([]string, error)