diff --git a/persistence.go b/persistence.go index d59b0e0..a17c04c 100644 --- a/persistence.go +++ b/persistence.go @@ -27,6 +27,7 @@ func NewMessageToPersistencePipeline(ctx context.Context, cfg Config) (Pipeline, func newMessageToPersistenceProcess(driver Driver) processFunc { return func(ctx context.Context, slack []byte) ([]byte, error) { + // TODO table design lets go return nil, io.EOF } }