dsunit

Dec 31, 2025

Changes in this version

+ var ReservedKeywordsKey = (*[]string)(nil)

Dec 31, 2025

Changes in this version

type ExpectRequest

+ SQLQuoteReservedKeywords string

type InitRequest

+ SQLQuoteReservedKeywords string

type PrepareRequest

+ SQLQuoteReservedKeywords string

type RegisterRequest

+ SQLQuoteReservedKeywords string

May 25, 2025

Changes in this version

type PrepareRequest

+ Threads int

May 25, 2023

Changes in this version

+ const ObfuscationMethodCipher

+ const ObfuscationMethodDictionary

+ const ObfuscationMethodReplace

+ const ObfuscationMethodShuffle

+ func ExpectWithURL(t *testing.T, checkPolicy int, URL string, datastore string, ...) bool

+ func PopulateWithURL(t *testing.T, URL string, datastore string, datasets ...*Dataset) bool

type FreezeRequest

+ ASCII []string

+ Obfuscation []Obfuscation

+ Override map[string]string

+ RelativeDate []string

+ Reset bool

+ type Obfuscation struct

+ Columns []string

+ Dictionary []string

+ DictionaryURL string

+ IDKey string

+ Key *kms.Key

+ Method ObfuscationMethod

+ Template string

+ func (o *Obfuscation) Init(ctx context.Context)

+ func (o *Obfuscation) Obfuscate(ctx context.Context, value string, record map[string]interface{}, ...) (string, error)

+ type ObfuscationMethod string

type Tester

+ ExpectWithURL func(t *testing.T, checkPolicy int, URL string, datastore string, ...) bool

+ PopulateWithURL func(t *testing.T, URL string, datastore string, datasets ...*Dataset) bool

Jul 10, 2019

Changes in this version

+ type CheckSchemaRequest struct

+ CheckNullables bool

+ CheckPrimaryKeys bool

+ Dest *SchemaTarget

+ Source *SchemaTarget

+ Tables []string

+ type CheckSchemaResponse struct

+ Tables []*SchemaTableCheck

+ func NewCheckSchemaResponse() *CheckSchemaResponse

type CompareRequest

+ func (r *CompareRequest) Init() error

+ type SchemaTableCheck struct

+ Table string

+ type SchemaTarget struct

+ Datastore string

+ MappingURL string

+ Target string

type Service

+ CheckSchema func(request *CheckSchemaRequest) *CheckSchemaResponse

Jun 6, 2019

Changes in this version

type DumpRequest

+ MappingURL string

+ Target string

Mar 12, 2019

Changes in this version

+ func Ping(t *testing.T, datastore string, timeoutMs int) bool

+ type PingRequest struct

+ Datastore string

+ TimeoutMs int

+ type PingResponse struct

type RegisterRequest

+ Ping bool

type Service

+ Ping func(request *PingRequest) *PingResponse

type Tester

+ Ping func(t *testing.T, datastore string, timeoutMs int) bool

Feb 6, 2019

Changes in this version

type DumpRequest

+ func NewDumpRequestFromURL(URL string) (*DumpRequest, error)

Jan 2, 2019

Changes in this version

type CompareRequest

+ OmitEmpty bool

Dec 30, 2018

Changes in this version

+ type CompareRequest struct

+ Directives map[string]interface{}

+ Ignore []string

+ MaxRowDiscrepancy int

+ Source1 *DatastoreSQL

+ Source2 *DatastoreSQL

+ func (r *CompareRequest) ApplyDirective(record map[string]interface{})

+ func (r CompareRequest) IndexBy() []string

+ type CompareResponse struct

+ Dataset1Count int

+ Dataset2Count int

+ MatchedRows int

+ type DatastoreSQL struct

+ Datastore string

+ SQL string

type Service

+ Compare func(request *CompareRequest) *CompareResponse

Dec 28, 2018

Changes in this version

type QueryRequest

+ Expect []map[string]interface{}

Nov 28, 2018

Changes in this version

type FreezeRequest

+ LocationTimezone string

+ TimeFormat string

+ TimeLayout string

+ func (r *FreezeRequest) Init() error

Nov 6, 2018

Changes in this version

+ var SubstitutionMapKey = (*data.Map)(nil)

+ type DumpRequest struct

+ Datastore string

+ DestURL string

+ Tables []string

