writer

Documentation

Overview

Package writer orchestrates the writing part of the import process.

Index

• type ErrorLevel
• type NodeWriter
• type OsmElemWriter
  • func NewNodeWriter(osmCache *cache.OSMCache, nodes chan *osm.Node, inserter database.Inserter, ...) *OsmElemWriter
  • func NewRelationWriter(osmCache *cache.OSMCache, diffCache *cache.DiffCache, singleIDSpace bool, ...) *OsmElemWriter
  • func NewWayWriter(osmCache *cache.OSMCache, diffCache *cache.DiffCache, singleIDSpace bool, ...) *OsmElemWriter
  • func (writer *OsmElemWriter) EnableConcurrent()
  • func (writer *OsmElemWriter) NodeToSrid(node *osm.Node)
  • func (writer *OsmElemWriter) NodesToSrid(nodes []osm.Node)
  • func (writer *OsmElemWriter) SetExpireor(exp expire.Expireor)
  • func (writer *OsmElemWriter) SetLimiter(limiter *limit.Limiter)
  • func (writer *OsmElemWriter) Start()
  • func (writer *OsmElemWriter) Wait()
• type RelationWriter
• type WayWriter

Types

type ErrorLevel

type ErrorLevel interface {
	Level() int
}

type NodeWriter

type NodeWriter struct {
	OsmElemWriter
	// contains filtered or unexported fields
}

type OsmElemWriter

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

func NewNodeWriter

func NewNodeWriter(
	osmCache *cache.OSMCache,
	nodes chan *osm.Node,
	inserter database.Inserter,
	progress *stats.Statistics,
	matcher mapping.NodeMatcher,
	srid int,
) *OsmElemWriter

func NewRelationWriter

func NewRelationWriter(
	osmCache *cache.OSMCache,
	diffCache *cache.DiffCache,
	singleIDSpace bool,
	rel chan *osm.Relation,
	inserter database.Inserter,
	progress *stats.Statistics,
	matcher mapping.RelWayMatcher,
	relMatcher mapping.RelationMatcher,
	relMemberMatcher mapping.RelationMatcher,
	srid int,
) *OsmElemWriter

func NewWayWriter

func NewWayWriter(
	osmCache *cache.OSMCache,
	diffCache *cache.DiffCache,
	singleIDSpace bool,
	ways chan *osm.Way,
	inserter database.Inserter,
	progress *stats.Statistics,
	polygonMatcher mapping.WayMatcher,
	lineMatcher mapping.WayMatcher,
	srid int,
) *OsmElemWriter

func (*OsmElemWriter) EnableConcurrent

func (writer *OsmElemWriter) EnableConcurrent()

func (*OsmElemWriter) NodeToSrid

func (writer *OsmElemWriter) NodeToSrid(node *osm.Node)

func (*OsmElemWriter) NodesToSrid

func (writer *OsmElemWriter) NodesToSrid(nodes []osm.Node)

func (*OsmElemWriter) SetExpireor

func (writer *OsmElemWriter) SetExpireor(exp expire.Expireor)

func (*OsmElemWriter) SetLimiter

func (writer *OsmElemWriter) SetLimiter(limiter *limit.Limiter)

func (*OsmElemWriter) Start

func (writer *OsmElemWriter) Start()

func (*OsmElemWriter) Wait

func (writer *OsmElemWriter) Wait()

type RelationWriter

type RelationWriter struct {
	OsmElemWriter
	// contains filtered or unexported fields
}

type WayWriter

type WayWriter struct {
	OsmElemWriter
	// contains filtered or unexported fields
}