(ctx context.Context, msgs <-chan message.WriteMessage)
| 89 | } |
| 90 | |
| 91 | func (c *Client) Write(ctx context.Context, msgs <-chan message.WriteMessage) error { |
| 92 | return c.writer.Write(ctx, msgs) |
| 93 | } |
| 94 | |
| 95 | func (c *Client) MigrateTable(ctx context.Context, ch <-chan *message.WriteMigrateTable) error { |
| 96 | // nolint:prealloc |