+ type DumpResponse struct

+ Count int

+ DestURL string

type Service

+ Dump func(request *DumpRequest) *DumpResponse

Oct 30, 2018

Changes in this version

+ const AutoincrementDirective

+ const FromQueryAliasDirective

+ const FromQueryDirective

+ const StatusOk

+ var LogF = fmt.Printf

+ func AddTableMapping(t *testing.T, request *MappingRequest) bool

+ func AddTableMappingFromURL(t *testing.T, URL string) bool

+ func Expect(t *testing.T, request *ExpectRequest) bool

+ func ExpectFor(t *testing.T, datastore string, checkPolicy int, baseDirectory string, ...) bool

+ func ExpectFromURL(t *testing.T, URL string) bool

+ func GetDatastoreDialect(datastore string, registry dsc.ManagerRegistry) dsc.DatastoreDialect

+ func Init(t *testing.T, request *InitRequest) bool

+ func InitFromURL(t *testing.T, URL string) bool

+ func Prepare(t *testing.T, request *PrepareRequest) bool

+ func PrepareFor(t *testing.T, datastore string, baseDirectory string, method string) bool

+ func PrepareFromURL(t *testing.T, URL string) bool

+ func Recreate(t *testing.T, request *RecreateRequest) bool

+ func RecreateDatastore(adminDatastore, targetDatastore string, registry dsc.ManagerRegistry) error

+ func RecreateFromURL(t *testing.T, URL string) bool

+ func Register(t *testing.T, request *RegisterRequest) bool

+ func RegisterFromURL(t *testing.T, URL string) bool

+ func RunSQL(t *testing.T, request *RunSQLRequest) bool

+ func RunSQLFromURL(t *testing.T, URL string) bool

+ func RunScript(t *testing.T, request *RunScriptRequest) bool

+ func RunScriptFromURL(t *testing.T, URL string) bool

+ type BaseResponse struct

+ Message string

+ Status string

+ func NewBaseOkResponse() *BaseResponse

+ func NewBaseResponse(status, message string) *BaseResponse

+ func (r *BaseResponse) SetError(err error)

+ func (r BaseResponse) Error() error

+ type DatafileInfo struct

+ Ext string

+ Filename string

+ Name string

+ Postfix string

+ Prefix string

+ func NewDatafileInfo(filename, prefix, postfix string) *DatafileInfo

type Dataset

+ Records Records

+ Table string

+ func NewDataset(table string, records ...map[string]interface{}) *Dataset

type DatasetResource

+ func NewDatasetResource(datastore string, URL, prefix, postfix string, datasets ...*Dataset) *DatasetResource

+ func (r *DatasetResource) Init() error

+ func (r *DatasetResource) Load() (err error)

+ type DatasetValidation struct

+ Actual interface{}

+ Dataset string

+ Expected interface{}

+ type DatastoreDatasets struct

+ Data map[string][]map[string]interface{}

+ Datasets []*Dataset

+ Datastore string

+ type ExpectRequest struct

+ CheckPolicy int

+ func NewExpectRequest(checkPolicy int, resource *DatasetResource) *ExpectRequest

+ func NewExpectRequestFromURL(URL string) (*ExpectRequest, error)

+ func (r *ExpectRequest) Validate() error

type ExpectResponse

+ FailedCount int

+ PassedCount int

+ Validation []*DatasetValidation

+ type FreezeRequest struct

+ Datastore string

+ DestURL string

+ Ignore []string

+ OmitEmpty bool

+ Replace map[string]string

+ SQL string

+ type FreezeResponse struct

+ Count int

+ DestURL string

+ type InitRequest struct

+ Admin *RegisterRequest

+ Datastore string

+ Recreate bool

+ func NewInitRequest(datastore string, recreate bool, register, admin *RegisterRequest, ...) *InitRequest

+ func NewInitRequestFromURL(URL string) (*InitRequest, error)

+ func (r *InitRequest) Init() (err error)

+ func (r *InitRequest) Validate() error

+ type InitResponse struct

+ Tables []string

+ type Mapper struct

+ func NewMapper() *Mapper

+ func (s *Mapper) Add(mapping *Mapping)

+ func (s *Mapper) Has(table string) bool

+ func (s *Mapper) Map(dataset *Dataset) []*Dataset

+ type Mapping struct

+ Name string

