worker

type Config struct {
	Storage storage.Config
	// Directory to write task files to
	WorkDir string
	// How often the worker sends task log updates
	UpdateRate time.Duration
	// Max `bytes` to store in-memory between updates
	BufferSize  units.MetricBytes
	Logger      logger.Config
	TaskReader  string
	TaskReaders struct {
		RPC struct {
			// RPC address of the Funnel server
			ServerAddress string
			// Password for basic auth. with the server APIs.
			ServerPassword string
		}
		Dynamo dynamo.Config
	}
	ActiveEventWriters []string
	EventWriters       struct {
		RPC struct {
			// RPC address of the Funnel server
			ServerAddress string
			// Password for basic auth. with the server APIs.
			ServerPassword string
			// Timeout duration for gRPC calls
			UpdateTimeout time.Duration
		}
		Dynamo dynamo.Config
	}
}