Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ChunkAndCopy ¶
func (*ChunkAndCopy) Run ¶
func (ct *ChunkAndCopy) Run(state *ImportState) (*ImportState, ImportResult, error)
type ChunkAndTrack ¶
type ChunkAndTrack struct {
ExternalStore *bsexternal.Blobstore
}
func (*ChunkAndTrack) Run ¶
func (ct *ChunkAndTrack) Run(state *ImportState) (*ImportState, ImportResult, error)
type CommitStage ¶
func (*CommitStage) Run ¶
func (cs *CommitStage) Run(state *ImportState) (*ImportState, ImportResult, error)
type IdeaStage ¶
func (*IdeaStage) Run ¶
func (is *IdeaStage) Run(state *ImportState) (*ImportState, ImportResult, error)
type ImportArgs ¶
type ImportFailure ¶
type ImportFailure struct {
Reason string
}
type ImportPipeline ¶
type ImportPipeline []ImportStage
func (ImportPipeline) Run ¶
func (ip ImportPipeline) Run(ia *ImportArgs) (res ImportResult, err error)
type ImportResult ¶
type ImportResult struct { *ImportSuccess *ImportFailure }
type ImportStage ¶
type ImportStage interface {
Run(args *ImportState) (*ImportState, ImportResult, error)
}
Import stage takes in an import state, and returns either and import state, an import result, or and error.
type ImportState ¶
type ImportSuccess ¶
type IndexStage ¶
func (*IndexStage) Run ¶
func (is *IndexStage) Run(state *ImportState) (*ImportState, ImportResult, error)
type ParsingStage ¶
type ParsingStage struct{}
func (*ParsingStage) Run ¶
func (*ParsingStage) Run(state *ImportState) (*ImportState, ImportResult, error)
type ReprStage ¶
func (*ReprStage) Run ¶
func (rs *ReprStage) Run(state *ImportState) (*ImportState, ImportResult, error)
Click to show internal directories.
Click to hide internal directories.