validations

Documentation

Index

• Variables
• func CreateTempLoadFile(req *DestinationValidationRequest) (filePath string, err error)
• func Init()
• type CTHandleT
  • func (ct *CTHandleT) Validating(req *proto.WHValidationRequest) (response *proto.WHValidationResponse, err error)
• type CTUploadJob
  • func (*CTUploadJob) GetFirstLastEvent() (time.Time, time.Time)
  • func (*CTUploadJob) GetLoadFileGenStartTIme() time.Time
  • func (job *CTUploadJob) GetLoadFileType() string
  • func (*CTUploadJob) GetLoadFilesMetadata(_ warehouseutils.GetLoadFilesOptionsT) []warehouseutils.LoadFileT
  • func (*CTUploadJob) GetLocalSchema() warehouseutils.SchemaT
  • func (*CTUploadJob) GetSampleLoadFileLocation(_ string) (string, error)
  • func (*CTUploadJob) GetSchemaInWarehouse() warehouseutils.SchemaT
  • func (*CTUploadJob) GetSingleLoadFile(_ string) (warehouseutils.LoadFileT, error)
  • func (*CTUploadJob) GetTableSchemaInUpload(_ string) warehouseutils.TableSchemaT
  • func (*CTUploadJob) GetTableSchemaInWarehouse(_ string) warehouseutils.TableSchemaT
  • func (*CTUploadJob) ShouldOnDedupUseNewRecord() bool
  • func (*CTUploadJob) UpdateLocalSchema(_ 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 CreateTempLoadFile

func CreateTempLoadFile(req *DestinationValidationRequest) (filePath string, err error)

func Init

func Init()

Types

type CTHandleT

type CTHandleT struct {
	CPClient         controlplane.InternalControlPlane
	EnableTunnelling bool
	// contains filtered or unexported fields
}

func (*CTHandleT) Validating

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

Validating Facade for Global invoking validation

type CTUploadJob

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

func (*CTUploadJob) GetFirstLastEvent

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

func (*CTUploadJob) GetLoadFileGenStartTIme

func (*CTUploadJob) GetLoadFileGenStartTIme() time.Time

func (*CTUploadJob) GetLoadFileType

func (job *CTUploadJob) GetLoadFileType() string

func (*CTUploadJob) GetLoadFilesMetadata

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

func (*CTUploadJob) GetLocalSchema

func (*CTUploadJob) GetLocalSchema() warehouseutils.SchemaT

func (*CTUploadJob) GetSampleLoadFileLocation

func (*CTUploadJob) GetSampleLoadFileLocation(_ string) (string, error)

func (*CTUploadJob) GetSchemaInWarehouse

func (*CTUploadJob) GetSchemaInWarehouse() warehouseutils.SchemaT

func (*CTUploadJob) GetSingleLoadFile

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

func (*CTUploadJob) GetTableSchemaInUpload

func (*CTUploadJob) GetTableSchemaInUpload(_ string) warehouseutils.TableSchemaT

func (*CTUploadJob) GetTableSchemaInWarehouse

func (*CTUploadJob) GetTableSchemaInWarehouse(_ string) warehouseutils.TableSchemaT

func (*CTUploadJob) ShouldOnDedupUseNewRecord

func (*CTUploadJob) ShouldOnDedupUseNewRecord() bool

func (*CTUploadJob) UpdateLocalSchema

func (*CTUploadJob) UpdateLocalSchema(_ 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.