directexport

Documentation

Index

• func AgentDelegateFactory(logger hclog.Logger, delegate AgentDelegate) func(exp expin.Export) rpcdef.Agent
• type AgentDelegate
• type ObjectsWriter
  • func NewObjectsWriter() *ObjectsWriter
  • func (s *ObjectsWriter) Done(id expsessions.ID, lastProcessed interface{}) error
  • func (s *ObjectsWriter) GetData() rpcdef.MutatedObjects
  • func (s *ObjectsWriter) Session(modelType string, parentSessionID expsessions.ID, ...) (_ expsessions.ID, lastProcessed interface{}, _ error)
  • func (s *ObjectsWriter) Write(id expsessions.ID, objs []map[string]interface{}) error
• type RepoExporter
  • func NewRepoExporter(opts RepoExporterOpts) *RepoExporter
  • func (s *RepoExporter) Done()
  • func (s RepoExporter) ExportGitRepo(fetch rpcdef.GitRepoFetch) error
  • func (s RepoExporter) Run() (res RepoExporterRes)
• type RepoExporterOpts
• type RepoExporterRes

Functions

func AgentDelegateFactory

func AgentDelegateFactory(logger hclog.Logger, delegate AgentDelegate) func(exp expin.Export) rpcdef.Agent

Types

type AgentDelegate

type AgentDelegate interface {
	OAuthNewAccessToken(ind expin.Export) (token string, _ error)
	ExportGitRepo(fetch rpcdef.GitRepoFetch) error
}

type ObjectsWriter

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

func NewObjectsWriter

func NewObjectsWriter() *ObjectsWriter

func (*ObjectsWriter) Done

func (s *ObjectsWriter) Done(id expsessions.ID, lastProcessed interface{}) error

func (*ObjectsWriter) GetData

func (s *ObjectsWriter) GetData() rpcdef.MutatedObjects

func (*ObjectsWriter) Session

func (s *ObjectsWriter) Session(modelType string, parentSessionID expsessions.ID, parentObjectID, parentObjectName string) (_ expsessions.ID, lastProcessed interface{}, _ error)

func (*ObjectsWriter) Write

func (s *ObjectsWriter) Write(id expsessions.ID, objs []map[string]interface{}) error

type RepoExporter

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

func NewRepoExporter

func NewRepoExporter(opts RepoExporterOpts) *RepoExporter

func (*RepoExporter) Done

func (s *RepoExporter) Done()

func (RepoExporter) ExportGitRepo

func (s RepoExporter) ExportGitRepo(fetch rpcdef.GitRepoFetch) error

func (RepoExporter) Run

func (s RepoExporter) Run() (res RepoExporterRes)

easier to return struct here to sync we call this async and want result back in chan

type RepoExporterOpts

type RepoExporterOpts struct {
	Logger        hclog.Logger
	AgentConfig   cmdintegration.AgentConfig
	LastProcessed *jsonstore.Store
	Locs          fsconf.Locs
}

type RepoExporterRes

type RepoExporterRes struct {
	Data rpcdef.MutatedObjects
	Err  error
}