pipelines4

Documentation

Index

• Variables

Variables

var P1 = &pipeline.Instance{
	ID: "pipeline1",
	Config: pipeline.Config{
		Name:        "name1",
		Description: "desc1",
	},
	Status:       pipeline.StatusRunning,
	Error:        "",
	DLQ:          pipeline.DefaultDLQ,
	ConnectorIDs: []string{"pipeline1:con1", "pipeline1:con2"},
	ProcessorIDs: []string{"pipeline1:proc1"},

	ProvisionedBy: pipeline.ProvisionTypeConfig,
	CreatedAt:     time.Now(),
	UpdatedAt:     time.Now(),
}

var P1C1 = &connector.Instance{
	ID:   "pipeline1:con1",
	Type: connector.TypeSource,
	Config: connector.Config{
		Name:     "file-src",
		Settings: map[string]string{"path": "./test/source-file.txt"},
	},
	PipelineID:   "pipeline1",
	Plugin:       "builtin:file",
	ProcessorIDs: nil,

	ProvisionedBy: connector.ProvisionTypeConfig,
	CreatedAt:     time.Now(),
	UpdatedAt:     time.Now(),
}

var P1C2 = &connector.Instance{
	ID:   "pipeline1:con2",
	Type: connector.TypeDestination,
	Config: connector.Config{
		Name:     "file-dest",
		Settings: map[string]string{"path": "./test/dest-file.txt"},
	},
	PipelineID:   "pipeline1",
	Plugin:       "builtin:file",
	ProcessorIDs: []string{"pipeline1:con2:con2proc1"},

	ProvisionedBy: connector.ProvisionTypeConfig,
	CreatedAt:     time.Now(),
	UpdatedAt:     time.Now(),
}

var P1C2P1 = &processor.Instance{
	ID:   "pipeline1:con2:con2proc1",
	Type: "removereadat",
	Parent: processor.Parent{
		ID:   "pipeline1:con2",
		Type: processor.ParentTypeConnector,
	},
	Config: processor.Config{
		Settings: nil,
		Workers:  1,
	},
	Processor: nil,

	ProvisionedBy: processor.ProvisionTypeConfig,
	CreatedAt:     time.Now(),
	UpdatedAt:     time.Now(),
}

var P1P1 = &processor.Instance{
	ID:   "pipeline1:proc1",
	Type: "removereadat",
	Parent: processor.Parent{
		ID:   "pipeline1",
		Type: processor.ParentTypePipeline,
	},
	Config: processor.Config{
		Settings: nil,
		Workers:  1,
	},
	Processor: nil,

	ProvisionedBy: processor.ProvisionTypeConfig,
	CreatedAt:     time.Now(),
	UpdatedAt:     time.Now(),
}

var P2 = &pipeline.Instance{
	ID: "pipeline2",
	Config: pipeline.Config{
		Name:        "name2",
		Description: "desc2",
	},
	Status:       pipeline.StatusUserStopped,
	Error:        "",
	DLQ:          pipeline.DefaultDLQ,
	ConnectorIDs: []string{"pipeline2:con1"},
	ProcessorIDs: nil,

	ProvisionedBy: pipeline.ProvisionTypeConfig,
	CreatedAt:     time.Now(),
	UpdatedAt:     time.Now(),
}

var P2C1 = &connector.Instance{
	ID:   "pipeline2:con1",
	Type: connector.TypeDestination,
	Config: connector.Config{
		Name:     "file-dest",
		Settings: map[string]string{"path": "./test/file3.txt"},
	},
	PipelineID:   "pipeline2",
	Plugin:       "builtin:file",
	ProcessorIDs: nil,

	ProvisionedBy: connector.ProvisionTypeConfig,
	CreatedAt:     time.Now(),
	UpdatedAt:     time.Now(),
}

var P3 = &pipeline.Instance{
	ID: "pipeline3",
	Config: pipeline.Config{
		Name:        "name3",
		Description: "empty",
	},
	Status:       pipeline.StatusUserStopped,
	Error:        "",
	DLQ:          pipeline.DefaultDLQ,
	ConnectorIDs: nil,
	ProcessorIDs: nil,

	ProvisionedBy: pipeline.ProvisionTypeConfig,
	CreatedAt:     time.Now(),
	UpdatedAt:     time.Now(),
}