+ func (m *Mapping) Tables() []string

+ type MappingColumn struct

+ DefaultValue string

+ FromColumn string

+ Name string

+ Required bool

+ Unique bool

+ type MappingRequest struct

+ Mappings []*Mapping

+ func NewMappingRequest(mappings ...*Mapping) *MappingRequest

+ func NewMappingRequestFromURL(URL string) (*MappingRequest, error)

+ func (r *MappingRequest) Init() (err error)

+ func (r *MappingRequest) Validate() error

+ type MappingResponse struct

+ Tables []string

+ type MappingTable struct

+ Associations []*MappingTable

+ Columns []*MappingColumn

+ Table string

+ type ModificationInfo struct

+ Added int

+ Deleted int

+ Method string

+ Modified int

+ Subject string

+ type PrepareRequest struct

+ Expand bool

+ func NewPrepareRequest(resource *DatasetResource) *PrepareRequest

+ func NewPrepareRequestFromURL(URL string) (*PrepareRequest, error)

+ func (r *PrepareRequest) Validate() error

+ type PrepareResponse struct

+ Expand bool

+ Modification map[string]*ModificationInfo

+ type QueryRequest struct

+ Datastore string

+ IgnoreError bool

+ SQL string

+ func NewQueryRequest(datastore, SQL string) *QueryRequest

+ type QueryResponse struct

+ Records Records

+ type Record map[string]interface

+ func (r *Record) AsMap() map[string]interface{}

+ func (r *Record) Columns() []string

+ func (r *Record) HasColumn(column string) bool

+ func (r *Record) IsEmpty() bool

+ func (r *Record) SetValue(column string, value interface{})

+ func (r *Record) String() string

+ func (r *Record) Value(column string) interface{}

+ func (r Record) ValueAsString(column string) string

+ type Records []map[string]interface

+ func (r *Records) Autoincrement() bool

+ func (r *Records) Columns() []string

+ func (r *Records) Expand(context toolbox.Context, includeDirectives bool) (result []interface{}, err error)

+ func (r *Records) FromQuery() (string, string)

+ func (r *Records) ShouldDeleteAll() bool

+ func (r *Records) UniqueKeys() []string

+ type RecreateRequest struct

+ AdminDatastore string

+ Datastore string

+ func NewRecreateRequest(datastore, adminDatastore string) *RecreateRequest

+ func NewRecreateRequestFromURL(URL string) (*RecreateRequest, error)

+ type RecreateResponse struct

+ type RegisterRequest struct

+ Config *dsc.Config

+ ConfigURL string

+ Datastore string

+ Tables []*dsc.TableDescriptor

+ func NewRegisterRequest(datastore string, config *dsc.Config, tables ...*dsc.TableDescriptor) *RegisterRequest

+ func NewRegisterRequestFromURL(URL string) (*RegisterRequest, error)

+ func (r *RegisterRequest) Init() (err error)

+ func (r *RegisterRequest) Validate() error

+ type RegisterResponse struct

+ type RunSQLRequest struct

+ Datastore string

+ Expand bool

+ SQL []string

+ func NewRunSQLRequest(datastore string, SQL ...string) *RunSQLRequest

+ func NewRunSQLRequestFromURL(URL string) (*RunSQLRequest, error)

+ type RunSQLResponse struct

+ RowsAffected int

+ type RunScriptRequest struct

+ Datastore string

+ Expand bool

+ Scripts []*url.Resource

+ func NewRunScriptRequest(datastore string, scripts ...*url.Resource) *RunScriptRequest

+ func NewRunScriptRequestFromURL(URL string) (*RunScriptRequest, error)

+ type SequenceRequest struct

+ Datastore string

+ Tables []string

+ func NewSequenceRequest(datastore string, tables ...string) *SequenceRequest

+ type SequenceResponse struct

+ Sequences map[string]int

type Service

+ func New() Service

+ AddTableMapping func(request *MappingRequest) *MappingResponse

+ Expect func(request *ExpectRequest) *ExpectResponse

+ Freeze func(request *FreezeRequest) *FreezeResponse

+ Prepare func(request *PrepareRequest) *PrepareResponse

+ Query func(request *QueryRequest) *QueryResponse

+ Recreate func(request *RecreateRequest) *RecreateResponse

+ Register func(request *RegisterRequest) *RegisterResponse

