configuration_testing

Documentation

Index

• Variables
• func Init()
• type CTHandleT
  • func (ct *CTHandleT) Validating(req *proto.WHValidationRequest) (response *proto.WHValidationResponse, err error)
• type CTUploadJob
  • func (job *CTUploadJob) GetFirstLastEvent() (time.Time, time.Time)
  • func (job *CTUploadJob) GetLoadFileGenStartTIme() time.Time
  • func (job *CTUploadJob) GetLoadFileType() string
  • func (job *CTUploadJob) GetLoadFilesMetadata(options warehouseutils.GetLoadFilesOptionsT) []warehouseutils.LoadFileT
  • func (job *CTUploadJob) GetLocalSchema() warehouseutils.SchemaT
  • func (job *CTUploadJob) GetSampleLoadFileLocation(tableName string) (string, error)
  • func (job *CTUploadJob) GetSchemaInWarehouse() warehouseutils.SchemaT
  • func (job *CTUploadJob) GetSingleLoadFile(tableName string) (warehouseutils.LoadFileT, error)
  • func (job *CTUploadJob) GetTableSchemaInUpload(tableName string) warehouseutils.TableSchemaT
  • func (job *CTUploadJob) GetTableSchemaInWarehouse(tableName string) warehouseutils.TableSchemaT
  • func (job *CTUploadJob) ShouldOnDedupUseNewRecord() bool
  • func (job *CTUploadJob) UpdateLocalSchema(schema warehouseutils.SchemaT) error
  • func (job *CTUploadJob) UseRudderStorage() bool
• type DestinationValidationRequest
• type DestinationValidationResponse
• type DestinationValidator
  • func NewDestinationValidator() DestinationValidator
• type DestinationValidatorImpl
  • func (dv *DestinationValidatorImpl) ValidateCredentials(req *DestinationValidationRequest) (*DestinationValidationResponse, error)

Variables

var (
	TestTableSchemaMap = map[string]string{
		"id":  "int",
		"val": "string",
	}
	TestPayloadMap = map[string]interface{}{
		"id":  1,
		"val": "RudderStack",
	}
	TestNamespace  = "_rudderstack_setup_test"
	AlterColumnMap = map[string]string{
		"val_alter": "string",
	}
)

Functions

func Init

func Init()

Types

type CTHandleT

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

func (*CTHandleT) Validating

func (ct *CTHandleT) Validating(req *proto.WHValidationRequest) (response *proto.WHValidationResponse, err error)

Validation Facade: Global invoking function for validation

type CTUploadJob

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

func (*CTUploadJob) GetFirstLastEvent

func (job *CTUploadJob) GetFirstLastEvent() (time.Time, time.Time)

func (*CTUploadJob) GetLoadFileGenStartTIme

func (job *CTUploadJob) GetLoadFileGenStartTIme() time.Time

func (*CTUploadJob) GetLoadFileType

func (job *CTUploadJob) GetLoadFileType() string

func (*CTUploadJob) GetLoadFilesMetadata

func (job *CTUploadJob) GetLoadFilesMetadata(options warehouseutils.GetLoadFilesOptionsT) []warehouseutils.LoadFileT

func (*CTUploadJob) GetLocalSchema

func (job *CTUploadJob) GetLocalSchema() warehouseutils.SchemaT

func (*CTUploadJob) GetSampleLoadFileLocation

func (job *CTUploadJob) GetSampleLoadFileLocation(tableName string) (string, error)

func (*CTUploadJob) GetSchemaInWarehouse

func (job *CTUploadJob) GetSchemaInWarehouse() warehouseutils.SchemaT

func (*CTUploadJob) GetSingleLoadFile

func (job *CTUploadJob) GetSingleLoadFile(tableName string) (warehouseutils.LoadFileT, error)

func (*CTUploadJob) GetTableSchemaInUpload

func (job *CTUploadJob) GetTableSchemaInUpload(tableName string) warehouseutils.TableSchemaT

func (*CTUploadJob) GetTableSchemaInWarehouse

func (job *CTUploadJob) GetTableSchemaInWarehouse(tableName string) warehouseutils.TableSchemaT

func (*CTUploadJob) ShouldOnDedupUseNewRecord

func (job *CTUploadJob) ShouldOnDedupUseNewRecord() bool

func (*CTUploadJob) UpdateLocalSchema

func (job *CTUploadJob) UpdateLocalSchema(schema warehouseutils.SchemaT) error

func (*CTUploadJob) UseRudderStorage

func (job *CTUploadJob) UseRudderStorage() bool

type DestinationValidationRequest

type DestinationValidationRequest struct {
	Destination backendconfig.DestinationT `json:"destination"`
}

type DestinationValidationResponse

type DestinationValidationResponse struct {
	Success bool              `json:"success"`
	Error   string            `json:"error"`
	Steps   []*validationStep `json:"steps"`
}

type DestinationValidator

type DestinationValidator interface {
	ValidateCredentials(req *DestinationValidationRequest) (*DestinationValidationResponse, error)
}

func NewDestinationValidator

func NewDestinationValidator() DestinationValidator

NewDestinationValidator encapsulates the process to generate the destination validator.

type DestinationValidatorImpl

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

func (*DestinationValidatorImpl) ValidateCredentials

func (dv *DestinationValidatorImpl) ValidateCredentials(req *DestinationValidationRequest) (*DestinationValidationResponse, error)

ValidateCredentials for now offloads the request to destination validation to the validationFunc. This function runs through all the steps in the validation check and then generate a valid response.