Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

driver

package

Go to main page

Versions in this module

v1

v1.0.2

Mar 6, 2020

Changes in this version

type Driver

+ Checker func(ctx context.Context, state *health.CheckState) error

v1.0.1

Feb 25, 2020

v1.0.0

Feb 4, 2020

Changes in this version

+ var ErrMultipleFound = errors.New("multiple found where should be one")

+ var ErrNotFound = errors.New("not found")

+ type CodeList interface

+ GetCode func(ctx context.Context, codeListID, edition string, code string) (*codelistModels.Code, error)

+ GetCodeDatasets func(ctx context.Context, codeListID, edition string, code string) (*codelistModels.Datasets, error)

+ GetCodeList func(ctx context.Context, codeListID string) (*codelistModels.CodeList, error)

+ GetCodeLists func(ctx context.Context, filterBy string) (*codelistModels.CodeListResults, error)

+ GetCodes func(ctx context.Context, codeListID, edition string) (*codelistModels.CodeResults, error)

+ GetEdition func(ctx context.Context, codeListID, edition string) (*codelistModels.Edition, error)

+ GetEditions func(ctx context.Context, codeListID string) (*codelistModels.Editions, error)

+ type Dimension interface

+ InsertDimension func(ctx context.Context, cache map[string]string, i *importModels.Instance, ...) (*importModels.Dimension, error)

+ type Driver interface

+ Close func(ctx context.Context) error

+ Healthcheck func() (string, error)

+ type ErrAttemptsExceededLimit struct

+ WrappedErr error

+ func (e ErrAttemptsExceededLimit) Error() string

+ type ErrNonRetriable struct

+ WrappedErr error

+ func (e ErrNonRetriable) Error() string

+ type Hierarchy interface

+ CloneNodes func(ctx context.Context, attempt int, instanceID, codeListID, dimensionName string) error

+ CloneRelationships func(ctx context.Context, attempt int, instanceID, codeListID, dimensionName string) error

+ CountNodes func(ctx context.Context, instanceID, dimensionName string) (count int64, err error)

+ CreateInstanceHierarchyConstraints func(ctx context.Context, attempt int, instanceID, dimensionName string) error

+ GetHierarchyCodelist func(ctx context.Context, instanceID, dimension string) (string, error)

+ GetHierarchyElement func(ctx context.Context, instanceID, dimension, code string) (*hierarchyModels.Response, error)

+ GetHierarchyRoot func(ctx context.Context, instanceID, dimension string) (*hierarchyModels.Response, error)

+ MarkNodesToRemain func(ctx context.Context, attempt int, instanceID, dimensionName string) error

+ RemoveNodesNotMarkedToRemain func(ctx context.Context, attempt int, instanceID, dimensionName string) error

+ RemoveRemainMarker func(ctx context.Context, attempt int, instanceID, dimensionName string) error

+ SetHasData func(ctx context.Context, attempt int, instanceID, dimensionName string) error

+ SetNumberOfChildren func(ctx context.Context, attempt int, instanceID, dimensionName string) error

+ type Instance interface

+ AddDimensions func(ctx context.Context, i *importModels.Instance) error

+ AddVersionDetailsToInstance func(ctx context.Context, instanceID string, datasetID string, edition string, ...) error

+ CountInsertedObservations func(ctx context.Context, instanceID string) (count int64, err error)

+ CreateCodeRelationship func(ctx context.Context, i *importModels.Instance, codeListID, code string) error

+ CreateInstance func(ctx context.Context, i *importModels.Instance) error

+ CreateInstanceConstraint func(ctx context.Context, i *importModels.Instance) error

+ InstanceExists func(ctx context.Context, i *importModels.Instance) (bool, error)

+ SetInstanceIsPublished func(ctx context.Context, instanceID string) error

+ type Observation interface

+ InsertObservationBatch func(ctx context.Context, attempt int, instanceID string, ...) error

+ StreamCSVRows func(ctx context.Context, filter *observation.Filter, limit *int) (observation.StreamRowReader, error)

Other modules containing this package

github.com/ONSdigital/dp-graph/v2