Function newSafeWriteClient

cli/cmd/sync_v3.go:116–118

(client grpc.ClientStreamingClient[plugin.Write_Request, plugin.Write_Response])

}

func newSafeWriteClient(client grpc.ClientStreamingClient[plugin.Write_Request, plugin.Write_Response]) safeWriteClient {
	return safeWriteClient{client: client, mu: &gosync.Mutex{}}
}

type shard struct {
	num   int32