+ Registry func() dsc.ManagerRegistry

+ RunSQL func(request *RunSQLRequest) *RunSQLResponse

+ RunScript func(request *RunScriptRequest) *RunSQLResponse

+ Sequence func(request *SequenceRequest) *SequenceResponse

+ SetContext func(context toolbox.Context)

+ type Tester interface

+ AddTableMapping func(t *testing.T, request *MappingRequest) bool

+ AddTableMappingFromURL func(t *testing.T, URL string) bool

+ Expect func(t *testing.T, request *ExpectRequest) bool

+ ExpectDatasets func(t *testing.T, datastore string, checkPolicy int) bool

+ ExpectFor func(t *testing.T, datastore string, checkPolicy int, baseDirectory string, ...) bool

+ ExpectFromURL func(t *testing.T, URL string) bool

+ Init func(t *testing.T, request *InitRequest) bool

+ InitFromURL func(t *testing.T, URL string) bool

+ Prepare func(t *testing.T, request *PrepareRequest) bool

+ PrepareDatastore func(t *testing.T, datastore string) bool

+ PrepareFor func(t *testing.T, datastore string, baseDirectory string, method string) bool

+ PrepareFromURL func(t *testing.T, URL string) bool

+ Recreate func(t *testing.T, request *RecreateRequest) bool

+ RecreateFromURL func(t *testing.T, URL string) bool

+ Register func(t *testing.T, request *RegisterRequest) bool

+ RegisterFromURL func(t *testing.T, URL string) bool

+ RunSQL func(t *testing.T, request *RunSQLRequest) bool

+ RunSQLFromURL func(t *testing.T, URL string) bool

+ RunScript func(t *testing.T, request *RunScriptRequest) bool

+ RunScriptFromURL func(t *testing.T, URL string) bool

+ func NewRemoveTester(endpoint string) Tester

+ func NewTester() Tester

Feb 8, 2018

Changes in this version

+ const FullTableDatasetCheckPolicy

+ const SnapshotDatasetCheckPolicy

+ const ViolationTypeInvalidRowCount

+ const ViolationTypeMissingActualRow

+ const ViolationTypeRowNotEqual

+ var TestSchema = "test://"

+ func ExecuteScriptFromURL(t *testing.T, url string)

+ func ExpandTestProtocolAsPathIfNeeded(input string) string

+ func ExpandTestProtocolAsURLIfNeeded(input string) string

+ func ExpectDatasetFor(t *testing.T, datastore string, checkPolicy int, baseDirectory string, ...)

+ func ExpectDatasets(t *testing.T, datastore string, checkPolicy int)

+ func InitDatastoreFromURL(t *testing.T, url string)

+ func ParseColumnarData(reader io.Reader, separator string) ([]string, [][]interface{})

+ func ParseSQLScript(reader io.Reader) []string

+ func PrepareDatastore(t *testing.T, datastore string)

+ func PrepareDatastoreFor(t *testing.T, datastore string, baseDirectory string, method string)

+ func SetService(service Service)

+ func StartServer(port string)

+ func UseRemoteTestServer(serverURL string)

+ type AssertViolation struct

+ Actual string

+ Datastore string

+ Expected string

+ Key string

+ Path string

+ Source string

+ Table string

+ Type string

+ type AssertViolations interface

+ HasViolations func() bool

+ String func() string

+ Violations func() []*AssertViolation

+ func NewAssertViolations(violations []*AssertViolation) AssertViolations

+ type Dataset struct

+ Rows []*Row

+ func (d *Dataset) AsMapArray() []map[string]interface{}

+ type DatasetColumn struct

+ DefaultValue string

+ FromColumn string

+ Name string

+ Required bool

+ type DatasetFactory interface

+ Create func(descriptor *dsc.TableDescriptor, dataset ...map[string]interface{}) *Dataset

+ CreateDatasets func(data *DatasetResource) (*Datasets, error)

+ CreateFromMap func(datastore string, table string, dataset ...map[string]interface{}) *Dataset

+ CreateFromURL func(datastore string, table string, url string) (*Dataset, error)

+ type DatasetMapping struct

+ Associations []*DatasetMapping

+ Columns []*DatasetColumn

+ Table string

+ func (m *DatasetMapping) Tables() []string

+ type DatasetResource struct

+ Credential string

