pipelines3

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: nil,

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

var P1C1 = &connector.Instance{
	ID:   "pipeline1:con1",
	Type: connector.TypeSource,
	Config: connector.Config{
		Name:     "source",
		Settings: map[string]string{"path": "my/path/file1.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:     "dest",
		Settings: map[string]string{"path": "my/path/file2.txt"},
	},
	PipelineID:   "pipeline1",
	Plugin:       "builtin:file",
	ProcessorIDs: nil,

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

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

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

var P2C1 = &connector.Instance{
	ID:   "pipeline2:con1",
	Type: connector.TypeSource,
	Config: connector.Config{
		Name:     "source",
		Settings: map[string]string{"path": "my/path/file1.txt"},
	},
	PipelineID:   "pipeline2",
	Plugin:       "builtin:file",
	ProcessorIDs: nil,

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

var P2C2 = &connector.Instance{
	ID:   "pipeline2:con2",
	Type: connector.TypeDestination,
	Config: connector.Config{
		Name:     "dest",
		Settings: map[string]string{"path": "my/path/file2.txt"},
	},
	PipelineID:   "pipeline2",
	Plugin:       "builtin:file",
	ProcessorIDs: nil,

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