+ Datastore string

+ Postfix string

+ Prefix string

+ TableRows []*TableRows

+ URL string

+ type DatasetTestManager interface

+ ClearDatastore func(adminDatastore string, targetDatastore string) error

+ DatasetFactory func() DatasetFactory

+ Execute func(script *Script) (int, error)

+ ExecuteFromURL func(datastore string, url string) (int, error)

+ ExpectDatasets func(checkPolicy int, expected *Datasets) (AssertViolations, error)

+ MacroEvaluator func() *toolbox.MacroEvaluator

+ ManagerRegistry func() dsc.ManagerRegistry

+ PrepareDatastore func(datasets *Datasets) (inserted, updated, deleted int, err error)

+ RegisterDatasetMapping func(name string, mapping *DatasetMapping)

+ RegisterTable func(datastore string, tableDescriptor *dsc.TableDescriptor)

+ RegisteredMapping func() []string

+ RegisteredTables func(datastore string) []string

+ SafeMode func(enable bool)

+ ValueProviderRegistry func() toolbox.ValueProviderRegistry

+ func NewDatasetTestManager() DatasetTestManager

+ type DatasetTester struct

+ func (t DatasetTester) Assert(datastore string, expected, actual *Dataset) []*AssertViolation

+ type DatasetTransformer struct

+ func NewDatasetTransformer() *DatasetTransformer

+ func (dt *DatasetTransformer) Transform(datastore string, sourceDataset *Dataset, mapping *DatasetMapping, ...) *Datasets

+ type Datasets struct

+ Datasets []*Dataset

+ Datastore string

+ type DatastoreConfig struct

+ AdminDbName string

+ ClearDatastore bool

+ Config *dsc.Config

+ ConfigURL string

+ DatasetMapping map[string]*DatasetMapping

+ Datastore string

+ Descriptors []*dsc.TableDescriptor

+ type DatastoreDatasetProvider struct

+ func NewDatastoreDatasetProvider(manager dsc.Manager) *DatastoreDatasetProvider

+ func (p *DatastoreDatasetProvider) Get(table string, columns ...string) (*Dataset, error)

+ type DatastoreDatasetSnapshotManager struct

+ func NewDatastoreDatasetSnapshotManager(registry dsc.ManagerRegistry) *DatastoreDatasetSnapshotManager

+ func (t *DatastoreDatasetSnapshotManager) Take(datastore string, targetDirectory string) error

+ type ExecuteScriptRequest struct

+ Scripts []Script

+ type ExpectDatasetRequest struct

+ CheckPolicy int

+ Expect []Datasets

+ type ExpectResponse struct

+ Violations []*AssertViolation

+ type InitDatastoreRequest struct

+ DatastoreConfigs []DatastoreConfig

+ type PrepareDatastoreRequest struct

+ Prepare []Datasets

+ type Response struct

+ Message string

+ Status string

+ type Row struct

+ Source string

+ Values map[string]interface{}

+ func AsRow(instance interface{}) *Row

+ func (r Row) Columns() []string

+ func (r Row) HasColumn(column string) bool

+ func (r Row) SetValue(column string, value interface{})

+ func (r Row) String() string

+ func (r Row) Value(column string) interface{}

+ func (r Row) ValueAsString(column string) string

+ type Script struct

+ Body string

+ Datastore string

+ Sqls []string

+ Url string

+ type Service interface

+ ExecuteScripts func(request *ExecuteScriptRequest) *Response

+ ExecuteScriptsFromURL func(url string) *Response

+ ExpectDatasets func(request *ExpectDatasetRequest) *ExpectResponse

+ ExpectDatasetsFor func(datastore string, baseDir string, method string, checkPolicy int) *ExpectResponse

+ ExpectDatasetsFromURL func(url string) *ExpectResponse

+ Init func(request *InitDatastoreRequest) *Response

+ InitFromURL func(url string) *Response

+ PrepareDatastore func(request *PrepareDatastoreRequest) *Response

+ PrepareDatastoreFor func(datastore string, baseDir string, method string) *Response

+ PrepareDatastoreFromURL func(url string) *Response

+ func GetService() Service

+ func NewServiceClient(testDirectory, serverURL string) Service

+ func NewServiceLocal(testDirectory string) Service

+ type TableRows struct

+ Rows []map[string]interface{}

+ Table string